淺談C# Connection對象
數據庫的訪問是所有編程語言中最重要的部分,C#提供了ADO.Net部件用于對數據庫進行訪問。我們將從最簡單易用的微軟Access數據庫入手討論在C#中對數據庫的訪問。
C# Connection對象和Command對象與Access類似,但在這里我們還將使用其另一個與RecordSet類似的被稱作ADODataReader的對象,它負責處理與查詢有關的RecordSet對象。
首先,必須使用微軟的Access創建一個數據庫。運行Access,創建一個數據庫,但不要創建任何表(我們將在下面的程序中創建表。),保存創建的數據庫。
打開控制面板中的ODBC圖標,點擊System DNS標簽,依次選擇Add>Microsoft Access,并點擊Finish按鈕。在拉下來的對話框中輸入數據源的名字,比如是mymdb,然后創建數據源,雙擊OK按鈕。
在下面的程序中,我們將創建一個表,并在其中插入一些值。
程序非常地簡單和直觀。在Main()函數中,C# Connection對象將數據源的名字取到構造器中,然后使用ADOConenction的Open()方法打開該連接。
在連接建立后,程序將創建包含二個字段的表a1,其中字段name的類型為字符型,vno的類型為整型。Create table命令已經放在ADOCommand的構造器中,ExecuteNonQuery()方法用于執行這一查詢,該方法不會返回任何記錄集。同樣,Insert和Delete查詢也可以放到ADOCommand的Constructor中,因此可以象在VB中那樣傳遞任何SQL查詢。
ADODataReader是新出現的,它是本段程序中主要的對象,負責處理ADOCommand返回的記錄集。使用xecute()方法,就可以看到從數據庫中返回的數據。ADODataReader的Read()方法則返回布爾型的值,TRUE標志著數據在ADODataReader對象中,而且將當前指針移動到了ADODataReader對象的下一條記錄上。namespace database1
- {
- using System;
- using System.Data.ADO;
- public class Class1
- {
- public Class1()
- {
- //
- // 在這里添加Constructor的邏輯
- //
- }
- public static int Main(string[] args)
- {
- try
- {
- ADOConnection s = new ADOConnection("Data Source=mymdb");
- s.Open();
- Console.WriteLine("Connection Established");
- //創建表
- Console.Write("Want to Create a Table?(y/n) ");
- string ch = Console.ReadLine();
- if (ch == "y")
- {
- ADOCommand CreateTable = new ADOCommand("Create Table a1(vno integer,name char(20))", s);
- CreateTable.ExecuteNonQuery();
- Console.WriteLine("AOCommand Executed / Table Created");
- }
- //在表中插入值
- Console.Write("Want to Insert Some values in a Table?(y/n) ");
- ch = Console.ReadLine();
- if (ch == "y")
- {
- ADOCommand InsTable = new
- ADOCommand("insert into a1 values(1, ‘hi‘)", s);
- InsTable.ExecuteNonQuery();
- Console.WriteLine("Values Inserted");
- }
- //刪除整個表
- Console.Write("Want to Delete All Records Present in the Table?(y/n) ");
- ch = Console.ReadLine();
- if (ch == "y")
- {
- ADOCommand DeleteTable = new ADOCommand("Delete from a1", s);
- DeleteTable.ExecuteNonQuery();
- Console.WriteLine("All Records Deleted From the Table");
- }
- //看所有記錄
- Console.Write("Want to See all the Records Present in the Table /Database (y/n)? ");
- ch = Console.ReadLine();
- if (ch == "y")
- {
- ADOCommand AllRecs = new ADOCommand("select * from a1", s);
- ADODataReader r;
- AllRecs.Execute(out r);
- while(r.Read())
- {
- for(int i=0; i < r.FieldCount;i++)
- {
- Console.Write(r.GetValue(i)+ " ");
- }
- Console.WriteLine();
- }
- Console.WriteLine("All Records Displayed");
- r.Close();
- }
- s.Close();
- Console.ReadLine();
- }
- catch(System.Exception e)
- {
- Console.WriteLine(e.ToString());
- Console.ReadLine();
- }
- return 0;
- } // Main函數結束
- } // Class結束
- }// 名字空間結束
以上介紹C# Connection對象
【編輯推薦】