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;
|
