關于數據庫編程,微軟提供了一個統一的數據對象訪問模型,在Visual Studio6.0中稱為ADO,在.NET中則統一為ADO.NET,掌握ADO.NET就等于掌握了數據庫編程的核心。 針對數據庫編程始終是程序設計語言的一個重要方面的內容,也是一個難點。數據庫編程的內容十分豐富,但最為基本編程的也就是那么幾點,譬如:連接數據 庫、得到需要的數據和針對數據記錄的瀏覽、刪除、修改、插入等操作。其中又以后面針對數據記錄的數據操作為重點。本文就來著重探討一下Visual C#數據庫基本編程,即:如何瀏覽記錄、修改記錄、刪除記錄和插入記錄。
一.程序設計和運行的環境設置:
(1).視窗2000服務器版
(2).Microsoft Data Acess Component 2.6 以上版本 ( MDAC 2.6 )
(3)..Net FrameWork SDK Beta 2
為了更清楚的說明問題,在數據庫的選用上,采用了當前比較典型的數據庫,一個是本地數據庫Access 2000,另外一個是遠程數據庫Sql Server 2000。其中本地數據庫名稱為"db.mdb",在其中定義了一張數據表"person","person"表的數據結構如下表: 字段名稱 | 字段類型 | 字段意思 | id | 數字 | 序號 | xm | 文本 | 姓名 | xb | 文本 | 性別 | nl | 文本 | 年齡 | zip | 文本 | 郵政編碼 |
遠程數據庫Sql Server 2000的數據庫服務器名稱為"Server1",數據庫名稱為"Data1",登陸的ID為"sa",口令為空,在數據庫也定義了一張"person"表,數據結構如上表。 二.如何瀏覽數據:
在《Visual C#的數據綁定》中,已經了解了如何把數據集中的某些字段綁定到WinForm組件的某個屬性上,這樣程序員就可以根據以WinForm組件的來定制數據 顯示的形式,并且此時的WinForm組件顯示內容就可以隨著記錄指針的變化而改變。至此可見,瀏覽數據記錄的關鍵就是如何改變記錄指針。要實現這種操 作,就要使用到BindingManagerBase類,此類的主要作用是管理對于那些實現了對同一個數據源進行綁定的對象。說的具體些,就是能夠使得 Windows窗體上的已經對同一數據源進行數據綁定的組件保持同步。在BindingManagerBase類中定義了一個屬性"Position", 通過這個屬性就可以改變BindingManagerBase對象中的數據指針。創建BindingManagerBase對象必須要使用到 BindingContext類,其實每一個由Control類中繼承而得到的對象,都有單一的BindingContext對象,在大多數創建窗體中實 現數據綁定組件的BindingManagerBase對象是使用Form類的BindingContext來得到。下列代碼是以Access 2000數據庫為模型,創建的一個名稱為"myBind"的BindingManagerBase對象。
//創建一個 OleDbConnection string strCon = " Provider = Microsoft.Jet.OLEDB.4.0 ; Data Source = db.mdb" ; OleDbConnection myConn = new OleDbConnection ( strCon ) ; string strCom = " SELECT * FROM person " ; file://創建一個 DataSet myDataSet = new DataSet ( ) ; myConn.Open ( ) ; file://用 OleDbDataAdapter 得到一個數據集 OleDbDataAdapter myCommand = new OleDbDataAdapter ( strCom , myConn ) ; file://把Dataset綁定books數據表 myCommand.Fill ( myDataSet , "person" ) ; file://關閉此OleDbConnection myConn.Close ( ) ; myBind = this.BindingContext [ myDataSet , "person" ] ; |
下列代碼是以Sql Server 2000數據庫為模型,創建一個名稱為"myBind"的BindingManagerBase對象。 //設定數據連接字符串,此字符串的意思是打開Sql server數據庫, //服務器名稱為server1,數據庫為data1 string strCon = "Provider = SQLOLEDB.1 ; Persist Security Info = False ; User ID = sa ; Initial Catalog = data1 ; Data Source = server1 " ; OleDbConnection myConn = new OleDbConnection ( strCon ) ; myConn.Open ( ) ; string strCom = " SELECT * FROM person " ; file://創建一個 DataSet myDataSet = new DataSet ( ) ; file://用 OleDbDataAdapter 得到一個數據集 OleDbDataAdapter myCommand = new OleDbDataAdapter ( strCom , myConn ) ; file://把Dataset綁定person數據表 myCommand.Fill ( myDataSet , " person " ) ; file://關閉此OleDbConnection myConn.Close ( ) ; myBind = this.BindingContext [ myDataSet , "person" ] ; |
得到了是同一數據源的BindingManagerBase對象,通過改變此對象的"Position"屬性值,這樣綁定數據的組件顯示的數據就隨之變化,從而實現導航數據記錄。 < I > .導航按鈕"上一條"實現方法: protected void GoPrevious ( object sender , System.EventArgs e ) { if ( myBind.Position == 0 ) MessageBox.Show ( "已經到了第一條記錄!" , "信息提示!" , MessageBoxButtons.OK , MessageBoxIcon.Information ) ; else myBind.Position -= 1 ; } |
< II > . 導航按鈕"下一條"實現方法:
protected void GoNext ( object sender , System.EventArgs e ) { if ( myBind.Position == myBind.Count -1 ) MessageBox.Show ( "已經到了最后一條記錄!", "信息提示!" , MessageBoxButtons.OK , MessageBoxIcon.Information ) ; else myBind.Position += 1 ; } |
< III > . 導航按鈕"至尾"實現方法:
protected void GoLast ( object sender , System.EventArgs e ) { myBind.Position = myBind.Count - 1 ; } < IV > . 導航按鈕"至首"實現方法: protected void GoFirst ( object sender , System.EventArgs e ) { myBind.Position = 0 ; } |
注釋:"Count"是BindingManagerBase對象的另外一個重要的屬性,是數據集記錄的總數。 三.實現刪除記錄:
在對數據記錄進行操作的時候,有二點必須十分清晰:
其一:在對數據記錄進行操作的時候,我想有一些程序員一定有這樣一個疑惑,當對數據庫服務器請求數據集的時候,就會產生"DataSet"對象,用以管 理數據集,這樣如果這些對數據庫服務器的請求非常多,同樣也就會產生很多的"DataSet"對象,達到一定時候必然會使得數據庫服務器崩潰。這種想法是 自然的,但和實際并不相符,因為"DataSet"對象并不是在服務器端產生的,而是在客戶端產生的。所以面對眾多的數據請求的時候對數據庫服務器的影響 并不十分太大。
其二:記得在用Delphi編寫三層數據模型的時候的,每一次對數據庫的修改其實只是對第二層產生的數據集的修改,要 真正修改數據庫,還必須調用一個另外的方法。在用ADO.NET處理數據庫的時候,雖然處理的直接對象是數據庫,但此時"DataSet"對象中的內容并 沒有隨之改變,而綁定的數據組件顯示的數據又來源于"DataSet"對象,這樣就會產生一個錯覺,就是修改了的記錄并沒有修改掉,刪除的記錄并沒有刪除 掉。所以對數據記錄進行操作的時候,在修改數據庫后,還要對"DataSet"對象進行必要的修改,這樣才能保證"DataSet"對象和數據庫內容一 致、同步。下面代碼是刪除當前綁定組件顯示的記錄的程序代碼,此代碼是以Access 2000數據庫為模板的:
protected void Delete_record ( object sender , System.EventArgs e ) { DialogResult r = MessageBox.Show ( "是否刪除當前記錄!" , "刪除當前記錄!" , MessageBoxButtons.YesNo, MessageBoxIcon.Question ) ; int ss = ( int ) r ; if ( ss == 6 ) // 按動"確定"按鈕 { try{ file://連接到一個數據庫 string strCon = " Provider = Microsoft.Jet.OLEDB.4.0 ; Data Source = db.mdb " ; OleDbConnection myConn = new OleDbConnection ( strCon ) ; myConn.Open ( ) ; string strDele = "DELETE FROM person WHERE id= " + t_id.Text ; OleDbCommand myCommand = new OleDbCommand ( strDele , myConn ) ; file://從數據庫中刪除指定記錄 myCommand.ExecuteNonQuery ( ) ; file://從DataSet中刪除指定記錄 myDataSet.Tables [ "person" ] . Rows [ myBind.Position ] . Delete ( ) ; myDataSet.Tables [ "person" ] . AcceptChanges ( ) ; myConn.Close ( ) ; } catch ( Exception ed ) { MessageBox.Show ( "刪除記錄錯誤信息: " + ed.ToString ( ) , "錯誤!" ) ; } } } | 四.插入數據記錄:
對數據庫進行插入記錄操作和刪除記錄操作基本的思路是一致的,就是通過ADO.NET首先插入數據記錄到數據庫,然后對"DataSet"對象進行必要的修改。下列代碼就是以Access 2000數據庫為模型修改當前記錄的代碼:<
protected void Update_record ( object sender , System.EventArgs e ) { int i = myBind.Position ; try{ file://連接到一個數據庫 string strCon = " Provider = Microsoft.Jet.OLEDB.4.0 ; Data Source = db.mdb " ; OleDbConnection myConn = new OleDbConnection ( strCon ) ; myConn.Open ( ) ; myDataSet.Tables [ "person" ] . Rows [ myBind.Position ] . BeginEdit ( ) ; file://從數據庫中修改指定記錄 string strUpdt = " UPDATE person SET xm = '" + t_xm.Text + "' , xb = '" + t_xb.Text + "' , nl = " + t_nl.Text + " , zip = " + t_books.Text + " WHERE id = " + t_id.Text ; OleDbCommand myCommand = new OleDbCommand ( strUpdt , myConn ) ; myCommand.ExecuteNonQuery ( ) ; myDataSet.Tables [ "person" ] . Rows [ myBind.Position ] . EndEdit ( ) ; myDataSet.Tables [ "person" ] . AcceptChanges ( ) ; myConn.Close ( ) ; } catch ( Exception ed ) { MessageBox.Show ( "修改指定記錄錯誤: " + ed.ToString ( ) , "錯誤!" ) ; } myBind.Position = i ; } |
由于對Sql Server 2000數據記錄修改操作和Access 2000數據記錄修改操作的差異只在于不同的數據鏈接,具體的代碼可以參考"刪除數據記錄"中的代碼,在這里就不提供了。 五.插入數據記錄: 和前面二種操作在思路是一致的,就是通過ADO.NET首先插入數據記錄到數據庫,然后對"DataSet"對象進行必要的修改。下列代碼就是以Access 2000數據庫為模型插入一條數據記錄的代碼 protected void Insert_record ( object sender , System.EventArgs e ) { try { file://判斷所有字段是否添完,添完則執行,反之彈出提示 if ( t_id.Text != "" && t_xm.Text != "" && t_xb.Text != "" && t_nl.Text != "" && t_books.Text != "" ) { string myConn1 = " Provider = Microsoft.Jet.OLEDB.4.0 ; Data Source = db.mdb" ; OleDbConnection myConn = new OleDbConnection ( myConn1 ) ; myConn.Open ( ) ; string strInsert = " INSERT INTO person ( id , xm , xb , nl , zip ) VALUES ( " ; strInsert += t_id.Text + ", '" ; strInsert += t_xm.Text + "', '" ; strInsert += t_xb.Text + "', " ; strInsert += t_nl.Text + ", " ; strInsert += t_books.Text + ")" ; OleDbCommand inst = new OleDbCommand ( strInsert , myConn ) ; inst.ExecuteNonQuery ( ) ; myConn.Close ( ) ; myDataSet.Tables [ "person" ] . Rows [ myBind.Position ] . BeginEdit ( ) ; myDataSet.Tables [ "person" ] . Rows [ myBind.Position ] . EndEdit ( ) ; myDataSet.Tables [ "person" ] . AcceptChanges ( ) ; } else { MessageBox.Show ( "必須填滿所有字段值!" , "錯誤!" ) ; } } catch ( Exception ed ) { MessageBox.Show ( "保存數據記錄發生 " + ed.ToString ( ) , "錯誤!" ) ; } } |
同樣對Sql Server 2000數據庫進行插入記錄操作和Access 2000數據庫插入記錄操作的差異也只在于不同的數據鏈接,具體的代碼可以參考"刪除數據記錄"中的代碼,在這里就不提供了。 六.Visual C#數據庫編程的完成源代碼和程序運行的主界面:
掌握了上面要點,編寫一個完整的數據庫編程的程序就顯得非常容易了,下面是Visual C#進行數據庫編程的完整代碼(Data01.cs),此代碼是以Access 2000數據庫為模型設計的,具體如下:
using System ; using System.Drawing ; using System.ComponentModel ; using System.Windows.Forms ; using System.Data.OleDb ; using System.Data ; public class Data : Form { private System.ComponentModel.Container components = null ; private Button lastrec ; private Button nextrec ; private Button previousrec ; private Button firstrec ; private TextBox t_books ; private TextBox t_nl ; private ComboBox t_xb ; private TextBox t_xm ; private TextBox t_id ; private Label l_books ; private Label l_nl ; private Label l_xb ; private Label l_xm ; private Label l_id ; private Label label1 ; private DataSet myDataSet ; private Button button1 ; private Button button2 ; private Button button3 ; private Button button4 ; private BindingManagerBase myBind ; public Data ( ) { file://連接到一個數據庫 GetConnected ( ) ; // 對窗體中所需要的內容進行初始化 InitializeComponent ( ) ; } file://清除在程序中使用過的資源 protected override void Dispose( bool disposing ) { if( disposing ) { if ( components != null ) { components.Dispose ( ) ; } } base.Dispose( disposing ) ; } public static void Main ( ) { Application.Run ( new Data ( ) ) ; } public void GetConnected ( ) { try { file://創建一個 OleDbConnection string strCon = " Provider = Microsoft.Jet.OLEDB.4.0 ; Data Source = db.mdb" ; OleDbConnection myConn = new OleDbConnection ( strCon ) ; string strCom = " SELECT * FROM person " ; file://創建一個 DataSet myDataSet = new DataSet ( ) ; myConn.Open ( ) ; file://用 OleDbDataAdapter 得到一個數據集 OleDbDataAdapter myCommand = new OleDbDataAdapter ( strCom , myConn ) ; file://把Dataset綁定books數據表 myCommand.Fill ( myDataSet , "person" ) ; file://關閉此OleDbConnection myConn.Close ( ) ; } catch ( Exception e ) { MessageBox.Show ( "連接錯誤! " + e.ToString ( ) , "錯誤" ) ; } } private void InitializeComponent ( ) { file://添加控件,略 this.Name = "Data" ; this.Text = "Visual C#的數據庫編程!" ; this.ResumeLayout(false) ; myBind = this.BindingContext [ myDataSet , "person" ] ; } protected void New_record ( object sender , System.EventArgs e ) { t_id.Text = ( myBind.Count + 1 ).ToString ( ) ; t_xm.Text = "" ; t_xb.Text = "" ; t_nl.Text = "" ; t_books.Text = "" ; } protected void Insert_record ( object sender , System.EventArgs e ) { try { file://判斷所有字段是否添完,添完則執行,反之彈出提示 if ( t_id.Text != "" && t_xm.Text != "" && t_xb.Text != "" && t_nl.Text != "" && t_books.Text != "" ) { string myConn1 = " Provider = Microsoft.Jet.OLEDB.4.0 ; Data Source = db.mdb" ; OleDbConnection myConn = new OleDbConnection ( myConn1 ) ; myConn.Open ( ) ; string strInsert = " INSERT INTO person ( id , xm , xb , nl , zip ) VALUES ( " ; strInsert += t_id.Text + ", '" ; strInsert += t_xm.Text + "', '" ; strInsert += t_xb.Text + "', " ; strInsert += t_nl.Text + ", " ; strInsert += t_books.Text + ")" ; OleDbCommand inst = new OleDbCommand ( strInsert , myConn ) ; inst.ExecuteNonQuery ( ) ; myConn.Close ( ) ; myDataSet.Tables [ "person" ] . Rows [ myBind.Position ] . BeginEdit ( ) ; myDataSet.Tables [ "person" ] . Rows [ myBind.Position ] . EndEdit ( ) ; myDataSet.Tables [ "person" ] . AcceptChanges ( ) ; } else { MessageBox.Show ( "必須填滿所有字段值!" , "錯誤!" ) ; } } catch ( Exception ed ) { MessageBox.Show ( "保存數據記錄發生 " + ed.ToString ( ) , "錯誤!" ) ; } } protected void Update_record ( object sender , System.EventArgs e ) { int i = myBind.Position ; try{ file://連接到一個數據庫 string strCon = " Provider = Microsoft.Jet.OLEDB.4.0 ; Data Source = db.mdb " ; OleDbConnection myConn = new OleDbConnection ( strCon ) ; myConn.Open ( ) ; myDataSet.Tables [ "person" ] . Rows [ myBind.Position ] . BeginEdit ( ) ; file://從數據庫中修改指定記錄 string strUpdt = " UPDATE person SET xm = '" + t_xm.Text + "' , xb = '" + t_xb.Text + "' , nl = " + t_nl.Text + " , zip = " + t_books.Text + " WHERE id = " + t_id.Text ; OleDbCommand myCommand = new OleDbCommand ( strUpdt , myConn ) ; myCommand.ExecuteNonQuery ( ) ; myDataSet.Tables [ "person" ] . Rows [ myBind.Position ] . EndEdit ( ) ; myDataSet.Tables [ "person" ] . AcceptChanges ( ) ; myConn.Close ( ) ; } catch ( Exception ed ) { MessageBox.Show ( "修改指定記錄錯誤: " + ed.ToString ( ) , "錯誤!" ) ; } myBind.Position = i ; } protected void Delete_record ( object sender , System.EventArgs e ) { DialogResult r = MessageBox.Show ( "是否刪除當前記錄!" , "刪除當前記錄!" , MessageBoxButtons.YesNo, MessageBoxIcon.Question ) ; int ss = ( int ) r ; if ( ss == 6 ) // 按動"確定"按鈕 { try{ file://連接到一個數據庫 string strCon = " Provider = Microsoft.Jet.OLEDB.4.0 ; Data Source = db.mdb " ; OleDbConnection myConn = new OleDbConnection ( strCon ) ; myConn.Open ( ) ; string strDele = "DELETE FROM person WHERE id= " + t_id.Text ; OleDbCommand myCommand = new OleDbCommand ( strDele , myConn ) ; file://從數據庫中刪除指定記錄 myCommand.ExecuteNonQuery ( ) ; file://從DataSet中刪除指定記錄 myDataSet.Tables [ "person" ] . Rows [ myBind.Position ] . Delete ( ) ; myDataSet.Tables [ "person" ] . AcceptChanges ( ) ; myConn.Close ( ) ; } catch ( Exception ed ) { MessageBox.Show ( "刪除記錄錯誤信息: " + ed.ToString ( ) , "錯誤!" ) ; } } } file://按鈕"尾記錄"對象事件程序 protected void GoLast ( object sender , System.EventArgs e ) { myBind.Position = myBind.Count - 1 ; } file://按鈕"下一條"對象事件程序 protected void GoNext ( object sender , System.EventArgs e ) { if ( myBind.Position == myBind.Count -1 ) MessageBox.Show ( "已經到了最后一條記錄!", "信息提示!" , MessageBoxButtons.OK , MessageBoxIcon.Information ) ; else myBind.Position += 1 ; } file://按鈕"上一條"對象事件程序 protected void GoPrevious ( object sender , System.EventArgs e ) { if ( myBind.Position == 0 ) MessageBox.Show ( "已經到了第一條記錄!" , "信息提示!" , MessageBoxButtons.OK , MessageBoxIcon.Information ) ; else myBind.Position -= 1 ; } file://按鈕"首記錄"對象事件程序 protected void GoFirst ( object sender , System.EventArgs e ) { myBind.Position = 0 ; } } |
對于以Sql Server 2000數據庫為模型的程序代碼,只要把Data01.cs中的數據鏈接,即: string myConn1 = " Provider = Microsoft.Jet.OLEDB.4.0 ; Data Source = db.mdb" ; |
改換成: string strCon = "Provider = SQLOLEDB.1 ; Persist Security Info = False ; User ID = sa ; Initial Catalog = data1 ; Data Source = server1 " ; |
注釋:此數據鏈接代表的意思是:打開Sql server數據庫,服務器名稱為server1,數據庫為data1就可以得到Visual C#針對Sql Server 2000數據庫為模板編程的完成源程序代碼了。所以本文就不再提供了。
七.總結:
數據庫編程始終是程序編程內容中的一個重點和難點。而以上介紹的這些操作又是數據庫編程中最為基本,也是最為重要的內容。那些復雜的編程無非是以上這些處理的若干個疊加。 |