C#發現之旅第十二講 基於反射和動態編譯的快速ORM框架（上）(8)

在這個過 程中，GetFIEldIndexs函數提供了一個映射表，而自動生成的代碼就是利用這個映射表將數 據從DataReader復制到DB_Employees的屬性中。

我們自動生成代碼實現了 InnerReadRecord函數後，在ORM框架中就可以調用基礎的RecordORMHelper中的ReadRecord函 數讀取一行數據並生成一個實體對象，而函數ReadRecords是ReadRecord的另外一個讀取多個 數據的版本。

根據上述設計，我們可以使用以下代碼來生成InnerReadRecord代碼

myWriter.WriteLine("//　從數據讀取器讀取數據創建對象");
myWriter.WriteLine("protected　override　object　InnerReadRecord(　 System.Data.IDataReader　reader　,　int[]　FIEldIndexs　)");
myWriter.BeginGroup("{");
myWriter.WriteLine(　RecordType.FullName　+　"　 record　=　new　"　+　RecordType.FullName　+　"();");
myWriter.WriteLine ("int　index　=　0　;");
//　獲得類型中綁定到數據庫的屬性信息
for(　int 　iCount　=　0　;　iCount　<　ps.Length　;　iCount　++　)
{
　　　　 　System.Reflection.PropertyInfo　p　=　ps[　iCount　]　;
　　　　　if(　 p.CanWrite　==　false　)
　　　　　{
　　　　　　　　　continue　;
　　　　　}

　　　　　BindFieldAttribute　fa　=　(　 BindFIEldAttribute　)　Attribute.GetCustomAttribute(
　　　　　　　　　p　, 　typeof(　BindFIEldAttribute　));

　　　　　myWriter.WriteLine ("");
　　　　　myWriter.WriteLine("index　=　FieldIndexs[　"　+　iCount　+ 　"　];　//　讀取字段　"　+　GetBindFIEldName(　p　));
　　　　　 myWriter.WriteLine("if(　index　>=　0　)");
　　　　　 myWriter.BeginGroup("{");
　　　　　Type　pt　=　p.PropertyType　;
　　 　　　object　DefaultValue　=　this.GetDefaultValue(　p　);
　　　　　string 　strRead　=　null;
　　　　　if(　pt.Equals(　typeof(　byte　)))
　　 　　　{
　　　　　　　　　strRead　=　"ConvertToByte(　reader.GetValue(　 index　)　,　"　+　GetValueString(　pt　,　DefaultValue　)　+　")";
　　　　 　}
　　　　　else　if(　pt.Equals(　typeof(　sbyte　)))
　　　　　{
　　　　　　　　　strRead　=　"ConvertToSByte(　reader.GetValue(　index　)　,　 "　+　GetValueString(　pt　,　DefaultValue　)　+　")";
　　　　　}
　　 　　　else　if(　pt.Equals(　typeof(　short　)))
　　　　　{
　　　　　 　　　　strRead　=　"ConvertToInt16(　reader.GetValue(　index　)　,　"　+　 GetValueString(　pt　,　DefaultValue　)　+　")";
　　　　　}
　　　　　 處理其他數據類型……
　　　　　else　if(　pt.Equals(　typeof(　 DateTime　)))
　　　　　{
　　　　　　　　　string　strDefault　= 　"DateTime.MinValue"　;
　　　　　　　　　DateTime　dt　=　 Convert.ToDateTime(　DefaultValue　);
　　　　　　　　　if(　dt.Equals(　 DateTime.MinValue　)　==　false　)
　　　　　　　　　{
　　　　　　　　 　　　　　　strDefault　=　"new　DateTime(　"　+　dt.Ticks　+　")";
　　　　 　　　　　}
　　　　　　　　　strRead　=　"ConvertToDateTime(　 reader.GetValue(　index　)　,　"　+　strDefault　+　"　,　"　+　(　fa.ReadFormat 　==　null　?　"null"　:　"\""　+　fa.ReadFormat　+　"\""　)　+　"　)";
　　 　　　}
　　　　　else　if(　pt.Equals(　typeof(　string　)))
　　　　 　{
　　　　　　　　　strRead　=　"ConvertToString(　reader.GetValue(　index 　)　,　"　+　(　DefaultValue　==　null　?　"null"　:　"@\""　+　 DefaultValue.ToString()　+　"\""　)　+　"　)";
　　　　　}
　　　　　 else　if(　pt.Equals(　typeof(　char　)))
　　　　　{
　　　　　　　　 　strRead　=　"ConvertToChar(　reader.GetValue(　index　)　,　"　+　 GetValueString(　pt　,　DefaultValue　)　+　"　)";
　　　　　}
　　　　 　else
　　　　　{
　　　　　　　　　throw　new　 InvalidOperationException("不支持屬性類型"　+　p.Name　+　"　"　+　pt.FullName 　);
　　　　　}
　　　　　myWriter.WriteLine("record."　+　p.Name　+　 "　=　"　+　strRead　+　"　;"　);
　　　　　myWriter.EndGroup("}");
}//for
myWriter.WriteLine("");
myWriter.WriteLine("return　record 　;");
myWriter.EndGroup(")//InnerReadRecord");