RelationalStorageExtensions.ExecuteAsync 方法
定義
重要
部分資訊涉及發行前產品,在發行之前可能會有大幅修改。 Microsoft 對此處提供的資訊,不做任何明確或隱含的瑕疵擔保。
多載
ExecuteAsync(IRelationalStorage, String, CancellationToken)
public static System.Threading.Tasks.Task<int> ExecuteAsync (this Orleans.SqlUtils.IRelationalStorage storage, string query, System.Threading.CancellationToken cancellationToken = default);
static member ExecuteAsync : Orleans.SqlUtils.IRelationalStorage * string * System.Threading.CancellationToken -> System.Threading.Tasks.Task<int>
<Extension()>
Public Function ExecuteAsync (storage As IRelationalStorage, query As String, Optional cancellationToken As CancellationToken = Nothing) As Task(Of Integer)
參數
- storage
- IRelationalStorage
要使用的儲存體。
- query
- String
執行指定的 語句。 特別是用於 INSERT、 UPDATE、 DELETE 或 DDL 查詢。
- cancellationToken
- CancellationToken
取消語彙基元。 預設值為 None。
傳回
受影響的資料列計數。
適用於
ExecuteAsync(IRelationalStorage, String, Object, CancellationToken)
public static System.Threading.Tasks.Task<int> ExecuteAsync (this Orleans.SqlUtils.IRelationalStorage storage, string query, object parameters, System.Threading.CancellationToken cancellationToken = default);
static member ExecuteAsync : Orleans.SqlUtils.IRelationalStorage * string * obj * System.Threading.CancellationToken -> System.Threading.Tasks.Task<int>
<Extension()>
Public Function ExecuteAsync (storage As IRelationalStorage, query As String, parameters As Object, Optional cancellationToken As CancellationToken = Nothing) As Task(Of Integer)
參數
- storage
- IRelationalStorage
要使用的儲存體。
- query
- String
執行指定的 語句。 特別是用於 INSERT、 UPDATE、 DELETE 或 DDL 查詢。
- parameters
- Object
將參數新增至查詢。 參數名稱必須符合查詢中定義的名稱。
- cancellationToken
- CancellationToken
取消語彙基元。 預設值為 None。
傳回
受影響的資料列計數。
範例
這會使用反映來提供參數給執行查詢,以在可用時唯讀取受影響的資料列計數。
//Here reflection (<seealso cref="M:Orleans.SqlUtils.DbExtensions.ReflectionParameterProvider``1(System.Data.IDbCommand,``0,System.Collections.Generic.IReadOnlyDictionary{System.String,System.String})"></seealso>)
is used to match parameter names as well as to read back the results (<seealso cref="M:Orleans.SqlUtils.DbExtensions.ReflectionSelector``1(System.Data.IDataRecord)"></seealso>).
var query = "IF NOT EXISTS(SELECT * FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_NAME = @tname) CREATE TABLE Test(Id INT PRIMARY KEY IDENTITY(1, 1) NOT NULL);"
await db.ExecuteAsync(query, new { tname = "test_table" });