From: Carlos G. Á. <car...@us...> - 2005-09-12 18:27:53
|
Update of /cvsroot/pgsqlclient/pgsqlclient_10/source/PostgreSql/Data/Protocol In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv1495/Data/Protocol Modified Files: PgResponsePacket.cs PgStatement.cs Log Message: Started the rework of the Schema support Index: PgResponsePacket.cs =================================================================== RCS file: /cvsroot/pgsqlclient/pgsqlclient_10/source/PostgreSql/Data/Protocol/PgResponsePacket.cs,v retrieving revision 1.4 retrieving revision 1.5 diff -C2 -d -r1.4 -r1.5 *** PgResponsePacket.cs 11 Sep 2005 13:29:16 -0000 1.4 --- PgResponsePacket.cs 12 Sep 2005 18:27:45 -0000 1.5 *************** *** 107,111 **** public PgResponsePacket(char message, Encoding encoding, byte[] contents) { ! this.packet = new BinaryReader(new MemoryStream(contents)); this.encoding = encoding; this.message = message; --- 107,112 ---- public PgResponsePacket(char message, Encoding encoding, byte[] contents) { ! this.stream = new MemoryStream(contents); ! this.packet = new BinaryReader(this.stream); this.encoding = encoding; this.message = message; *************** *** 664,667 **** --- 665,673 ---- #endregion + + internal byte[] ToArray() + { + return ((MemoryStream)this.stream).ToArray(); + } } } Index: PgStatement.cs =================================================================== RCS file: /cvsroot/pgsqlclient/pgsqlclient_10/source/PostgreSql/Data/Protocol/PgStatement.cs,v retrieving revision 1.6 retrieving revision 1.7 diff -C2 -d -r1.6 -r1.7 *** PgStatement.cs 12 Sep 2005 16:18:58 -0000 1.6 --- PgStatement.cs 12 Sep 2005 18:27:45 -0000 1.7 *************** *** 740,752 **** if (this.status == PgStatementStatus.OnQuery) { ! values[i] = packet.ReadValueFromString( ! this.rowDescriptor.Fields[i].DataType, ! length); } else { ! values[i] = packet.ReadValue( ! this.rowDescriptor.Fields[i].DataType, ! length); } break; --- 740,748 ---- if (this.status == PgStatementStatus.OnQuery) { ! values[i] = packet.ReadValueFromString(this.rowDescriptor.Fields[i].DataType, length); } else { ! values[i] = packet.ReadValue(this.rowDescriptor.Fields[i].DataType, length); } break; |