目錄
为什么呢?
首頁 資料庫 mysql教程 LINQ-to-SQL那点事~利用反射在LINQ-to-SQL环境中实现Ado.net的CU

LINQ-to-SQL那点事~利用反射在LINQ-to-SQL环境中实现Ado.net的CU

Jun 07, 2016 pm 03:14 PM
使用 反射 實現 環境

回到目录 对于linq to sql提供的CURD 操作 ,给我们的感觉就是简单,容易使用,更加面向对象,不用拼SQL语句了,这些好处都表示在处理单条实体或者集合长度小的情况下,如果有一个1000条的集合实体,希望进行update 操作 ,如果你还用linq to sql提代的updat

回到目录

对于linq to sql提供的CURD操作,给我们的感觉就是简单,容易使用,更加面向对象,不用拼SQL语句了,这些好处都表示在处理单条实体或者集合长度小的情况下,如果有一个1000条的集合实体,希望进行update操作,如果你还用linq to sql提代的update,那你服务器就快要挂了,呵呵。

为什么呢?

对于LINQ提借的命令,如update(list),它会把list进行foreache的遍历,然后一条一条指令的向SQLSERVER发送,好家伙,这要是1000,1W条实体的集合,进行update操作,这个对IO的开销和服务器的性能来说都是没法接受的,呵呵,应该是一个SQL链接,一个指令,就能解决问题呀!

