SQL到Linq语句中的独立子查询(只命中DB一次)
本文关键字:DB 一次 查询 Linq 语句 独立 SQL | 更新日期: 2023-09-27 18:22:01
有类似于的东西
SELECT (SELECT COUNT(*) from Table1),(SELECT COUNT(*) from Table2 )
我该怎么用linq写?还是简单的不可能?
限制:
只能命中数据库一次:
var result = new { Sum1 = db.Table1.Count(), Sum2 = db.Table2.Count() }); // is not valid.....
我不想使用类似于(使用"帮助"表)的东西:
var result = (from t3 in db.Table3 select new { Sum1 = db.Table1.Count(), Sum2 = db.Table2.Count() }).firstOrDefault(); //In order to get only the first row //but it will not return nothing if the table 3 has no entries......
不使用
db.Database.ExecuteSqlCommand
我看不到能解决所有限制的解决方案。这是使用ORM映射器的注意事项之一,您无法控制生成的SQL。
在这种情况下,如果向数据库发送多个查询是完全不可接受的,那么严酷的事实是,您将不得不自己编写查询。
更新
我很好奇,创建了一个可以做到这一点的扩展方法!当然,它构造了自己的SQL命令,并且只适用于Linq2SQL。还有大量免责声明:这是一个相当脏的代码,如果我有时间,我会在周末修复它:)
public static TOut CountMany<TContext, TOut>(this TContext db, Expression<Func<TContext, TOut>> tableSelector)
where TContext: DataContext
{
var newExpression = (NewExpression) tableSelector.Body;
var tables =
newExpression.Arguments.OfType<MethodCallExpression>()
.SelectMany(mce => mce.Arguments.OfType<MemberExpression>())
.ToList();
var command = new string[tables.Count];
for(var i = 0; i < tables.Count; i++)
{
var table = tables[i];
var tableType = ((PropertyInfo) table.Member).PropertyType.GetGenericArguments()[0];
var tableName = tableType.GetCustomAttribute<TableAttribute>().Name;
command[i] = string.Format("(SELECT COUNT(*) FROM {0}) AS T{1}", tableName, i);
}
var dbCommand = db.Connection.CreateCommand();
dbCommand.CommandText = string.Format("SELECT {0}", String.Join(",", command));
db.Connection.Open();
IDataRecord result;
try
{
result = dbCommand.ExecuteReader().OfType<IDataRecord>().First();
}
finally
{
db.Connection.Close();
}
var results = new object[tables.Count];
for (var i = 0; i < tables.Count; i++)
results[i] = result.GetInt32(i);
var ctor = typeof(TOut).GetConstructor(Enumerable.Repeat(typeof(int), tables.Count).ToArray());
return (TOut) ctor.Invoke(results);
}
代码的名称如下:
var counts = dbContext.CountMany(db => new
{
table1Count = db.Table1.Count(),
table2Count = db.Table2.Count()
//etc.
});