如写的不好请见谅,本人水平有限。 个人简历及水平:。 http://www.cnblogs.com/hackdragon/p/3662599.html 接到一个程序和网页交互的项目,用ADO.NET Entity Framework (以下简称EF)很快就搞完了,但是对方的空间提供的MSSQL数据库比较昂贵,所以就采用AC
个人简历及水平:。 http://www.cnblogs.com/hackdragon/p/3662599.html
接到一个程序和网页交互的项目,用ADO.NET Entity Framework (以下简称EF)很快就搞完了,但是对方的空间提供的MSSQL数据库比较昂贵,所以就采用ACCESS数据库,但是我查了资料发现 EF不支持Access数据库,(以前觉得LINQ TO SQL 不支持 这个应该支持),写完的代码不想用OLEDB在写了,于是网上一顿查,试验了ALINQ和其他很多的,总是不能符合项目的需要。不是更新不行就算插入失败,要不就是经常查询错误。最后没办法,我自己决定写一个实体支持ACCESS数据库,我觉得懒人应该有需要这个的,当然大侠们估计有更好的办法来更懒一些。
因为VS的实体生成器不支持ACCESS数据库,所以无法生成代码,但是想快速开发项目,那么你可以用SQL数据库先来设计,然后导出数据库到ACCESS数据库,这样做的目的是让生成器可以生成我们所需要的代码。注意设计数据库字段的时候要考虑他们的兼容性。
开始写代码了,原始的上下文代码如下:
<span>#region</span> 上下文 <span>///</span> <span><summary></span> <span>///</span><span> 没有元数据文档可用。 </span><span>///</span> <span></summary></span> <span>public</span> <span>partial</span> <span>class</span><span> SqlDoorEntities1 : ObjectContext { </span><span>#region</span> 构造函数 <span>///</span> <span><summary></span> <span>///</span><span> 请使用应用程序配置文件的“SqlDoorEntities1”部分中的连接字符串初始化新 SqlDoorEntities1 对象。 </span><span>///</span> <span></summary></span> <span>public</span> SqlDoorEntities1() : <span>base</span>(<span>"</span><span>name=SqlDoorEntities1</span><span>"</span>, <span>"</span><span>SqlDoorEntities1</span><span>"</span><span>) { OnContextCreated(); } </span><span>///</span> <span><summary></span> <span>///</span><span> 初始化新的 SqlDoorEntities1 对象。 </span><span>///</span> <span></summary></span> <span>public</span> SqlDoorEntities1(<span>string</span> connectionString) : <span>base</span>(connectionString, <span>"</span><span>SqlDoorEntities1</span><span>"</span><span>) { OnContextCreated(); } </span><span>///</span> <span><summary></span> <span>///</span><span> 初始化新的 SqlDoorEntities1 对象。 </span><span>///</span> <span></summary></span> <span>public</span> SqlDoorEntities1(EntityConnection connection) : <span>base</span>(connection, <span>"</span><span>SqlDoorEntities1</span><span>"</span><span>) { OnContextCreated(); } </span><span>#endregion</span> <span>#region</span> 分部方法 <span>partial</span> <span>void</span><span> OnContextCreated(); </span><span>#endregion</span> <span>#region</span> ObjectSet 属性 <span>///</span> <span><summary></span> <span>///</span><span> 没有元数据文档可用。 </span><span>///</span> <span></summary></span> <span>public</span> ObjectSet<CmdMsg><span> CmdMsg { </span><span>get</span><span> { </span><span>if</span> ((_CmdMsg == <span>null</span><span>)) { _CmdMsg </span>= <span>base</span>.CreateObjectSet<CmdMsg>(<span>"</span><span>CmdMsg</span><span>"</span><span>); } </span><span>return</span><span> _CmdMsg; } } </span><span>private</span> ObjectSet<CmdMsg><span> _CmdMsg; </span><span>///</span> <span><summary></span> <span>///</span><span> 没有元数据文档可用。 </span><span>///</span> <span></summary></span> <span>public</span> ObjectSet<Door><span> Door { </span><span>get</span><span> { </span><span>if</span> ((_Door == <span>null</span><span>)) { _Door </span>= <span>base</span>.CreateObjectSet<Door>(<span>"</span><span>Door</span><span>"</span><span>); } </span><span>return</span><span> _Door; } } </span><span>private</span> ObjectSet<Door><span> _Door; </span><span>///</span> <span><summary></span> <span>///</span><span> 没有元数据文档可用。 </span><span>///</span> <span></summary></span> <span>public</span> ObjectSet<Manager><span> Manager { </span><span>get</span><span> { </span><span>if</span> ((_Manager == <span>null</span><span>)) { _Manager </span>= <span>base</span>.CreateObjectSet<Manager>(<span>"</span><span>Manager</span><span>"</span><span>); } </span><span>return</span><span> _Manager; } } </span><span>private</span> ObjectSet<Manager><span> _Manager; </span><span>///</span> <span><summary></span> <span>///</span><span> 没有元数据文档可用。 </span><span>///</span> <span></summary></span> <span>public</span> ObjectSet<Users><span> Users { </span><span>get</span><span> { </span><span>if</span> ((_Users == <span>null</span><span>)) { _Users </span>= <span>base</span>.CreateObjectSet<Users>(<span>"</span><span>Users</span><span>"</span><span>); } </span><span>return</span><span> _Users; } } </span><span>private</span> ObjectSet<Users><span> _Users; </span><span>#endregion</span> <span>#region</span> AddTo 方法 <span>///</span> <span><summary></span> <span>///</span><span> 用于向 CmdMsg EntitySet 添加新对象的方法,已弃用。请考虑改用关联的 ObjectSet<T> 属性的 .Add 方法。 </span><span>///</span> <span></summary></span> <span>public</span> <span>void</span><span> AddToCmdMsg(CmdMsg cmdMsg) { </span><span>base</span>.AddObject(<span>"</span><span>CmdMsg</span><span>"</span><span>, cmdMsg); } </span><span>///</span> <span><summary></span> <span>///</span><span> 用于向 Door EntitySet 添加新对象的方法,已弃用。请考虑改用关联的 ObjectSet<T> 属性的 .Add 方法。 </span><span>///</span> <span></summary></span> <span>public</span> <span>void</span><span> AddToDoor(Door door) { </span><span>base</span>.AddObject(<span>"</span><span>Door</span><span>"</span><span>, door); } </span><span>///</span> <span><summary></span> <span>///</span><span> 用于向 Manager EntitySet 添加新对象的方法,已弃用。请考虑改用关联的 ObjectSet<T> 属性的 .Add 方法。 </span><span>///</span> <span></summary></span> <span>public</span> <span>void</span><span> AddToManager(Manager manager) { </span><span>base</span>.AddObject(<span>"</span><span>Manager</span><span>"</span><span>, manager); } </span><span>///</span> <span><summary></span> <span>///</span><span> 用于向 Users EntitySet 添加新对象的方法,已弃用。请考虑改用关联的 ObjectSet<T> 属性的 .Add 方法。 </span><span>///</span> <span></summary></span> <span>public</span> <span>void</span><span> AddToUsers(Users users) { </span><span>base</span>.AddObject(<span>"</span><span>Users</span><span>"</span><span>, users); } </span><span>#endregion</span><span> } </span><span>#endregion</span>
ObjectContext 继承于IDisposable 那么我写一个自己的 ObjectContext 这样的类 我给他起个名字叫EFToAccess 那么多 构造方法 我们就需要2个一个 是 给定的连接字符串 一个是默认从webconfig中读取的链接字符串就可以了。本人偷懒,直接读取指定的路径了。数据库的简单读写可能都依赖一个where查询,那么怎么实现自己的where查询就很关键,于是我看资料研究了2天Lambda Expression 表达式。最后还是看了 博客园的一篇 扩展LINQ to SQL:使用Lambda Expression批量删除数据才会用,现在也不是很明白,懒人就是拿来主义,不怎么消化,我现在也没多少时间消化知识,估计这样的人也不少吧。下面是我自己用的的方法,利用VS生成的代码 2个替换1个删除搞定 (ObjectContext替换“你自己的类名我的是SqlDoorEntities”,ObjectSet替换成IEnumerable,删除无用的构造函数)
<span>public</span> <span>class</span><span> SqlDoorEntities : EFToAccess { </span><span>public</span><span> SqlDoorEntities()</span>:base("Provider=Microsoft.Jet.OLEDB.4.0;Data Source=" <br>+<em>AppDomain.CurrentDomain.BaseDirectory + "bin\\DataDoor.mdb")</em>
<span> { } </span><span>#region</span> IEnumerable 属性 <span>///</span> <span><summary></span> <span>///</span><span> 没有元数据文档可用。 </span><span>///</span> <span></summary></span> <span>public</span> IEnumerable<CmdMsg><span> CmdMsg { </span><span>get</span><span> { </span><span>if</span> ((_CmdMsg == <span>null</span><span>)) { _CmdMsg </span>= <span>base</span>.CreateObjectSet<CmdMsg>(<span>"</span><span>CmdMsg</span><span>"</span><span>); } </span><span>return</span><span> _CmdMsg; } } </span><span>private</span> IEnumerable<CmdMsg><span> _CmdMsg; </span><span>///</span> <span><summary></span> <span>///</span><span> 没有元数据文档可用。 </span><span>///</span> <span></summary></span> <span>public</span> IEnumerable<Door><span> Door { </span><span>get</span><span> { </span><span>if</span> ((_Door == <span>null</span><span>)) { _Door </span>= <span>base</span>.CreateObjectSet<Door>(<span>"</span><span>Door</span><span>"</span><span>); } </span><span>return</span><span> _Door; } } </span><span>private</span> IEnumerable<Door><span> _Door; </span><span>///</span> <span><summary></span> <span>///</span><span> 没有元数据文档可用。 </span><span>///</span> <span></summary></span> <span>public</span> IEnumerable<Manager><span> Manager { </span><span>get</span><span> { </span><span>if</span> ((_Manager == <span>null</span><span>)) { _Manager </span>= <span>base</span>.CreateObjectSet<Manager>(<span>"</span><span>Manager</span><span>"</span><span>); } </span><span>return</span><span> _Manager; } } </span><span>private</span> IEnumerable<Manager><span> _Manager; </span><span>///</span> <span><summary></span> <span>///</span><span> 没有元数据文档可用。 </span><span>///</span> <span></summary></span> <span>public</span> IEnumerable<Users><span> Users { </span><span>get</span><span> { </span><span>if</span> ((_Users == <span>null</span><span>)) { _Users </span>= <span>base</span>.CreateObjectSet<Users>(<span>"</span><span>Users</span><span>"</span><span>); } </span><span>return</span><span> _Users; } } </span><span>private</span> IEnumerable<Users><span> _Users; </span><span>#endregion</span> <span>#region</span> AddTo 方法 <span>///</span> <span><summary></span> <span>///</span><span> 用于向 CmdMsg EntitySet 添加新对象的方法,已弃用。请考虑改用关联的 IEnumerable<T> 属性的 .Add 方法。 </span><span>///</span> <span></summary></span> <span>public</span> <span>void</span><span> AddToCmdMsg(CmdMsg cmdMsg) { </span><span>base</span>.AddObject(<span>"</span><span>CmdMsg</span><span>"</span><span>, cmdMsg); } </span><span>///</span> <span><summary></span> <span>///</span><span> 用于向 Door EntitySet 添加新对象的方法,已弃用。请考虑改用关联的 IEnumerable<T> 属性的 .Add 方法。 </span><span>///</span> <span></summary></span> <span>public</span> <span>void</span><span> AddToDoor(Door door) { </span><span>base</span>.AddObject(<span>"</span><span>Door</span><span>"</span><span>, door); } </span><span>///</span> <span><summary></span> <span>///</span><span> 用于向 Manager EntitySet 添加新对象的方法,已弃用。请考虑改用关联的 IEnumerable<T> 属性的 .Add 方法。 </span><span>///</span> <span></summary></span> <span>public</span> <span>void</span><span> AddToManager(Manager manager) { </span><span>base</span>.AddObject(<span>"</span><span>Manager</span><span>"</span><span>, manager); } </span><span>///</span> <span><summary></span> <span>///</span><span> 用于向 Users EntitySet 添加新对象的方法,已弃用。请考虑改用关联的 IEnumerable<T> 属性的 .Add 方法。 </span><span>///</span> <span></summary></span> <span>public</span> <span>void</span><span> AddToUsers(Users users) { </span><span>base</span>.AddObject(<span>"</span><span>Users</span><span>"</span><span>, users); } </span><span>#endregion</span><span> }</span>
为了让代码和EF使用方法基本一致,所以不得不做一些工作让我写的类基本满足项目需要。首先实现一个让Lambda Expression 表达式变成字符串的函数
<span>string</span><span> GetWhereString(Expression Func) { ConditionBuilder conditionBuilder </span>= <span>new</span><span> ConditionBuilder(); conditionBuilder.Build(Func); </span><span>for</span> (<span>int</span> i = <span>0</span>; i < conditionBuilder.Arguments.Length; i++<span>) { </span><span>object</span> ce =<span> conditionBuilder.Arguments[i]; </span><span>if</span> (ce == <span>null</span><span>) conditionBuilder.Arguments[i] </span>= <span>"</span><span>null</span><span>"</span><span>; </span><span>else</span> <span>if</span> (ce <span>is</span><span> ValueType) conditionBuilder.Arguments[i] </span>=<span> ce.ToString(); </span><span>else</span> <span>if</span> (ce <span>is</span> <span>string</span> || ce <span>is</span> <span>char</span><span>) conditionBuilder.Arguments[i] </span>= <span>string</span>.Format(<span>"</span><span>'{0}'</span><span>"</span><span>, ce.ToString()); </span><span>else</span> <span>if</span> (ce <span>is</span><span> DateTime) conditionBuilder.Arguments[i] </span>= <span>string</span>.Format(<span>"</span><span>#{0}#</span><span>"</span><span>, ce.ToString()); } </span><span>return</span> <span>string</span><span>.Format(conditionBuilder.Condition, conditionBuilder.Arguments); }</span>
上面的ConditionBuilder类代码我就不贴出了。大家参考我提到的那篇文章,如果实际应用当中,有死循环的地方那么应该在该调用基类的地方加入base.XXX比如base.Visit
实现我们自己的where 这里如果我们自己生成类 那么我们的实体类类可以直接有一个where 方法,但是我为了能让我们懒人使用VS生成的实体类只能这么实现了。为了代码利用率,我们还需要另外2个函数。
取得所有记录
IEnumerable<TEntity> SelectAll<TEntity>() <span>where</span> TEntity : <span>new</span><span>() { TEntity TDefault </span>= <span>new</span><span> TEntity(); </span><span>string</span> entitySetName =<span> TDefault.GetType().Name; </span><span>string</span> strSqlQuery = <span>string</span>.Format(<span>"</span><span>SELECT * FROM {0}</span><span>"</span><span>, entitySetName); m_LastSqlCommand </span>=<span> strSqlQuery; </span><span>return</span> SelectWhere<TEntity><span>(strSqlQuery); }</span>
经常的条件查询
<span>public</span> IEnumerable<TEntity> Where<TEntity>(Expression<Func<TEntity, <span>bool</span>>> Func) <span>where</span> TEntity : <span>new</span><span>() { TEntity TDefault </span>= <span>new</span><span> TEntity(); </span><span>string</span> entitySetName =<span> TDefault.GetType().Name; </span><span>string</span> strWhere = GetWhereString(Func).Replace(<span>"</span><span>Where</span><span>"</span><span>, entitySetName); </span><span>string</span> strSqlQuery = <span>string</span>.Format(<span>"</span><span>SELECT * FROM {0} WHERE {1} </span><span>"</span><span>, entitySetName, strWhere); m_LastSqlCommand </span>=<span> strSqlQuery; </span><span>return</span> SelectWhere<TEntity><span>(strSqlQuery); }</span>
最后的where
IEnumerable<TEntity> SelectWhere<TEntity>(<span>string</span> strSqlQuery) <span>where</span> TEntity : <span>new</span><span>() { TEntity TDefault </span>= <span>new</span><span> TEntity(); </span><span>//</span><span>确认基础类型是否是 EntityObject类型</span> Type TBase =<span> TDefault.GetType(); </span><span>while</span> ((TBase.BaseType) != <span>null</span><span>) { </span><span>if</span> (TBase.Name == <span>"</span><span>EntityObject</span><span>"</span>) <span>break</span><span>; TBase </span>=<span> TBase.BaseType; } </span><span>bool</span> IsPCEH = <span>false</span><span>; </span><span>if</span> (TBase != <span>null</span> && TBase.Name == <span>"</span><span>EntityObject</span><span>"</span>) IsPCEH = <span>true</span><span>; PropertyInfo[] properties </span>= TDefault.GetType().GetProperties(BindingFlags.Public |<span> BindingFlags.Instance); List</span><TEntity> Records = <span>new</span> List<TEntity><span>(); </span><span>string</span> entitySetName =<span> TDefault.GetType().Name; </span><span>try</span><span> { OleDbCommand Cmd </span>= <span>new</span><span> OleDbCommand(strSqlQuery, AccessConn); OleDbDataReader sqlReader </span>=<span> Cmd.ExecuteReader(); </span><span>#region</span> 数据库查询开始 <span>while</span><span> (sqlReader.Read()) { TEntity TValue </span>= <span>new</span><span> TEntity(); </span><span>//</span><span>输入是EntityObject类型,那么加入属性改变事件</span> <span>if</span><span> (IsPCEH) { EntityObject EO </span>= TValue <span>as</span><span> EntityObject; EO.PropertyChanged </span>+=<span> PropertyChangedEH; } </span><span>for</span> (<span>int</span> i = <span>0</span>; i < sqlReader.FieldCount; i++<span>) { </span><span>string</span> strField =<span> sqlReader.GetName(i); </span><span>//</span><span>根据字段名 反射 类的属性</span> PropertyInfo p = properties.Where(P => <span>string</span>.Compare(P.Name, strField, <span>true</span>) == <span>0</span><span>).First(); </span><span>#region</span> 数据转换 <span>switch</span><span> (p.PropertyType.Name.ToString().ToLower()) { </span><span>case</span> <span>"</span><span>int16</span><span>"</span><span>: </span><span>if</span> (!sqlReader.IsDBNull(i)) p.SetValue(TValue, sqlReader.GetInt16(i), <span>null</span><span>); </span><span>break</span><span>; </span><span>case</span> <span>"</span><span>int32</span><span>"</span><span>: </span><span>if</span> (!sqlReader.IsDBNull(i)) p.SetValue(TValue, sqlReader.GetInt32(i), <span>null</span><span>); </span><span>break</span><span>; </span><span>case</span> <span>"</span><span>int64</span><span>"</span><span>: </span><span>if</span> (!sqlReader.IsDBNull(i)) p.SetValue(TValue, sqlReader.GetInt64(i), <span>null</span><span>); </span><span>break</span><span>; </span><span>case</span> <span>"</span><span>string</span><span>"</span><span>: </span><span>if</span> (!sqlReader.IsDBNull(i)) p.SetValue(TValue, sqlReader.GetString(i), <span>null</span><span>); </span><span>break</span><span>; </span><span>case</span> <span>"</span><span>double</span><span>"</span><span>: </span><span>if</span> (!sqlReader.IsDBNull(i)) p.SetValue(TValue, sqlReader.GetDouble(i), <span>null</span><span>); </span><span>break</span><span>; </span><span>case</span> <span>"</span><span>float</span><span>"</span><span>: </span><span>if</span> (!sqlReader.IsDBNull(i)) p.SetValue(TValue, sqlReader.GetFloat(i), <span>null</span><span>); </span><span>break</span><span>; </span><span>case</span> <span>"</span><span>decimal</span><span>"</span><span>: </span><span>if</span> (!sqlReader.IsDBNull(i)) p.SetValue(TValue, sqlReader.GetDecimal(i), <span>null</span><span>); </span><span>break</span><span>; </span><span>case</span> <span>"</span><span>datetime</span><span>"</span><span>: </span><span>if</span> (!sqlReader.IsDBNull(i)) p.SetValue(TValue, sqlReader.GetDateTime(i), <span>null</span><span>); </span><span>break</span><span>; </span><span>default</span><span>: </span><span>if</span> (!sqlReader.IsDBNull(i)) p.SetValue(TValue, sqlReader.GetValue(i), <span>null</span><span>); </span><span>break</span><span>; } </span><span>#endregion</span><span> } Records.Add(TValue); } </span><span>#endregion</span><span> Cmd.Clone(); m_IsDetectionChange </span>= <span>true</span><span>; } </span><span>catch</span><span> (Exception) { </span><span>throw</span><span>; } </span><span>return</span><span> Records; }</span>
属性的改变(也就是数据库记录的字段值)我们要知道才能实现EF的SaveChanges()函数那么我们需要简历一个数组变量,直接上代码
<span>//</span><span>表名 </span><span>//</span><span>主键 </span><span>//</span><span>属性 值1 值2 主键类型名字</span> Dictionary<<span>string</span>, Dictionary<<span>string</span>, Dictionary<<span>string</span>, <span>object</span>[]>>> m_ArrDetection = <span>new</span> Dictionary<<span>string</span>, Dictionary<<span>string</span>, Dictionary<<span>string</span>, <span>object</span>[]>>><span>(); </span>
<span>void</span> PropertyChangedEH(<span>object</span><span> sender, PropertyChangedEventArgs e) { </span><span>//</span><span>没有开启返回</span> <span>if</span> (!m_IsDetectionChange) <span>return</span><span>; </span><span>//</span><span>反射所有属性</span> PropertyInfo[] properties = sender.GetType().GetProperties(BindingFlags.Public |<span> BindingFlags.Instance); </span><span>//</span><span>查询主键</span> PropertyInfo EntityKey =<span> GetEntityKeyFormAllProperty(properties); </span><span>//</span><span>没有主键的返回(表必须要有主键)</span> <span>if</span> (EntityKey == <span>null</span>) <span>return</span><span>; </span><span>//</span><span>表名字</span> <span>string</span> Table =<span> sender.GetType().Name; </span><span>//</span><span>主键值</span> <span>string</span> MainKey = EntityKey.GetValue(sender, <span>null</span><span>).ToString(); </span><span>if</span> (MainKey == <span>null</span> || MainKey == <span>""</span>) <span>return</span><span>; </span><span>//</span><span>没有表 就添加</span> <span>if</span> (!m_ArrDetection.ContainsKey(Table)) m_ArrDetection[Table] = <span>new</span> Dictionary<<span>string</span>, Dictionary<<span>string</span>, <span>object</span>[]>><span>(); </span><span>//</span><span>没有主键 就添加</span> <span>if</span> (!m_ArrDetection[Table].ContainsKey(MainKey)) m_ArrDetection[Table][MainKey] = <span>new</span> Dictionary<<span>string</span>, <span>object</span>[]><span>(); </span><span>//</span><span>主键是不用更新的(一般数据库主键都是自动增长的吧,尤其快速开发的项目)</span> <span>if</span> (e.PropertyName == MainKey) <span>return</span><span>; PropertyInfo p </span>= properties.Where(P => <span>string</span>.Compare(P.Name, e.PropertyName, <span>true</span>) == <span>0</span><span>).First(); </span><span>//</span><span>赋值</span> m_ArrDetection[Table][MainKey][e.PropertyName] = <span>new</span> <span>object</span>[<span>2</span>] { p.GetValue(sender, <span>null</span><span>), EntityKey.Name }; }</span>
查找主键的函数
<span>private</span> <span>bool</span><span> IsEntityKeyProperty(PropertyInfo Info) { </span><span>foreach</span> (Attribute attr <span>in</span><span> Attribute.GetCustomAttributes(Info)) { </span><span>if</span> (attr <span>is</span><span> System.Data.Objects.DataClasses.EdmScalarPropertyAttribute) { System.Data.Objects.DataClasses.EdmScalarPropertyAttribute Key </span>=<span> (System.Data.Objects.DataClasses.EdmScalarPropertyAttribute)attr; </span><span>if</span> (Key.EntityKeyProperty == <span>true</span><span>) { </span><span>return</span> <span>true</span><span>; } } } </span><span>return</span> <span>false</span><span>; } </span><span>private</span><span> PropertyInfo GetEntityKeyFormAllProperty(PropertyInfo[] properties) { </span><span>foreach</span> (PropertyInfo Info <span>in</span><span> properties) { </span><span>if</span> (IsEntityKeyProperty(Info)) <span>return</span><span> Info; } </span><span>return</span> <span>null</span><span>; }</span>
在实际的调用过程中,我们使用基本可以和EF使用一样
<span>public</span><span> ActionResult Index() { </span><span>int</span> UID =<span> GetUerID(); List</span><Door> Arr = <span>new</span> List<Door><span>(); </span><span>try</span><span> { </span><span>//</span><span> TODO: Add insert logic here</span> <span>using</span> (SqlDoorEntities Database = <span>new</span><span> SqlDoorEntities()) { </span><span>//</span><span>EF写法 </span><span>//</span><span>IEnumerable<Door> Records = Database.Door.Where(R => R.U_ID == UID);</span> IEnumerable<Door> Records = Database.Where<Door>(R => R.U_ID ==<span> UID); </span><span>foreach</span> (Door Record <span>in</span><span> Records) Arr.Add(Record); } } </span><span>catch</span><span> (Exception E) { </span><span>return</span><span> Content(E.Message); } </span><span>return</span><span> View(Arr); }</span>
当然你可以直接用EF的方式 ,缺点就是直接把整个表的数据都读取过来了。下面我依次说说 数据库的 增加 删除 修改;
实现CreateObjectSet,懒人嘛,要不还得去修改。
<span>public</span> IEnumerable<TEntity> CreateObjectSet<TEntity>(<span>string</span> entitySetName) <span>where</span> TEntity : <span>new</span><span>() { </span><span>return</span> SelectAll<TEntity><span>(); }</span>
实现AddObject 直接一个简单把对象插入到数组中。实现的时候可以让SaveChanges()在处理
List<<span>object</span>> m_ArrAdd = <span>new</span> List<<span>object</span>><span>(); </span><span>public</span> <span>void</span> AddObject(<span>string</span> strName, <span>object</span><span> o) { m_ArrAdd.Add(o); }</span>
总说SaveChanges()那么先把他贴出来
<span>public</span> <span>int</span><span> SaveChanges() { </span><span>if</span> (m_ArrDel.Count > <span>0</span><span>) { DeleteAll(); m_ArrDel.Clear(); } </span><span>if</span> (m_ArrAdd.Count > <span>0</span><span>) { AddAll(); m_ArrAdd.Clear(); } </span><span>if</span> (m_ArrDetection.Count > <span>0</span><span>) { AutoUpdate(); m_ArrDetection.Clear(); } m_IsDetectionChange </span>= <span>false</span><span>; </span><span>return</span> <span>0</span><span>; }</span>
其实也没什么,就是看看数组中哪个有了需要增删改的 就处理下,接着写添加所有的函数。
<span>int</span><span> AddAll() { </span><span>foreach</span> (<span>object</span> O <span>in</span><span> m_ArrAdd) { AddNew(O); } </span><span>return</span> <span>0</span><span>; }</span>
下面该实现我们的insert into 了 直接使用也是可以的 就不用使用纠结的SaveChanges()了。
<span>public</span> <span>int</span> AddNew<TEntity>(TEntity TDefault) <span>where</span> TEntity : <span>class</span><span> { PropertyInfo[] properties </span>= TDefault.GetType().GetProperties(BindingFlags.Public |<span> BindingFlags.Instance); PropertyInfo EntityKey </span>=<span> GetEntityKeyFormAllProperty(properties); </span><span>if</span> (EntityKey == <span>null</span>) <span>throw</span> <span>new</span> Exception(<span>"</span><span>未设置主键,无法使用本函数请使用其他函数!</span><span>"</span><span>); </span><span>string</span> TabName =<span> TDefault.GetType().Name; </span><span>string</span> EntityValue = <span>""</span><span>; </span><span>string</span> strRows = <span>""</span><span>; </span><span>string</span> strValues = <span>""</span><span>; </span><span>#region</span> Rows Values <span>foreach</span> (PropertyInfo Info <span>in</span><span> properties) { </span><span>object</span> ce = Info.GetValue(TDefault, <span>null</span><span>); </span><span>string</span> strLeft =<span> Info.Name; </span><span>string</span> strRight = <span>""</span><span>; </span><span>if</span> (ce == <span>null</span><span>) </span><span>continue</span><span>; </span><span>else</span> <span>if</span> (ce <span>is</span><span> DateTime) strRight </span>= <span>string</span>.Format(<span>"</span><span>#{0}#</span><span>"</span><span>, ce.ToString()); </span><span>else</span> <span>if</span> (ce <span>is</span><span> ValueType) strRight </span>=<span> ce.ToString(); </span><span>else</span> <span>if</span> (ce <span>is</span><span> ValueType) strRight </span>=<span> ce.ToString(); </span><span>else</span> <span>if</span> (ce <span>is</span> <span>string</span> || ce <span>is</span> <span>char</span><span>) strRight </span>= <span>string</span>.Format(<span>"</span><span>'{0}'</span><span>"</span><span>, ce.ToString()); </span><span>if</span> (strLeft ==<span> EntityKey.Name) { EntityValue </span>=<span> strRight; </span><span>continue</span><span>; } </span><span>if</span> (strRight.Length == <span>0</span>) <span>continue</span><span>; </span><span>if</span> (strLeft == <span>"</span><span>EntityKey</span><span>"</span> || strLeft == <span>"</span><span>EntityState</span><span>"</span>) <span>continue</span><span>; strRows </span>= strRows + strLeft + <span>"</span><span>,</span><span>"</span><span>; strValues </span>= strValues + strRight + <span>"</span><span>,</span><span>"</span><span>; } </span><span>#endregion</span> <span>if</span> (strRows.Length < <span>2</span> || strValues.Length < <span>2</span>) <span>throw</span> <span>new</span> Exception(<span>"</span><span>SQL语句错误</span><span>"</span><span>); strRows </span>= strRows.Remove(strRows.Length - <span>1</span><span>); strValues </span>= strValues.Remove(strValues.Length - <span>1</span><span>); </span><span>string</span> strSqlQuery = <span>string</span>.Format(<span>"</span><span>INSERT INTO {0} ({1}) VALUES ({2})</span><span>"</span><span>, TabName, strRows, strValues); m_LastSqlCommand </span>=<span> strSqlQuery; </span><span>try</span><span> { OleDbCommand Cmd </span>= <span>new</span><span> OleDbCommand(strSqlQuery, AccessConn); Cmd.ExecuteNonQuery(); } </span><span>catch</span><span> (Exception) { </span><span>throw</span><span>; } </span><span>return</span> <span>0</span><span>; }</span>
函数中也没什么,就是注意一下不要生成SQL语句的时候,把主键信息也生成进去,一般情况主键大多是个自动增长的数字吧。还有就是不要把EntityObject的属性的特有主键信息写入到数据库中。根据反射写入数据库。
还是先现实EF的删除方法DeleteObject
<span>public</span> <span>void</span> DeleteObject(<span>object</span><span> TDefault) { PropertyInfo[] properties </span>= TDefault.GetType().GetProperties(BindingFlags.Public |<span> BindingFlags.Instance); PropertyInfo EntityKey </span>=<span> GetEntityKeyFormAllProperty(properties); </span><span>if</span> (EntityKey == <span>null</span>) <span>throw</span> <span>new</span> Exception(<span>"</span><span>未设置主键,无法使用本函数请使用其他函数!</span><span>"</span><span>); </span><span>string</span> EntityValue = EntityKey.GetValue(TDefault, <span>null</span><span>).ToString(); </span><span>if</span> (EntityValue == <span>null</span> || EntityValue == <span>""</span>) <span>throw</span> <span>new</span> Exception(<span>"</span><span>反射取值失败!</span><span>"</span><span>); </span><span>string</span> entitySetName =<span> TDefault.GetType().Name; </span><span>string</span> KeyName =<span> TDefault.GetType().Name; </span><span>if</span> (!m_ArrDel.ContainsKey(KeyName)) m_ArrDel.Add(KeyName,<span>new</span> List<<span>string</span>><span>()); m_ArrDel[KeyName].Add(</span><span>string</span>.Format(<span>"</span><span>(({0})={1})</span><span>"</span><span>, EntityKey.Name, EntityValue)); }</span>
然后我们需要建立我们自己的列表
Dictionary<<span>string</span>, List<<span>string</span>>> m_ArrDel = <span>new</span> Dictionary<<span>string</span>, List<<span>string</span>>>();
实现删除函数
<span>public</span> <span>int</span> Delete<TEntity><span>(TEntity TDefault) { PropertyInfo[] properties </span>= TDefault.GetType().GetProperties(BindingFlags.Public |<span> BindingFlags.Instance); PropertyInfo EntityKey </span>=<span> GetEntityKeyFormAllProperty(properties); </span><span>if</span> (EntityKey == <span>null</span>) <span>throw</span> <span>new</span> Exception(<span>"</span><span>未设置主键,无法使用本函数请使用其他函数!</span><span>"</span><span>); </span><span>string</span> EntityValue = EntityKey.GetValue(TDefault, <span>null</span><span>).ToString(); </span><span>if</span> (EntityValue == <span>null</span> || EntityValue == <span>""</span>) <span>throw</span> <span>new</span> Exception(<span>"</span><span>反射取值失败!</span><span>"</span><span>); </span><span>string</span> entitySetName =<span> TDefault.GetType().Name; </span><span>string</span> strSqlQuery = <span>string</span>.Format(<span>"</span><span>DELETE FROM {0} WHERE {1}={2} </span><span>"</span><span>, entitySetName, EntityKey, EntityValue); m_LastSqlCommand </span>=<span> strSqlQuery; </span><span>try</span><span> { OleDbCommand Cmd </span>= <span>new</span><span> OleDbCommand(strSqlQuery, AccessConn); Cmd.ExecuteNonQuery(); } </span><span>catch</span><span> (Exception) { </span><span>throw</span><span>; } </span><span>return</span> <span>0</span><span>; }</span>
这里是根据主键更新的,没有实现update …where…,因为往往都是查询到记录,然后根据这个记录更新的,所以还需要更多代码的实现Select等,为了这个小的项目进度没有写完。上面代码已经告诉了,可以侦测到查询到的属性的变更所以SaveChanges()保存更改时,我们就直接根据数组进行更改了。
<span>public</span> <span>int</span><span> AutoUpdate() { List</span><<span>string</span>> ArrSqlText = <span>new</span> List<<span>string</span>><span>(); </span><span>foreach</span> (KeyValuePair<<span>string</span>, Dictionary<<span>string</span>, Dictionary<<span>string</span>, <span>object</span>[]>>> TabKVP <span>in</span><span> m_ArrDetection) { </span><span>//</span><span>遍历表名</span> <span>string</span> TabName =<span> TabKVP.Key; </span><span>foreach</span> (KeyValuePair<<span>string</span>, Dictionary<<span>string</span>, <span>object</span>[]>> KeyKVP <span>in</span><span> TabKVP.Value) { </span><span>string</span> strSet = <span>""</span><span>; </span><span>string</span> strMainKeyName = <span>""</span><span>; </span><span>#region</span> 把数据列出来例如: a=1,c="2" <span>foreach</span> (KeyValuePair<<span>string</span>, <span>object</span>[]> ValueKVP <span>in</span><span> KeyKVP.Value) { </span><span>if</span> (strMainKeyName.Length == <span>0</span>) strMainKeyName = ValueKVP.Value[<span>1</span><span>].ToString(); </span><span>object</span> Va = ValueKVP.Value[<span>0</span><span>]; </span><span>string</span> strLeft =<span> ValueKVP.Key; </span><span>string</span> strRight = <span>""</span><span>; </span><span>#region</span> 根据值确认是否添加引号 <span>if</span> (ValueKVP.Value == <span>null</span><span>) </span><span>continue</span><span>; </span><span>else</span> <span>if</span> (Va <span>is</span><span> DateTime) strRight </span>= <span>string</span>.Format(<span>"</span><span>#{0}#</span><span>"</span><span>, Va.ToString()); </span><span>else</span> <span>if</span> (Va <span>is</span><span> ValueType) strRight </span>=<span> Va.ToString(); </span><span>else</span> <span>if</span> (Va <span>is</span> <span>string</span> || Va <span>is</span> <span>char</span><span>) strRight </span>= <span>string</span>.Format(<span>"</span><span>'{0}'</span><span>"</span><span>, Va.ToString()); </span><span>#endregion</span> <span>if</span> (strRight.Length == <span>0</span>) <span>continue</span><span>; </span><span>if</span> (strLeft == <span>"</span><span>EntityKey</span><span>"</span> || strLeft == <span>"</span><span>EntityState</span><span>"</span>) <span>continue</span><span>; strSet </span>+= strLeft + <span>"</span><span>=</span><span>"</span> + strRight + <span>"</span><span>,</span><span>"</span><span>; } </span><span>#endregion</span> <span>if</span> (strSet.Length < <span>2</span>) <span>continue</span><span>; strSet </span>= strSet.Remove(strSet.Length - <span>1</span><span>); </span><span>//</span><span>根据当前的主键[ID] 生成一个SQL语句</span> <span>string</span> strSqlQuery = <span>string</span>.Format(<span>"</span><span>UPDATE {0} SET {1} WHERE {2}={3} </span><span>"</span><span>, TabName, strSet, strMainKeyName, KeyKVP.Key); ArrSqlText.Add(strSqlQuery); } } </span><span>foreach</span> (<span>string</span> strSqlQuery <span>in</span><span> ArrSqlText) { m_LastSqlCommand </span>=<span> strSqlQuery; </span><span>try</span><span> { OleDbCommand Cmd </span>= <span>new</span><span> OleDbCommand(strSqlQuery, AccessConn); Cmd.ExecuteNonQuery(); } </span><span>catch</span><span> { } } </span><span>return</span> <span>0</span><span>; }</span>
当然我们还有直接把对象直接赋值拷贝的时候( a = b),这时候是侦测不到属性的变化的,所以我们要另外一个函数来支持更新,就是让他实现侦测到属性的变化。
<span>public</span> <span>void</span> CopyPropertiesFrom(<span>object</span> destObject, <span>object</span><span> sourceObject) { </span><span>if</span> (destObject.GetType().Name != destObject.GetType().Name) <span>throw</span> <span>new</span> Exception(<span>"</span><span>类型不同</span><span>"</span><span>); PropertyInfo[] destProperties </span>= destObject.GetType().GetProperties(BindingFlags.Public |<span> BindingFlags.Instance); PropertyInfo[] sourceProperties </span>= sourceObject.GetType().GetProperties(BindingFlags.Public |<span> BindingFlags.Instance); PropertyInfo EntityKey </span>=<span> GetEntityKeyFormAllProperty(destProperties); </span><span>if</span> (EntityKey == <span>null</span>) <span>throw</span> <span>new</span> Exception(<span>"</span><span>未设置主键,无法使用本函数请使用其他函数!</span><span>"</span><span>); </span><span>for</span> (<span>int</span> i = <span>0</span>; i < destProperties.Length; i++<span>) { </span><span>if</span> (destProperties[i]==<span>null</span>|| destProperties[i].Name == EntityKey.Name) <span>continue</span><span>; </span><span>if</span> (destProperties[i].Name == <span>"</span><span>EntityKey</span><span>"</span> || destProperties[i].Name == <span>"</span><span>EntityState</span><span>"</span>) <span>continue</span><span>; </span><span>object</span> DstV = destProperties[i].GetValue(destObject,<span>null</span><span>); </span><span>object</span> SrcV = sourceProperties[i].GetValue(sourceObject, <span>null</span><span>); </span><span>if</span> (SrcV == <span>null</span>) <span>continue</span>;<span>//</span><span>源 是NULL 不拷贝</span> <span>if</span> (DstV.ToString() == SrcV.ToString()) <span>continue</span><span>; destProperties[i].SetValue(destObject, SrcV,</span><span>null</span><span>); </span><span>//</span><span>Action<object, object> LmdSetProp = LmdSet(destObject.GetType(), destProperties[i].Name); <span>//</span><span>LmdSetProp(destObject, SrcV);</span> <span> } }</span>
<span>#region</span> 显示用户<span> [Authorize(Roles </span>= <span>"</span><span>manager</span><span>"</span><span>)] </span><span>public</span><span> ActionResult Index() { List</span><Users> Users = <span>new</span> List<Users><span>(); Users u </span>= <span>new</span><span> Users(); </span><span>try</span><span> { </span><span>using</span> (SqlDoorEntities Database = <span>new</span><span> SqlDoorEntities()) { IEnumerable</span><Users> Records =<span> Database.Users; </span><span>if</span> (Records.Count() > <span>0</span><span>) { </span><span>foreach</span> (Users U <span>in</span><span> Records) Users.Add(U); } } } </span><span>catch</span><span> { } </span><span>return</span><span> View(Users); } </span><span>#endregion</span> <span>#region</span> 创建用户<span> [Authorize(Roles </span>= <span>"</span><span>manager</span><span>"</span><span>)] [HttpPost] </span><span>public</span><span> ActionResult CreateUser(Users collection) { </span><span>try</span><span> { </span><span>//</span><span> TODO: Add insert logic here</span> <span>using</span> (SqlDoorEntities Database = <span>new</span><span> SqlDoorEntities()) { IEnumerable</span><Users> Records = Database.Where<Users>(R => R.U_Number ==<span> collection.U_Number); </span><span>if</span> (Records.Count() > <span>0</span><span>) { ModelState.AddModelError(</span><span>""</span>, <span>"</span><span>已經有了記錄了!</span><span>"</span><span>); </span><span>return</span> RedirectToAction(<span>"</span><span>Index</span><span>"</span><span>); } Database.AddToUsers(collection); Database.SaveChanges(); </span><span>//</span><span>collection.U_LastIP = GetWebClientIp();</span> <span> } </span><span>return</span> RedirectToAction(<span>"</span><span>Index</span><span>"</span><span>); } </span><span>catch</span><span> (Exception E) { ModelState.AddModelError(</span><span>""</span>, <span>"</span><span>数据库错误!</span><span>"</span> +<span> E.Message); } </span><span>return</span><span> View(); } [Authorize(Roles </span>= <span>"</span><span>manager</span><span>"</span><span>)] </span><span>public</span><span> ActionResult CreateUser() { </span><span>return</span><span> View(); } </span><span>#endregion</span> <span>#region</span> 编辑用户<span> [Authorize(Roles </span>= <span>"</span><span>manager</span><span>"</span><span>)] [HttpPost] </span><span>public</span> ActionResult EditUser(<span>int</span><span> id, Users collection) { </span><span>try</span><span> { </span><span>//</span><span> TODO: Add insert logic here</span> <span>using</span> (SqlDoorEntities Database = <span>new</span><span> SqlDoorEntities()) { Users Record </span>= Database.Where<Users>(R => R.U_ID ==<span> id).FirstOrDefault(); </span><span>//</span><span>Database.Update<Users>(Record);</span> <span> Database.CopyPropertiesFrom(Record, collection); Database.SaveChanges(); } </span><span>return</span> Content(<span>"</span><span>OK</span><span>"</span><span>); } </span><span>catch</span><span> (Exception E) { </span><span>return</span><span> Content(E.Message); } } </span><span>#endregion</span> <span>#region</span> 删除用户<span> [Authorize(Roles </span>= <span>"</span><span>manager</span><span>"</span><span>)] </span><span>public</span> ActionResult DeleteUser(<span>int</span><span> id) { </span><span>try</span><span> { </span><span>//</span><span> TODO: Add insert logic here</span> <span>using</span> (SqlDoorEntities Database = <span>new</span><span> SqlDoorEntities()) { Users Record </span>= Database.Where<Users>(R => R.U_ID ==<span> id).FirstOrDefault(); </span><span>if</span> (User != <span>null</span><span>) { Database.DeleteObject(Record); Database.SaveChanges(); } } } </span><span>catch</span><span> { } </span><span>return</span> RedirectToAction(<span>"</span><span>Index</span><span>"</span><span>); } </span><span>#endregion</span>
算是写完了,也算是我cnblog的第一篇技术类文章吧。写的不对的地方欢迎指正啊。本人QQ78486367。下面是用到的源文件。
http://files.cnblogs.com/hackdragon/EFToAccess.zip