DapperExecutor 类

命名空间

Dapper.Shadow

程序集

Dapper.Shadow.Core.dll

Dapper执行器

public class DapperExecutor : IExecutor

继承

object

DapperExecutor

实现

IExecutor

衍生

ParametricExecutor

扩展方法

DapperShadowCoreServices.From(IExecutor, string)

构造函数

DapperExecutor(ISqlEngine, IDbConnection, bool, int)

Dapper执行器

public DapperExecutor(ISqlEngine engine, IDbConnection connection, bool buffered = true, int capacity = 128)

参数

engine ISqlEngine

数据库引擎

connection IDbConnection

数据库连接

buffered bool

capacity int

字段

_capacity

sql语句默认大小

protected readonly int _capacity

字段值

int

_engine

数据库引擎

protected readonly ISqlEngine _engine

字段值

ISqlEngine

属性

Capacity

sql语句默认大小

public int Capacity { get; }

属性值

int

CommandTimeout

Number of seconds before command execution timeout.

public int? CommandTimeout { get; set; }

属性值

int?

Connection

数据库连接

public IDbConnection Connection { get; }

属性值

IDbConnection

Engine

数据库引擎

public ISqlEngine Engine { get; }

属性值

ISqlEngine

Flags

Whether the results should be buffered during query execution.

public CommandFlags Flags { get; }

属性值

CommandFlags

Transaction

The transaction to use for this command.

public IDbTransaction? Transaction { get; }

属性值

IDbTransaction

方法

BeginTransaction()

开启事务

public void BeginTransaction()

BeginTransaction(IsolationLevel)

开启事务

public void BeginTransaction(IsolationLevel level)

参数

level IsolationLevel

Commit()

提交事务

public void Commit()

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)

执行

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

Rollback()

回滚事务

public void Rollback()