Repository: activemq-artemis Updated Branches: refs/heads/1.x 512dbee13 -> 87c7e0582
ARTEMIS-930 Return the ID field on createFile statement (cherry picked from commit 0bcf003a870780136854ec2f2f238a2fb37501f0) Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/87c7e058 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/87c7e058 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/87c7e058 Branch: refs/heads/1.x Commit: 87c7e05820e916e9afe9f14ee03bcfcd91958edd Parents: 512dbee Author: Martyn Taylor <[email protected]> Authored: Fri Jan 20 12:13:24 2017 +0000 Committer: Martyn Taylor <[email protected]> Committed: Mon Mar 13 10:20:28 2017 +0000 ---------------------------------------------------------------------- .../artemis/jdbc/store/file/JDBCSequentialFileFactoryDriver.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/87c7e058/artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/file/JDBCSequentialFileFactoryDriver.java ---------------------------------------------------------------------- diff --git a/artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/file/JDBCSequentialFileFactoryDriver.java b/artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/file/JDBCSequentialFileFactoryDriver.java index 54e6965..cf8d39d 100644 --- a/artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/file/JDBCSequentialFileFactoryDriver.java +++ b/artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/file/JDBCSequentialFileFactoryDriver.java @@ -69,7 +69,7 @@ public class JDBCSequentialFileFactoryDriver extends AbstractJDBCDriver { @Override protected void prepareStatements() throws SQLException { this.deleteFile = connection.prepareStatement(sqlProvider.getDeleteFileSQL()); - this.createFile = connection.prepareStatement(sqlProvider.getInsertFileSQL(), Statement.RETURN_GENERATED_KEYS); + this.createFile = connection.prepareStatement(sqlProvider.getInsertFileSQL(), new String[] {"ID"}); this.selectFileByFileName = connection.prepareStatement(sqlProvider.getSelectFileByFileName()); this.copyFileRecord = connection.prepareStatement(sqlProvider.getCopyFileRecordByIdSQL()); this.renameFile = connection.prepareStatement(sqlProvider.getUpdateFileNameByIdSQL());
