一步步实现本身的ORM（一）

 最近在研究ORM，尝试着本身开发了一个简单的ORM。我我的不喜欢EF由于跟不上EF升级太快了，再说公司里还停留在c# 3.5时代，对于NHibernate配置太复杂看到就头晕，就心生本身作一个ORM的念头，如今把开发过程当中的点点滴滴记录下来，供本身和新手参考，大神请直接忽略这篇文章。

  ORM（object relation mapping）对象关系映射，经常使用来映射数据库里表、字段等信息。ORM的原理无非就是用配置文件、Attribute来映射数据关系。咱们一步步来来建立ORM，定义一个实体类，而后用反射得到类名（表名）、属性（对应是字段名称），例子以下：

CREATE TABLE [dbo].[User](
    [UserId] [int] NOT NULL primary key,
    [Email] [nvarchar](100) NULL,
    [CreatedTime] [datetime] NULL
)

 

　　在这里我建立一张表，其中UserId是主键，为何不定义成自增加的呢？请保留这个疑问，继续看下去。表建立好了，下面就是定义一个类，以下：

    public class User
    {
        public int UserId { get; set; }

        public string Email { get; set; }

        public DateTime CreatedTime { get; set; }
    }

如今咱们要对这个类写一个INSERT操做，直接传入User对象而后插入到数据库。咱们要用系统自动构建SQL语句，不须要手写SQL语句，在这咱们先分析下INSERT INTO SQL语句。

INSERT INTO 表名
           (字段1
           ,字段2
           ,字段3...)
     VALUES
           值1,
           值2,
           值3...

咱们须要知道表名、字段名和值才可以完成SQL拼接，怎么获得这些信息呢，万能的反射该出场。 

            string className = typeof(User).Name;
            Console.WriteLine("类名：{0}", className);
            Console.WriteLine("-----获取属性信息-----");
            var properties = typeof(User).GetProperties();
            foreach (var item in properties)
            {
                Console.WriteLine("属性名：{0}",item.Name);
            }
            Console.WriteLine("-----end-----");

运行结果以下

 

LOOK，User类的信息都显示出来了，属性的值该如何显示？也就是SQL语句的VALUE，仍是要靠万能的反射，请看官门继续往下看。

            string className = typeof(User).Name;
            Console.WriteLine("类名：{0}", className);
            var properties = typeof(User).GetProperties();
            User user = new User() { 
                 UserId = 123,
                  Email = "abc@123.com",
                   CreatedTime = DateTime.Now
            };

            foreach (var item in properties)
            {
                Console.WriteLine("{0}：{1}", item.Name, item.GetValue(user, null));
            }

类名、属性名、属性值咱们都获得了，那下面要作的就是拼写SQL语句了

        public static void Main()
        {
            PritSql(new User()
            {
                UserId = 123,
                Email = "abc@123.com",
                CreatedTime = DateTime.Now
            });

        }

        public static void PritSql(User user)
        {

            string className = typeof(User).Name;
            var properties = typeof(User).GetProperties();

            StringBuilder sql = new StringBuilder();
            sql.Append("INSERT INTO ").Append(className).Append("(");

            for (int i = 0; i < properties.Length; i++)
            {
                var pi = properties[i];
                if (i > 0)
                    sql.Append(",");
                sql.Append(pi.Name);
            }
            sql.Append(") VALUES (");
            for (int i = 0; i < properties.Length; i++)
            {
                var pi = properties[i];
                if (i > 0)
                    sql.Append(",");
                sql.Append("'").Append(pi.GetValue(user,null)).Append("'");
            }
            sql.Append(")");
            Console.WriteLine(sql);

        }

View Code

 为避免SQL注入，我把SQL改为参数的信息

INSERT INTO 表名
           (字段1
           ,字段2
           ,字段3...)
     VALUES
           @p1,
           @p2,
           @p3...

修改后的c#代码

    public static void Main()
        {
            PritParameterSql(new User()
            {
                UserId = 123,
                Email = "abc@123.com",
                CreatedTime = DateTime.Now
            });

        }
        public static int PritParameterSql<T>(T user)
        {
            Dictionary<string, object> parameters = new Dictionary<string, object>();
            string className = typeof(T).Name;
            var properties = typeof(T).GetProperties();

            StringBuilder sql = new StringBuilder();
            sql.Append("INSERT INTO [").Append(className).Append("](");

            for (int i = 0; i < properties.Length; i++)
            {
                var pi = properties[i];
                if (i > 0)
                    sql.Append(",");
                sql.Append(pi.Name);
            }
            sql.Append(") VALUES (");
            for (int i = 0; i < properties.Length; i++)
            {
                var pi = properties[i];
                if (i > 0)
                    sql.Append(",");
                sql.Append("@p").Append(i);

                parameters.Add("@p" + i, pi.GetValue(user, null));
            }
            sql.Append(")");
            Console.WriteLine(sql);

            SqlConnection conn = new SqlConnection(connectionString);
            var cmd = conn.CreateCommand();
            cmd.CommandText = sql.ToString();
            foreach (var item in parameters)
            {
                var pa = cmd.CreateParameter();
                pa.ParameterName = item.Key;
                pa.Value = item.Value ?? DBNull.Value;
                cmd.Parameters.Add(pa);
            }


            conn.Open();
            return cmd.ExecuteNonQuery();
        }

View Code

执行后的结果

 

还记得前面提到为何UserId不设置成自增加吗？由于这种单纯的反射没法识别哪一个是自增加字段，若是想用自增加主键怎么办？请看后续文章。