IT技术互动交流平台

.NET程序迁移到Mysql的极简方案让GGTalk同时支持Sqlserver与mysql全程记录!

作者:CJM恣肆  来源:IT165收集  发布日期:2016-12-14 20:33:13

        园子里的这个GGTalk,咱们前前后后用它移花接木做的IM项目也不下三四个了。初次入手的时候,洋洋代码,多少感觉有些难以把握。不过一来二去,理清了头绪,也就一览无余了。相信跟我们一样想要利用GGTalk的同学大有人在,于是我打算写这样一个《GGTalk源码详解系列》,把自己对GGTalk的梳理分享给大家,让大家更容易上手。

        之前有一个企业级的IM项目,我们用GGTalk改造的,但是要求使用Mysql数据库,所以花了一番功夫将GGTalk迁移到的Mysql,功夫不负有心人,总算弄出了个成果。如今使用Mysql的企业还真不少,今天就来给大家分享分享,对大家一定会有所帮助! 

常用的数据库:
         商业:oracle, SQLserver,DB2
         开源:MySQL,postgreSQL,SQLite 

MySQL

        是一个小型关系型数据库管理系统,开发者为瑞典MySQL AB公司。

        在2008年1月16号被Sun公司收购。而2009年,SUN又被Oracle收购。

        由于其体积小、速度快、总体拥有成本低,尤其是开放源码这一特点,MySQL得到了广泛地应用。

        

Step0.Mysql安装相关问题

          1.1045 Access denied for user 'root'@'localhost' 
          解决方案:在my.ini文件中的[mysqld]下面一行添加 skip_grant_tables

          2.1067 进程意外终止

          解决方案:my.ini中将default-storage-engine=INNODB改成MYISAM

          3.cmd中显示mysql不是内部或外部命令

          解决方案:环境变量Path中添加mysql安装目录bin的全路径        

Step1.启动Mysql服务

          

Step2.导入sql脚本

          其中有三张表:

                 

          1.GGUser表:

          

          2.GGgroup表:

          

          3.ChatMessageRecord表:

          

          ChatMessageRecord中的索引

          

Step3.修改服务端配置文件 

    <!--数据库相关信息配置-->
    <!--使用内存虚拟数据库-->
    <add key='UseVirtualDB' value='true'/>
    <!--数据库类型:SqlServer、MySQL-->
    <add key='DBType' value='MySQL'/>
    <!--数据库名称-->
    <add key='DBName' value='GGTalk'/>
    <!--数据库IP-->
    <add key='DBIP' value='127.0.0.1'/>
    <!--数据库Port,SqlServer默认为1433-->
    <add key='DBPort' value='1433'/>
    <!--数据库sa或root的密码-->
    <add key='SaPwd' value='123qwe'/>

          其中UseVirtualDB赋值为false表示使用真实数据库。数据库类型则可以配置为Sqlserver或者Mysql,程序中默认使用的是Sqlserver,需要切换到Mysql的时候修改此处即可。    

Step4.在服务端引用MySql.Data.dll

Step5.修改服务端的RealDB类的构造方法 

        /// <summary>
        /// 该构造函数用于SqlServer数据库。
        /// </summary>        
        public RealDB(string sqlServerDBName, string dbIP,string saPwd )
        {
            DataConfiguration config = new SqlDataConfiguration(dbIP, 'sa', saPwd, sqlServerDBName);
            this.transactionScopeFactory = new TransactionScopeFactory(config);
            this.transactionScopeFactory.Initialize();
            base.Initialize(this.transactionScopeFactory);
        }

        /// <summary>
        /// 该构造函数用于MySQL数据库。
        /// </summary>   
        public RealDB(string mysqlDBName, string dbIP, int dbPort, string rootPwd)
        {
            DataConfiguration config = new MysqlDataConfiguration(dbIP, dbPort, 'root', rootPwd, mysqlDBName);
            this.transactionScopeFactory = new TransactionScopeFactory(config);
            this.transactionScopeFactory.Initialize();
            base.Initialize(this.transactionScopeFactory);
        }

 Step6.重新编译,大功告成!

———————————————————分割线—————————————————————

     该解决方案目前已经分享给到GGTalk的作者,GGTalk也更新了最新版本V5.5,大家可以去下载部署到到Mysql了!!!

     源码下载GGTalk-V5.5.rar     网盘下载更快

   部署下载GGTalk V5.5 可直接部署版本    网盘下载更快

原理浅析: 

        正如ORM名称所指示的,实现ORM的关键点在于解决“对象--关系”之间的映射,例如,如何将一个DataRow转换为一个Entity Object,又如何将一个对某Entity Object的操作映射到一个IDbCommand,等等。比如我们以使用IORMapping接口来抽象这些映射:

  public interface IORMapping<TEntity>
    {
        TEntity GetEntityFrom(DataRow row ,bool withBlob);
        
        /// <summary>
        /// FillParameterValue  使用entity的内容填充command中的各个IDbDataParameter的参数值。
        /// </summary>      
        void FillParameterValue(IDbCommand command, TEntity entity);
     }

       关于如何实现IORMapping接口,至少有四种方案。我们以实现GetEntityFrom方法为例为例来讲述这四种方案,这个方法是将一个DataRow转换为一个Entity Object。 

1.代码生成器

       现在有很多代码生成器可以直接生成实现了ORM功能的DAL层,其背后的原理是,根据数据表的大纲(如有哪些列、每个列的类型等信息)来生成对应的实现了IORMapping接口的类。代码生成器是在编译之前就完成了这些工作的。 

