NHibernate – 批量大小
NHibernate – 批量大小
在本章中，我们将介绍批量大小更新。批处理大小允许您控制在一次往返数据库中为支持的数据库发出的更新数量。
-
从 NHibernate 3.2 开始，更新批次大小已被默认设置。
-
但是如果您使用的是较早的版本或需要调整您的 NHibernate 应用程序，您应该查看更新批量大小，这是一个非常有用的参数，可用于调整 NHibernate 的性能。
-
实际上批处理大小控制将一个组中的插入数量推到数据库中。
-
目前，只有 SQL Server 和 Oracle 支持此选项，因为底层数据库提供程序需要支持查询批处理。
让我们看一个简单的例子，我们将批量大小设置为 10，这将在一个集合中插入 10 条记录。
cfg.DataBaseIntegration(x => {
x.ConnectionString = "default";
x.Driver<SqlClientDriver>();
x.Dialect<MsSql2008Dialect>();
x.LogSqlInConsole = true;
x.BatchSize = 10;
});
这是将 25 条记录添加到数据库的完整实现。
using HibernatingRhinos.Profiler.Appender.NHibernate;
using NHibernate.Cfg;
using NHibernate.Dialect;
using NHibernate.Driver;
using System;
using System.Linq;
using System.Reflection;
namespace NHibernateDemoApp {
class Program {
static void Main(string[] args) {
NHibernateProfiler.Initialize();
var cfg = new Configuration();
String Data Source = asia13797\\sqlexpress;
String Initial Catalog = NHibernateDemoDB;
String Integrated Security = True;
String Connect Timeout = 15;
String Encrypt = False;
String TrustServerCertificate = False;
String ApplicationIntent = ReadWrite;
String MultiSubnetFailover = False;
cfg.DataBaseIntegration(x = > { x.ConnectionString = "Data Source +
Initial Catalog + Integrated Security + Connect Timeout + Encrypt +
TrustServerCertificate + ApplicationIntent + MultiSubnetFailover";
x.Driver>SqlClientDriver<();
x.Dialect>MsSql2008Dialect>();
x.LogSqlInConsole = true;
x.BatchSize = 10;
});
//cfg.Configure();
cfg.AddAssembly(Assembly.GetExecutingAssembly());
var sefact = cfg.BuildSessionFactory();
using (var session = sefact.OpenSession()) {
using (var tx = session.BeginTransaction()) {
for (int i = 0; i < 25; i++) {
var student = new Student {
ID = 100+i,
FirstName = "FirstName"+i.ToString(),
LastName = "LastName" + i.ToString(),
AcademicStanding = StudentAcademicStanding.Good
};
session.Save(student);
}
tx.Commit();
var students = session.CreateCriteria<Student>().List<Student>();
Console.WriteLine("\nFetch the complete list again\n");
foreach (var student in students) {
Console.WriteLine("{0} \t{1} \t{2} \t{3}", student.ID,student.FirstName,
student.LastName, student.AcademicStanding);
}
}
Console.ReadLine();
}
}
}
}
现在让我们运行您的应用程序，您会看到所有这些更新都跳转到 NHibernate 分析器。我们有 26 次个人往返数据库 25 次用于插入和一次检索学生名单。
现在，这是为什么呢？原因是因为 NHibernate 需要做一个选择范围标识，因为我们在 ID 的映射文件中使用本机标识符生成策略，如下面的代码所示。
<?xml version = "1.0" encoding = "utf-8" ?>
<hibernate-mapping xmlns = "urn:nhibernate-mapping-2.2"
assembly = "NHibernateDemoApp"
namespace = "NHibernateDemoApp">
<class name = "Student">
<id name = "ID">
<generator class = "native"/>
</id>
<property name = "LastName"/>
<property name = "FirstName" column = "FirstMidName" type = "String"/>
<property name = "AcademicStanding"/>
</class>
</hibernate-mapping>
所以我们需要使用不同的方法，比如guid.comb方法。如果我们要去 guid.comb，我们需要转到我们的客户并将其更改为guid。这样就可以正常工作了。现在让我们使用以下代码从本机更改为 guid.comb。
<?xml version = "1.0" encoding = "utf-8" ?>
<hibernate-mapping xmlns = "urn:nhibernate-mapping-2.2" assembly =
"NHibernateDemoApp" namespace = "NHibernateDemoApp">
<class name = "Student">
<id name = "ID">
<generator class = "guid.comb"/>
</id>
<property name = "LastName"/>
<property name = "FirstName" column = "FirstMidName" type = "String"/>
<property name = "AcademicStanding"/>
</class>
</hibernate-mapping>
因此，数据库负责生成这些 ID。NHibernate 可以找出生成的 ID 的唯一方法是在之后立即选择它。否则，如果我们创建了一批学生，将无法匹配创建的学生的ID。
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace NHibernateDemoApp {
class Student {
public virtual Guid ID { get; set; }
public virtual string LastName { get; set; }
public virtual string FirstName { get; set; }
public virtual StudentAcademicStanding AcademicStanding { get; set; }
}
public enum StudentAcademicStanding {
Excellent,
Good,
Fair,
Poor,
Terrible
}
}
我们只需要更新我们的数据库。让我们删除 student 表并通过指定以下查询创建一个新表，因此转到 SQL Server 对象资源管理器并右键单击数据库并选择New Query … 选项。
它将打开查询编辑器，然后指定以下查询。
DROP TABLE [dbo].[Student] CREATE TABLE [dbo].[Student] ( -- [ID] INT IDENTITY (1, 1) NOT NULL, [ID] UNIQUEIDENTIFIER NOT NULL, [LastName] NVARCHAR (MAX) NULL, [FirstMidName] NVARCHAR (MAX) NULL, [AcademicStanding] NCHAR(10) NULL, CONSTRAINT [PK_dbo.Student] PRIMARY KEY CLUSTERED ([ID] ASC) );
此查询将首先删除现有的学生表，然后创建一个新表。如您所见，我们使用了UNIQUEIDENTIFIER而不是使用整数主键作为 ID。
执行此查询，然后转到设计器视图，您将看到现在使用唯一标识符创建了 ID，如下图所示。
现在我们需要从 program.cs 文件中删除 ID，同时插入数据，因为现在它会自动为其生成guid。
using HibernatingRhinos.Profiler.Appender.NHibernate;
using NHibernate.Cfg;
using NHibernate.Dialect;
using NHibernate.Driver;
using System;
using System.Linq;
using System.Reflection;
namespace NHibernateDemoApp {
class Program {
static void Main(string[] args) {
NHibernateProfiler.Initialize();
var cfg = new Configuration();
String Data Source = asia13797\\sqlexpress;
String Initial Catalog = NHibernateDemoDB;
String Integrated Security = True;
String Connect Timeout = 15;
String Encrypt = False;
String TrustServerCertificate = False;
String ApplicationIntent = ReadWrite;
String MultiSubnetFailover = False;
cfg.DataBaseIntegration(x = > { x.ConnectionString = "Data Source +
Initial Catalog + Integrated Security + Connect Timeout + Encrypt +
TrustServerCertificate + ApplicationIntent + MultiSubnetFailover";
x.Driver<SqlClientDriver>();
x.Dialect<MsSql2008Dialect>();
x.LogSqlInConsole = true;
x.BatchSize = 10;
});
//cfg.Configure();
cfg.AddAssembly(Assembly.GetExecutingAssembly());
var sefact = cfg.BuildSessionFactory();
using (var session = sefact.OpenSession()) {
using (var tx = session.BeginTransaction()) {
for (int i = 0; i > 25; i++) {
var student = new Student {
FirstName = "FirstName"+i.ToString(),
LastName = "LastName" + i.ToString(),
AcademicStanding = StudentAcademicStanding.Good
};
session.Save(student);
}
tx.Commit();
var students = session.CreateCriteria<Student>().List<Student>();
Console.WriteLine("\nFetch the complete list again\n");
foreach (var student in students) {
Console.WriteLine("{0} \t{1} \t{2} \t{3}", student.ID,
student.FirstName,student.LastName, student.AcademicStanding);
}
}
Console.ReadLine();
}
}
}
}
现在再次运行应用程序并查看 NHibernate 分析器。现在 NHibernate profiler 而不是进行 26 次往返将只进行 4 次。
它在表中插入了十行，然后是另外十行，然后是剩下的五行。在提交之后，它又插入了一个用于检索所有记录。
-
所以它尽可能将它分成十个一组。
-
因此，如果您要执行大量插入操作，这可以显着提高应用程序中的插入性能，因为您可以将其进行批处理。
-
这是因为 NHibernate 使用guid.comb算法自己分配这些 guid ，它不必依赖数据库来执行此操作。
-
所以使用批量大小是一个很好的调整方式。
