扩展ADO.net实现对象化CRUD(.net core/framework)

实现数据操作

获取数据访问连接IDbConnection dbConnection

通过扩展方法GetDBExtend获取IAbsDBExtend对象

    public IAbsDBExtend GetDBExtend()
    {
        return dbConnection.GetDBExtend(dbTrans);
    }

使用IAbsDBExtend实现对象化操作

var db = GetDBExtend();
db.BatchInsert(new List() { new TestClass() { Id = DateTime.Now.Millisecond, Name = "ddddd" } },true);
db.Update(b => b.Id == 1, new { Number = 2 });

IAbsDBExtend可以实现所有数据操作，如：

实现查询

通过扩展方法**GetLambdaQuery**获取ILambdaQuery对象

public ILambdaQuery GetLambdaQuery() where T : class
        {
            return dbConnection.GetLambdaQuery(dbTrans);
        }

使用ILambdaQuery实现查询

var query = GetLambdaQuery();
                query.Join((a, b) => a.Id == b.Id);
                query.PrintQuery();

ILambdaQuery能实现子查询和嵌套查询，只要符合T-SQL语义逻辑，可以使用ILambdaQueryResultSelect无限叠加

如：

• join后group

• join后再join

• group后再join

• join一个group结果

• join一个union结果

• 对union进行group再join

• ...

示例查询:

var q1 = GetLambdaQuery();
            var q2 = q1.CreateQuery();
            q2.Where(b => b.Id > 0);
            var view = q2.CreateQuery().Where(b => b.Id > 0).GroupBy(b => b.Name).Select(b => new { b.Name, aa = b.Id.COUNT() });//GROUP查询
            var view2 = q2.Join(view, (a, b) => a.CategoryName == b.Name).Select((a, b) => new { ss1 = a.UserId, ss2 = b.aa });//关联GROUP
            q1.Join(view2, (a, b) => a.Id == b.ss1).Select((a, b) => new { a.Id, b.ss1 }).ToList();//再关联
            //var result = view2.ToList();
            var sql = q1.PrintQuery();

源码示例参考