2.反射

       将一个DataRow转换为一个Entity Object,如果粒度更细一点,我们实际要解决的是如何将DataRow的一列的值赋值给Entity Object对应的属性,我们可以使用反射在运行时给Entity Object的属性赋值,如:

entityType.InvokeMember(columnName, BindingFlags.Public | BindingFlags.IgnoreCase |
BindingFlags.Instance | BindingFlags.SetProperty, null, entity, row[columnName]);

     这行代码的含义是将row中【columnName】列的值赋值给entity对象的【columnName】属性。 

3.Emit

       我们可以在运行时根据每个Entity类型动态发射对应的实现了IORMapping接口的类型,这些动态类型发射成功后,便可以被实例化然后被使用。比如我们要发射实现GetEntityFrom方法的代码:

        private void EmitGetEntityFromMethod(TypeBuilder typeBuilder, MethodInfo baseMethod, Type entityType, DataSchema dataSchema)
        {
            MethodBuilder methodBuilder = typeBuilder.DefineMethod('GetEntityFrom', baseMethod.Attributes & ~MethodAttributes.Abstract, baseMethod.CallingConvention, baseMethod.ReturnType, EmitHelper.GetParametersType(baseMethod));
            ILGenerator ilGenerator = methodBuilder.GetILGenerator();
            Label retLabel = ilGenerator.DefineLabel();
            ilGenerator.DeclareLocal(entityType); //Member member = null ;
            ilGenerator.Emit(OpCodes.Nop);
            ilGenerator.Emit(OpCodes.Newobj, entityType.GetConstructor(new Type[] { }));
            ilGenerator.Emit(OpCodes.Stloc_0); //member = new Member() ;

            IList<PropertyInfo> blobList = new List<PropertyInfo>();
            #region 为非blob属性赋值
            foreach (PropertyInfo property in entityType.GetProperties())
            {
                ColumnSchema columnSchema = dataSchema.GetColumnSchema(property.Name);
                if (columnSchema == null)
                {
                    continue;
                }

                if ((property.PropertyType == typeof(byte[])) && (!columnSchema.IsTimestamp))
                {
                    blobList.Add(property);
                    continue;
                }

                EmitSetProperty(entityType, ilGenerator, property);
            }
            #endregion

            if (blobList.Count > 0)
            {
                ilGenerator.Emit(OpCodes.Ldarg_2);
                ilGenerator.Emit(OpCodes.Brfalse, retLabel);

                #region 为blob属性赋值
                foreach (PropertyInfo property in blobList)
                {
                    EmitSetProperty(entityType, ilGenerator, property);
                }
                #endregion
            }

            ilGenerator.MarkLabel(retLabel);
            ilGenerator.Emit(OpCodes.Nop);
            ilGenerator.Emit(OpCodes.Ldloc_0);
            ilGenerator.Emit(OpCodes.Ret);

            typeBuilder.DefineMethodOverride(methodBuilder, baseMethod);    // 定义方法重载
        }

4.使用Lamda表达式

       如果是在.NET3.5上,我们可以使用动态生成的Lamda表达式来完成Entity Object属性的赋值操作,关键点是要如何生成用于赋值的动态委托。比如: 

 private Action<TEntity, object> CreateFunctionOfSetProperty<TEntity>(MethodInfo setPropertyMethod, Type columnType)
        {
            ParameterExpression paramEntityObj = Expression.Parameter(typeof(TEntity), 'entity');
            ParameterExpression paramProVal = Expression.Parameter(typeof(object), 'propertyVal');
            UnaryExpression paramProVal2 = Expression.Convert(paramProVal, columnType);
            MethodCallExpression body = Expression.Call(paramEntityObj, setPropertyMethod, paramProVal2);
            Expression<Action<TEntity, object>> setPropertyExpression = Expression.Lambda<Action<TEntity, object>>(body, paramEntityObj, paramProVal);

            Action<TEntity, object> setPropertyAction = setPropertyExpression.Compile();

            return (entity, propertyVal) => { setPropertyAction(entity, propertyVal); };
        } 

     这个方法返回一个委托,返回的委托接收两个参数--Entity Object 和要赋的属性值,调用这个委托便可以为Entity Object的某个属性进行赋值。 

     好了,四种方案已经简单介绍完毕,下面我们来比较一下。 

(1)除了第一种方案是在编译期完成外,后面三种方案都是在运行期完成的。 

(2)第一种方案的效率是最高的,但是所需的手工操作也是最多的(比如每次修改了表结构都需要重新生成DAL层)。第二种方案的效率是最低的,反射使效率的折损非常之大。后两种方案的效率都不错(几乎接近第一种方案)。 

(3)Emit方案的实现难度应当是最大的,其次是Lamda表达式方案。 

(4)Lamda表达式方案在.NET3.5及以上平台才可使用。 

     源码下载:http://115.29.163.42/DownloadFiles/GGTalk-V5.5.rar

   部署下载:http://115.29.163.42/DownloadFiles/GGTalk5.5%E9%83%A8%E7%BD%B2%E7%89%88.rar

Tag标签: 全程   同时   方案  
  • 专题推荐

About IT165 - 广告服务 - 隐私声明 - 版权申明 - 免责条款 - 网站地图 - 网友投稿 - 联系方式
本站内容来自于互联网,仅供用于网络技术学习,学习中请遵循相关法律法规