Update of /cvsroot/pgsqlclient/pgsqlclient_10/PostgreSql.Data.PgSqlClient/source/NPgClient
In directory sc8-pr-cvs1:/tmp/cvs-serv31311
Modified Files:
PgStatement.cs
Log Message:
Minor change for try to improve statement execution.
Index: PgStatement.cs
===================================================================
RCS file: /cvsroot/pgsqlclient/pgsqlclient_10/PostgreSql.Data.PgSqlClient/source/NPgClient/PgStatement.cs,v
retrieving revision 1.16
retrieving revision 1.17
diff -C2 -d -r1.16 -r1.17
*** PgStatement.cs 5 Dec 2003 10:35:45 -0000 1.16
--- PgStatement.cs 5 Dec 2003 18:15:56 -0000 1.17
***************
*** 180,212 ****
#region METHODS
- public void Prepare()
- {
- lock (db)
- {
- this.Parse();
- this.Describe();
-
- // Flush pending messages
- db.Flush();
-
- // Receive Parse response
- PgResponsePacket response = new PgResponsePacket();
- while (response.Message != PgBackendCodes.PARSE_COMPLETE)
- {
- response = db.ReceiveResponsePacket();
- processSqlPacket(response);
- }
-
- // Receive Describe response
- response = new PgResponsePacket();
- while ((response.Message != PgBackendCodes.ROW_DESCRIPTION &&
- response.Message != PgBackendCodes.NODATA))
- {
- response = db.ReceiveResponsePacket();
- processSqlPacket(response);
- }
- }
- }
-
public void Parse()
{
--- 180,183 ----
***************
*** 270,273 ****
--- 241,253 ----
// Send packet to the server
db.SendData(packet.GetPacketBytes(PgFrontEndCodes.DESCRIBE));
+
+ // Receive Describe response
+ PgResponsePacket response = new PgResponsePacket();
+ while ((response.Message != PgBackendCodes.ROW_DESCRIPTION &&
+ response.Message != PgBackendCodes.NODATA))
+ {
+ response = db.ReceiveResponsePacket();
+ processSqlPacket(response);
+ }
// Update status
|
