|
Linq To Sql(以下简称LS)从一降世似乎就是个问题宝宝。批更新问题, Like问题，RTM之前的"BUG"(select new不能显式创建实体)等等接踵而至，很多时候我们不得不回到SqlCommand去来"扩展"LS，不巧的是，LS留给程序员的灵活性很有限，我们的Extension总是有不尽完美的地方，在自我扩展的同时我更多的是期待Entity Framework正式Release时候能解决这些问题，至少是能够带给我们更多的灵活性。今天我要说的是LS中的继承问题，先看实体关系： 
图中已经去掉了多余的字段，仅仅留下关键字段，简要说明一下：Order实体和Supplier实体对应数据库中的表,而OrderInfo实体很明显是连接了两个实体的“视图”。这样的应用场景很常见，我可能需要OrderInfo去填充一个Grid，而又需要在OrderInfo被修改之后提交回数据库, 很显然OrderInfo必须是一个实际类型而非匿名类型。有人会问为什么不用视图去生成OrderInfo实体，原因很简单，视图是无法提交修改的，为了让能够OrderInfo直接提交回数据库更好的做法是让他继承于Order,于是乎，很自然的想到OrderInfo的代码是这样: 以下是引用片段：
[Table(Name="dbo.Order")]
publicclassOrderInfo:Order
{
privatestring_SupplierName;
publicOrderInfo()
{
}
publicstringSupplierName
{
get
{
returnthis._SupplierName;
}
set
{
if((this._SupplierName!=value))
{
this._SupplierName=value;
}
}
}
} |
那么查询可以是这样的: 以下是引用片段：
using(DataClasses1DataContextcontext=newDataClasses1DataContext())
{
OrderInfo[]infos=fromoincontext.Orders
joinsincontext.Suppliersono.SupplierIdequalss.SupplierId
selectnewOrderInfo
{
OrderId=o.OrderId,
SupplierId=o.SupplierId,
SupplierName=s.SupplierName
};
returninfos;
} |
不好意思，RTM之后这个语句运行时候会出错，具体的可以参看JeffreyZhao的文章，里面给了一个扩展可以绕过这先限制，但是遗憾的是在这个问题上那个扩展一样失败，原因是OrderInfo从基类(Order)继承下来的属性不属于OrderInfo的映射，我很自然的想到用LS继承方式,那么代码可以这样: 以下是引用片段：
[System.Data.Linq.Mapping.InheritanceMapping(Code="Order",Type=typeof(Order),IsDefault=true)]
[System.Data.Linq.Mapping.InheritanceMapping(Code="OrderInfo",Type=typeof(OrderInfo))]
publicpartialclassOrder
{
[Column(IsDiscriminator=true,IsDbGenerated=true,AutoSync=AutoSync.Never)]
publicstringType{get;set;}
} |
同时去掉OrderInfo类上的TableAttribute，注意，上面的Order类代码是放在LS设计器生成的代码之外的运用了局部类特性，不好意思这样的代码过不去，LS的继承方式必须要有个叫做鉴别器列的东西，那么我们还要向Order类添加一个属性：  以下是引用片段：
[Column(IsDiscriminator=true)]
publicstringType{get;set;} |
很显然，这样的属性必定导致我们提交数据失败，因为数据库中根本没有这个列，那么我们在做一点手脚： 以下是引用片段：
[Column(IsDiscriminator=true,IsDbGenerated=true,AutoSync=AutoSync.Never)]
publicstringType{get;set;} |
似乎很阴险，骗过LS，让他认为Type列示个自动生成列，这样提交时候就不会向这个列插入数据了，同时把AutoSync属性置为AutoSync.Never，这样做是因为LS在做插入或者更新操作时候会把这个列的值同步到实体，算是LS应对并发的一点自动化操作吧，如果他同步属性值那同样会由于数据库中没这个列而失败，因此我们禁止这样的同步。 好了，现在我们再用JeffreyZhao的那个扩展去查询，在这里借花献佛了(很感谢老赵提供了这个扩展)，展示一个那个扩展是怎么用的: 以下是引用片段：
using(DataClasses1DataContextcontext=newDataClasses1DataContext())
{
IQueryableinfos=fromoincontext.Orders
joinsincontext.Suppliersono.SupplierIdequalss.SupplierId
selectnew
{
OrderId=o.OrderId,
SupplierId=o.SupplierId,
SupplierName=s.SupplierName
};
returncontext.ExecuteQuery(infos);
} |
非常抱歉，这个扩展还是失败了，原因是鉴别器列并没有在查询结果中，因此使用了默认类型Order来做Translate(默认类型设置在[System.Data.Linq.Mapping.InheritanceMapping(Code = "Order", Type = typeof(Order), IsDefault = true)])，最后导致了无法将Order强制转换为OrderInfo的异常。如何应对?两个方法：方法一，把Type = typeof(OrderInfo)那个InheritanceMapping特性设为IsDefault = true, 这样其实治标不治本，当你有第二个类继承于Order时候怎么办?方法二，想办法在查询结果中包含鉴别器列的值，很自然的想到查询代码select时候: 以下是引用片段：
selectnew
{
OrderId=o.OrderId,
SupplierId=o.SupplierId,
SupplierName=s.SupplierName,
Type="OrderInfo"
}; |
不好意思，非常不好意思，我们追踪这个代码获得的Sql是这样的： 以下是引用片段：
SELECT[t0].[OrderId],[t0].[SupplierId],[t1].[SupplierName]
FROM[Order]AS[t0]
INNERJOIN[Supplier]AS[t1]ON[t0].[SupplierId]=[t1].[SupplierId] |
也就是说，查询结果中还是没有Type列，可以看出LS在处理常量时候是在创建对象时候赋值的，而不是在SQL端查询，在没有更好的做法时候我只能回到SqlCommand去处理这个强行查询这个常量个，我们的目标是让SQL变成这个样子:以下是引用片段：
SELECT[t0].[OrderId],[t0].[SupplierId],[t1].[SupplierName],'OrderInfo'AS[Type]
FROM[Order]AS[t0]
INNERJOIN[Supplier]AS[t1]ON[t0].[SupplierId]=[t1].[SupplierId] |
我看过JeffreyZhao的那个扩展，他提供一个开关了控制查询锁，我们对其进一步扩展，也提供一个开关来控制是否生成鉴别器列，在做这个扩展之前我写了这么几个扩展方法使用: 以下是引用片段：
TypeExtension
publicstaticclassTypeExtension
{
/**////
///获取一个Linq实体类型在Linq继承层次中的鉴别列的值(类型必须是继承连中的顶级类型)
///
///
///要查找Code值的子类别
publicstaticobjectGetDiscriminatorCode(thisTypetype,TypetypeChild)
{
InheritanceMappingAttribute[]inheritances=(InheritanceMappingAttribute[])type.GetCustomAttributes(typeof(InheritanceMappingAttribute),true);
if(inheritances.Length>0)
{
foreach(InheritanceMappingAttributeattininheritances)
{
if(typeChild.Equals(att.Type))
{
returnatt.Code;
}
}
}
returnnull;
}
/**////
///获取一个Linq实体类型的鉴别器列的列名(不查找继承链)
///
publicstaticstringGetDiscriminatorColumnName(thisTypetype)
{
PropertyInfo[]properties=type.GetProperties(BindingFlags.Public|BindingFlags.Instance|BindingFlags.GetProperty|BindingFlags.SetField);
foreach(PropertyInfopropertyinproperties)
{
ColumnAttribute[]colAtts=(ColumnAttribute[])property.GetCustomAttributes(typeof(ColumnAttribute),true);
if(colAtts!=null&&colAtts.Length>0)
{
ColumnAttributecolAtt=colAtts[0];
if(colAtt.IsDiscriminator)
{
return(String.IsNullOrEmpty(colAtt.Name))?property.Name:colAtt.Name;
}
}
}
returnnull;
}
/**////
///获取一个Linq实体类型的在继承层次中的顶层基类
///
///
///
publicstaticTypeFindTopEntityType(thisTypetype)
{
Typety=type;
while(!ty.IsLinqDataEntity())
{
ty=type.BaseType;
if(ty.Equals(typeof(Object)))
{
ty=null;
break;
}
}
returnty;
}
/**////
///指示一个类型是否是一个LinqToSql实体(不查找继承链)
///
publicstaticboolIsLinqDataEntity(thisTypetype)
{
TableAttribute[]atts=(TableAttribute[])type.GetCustomAttributes(typeof(TableAttribute),false);
return(atts!=null&&atts.Length>0);
}
} |
我在那个扩展中添加一个方法(很多代码都是自己直接修改了JeffreyZhao的代码，主要是懒得写了，特此声明，我不是郭敬明，剽窃我是会道歉的)：以下是引用片段：
privatestaticRegexm_fieldResgex=newRegex(@"\sFROM\s",RegexOptions.IgnoreCase);
privatestaticvoidAddDiscriminatorColum(DbCommandcmd)
{
stringcmdText=cmd.CommandText;
IEnumerablematches=
m_fieldResgex.Matches(cmdText).Cast().OrderByDescending(m=>m.Index);
foreach(Matchminmatches)
{
intsplitIndex=m.Index;
cmdText=
cmdText.Substring(0,splitIndex)+GetDiscriminatorColumSelectString()+
cmdText.Substring(splitIndex);
}
cmd.CommandText=cmdText;
}
privatestaticstringGetDiscriminatorColumSelectString()
{
Typetype=typeof(T);
TypetopType=type.FindTopEntityType();
stringvalue=topType.GetDiscriminatorCode(type).ToString();
stringcolumnName=topType.GetDiscriminatorColumnName();
if(!String.IsNullOrEmpty(value)&&!String.IsNullOrEmpty(columnName))
{
returnString.Format(@",'{0}'AS[{1}]",value,columnName);
}
returnString.Empty;
}
完成很扩展(有的代码我有所修改，我不太理解为什么JeffreyZhao的代码中要在方法外部关闭数据库连接，为了降低打开连接的开销吗?可是有连接池啊，疑惑中。。。。)：
publicstaticListExecuteQuery(thisDataContextdataContext,IQueryablequery,boolwithNoLock,boolgenerateDiscriminateColumn)
{
stringdiscriminatorCode=null;
Typetype=typeof(T);
DbCommandcommand=dataContext.GetCommand(query,withNoLock);
if(generateDiscriminateColumn)
{
AddDiscriminatorColum(command);
}
try
{
command.Connection.Open();
using(DbDataReaderreader=command.ExecuteReader())
{
returndataContext.Translate(reader).ToList();
}
}
finally
{
if(command!=null)
{
command.Connection.Close();
}
command.Dispose();
}
} |
有了这个扩展我们可以很方便的查询了： 以下是引用片段：
using(DataClasses1DataContextcontext=newDataClasses1DataContext())
{
IQueryableinfos=fromoincontext.Orders
joinsincontext.Suppliersono.SupplierIdequalss.SupplierId
selectnew
{
OrderId=o.OrderId,
SupplierId=o.SupplierId,
SupplierName=s.SupplierName
};
returncontext.ExecuteQuery(infos,true,true);
} |
一切似乎很顺利，不好意思，非常非常不好意思，还是有问题，这个查询得到的OrderInfo.SupplierName属性总是为空，对于这个问题我现在也不是很明白，这个扩展的关键是DataContext.Translate方法，这个方法是完成查询结果到Entity的映射，我们看看这个方法的算法, MSDN上是这样写的： 使查询结果中的列与对象中的字段和属性相匹配的算法如下所示： - 如果字段或属性映射到特定列名称，则结果集中应包含该列名称。
- 如果未映射字段或属性，则结果集中应包含其名称与该字段或属性相同的列。
通过先查找区分大小写的匹配来执行比较。如果未找到匹配项，则会继续搜索不区分大小写的匹配项。 如果同时满足下列所有条件，则该查询应当返回(除延迟加载的对象外的)对象的所有跟踪的字段和属性： - T 是由 DataContext 显式跟踪的实体。
- ObjectTrackingEnabled 为 true。
- 实体具有主键。
我标注了红色的两个地方个人认为是对立的，我的理解是如果是DataContext追踪的实体则只映射对象追踪的字段和属性，如果不是DataContext追踪的实体则会映射追踪的和不追踪的属性和字段。 解决之道是在OrderInfo.SupplierName属性上加上ColumnAttribute特性，同时处于更新时候的需要，一样要欺骗LS： 以下是引用片段：
[Column(Storage="_SupplierName",IsDbGenerated=true,AutoSync=AutoSync.Never)]
publicstringSupplierName
{
get
{
returnthis._SupplierName;
}
set
{
if((this._SupplierName!=value))
{
this._SupplierName=value;
}
}
} |
再次执行扩展，一切顺利，我们也就可以这样插入数据了: 以下是引用片段：
OrderInfoinfo=newOrderInfo();
using(DataClasses1DataContextcontext=newDataClasses1DataContext())
{
context.Orders.InsertOnSubmit(info);
context.SubmitChanges();
} |
写到这里我还是要感谢老赵无私的提供他的LS扩展思路和CODE，同时也对老赵在LS方面的独到见解感到钦佩和赞赏。
 |