mirror of
https://github.com/nsnail/FreeSql.git
synced 2025-04-21 18:22:51 +08:00
397 lines
27 KiB
C#
397 lines
27 KiB
C#
using FreeSql.DatabaseModel;
|
||
using SafeObjectPool;
|
||
using System;
|
||
using System.Collections.Generic;
|
||
using System.Data;
|
||
using System.Data.Common;
|
||
using System.Text;
|
||
using System.Threading.Tasks;
|
||
|
||
namespace FreeSql
|
||
{
|
||
public partial interface IAdo
|
||
{
|
||
/// <summary>
|
||
/// 主库连接池
|
||
/// </summary>
|
||
ObjectPool<DbConnection> MasterPool { get; }
|
||
/// <summary>
|
||
/// 从库连接池
|
||
/// </summary>
|
||
List<ObjectPool<DbConnection>> SlavePools { get; }
|
||
/// <summary>
|
||
/// 监视数据库命令对象(执行前，调试)
|
||
/// </summary>
|
||
Action<DbCommand> AopCommandExecuting { get; set; }
|
||
/// <summary>
|
||
/// 监视数据库命令对象(执行后，用于监视执行性能)
|
||
/// </summary>
|
||
Action<DbCommand, string> AopCommandExecuted { get; set; }
|
||
/// <summary>
|
||
/// 数据库类型
|
||
/// </summary>
|
||
DataType DataType { get; }
|
||
|
||
#region 事务
|
||
/// <summary>
|
||
/// 开启事务（不支持异步），60秒未执行完将自动提交
|
||
/// </summary>
|
||
/// <param name="handler">事务体 () => {}</param>
|
||
void Transaction(Action handler);
|
||
/// <summary>
|
||
/// 开启事务（不支持异步）
|
||
/// </summary>
|
||
/// <param name="handler">事务体 () => {}</param>
|
||
/// <param name="timeout">超时，未执行完将自动提交</param>
|
||
void Transaction(Action handler, TimeSpan timeout);
|
||
/// <summary>
|
||
/// 当前线程的事务
|
||
/// </summary>
|
||
DbTransaction TransactionCurrentThread { get; }
|
||
#endregion
|
||
|
||
/// <summary>
|
||
/// 查询，若使用读写分离，查询【从库】条件cmdText.StartsWith("SELECT ")，否则查询【主库】
|
||
/// </summary>
|
||
/// <param name="readerHander"></param>
|
||
/// <param name="cmdType"></param>
|
||
/// <param name="cmdText"></param>
|
||
/// <param name="cmdParms"></param>
|
||
void ExecuteReader(Action<DbDataReader> readerHander, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
void ExecuteReader(DbTransaction transaction, Action<DbDataReader> readerHander, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
void ExecuteReader(DbConnection connection, DbTransaction transaction, Action<DbDataReader> readerHander, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
/// <summary>
|
||
/// 查询，ExecuteReader(dr => {}, "select * from user where age > @age", new { age = 25 })
|
||
/// </summary>
|
||
/// <param name="cmdText"></param>
|
||
/// <param name="parms"></param>
|
||
void ExecuteReader(Action<DbDataReader> readerHander, string cmdText, object parms = null);
|
||
void ExecuteReader(DbTransaction transaction, Action<DbDataReader> readerHander, string cmdText, object parms = null);
|
||
void ExecuteReader(DbConnection connection, DbTransaction transaction, Action<DbDataReader> readerHander, string cmdText, object parms = null);
|
||
/// <summary>
|
||
/// 查询
|
||
/// </summary>
|
||
/// <param name="cmdText"></param>
|
||
/// <param name="cmdParms"></param>
|
||
object[][] ExecuteArray(CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
object[][] ExecuteArray(DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
object[][] ExecuteArray(DbConnection connection, DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
/// <summary>
|
||
/// 查询，ExecuteArray("select * from user where age > @age", new { age = 25 })
|
||
/// </summary>
|
||
/// <param name="cmdText"></param>
|
||
/// <param name="parms"></param>
|
||
/// <returns></returns>
|
||
object[][] ExecuteArray(string cmdText, object parms = null);
|
||
object[][] ExecuteArray(DbTransaction transaction, string cmdText, object parms = null);
|
||
object[][] ExecuteArray(DbConnection connection, DbTransaction transaction, string cmdText, object parms = null);
|
||
/// <summary>
|
||
/// 查询
|
||
/// </summary>
|
||
/// <param name="cmdText"></param>
|
||
/// <param name="cmdParms"></param>
|
||
DataSet ExecuteDataSet(CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
DataSet ExecuteDataSet(DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
DataSet ExecuteDataSet(DbConnection connection, DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
/// <summary>
|
||
/// 查询，ExecuteDataSet("select * from user where age > @age; select 2", new { age = 25 })
|
||
/// </summary>
|
||
/// <param name="cmdText"></param>
|
||
/// <param name="parms"></param>
|
||
/// <returns></returns>
|
||
DataSet ExecuteDataSet(string cmdText, object parms = null);
|
||
DataSet ExecuteDataSet(DbTransaction transaction, string cmdText, object parms = null);
|
||
DataSet ExecuteDataSet(DbConnection connection, DbTransaction transaction, string cmdText, object parms = null);
|
||
/// <summary>
|
||
/// 查询
|
||
/// </summary>
|
||
/// <param name="cmdText"></param>
|
||
/// <param name="cmdParms"></param>
|
||
DataTable ExecuteDataTable(CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
DataTable ExecuteDataTable(DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
DataTable ExecuteDataTable(DbConnection connection, DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
/// <summary>
|
||
/// 查询，ExecuteDataTable("select * from user where age > @age", new { age = 25 })
|
||
/// </summary>
|
||
/// <param name="cmdText"></param>
|
||
/// <param name="parms"></param>
|
||
/// <returns></returns>
|
||
DataTable ExecuteDataTable(string cmdText, object parms = null);
|
||
DataTable ExecuteDataTable(DbTransaction transaction, string cmdText, object parms = null);
|
||
DataTable ExecuteDataTable(DbConnection connection, DbTransaction transaction, string cmdText, object parms = null);
|
||
/// <summary>
|
||
/// 在【主库】执行
|
||
/// </summary>
|
||
/// <param name="cmdType"></param>
|
||
/// <param name="cmdText"></param>
|
||
/// <param name="cmdParms"></param>
|
||
int ExecuteNonQuery(CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
int ExecuteNonQuery(DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
int ExecuteNonQuery(DbConnection connection, DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
/// <summary>
|
||
/// 在【主库】执行，ExecuteNonQuery("delete from user where age > @age", new { age = 25 })
|
||
/// </summary>
|
||
/// <param name="cmdText"></param>
|
||
/// <param name="parms"></param>
|
||
/// <returns></returns>
|
||
int ExecuteNonQuery(string cmdText, object parms = null);
|
||
int ExecuteNonQuery(DbTransaction transaction, string cmdText, object parms = null);
|
||
int ExecuteNonQuery(DbConnection connection, DbTransaction transaction, string cmdText, object parms = null);
|
||
/// <summary>
|
||
/// 在【主库】执行
|
||
/// </summary>
|
||
/// <param name="cmdType"></param>
|
||
/// <param name="cmdText"></param>
|
||
/// <param name="cmdParms"></param>
|
||
object ExecuteScalar(CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
object ExecuteScalar(DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
object ExecuteScalar(DbConnection connection, DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
/// <summary>
|
||
/// 在【主库】执行，ExecuteScalar("select 1 from user where age > @age", new { age = 25 })
|
||
/// </summary>
|
||
/// <param name="cmdText"></param>
|
||
/// <param name="parms"></param>
|
||
/// <returns></returns>
|
||
object ExecuteScalar(string cmdText, object parms = null);
|
||
object ExecuteScalar(DbTransaction transaction, string cmdText, object parms = null);
|
||
object ExecuteScalar(DbConnection connection, DbTransaction transaction, string cmdText, object parms = null);
|
||
|
||
/// <summary>
|
||
/// 执行SQL返回对象集合，Query<User>("select * from user where age > @age", new SqlParameter { ParameterName = "age", Value = 25 })
|
||
/// </summary>
|
||
/// <typeparam name="T"></typeparam>
|
||
/// <param name="cmdType"></param>
|
||
/// <param name="cmdText"></param>
|
||
/// <param name="cmdParms"></param>
|
||
/// <returns></returns>
|
||
List<T> Query<T>(CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
List<T> Query<T>(DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
List<T> Query<T>(DbConnection connection, DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
/// <summary>
|
||
/// 执行SQL返回对象集合，Query<User>("select * from user where age > @age", new { age = 25 })
|
||
/// </summary>
|
||
/// <typeparam name="T"></typeparam>
|
||
/// <param name="cmdText"></param>
|
||
/// <param name="parms"></param>
|
||
/// <returns></returns>
|
||
List<T> Query<T>(string cmdText, object parms = null);
|
||
List<T> Query<T>(DbTransaction transaction, string cmdText, object parms = null);
|
||
List<T> Query<T>(DbConnection connection, DbTransaction transaction, string cmdText, object parms = null);
|
||
|
||
/// <summary>
|
||
/// 执行SQL返回对象集合，Query<User>("select * from user where age > @age; select * from address", new SqlParameter { ParameterName = "age", Value = 25 })
|
||
/// </summary>
|
||
/// <typeparam name="T1"></typeparam>
|
||
/// <param name="cmdType"></param>
|
||
/// <param name="cmdText"></param>
|
||
/// <param name="cmdParms"></param>
|
||
/// <returns></returns>
|
||
(List<T1>, List<T2>) Query<T1, T2>(CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
(List<T1>, List<T2>) Query<T1, T2>(DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
(List<T1>, List<T2>) Query<T1, T2>(DbConnection connection, DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
/// <summary>
|
||
/// 执行SQL返回对象集合，Query<User>("select * from user where age > @age; select * from address", new { age = 25 })
|
||
/// </summary>
|
||
/// <typeparam name="T1"></typeparam>
|
||
/// <param name="cmdText"></param>
|
||
/// <param name="parms"></param>
|
||
/// <returns></returns>
|
||
(List<T1>, List<T2>) Query<T1, T2>(string cmdText, object parms = null);
|
||
(List<T1>, List<T2>) Query<T1, T2>(DbTransaction transaction, string cmdText, object parms = null);
|
||
(List<T1>, List<T2>) Query<T1, T2>(DbConnection connection, DbTransaction transaction, string cmdText, object parms = null);
|
||
|
||
(List<T1>, List<T2>, List<T3>) Query<T1, T2, T3>(CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
(List<T1>, List<T2>, List<T3>) Query<T1, T2, T3>(DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
(List<T1>, List<T2>, List<T3>) Query<T1, T2, T3>(DbConnection connection, DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
(List<T1>, List<T2>, List<T3>) Query<T1, T2, T3>(string cmdText, object parms = null);
|
||
(List<T1>, List<T2>, List<T3>) Query<T1, T2, T3>(DbTransaction transaction, string cmdText, object parms = null);
|
||
(List<T1>, List<T2>, List<T3>) Query<T1, T2, T3>(DbConnection connection, DbTransaction transaction, string cmdText, object parms = null);
|
||
(List<T1>, List<T2>, List<T3>, List<T4>) Query<T1, T2, T3, T4>(CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
(List<T1>, List<T2>, List<T3>, List<T4>) Query<T1, T2, T3, T4>(DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
(List<T1>, List<T2>, List<T3>, List<T4>) Query<T1, T2, T3, T4>(DbConnection connection, DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
(List<T1>, List<T2>, List<T3>, List<T4>) Query<T1, T2, T3, T4>(string cmdText, object parms = null);
|
||
(List<T1>, List<T2>, List<T3>, List<T4>) Query<T1, T2, T3, T4>(DbTransaction transaction, string cmdText, object parms = null);
|
||
(List<T1>, List<T2>, List<T3>, List<T4>) Query<T1, T2, T3, T4>(DbConnection connection, DbTransaction transaction, string cmdText, object parms = null);
|
||
(List<T1>, List<T2>, List<T3>, List<T4>, List<T5>) Query<T1, T2, T3, T4, T5>(CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
(List<T1>, List<T2>, List<T3>, List<T4>, List<T5>) Query<T1, T2, T3, T4, T5>(DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
(List<T1>, List<T2>, List<T3>, List<T4>, List<T5>) Query<T1, T2, T3, T4, T5>(DbConnection connection, DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
(List<T1>, List<T2>, List<T3>, List<T4>, List<T5>) Query<T1, T2, T3, T4, T5>(string cmdText, object parms = null);
|
||
(List<T1>, List<T2>, List<T3>, List<T4>, List<T5>) Query<T1, T2, T3, T4, T5>(DbTransaction transaction, string cmdText, object parms = null);
|
||
(List<T1>, List<T2>, List<T3>, List<T4>, List<T5>) Query<T1, T2, T3, T4, T5>(DbConnection connection, DbTransaction transaction, string cmdText, object parms = null);
|
||
|
||
#if net40
|
||
#else
|
||
#region async
|
||
/// <summary>
|
||
/// 查询，若使用读写分离，查询【从库】条件cmdText.StartsWith("SELECT ")，否则查询【主库】
|
||
/// </summary>
|
||
/// <param name="readerHander"></param>
|
||
/// <param name="cmdType"></param>
|
||
/// <param name="cmdText"></param>
|
||
/// <param name="cmdParms"></param>
|
||
Task ExecuteReaderAsync(Func<DbDataReader, Task> readerHander, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
Task ExecuteReaderAsync(DbTransaction transaction, Func<DbDataReader, Task> readerHander, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
Task ExecuteReaderAsync(DbConnection connection, DbTransaction transaction, Func<DbDataReader, Task> readerHander, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
/// <summary>
|
||
/// 查询，ExecuteReaderAsync(dr => {}, "select * from user where age > @age", new { age = 25 })
|
||
/// </summary>
|
||
/// <param name="cmdText"></param>
|
||
/// <param name="parms"></param>
|
||
Task ExecuteReaderAsync(Func<DbDataReader, Task> readerHander, string cmdText, object parms = null);
|
||
Task ExecuteReaderAsync(DbTransaction transaction, Func<DbDataReader, Task> readerHander, string cmdText, object parms = null);
|
||
Task ExecuteReaderAsync(DbConnection connection, DbTransaction transaction, Func<DbDataReader, Task> readerHander, string cmdText, object parms = null);
|
||
/// <summary>
|
||
/// 查询
|
||
/// </summary>
|
||
/// <param name="cmdText"></param>
|
||
/// <param name="cmdParms"></param>
|
||
Task<object[][]> ExecuteArrayAsync(CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
Task<object[][]> ExecuteArrayAsync(DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
Task<object[][]> ExecuteArrayAsync(DbConnection connection, DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
/// <summary>
|
||
/// 查询，ExecuteArrayAsync("select * from user where age > @age", new { age = 25 })
|
||
/// </summary>
|
||
/// <param name="cmdText"></param>
|
||
/// <param name="parms"></param>
|
||
/// <returns></returns>
|
||
Task<object[][]> ExecuteArrayAsync(string cmdText, object parms = null);
|
||
Task<object[][]> ExecuteArrayAsync(DbTransaction transaction, string cmdText, object parms = null);
|
||
Task<object[][]> ExecuteArrayAsync(DbConnection connection, DbTransaction transaction, string cmdText, object parms = null);
|
||
/// <summary>
|
||
/// 查询
|
||
/// </summary>
|
||
/// <param name="cmdText"></param>
|
||
/// <param name="cmdParms"></param>
|
||
Task<DataSet> ExecuteDataSetAsync(CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
Task<DataSet> ExecuteDataSetAsync(DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
Task<DataSet> ExecuteDataSetAsync(DbConnection connection, DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
/// <summary>
|
||
/// 查询，ExecuteDataSetAsync("select * from user where age > @age; select 2", new { age = 25 })
|
||
/// </summary>
|
||
/// <param name="cmdText"></param>
|
||
/// <param name="parms"></param>
|
||
/// <returns></returns>
|
||
Task<DataSet> ExecuteDataSetAsync(string cmdText, object parms = null);
|
||
Task<DataSet> ExecuteDataSetAsync(DbTransaction transaction, string cmdText, object parms = null);
|
||
Task<DataSet> ExecuteDataSetAsync(DbConnection connection, DbTransaction transaction, string cmdText, object parms = null);
|
||
/// <summary>
|
||
/// 查询
|
||
/// </summary>
|
||
/// <param name="cmdText"></param>
|
||
/// <param name="cmdParms"></param>
|
||
Task<DataTable> ExecuteDataTableAsync(CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
Task<DataTable> ExecuteDataTableAsync(DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
Task<DataTable> ExecuteDataTableAsync(DbConnection connection, DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
/// <summary>
|
||
/// 查询，ExecuteDataTableAsync("select * from user where age > @age", new { age = 25 })
|
||
/// </summary>
|
||
/// <param name="cmdText"></param>
|
||
/// <param name="parms"></param>
|
||
/// <returns></returns>
|
||
Task<DataTable> ExecuteDataTableAsync(string cmdText, object parms = null);
|
||
Task<DataTable> ExecuteDataTableAsync(DbTransaction transaction, string cmdText, object parms = null);
|
||
Task<DataTable> ExecuteDataTableAsync(DbConnection connection, DbTransaction transaction, string cmdText, object parms = null);
|
||
/// <summary>
|
||
/// 在【主库】执行
|
||
/// </summary>
|
||
/// <param name="cmdType"></param>
|
||
/// <param name="cmdText"></param>
|
||
/// <param name="cmdParms"></param>
|
||
Task<int> ExecuteNonQueryAsync(CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
Task<int> ExecuteNonQueryAsync(DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
Task<int> ExecuteNonQueryAsync(DbConnection connection, DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
/// <summary>
|
||
/// 在【主库】执行，ExecuteNonQueryAsync("delete from user where age > @age", new { age = 25 })
|
||
/// </summary>
|
||
/// <param name="cmdText"></param>
|
||
/// <param name="parms"></param>
|
||
/// <returns></returns>
|
||
Task<int> ExecuteNonQueryAsync(string cmdText, object parms = null);
|
||
Task<int> ExecuteNonQueryAsync(DbTransaction transaction, string cmdText, object parms = null);
|
||
Task<int> ExecuteNonQueryAsync(DbConnection connection, DbTransaction transaction, string cmdText, object parms = null);
|
||
/// <summary>
|
||
/// 在【主库】执行
|
||
/// </summary>
|
||
/// <param name="cmdType"></param>
|
||
/// <param name="cmdText"></param>
|
||
/// <param name="cmdParms"></param>
|
||
Task<object> ExecuteScalarAsync(CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
Task<object> ExecuteScalarAsync(DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
Task<object> ExecuteScalarAsync(DbConnection connection, DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
/// <summary>
|
||
/// 在【主库】执行，ExecuteScalarAsync("select 1 from user where age > @age", new { age = 25 })
|
||
/// </summary>
|
||
/// <param name="cmdText"></param>
|
||
/// <param name="parms"></param>
|
||
/// <returns></returns>
|
||
Task<object> ExecuteScalarAsync(string cmdText, object parms = null);
|
||
Task<object> ExecuteScalarAsync(DbTransaction transaction, string cmdText, object parms = null);
|
||
Task<object> ExecuteScalarAsync(DbConnection connection, DbTransaction transaction, string cmdText, object parms = null);
|
||
|
||
/// <summary>
|
||
/// 执行SQL返回对象集合，QueryAsync<User>("select * from user where age > @age", new SqlParameter { ParameterName = "age", Value = 25 })
|
||
/// </summary>
|
||
/// <typeparam name="T"></typeparam>
|
||
/// <param name="cmdType"></param>
|
||
/// <param name="cmdText"></param>
|
||
/// <param name="cmdParms"></param>
|
||
/// <returns></returns>
|
||
Task<List<T>> QueryAsync<T>(CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
Task<List<T>> QueryAsync<T>(DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
Task<List<T>> QueryAsync<T>(DbConnection connection, DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
/// <summary>
|
||
/// 执行SQL返回对象集合，QueryAsync<User>("select * from user where age > @age", new { age = 25 })
|
||
/// </summary>
|
||
/// <typeparam name="T"></typeparam>
|
||
/// <param name="cmdText"></param>
|
||
/// <param name="parms"></param>
|
||
/// <returns></returns>
|
||
Task<List<T>> QueryAsync<T>(string cmdText, object parms = null);
|
||
Task<List<T>> QueryAsync<T>(DbTransaction transaction, string cmdText, object parms = null);
|
||
Task<List<T>> QueryAsync<T>(DbConnection connection, DbTransaction transaction, string cmdText, object parms = null);
|
||
|
||
/// <summary>
|
||
/// 执行SQL返回对象集合，Query<User>("select * from user where age > @age; select * from address", new SqlParameter { ParameterName = "age", Value = 25 })
|
||
/// </summary>
|
||
/// <typeparam name="T1"></typeparam>
|
||
/// <param name="cmdType"></param>
|
||
/// <param name="cmdText"></param>
|
||
/// <param name="cmdParms"></param>
|
||
/// <returns></returns>
|
||
Task<(List<T1>, List<T2>)> QueryAsync<T1, T2>(CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
Task<(List<T1>, List<T2>)> QueryAsync<T1, T2>(DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
Task<(List<T1>, List<T2>)> QueryAsync<T1, T2>(DbConnection connection, DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
/// <summary>
|
||
/// 执行SQL返回对象集合，Query<User>("select * from user where age > @age; select * from address", new { age = 25 })
|
||
/// </summary>
|
||
/// <typeparam name="T1"></typeparam>
|
||
/// <param name="cmdText"></param>
|
||
/// <param name="parms"></param>
|
||
/// <returns></returns>
|
||
Task<(List<T1>, List<T2>)> QueryAsync<T1, T2>(string cmdText, object parms = null);
|
||
Task<(List<T1>, List<T2>)> QueryAsync<T1, T2>(DbTransaction transaction, string cmdText, object parms = null);
|
||
Task<(List<T1>, List<T2>)> QueryAsync<T1, T2>(DbConnection connection, DbTransaction transaction, string cmdText, object parms = null);
|
||
|
||
Task<(List<T1>, List<T2>, List<T3>)> QueryAsync<T1, T2, T3>(CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
Task<(List<T1>, List<T2>, List<T3>)> QueryAsync<T1, T2, T3>(DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
Task<(List<T1>, List<T2>, List<T3>)> QueryAsync<T1, T2, T3>(DbConnection connection, DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
Task<(List<T1>, List<T2>, List<T3>)> QueryAsync<T1, T2, T3>(string cmdText, object parms = null);
|
||
Task<(List<T1>, List<T2>, List<T3>)> QueryAsync<T1, T2, T3>(DbTransaction transaction, string cmdText, object parms = null);
|
||
Task<(List<T1>, List<T2>, List<T3>)> QueryAsync<T1, T2, T3>(DbConnection connection, DbTransaction transaction, string cmdText, object parms = null);
|
||
Task<(List<T1>, List<T2>, List<T3>, List<T4>)> QueryAsync<T1, T2, T3, T4>(CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
Task<(List<T1>, List<T2>, List<T3>, List<T4>)> QueryAsync<T1, T2, T3, T4>(DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
Task<(List<T1>, List<T2>, List<T3>, List<T4>)> QueryAsync<T1, T2, T3, T4>(DbConnection connection, DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
Task<(List<T1>, List<T2>, List<T3>, List<T4>)> QueryAsync<T1, T2, T3, T4>(string cmdText, object parms = null);
|
||
Task<(List<T1>, List<T2>, List<T3>, List<T4>)> QueryAsync<T1, T2, T3, T4>(DbTransaction transaction, string cmdText, object parms = null);
|
||
Task<(List<T1>, List<T2>, List<T3>, List<T4>)> QueryAsync<T1, T2, T3, T4>(DbConnection connection, DbTransaction transaction, string cmdText, object parms = null);
|
||
Task<(List<T1>, List<T2>, List<T3>, List<T4>, List<T5>)> QueryAsync<T1, T2, T3, T4, T5>(CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
Task<(List<T1>, List<T2>, List<T3>, List<T4>, List<T5>)> QueryAsync<T1, T2, T3, T4, T5>(DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
Task<(List<T1>, List<T2>, List<T3>, List<T4>, List<T5>)> QueryAsync<T1, T2, T3, T4, T5>(DbConnection connection, DbTransaction transaction, CommandType cmdType, string cmdText, params DbParameter[] cmdParms);
|
||
Task<(List<T1>, List<T2>, List<T3>, List<T4>, List<T5>)> QueryAsync<T1, T2, T3, T4, T5>(string cmdText, object parms = null);
|
||
Task<(List<T1>, List<T2>, List<T3>, List<T4>, List<T5>)> QueryAsync<T1, T2, T3, T4, T5>(DbTransaction transaction, string cmdText, object parms = null);
|
||
Task<(List<T1>, List<T2>, List<T3>, List<T4>, List<T5>)> QueryAsync<T1, T2, T3, T4, T5>(DbConnection connection, DbTransaction transaction, string cmdText, object parms = null);
|
||
#endregion
|
||
#endif
|
||
}
|
||
}
|