2011-12-21 3 views
2

이것은 설명서에 제공된 예제입니다. 내가 똑같은 것을 시도 할 때 나는 예외가 많다. 이것의 실수는 무엇입니까?Npgsql 이상한 예외

using(NpgsqlConnection conn = new NpgsqlConnection("connstring")) 
{ 
    conn.Open(); 
    using(NpgsqlCommand command = new NpgsqlCommand("select command", conn)) 
    { 
     command.Parameters.Add(new NpgsqlParameter("column1", NpgsqlDbType.Integer); 
     command.Parameters[0].Value = 4; 
     using(NpgsqlDataReader dr = command.ExecuteReader()) 
     { 
      dr.Read(); 
      Console.Write("{0} \t", dr[0]); 
     } 
    } 
} 

는 예외 :

System exception System.IO.IOException: I/O error occurred. 
at Npgsql.NpgsqlState.<ProcessBackendResponses_Ver_3>d__a.MoveNext() 
at Npgsql.NpgsqlState.IterateThroughAllResponses(IEnumerable`1 ienum) 
at Npgsql.NpgsqlState.Query(NpgsqlConnector context, NpgsqlCommand command) 
at Npgsql.NpgsqlConnector.Query(NpgsqlCommand queryCommand) 
at Npgsql.NpgsqlConnector.ReleaseRegisteredListen() 
at Npgsql.NpgsqlConnector.ReleaseResources() 
at Npgsql.NpgsqlConnectorPool.UngetPooledConnector(NpgsqlConnection Connection, NpgsqlConnector Connector) 
at Npgsql.NpgsqlConnectorPool.ReleasePooledConnectorInternal(NpgsqlConnection Connection, NpgsqlConnector Connector) 
at Npgsql.NpgsqlConnectorPool.ReleasePooledConnector(NpgsqlConnection Connection, NpgsqlConnector Connector) 
at Npgsql.NpgsqlConnectorPool.ReleaseConnector(NpgsqlConnection Connection, NpgsqlConnector Connector) 
at Npgsql.NpgsqlConnection.Close() 
at Npgsql.NpgsqlConnection.Dispose(Boolean disposing) 
at System.ComponentModel.Component.Dispose() 

지금이 올바르게 작동합니다. 차이점은 무엇입니까?

using(NpgsqlConnection conn = new NpgsqlConnection("connstring")) 
{ 
    conn.Open(); 
    using(NpgsqlCommand command = new NpgsqlCommand("select command", conn)) 
    { 
     command.Parameters.Add(new NpgsqlParameter("column1", NpgsqlDbType.Integer); 
     command.Parameters[0].Value = 4; 
     NpgsqlDataReader dr = command.ExecuteReader();    
     dr.Read(); 
     Console.Write("{0} \t", dr[0]); 
    } 
} 

데이터 어뎁터를 Idisposable과 함께 사용할 수없는 이유는 무엇입니까?

+0

예외가 발생하기 전에 결과가 나타나고 postgres 로그에 오류가 있습니까? 'NpgsqlState.IterateThroughAllResponses'는 결과가 아닌 쿼리의 응답을 파싱하는 중이고 연결이 정리되면 내부 쿼리가 전송됩니다. 여기 Npgsql 버그가 있거나 거기에 버그가 있습니다 (아마도 연결 문자열 또는 예제 코드에서 제공하지 않는 쿼리는 버그가있는 곳입니다) 그리고 나서 Npgsql은이를 잘못 처리합니다. 문제에 대한 좋은 설명이 아니라 내부에서 온 메시지 –

+1

또한, 사용자 이름, 서버 이름 및 암호가 XXXX로 변경된 실제 ""connstring 및' "select 명령"을 표시 할 수 있습니까? 분명히 게시하고 싶지는 않지만 문제가있을 수 있습니다. –

+1

이것은 Npgsql에서 오류 상황을 올바르게 처리하지 못하는 문제입니다. 이상한 부분은 연결을 끊을 때 IOException을 얻는 이유입니다. 프로그램을 실행하는 동안 서버에서 연결을 해제합니까? –

답변

3

Idisposable과 함께 datareader를 사용하는 경우 Npgsql에서 연결 인터럽트를 처리하지 않습니다. 서버가 응용 프로그램과 통신하기 전에 연결을 종료하고 연결 풀로 연결이 반환되면 연결을 확인하기 위해 서버로 이동하며이 때 데이터 판독기가 제대로 처리되지 않습니다. 멀티 스레드 환경에서는 불행한 상황이 발생합니다. 서버가 연결에서 연결 해제되면 Npgsql이 다시 통신 할 수 없도록 즉시 연결을 종료하면 안됩니다. 서버의 연결 해제 시간을 길게 늘리십시오. 내 경우는 서버를 갑자기 연결 해제하는 경우입니다.

해결책 : Npgsql은 아직없는 예외를 내부적으로 처리해야합니다.