LINQ体验(13)——LINQ to SQL语句之运算符转换和ADO.NET与LINQ to SQL

运算符转换

1.AsEnumerable：将类型转换为泛型 IEnumerable

使用 AsEnumerable<TSource> 可返回类型化为泛型 IEnumerable 的參数。在此演示样例中，LINQ to SQL（使用默认泛型 Query）会尝试将查询转换为 SQL 并在server上运行。

但 where 子句引用用户定义的client方法 (isValidProduct)，此方法无法转换为 SQL。
解决方法是指定 where 的client泛型 IEnumerable<T> 实现以替换泛型 IQueryable<T>。可通过调用 AsEnumerable<TSource>运算符来运行此操作。

var q =
    from p in db.Products.AsEnumerable()
    where isValidProduct(p)
    select p;

语句描写叙述：这个样例就是使用AsEnumerable以便使用Where的clientIEnumerable实现，而不是默认的IQueryable将在server上转换为SQL并运行的默认Query<T>实现。这非常有必要，由于Where子句引用了用户定义的client方法isValidProduct，该方法不能转换为SQL。

2.ToArray：将序列转换为数组

使用 ToArray <TSource>可从序列创建数组。

var q =
    from c in db.Customers
    where c.City == "London"
    select c;
Customer[] qArray = q.ToArray();

语句描写叙述：这个样例使用 ToArray 将查询直接计算为数组。

3.ToList：将序列转换为泛型列表

使用 ToList<TSource>可从序列创建泛型列表。以下的演示样例使用 ToList<TSource>直接将查询的计算结果放入泛型 List<T>。

var q =
    from e in db.Employees
    where e.HireDate >= new DateTime(1994, 1, 1)
    select e;
List<Employee> qList = q.ToList();

4.ToDictionary：将序列转化为字典

使用Enumerable.ToDictionary<TSource, TKey>方法能够将序列转化为字典。TSource表示source中的元素的类型；TKey表示keySelector返回的键的类型。其返回一个包括键和值的Dictionary<TKey, TValue>。

var q =
    from p in db.Products
    where p.UnitsInStock <= p.ReorderLevel && !p.Discontinued
    select p;
Dictionary<int, Product> qDictionary =
    q.ToDictionary(p => p.ProductID);
foreach (int key in qDictionary.Keys)
{
    Console.WriteLine(key);
}

语句描写叙述：这个样例使用 ToDictionary 将查询和键表达式直接键表达式直接计算为 Dictionary<K, T>。

ADO.NET与LINQ to SQL

LINQ to SQL 基于由 ADO.NET 提供程序模型提供的服务。因此，我们能够将 LINQ to SQL 代码与现有的 ADO.NET 应用程序混合在一起，将当前 ADO.NET 解决方式迁移到 LINQ to SQL。

1.连接

在创建 LINQ to SQL DataContext 时，能够提供现有 ADO.NET 连接。对 DataContext 的全部操作（包含查询）都使用所提供的这个连接。

假设此连接已经打开，则在您使用完此连接时，LINQ to SQL 会保持它的打开状态不变。我们始终能够訪问此连接。另外还能够使用 Connection 属性自行关闭它。

//新建一个标准的ADO.NET连接:
SqlConnection nwindConn = new SqlConnection(connString);
nwindConn.Open();
// ... 其他的ADO.NET数据操作代码... //
//利用现有的ADO.NET连接来创建一个DataContext:
Northwind interop_db = new Northwind(nwindConn);
var orders =
     from o in interop_db.Orders
     where o.Freight > 500.00M
     select o;
//返回Freight>500.00M的订单
nwindConn.Close();

语句描写叙述：这个样例使用预先存在的ADO.NET连接创建Northwind对象。本例中的查询返回运费至少为500.00 的全部订单。

2.事务

当我们已经启动了自己的数据库事务而且我们希望DataContext 包括在内时。我们能够向 DataContext 提供此事务。

通过 .NET Framework 创建事务的首选方法是使用 TransactionScope 对象。通过使用此方法，我们能够创建跨数据库及其它驻留在内存中的资源管理器运行的分布式事务。

事务范围差点儿不须要资源就能够启动。它们仅在事务范围内存在多个连接时才将自身提升为分布式事务。

using (TransactionScope ts = new TransactionScope())
{
    db.SubmitChanges();
    ts.Complete();
}

注意：不能将此方法用于全部数据库。

比如。SqlClient 连接在针对 SQL Server 2000 server使用时无法提升系统事务。它採取的方法是。仅仅要它发现有使用事务范围的情况，它就会自己主动向完整的分布式事务登记。

以下用一个样例说明一下事务的用法。在这里。也说明了重用 ADO.NET 命令和 DataContext 之间的同一连接。

var q =
     from p in db.Products
     where p.ProductID == 3
     select p;
//使用LINQ to SQL查询出来
//新建一个标准的ADO.NET连接:
SqlConnection nwindConn = new SqlConnection(connString);
nwindConn.Open();
//利用现有的ADO.NET连接来创建一个DataContext:
Northwind interop_db = new Northwind(nwindConn);
SqlTransaction nwindTxn = nwindConn.BeginTransaction();
try
{
    SqlCommand cmd = new SqlCommand("UPDATE Products SET"
    +"QuantityPerUnit = 'single item' WHERE ProductID = 3");
    cmd.Connection = nwindConn;
    cmd.Transaction = nwindTxn;
    cmd.ExecuteNonQuery();
    interop_db.Transaction = nwindTxn;
    Product prod1 = interop_db.Products.First(p => p.ProductID == 4);
    Product prod2 = interop_db.Products.First(p => p.ProductID == 5);
    prod1.UnitsInStock -= 3;
    prod2.UnitsInStock -= 5;//这有一个错误，不能为负数
    interop_db.SubmitChanges();
    nwindTxn.Commit();
}
catch (Exception e)
{
    //假设有一个错误。全部的操作回滚
    Console.WriteLine(e.Message);
}
nwindConn.Close();

语句描写叙述：这个样例使用预先存在的 ADO.NET 连接创建 Northwind 对象，然后与此对象共享一个 ADO.NET 事务。此事务既用于通过 ADO.NET 连接运行 SQL 命令。又用于通过 Northwind 对象提交更改。当事务因违反 CHECK 约束而中止时。将回滚全部更改。包含通过 SqlCommand 做出的更改。以及通过Northwind 对象做出的更改。

3.直接运行 SQL语句

1.直接运行SQL查询

假设 LINQ to SQL 查询不足以满足专门任务的须要，我们能够使用 ExecuteQuery 方法来运行 SQL 查询，然后将查询的结果直接转换成对象。

var products = db.ExecuteQuery<Product>(
    "SELECT [Product List].ProductID,"+
    "[Product List].ProductName " +
    "FROM Products AS [Product List] " +
    "WHERE [Product List].Discontinued = 0 " +
    "ORDER BY [Product List].ProductName;"
);

语句描写叙述：这个样例使用ExecuteQuery<T>运行随意 SQL 查询，并将所得的行映射为 Product 对象的序列。

2.直接运行SQL命令

採用DataContext 连接时，能够使用ExecuteCommand来运行不返回对象的 SQL 命令。

db.ExecuteCommand
    ("UPDATE Products SET UnitPrice = UnitPrice + 1.00");