-
Notifications
You must be signed in to change notification settings - Fork 857
ADO
2881099 edited this page Oct 10, 2022
·
13 revisions
Ado 是 IFreeSql 下重要的对象之一,它包括所有对 SQL 操作的封装,提供 ExecuteReader、ExecuteDataSet、ExecuteDataTable、ExecuteNonQuery、ExecuteScalar 等方法,使用起来和传统 SqlHelper 一样。
//返回多条记录
List<T> list = fsql.Ado.Query<T>("select * from t1");
//返回单条记录
T item = fsql.Ado.QuerySingle<T>("select * from t1 where id = @id", new { id = 1 });
//返回多个结果集
var result = fsql.Ado.Query<T1, T2>("select * from t1; select * from t2");
List<T1> list1 = result.Item1;
List<T2> list2 = result.Item2;
//like 查询
string searchText = "abc";
List<T> users = _fsql.Ado.Query<T>("select * from t1 where name like @name", new { name = "%" + searchText + "%" });
//SELECT now(), utc_timestamp()
var result = fsql.Ado.QuerySingle(() => new
{
DateTime.Now,
DateTime.UtcNow
});
Ado 下面所有参数 object parms 都可以接受匿名对象,或者字典:
- new { id = 1, name = "xx" }
- new Dictionary<string, object> { ["id"] = 1, ["name"] = "xx" }
关于参数前缀:
- odbc 是 ? 并且没有标识,所以freesql禁用了 odbc 参数化
- oracle 是 :
- mysql.data 是 ?
- mysqlconnector 是 @
- 其他基本都是 @
IN 参数化查询:
当前仅支持Array和IList类型绑定
var ids = new int[] { 1,2,3 };
List<T> list = fsql.Ado.Query<T>("select * from t1 where id in @ids", new { ids = ids });
bool isok = fsql.Ado.ExecuteConnectTest();
fsql.Ado 重载方法太多的情况下,建议使用 CommandFluent,例如存储过程:
DbParameter p2 = null;
fsql.Ado.CommandFluent("dbo.GetICMaxNum")
.CommandType(CommandType.StoredProcedure)
.CommandTimeout(60)
.WithParameter("TableName", "tb1")
.WithParameter("FInterID", null, p =>
{
//(p as OracleParameter).OracleType = ...;
p2 = p; //Output 参数
p.DbType = DbType.Int32;
p.Direction = ParameterDirection.Output;
})
.ExecuteNonQuery(); //.Query<T>() 或者 .ExecuteDataTable() 或者 ...
Console.WriteLine(p2.Value);
Oracle 存储过程获取 DataTable:
OracleParameter p2 = null;
var dt = fsql.Ado.CommandFluent("getTableInfo")
.CommandType(CommandType.StoredProcedure)
.CommandTimeout(60)
.WithParameter("out_var", null, p =>
{
p2 = p as OracleParameter;
p2.OracleDbType = OracleDbType.RefCursor;
p2.Direction = ParameterDirection.Output;
})
.ExecuteDataTable();
Console.WriteLine(dt.Rows.Count);
提供了类似 Dapper 的使用方法,FreeSql 增加了 IDbConnection/IDbTransaction 对象的扩展方法 Select/Insert/Update/Delete 实现 CRUD。
using FreeSql;
using (var conn = new SqlConnection(...))
{
//IFreeSql fsql = conn.GetIFreeSql();
//fsql.CodeFirst.IsNoneCommandParameter = true;
//fsql.CodeFirst.IsSyncStructureToUpper = true;
//fsql.Aop.CommandBefore += (_, e) => Trace.WriteLine(e.Command.CommandText);
//以上整个程序只需要设置一次
conn.Select<T>().Where(...).ToList();
conn.Insert(new T {}).ExecuteAffrows();
conn.Update().SetSource(new T {}).ExecuteAffrows();
conn.InsertOrUpdate().SetSource(new T {}).ExecuteAffrows();
conn.Delete<T>().Where(...).ExecuteAffrows();
}
- 每个 SqlConnection GetFreeSql() 返回的 IFreeSql 实例相同;
- 可以对 fsql 设置 Aop 事件,比如监视 SQL;
- IFreeSql 自身的成员 IDbFirst、Transaction 不可用;
利用本功能可以快速将 FreeSql 使用到项目中,只需要处理好实体类的特性。
提示:FreeSql 兼容 EFCore 99% 的实体特性