pgsqlclient-checkins

[<car...@us...>]

Update of /cvsroot/pgsqlclient/pgsqlclient_10/PostgreSql.Data.PgSqlClient/source/NPgClient
In directory sc8-pr-cvs1:/tmp/cvs-serv9666

Modified Files:
	PgStatement.cs 
Log Message:
Improved protocol handling

Index: PgStatement.cs
===================================================================
RCS file: /cvsroot/pgsqlclient/pgsqlclient_10/PostgreSql.Data.PgSqlClient/source/NPgClient/PgStatement.cs,v
retrieving revision 1.4
retrieving revision 1.5
diff -C2 -d -r1.4 -r1.5
*** PgStatement.cs	15 Sep 2003 11:56:19 -0000	1.4
--- PgStatement.cs	15 Sep 2003 12:21:15 -0000	1.5
***************
*** 195,201 ****
  					db.Flush();
  
! 					// Receive reponse
! 					PgResponsePacket response = db.ReceiveResponsePacket();
! 					processSqlPacket(response);
  
  					// Clear actual row list
--- 195,205 ----
  					db.Flush();
  
! 					// Read until PARSE COMPLETE message is received
! 					PgResponsePacket response = new PgResponsePacket();
! 					while (response.Message != PgBackendCodes.PARSE_COMPLETE)
! 					{
! 						response = db.ReceiveResponsePacket();
! 						processSqlPacket(response);
! 					}
  
  					// Clear actual row list
***************
*** 245,250 ****
  
  					// Receive response
- 					// case PgBackendCodes.EMPTY_QUERY_RESPONSE:
- 
  					PgResponsePacket response = new PgResponsePacket();
  					while (response.Message != PgBackendCodes.ROW_DESCRIPTION &&
--- 249,252 ----
***************
*** 312,316 ****
  					db.Flush();
  
! 					// Read BIND Complete message
  					PgResponsePacket response = new PgResponsePacket();
  					while (response.Message != PgBackendCodes.BIND_COMPLETE)
--- 314,318 ----
  					db.Flush();
  
! 					// Read until BIND COMPLETE message is received
  					PgResponsePacket response = new PgResponsePacket();
  					while (response.Message != PgBackendCodes.BIND_COMPLETE)
***************
*** 506,512 ****
  					db.Flush();
  
! 					// Receive repsonse
! 					PgResponsePacket response = db.ReceiveResponsePacket();
! 					processSqlPacket(response);
  
  					// Clear rows
--- 508,518 ----
  					db.Flush();
  
! 					// Read until CLOSE COMPLETE message is received
! 					PgResponsePacket response = new PgResponsePacket();
! 					while (response.Message != PgBackendCodes.CLOSE_COMPLETE)
! 					{
! 						response = db.ReceiveResponsePacket();
! 						processSqlPacket(response);
! 					}
  
  					// Clear rows