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 + "   ");
            }
        }
    }
}

Linq2Sql过了一会儿就慢了下来

您使用的是单个数据上下文。数据上下文包括:

  • 身份管理器
  • 变化跟踪器

这意味着你接触的物体越多,它就越胖。它越胖,每次要做的工作就越多。而且速度越慢。

数据上下文的保存时间不要超过您的需要;例如,一个工作单元应该是一个非常小而谨慎的单元。

然后启动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;

新手失误,伤心地说:-|