共用方式為


RelationalStorageExtensions.ExecuteAsync 方法

定義

多載

ExecuteAsync(IRelationalStorage, String, CancellationToken)

搭配 ReflectionSelector<TResult>(IDataRecord) 使用 IRelationalStorage

ExecuteAsync(IRelationalStorage, String, Object, CancellationToken)

搭配 ReflectionSelector<TResult>(IDataRecord) 使用 IRelationalStorage

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

執行指定的 語句。 特別是用於 INSERTUPDATEDELETEDDL 查詢。

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

執行指定的 語句。 特別是用於 INSERTUPDATEDELETEDDL 查詢。

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" });

適用於