🎉 Destination DynamoDB: rename dynamodb_table_name to dynamodb_table_name_prefix (#9314)

Author: alafanechere

airbyte-config/init/src/main/resources/config/STANDARD_DESTINATION_DEFINITION/8ccd8909-4e99-4141-b48d-4984b70b2d89.json

@@ -2,7 +2,7 @@
   "destinationDefinitionId": "8ccd8909-4e99-4141-b48d-4984b70b2d89",
   "name": "DynamoDB",
   "dockerRepository": "airbyte/destination-dynamodb",
-  "dockerImageTag": "0.1.0",
+  "dockerImageTag": "0.1.1",
   "documentationUrl": "https://docs.airbyte.io/integrations/destinations/dynamodb",
   "icon": "dynamodb.svg"
 }

airbyte-integrations/connectors/destination-dynamodb/Dockerfile

@@ -16,5 +16,5 @@ ENV APPLICATION destination-dynamodb
 
 COPY --from=build /airbyte /airbyte
 
-LABEL io.airbyte.version=0.1.0
+LABEL io.airbyte.version=0.1.1
 LABEL io.airbyte.name=airbyte/destination-dynamodb

airbyte-integrations/connectors/destination-dynamodb/sample_secrets/config.json

@@ -1,5 +1,5 @@
 {
-  "dynamodb_table_name": "paste-table-name-here",
+  "dynamodb_table_name_prefix": "paste-table-name-here",
   "dynamodb_region": "paste-dynamodb-region-here",
   "access_key_id": "paste-access-key-id-here",
   "secret_access_key": "paste-secret-access-key-here"

airbyte-integrations/connectors/destination-dynamodb/src/main/java/io/airbyte/integrations/destination/dynamodb/DynamodbChecker.java

@@ -23,7 +23,7 @@ public class DynamodbChecker {
   private static final Logger LOGGER = LoggerFactory.getLogger(DynamodbChecker.class);
 
   public static void attemptDynamodbWriteAndDelete(final DynamodbDestinationConfig dynamodbDestinationConfig) throws Exception {
-    final var prefix = dynamodbDestinationConfig.getTableName();
+    final var prefix = dynamodbDestinationConfig.getTableNamePrefix();
     final String outputTableName = prefix + "_airbyte_connection_test_" + UUID.randomUUID().toString().replaceAll("-", "");
     attemptWriteAndDeleteDynamodbItem(dynamodbDestinationConfig, outputTableName);
   }

airbyte-integrations/connectors/destination-dynamodb/src/main/java/io/airbyte/integrations/destination/dynamodb/DynamodbDestinationConfig.java

@@ -9,19 +9,19 @@
 public class DynamodbDestinationConfig {
 
   private final String endpoint;
-  private final String tableName;
+  private final String tableNamePrefix;
   private final String accessKeyId;
   private final String secretAccessKey;
   private final String region;
 
   public DynamodbDestinationConfig(
                                    final String endpoint,
-                                   final String tableName,
+                                   final String tableNamePrefix,
                                    final String region,
                                    final String accessKeyId,
                                    final String secretAccessKey) {
     this.endpoint = endpoint;
-    this.tableName = tableName;
+    this.tableNamePrefix = tableNamePrefix;
     this.region = region;
     this.accessKeyId = accessKeyId;
     this.secretAccessKey = secretAccessKey;
@@ -30,7 +30,7 @@ public DynamodbDestinationConfig(
   public static DynamodbDestinationConfig getDynamodbDestinationConfig(final JsonNode config) {
     return new DynamodbDestinationConfig(
         config.get("dynamodb_endpoint") == null ? "" : config.get("dynamodb_endpoint").asText(),
-        config.get("dynamodb_table_name").asText(),
+        config.get("dynamodb_table_name_prefix").asText(),
         config.get("dynamodb_region").asText(),
         config.get("access_key_id").asText(),
         config.get("secret_access_key").asText());
@@ -52,8 +52,8 @@ public String getRegion() {
     return region;
   }
 
-  public String getTableName() {
-    return tableName;
+  public String getTableNamePrefix() {
+    return tableNamePrefix;
   }
 
 }

airbyte-integrations/connectors/destination-dynamodb/src/main/java/io/airbyte/integrations/destination/dynamodb/DynamodbOutputTableHelper.java

@@ -11,15 +11,15 @@
 
 public class DynamodbOutputTableHelper {
 
-  public static String getOutputTableName(final String tableName, final AirbyteStream stream) {
-    return getOutputTableName(tableName, stream.getNamespace(), stream.getName());
+  public static String getOutputTableName(final String tableNamePrefix, final AirbyteStream stream) {
+    return getOutputTableName(tableNamePrefix, stream.getNamespace(), stream.getName());
   }
 
-  public static String getOutputTableName(final String tableName, final String namespace, final String streamName) {
+  public static String getOutputTableName(final String tableNamePrefix, final String namespace, final String streamName) {
     final List<String> paths = new LinkedList<>();
 
-    if (tableName != null) {
-      paths.add(tableName);
+    if (tableNamePrefix != null) {
+      paths.add(tableNamePrefix);
     }
     if (namespace != null) {
       paths.add(new ExtendedNameTransformer().convertStreamName(namespace));

airbyte-integrations/connectors/destination-dynamodb/src/main/java/io/airbyte/integrations/destination/dynamodb/DynamodbWriter.java

@@ -46,7 +46,7 @@ public DynamodbWriter(final DynamodbDestinationConfig config,
     this.dynamodb = new DynamoDB(amazonDynamodb);
     this.configuredStream = configuredStream;
     this.uploadTimestamp = uploadTimestamp;
-    this.outputTableName = DynamodbOutputTableHelper.getOutputTableName(config.getTableName(), configuredStream.getStream());
+    this.outputTableName = DynamodbOutputTableHelper.getOutputTableName(config.getTableNamePrefix(), configuredStream.getStream());
 
     final DestinationSyncMode syncMode = configuredStream.getDestinationSyncMode();
     if (syncMode == null) {

airbyte-integrations/connectors/destination-dynamodb/src/main/resources/spec.json

@@ -9,7 +9,7 @@
     "title": "DynamoDB Destination Spec",
     "type": "object",
     "required": [
-      "dynamodb_table_name",
+      "dynamodb_table_name_prefix",
       "dynamodb_region",
       "access_key_id",
       "secret_access_key"
@@ -23,10 +23,10 @@
         "description": "This is your DynamoDB endpoint url.(if you are working with AWS DynamoDB, just leave empty).",
         "examples": ["http://localhost:9000"]
       },
-      "dynamodb_table_name": {
-        "title": "DynamoDB Table Name",
+      "dynamodb_table_name_prefix": {
+        "title": "Table name prefix",
         "type": "string",
-        "description": "The name of the DynamoDB table.",
+        "description": "The prefix to use when naming DynamoDB tables.",
         "examples": ["airbyte_sync"]
       },
       "dynamodb_region": {

airbyte-integrations/connectors/destination-dynamodb/src/test-integration/java/io/airbyte/integrations/destination/dynamodb/DynamodbDestinationAcceptanceTest.java

@@ -66,7 +66,7 @@ protected JsonNode getFailCheckConfig() {
    */
   protected List<Item> getAllSyncedObjects(final String streamName, final String namespace) {
     final var dynamodb = new DynamoDB(this.client);
-    final var tableName = DynamodbOutputTableHelper.getOutputTableName(this.config.getTableName(), streamName, namespace);
+    final var tableName = DynamodbOutputTableHelper.getOutputTableName(this.config.getTableNamePrefix(), streamName, namespace);
     final var table = dynamodb.getTable(tableName);
     final List<Item> items = new ArrayList<Item>();
     final List<Item> resultItems = new ArrayList<Item>();
@@ -148,7 +148,7 @@ protected void tearDown(final TestDestinationEnv testEnv) {
     final var dynamodb = new DynamoDB(this.client);
     final List<String> tables = new ArrayList<String>();
     dynamodb.listTables().forEach(o -> {
-      if (o.getTableName().startsWith(this.config.getTableName()))
+      if (o.getTableName().startsWith(this.config.getTableNamePrefix()))
         tables.add(o.getTableName());
     });
 

airbyte-integrations/connectors/destination-dynamodb/src/test/java/io/airbyte/integrations/destination/dynamodb/DynamodbDestinationTest.java

@@ -31,14 +31,14 @@ void testGetOutputTableNameWithStream() throws Exception {
   @Test
   void testGetDynamodbDestinationdbConfig() throws Exception {
     final JsonNode json = Jsons.deserialize("{\n" +
-        "  \"dynamodb_table_name\": \"test_table\",\n" +
+        "  \"dynamodb_table_name_prefix\": \"test_table\",\n" +
         "  \"dynamodb_region\": \"test_region\",\n" +
         "  \"access_key_id\": \"test_key_id\",\n" +
         "  \"secret_access_key\": \"test_access_key\"\n" +
         "}");
     final var config = DynamodbDestinationConfig.getDynamodbDestinationConfig(json);
 
-    assertEquals(config.getTableName(), "test_table");
+    assertEquals(config.getTableNamePrefix(), "test_table");
     assertEquals(config.getRegion(), "test_region");
     assertEquals(config.getAccessKeyId(), "test_key_id");
     assertEquals(config.getSecretAccessKey(), "test_access_key");