.NET程序迁移到Mysql的极简方案

7007

　　园子里的这个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及以上平台才可使用。
　　  源码下载：GGTalk-V5.5.rar     网盘下载更快
　　部署下载：GGTalk V5.5 可直接部署版本    网盘下载更快