NHibernate系列文章十三：NHibernate批量更新

摘要

對於批量插入和批量修改數據，通過設置NHibernate配置文件的BatchSize屬性，可以大量減少NHibernate與數據庫交互的次數。

1. Batch屬性介紹

設置了BatchSize屬性后，NHibernate將對批量的Insert/Update操作進行自動分組，按分組提交到數據庫，大量減少了與數據庫交互的次數。

NHibernate目前只支持對SQL Server數據庫和Oracle數據庫的批量Insert/Update操作進行BatchSize優化。

對於Insert操作，NHibernate只能對主鍵數據類型是UNIQUEIDENTIFIER的表提供BatchSize優化。

1）IDENTITY類型主鍵

在上一篇文章中，Customer表主鍵類型是IDENTITY類型的。

程序演示

修改SessionFactory屬性，添加x.BatchSize = 10的配置。

        public static ISessionFactory SessionFactory
        {
            get
            {
                if (_sessionFactory == null)
                {
                    var cfg = new Configuration();
                    cfg.DataBaseIntegration(x=> {
                        x.BatchSize = 10;
                    });
                    cfg.Configure();
                    _sessionFactory = cfg.BuildSessionFactory();
                }
                return _sessionFactory;
            }
        }

修改Main函數

        static void Main(string[] args)
        {
            HibernatingRhinos.Profiler.Appender.NHibernate.NHibernateProfiler.Initialize();

            using (var session = SessionFactory.OpenSession())
            {
                for (int i = 0; i < 25; i++)
                {
                    var customer = new Customer
                    {
                        FirstName = "FirstName" + i,
                        LastName = "LastName" + i,
                        MemberSince = new DateTime(2012, 1, 1)
                    };
                    session.Save(customer);
                }
                session.Flush();
                Console.WriteLine("fetch the complete list");
                var list = session.CreateCriteria<Customer>().List<Customer>();
                foreach (Customer customer in list)
                {
                    Console.WriteLine("{0} {1}", customer.FirstName,customer.LastName);
                }
            }

            Console.WriteLine("Completed");
            Console.ReadLine();
        }

打開NHibernate Profile，清空Session，執行程序，得到結果

監控到NHibernate執行了26次SQL語句，25次Insert語句和1次Select語句。

這是因為，雖然配置了BatchSize=10，但是Customer表的主鍵列的生成策略是Identity，每次Insert操作完成后都要計算下一條新記錄的主鍵值，因此BatchSize沒辦法對其進行分組優化。

選擇一條Insert監控數據，在Detail欄中看到執行了select SCOP_IDENTITY()語句。

2）UNIQUEIDENTIFIER類型主鍵

刪除Customer表，用UNIQUEIDENTIFIER主鍵重建Customer表。

重建Customer表的SQL語句。

CREATE TABLE [dbo].[Customer](
    --[Id] [int] IDENTITY(1,1) NOT NULL,
    Id UNIQUEIDENTIFIER NOT NULL,  4     [FirstName] [nvarchar](100) NOT NULL,
    [LastName] [nvarchar](100) NOT NULL,
    [Points] [int] NULL,
    [HasGoldStatus] [bit] NULL,
    [MemberSince] [date] NULL,
    [CreditRating] [nchar](20) NULL,
    [AverageRating] [decimal](18, 4) NULL,
    [Street] [nvarchar](100) NULL,
    [City] [nvarchar](100) NULL,
    [Province] [nvarchar](100) NULL,
    [Country] [nvarchar](100) NULL,
 CONSTRAINT [PK_Customer] 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]

修改Customer類，Id屬性類型改成了Guid。

    public class Customer
    {
        public virtual Guid Id { get; set; }  4         public virtual string FirstName { get; set; }
        public virtual string LastName { get; set; }
        public virtual double AverageRating { get; set; }
        public virtual int Points { get; set; }
        public virtual bool HasGoldStatus { get; set; }
        public virtual DateTime MemberSince { get; set; }
        public virtual CustomerCreditRating CreditRating { get; set; }
        public virtual string Street { get; set; }
        public virtual string City { get; set; }
        public virtual string Province { get; set; }
        public virtual string Country { get; set; }
    }

修改Customer.hbm.xml文件，將Id的generator class改成了guid.comb。

<?xml version="1.0" encoding="utf-8" ?>
<hibernate-mapping xmlns="urn:nhibernate-mapping-2.2" assembly="NHibernateDemoApp" namespace="NHibernateDemoApp">
  <class name="Customer" table="Customer">
    <id name="Id">
      <generator class="guid.comb"/>
    </id>
    <property name="FirstName" not-null="true"/>
    <property name="LastName" not-null ="true"/>
    <property name="AverageRating"/>
    <property name="Points"/>
    <property name="HasGoldStatus"/>
    <property name="MemberSince"/>
    <property name="CreditRating" type="CustomerCreditRating"/>
    <property name="Street"/>
    <property name="City"/>
    <property name="Province"/>
    <property name="Country"/>
  </class>
</hibernate-mapping>

清空NHibernate Profile的Session，執行程序，得到結果。

NHibernate只與數據庫交互了四次，三次Insert，一次Select。因為表的主鍵類型是UNIQUEIDENTIFIER，每次Insert記錄時NHibernate自動生成新記錄主鍵值，不需要數據庫計算下一條記錄的主鍵值。

設置了BatchSize=10，NHibernate將25次Insert操作自動分成三組，第一組10條Insert語句，第二組10條Insert語句，第三組5條Insert語句，再加上最后的一次查詢語句，一共是4次與數據庫交互。