ch10_09.cs

来自「《c#技术内幕代码》」· CS 代码 · 共 110 行

using System; 
using System.Data; 
using System.Data.SQL; 
using System.Data.ADO; 

public class CH10_4
{ 
   public static void Main () 
   { 
       // Define the connection string
       string strConn = "Provider=Microsoft.Jet.OLEDB.4.0;Data Source=CH10.MDB"; 
       
       ADOCommand myCmd;

       // Create the connection object, using our connection string
       ADOConnection myConn = new ADOConnection(strConn); 
       // This will do the connection to the database
       myConn.Open(); 
       
       ADOCommand myCommand = new ADOCommand();
    
       // Begin the transaction.
       myConn.BeginTransaction();
    
       bool done = false;
       
       do
       {
           Console.WriteLine("(A) Add Record");
	   Console.WriteLine("(C) Commit Changes");
	   Console.WriteLine("(R) Rollback Changes");
	   Console.WriteLine("(E) Exit");
	   
           string s = Console.ReadLine();
	   switch ( s[0] )
	   {
	       case 'A':
	       case 'a':
	       
		       // Define our selection criteria
		       string strRec = "Insert Into Contact (Name, Address, City, State, ZipCode, Age) "; 
		       strRec += " VALUES (\"";
		       
		       Console.WriteLine("Enter Name: ");
		       strRec += Console.ReadLine();
		       strRec += "\",\"";
		       
		       Console.WriteLine("Enter Address: ");
		       strRec += Console.ReadLine();
		       strRec += "\",\"";
		
		       Console.WriteLine("Enter City: ");
		       strRec += Console.ReadLine();
		       strRec += "\",\"";
		
		       Console.WriteLine("Enter State: ");
		       strRec += Console.ReadLine();
		       strRec += "\",\"";
		
		       Console.WriteLine("Enter Zip Code: ");
		       strRec += Console.ReadLine();
		       strRec += "\",";
		
		       Console.WriteLine("Enter Age: ");
		       strRec += Console.ReadLine();
		       strRec += ");";
		       
		       Console.WriteLine("Executing command: {0}", strRec );
		  
		       // Create the command object from our selection criteria string       
		       myCmd = new ADOCommand( strRec, myConn ); 

		       // Try to execute the command       
		       ADODataReader outData = null; 
		       try 
		       { 
			    // This will run our query and put the result in outData
			    myCmd.Execute( out outData ); 
			
		       } 
		       catch ( Exception e )
		       {
			  Console.WriteLine("Exception {0}", e );
		       }
		       break;
		       
               case 'C':
	       case 'c':

                       myConn.CommitTransaction();
                       myConn.BeginTransaction();
		       break;
	       case 'R':
	       case 'r':
	               myConn.RollbackTransaction();
                       myConn.BeginTransaction();
		       break;
	       case 'E':
	       case 'e':
                       myConn.CommitTransaction();
		       done = true;
		       break;
           }
	   
        } while ( !done );

    }
}