LINQ体验(16)——LINQ to SQL语句之DataContext

接下来的一段代码先创建一个数据库，在调用CreateDatabase后，新的数据库就会存在并且会接受一般的查询和命令。接着插入一条记录并且查询。最后删除这个数据库。

 //1.新建一个临时文件夹来存放新建的数据库
 string userTempFolder = Environment.GetEnvironmentVariable
 ("SystemDrive") + @"\YJingLee";
 Directory.CreateDirectory(userTempFolder);
 //2.新建数据库NewCreateDB
 string userMDF = System.IO.Path.Combine(userTempFolder,
  @"NewCreateDB.mdf");
 string connStr = String.Format(@"Data Source=.\SQLEXPRESS;
AttachDbFilename={0};Integrated Security=True;
Connect Timeout=30;User Instance=True; 
Integrated Security = SSPI;", userMDF);
 NewCreateDB newDB = new NewCreateDB(connStr);
 newDB.CreateDatabase();
 //3.插入数据并查询
 var newRow = new Person
 {
     PersonID = 1,
     PersonName = "YJingLee",
     Age = 22
 };

 newDB.Persons.InsertOnSubmit(newRow);
 newDB.SubmitChanges();
 var q = from x in newDB.Persons
         select x;
 //4.删除数据库
 newDB.DeleteDatabase();
 //5.删除临时目录
 Directory.Delete(userTempFolder);

数据库验证

DatabaseExists方法用于尝试通过使用DataContext中的连接打开数据库，如果成功返回true。

下面代码说明是否存在Northwind数据库和NewCreateDB数据库 。

//检测Northwind数据库是否存在
if (db.DatabaseExists())
    Console.WriteLine("Northwind数据库存在");
else
    Console.WriteLine("Northwind数据库不存在");
//检测NewCreateDB数据库是否存在
string userTempFolder = Environment.GetEnvironmentVariable("Temp");
string userMDF = System.IO.Path.Combine(userTempFolder,
@"NewCreateDB.mdf");
NewCreateDB newDB = new NewCreateDB(userMDF);

if (newDB.DatabaseExists())
    Console.WriteLine("NewCreateDB数据库存在");
else
    Console.WriteLine("NewCreateDB数据库不存在");

数据库更改

SubmitChanges方法计算要插入、更新或删除的已修改对象的集，并执行相应命令以实现对数据库的更改。

无论对象做了多少项更改，都只是在更改内存中的副本。并未对数据库中的实际数据做任何更改。直到对DataContext显式调用SubmitChanges，所做的更改才会传输到服务器。调用时，DataContext会设法将我们所做的更改转换为等效的SQL命令。我们也可以使用自己的自定义逻辑来重写这些操作，但提交顺序是由DataContext的一项称作“更改处理器”的服务来协调的。事件的顺序如下：

1. 当调用SubmitChanges时，LINQ to SQL会检查已知对象的集合以确定新实例是否已附加到它们。如果已附加，这些新实例将添加到被跟踪对象的集合。
2. 所有具有挂起更改的对象将按照它们之间的依赖关系排序成一个对象序列。如果一个对象的更改依赖于其他对象，则这个对象将排在其依赖项之后。
3. 在即将传输任何实际更改时，LINQ to SQL会启动一个事务来封装由各条命令组成的系列。
4. 对对象的更改会逐个转换为SQL命令，然后发送到服务器。

如果数据库检测到任何错误，都会造成提交进程停止并引发异常。将回滚对数据库的所有更改，就像未进行过提交一样。DataContext 仍具有所有更改的完整记录。

下面代码说明的是在数据库中查询CustomerID为ALFKI的顾客，然后修改其公司名称，第一次更新并调用SubmitChanges()方法，第二次更新了数据但并未调用SubmitChanges()方法。

//查询
Customer cust = db.Customers.First(c => c.CustomerID == "ALFKI");
//更新数据并调用SubmitChanges()方法
cust.CompanyName = "YJingLee‘s Blog";
db.SubmitChanges();
//更新数据没有调用SubmitChanges()方法
cust.CompanyName = "http://lyj.cnblogs.com";

动态查询

使用动态查询，这个例子用CreateQuery()方法创建一个IQueryable<T>类型表达式输出查询的语句。这里给个例子说明一下。有关动态查询具体内容，下一篇介绍。

var c1 = Expression.Parameter(typeof(Customer), "c");
PropertyInfo City = typeof(Customer).GetProperty("City");

var pred = Expression.Lambda<Func<Customer, bool>>(
    Expression.Equal(
    Expression.Property(c1, City),
    Expression.Constant("Seattle")
   ), c1
);
IQueryable custs = db.Customers;
Expression expr = Expression.Call(typeof(Queryable), "Where",
    new Type[] { custs.ElementType }, custs.Expression, pred);
IQueryable<Customer> q = db.Customers.AsQueryable().
Provider.CreateQuery<Customer>(expr);

日志

Log属性用于将SQL查询或命令打印到TextReader。此方法对了解 LINQ to SQL 功能和调试特定的问题可能很有用。

下面的示例使用Log属性在SQL代码执行前在控制台窗口中显示此代码。我们可以将此属性与查询、插入、更新和删除命令一起使用。

//关闭日志功能
//db.Log = null;
//使用日志功能：日志输出到控制台窗口
db.Log = Console.Out;
var q = from c in db.Customers
        where c.City == "London"
        select c;
//日志输出到文件
StreamWriter sw = new StreamWriter(Server.MapPath("log.txt"), true);
db.Log = sw;
var q = from c in db.Customers
        where c.City == "London"
        select c;
sw.Close();

版权声明：本文为博主http://www.zuiniusn.com原创文章，未经博主允许不得转载。

LINQ体验(16)——LINQ to SQL语句之DataContext

标签：