[pgsqlclient-checkins] pgsqlclient_10/PostgreSql.Data.PgSqlClient/source/NPgClient PgStatement.cs,1.
Status: Inactive
Brought to you by:
carlosga_fb
From: <car...@us...> - 2003-12-05 18:15:59
|
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 |