对象-关系映射(Object/Relation Mapping,简称ORM),是随着面向对象的软件开发方法发展而产生的。面向对象的开发方法是当今企业级应用开发环境中的主流开发方法,关系数据库是企业级应用环境中永久存放数据的主流数据存储系统。对象和关系数据是业务实体的两种表现形式,业务实体在内存中表现为对象,在数据库中表现为关系数据。内存中的对象之间存在关联和继承关系,而在数据库中,关系数据无法直接表达多对多关联和继承关系。因此,对象-关系映射(ORM)系统一般以中间件的形式存在,主要实现程序对象到关系数据库数据的映射。
如果打开你最近的程序,看看DAL代码,你肯定会看到很多近似的通用的模式。我们以保存对象的方法为例,你传入一个对象,为SqlCommand对象添加SqlParameter,把所有属性和对象对应,设置SqlCommand的CommandText属性为存储过程,然后运行SqlCommand。对于每个对象都要重复的写这些代码。
一个对持久类对象进行CRUD操作的API;
一个语言或API用来规定与类和类属性相关的查询;
一个规定mapping metadata的工具;
一种技术可以让ORM的实现同事务对象一起进行dirty checking, lazy association fetching以及其他的优化操作。
Cayenne (http://objectstyle.org/cayenne/)
Jaxor (http://jaxor.sourceforge.net)
Hibernate (http://www.hibernate.org)
iBatis (http://www.ibatis.com)
jRelationalFramework (http://ijf.sourceforge.net)
mirage (http://itor.cq2.org/en/oss/mirage/toon)
SMYLE (http://www.drjava.de/smyle)
TopLink (http://otn.oracle.com/products/ias/toplink/index.html)
1.2枚举数据类型模式:每种枚举类型对应一个表,只有一个列(_EnumLiteral)表示枚举值。
1.3基于类的数据类型模式:使用外键约束,将基础列与基于类的类型实例相关联。
2.2多值属性模式:每个多值属性映射成一个独立的表,使用外键连接到类所对应的表上。
2.3继承模式:每加入一个类的实例时,根据其继承关系自顶向下生成每个类的对象,这些对象具有相同的ID(根对象对应记录的主键)。删除对象实例时,自底向上删除数据。遇到从中间删的情况怎么办?多重继承怎么处理?(金龙飞)
3.2一对多关联模式:和3.1一样。如果多这端是有序的,还需加入一列表示序号。
3.3多对多关联模式:将关联单独作一个表。
3.4组合关联模式:注意级联式删除。
3.5反演关联模式:关联两端指向相关的类型,和普通关联一样。
3.6成对关联模式:关联记录两个类间的关系,用交集类表示关联,表示成一个单独的表,每个关联对应一个表,用外键表示它们间的关系。
3.7关联上的OCL需要分析成对应的存储过程代码。
3.8保证关联的cardinality也需要分析成对应的存储过程代码。
希望能给O/RM的初学者带来一点帮助。
[改造计划]
1、不用每次遍历所有的映射文件,只需查找当前对象所映射的文件。
2、分层,做到与PetShop架构结合。
3、用Attribute实现。目前Demo例子是用xml做映射文件的。
首先看下类视图及代码说明:
|
好了以下就让我们看看Execute(T obj, string cnHint, string cmdName)方法都做了什么吧:
...{
DateTime start = DateTime.Now;
MappingInfo map = MappingStore.TheInstance.GetMappingInfo(obj.ToString());//
CommandInfo cmdInfo = map.Commands[cmdName];//获取操作命令
//51aspx.com
using (DbConnection cn = DbConnectionStore.TheInstance.GetConnection(cnHint))//打开连接
...{
DbCommand cmd = DbCommandStore.TheInstance.GetCommand(cnHint, cmdInfo.CommandText);//建立一个Command对象
cmd.Connection = cn;
_setParamValues(obj, cmd, cmdInfo);
cmd.ExecuteNonQuery();
_getParamValues(obj, cmd, cmdInfo);//执行
}
TimeSpan duration = DateTime.Now - start;
return duration.ToString();
}
以上代码和一般的ADO.NET数据库操作类似。
下面再来看看映射文件的结构,以Emplyee为例:
<object.mappings>
<object.mapping for="Employee" namespace="ClassLibrary1">
<command type="Insert">
<text>
dbo.EMPLOYEE_INS_SP
</text>
<parameters>
<add objMember="_employeeId" dbMember="@EmployeeId"/>
<add objMember="_firstName" dbMember="@FirstName" />
<add objMember="_lastName" dbMember="@LastName" />
<add objMember="_age" dbMember="@Age" />
</parameters>
</command>
<!--省略了Select和Update的映射,代码可见Demo-->
</object.mapping>
</object.mappings>
我们再看看MappingStore.cs这个文件中的类:
其中有三个类(我觉得这里就不是很符合规范,一个文件包含了三个类,但至少阅读起来的确比较方便)
·MappingStore类:负责加载映射文件,这里的Demo是遍历所有映射文件,然后通过GetMappingInfo(string typeName)方法返回一个MappingInfo类对象。
·MappingInfo类:负责加载映射文件中的所有Command,保存在Dictionary<TKey, TValue>中,其中TKey是CommandTtype,比如“Insert”、“Select”、“Update”等,TValue就是一个CommandInfo类对象。
·CommangInfo类:负责加载映射文件中的Parameters参数,也是保存在一个Dictionary< TKey, TValue>中,其中TKey是映射文件中dbMember,这个dbMember必须和数据库的字段名一致;TValue是objMember,对应Employee和Person这两个实体类的参数名。
2 ...{
3 DateTime start = DateTime.Now;
4 MappingStore mapStoreInstance = new MappingStore();
5 MappingInfo map = MappingStore.TheInstance.GetMappingInfo(obj.ToString());
6 CommandInfo cmdInfo = map.Commands[cmdName];
7
8 using (DbConnection cn = DbConnectionStore.TheInstance.GetConnection(cnHint))
9 ...{
10 DbCommand cmd = DbCommandStore.TheInstance.GetCommand(cnHint, cmdInfo.CommandText);
11 cmd.Connection = cn;
12 _setParamValues(obj, cmd, cmdInfo);
13 cmd.ExecuteNonQuery();
14 _getParamValues(obj, cmd, cmdInfo);
15 }
16 TimeSpan duration = DateTime.Now - start;
17 return duration.ToString();
18 }
接上篇,我们先来看看以上这段代码(ObjectStore.cs文件中的一个方法)
第5、6行,分别根据传入的当前类的实例名obj和命令参数cmdName,从MappingInfo和CommandInfo中获取信息。实际上,在第5行MappingStore.TheInstance这里,就已经得出了MappingInfo和CommandInfo。
2 ...{
3 public static DbConnectionStore TheInstance = new DbConnectionStore();
4
5 private DbConnectionStore()
6 ...{
7 }
8
9 public DbConnection GetConnection(string cnHint)
10 ...{
11 ConnectionStringSettings cnSettings = DbConnectionStore.TheInstance.GetConnectionStringSettings(cnHint);
12 DbProviderFactory providerFactory = DbProviderFactories.GetFactory(cnSettings.ProviderName);
13 DbConnection cn = providerFactory.CreateConnection();
14 cn.ConnectionString = cnSettings.ConnectionString;
15 cn.Open();
16
17 return cn;
18 }
19
20 public ConnectionStringSettings GetConnectionStringSettings(string cnHint)
21 ...{
22 ConnectionStringsSection connectionStringsSection = WebConfigurationManager.GetSection("connectionStrings") as ConnectionStringsSection;
23 ConnectionStringSettingsCollection connectionStrings = connectionStringsSection.ConnectionStrings;
24 ConnectionStringSettings connStringSettings = connectionStrings[cnHint];
25 return connStringSettings;
26 }
27 }
再看看以下config文件部分代码 <add name="myDB" connectionString="Data Source=.;Initial Catalog=Test;Integrated Security=True" providerName="System.Data.SqlClient"/>DbConnectionStore类中的参数cnHint就是其中的myDB。
为什么会这么设计呢?为什么不直接读取数据库连接字符串?
很简单,这样可以实现预先设定多个数据库连接。根据传入的cnHint参数不同获取对应的连接字符串。
·一个就是映射文件的设计,结合了MappingInfo和CommandInfo的设计以及信息提取
·再一个就是DbConnectionStore类和DbCommandStore类的设计。当然,这两个类都可以直接在其他项目中使用,而不需要大的改变。
·对了,原有的Demo中,还有一个MyBuildProvider类,主要是为了读取映射文件用的。对了,差点忘了说,最初的Demo代码中,映射文件的格式是.orm,同时web.config文件中,还有这么一段: <compilation debug="true">
<add extension=".orm" type="Research.MyBuildProvider, CodeGenerator" appliesTo="Code"/>
</buildProviders>
</compilation>提供下载的Demo中,这一段被我注释掉了。
上面的代码,是为了寻找映射文件。标明后缀名是.orm,可以通过Research命名空间下的MyBuildProvider类来加载。
后来不知道为什么,编译的时候,VS2005总是提示“无法识别的属性appliesTo,区分大小写”什么的,可是我查了MSDN上都是这么写的。不知道谁知道怎么解决这个问题,好在我直接修改了映射文件的格式为xml文件,通过对xml文件的读取来实现同样的功能。
1、不要遍历所有的映射文件。如果有很多实体类,全部遍历并加载的话,开销可想而知。
2、分层实现,不用在每个调用的地方传入cnHint——用于识别数据库连接字符串。
3、用Attribute实现。参考别的ORM代码,比如websharp。
4、支持批量操作。
1、对Select操作,预备了SelectAll操作,以及带param U[] key 参数的查询操作,即:一个或多个任意类型的参数查询。每个查询支持的SQL脚本必须在映射文件能找到,否则报错。(下一阶段目标,准备订制生成存储过程的策略,动态修复映射文件和存储过程。)
Select操作支持只读取当前类映射文件。
Default.aspx演示Select操作
Employee.aspx 插入Employee数据;
Person.aspx插入Person数据。
1、建立一整套完整的Demo演示程序。含常规功能,并以一个实例说明。[完成]
2、做成可配置的小框架应用程序,支持依托数据库,生成存储过程和映射文件。[未完成]
3、多表连接的情况。。。[完成]
@生成存储过程的步骤我就省去了,类似的工具网上多的是。本帖子的第二个评论下载文件中,也有一个代码生成工具。而且,每个人对生成的存储过程的风格各不一样,我就不创造文字了...
@马上写一个生成映射文件的小程序,然后提供下载。
@其实说起来,这个程序不能算是ORM,因为SQL并不会自动生成。业务各不一样,很难做到这一点,更优良的ORM工具会有这个功能。
@多表连接的问题,其实没什么区别,做的好一点,弄个视图,然后依据视图生成映射文件和Select查询。
@ColdDog
Sql方面类似ibaties,对每个类有个Xml的配置文件,用来设置这个类所涉及的Sql语句,这样子有个好处是可以人工优化Sql提高效率,特别是在查询时指定索引对效率的提高尤为明显,还有就是这里对查询的缓存也是在这里设置,对设置了要缓存的Sql的查询结果缓存起来,当下一次调用的时候就直接从缓存获取,基本上没有开销,对分页的SQL是把每一个页的查询当作一次单独的查询缓存,每个页都可以缓存.当这次查询所涉及的表被更新(update,insert,delete了的时候,这个缓存项就会作废,但是不会马上去刷新它,当下一次再次被请求的时候才会被重新加载)
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Data.Common;
using System.Configuration;
using System.Data.SqlClient;
using System.Reflection;
namespace DAL
...{
public class Query<T, U> where T : new()
...{
private Type _type;
private T _obj;
private CommandInfo _cmdInfo;
public static Query<T, U> TheInstance = new Query<T,U>();
private Query()
...{}
/**//**//**//// <summary>
/// Select one or many
/// </summary>
/// <param name="cmdName"></param>
/// <param name="key"></param>
/// <returns>返回集合,可能只有一个T</returns>
public IList<T> Select(string cmdName, params U[] key)
...{
string cmdText = this.PrepareCommandText(cmdName, key);//initialize: _type,_obj,_cmdInfo
return this.GetCollection(cmdText);
}
/**//**//**//// <summary>
/// Select All
/// </summary>
/// <param name="cmdName"></param>
/// <returns></returns>
public IList<T> Select(string cmdName)
...{
string cmdText = this.PrepareCommandText(cmdName);//key == null
return this.GetCollection(cmdText);
}
/**//**//**//// <summary>
/// 将DataTable对象dt赋给_obj
/// </summary>
/// <param name="dt"></param>
private IList<T> GetCollection(string cmdText)
...{
DataTable dt = this.FillDataTable(cmdText);
IList<T> objs = new List<T>();
T obj;
for (int i = 0; i < dt.Rows.Count; i++)
...{
obj = new T();
foreach (DataColumn col in dt.Columns)
...{
string objMember = this._cmdInfo.ParamMappings[col.ColumnName];
FieldInfo fld = this._type.GetField(objMember, BindingFlags.NonPublic | BindingFlags.Instance);
PropertyInfo prp = this._type.GetProperty(objMember);
if (fld == null && prp == null)
throw new Exception("Invalid mapping");
object fieldValue = null;
if (dt.Rows[i][col] != DBNull.Value)
fieldValue = dt.Rows[i][col];
if (fld != null)
fld.SetValue(obj, fieldValue);
if (prp != null)
prp.SetValue(obj, fieldValue, null);
}
objs.Add(obj);
}
return objs;
}
/**//**//**//// <summary>
/// 获取CommandText
/// </summary>
/// <param name="cmdName"></param>
/// <param name="key"></param>
/// <returns></returns>
private string PrepareCommandText(string cmdName, params U[] key)
...{
this._type = typeof(T);
this._obj = (T)Activator.CreateInstance(this._type);
string mappingFileName = this._type.Name + ".xml";//namespaces.classname
MappingStore mapStoreInstance = new MappingStore(mappingFileName);
MappingInfo map = mapStoreInstance.GetMappingInfo(this._obj.ToString());
this._cmdInfo = map.Commands[cmdName];//cmdName := "Select" and so on
if (key.Length > 0)
...{
string cmdText = this._cmdInfo.CommandText;
if (this.FormatCommandText(ref cmdText, key))
return cmdText;
else
throw new Exception("Invalid mapping:Parameters's Length or CommandName is error:" + cmdName);//参数长度不匹配
}
else
return this._cmdInfo.CommandText;
}
/**//**//**//// <summary>
/// 格式化CommandText,key长度不定
/// </summary>
/// <param name="cmdText"></param>
/// <param name="key"></param>
private bool FormatCommandText(ref string cmdText, params U[] key)
...{
for (int i = 0; i < key.Length; i++)
...{
string param = "{" + i + "}";
if (!cmdText.Contains(param))
...{
return false;
}
else
...{
U u = key[i];
cmdText = cmdText.Replace(param, u.ToString());
}
}
if (cmdText.Contains("{") && cmdText.Contains("}"))//如果还有没有匹配的参数,则返回错误
return false;
return true;
}
/**//**//**//// <summary>
/// 根据cmdText获取数据集合
/// </summary>
/// <param name="cmdText">Sql语句</param>
/// <returns>返回DataTable对象</returns>
private DataTable FillDataTable(string cmdText)
...{
using (DbConnection cn = DbConnectionStore.TheInstance.GetConnection())
...{
DbCommand cmd = DbCommandStore.TheInstance.PrepareCommand();
cmd.CommandText = cmdText;
cmd.Connection = cn;
DbDataReader rd = cmd.ExecuteReader();
DataTable dt = new DataTable();
dt.Load(rd);
rd.Close();
return dt;
}
}
}
}