數據庫的訪問是所有編程語言中最重要的部分,C#提供了ADO.Net部件用於對數據庫進行訪問。我們將從最簡單易用的微軟Access數據庫入手討論在C#中對數據庫的訪問。
C#中的Connection對象和Command對象與Access類似,但在這裡我們還將使用其另一個與RecordSet類似的被稱作ADODataReader的對象,它負責處理與查詢有關的RecordSet對象。
首先,必須使用微軟的Access創建一個數據庫。運行Access,創建一個數據庫,但不要創建任何表(我們將在下面的程序中創建表。),保存創建的數據庫。
打開控制面板中的ODBC圖標,點擊System DNS標簽,依次選擇Add>Microsoft Access,並點擊Finish按鈕。在拉下來的對話框中輸入數據源的名字,比如是mymdb,然後創建數據源,雙擊OK按鈕。
在下面的程序中,我們將創建一個表,並在其中插入一些值。
程序非常地簡單和直觀。在Main()函數中,ADOConnection對象將數據源的名字取到構造器中,然後使用ADOConenction的Open()方法打開該連接。
在連接建立後,程序將創建包含二個字段的表a1,其中字段name的類型為字符型,vno的類型為整型。Create table命令已經放在ADOCommand的構造器中,ExecuteNonQuery()方法用於執行這一查詢,該方法不會返回任何記錄集。同樣,Insert和Delete查詢也可以放到ADOCommand的Constructor中,因此可以象在VB中那樣傳遞任何SQL查詢。
ADODataReader是新出現的,它是本段程序中主要的對象,負責處理ADOCommand返回的記錄集。使用xecute()方法,就可以看到從數據庫中返回的數據。ADODataReader的Read()方法則返回布爾型的值,TRUE標志著數據在ADODataReader對象中,而且將當前指針移動到了ADODataReader對象的下一條記錄上。
使用Visual Studio.Net β1編譯下面的程序代碼。
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結束
}// 名字空間結束