[pgsqlclient-checkins] pgsqlclient/PostgreSql.Data.PGSqlClient.UnitTests/source PGCommandTest.cs,1.2
Status: Inactive
Brought to you by:
carlosga_fb
From: <car...@us...> - 2003-07-13 13:55:34
|
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(); } } |