12

在分区的 postgresql 表中是否有通过休眠进行批量插入的解决方案？目前我遇到这样的错误......

ERROR org.hibernate.jdbc.AbstractBatcher - Exception executing batch:
org.hibernate.StaleStateException: Batch update returned unexpected row count from update [0]; actual row count: 0; expected: 1
   at org.hibernate.jdbc.Expectations$BasicExpectation.checkBatched(Expectations.java:61)
   at org.hibernate.jdbc.Expectations$BasicExpectation.verifyOutcome(Expectations.java:46)
   at org.hibernate.jdbc.BatchingBatcher.checkRowCounts(BatchingBatcher.java:68)....

我找到了这个链接http://lists.jboss.org/pipermail/hibernate-dev/2007-October/002771.html但我在网上找不到任何地方解决这个问题或如何解决它

4

6 回答 6

4

您可能想通过设置 hibernate.jdbc.factory_class 属性来尝试使用自定义 Batcher。确保 hibernate 不会检查批处理操作的更新计数可能会解决您的问题，您可以通过使自定义 Batcher 扩展类 BatchingBatcher 来实现这一点，然后覆盖方法 doExecuteBatch(...) 看起来像：

    @Override
    protected void doExecuteBatch(PreparedStatement ps) throws SQLException, HibernateException {
        if ( batchSize == 0 ) {
            log.debug( "no batched statements to execute" );
        }
        else {
            if ( log.isDebugEnabled() ) {
                log.debug( "Executing batch size: " + batchSize );
            }

            try {
//              checkRowCounts( ps.executeBatch(), ps );
                ps.executeBatch();
            }
            catch (RuntimeException re) {
                log.error( "Exception executing batch: ", re );
                throw re;
            }
            finally {
                batchSize = 0;
            }

        }

    }

请注意，新方法不检查执行准备好的语句的结果。请记住，进行此更改可能会以某种意想不到的方式（或者可能不会）影响休眠。

于 2008-09-18T04:31:51.630 回答
2

谢谢！它成功了，到目前为止没有出现任何问题:)....你有一件事...我必须实现BatcherFactory类并将其放入persistence.xml文件中，如下所示：

property name="hibernate.jdbc.factory_class" value="path.to.my.batcher.factory.implementation"

从那个工厂，我用上面的代码调用了我的批处理器实现

ps休眠核心3.2.6 GA

再次感谢

于 2008-09-18T12:22:02.030 回答
2

他们说在分区表或@SQLInsert 注释中使用两个触发器：http ://www.redhat.com/f/pdf/jbw/jmlodgenski_940_scaling_hibernate.pdf第 21-26 页（它还提到了一个指定字符串的 @SQLInsert方法）。

这是一个带有后触发器的示例，用于删除 master 中的额外行：https ://gist.github.com/copiousfreetime/59067

于 2010-05-25T14:05:07.503 回答
2

如果您可以使用 RULES 而不是用于插入的触发器，那么它可以返回正确的数字，但只能使用没有 WHERE 语句的单个 RULE。

参考1

参考2

参考文献3

另一种选择可能是创建一个“包装”分区表的视图，然后返回新行以指示成功的行更新，而不会意外向主表添加额外的不需要的行。 

create view tablename_view as select * from tablename; -- create trivial wrapping view

CREATE OR REPLACE FUNCTION partitioned_insert_trigger() -- partitioned insert trigger
RETURNS TRIGGER AS $$
BEGIN
   IF (NEW.partition_key>= 5500000000 AND
       NEW.partition_key <  6000000000) THEN
      INSERT INTO tablename_55_59 VALUES (NEW.*);
   ELSIF (NEW.partition_key >= 5000000000 AND
          NEW.partition_key <  5500000000) THEN
      INSERT INTO tablename_50_54 VALUES (NEW.*);
   ELSIF (NEW.partition_key >= 500000000 AND
          NEW.partition_key  <  1000000000) THEN
      INSERT INTO tablename_5_9 VALUES (NEW.*);
   ELSIF (NEW.partition_key >= 0 AND
          NEW.partition_key <  500000000) THEN
      INSERT INTO tablename_0_4 VALUES (NEW.*);
   ELSE
      RAISE EXCEPTION 'partition key is out of range.  Fix the trigger function';
   END IF;
   RETURN NEW; -- RETURN NEW in this case, typically you'd return NULL from this trigger, but for views we return NEW
END;
$$
LANGUAGE plpgsql;

CREATE TRIGGER insert_view_trigger
   INSTEAD OF INSERT ON tablename_view
   FOR EACH ROW EXECUTE PROCEDURE partitioned_insert_trigger(); -- create "INSTEAD OF" trigger

参考：http ://www.postgresql.org/docs/9.2/static/trigger-definition.html

如果您使用视图包装器路线，则一种选择是也为删除和更新定义简单的“而不是”触发器，那么您可以在所有事务中使用视图表的名称代替普通表。

使用视图的另一个选项是创建一个插入规则，以便主表上的任何插入都转到视图[使用其触发器]，例如（假设您已经partitioned_insert_trigger创建了上面列出的 tablename_view 和 insert_view_trigger）

create RULE use_right_inserter_tablename AS
      ON INSERT TO tablename
      DO INSTEAD insert into tablename_view VALUES (NEW.*);

然后它将使用您的新工作视图包装插入。

于 2014-09-30T14:45:33.000 回答
0

在经过大量搜索后，我在通过休眠插入文档时遇到了同样的问题，发现它期望应该返回更新的行，因此在触发器过程中将其更改为新的而不是 null，这将解决问题，如下所示

返回新

于 2017-05-02T06:16:31.760 回答
0

我在这个网页上找到了同样问题的另一个解决方案：

这暗示了@rogerdpack 所说的相同解决方案，将Return Null更改为Return NEW，并添加一个新触发器，该触发器使用查询删除 master 中的重复元组：

DELETE FROM ONLY master_table;
于 2018-10-03T12:57:29.733 回答