摘要:暂停了五天,终于开始第三篇文章的写作,本文将有更多个人补充和实例实用。数据库仍然和上一版本的一致,存储过程有修改,为了能准确运行Demo,建议重新运行SQL脚本。
先提几点:
1、对Select操作,预备了SelectAll操作,以及带param U[] key 参数的查询操作,即:一个或多个任意类型的参数查询。每个查询支持的SQL脚本必须在映射文件能找到,否则报错。(下一阶段目标,准备订制生成存储过程的策略,动态修复映射文件和存储过程。)
2、对其他操作(Insert、Update、Delete)等,只支持存储过程,不支持把SQL脚本直接写在映射文件中。因为程序用到了SqlCommandBuilder的DeriveParameters(SqlCommand cmd)方法(该方法的意思是从cmd指定的存储过程中检索参数,并把参数填充到cmd对象的Parameters集合中,这里涉及到参数的类型,所以当我尝试从单纯的sql语句中提取参数并填充到SqlCommand对象cmd中时,我失败了。)
3、增加了批处理Insert、Update、Delete操作。
4、当第一次请求时,仍然遍历并读取所有映射文件信息。不过可以把映射文件信息缓存,第二次以后请求就可以提速。
Select操作支持只读取当前类映射文件。
5、在BLL层引入
ObjectStore类,封装了所有
Insert、Update、Delete操作,其他业务对象类(如Demo中BLL层的Person和Employee类)继承此类,可重写或不重写父类方法,进行相关操作。对Select操作,请见6。
6、在DAL层引入了
Query类,封装了所有
Select操作。BLL层的业务对象类(如Demo中BLL层的Person和Employee类)直接访问DAL的Query方法。具体请见第1点。
使用说明:
Default.aspx演示Select操作
Employee.aspx 插入Employee数据;
Person.aspx插入Person数据。
下一阶段的工作:1、建立一整套完整的Demo演示程序。含常规功能,并以一个实例说明。[完成]2、做成可配置的小框架应用程序,支持依托数据库,生成存储过程和映射文件。[未完成]3、多表连接的情况。。。[完成]
2月1号补充:@生成存储过程的步骤我就省去了,类似的工具网上多的是。本帖子的第二个评论下载文件中,也有一个代码生成工具。而且,每个人对生成的存储过程的风格各不一样,我就不创造文字了...@马上写一个生成映射文件的小程序,然后提供下载。@其实说起来,这个程序不能算是ORM,因为SQL并不会自动生成。业务各不一样,很难做到这一点,更优良的ORM工具会有这个功能。@多表连接的问题,其实没什么区别,做的好一点,弄个视图,然后依据视图生成映射文件和Select查询。
以下是给我的建议,我采纳了,希望能实现:)
2007-02-01 08:22 by
亚历山大同志
2007-02-01 08:22 by 亚历山大同志
@ColdDog
Sql方面类似ibaties,对每个类有个Xml的配置文件,用来设置这个类所涉及的Sql语句,这样子有个好处是可以人工优化Sql提高效率,特别是在查询时指定索引对效率的提高尤为明显,还有就是这里对查询的缓存也是在这里设置,对设置了要缓存的Sql的查询结果缓存起来,当下一次调用的时候就直接从缓存获取,基本上没有开销,对分页的SQL是把每一个页的查询当作一次单独的查询缓存,每个页都可以缓存.当这次查询所涉及的表被更新(update,insert,delete了的时候,这个缓存项就会作废,但是不会马上去刷新它,当下一次再次被请求的时候才会被重新加载)
下面简单说明一下DAL中的Query类:
using
System;
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; } } }}