2002-08-18 Rodrigo Moya <rodrigo@ximian.com>

[mono.git] / mcs / class / System.Data / System.Data.OleDb / TestOleDb.cs

diff --git a/mcs/class/System.Data/System.Data.OleDb/TestOleDb.cs b/mcs/class/System.Data/System.Data.OleDb/TestOleDb.cs
index 2becacc4aef4c709ddb07d2031c1a01b839bd107..e54d5c0e5898cf2f6a23c3b272542c7131ccddc2 100644 (file)
--- a/mcs/class/System.Data/System.Data.OleDb/TestOleDb.cs
+++ b/mcs/class/System.Data/System.Data.OleDb/TestOleDb.cs
@@ -6,23 +6,81 @@ namespace System.Data.OleDb.Test
        public class TestOleDb
        {
                private OleDbConnection m_cnc;
-               
+
                private TestOleDb ()
                {
+                       OleDbCommand cmd;
+                       
                        m_cnc = new OleDbConnection ("PostgreSQL");
                        m_cnc.Open ();
+
+                       Console.WriteLine ("Creating temporary table...");
+                       cmd = new OleDbCommand ("CREATE TABLE mono_test_table ( " +
+                                               " name varchar(25), email varchar(50), date_entered timestamp)",
+                                               m_cnc);
+                       cmd.ExecuteNonQuery ();
+                       InsertRow ("Mike Smith", "mike@smiths.com");
+                       InsertRow ("Julie Andrews", "julie@hollywood.com");
+                       InsertRow ("Michael Jordan", "michael@bulls.com");
                }
 
+               void InsertRow (string name, string email)
+               {
+                       OleDbCommand cmd;
+
+                       cmd = new OleDbCommand ("INSERT INTO mono_test_table (name, email, date_entered) VALUES ('" +
+                                               name + "', '" + email +"', date 'now')", m_cnc);
+                       Console.WriteLine ("Executing command '" + cmd.CommandText + "'");
+                       cmd.ExecuteNonQuery ();
+
+               }
+               
+               void DisplayRow (OleDbDataReader reader)
+               {
+                       for (int i = 0; i < reader.FieldCount; i++) {
+                               Console.WriteLine (" " + reader.GetDataTypeName (i) + ": " +
+                                                  reader.GetValue (i).ToString ());
+                       }
+               }
+               
                void TestDataReader ()
                {
-                       string sql = "SELECT * FROM pg_tables";
+                       int i = 0;
+                       string sql = "SELECT * FROM mono_test_table";
+                       
+                       Console.WriteLine ("Executing SELECT command...");
                        OleDbCommand cmd = new OleDbCommand (sql, m_cnc);
+                       OleDbDataReader reader = cmd.ExecuteReader ();
 
-                       IDataReader reader = cmd.ExecuteReader ();
+                       Console.WriteLine (" Recordset description:");
+                       for (i = 0; i < reader.FieldCount; i++) {
+                               Console.WriteLine ("  Field " + i + ": " +
+                                                  reader.GetName (i) + " (" +
+                                                  reader.GetDataTypeName (i) + ")");
+                       }
+
+                       Console.WriteLine ("Reading data...");
+                       i = 0;
+                       while (reader.Read ()) {
+                               Console.WriteLine ("Row " + i + ":");
+                               DisplayRow (reader);
+                               i++;
+                       }
                }
 
+               void TestTransaction ()
+               {
+                       Console.WriteLine ("Starting transaction...");
+                       OleDbTransaction xaction = m_cnc.BeginTransaction ();
+
+                       Console.WriteLine ("Aborting transaction...");
+                       xaction.Rollback ();
+               }
+               
                void Close ()
                {
+                       OleDbCommand cmd = new OleDbCommand ("DROP TABLE mono_test_table", m_cnc);
+                       cmd.ExecuteNonQuery ();
                        m_cnc.Close ();
                }
 
@@ -31,6 +89,7 @@ namespace System.Data.OleDb.Test
                        try {
                                TestOleDb test = new TestOleDb ();
                                test.TestDataReader ();
+                               test.TestTransaction ();
                                test.Close ();
                        } catch (Exception e) {
                                Console.WriteLine ("An error has occured: {0}", e.ToString ());