五分鐘知道ADO.NET異步查詢
ADO.NET經過長時間的發展,很多用戶都很了解ADO.NET了,這里我發表一下個人理解,和大家討論討論。ADO.NET數據庫提供程序包含Connection、Command、DataAdapter和DataReader對象。在一般的ADO.NET編程中,首先要創建Connection對象,給它提供需要的信息,例如連接字符串。然后創建一個Command對象,給它提供要執行的SQL命令的細節。這個命令可以是內置的SQL文本命令、存儲過程或對表的直接訪問。如果需要,還可以為這些命令提供參數。
#T#在創建Connection和Command對象后,就必須確定命令是否返回結果集。如果命令不返回結果集,就可以通過調用幾個Execute方法之一,執行命令。另一方面,如果命令返回結果集,就必須確定是否要保留結果集,以備將來在不維持與數據庫的連接的情況下使用。如果要保留結果集,就必須創建一個DataAdapter對象,用它填充DataSet或DataTable對象。這些對象可以在斷開連接的模式下維護其中的信息。但是,如果不想保留結果集,只是要以快速方式執行命令,就可以使用Command對象創建DataReader對象。DataReader對象需要與數據庫的實時連接,它是一個只向前的只讀光標。下面我們來看一個關于使用ADO.NET異步查詢的案例。
使用ADO.NET異步查詢,并將查詢結果呈現在指定的Form的DataGridView中
- Public Class Asynchronous
- Private Delegate Sub MainInvoke(ByVal TableItems() As String, ByVal RowCount As Integer) '委托
- Delegate Sub AsyncMethodCaller()
- Public connstr As String
- Public cmdstr As String
- Public frm As Form ' 指定的form
- Public dgv As DataGridView ' 指定的datagridview
- Public statuscontrol As Control ' 顯示狀態的控件
- Public message As String'狀態提示文本
- Private Sub CallbackHandler()
- Using conn As New SqlConnection(connstr), cmd As New SqlCommand(cmdstr, conn)
- conn.Open()
- Using reader As SqlDataReader = cmd.ExecuteReader
- Dim i As Integer
- Dim items(dgv.Columns.Count - 1) As String
- While reader.Read()
- For j As Int32 = 0 To dgv.Columns.Count - 1
- items(j) = reader(dgv.Columns(j).HeaderText)
- Next
- frm.Invoke(New MainInvoke(AddressOf Addrows), items, i)
- i += 1
- End While
- End Using
- conn.Close()
- End Using
- End Sub
- Public Sub getdatabase()
- Dim caller As New AsyncMethodCaller(AddressOf CallbackHandler)
- Dim result As IAsyncResult = caller.BeginInvoke(AddressOf StopRead, caller)
- End Sub
- Private Sub Addrows(ByVal TableItems() As String, ByVal row As Integer) '添加新行,并顯示處理進度
- dgv.Rows.Add()
- For i As Int32 = 0 To TableItems.Length - 1
- dgv.Rows(row).Cells(i).Value = TableItems(i)
- Next
- If statuscontrol IsNot Nothing Then statuscontrol.Text = message & row
- End Sub
- Private Sub StopRead(ByVal ar As IAsyncResult)
- Dim caller As AsyncMethodCaller = CType(ar.AsyncState, AsyncMethodCaller)
- caller.EndInvoke(ar)
- End Sub
- End Class
ADO.NET異步查詢使用方法:
- DataG.Columns.Add("編號", "編號")
- DataG.Columns.Add("時間", "時間")
- DataG.Columns.Add("用戶名", "用戶名")
- Dim newselect As New Asynchronous
- newselect.connstr = "SERVER=x;DATABASE=x;USER=x;PASSWORD=x;Asynchronous Processing=true"
- newselect.cmdstr = "select * from log"
- newselect.frm = Me
- newselect.dgv = DataG
- newselect.statuscontrol = Me
- newselect.message = "數據檢索中..."
- newselect.getdatabase()

















