0

编辑：

我正在使用 Fluent NHibernate、NHibernate 和 Oracle DB 所以我正在进行的测试如下：

    [Test]
    public void CanIInsertLargeVolumesOfDataToOracleInUnder5Mins()
    {
        var stopwatch = new Stopwatch();
        stopwatch.Start();
        var entities = GetEntities();

        using (var session = UnitOfStatelessWork.GetUnderlyingSession())
        {
            using (var transaction = session.BeginTransaction(IsolationLevel.ReadCommitted))
            {
                foreach (var entity in entities.Select(entity => new EntityObject(entity) {SomeProperty = 19675464.25M}))
                {
                    session.Insert(entity);
                }

                transaction.Commit();
            }
        }

        stopwatch.Stop();
        var time = stopwatch.Elapsed;
        Assert.IsTrue(time < TimeSpan.FromMinutes(5.0));
    }

我的连接字符串如下所示：

<connectionStrings>
  <add connectionString="Data Source=(DESCRIPTION=(ADDRESS_LIST=(ADDRESS=(PROTOCOL=TCP)(HOST=myhost)(PORT=1521)))(CONNECT_DATA=(SERVER=DEDICATED)(SERVICE_NAME=some.service.com)));User ID=user;Password=user" name="OracleConnection" providerName="Oracle.DataAccess.Client" />
</connectionStrings>

对于 SQL Server，我有以下流畅的配置：

var fluentConfiguration = Fluently
            .Configure()
            .Database(MsSqlConfiguration.MsSql2005.ConnectionString(c => c.Is(connStr)))
            .Mappings(m => m.FluentMappings.AddFromAssembly(mappingAssembly));
        fluentConfiguration.ExposeConfiguration(f =>
                                                    {
                                                        f.SetProperty("generate_statistics", "false");
                                                        f.SetProperty("command_timeout", "60");
                                                        f.SetListener(ListenerType.PreInsert, new AuditEventListener());
                                                        f.SetListener(ListenerType.PreUpdate, new AuditEventListener());
                                                        f.SetProperty("adonet.batch_size", "1");
                                                        f.SetProperty("hibernate.order_inserts", "true");
                                                        f.SetProperty("hibernate.order_updates", "true");
                                                    });

然后对于甲骨文：

var fluentConfiguration = Fluently
            .Configure()
            .Database(OracleClientConfiguration.Oracle10.AdoNetBatchSize(1000).ConnectionString(c => c.Is(connStr)))
            .Mappings(m => m.FluentMappings.AddFromAssembly(mappingAssembly));
        fluentConfiguration.ExposeConfiguration(f =>
                                                    {
                                                        f.SetProperty("generate_statistics", "false");
                                                        f.SetProperty("command_timeout", "60");
                                                        f.SetProperty("hibernate.connection.driver_class", "NHibernate.Driver.OracleDataClientDriver");
                                                        f.SetListener(ListenerType.PreInsert, new AuditEventListener());
                                                        f.SetListener(ListenerType.PreUpdate, new AuditEventListener());
                                                        f.SetProperty("hibernate.order_inserts", "true");
                                                        f.SetProperty("hibernate.order_updates", "true");
                                                    });

然后我对两个数据库使用无状态会话和批处理，大约可以在 SQL DB 中插入 750000 条记录。100 秒。

在 Oracle 中，相同的测试大约需要 12 分钟。

有人看到我没有看到的任何重大错误吗？

4

1 回答 1

0
  • 无状态会话不使用批处理
  • 当您覆盖批量大小时SetProperty("adonet.batch_size", "1")

所以批处理与它无关。我们没有足够的信息来说明您的代码如何进行插入以进一步帮助您。

我的建议是您使用 .net 分析器来确定时间花在哪里。

于 2012-06-15T02:03:18.013 回答