这是有效的代码:
Connection c = ds.getConnection();
c.setAutoCommit(false);
PreparedStatement stmt = c.prepareStatement("INSERT INTO items (name, description) VALUES(?, ?)");
while (!(items = bus.take()).isEmpty()) {
for (Item item : items) {
stmt.setString(1, item.name);
stmt.setString(2, item.description);
stmt.addBatch();
}
stmt.executeBatch();
c.commit();
}
但现在我需要填充另一个表,其中 id 是外键。如果我将 INSERT 与RETURNING id
then一起使用,则executeBatch
失败并出现“预期没有结果时返回结果”错误。
我看到了几种解决这个问题的方法
- 进行单独插入而不是批量插入。
- 用客户端生成的 guid 替换序列号。
- 使用某种存储过程来执行批量插入并返回一个 id 列表。
在我看到的三种方法中,最后一种似乎保留了批量插入和返回 id 的效率,但它对我来说也是最复杂的,因为我从未编写过存储过程。
有没有更好的方法来批量插入和获取 ID?我使用 postgresql 特定的 API 而不是 jdbc 没有问题。
如果没有,任何人都可以画出这样一个存储过程吗?
这是表架构:
CREATE UNLOGGED TABLE items
(
id serial,
name character varying(1000),
description character varying(10000)
)
WITH (
OIDS=FALSE
);