GVKun编程网logo

使用Linq to SQL进行多线程

12

如果您对使用LinqtoSQL进行多线程感兴趣，那么这篇文章一定是您不可错过的。我们将详细讲解使用LinqtoSQL进行多线程的各种细节，此外还有关于.net–使用LinqToSQL进行多个Submi

如果您对使用Linq to SQL进行多线程感兴趣，那么这篇文章一定是您不可错过的。我们将详细讲解使用Linq to SQL进行多线程的各种细节，此外还有关于.net – 使用Linq To SQL进行多个SubmitChanges和事务回滚、asp.net-mvc – 如果使用LINQ to SQL,还有什么理由学习SQL查询/语法吗？、asp.net使用LINQ to SQL连接数据库及SQL操作语句用法分析、c# – 使用LINQ to MySQL(DbLinq)和动态LINQ的可排序JqGrid – Orderby不起作用的实用技巧。

本文目录一览：

使用Linq to SQL进行多线程

使用Linq to SQL进行多线程

由于原始线程（使用Linq to
SQL的多线程）到现在已经很老了，我想我会在类似的主题上发布另一个问题。考虑一个方案，其中DomainService公开了许多方法来从SQL
Server数据库检索数据。显然，在多用户方案中，同时有多个请求，人们必须期望this.DataContext可以并行使用，而开发人员无需控制也无需付出额外努力来处理这些多个请求。因此，如果我将顺序的LINQ查询放入Parallel.Invoke（），结果将彻底松开，然后我得到的内容
是“已经有与此命令关联的打开的DataReader，必须先关闭它”。 错误 …？

为了证明这一点，它可以工作：

List<Data> retVal = new List<Data>();retVal.AddRange(this.DataContext.Table1.Where(w=>w.A==1).Select(s=>new Data{f1=s.D}).ToList());retVal.AddRange(this.DataContext.Table1.Where(w=>w.B==2).Select(s=>new Data{f1=s.D}).ToList());retVal.AddRange(this.DataContext.Table1.Where(w=>w.C==3).Select(s=>new Data{f1=s.D}).ToList());

…但是这不是：

List<Data> retVal = new List<Data>();Parallel.Invoke(()=>retVal.AddRange(this.DataContext.Table1.Where(w=>w.A==1).Select(s=>new Data{f1=s.D}).ToList()),()=>retVal.AddRange(this.DataContext.Table1.Where(w=>w.B==2).Select(s=>new Data{f1=s.D}).ToList()),()=>retVal.AddRange(this.DataContext.Table1.Where(w=>w.C==3).Select(s=>new Data{f1=s.D})).ToList());

不用担心，List不是线程安全的，因为错误来自SQL数据连接。

任何见解和解释将不胜感激。

答案1

小编典典

首先，需要澄清的是，此问题与多线程而不是多用户有关。在多用户方案中，每个用户将拥有自己的DataContext实例，从而避免了共享实例周围的线程问题。

并行示例失败，因为该DataContext对象不是线程安全的对象。它期望由单个线程使用，而不是由多个并行线程使用。这是与数据读取器相关的一个例外，因为DataContext它的连接已打开，当您尝试并行执行第二条语句时，将与数据读取器一起读取。

如果您尝试在不使用SqlConnection任何序列化技术的情况下跨多个线程使用一个实例，则同样的问题将很明显。

.net – 使用Linq To SQL进行多个SubmitChanges和事务回滚

.net – 使用Linq To SQL进行多个SubmitChanges和事务回滚

我使用TransactionScope将 Linq中的数据提交到sql.我的问题是,如果我在同一个范围内使用多个SubmitChanges,所有范围将在发生错误或仅在最后一个SubmitChanges之后进行更改时回滚？例如： 
using (TransactionScope trans = new TransactionScope())
{
    using (dbDataContext db = new dbDataContext())
    {
        try
        {
            //do some insert
            db.SubmitChanges();

            //do some updates
            db.SubmitChanges();

            trans.Complete();
        }
        catch(Exception ex){}
    }
}

