TIKA-4190 -- turn off autocommit (#1576)

apache · Feb 6, 2024 · c25ff4c · c25ff4c
1 parent c2df01c
commit c25ff4c
Showing 1 changed file with 13 additions and 1 deletion.
diff --git a/...tters/tika-emitter-jdbc/src/main/java/org/apache/tika/pipes/emitter/jdbc/JDBCEmitter.java b/...tters/tika-emitter-jdbc/src/main/java/org/apache/tika/pipes/emitter/jdbc/JDBCEmitter.java
@@ -304,7 +304,17 @@ private void emitNow(List<? extends EmitData> emitData) throws SQLException {
                 insertAll(d.getEmitKey().getEmitKey(), d.getMetadataList());
             }
         }
-        insertStatement.executeBatch();
+        if (LOGGER.isDebugEnabled()) {
+            long start = System.currentTimeMillis();
+            insertStatement.executeBatch();
+            connection.commit();
+            LOGGER.debug("took {}ms to insert {} rows ", System.currentTimeMillis() - start,
+                    emitData.size());
+        } else {
+            insertStatement.executeBatch();
+            connection.commit();
+        }
+
     }
 
     private void insertAll(String emitKey, List<Metadata> metadataList) throws SQLException {
@@ -361,6 +371,7 @@ private void tryClose() {
 
         if (connection != null) {
             try {
+                connection.commit();
                 connection.close();
             } catch (SQLException e) {
                 LOGGER.warn("exception closing connection", e);
@@ -370,6 +381,7 @@ private void tryClose() {
 
     private void createConnection() throws SQLException {
         connection = DriverManager.getConnection(connectionString);
+        connection.setAutoCommit(false);
         if (postConnectionString.isPresent()) {
             try (Statement st = connection.createStatement()) {
                 st.execute(postConnectionString.get());