SqlCommand.BeginExecuteNonQuery 方法
定義
重要
部分資訊涉及發行前產品，在發行之前可能會有大幅修改。 Microsoft 對此處提供的資訊，不做任何明確或隱含的瑕疵擔保。
多載
| BeginExecuteNonQuery() |
起始這個 所描述 SqlCommand 之 Transact-SQL 語句或預存程式的非同步執行。 |
| BeginExecuteNonQuery(AsyncCallback, Object) |
根據回呼程式和狀態資訊，起始這個 SqlCommand 所描述之 Transact-SQL 語句或預存程式的非同步執行。 |
BeginExecuteNonQuery()
起始這個 所描述 SqlCommand 之 Transact-SQL 語句或預存程式的非同步執行。
public:
IAsyncResult ^ BeginExecuteNonQuery();public IAsyncResult BeginExecuteNonQuery ();member this.BeginExecuteNonQuery : unit -> IAsyncResultPublic Function BeginExecuteNonQuery () As IAsyncResult傳回
IAsyncResult，可用來輪詢或等候結果，或兩者;叫用 時 EndExecuteNonQuery(IAsyncResult) 也需要這個值，這會傳回受影響的資料列數目。
例外狀況
SqlDbType當 設定 Stream 為 時 Value ，使用了Binary或VarBinary以外的 。 如需串流的詳細資訊，請參閱 SqlClient 串流支援。
-或-
SqlDbType當 設定 TextReader 為 時 Value ，會使用Char、NChar、NVarChar、VarChar或Xml以外的 。
-或-
在串流作業期間已關閉或卸除的 SqlConnection。 如需串流的詳細資訊，請參閱 SqlClient 串流支援。
- or -
<xref data-throw-if-not-resolved="true" uid="Microssoft.Data.SqlClient.SqlCommand.EnableOptimizedParameterBinding"></xref>
is set to true and a parameter with direction Output or InputOutput has been added to the <xref data-throw-if-not-resolved="true" uid="Microsoft.Data.SqlClient.SqlCommand.Parameters"></xref> collection.
在串流作業期間， XmlReader 或 TextReader 物件中 Stream 發生錯誤。 如需串流的詳細資訊，請參閱 SqlClient 串流支援。
XmlReader在 Stream 串流作業期間，或 TextReader 物件已關閉。 如需串流的詳細資訊，請參閱 SqlClient 串流支援。
範例
下列主控台應用程式會在 AdventureWorks 範例資料庫中建立更新資料，以非同步方式執行其工作。 為了模擬長時間執行的程序，此範例會在命令文字中插入 WAITFOR 陳述式。 一般而言，您不需要投入心力讓命令執行速度變慢，但在此案例中這麼做可讓您更輕鬆地示範非同步行為。
// <Snippet1>
using System;
using System.Data;
using Microsoft.Data.SqlClient;
class Class1
{
static void Main()
{
// This is a simple example that demonstrates the usage of the
// BeginExecuteNonQuery functionality.
// The WAITFOR statement simply adds enough time to prove the
// asynchronous nature of the command.
string commandText =
"UPDATE Production.Product SET ReorderPoint = ReorderPoint + 1 " +
"WHERE ReorderPoint Is Not Null;" +
"WAITFOR DELAY '0:0:3';" +
"UPDATE Production.Product SET ReorderPoint = ReorderPoint - 1 " +
"WHERE ReorderPoint Is Not Null";
RunCommandAsynchronously(commandText, GetConnectionString());
Console.WriteLine("Press ENTER to continue.");
Console.ReadLine();
}
private static void RunCommandAsynchronously(
string commandText, string connectionString)
{
// Given command text and connection string, asynchronously execute
// the specified command against the connection. For this example,
// the code displays an indicator as it is working, verifying the
// asynchronous behavior.
using (SqlConnection connection =
new SqlConnection(connectionString))
{
try
{
int count = 0;
SqlCommand command = new SqlCommand(commandText, connection);
connection.Open();
IAsyncResult result = command.BeginExecuteNonQuery();
while (!result.IsCompleted)
{
Console.WriteLine("Waiting ({0})", count++);
// Wait for 1/10 second, so the counter
// does not consume all available resources
// on the main thread.
System.Threading.Thread.Sleep(100);
}
Console.WriteLine("Command complete. Affected {0} rows.",
command.EndExecuteNonQuery(result));
}
catch (SqlException ex)
{
Console.WriteLine("Error ({0}): {1}", ex.Number, ex.Message);
}
catch (InvalidOperationException ex)
{
Console.WriteLine("Error: {0}", ex.Message);
}
catch (Exception ex)
{
// You might want to pass these errors
// back out to the caller.
Console.WriteLine("Error: {0}", ex.Message);
}
}
}
private static string GetConnectionString()
{
// To avoid storing the connection string in your code,
// you can retrieve it from a configuration file.
return "Data Source=(local);Integrated Security=SSPI;" +
"Initial Catalog=AdventureWorks";
}
}
// </Snippet1>
備註
方法 BeginExecuteNonQuery 會啟動非同步執行 Transact-SQL 語句或未傳回資料列的預存程式的程式，讓其他工作可以在語句執行時同時執行。 當語句完成時，開發人員必須呼叫 EndExecuteNonQuery 方法來完成作業。 方法 BeginExecuteNonQuery 會立即傳回，但直到程式碼執行對應的 EndExecuteNonQuery 方法呼叫為止，它不得執行任何其他針對相同 SqlCommand 物件啟動同步或非同步執行的呼叫。 EndExecuteNonQuery在命令的執行完成之前呼叫 ，會導致 SqlCommand 物件封鎖直到執行完成為止。
請注意，命令文字和參數會同步傳送至伺服器。 如果傳送大型命令或許多參數，這個方法可能會在寫入期間封鎖。 傳送命令之後，方法會立即傳回，而不需要等候來自伺服器的答案，也就是讀取是非同步。
由於此多載不支援回呼程式，因此開發人員必須輪詢以判斷命令是否已完成，方法是使用 IsCompleted 方法所 BeginExecuteNonQuery 傳回的 IAsyncResult 屬性，或等候使用 AsyncWaitHandle 傳回 IAsyncResult 之 屬性完成一或多個命令。
這個方法會 CommandTimeout 忽略 屬性。
適用於
BeginExecuteNonQuery(AsyncCallback, Object)
根據回呼程式和狀態資訊，起始這個 SqlCommand 所描述之 Transact-SQL 語句或預存程式的非同步執行。
public:
IAsyncResult ^ BeginExecuteNonQuery(AsyncCallback ^ callback, System::Object ^ stateObject);public IAsyncResult BeginExecuteNonQuery (AsyncCallback callback, object stateObject);member this.BeginExecuteNonQuery : AsyncCallback * obj -> IAsyncResultPublic Function BeginExecuteNonQuery (callback As AsyncCallback, stateObject As Object) As IAsyncResult參數
- callback
- AsyncCallback
完成執行命令時叫用的 AsyncCallback 委派。 通過nullNothingmicrosoft Visual Basic) 中的 (，表示不需要回呼。
- stateObject
- Object
已傳遞至回呼程序的使用者定義狀態物件。 使用 AsyncState 屬性，從回呼程序內擷取這個物件。
傳回
IAsyncResult，可用來輪詢或等候結果，或兩者;叫用 時 EndExecuteNonQuery(IAsyncResult) 也需要這個值，這會傳回受影響的資料列數目。
例外狀況
SqlDbType當 設定 Stream 為 時 Value ，使用了Binary或VarBinary以外的 。 如需串流的詳細資訊，請參閱 SqlClient 串流支援。
-或-
SqlDbType當 設定 TextReader 為 時 Value ，會使用Char、NChar、NVarChar、VarChar或Xml以外的 。
-或-
在串流作業期間已關閉或卸除的 SqlConnection。 如需串流的詳細資訊，請參閱 SqlClient 串流支援。
- or -
<xref data-throw-if-not-resolved="true" uid="Microssoft.Data.SqlClient.SqlCommand.EnableOptimizedParameterBinding"></xref>
is set to true and a parameter with direction Output or InputOutput has been added to the <xref data-throw-if-not-resolved="true" uid="Microsoft.Data.SqlClient.SqlCommand.Parameters"></xref> collection.
範例
下列 Windows 應用程式示範如何使用 BeginExecuteNonQuery 方法，執行包含數秒延遲的 Transact-SQL 語句， (模擬長時間執行的命令) 。
此範例示範許多重要的技術。 這包括呼叫從個別執行緒與表單互動的方法。 此外，此範例示範如何封鎖使用者多次同時執行命令，以及如何確保表單在呼叫回呼程式之前不會關閉。
若要設定此範例，請建立新的 Windows 應用程式。 Button將控制項和 Label 控制項放在表單上， (接受每個控制項的預設名稱) 。 將下列程式碼新增至表單的 類別，視您的環境需要修改連接字串。
// <Snippet1>
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Text;
using System.Windows.Forms;
using Microsoft.Data.SqlClient;
namespace Microsoft.AdoDotNet.CodeSamples
{
public partial class Form1 : Form
{
public Form1()
{
InitializeComponent();
}
// Hook up the form's Load event handler (you can double-click on
// the form's design surface in Visual Studio), and then add
// this code to the form's class:
private void Form1_Load(object sender, EventArgs e)
{
this.button1.Click += new System.EventHandler(this.button1_Click);
this.FormClosing += new System.Windows.Forms.
FormClosingEventHandler(this.Form1_FormClosing);
}
// You need this delegate in order to display text from a thread
// other than the form's thread. See the HandleCallback
// procedure for more information.
// This same delegate matches both the DisplayStatus
// and DisplayResults methods.
private delegate void DisplayInfoDelegate(string Text);
// This flag ensures that the user does not attempt
// to restart the command or close the form while the
// asynchronous command is executing.
private bool isExecuting;
// This example maintains the connection object
// externally, so that it is available for closing.
private SqlConnection connection;
private static string GetConnectionString()
{
// To avoid storing the connection string in your code,
// you can retrieve it from a configuration file.
return "Data Source=(local);Integrated Security=true;" +
"Initial Catalog=AdventureWorks";
}
private void DisplayStatus(string Text)
{
this.label1.Text = Text;
}
private void DisplayResults(string Text)
{
this.label1.Text = Text;
DisplayStatus("Ready");
}
private void Form1_FormClosing(object sender,
System.Windows.Forms.FormClosingEventArgs e)
{
if (isExecuting)
{
MessageBox.Show(this, "Cannot close the form until " +
"the pending asynchronous command has completed. Please wait...");
e.Cancel = true;
}
}
private void button1_Click(object sender, System.EventArgs e)
{
if (isExecuting)
{
MessageBox.Show(this,
"Already executing. Please wait until the current query " +
"has completed.");
}
else
{
SqlCommand command = null;
try
{
DisplayResults("");
DisplayStatus("Connecting...");
connection = new SqlConnection(GetConnectionString());
// To emulate a long-running query, wait for
// a few seconds before working with the data.
// This command does not do much, but that's the point--
// it does not change your data, in the long run.
string commandText =
"WAITFOR DELAY '0:0:05';" +
"UPDATE Production.Product SET ReorderPoint = ReorderPoint + 1 " +
"WHERE ReorderPoint Is Not Null;" +
"UPDATE Production.Product SET ReorderPoint = ReorderPoint - 1 " +
"WHERE ReorderPoint Is Not Null";
command = new SqlCommand(commandText, connection);
connection.Open();
DisplayStatus("Executing...");
isExecuting = true;
// Although it is not required that you pass the
// SqlCommand object as the second parameter in the
// BeginExecuteNonQuery call, doing so makes it easier
// to call EndExecuteNonQuery in the callback procedure.
AsyncCallback callback = new AsyncCallback(HandleCallback);
command.BeginExecuteNonQuery(callback, command);
}
catch (Exception ex)
{
isExecuting = false;
DisplayStatus(string.Format("Ready (last error: {0})", ex.Message));
if (connection != null)
{
connection.Close();
}
}
}
}
private void HandleCallback(IAsyncResult result)
{
try
{
// Retrieve the original command object, passed
// to this procedure in the AsyncState property
// of the IAsyncResult parameter.
SqlCommand command = (SqlCommand)result.AsyncState;
int rowCount = command.EndExecuteNonQuery(result);
string rowText = " rows affected.";
if (rowCount == 1)
{
rowText = " row affected.";
}
rowText = rowCount + rowText;
// You may not interact with the form and its contents
// from a different thread, and this callback procedure
// is all but guaranteed to be running from a different thread
// than the form. Therefore you cannot simply call code that
// displays the results, like this:
// DisplayResults(rowText)
// Instead, you must call the procedure from the form's thread.
// One simple way to accomplish this is to call the Invoke
// method of the form, which calls the delegate you supply
// from the form's thread.
DisplayInfoDelegate del = new DisplayInfoDelegate(DisplayResults);
this.Invoke(del, rowText);
}
catch (Exception ex)
{
// Because you are now running code in a separate thread,
// if you do not handle the exception here, none of your other
// code catches the exception. Because none of
// your code is on the call stack in this thread, there is nothing
// higher up the stack to catch the exception if you do not
// handle it here. You can either log the exception or
// invoke a delegate (as in the non-error case in this
// example) to display the error on the form. In no case
// can you simply display the error without executing a delegate
// as in the try block here.
// You can create the delegate instance as you
// invoke it, like this:
this.Invoke(new DisplayInfoDelegate(DisplayStatus),
String.Format("Ready(last error: {0}", ex.Message));
}
finally
{
isExecuting = false;
if (connection != null)
{
connection.Close();
}
}
}
}
}
// </Snippet1>
備註
方法 BeginExecuteNonQuery 會啟動非同步執行 Transact-SQL 語句或未傳回資料列的預存程式的程式，讓其他工作可以在語句執行時同時執行。 當語句完成時，開發人員必須呼叫 EndExecuteNonQuery 方法來完成作業。 方法 BeginExecuteNonQuery 會立即傳回，但直到程式碼執行對應的 EndExecuteNonQuery 方法呼叫為止，它不得執行任何其他針對相同 SqlCommand 物件啟動同步或非同步執行的呼叫。 EndExecuteNonQuery在命令的執行完成之前呼叫 ，會導致 SqlCommand 物件封鎖直到執行完成為止。
參數 callback 可讓您指定 AsyncCallback 語句完成時所呼叫的委派。 您可以從這個委派程式或應用程式內的任何其他位置呼叫 EndExecuteNonQuery 方法。 此外，您可以在 參數中 asyncStateObject 傳遞任何物件，而回呼程式可以使用 屬性擷取這項資訊 AsyncState 。
請注意，命令文字和參數會同步傳送至伺服器。 如果傳送大型命令或許多參數，這個方法可能會在寫入期間封鎖。 傳送命令之後，方法會立即傳回，而不需要等候來自伺服器的答案，也就是讀取是非同步。
由於回呼程式是從 Microsoft .NET Common Language Runtime 所提供的背景執行緒內執行，因此您必須採取嚴格的方法來處理應用程式中的跨執行緒互動。 例如，您不得從回呼程式內與表單的內容互動;如果必須更新表單，您必須切換回表單的執行緒，才能執行您的工作。 本主題中的範例示範此行為。
在作業執行期間發生的所有錯誤都會在回呼程式中擲回為例外狀況。 您必須在回呼程式中處理例外狀況，而不是在主應用程式中。 如需在回呼程式中處理例外狀況的其他資訊，請參閱本主題中的範例。
這個方法會 CommandTimeout 忽略 屬性。