自己封套性能更好的CURD集合操作(选自我的entity framework架构,linq to sql没来的及实现

     <span>///</span> <span><summary></summary></span>
        <span>///</span><span> SQL<strong>操作</strong>类型
        </span><span>///</span> <span></span>
        <span>protected</span> <span>enum</span><span> SQLType
        {
            Insert,
            Update,
            Delete,
        }

        </span><span>///</span> <span><summary></summary></span>
        <span>///</span><span> 构建Update语句串
        </span><span>///</span> <span></span>
        <span>///</span> <span><typeparam name="TEntity"></typeparam></span>
        <span>///</span> <span><param name="entity"></span>
        <span>///</span> <span><returns></returns></span>
        <span>private</span> Tuplestring, <span>object</span>[]> CreateUpdateSQL<tentity>(TEntity entity) <span>where</span> TEntity : <span>class</span><span>
        {
            </span><span>if</span> (entity == <span>null</span><span>)
                </span><span>throw</span> <span>new</span> ArgumentException(<span>"</span><span>The database entity can not be null.</span><span>"</span><span>);
            List</span>string> pkList = GetPrimaryKey<tentity>().Select(i =><span> i.Name).ToList();

            Type entityType </span>=<span> entity.GetType();
            </span><span>var</span> table = entityType.GetProperties().Where(i =>
                !<span>pkList.Contains(i.Name)
                </span>&& i.GetValue(entity, <span>null</span>) != <span>null</span>
                && i.PropertyType != <span>typeof</span><span>(EntityState)
                </span>&& !(i.GetCustomAttributes(<span>false</span>).Length > <span>0</span>
                && i.GetCustomAttributes(<span>false</span>).Where(j => j.GetType() == <span>typeof</span>(NavigationAttribute)) != <span>null</span><span>)
                </span>&& (i.PropertyType.IsValueType || i.PropertyType == <span>typeof</span>(<span>string</span>)) <span>//</span><span>过滤导航属性</span>
<span>                 ).ToArray();

            </span><span>//</span><span>过滤主键,航行属性,状态属性等</span>
            <span>if</span> (pkList == <span>null</span> || pkList.Count == <span>0</span><span>)
                </span><span>throw</span> <span>new</span> ArgumentException(<span>"</span><span>The Table entity have not a primary key.</span><span>"</span><span>);
            List</span>object> arguments = <span>new</span> Listobject><span>();
            StringBuilder builder </span>= <span>new</span><span> StringBuilder();

            </span><span>foreach</span> (<span>var</span> change <span>in</span><span> table)
            {
                </span><span>if</span><span> (pkList.Contains(change.Name))
                    </span><span>continue</span><span>;
                </span><span>if</span> (arguments.Count != <span>0</span><span>)
                    builder.Append(</span><span>"</span><span>, </span><span>"</span><span>);
                builder.Append(change.Name </span>+ <span>"</span><span> = {</span><span>"</span> + arguments.Count + <span>"</span><span>}</span><span>"</span><span>);
                </span><span>if</span> (change.PropertyType == <span>typeof</span>(<span>string</span>) || change.PropertyType == <span>typeof</span><span>(DateTime))
                    arguments.Add(</span><span>"</span><span>'</span><span>"</span> + change.GetValue(entity, <span>null</span>).ToString().Replace(<span>"</span><span>'</span><span>"</span>, <span>"</span><span>char(39)</span><span>"</span>) + <span>"</span><span>'</span><span>"</span><span>);
                </span><span>else</span><span>
                    arguments.Add(change.GetValue(entity, </span><span>null</span><span>));
            }

            </span><span>if</span> (builder.Length == <span>0</span><span>)
                </span><span>throw</span> <span>new</span> Exception(<span>"</span><span>没有任何属性进行更新</span><span>"</span><span>);

            builder.Insert(</span><span>0</span>, <span>"</span><span> UPDATE </span><span>"</span> + <span>string</span>.Format(<span>"</span><span>[{0}]</span><span>"</span>, entityType.Name) + <span>"</span><span> SET </span><span>"</span><span>);

            builder.Append(</span><span>"</span><span> WHERE </span><span>"</span><span>);
            </span><span>bool</span> firstPrimaryKey = <span>true</span><span>;

            </span><span>foreach</span> (<span>var</span> primaryField <span>in</span><span> pkList)
            {
                </span><span>if</span><span> (firstPrimaryKey)
                    firstPrimaryKey </span>= <span>false</span><span>;
                </span><span>else</span><span>
                    builder.Append(</span><span>"</span><span> AND </span><span>"</span><span>);

                </span><span>object</span> val = entityType.GetProperty(primaryField).GetValue(entity, <span>null</span><span>);
                builder.Append(GetEqualStatment(primaryField, arguments.Count));
                arguments.Add(val);
            }
            </span><span>return</span> <span>new</span> Tuplestring, <span>object</span>[]><span>(builder.ToString(), arguments.ToArray());

        }

        </span><span>///</span> <span><summary></summary></span>
        <span>///</span><span> 构建Delete语句串
        </span><span>///</span> <span></span>
        <span>///</span> <span><typeparam name="TEntity"></typeparam></span>
        <span>///</span> <span><param name="entity"></span>
        <span>///</span> <span><returns></returns></span>
        <span>private</span> Tuplestring, <span>object</span>[]> CreateDeleteSQL<tentity>(TEntity entity) <span>where</span> TEntity : <span>class</span><span>
        {
            </span><span>if</span> (entity == <span>null</span><span>)
                </span><span>throw</span> <span>new</span> ArgumentException(<span>"</span><span>The database entity can not be null.</span><span>"</span><span>);

            Type entityType </span>=<span> entity.GetType();
            List</span>string> pkList = GetPrimaryKey<tentity>().Select(i =><span> i.Name).ToList();
            </span><span>if</span> (pkList == <span>null</span> || pkList.Count == <span>0</span><span>)
                </span><span>throw</span> <span>new</span> ArgumentException(<span>"</span><span>The Table entity have not a primary key.</span><span>"</span><span>);

            List</span>object> arguments = <span>new</span> Listobject><span>();
            StringBuilder builder </span>= <span>new</span><span> StringBuilder();
            builder.Append(</span><span>"</span><span> Delete from </span><span>"</span> + <span>string</span>.Format(<span>"</span><span>[{0}]</span><span>"</span><span>, entityType.Name));

            builder.Append(</span><span>"</span><span> WHERE </span><span>"</span><span>);
            </span><span>bool</span> firstPrimaryKey = <span>true</span><span>;

            </span><span>foreach</span> (<span>var</span> primaryField <span>in</span><span> pkList)
            {
                </span><span>if</span><span> (firstPrimaryKey)
                    firstPrimaryKey </span>= <span>false</span><span>;
                </span><span>else</span><span>
                    builder.Append(</span><span>"</span><span> AND </span><span>"</span><span>);

                </span><span>object</span> val = entityType.GetProperty(primaryField).GetValue(entity, <span>null</span><span>);
                builder.Append(GetEqualStatment(primaryField, arguments.Count));
                arguments.Add(val);
            }
            </span><span>return</span> <span>new</span> Tuplestring, <span>object</span>[]><span>(builder.ToString(), arguments.ToArray());
        }

        </span><span>///</span> <span><summary></summary></span>
        <span>///</span><span> 构建Insert语句串
        </span><span>///</span><span> 主键为自增时,如果主键值为0,我们将主键插入到SQL串中
        </span><span>///</span> <span></span>
        <span>///</span> <span><typeparam name="TEntity"></typeparam></span>
        <span>///</span> <span><param name="entity"></span>
        <span>///</span> <span><returns></returns></span>
        <span>private</span> Tuplestring, <span>object</span>[]> CreateInsertSQL<tentity>(TEntity entity) <span>where</span> TEntity : <span>class</span><span>
        {
            </span><span>if</span> (entity == <span>null</span><span>)
                </span><span>throw</span> <span>new</span> ArgumentException(<span>"</span><span>The database entity can not be null.</span><span>"</span><span>);

            Type entityType </span>=<span> entity.GetType();
            </span><span>var</span> table = entityType.GetProperties().Where(i => i.PropertyType != <span>typeof</span><span>(EntityKey)
                 </span>&& i.PropertyType != <span>typeof</span><span>(EntityState)
                 </span>&& i.Name != <span>"</span><span>IsValid</span><span>"</span>
                 && i.GetValue(entity, <span>null</span>) != <span>null</span>
                 && !(i.GetCustomAttributes(<span>false</span>).Length > <span>0</span>
                 && i.GetCustomAttributes(<span>false</span>).Where(j => j.GetType() == <span>typeof</span>(NavigationAttribute)) != <span>null</span><span>)
                 </span>&& (i.PropertyType.IsValueType || i.PropertyType == <span>typeof</span>(<span>string</span>))).ToArray();<span>//</span><span>过滤主键,航行属性,状态属性等</span>
<span>
            List</span>string> pkList = GetPrimaryKey<tentity>().Select(i =><span> i.Name).ToList();
            List</span>object> arguments = <span>new</span> Listobject><span>();
            StringBuilder fieldbuilder </span>= <span>new</span><span> StringBuilder();
            StringBuilder valuebuilder </span>= <span>new</span><span> StringBuilder();

            fieldbuilder.Append(</span><span>"</span><span> INSERT INTO </span><span>"</span> + <span>string</span>.Format(<span>"</span><span>[{0}]</span><span>"</span>, entityType.Name) + <span>"</span><span> (</span><span>"</span><span>);

            </span><span>foreach</span> (<span>var</span> member <span>in</span><span> table)
            {
                </span><span>if</span> (pkList.Contains(member.Name) && Convert.ToString(member.GetValue(entity, <span>null</span>)) == <span>"</span><span>0</span><span>"</span><span>)
                    </span><span>continue</span><span>;
                </span><span>object</span> value = member.GetValue(entity, <span>null</span><span>);
                </span><span>if</span> (value != <span>null</span><span>)
                {
                    </span><span>if</span> (arguments.Count != <span>0</span><span>)
                    {
                        fieldbuilder.Append(</span><span>"</span><span>, </span><span>"</span><span>);
                        valuebuilder.Append(</span><span>"</span><span>, </span><span>"</span><span>);
                    }

                    fieldbuilder.Append(member.Name);
                    </span><span>if</span> (member.PropertyType == <span>typeof</span>(<span>string</span>) || member.PropertyType == <span>typeof</span><span>(DateTime))
                        valuebuilder.Append(</span><span>"</span><span>'{</span><span>"</span> + arguments.Count + <span>"</span><span>}'</span><span>"</span><span>);
                    </span><span>else</span><span>
                        valuebuilder.Append(</span><span>"</span><span>{</span><span>"</span> + arguments.Count + <span>"</span><span>}</span><span>"</span><span>);
                    </span><span>if</span> (value.GetType() == <span>typeof</span>(<span>string</span><span>))
                        value </span>= value.ToString().Replace(<span>"</span><span>'</span><span>"</span>, <span>"</span><span>char(39)</span><span>"</span><span>);
                    arguments.Add(value);

                }
            }


            fieldbuilder.Append(</span><span>"</span><span>) Values (</span><span>"</span><span>);

            fieldbuilder.Append(valuebuilder.ToString());
            fieldbuilder.Append(</span><span>"</span><span>);</span><span>"</span><span>);
            </span><span>return</span> <span>new</span> Tuplestring, <span>object</span>[]><span>(fieldbuilder.ToString(), arguments.ToArray());
        }
    
        </span><span>///</span> <span><summary></summary></span>
        <span>///</span><span> 执行SQL,根据SQL<strong>操作</strong>的类型
        </span><span>///</span> <span></span>
        <span>///</span> <span><typeparam name="TEntity"></typeparam></span>
        <span>///</span> <span><param name="list"></span>
        <span>///</span> <span><param name="sqlType"></span>
        <span>///</span> <span><returns></returns></span>
        <span>protected</span> <span>string</span> DoSQL<tentity>(IEnumerable<tentity> list, SQLType sqlType) <span>where</span> TEntity : <span>class</span><span>
        {
            StringBuilder sqlstr </span>= <span>new</span><span> StringBuilder();
            </span><span>switch</span><span> (sqlType)
            {
                </span><span>case</span><span> SQLType.Insert:
                    list.ToList().ForEach(i </span>=><span>
                    {
                        Tuple</span>string, <span>object</span>[]> sql =<span> CreateInsertSQL(i);
                        sqlstr.AppendFormat(sql.Item1, sql.Item2);
                    });
                    </span><span>break</span><span>;
                </span><span>case</span><span> SQLType.Update:
                    list.ToList().ForEach(i </span>=><span>
                    {
                        Tuple</span>string, <span>object</span>[]> sql =<span> CreateUpdateSQL(i);
                        sqlstr.AppendFormat(sql.Item1, sql.Item2);
                    });
                    </span><span>break</span><span>;
                </span><span>case</span><span> SQLType.Delete:
                    list.ToList().ForEach(i </span>=><span>
                    {
                        Tuple</span>string, <span>object</span>[]> sql =<span> CreateDeleteSQL(i);
                        sqlstr.AppendFormat(sql.Item1, sql.Item2);
                    });
                    </span><span>break</span><span>;
                </span><span>default</span><span>:
                    </span><span>throw</span> <span>new</span> ArgumentException(<span>"</span><span>请输入正确的参数</span><span>"</span><span>);
            }
            </span><span>return</span><span> sqlstr.ToString();
        }</span></tentity></tentity></tentity></tentity></tentity></tentity></tentity></tentity>
登入後複製

 

前方永远都是通往成功的路,只要你相信,它就会更快的实现...

回到目录

本網站聲明
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn

熱AI工具

Undresser.AI Undress

Undresser.AI Undress

人工智慧驅動的應用程序,用於創建逼真的裸體照片

AI Clothes Remover

AI Clothes Remover

用於從照片中去除衣服的線上人工智慧工具。

Undress AI Tool

Undress AI Tool

免費脫衣圖片

Clothoff.io

Clothoff.io

AI脫衣器

Video Face Swap

Video Face Swap

使用我們完全免費的人工智慧換臉工具,輕鬆在任何影片中換臉!

熱工具

記事本++7.3.1

記事本++7.3.1

好用且免費的程式碼編輯器

SublimeText3漢化版

SublimeText3漢化版

中文版,非常好用

禪工作室 13.0.1

禪工作室 13.0.1

強大的PHP整合開發環境

Dreamweaver CS6

Dreamweaver CS6

視覺化網頁開發工具

SublimeText3 Mac版

SublimeText3 Mac版

神級程式碼編輯軟體(SublimeText3)

Java 中介面和抽象類別的反射機制實現 Java 中介面和抽象類別的反射機制實現 May 02, 2024 pm 05:18 PM

反射機制允許程式在執行時間取得和修改類別訊息,它可用於實作介面和抽象類別的反射:介面的反射:透過Class.forName()取得介面反射對象,存取其元資料(名稱、方法和欄位) 。抽象類別的反射:與介面類似,可取得抽象類別的反射對象,存取其元資料以及非抽象方法。實戰案例:反射機制可用於實作動態代理,透過動態建立代理類別在執行時攔截對介面方法的呼叫。

華為手機如何實現雙微信登入? 華為手機如何實現雙微信登入? Mar 24, 2024 am 11:27 AM

華為手機如何實現雙微信登入?隨著社群媒體的興起,微信已成為人們日常生活中不可或缺的溝通工具之一。然而,許多人可能會遇到一個問題:在同一部手機上同時登入多個微信帳號。對於華為手機用戶來說,實現雙微信登入並不困難,本文將介紹華為手機如何實現雙微信登入的方法。首先,華為手機自帶的EMUI系統提供了一個很方便的功能-應用程式雙開。透過應用程式雙開功能,用戶可以在手機上同

golang 如何使用反射存取私有欄位和方法 golang 如何使用反射存取私有欄位和方法 May 03, 2024 pm 12:15 PM

Go語言中可以使用反射來存取私有欄位和方法:存取私有欄位:透過reflect.ValueOf()取得值的反射值,再使用FieldByName()取得欄位的反射值,並呼叫String()方法列印欄位的值。呼叫私有方法:同樣透過reflect.ValueOf()取得值的反射值,再使用MethodByName()取得方法的反射值,最後呼叫Call()方法執行方法。實戰案例:透過反射修改私有欄位值和呼叫私有方法,實現物件的控制和單元測試覆寫。

PHP程式設計指南:實作斐波那契數列的方法 PHP程式設計指南:實作斐波那契數列的方法 Mar 20, 2024 pm 04:54 PM

程式語言PHP是一種用於Web開發的強大工具,能夠支援多種不同的程式設計邏輯和演算法。其中,實作斐波那契數列是一個常見且經典的程式設計問題。在這篇文章中,將介紹如何使用PHP程式語言來實作斐波那契數列的方法,並附上具體的程式碼範例。斐波那契數列是一個數學上的序列,其定義如下:數列的第一個和第二個元素為1,從第三個元素開始,每個元素的值等於前兩個元素的和。數列的前幾元

如何在華為手機上實現微信分身功能 如何在華為手機上實現微信分身功能 Mar 24, 2024 pm 06:03 PM

如何在華為手機上實現微信分身功能隨著社群軟體的普及和人們對隱私安全的日益重視,微信分身功能逐漸成為人們關注的焦點。微信分身功能可以幫助使用者在同一台手機上同時登入多個微信帳號,方便管理和使用。在華為手機上實現微信分身功能並不困難,只需要按照以下步驟操作即可。第一步:確保手機系統版本和微信版本符合要求首先,確保你的華為手機系統版本已更新至最新版本,以及微信App

掌握Golang如何實現遊戲開發的可能性 掌握Golang如何實現遊戲開發的可能性 Mar 16, 2024 pm 12:57 PM

在現今的軟體開發領域中,Golang(Go語言)作為一種高效、簡潔、並發性強的程式語言,越來越受到開發者的青睞。其豐富的標準庫和高效的並發特性使它成為遊戲開發領域的一個備受關注的選擇。本文將探討如何利用Golang來實現遊戲開發,並透過具體的程式碼範例來展示其強大的可能性。 1.Golang在遊戲開發中的優勢作為靜態類型語言,Golang正在建構大型遊戲系統

PHP遊戲需求實作指南 PHP遊戲需求實作指南 Mar 11, 2024 am 08:45 AM

PHP遊戲需求實現指南隨著網路的普及和發展,網頁遊戲的市場也越來越火爆。許多開發者希望利用PHP語言來開發自己的網頁遊戲,而實現遊戲需求是其中一個關鍵步驟。本文將介紹如何利用PHP語言來實現常見的遊戲需求,並提供具體的程式碼範例。 1.創造遊戲角色在網頁遊戲中,遊戲角色是非常重要的元素。我們需要定義遊戲角色的屬性,例如姓名、等級、經驗值等,並提供方法來操作這些

golang 反射的安全性考量和最佳方案 golang 反射的安全性考量和最佳方案 May 04, 2024 pm 04:48 PM

反射在Go中提供類型檢查和修改功能,但存在安全隱患,包括任意程式碼執行、類型偽造和資料外洩。最佳方案包括限制反射權限、操作、使用白名單或黑名單、驗證輸入以及使用安全工具。實務中,反射可安全用於檢查類型資訊。

See all articles