Linq2Sql过了一会儿就慢了下来
本文关键字:过了 一会儿 Linq2Sql | 更新日期: 2023-09-27 18:21:31
在一个更大的项目中,我们决定在web服务(WCF)中使用Linq2Sql。我们"很快"发现,在添加了一些数据后(通过一个导入客户数据的小型控制台应用程序),网络服务的速度明显减慢了——在该应用程序的使用寿命内。
每次我们重新启动应用程序时,它一开始似乎导入数据很快,导入10-15分钟后速度就会减慢。
我决定尝试创建一个示例应用程序,模仿我们主应用程序的小部分。
- 我必须补充一点,我们决定在web服务中省略Linq2Sql,用reqularsqlcommand/SqlConnection等替换它们
有人知道应用程序速度减慢可能是什么原因吗?
以下是模拟一些数据库查询的"最小化"应用程序的代码:
包括SQL语句的应用程序来创建表:
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
namespace Linq2SqlTest
{
class Program
{
/*
* USE [Linq2SqlTest]
GO
SET ANSI_NULLS ON
GO
SET QUOTED_IDENTIFIER ON
GO
CREATE TABLE [dbo].[Adresse](
[id] [int] IDENTITY(1,1) NOT NULL,
[person_id] [int] NOT NULL,
[Gate] [nvarchar](50) NOT NULL,
[Poststed] [nvarchar](50) NOT NULL,
[By] [nvarchar](50) NOT NULL,
CONSTRAINT [PK_Adresse] PRIMARY KEY CLUSTERED
(
[id] ASC
)WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) ON [PRIMARY]
) ON [PRIMARY]
GO
ALTER TABLE [dbo].[Adresse] WITH CHECK ADD CONSTRAINT [FK_Adresse_Person1] FOREIGN KEY([person_id])
REFERENCES [dbo].[Person] ([id])
GO
ALTER TABLE [dbo].[Adresse] CHECK CONSTRAINT [FK_Adresse_Person1]
*
*
* USE [Linq2SqlTest]
GO
SET ANSI_NULLS ON
GO
SET QUOTED_IDENTIFIER ON
GO
CREATE TABLE [dbo].[Items](
[ItemID] [int] IDENTITY(1,1) NOT NULL,
[ItemNumber] [nchar](10) NOT NULL,
[PersonID] [int] NOT NULL,
[name] [nvarchar](50) NULL,
CONSTRAINT [PK_Items] PRIMARY KEY CLUSTERED
(
[ItemID] ASC
)WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) ON [PRIMARY]
) ON [PRIMARY]
GO
ALTER TABLE [dbo].[Items] WITH CHECK ADD CONSTRAINT [FK_Items_Person] FOREIGN KEY([PersonID])
REFERENCES [dbo].[Person] ([id])
GO
ALTER TABLE [dbo].[Items] CHECK CONSTRAINT [FK_Items_Person]
*
* USE [Linq2SqlTest]
GO
SET ANSI_NULLS ON
GO
SET QUOTED_IDENTIFIER ON
GO
CREATE TABLE [dbo].[Person](
[id] [int] IDENTITY(1,1) NOT NULL,
[name] [nvarchar](50) NOT NULL,
[AddedDate] [datetime] NOT NULL,
[ssn] [nvarchar](50) NOT NULL,
CONSTRAINT [PK_Person] PRIMARY KEY CLUSTERED
(
[id] ASC
)WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) ON [PRIMARY]
) ON [PRIMARY]
*/
public static Random randomizer = new Random();
public static String GenerateName()
{
int nLetterCount = (randomizer.Next() % 5) + 3;
String s = "";
for (int i = 0; i < nLetterCount;i++)
{
int r = (randomizer.Next() % 26)+97;
s += Convert.ToChar(r);
}
return s;
}
public static String GenerateFullname()
{
String Fullname = "";
int nNameCount = randomizer.Next() % 3;
nNameCount++;
while (nNameCount>0)
{
if (Fullname.Length == 0)
Fullname = GenerateName();
else
Fullname += " " + GenerateName();
nNameCount--;
}
return Fullname;
}
static void Main(string[] args)
{
DatabaseDataContext db = new DatabaseDataContext();
for (int i = 0; i < 300000;i++ )
{
int personid = randomizer.Next() % 100;
Person p = db.Persons.FirstOrDefault(_p=> _p.ssn == personid.ToString());
if (p == null)
{
p = new Person();
p.name = GenerateFullname();
p.ssn = personid.ToString();
p.AddedDate = DateTime.Now;
db.Persons.InsertOnSubmit(p);
db.SubmitChanges();
Adresse a = new Adresse();
a.person_id = p.id;
a.Gate = GenerateFullname();
a.Poststed = GenerateName();
a.By = GenerateName();
db.Adresses.InsertOnSubmit(a);
db.SubmitChanges();
int jj = randomizer.Next() % 10 + 1;
for (int j = 0; j < jj; j++)
{
Item item = new Item();
item.ItemNumber = randomizer.Next().ToString();
item.PersonID = p.id;
db.Items.InsertOnSubmit(item);
db.SubmitChanges();
}
}
else
{
int jj = randomizer.Next() % 10 + 1;
for (int j = 0; j < jj; j++)
{
int number = randomizer.Next();
Item item = db.Items.FirstOrDefault(_i => _i.ItemNumber == number.ToString());
if (item == null)
{
item = new Item();
item.ItemNumber = number.ToString();
item.PersonID = p.id;
db.Items.InsertOnSubmit(item);
}
else
{
item.ItemNumber = randomizer.Next().ToString();
}
db.SubmitChanges();
}
}
Console.WriteLine("'r" + i + " ");
}
}
}
}
您使用的是单个数据上下文。数据上下文包括:
- 身份管理器
- 变化跟踪器
这意味着你接触的物体越多,它就越胖。它越胖,每次要做的工作就越多。而且速度越慢。
数据上下文的保存时间不要超过您的需要;例如,一个工作单元应该是一个非常小而谨慎的单元。
然后启动AFRESH
由于L2S实现了IDisposable
,您还应该确保处理您使用的每个数据上下文。
我在正在开发的应用程序上看到了类似的行为。在我的案例中,原因是SQL服务器消耗了大量内存。
如果您在类似的设置中运行(1台带有客户端、SQL server、visual studio的机器),请查看计算机上的内存使用情况(进程资源管理器,添加虚拟大小列并按其排序)。如果您看到速度减慢与虚拟大小之间存在相关性-->请将您的计算机增加一些RAM,或者清理不必要的进程。
BTW-如果关于数据上下文的答案与您的案例相关,那么首先解决该问题。
在使用预编译的LINQ语句调用只返回1个或几个项的Linq2SQl函数时,我看到了一些重大改进。
欲了解更多信息,请查看此帖子http://www.foliotek.com/devblog/unexpected-benefits-of-precompilation-of-linq/
我发现了如何解决这个问题。一些数据已经"预加载"(延迟加载?),并且这并没有被禁用。因此,如果你想控制LINQ应该做什么,而不是"幕后",你应该禁用这个功能。
DatabaseContext.DeferredLoadingEnabled = false;
新手失误,伤心地说:-|