Disable PostgreSQL autovacuum for staging table

Only drop staging table on incremental mode.
osalvador · Jan 10, 2019 · a6fd326 · a6fd326
1 parent 60dc7aa
commit a6fd326
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 8 deletions.
diff --git a/src/main/java/org/replicadb/manager/OracleManager.java b/src/main/java/org/replicadb/manager/OracleManager.java
@@ -56,9 +56,7 @@ else if (options.getSourceWhere() != null && !options.getSourceWhere().isEmpty()
                     escapeTableName(tableName) + " where ora_hash(rowid," + (options.getJobs() - 1) + ") = ?";
         }
 
-
-        LOG.debug("Reading table with command: " + sqlCmd);
-        return super.execute(sqlCmd, nThread);
+        return super.execute(sqlCmd, (Object) nThread);
     }
 
     private void oracleAlterSession(Boolean directRead) throws SQLException {

diff --git a/src/main/java/org/replicadb/manager/PostgresqlManager.java b/src/main/java/org/replicadb/manager/PostgresqlManager.java
@@ -183,7 +183,7 @@ protected void createStagingTable() throws SQLException {
         Statement statement = this.getConnection().createStatement();
         String sinkStagingTable = getQualifiedStagingTableName();
 
-        String sql = "CREATE UNLOGGED TABLE IF NOT EXISTS " + sinkStagingTable + " ( LIKE " + this.getSinkTableName() + " INCLUDING DEFAULTS INCLUDING CONSTRAINTS )";
+        String sql = "CREATE UNLOGGED TABLE IF NOT EXISTS " + sinkStagingTable + " ( LIKE " + this.getSinkTableName() + " INCLUDING DEFAULTS INCLUDING CONSTRAINTS ) WITH (autovacuum_enabled=false)";
 
         LOG.info("Creating staging table with this command: " + sql);
         statement.executeUpdate(sql);

diff --git a/src/main/java/org/replicadb/manager/SqlManager.java b/src/main/java/org/replicadb/manager/SqlManager.java
@@ -447,10 +447,15 @@ public void postSinkTasks() throws SQLException {
 
     @Override
     public void cleanUp() throws SQLException {
-        // Only drop staging table if it was created automatically
-        if (options.getSinkStagingTable() == null || options.getSinkStagingTable().isEmpty()) {
-            // Drop staging table
-            this.dropStagingTable();
+
+        // On INCREMENTAL mode
+        if (options.getMode().equals(ReplicationMode.INCREMENTAL.getModeText())) {
+
+            // Only drop staging table if it was created automatically
+            if (options.getSinkStagingTable() == null || options.getSinkStagingTable().isEmpty()) {
+                // Drop staging table
+                this.dropStagingTable();
+            }
         }
 
     }