Update of /cvsroot/pgsqlclient/pgsqlclient/PostgreSql.Data.PGSqlClient.UnitTests/source
In directory sc8-pr-cvs1:/tmp/cvs-serv30721
Modified Files:
PGCommandTest.cs
Log Message:
Added new tests cases
Index: PGCommandTest.cs
===================================================================
RCS file: /cvsroot/pgsqlclient/pgsqlclient/PostgreSql.Data.PGSqlClient.UnitTests/source/PGCommandTest.cs,v
retrieving revision 1.2
retrieving revision 1.3
diff -C2 -d -r1.2 -r1.3
*** PGCommandTest.cs 13 Jul 2003 12:39:30 -0000 1.2
--- PGCommandTest.cs 13 Jul 2003 13:55:31 -0000 1.3
***************
*** 74,78 ****
Console.WriteLine("\r\nPGCommandTest.ExecuteReaderTest");
! PGCommand command = new PGCommand("select * from public.test_table order by date_field", Connection);
PGDataReader reader = command.ExecuteReader();
--- 74,78 ----
Console.WriteLine("\r\nPGCommandTest.ExecuteReaderTest");
! PGCommand command = new PGCommand("SELECT * FROM public.test_table ORDER BY date_field", Connection);
PGDataReader reader = command.ExecuteReader();
***************
*** 99,102 ****
--- 99,179 ----
public void ExecuteScalarTest()
{
+ PGCommand command = Connection.CreateCommand();
+
+ command.CommandText = "SELECT char_field FROM public.test_table where int_field = @int_field";
+
+ command.Parameters.Add("@int_Field", 2);
+
+ string charFieldValue = command.ExecuteScalar().ToString();
+
+ Console.WriteLine("Scalar value: {0}", charFieldValue);
+
+ command.Dispose();
+ }
+
+ [Test]
+ public void PrepareTest()
+ {
+ PGCommand command = Connection.CreateCommand();
+
+ command.CommandText = "SELECT char_field FROM public.test_table where int_field = @int_field";
+
+ command.Parameters.Add("@int_field", 2);
+ command.Prepare();
+ command.Dispose();
+ }
+
+ [Test]
+ public void NamedParametersTest()
+ {
+ PGCommand command = Connection.CreateCommand();
+
+ command.CommandText = "SELECT char_field FROM public.test_table where int_field = @int_field or char_field = @char_field";
+
+ command.Parameters.Add("@int_field", 2);
+ command.Parameters.Add("@char_field", "IRow 20");
+
+ PGDataReader reader = command.ExecuteReader();
+
+ int count = 0;
+ while (reader.Read())
+ {
+ Console.WriteLine(reader.GetValue(0));
+ count++;
+ }
+
+ Console.WriteLine("\r\n Record fetched {0} \r\n", count);
+
+ reader.Close();
+ command.Dispose();
+ }
+
+ [Test]
+ [Ignore("Not implemented.")]
+ public void ExecuteStoredProcTest()
+ {
+ }
+
+ [Test]
+ public void RecordsAffectedTest()
+ {
+ PGCommand selectCommand = new PGCommand("SELECT * FROM public.test_table WHERE int_field = 100", Connection);
+ int recordsAffected = selectCommand.ExecuteNonQuery();
+ Console.WriteLine("\r\nRecords Affected by SELECT command: {0}", recordsAffected);
+ if (recordsAffected != -1)
+ {
+ throw new EvaluateException("Invalid RecordsAffected value for SELECT command");
+ }
+ selectCommand.Dispose();
+
+ PGCommand deleteCommand = new PGCommand("DELETE FROM public.test_table WHERE int_field = 45", Connection);
+ recordsAffected = deleteCommand.ExecuteNonQuery();
+ Console.WriteLine("\r\nRecords Affected by DELETE command: {0}", recordsAffected);
+ if (recordsAffected != 1)
+ {
+ throw new EvaluateException("Invalid RecordsAffected value for DELETE command");
+ }
+ // Assertion.Assert(recordsAffected == 1);
+ deleteCommand.Dispose();
}
}
|
