性能优化总结（三）：聚合SQL在GIX4中的应用

///<summary>
///这是个子表格。
///
///它表示的是某一表格中的一些指定的行。
///</summary>
publicclassSubTable:IGTable
{
privateIGTable_table;
privateint_startRow;
privateint_endRow;

///<summary>
///构造一个指定table的子表。
///</summary>
///<paramname="table"></param>
///<paramname="startRow">这个表在table中的开始行。</param>
///<paramname="endRow">这个表在table中的结束行。</param>
publicSubTable(IGTabletable,intstartRow,intendRow){…}
}

定义好被读取的数据的结构后，按照刚才划分子表的逻辑，并调用TGEntity<T>.ReadDataDirectly(DataRow)方法生成所有对象即可：

publicstaticclassEntityListHelper
{
///<summary>
///这个方法把table中的数据全部读取并转换为对象存入对象列表中。
///
///算法简介：
///由于子对象的数据都是存储在这个IGTable中，所以每一个TEntity可能对应多个行，
///每一行数据其实就是一个子对象的数据，而TEntity的属性值是重复的。
///所以这里找到每个TEntity对应的第一行和最后一行，把它封装为一个子表格，传给子对象集合进行加载。
///这样的设计是为了实现重用这个方法：集合加载IGTable中的数据。
///</summary>
///<typeparamname="TCollection"></typeparam>
///<typeparamname="TEntity"></typeparam>
///<paramname="list">转换的对象存入这个列表中</param>
///<paramname="table">
///表格数据，数据类型于以下形式：
///TableATableBTableCTableD...
///a1b1c1
///a1b1c2
///a2b2c3
///a2b3NULL
///a3NULLNULL
///...
///</param>
///<paramname="relationLoader">
///为每个TEntity调用此方法，从IGTable中加载它对应的孩子对象。
///加载完成后的对象会被加入到list中，所以此方法有可能返回一个全新的TEntity。
///</param>
publicstaticvoidReadFromTable<TCollection,TEntity>(TCollectionlist,IGTabletable,Func<TEntity,IGTable,TEntity>relationLoader)
whereTCollection:GBusinessListBase<TCollection,TEntity>
whereTEntity:GEntity<TEntity>
{
list.RaiseListChangedEvents=false;

Guid?lastId=null;
//每个TEntity对象对应的第一行数据
intstartRow=0;
for(inti=0,c=table.Count;i<c;i++)
{
varrow=table[i];

stringidName=GEntity<TEntity>.GetReadableColumnSql("Id");
varobjId=row[idName];
Guid?id=objId!=DBNull.Value?(Guid)objId:(Guid?)null;

//如果id改变，表示已经进入到下一个TEntity对象的开始行了。
if(id!=lastId)
{
//不是第一次
if(lastId.HasValue)
{
//前一行就是最后一行。
intendRow=i-1;
TEntityitem=CreateEntity<TEntity>(table,startRow,endRow,relationLoader);
list.Add(item);
//重置startRow为下一个TEntity
startRow=i;
}
}
lastId=id;
}

//加入最后一个Entity
if(lastId.HasValue)
{
TEntitylastEntity=CreateEntity<TEntity>(table,startRow,table.Count-1,relationLoader);
list.Add(lastEntity);
}

//完毕，退出
list.RaiseListChangedEvents=true;
}

///<summary>
///把table从startRow到endRow之间的数据，都转换为一个TEntity并返回。
///</summary>
privatestaticTEntityCreateEntity<TEntity>(IGTabletable,intstartRow,intendRow,Func<TEntity,IGTable,TEntity>relationLoader)whereTEntity:GEntity<TEntity>
{
//新的TEntity
TEntityitem=GEntity<TEntity>.ReadDataDirectly(table[startRow]);
Debug.Assert(item!=null,"id不为空，对象也不应该为空。");

varchildTable=newSubTable(table,startRow,endRow);
item=relationLoader(item,childTable);
returnitem;
}
}
这段代码中最关键的地方是relationLoader的定义，这个方法传入一个Entity和其对应的所有行，由它自己再来调用关系对象类的方法读取行并生成最后的Entity返回。在后面，我会给出一个较完事的例子。

工厂方法-命名约定：

publicstaticPBSsGetListByPBSTypeId_With_Properties(GuidpbsTypeId)
{

//开始调用远程对象的DataPortal_Fetch方法
returnDataPortal.Fetch<PBSs>(newGetListCriteria_With_Properties(pbsTypeId));
}

//以下所有方法在服务端执行

privatevoidDataPortal_Fetch(GetListCriteria_With_Propertiescriteria)
{
varpbsTypeId=criteria.PBSTypeId;
varsql=string.Format(SQL_GET_PBS_BY_PBSTYPE_WITH_PROPERTIES,pbsTypeId);

using(vardb=Helper.CreateDb())
{
IGTabletable=db.QueryTable(sql);
this.ReadFromTable(table,PBS.GetChild_With_Properties);
}
}

注意到传入的委托是PBS.GetChild_With_Properties，正是上文提到的relationLoader，接着看：

publicclassPBS:GTreeEntity<PBS>,IDisplayModel
{
publicstaticPBSGetChild_With_Properties(PBSpbs,IGTablesubTable)
{
pbs=GetChild(pbs);//获取一个新的对象，并从参数中拷贝数据。

//同时，加载PBS的Properties属性。
varproperties=PBSPropertys.GetChild_WithValues(pbs,subTable);
pbs.LoadProperty(PBSPropertysProperty,properties);

returnpbs;
}
}

publicclassPBSPropertys:GEntityTreeList<PBSPropertys,PBSProperty>
{
publicstaticPBSPropertysGetChild_WithValues(PBSpbs,IGTabletable)
{
varproperties=GetChild();

properties.ReadFromTable(table,PBSProperty.GetChild_With_Values);

foreach(varpropertyinproperties)
{
property.PBS=pbs;
}

//排序
varresult=GetChild();
result.AddRange(properties.OrderBy(p=>p.OrderNo));

returnresult;
}
}

publicclassPBSProperty:GEntity<PBSProperty>,ITreeNode,IOrderedObject
{
publicstaticPBSPropertyGetChild_With_Values(PBSPropertyproperty,IGTabletable)
{
varmodel=GetChild(property);

varvalues=PBSPropertyOptionalValues.GetChild(model,table);
model.LoadProperty(PBSPropertyOptionalValuesProperty,values);

returnmodel;
}
}

publicpartialclassPBSPropertyOptionalValues:GEntityList<PBSPropertyOptionalValues,PBSPropertyOptionalValue>
{
internalstaticPBSPropertyOptionalValuesGetChild(PBSPropertyparent,IGTabletable)
{
varvalues=GetChild();

values.ReadFromTable(table);

foreach(varvalueinvalues)
{
value.PBSProperty=parent;
}

returnvalues;
}
}

varpbsList=PBSs.GetListByPBSTypeId_With_Properties(id);
foreach(varpbsinpbsList)
{
foreach(varpropertyinpbs.PBSPropertys)
{
foreach(varoptionalValueinproperty.PBSPropertyOptionalValues)
{
//......
}
}
}