Destination Teradata: make connector avaialble on Airbyte Cloud (airbytehq#28667)

Co-authored-by: SatishChGit <[email protected]>
Co-authored-by: evantahler <[email protected]>

Author: 3 people

airbyte-integrations/connectors/destination-teradata/metadata.yaml

@@ -2,20 +2,19 @@ data:
   connectorSubtype: database
   connectorType: destination
   definitionId: 58e6f9da-904e-11ed-a1eb-0242ac120002
-  dockerImageTag: 0.1.3
+  dockerImageTag: 0.1.5
   dockerRepository: airbyte/destination-teradata
   githubIssueLabel: destination-teradata
   icon: teradata.svg
   license: MIT
   name: Teradata Vantage
   registries:
     cloud:
-      enabled: false
+      enabled: true
     oss:
       enabled: true
   releaseStage: alpha
   documentationUrl: https://docs.airbyte.com/integrations/destinations/teradata
-  supportsDbt: true
   tags:
     - language:java
   ab_internal:

airbyte-integrations/connectors/destination-teradata/src/main/java/io/airbyte/integrations/destination/teradata/TeradataDestination.java

@@ -49,6 +49,10 @@ public class TeradataDestination extends AbstractJdbcDestination implements Dest
 
   protected static final String CA_CERT_KEY = "ssl_ca_certificate";
 
+  protected static final String ENCRYPTDATA = "ENCRYPTDATA";
+
+  protected static final String ENCRYPTDATA_ON = "ON";
+
   public static void main(String[] args) throws Exception {
     new IntegrationRunner(new TeradataDestination()).run(args);
   }
@@ -57,6 +61,12 @@ public TeradataDestination() {
     super(DRIVER_CLASS, new StandardNameTransformer(), new TeradataSqlOperations());
   }
 
+  private static void createCertificateFile(String fileName, String fileValue) throws IOException {
+    try (final PrintWriter out = new PrintWriter(fileName, StandardCharsets.UTF_8)) {
+      out.print(fileValue);
+    }
+  }
+
   @Override
   protected Map<String, String> getDefaultConnectionProperties(final JsonNode config) {
     final Map<String, String> additionalParameters = new HashMap<>();
@@ -69,15 +79,10 @@ protected Map<String, String> getDefaultConnectionProperties(final JsonNode conf
         additionalParameters.put(PARAM_SSLMODE, REQUIRE);
       }
     }
+    additionalParameters.put(ENCRYPTDATA, ENCRYPTDATA_ON);
     return additionalParameters;
   }
 
-  private static void createCertificateFile(String fileName, String fileValue) throws IOException {
-    try (final PrintWriter out = new PrintWriter(fileName, StandardCharsets.UTF_8)) {
-      out.print(fileValue);
-    }
-  }
-
   private Map<String, String> obtainConnectionOptions(final JsonNode encryption) {
     final Map<String, String> additionalParameters = new HashMap<>();
     if (!encryption.isNull()) {

airbyte-integrations/connectors/destination-teradata/src/main/java/io/airbyte/integrations/destination/teradata/TeradataSqlOperations.java

@@ -107,10 +107,10 @@ public void createTableIfNotExists(final JdbcDatabase database, final String sch
   @Override
   public String createTableQuery(final JdbcDatabase database, final String schemaName, final String tableName) {
     return String.format(
-        "CREATE SET TABLE %s.%s, FALLBACK ( \n" + "%s VARCHAR(256), \n" + "%s JSON, \n" + "%s TIMESTAMP(6) \n"
-            + ");\n",
+        "CREATE SET TABLE %s.%s, FALLBACK ( %s VARCHAR(256), %s JSON, %s TIMESTAMP(6)) " +
+            " UNIQUE PRIMARY INDEX (%s) ",
         schemaName, tableName, JavaBaseConstants.COLUMN_NAME_AB_ID, JavaBaseConstants.COLUMN_NAME_DATA,
-        JavaBaseConstants.COLUMN_NAME_EMITTED_AT);
+        JavaBaseConstants.COLUMN_NAME_EMITTED_AT, JavaBaseConstants.COLUMN_NAME_AB_ID);
   }
 
   @Override

airbyte-integrations/connectors/destination-teradata/src/test-integration/java/io/airbyte/integrations/destination/teradata/TeradataDestinationAcceptanceTest.java

@@ -179,6 +179,12 @@ public void testSecondSync() {
     // overrides test in coming releases
   }
 
+  @Override
+  @Test
+  public void testCustomDbtTransformations() throws Exception {
+    // overrides test in coming releases
+  }
+
   protected DataSource getDataSource(final JsonNode config) {
     final JsonNode jdbcConfig = destination.toJdbcConfig(config);
     return DataSourceFactory.create(jdbcConfig.get(JdbcUtils.USERNAME_KEY).asText(),

docs/integrations/destinations/teradata.md

@@ -26,7 +26,7 @@ You'll need the following information to configure the Teradata destination:
 
 Each stream will be output into its own table in Teradata. Each table will contain 3 columns:
 
-- `_airbyte_ab_id`: a uuid assigned by Airbyte to each event that is processed. The column type in Teradata is `VARCHAR(256)`.
+- `_airbyte_ab_id`: a unique uuid assigned by Airbyte to each event that is processed. This is the primary index column. The column type in Teradata is `VARCHAR(256)`.
 - `_airbyte_emitted_at`: a timestamp representing when the event was pulled from the data source. The column type in Teradata is `TIMESTAMP(6)`.
 - `_airbyte_data`: a json blob representing with the event data. The column type in Teradata is `JSON`.
 
@@ -84,9 +84,11 @@ You can also use a pre-existing user but we highly recommend creating a dedicate
 
 ## CHANGELOG
 
-| Version | Date       | Pull Request                                    | Subject                          |
-| :------ | :--------- | :---------------------------------------------- | :------------------------------- |
-| 0.1.3   | 2023-08-17 | https://github.com/airbytehq/airbyte/pull/30740 | Enable custom DBT transformation |
-| 0.1.2   | 2023-08-09 | https://github.com/airbytehq/airbyte/pull/29174 | Small internal refactor          |
-| 0.1.1   | 2023-03-03 | https://github.com/airbytehq/airbyte/pull/21760 | Added SSL support                |
-| 0.1.0   | 2022-12-13 | https://github.com/airbytehq/airbyte/pull/20428 | New Destination Teradata Vantage |
+| Version | Date       | Pull Request                                    | Subject                                                 |
+|:--------|:-----------| :---------------------------------------------- |:--------------------------------------------------------|
+| 0.1.5   | 2024-01-12 | https://github.com/airbytehq/airbyte/pull/33872 | Added Primary Index on _airbyte_ab_id to fix NoPI issue |
+| 0.1.4   | 2023-12-04 | https://github.com/airbytehq/airbyte/pull/28667 | Make connector available on Airbyte Cloud               |
+| 0.1.3   | 2023-08-17 | https://github.com/airbytehq/airbyte/pull/30740 | Enable custom DBT transformation                        |
+| 0.1.2   | 2023-08-09 | https://github.com/airbytehq/airbyte/pull/29174 | Small internal refactor                                 |
+| 0.1.1   | 2023-03-03 | https://github.com/airbytehq/airbyte/pull/21760 | Added SSL support                                       |
+| 0.1.0   | 2022-12-13 | https://github.com/airbytehq/airbyte/pull/20428 | New Destination Teradata Vantage                        |