如果更新SubmitChanges引发异常,InsertChanges会插入吗？

解决方法

所有更改将回滚,而不仅仅是最后一个SubmitChanges()的更改.

当您有数据取决于其他数据时,您通常需要使用此模式,例如,如果您需要创建一个对象并获取自动生成的ID以便执行其他操作(尽管L2sql支持使用一个SubmitChanges调用大多数场景只是创建对象,但我离题…).

asp.net-mvc – 如果使用LINQ to SQL,还有什么理由学习SQL查询/语法吗？

asp.net-mvc – 如果使用LINQ to SQL,还有什么理由学习SQL查询/语法吗？

由于以前使用ASP.NET Web表单和存储过程的工作,我确实理解SQL查询和语法,但我不会称自己为“专家”.

由于我一直在使用ASP.NET MVC和LinqTosql,似乎很多繁重工作都是为我完成的,并且在sql端封装了我正在质疑我是否在继续充实我的知识方面有任何好处. SQL查询或者我是否最好将我的“学习时间”集中在其他事情上.

你的意见？

解决方法

您应该完全了解sql并使您的知识保持最新. ORM旨在减轻做一些你知道如何做的乏味的痛苦,就像图形计算器旨在做一些你可以手工完成的事情(并且应该知道如何).

您开始让ORM在数据库中执行您不完全理解的事情的那一刻就是您失去对模型的控制权.

asp.net使用LINQ to SQL连接数据库及SQL操作语句用法分析

asp.net使用LINQ to SQL连接数据库及SQL操作语句用法分析

本文实例讲述了asp.net使用LINQ to SQL连接数据库及SQL操作语句用法。分享给大家供大家参考，具体如下：

LINQ简介

LINQ:语言集成查询（Language INtegrated Query）是一组用于c#和Visual Basic语言的扩展。它允许编写C#或者Visual Basic代码以查询数据库相同的方式操作内存数据。

LINQ是一门查询语言，和SQL一样，通过一些关键字的组合，实现最终的查询。

LINQ的分类

LINQ to Object
LINQ to XML
LINQ to SQL
LINQ to DataSet
LINQ to ADO.NET

命名空间为System.Linq;

LINQ查询

语法：
from 临时变量 in 集合对象或数据库对象
　　where 条件表达式
　　[orderby条件]
　　[group by 条件]
　　select 临时变量中被查询的值

例：

from c in Student select c;

假设Student是一个数据库表对应的一个实体类

则查询语句为：

from c in Student select c; 
//整表查询
from c in Student where c.name=="张三" select c;
//查询姓名为张三的所有信息

其中C为临时变量，可任意取。

查询几个字段

1、查询student表中的几个字段

复制代码 代码如下:
var query=from c in student  select new {c.number,c.name,c.age};

2、查询student表中的几个字段，并重新设定列名

复制代码 代码如下:
var query=from c in student select new {学号=c.number,姓名=c.name, 年领=c.age};

注意事项

linq查询语句必须以from子句开始，以select 子句结束。

Linq是在.NET Framework 3.5 中出现的技术，所以在创建新项目的时候必须要选3.5或者更高版本，否则无法使用。

3、排序

var query=from c in student orderby c.age ascending select c;//升序
var query=from c in studeng orderby c.age descending select c;//降序

4、分组

复制代码 代码如下:
var  query=from c in student group c by c.sex into d select new {性别=c.age}; //d为新表，c.sex为分组字段

5、过滤重复记录

var query=(from c in dc.student select new {c.place}).Distinct();//Distinct()的作用是过滤重复的记录。
var query=(from c in dc.student select new {分布地区=c.place}).Distinct();

6、查询行数

（1）查询表的总行数

int count=student.count();

(2)查询满足条件的行数

