Intro#
最近有个想法，想不写 sql 语句，做一个类似于 ORM 的东西，自己解析表达式树，生成要执行的 sql 语句，最后再执行 sql 语句，返回相应结果。
思路解析#
常用的 sql 语句基本都有一定的模式，就是 INSERT/DELETE/Update/SELECT，我把公用的部分给抽离出来，把查询/更新/删除条件和指定字段通过表达式树来指出，解析传入的表达式树对象来获取条件以及要更新的字段。
源码#
源码链接
-
Repository
-
表达式树解析
Sample#
请看使用示例：
安装 nuget 包 WihanLi.Common
public static class RepositoryTest { public static void MainTest() { var connectionPool = new DbConnectionPool(new DbConnectionPoolPolicy(ConfigurationHelper.ConnectionString("TestDb"))); var repo = new Repository<TestEntity>(() => connectionPool.Get()); repo.Insert(new TestEntity { Token = "1233", CreatedTime = DateTime.UtcNow }); var entity = repo.Fetch(t => t.PKID == 1); System.Console.WriteLine(entity.Token); repo.Update(t => t.PKID == 1, t => t.Token, 1); entity = repo.Fetch(t => t.PKID == 1); System.Console.WriteLine(entity.Token); repo.Delete(t => t.PKID == 1); entity = repo.Fetch(t => t.PKID == 1); System.Console.WriteLine($"delete operation {(entity == null ? "Success" : "Failed")}"); repo.Execute("TRUNCATE TABLE dbo.tabTestEntity"); Console.WriteLine("finished."); } public class DbConnectionPool : DefaultObjectPool<DbConnection> { public DbConnectionPool(IPooledObjectPolicy<DbConnection> policy) : base(policy) { } public DbConnectionPool(IPooledObjectPolicy<DbConnection> policy, int maximumRetained) : base(policy, maximumRetained) { } } public class DbConnectionPoolPolicy : IPooledObjectPolicy<DbConnection> { private readonly string _connString; public DbConnectionPoolPolicy(string connString) { _connString = connString; } public DbConnection Create() { return new SqlConnection(_connString); } public bool Return(DbConnection obj) { return obj.ConnectionString.IsNotNullOrWhiteSpace(); } } [] internal class TestEntity { [] public int PKID { get; set; } public string Token { get; set; } public DateTime CreatedTime { get; set; } } }
示例使用了 ObjectPool 实现了一个数据库连接池，Repository 实例化需要一个获取 DbConnection 对象的委托，而数据库连接就是从这数据库连接池中获取。
不足/TODO#
- 支持通过 Column 自定义列名称
- 支持指数化查询，现在是将条件直接拼接成了字符串，做了防注入处理，要改成使用参数化查询
- 支持更多的方法解析成对应的 Sql 语句
