借助表达式树感受不一样的CRUD

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();
            }
        }
        [Table("tabTestEntity")]
        internal class TestEntity
        {
            [DatabaseGenerated(DatabaseGeneratedOption.Identity)]
            public int PKID { get; set; }

            public string Token { get; set; }

            public DateTime CreatedTime { get; set; }
        }
    }

示例使用了 ObjectPool 实现了一个数据库连接池，Repository 实例化需要一个获取 DbConnection 对象的委托，而数据库连接就是从这数据库连接池中获取。

不足/TODO

• 支持指数化查询，现在是将条件直接拼接成了字符串，做了防注入处理，要改成使用参数化查询
• 支持更多的方法解析成对应的 Sql 语句