DapperExecutor 类

命名空间

Dapper.Shadow

程序集

Dapper.Shadow.Core.dll

Dapper执行器

public class DapperExecutor : IExecutor

继承

object

DapperExecutor

实现

IExecutor

衍生

ParametricExecutor

扩展方法

DapperShadowCoreServices.From(IExecutor, string)

构造函数

DapperExecutor(ISqlEngine, ISqlSource, bool, int)

Dapper执行器

public DapperExecutor(ISqlEngine engine, ISqlSource source, bool buffered = true, int capacity = 128)

参数

engine ISqlEngine

数据库引擎

source ISqlSource

数据库连接

buffered bool

capacity int

字段

_capacity

sql语句默认大小

protected readonly int _capacity

字段值

int

_engine

数据库引擎

protected readonly ISqlEngine _engine

字段值

ISqlEngine

属性

Capacity

sql语句默认大小

public int Capacity { get; }

属性值

int

Engine

数据库引擎

public ISqlEngine Engine { get; }

属性值

ISqlEngine

Flags

Whether the results should be buffered during query execution.

public CommandFlags Flags { get; }

属性值

CommandFlags

source

数据源

public ISqlSource source { get; }

属性值

ISqlSource

方法

CountAsync<T>(ITableView, object?, CancellationToken)

异步计数

public virtual Task<T?> CountAsync<T>(ITableView view, object? param = null, CancellationToken token = default)

参数

view ITableView

param object

token CancellationToken

返回

Task<T>

类型参数

T

ExecuteAsync(ISqlEntity, object?, CancellationToken)

执行SQL 并返回受影响的行数

public virtual Task<int> ExecuteAsync(ISqlEntity entity, object? param = null, CancellationToken token = default)

参数

entity ISqlEntity

param object

token CancellationToken

返回

Task<int>

ExecuteAsync(string, object?, CancellationToken)

执行SQL 并返回受影响的行数

public Task<int> ExecuteAsync(string sql, object? param = null, CancellationToken token = default)

参数

sql string

param object

token CancellationToken

返回

Task<int>

ExecuteScalarAsync<T>(ISqlEntity, object?, CancellationToken)

获取第一行第一列

public virtual Task<T?> ExecuteScalarAsync<T>(ISqlEntity entity, object? param = null, CancellationToken token = default)

参数

entity ISqlEntity

param object

token CancellationToken

返回

Task<T>

类型参数

T

ExecuteScalarAsync<T>(string, object?, CancellationToken)

获取第一行第一列

public Task<T?> ExecuteScalarAsync<T>(string sql, object? param = null, CancellationToken token = default)

参数

sql string

param object

token CancellationToken

返回

Task<T>

类型参数

T

QueryAsync<T>(ISqlEntity, object?, CancellationToken)

获取多行结果

public virtual Task<IEnumerable<T>> QueryAsync<T>(ISqlEntity entity, object? param = null, CancellationToken token = default)

参数

entity ISqlEntity

param object

token CancellationToken

返回

Task<IEnumerable<T>>

类型参数

T

QueryAsync<T>(string, object?, CancellationToken)

获取多行结果

public Task<IEnumerable<T>> QueryAsync<T>(string sql, object? param = null, CancellationToken token = default)

参数

sql string

param object

token CancellationToken

返回

Task<IEnumerable<T>>

类型参数

T

QueryFirstOrDefaultAsync<T>(ISqlEntity, object?, CancellationToken)

获取一行结果

public virtual Task<T?> QueryFirstOrDefaultAsync<T>(ISqlEntity entity, object? param = null, CancellationToken token = default)

参数

entity ISqlEntity

param object

token CancellationToken

返回

Task<T>

类型参数

T

QueryFirstOrDefaultAsync<T>(string, object?, CancellationToken)

获取一行结果

public Task<T?> QueryFirstOrDefaultAsync<T>(string sql, object? param = null, CancellationToken token = default)

参数

sql string

param object

token CancellationToken

返回

Task<T>

类型参数

T