diff --git a/airbyte-integrations/connectors/destination-jdbc/src/main/java/io/airbyte/integrations/destination/jdbc/SqlOperations.java b/airbyte-integrations/connectors/destination-jdbc/src/main/java/io/airbyte/integrations/destination/jdbc/SqlOperations.java index 1ec438e7fb89..b1f8c74984a9 100644 --- a/airbyte-integrations/connectors/destination-jdbc/src/main/java/io/airbyte/integrations/destination/jdbc/SqlOperations.java +++ b/airbyte-integrations/connectors/destination-jdbc/src/main/java/io/airbyte/integrations/destination/jdbc/SqlOperations.java @@ -20,7 +20,7 @@ *
  • Create - overloaded function but primarily to create tables if they don't exist (e.g. tmp tables to "stage" records before finalizing * to final table
  • *
  • Drop - removes a table from the schema
  • - *
  • Copy - move data from one table to another table - usually used for copying data from tmp to final table (aka airbyte_raw)
  • + *
  • Insert - move data from one table to another table - usually used for inserting data from tmp to final table (aka airbyte_raw)
  • * */ public interface SqlOperations { diff --git a/airbyte-integrations/connectors/destination-jdbc/src/main/java/io/airbyte/integrations/destination/staging/StagingConsumerFactory.java b/airbyte-integrations/connectors/destination-jdbc/src/main/java/io/airbyte/integrations/destination/staging/StagingConsumerFactory.java index 93edb21d89cd..94698125a923 100644 --- a/airbyte-integrations/connectors/destination-jdbc/src/main/java/io/airbyte/integrations/destination/staging/StagingConsumerFactory.java +++ b/airbyte-integrations/connectors/destination-jdbc/src/main/java/io/airbyte/integrations/destination/staging/StagingConsumerFactory.java @@ -196,7 +196,7 @@ private CheckedBiConsumerMigrating data stored in staging area to temporary tables *
  • Creates a final table (if one does not already exist)
  • - *
  • Copies all data from the temporary table into the final table
  • + *
  • Inserts all data from the temporary table into the final table
  • * * @param database database used for syncing * @param stagingOperations SQL queries used to write and delete data from the staging folder diff --git a/airbyte-integrations/connectors/destination-jdbc/src/main/java/io/airbyte/integrations/destination/staging/StagingOperations.java b/airbyte-integrations/connectors/destination-jdbc/src/main/java/io/airbyte/integrations/destination/staging/StagingOperations.java index 0d64468323b6..f73648fa7b74 100644 --- a/airbyte-integrations/connectors/destination-jdbc/src/main/java/io/airbyte/integrations/destination/staging/StagingOperations.java +++ b/airbyte-integrations/connectors/destination-jdbc/src/main/java/io/airbyte/integrations/destination/staging/StagingOperations.java @@ -69,7 +69,7 @@ void copyIntoTmpTableFromStage(JdbcDatabase database, * * @param database database used for syncing * @param stageName name of staging area folder - * @param stagedFiles collection of the staging files + * @param stagedFiles collection of the staging files to remove */ void cleanUpStage(JdbcDatabase database, String stageName, List stagedFiles) throws Exception;