假设我有一个包含四列的数据表,公司(字符串),基金(字符串),州(字符串),值(双精度):
table1.Rows.Add("Company 1","Fund 1","NY",100));
table1.Rows.Add("Company 2","Fund 1","CA",200));
table1.Rows.Add("Company 3","Fund 1","FL",300));
table1.Rows.Add("Company 4","Fund 2","CA",400));
table1.Rows.Add("Company 5","Fund 1","NY",500));
table1.Rows.Add("Company 6","Fund 2","CA",600));
table1.Rows.Add("Company 7","Fund 3","FL",700));
我想使用System.LINQ.Dynamic构建一个动态查询,该查询将对公司,基金或州进行分组,然后按条件选择我的组作为第一列,并求和(值):
string groupbyvalue="Fund";
var q1= table1.AsEnumerable().AsQueryable()
.GroupBy(groupbyvalue,"it")
.Select("new ("+groupbyvalue+" as Group, Sum(Value) as TotalValue)");
在上面的查询中,所选的groupbyvalue(Group)将始终为字符串,并且总和始终为双精度,因此我希望能够转换为类似List的对象,其中Result是具有属性Group(string)的对象)和TotalValue(双精度)。
我对此有很多麻烦,有人可以阐明吗?
首先,您将在Select子句中以Key
访问当前分组的值:
.Select("new (Key as Group, Sum(Value) as TotalValue)");
那应该使您的查询工作。更为棘手的问题是如何将返回的对象(具有从DynamicClass
继承的动态生成的类型)转换为静态类型。
选项1:使用反射来访问动态对象的Group
和TotalValue
属性。
选项2:使用编译的表达式树进行轻量级代码生成以访问Group
和TotalValue
属性。
选项3:修改动态库以支持强类型的结果。事实证明这很简单:
在ExpressionParser.Parse()
,在私有字段中捕获type参数:
private Type newResultType;
public Expression Parse(Type resultType)
{
newResultType = resultType;
int exprPos = token.pos;
// ...
在ExpressionParser.ParseNew()
的结尾附近,我们将尝试在默认为动态类型之前使用newResultType
:
Expression ParseNew()
{
// ...
NextToken();
Type type = newResultType ?? DynamicExpression.CreateClass(properties);
MemberBinding[] bindings = new MemberBinding[properties.Count];
for (int i = 0; i < bindings.Length; i++)
bindings[i] = Expression.Bind(type.GetProperty(properties[i].Name), expressions[i]);
return Expression.MemberInit(Expression.New(type), bindings);
}
最后,我们需要一个Select()
的强类型版本:
public static IQueryable<TResult> Select<TResult>(this IQueryable source, string selector, params object[] values)
{
if (source == null) throw new ArgumentNullException("source");
if (selector == null) throw new ArgumentNullException("selector");
LambdaExpression lambda = DynamicExpression.ParseLambda(source.ElementType, typeof(TResult), selector, values);
return source.Provider.CreateQuery<TResult>(
Expression.Call(
typeof(Queryable), "Select",
new Type[] { source.ElementType, typeof(TResult) },
source.Expression, Expression.Quote(lambda)));
}
对原始Select()
的唯一更改是我们引用TResult
。
现在我们只需要一个命名类型即可返回:
public class Result
{
public string Group { get; set; }
public double TotalValue { get; set; }
}
您更新的查询将如下所示:
IQueryable<Result> res = table1.AsQueryable()
.GroupBy(groupbyvalue, "it")
.Select<Result>("new (Key as Group, Sum(Value) as TotalValue)");