int count=(from c in student where c.name=="王明" select c).count();

7、模糊查询

from c in dc.Student where c.name.Contain("王") select c

查询姓名中含有王字的所有学生

复制代码 代码如下:
var query=from c in dc.Student where c.number.Contain("2009") select c

查询学号中含有2009字符的所有学生

查询结果

LINQ的查询结果有可能是一个对象，也有可能是一个数据集，可用var类型进行接收

如：

var query=from c in Student select c;

输入结果可用foreach循环

如：

var query=from c in Student select c;
foreach( var x in query)
{ Response.Write(x.toString());}

常用函数

Count( )：计算查询结果的行数
Distinct( )：对查询结果的重复行进行筛选
First( )：取得查询结果的第一行
Last( )：取得查询结果的最后一行
Take(n)：取得查询结果的前n行
Skip(n)：略过前n行,从n+1行开始取
Skip(m).Take(n)：从m+1行开始取后面的n行

8、更新操作

思路：先把需要更新的行查询出来，然后进行更新。LINQ只需要写出查询语句即可，不需要写更新语句！

例：将学生表中学号为00001的学生进行更新

1、(from c in Stuent where c.id=="00001" select c).First();

在数据空间中显示数据查询结果：

前两行是连接数据库，其中第一中，经常用，可以放到最开始，这样就不必每次用到时都写了。

studentDataContext dc = new studentDataContext();
//注意：xxxDataContext需要与.dbml的文件名一致
var query=from c in dc.student select c;
GridView1.DataSource=query;
GridView1.DataBind();

更新操作

string num = TextBox2.Text.Trim(); //将要更新学号为多少的相关信息
string name = TextBox3.Text.Trim();//更新的姓名
int age = Convert.ToInt32(TextBox4.Text.Trim());//Int32整型 //更新的年龄
StudentDataContext dc=new StudentDataContext();
student stu=(from c in dc.student where c.number==num select c).First();//变量，选取第一行。where后根据主键来更新，其他字段不能。即通过获取主键后，来更新其他字段。
//除过主键不修改外，其他字段都可以修改
stu.name = name;//将新修改的名字赋值给数据库中的字段名name
stu.age = age;//修改年龄
dc.SubmitChanges();//真正的用于修改数据库。
bind();//一更改，就显示，和及时刷新相同。


private void bind()
{
studentDataContext dc = new studentDataContext();
 var query = (from c in dc.student select c); //全表查询
 GridView1.DataSource = query;
 GridView1.DataBind();
}

9、插入操作

//插入
string num = TextBox1.Text.Trim();
string username = TextBox2.Text.Trim();
string sex = TextBox3.Text.Trim();
string place = TextBox4.Text.Trim();
int age = Convert.ToInt32(TextBox5.Text.Trim());
student stu = new student();//创建对象
//赋新值
//主键不能重复
stu.number = num;
stu.name = username;
stu.sex = sex;
stu.place = place;
stu.age = age;
dc.student.InsertOnSubmit(stu);
//对表studen表进行插入操作。
//注意，该函数必须写正确。
dc.SubmitChanges();//数据库保存
bind();//内容和上面的相同

10、数据删除

string num = TextBox6.Text.Trim();
student stu =(from c in dc.student where c.number == num select c).First();
dc.student.DeleteOnSubmit(stu);
//删除数据库中的字段，具体怎样删除不管，只管调用该函数即可。
dc.SubmitChanges();
bind();

更多关于asp.net相关内容感兴趣的读者可查看本站专题：《asp.net字符串操作技巧汇总》、《asp.net操作XML技巧总结》、《asp.net文件操作技巧汇总》、《asp.net ajax技巧总结专题》及《asp.net缓存操作技巧总结》。

希望本文所述对大家asp.net程序设计有所帮助。

您可能感兴趣的文章:

c# – 使用LINQ to MySQL(DbLinq)和动态LINQ的可排序JqGrid – Orderby不起作用

c# – 使用LINQ to MySQL(DbLinq)和动态LINQ的可排序JqGrid – Orderby不起作用

我在Jqgrid中排序条目时遇到问题. Orderby似乎不起作用.我在代码中设置了断点,我注意到,orderby不会改变元素的顺序.知道什么可能是错的吗？

我正在使用LINQ to sql with MySQL(DbLinq项目).

我的行动代码：

public ActionResult All(string sidx,string sord,int page,int rows)
        {
            var tickets = ZTRepository.GetAllTickets().OrderBy(sidx + " " + sord).ToList();
            var rowdata = (
                from ticket in tickets
                select new {
                    i = ticket.ID,cell = new String[] {
                        ticket.ID.ToString(),ticket.Hardware,ticket.Issue,ticket.IssueDetails,ticket.RequestedBy,ticket.AssignedTo,ticket.Priority.ToString(),ticket.State
                    }
                }).ToArray();

            var jsonData = new
            {
                total = 1,// we'll implement later 
                page = page,records = tickets.Count(),rows = rowdata
            };

            return Json(jsonData,JsonRequestBehavior.AllowGet);
        }

解决方法

尝试以下方法 

public ActionResult All(string sidx,int rows)
{
    IQueryable<Ticket> repository = ZTRepository.GetAllTickets();
    int totalRecords = repository.Count();

    // first sorting the data as IQueryable<Ticket> without converting ToList()
    IQueryable<Ticket> orderdData = repository;
    System.Reflection.PropertyInfo propertyInfo =
        typeof(Ticket).GetProperty (sidx);
    if (propertyInfo != null) {
        orderdData = String.Compare(sord,"desc",StringComparison.Ordinal) == 0 ?
            (from x in repository
             orderby propertyInfo.GetValue (x,null) descending
             select x) :
            (from x in repository
             orderby propertyInfo.GetValue (x,null)
             select x);
    }
    // if you use fields instead of properties,then one can modify the code above
    // to the following
    // System.Reflection.FieldInfo fieldInfo =
    //         typeof(Ticket).GetField (sidx);
    // if (fieldInfo != null) {
    //  orderdData = String.Compare(sord,StringComparison.Ordinal) == 0 ?
    //      (from x in repository
    //       orderby fieldInfo.GetValue (x,null) descending
    //       select x) :
    //      (from x in repository
    //       orderby fieldInfo.GetValue (x,null)
    //       select x);
    //}

    // paging of the results
    IQueryable<Ticket> pagedData = orderdData
        .Skip ((page > 0? page - 1: 0) * rows)
        .Take (rows);

    // Now the select statement with both sorting and paging is prepared
    // and we can get the data
    var rowdata = ( from ticket in tickets
                    select new {
                        id = ticket.ID,cell = new String[] {
                            ticket.ID.ToString(),ticket.State
                        }
                    }).ToList();                

    var jsonData = new {
        total = page,records = totalRecords,total = (totalRecords + rows - 1) / rows,rows = pagedData
    };

    return Json(jsonData,JsonRequestBehavior.AllowGet);
}

在这里,我假设您的票证对象的类型是Ticket.

关于使用Linq to SQL进行多线程的问题我们已经讲解完毕，感谢您的阅读，如果还想了解更多关于.net – 使用Linq To SQL进行多个SubmitChanges和事务回滚、asp.net-mvc – 如果使用LINQ to SQL,还有什么理由学习SQL查询/语法吗？、asp.net使用LINQ to SQL连接数据库及SQL操作语句用法分析、c# – 使用LINQ to MySQL(DbLinq)和动态LINQ的可排序JqGrid – Orderby不起作用等相关内容，可以在本站寻找。

本文标签：

上一篇MS Access SQL，更改数据类型（修改sql数据类型）

下一篇计算外环的角度PostGIS（多边形和多面体）（求外环的面积公式）

相关文章