fix(glue): empty string in Table.s3prefix is not undefined (#5783)

When the Glue Table's s3Prefix property is an empty string, it should not be replaced with the default value. Fixes #5763
aws · Jan 13, 2020 · 18e15de · 18e15de
1 parent 5292bd5
commit 18e15de
Show file tree

Hide file tree

Showing 2 changed files with 69 additions and 1 deletion.
diff --git a/packages/@aws-cdk/aws-glue/lib/table.ts b/packages/@aws-cdk/aws-glue/lib/table.ts
@@ -236,7 +236,7 @@ export class Table extends Resource implements ITable {
 
     this.database = props.database;
     this.dataFormat = props.dataFormat;
-    this.s3Prefix = props.s3Prefix || 'data/';
+    this.s3Prefix = (props.s3Prefix !== undefined && props.s3Prefix !== null) ? props.s3Prefix : 'data/';
 
     validateSchema(props.columns, props.partitionKeys);
     this.columns = props.columns;

diff --git a/packages/@aws-cdk/aws-glue/test/test.table.ts b/packages/@aws-cdk/aws-glue/test/test.table.ts
@@ -1079,6 +1079,74 @@ export = {
     test.done();
   },
 
+  'explicit s3 bucket and with empty prefix'(test: Test) {
+    const app = new cdk.App();
+    const dbStack = new cdk.Stack(app, 'db');
+    const stack = new cdk.Stack(app, 'app');
+    const bucket = new s3.Bucket(stack, 'ExplicitBucket');
+    const database = new glue.Database(dbStack, 'Database', {
+      databaseName: 'database',
+    });
+
+    new glue.Table(stack, 'Table', {
+      database,
+      bucket,
+      s3Prefix: '',
+      tableName: 'table',
+      columns: [{
+        name: 'col',
+        type: glue.Schema.STRING
+      }],
+      dataFormat: glue.DataFormat.Json,
+    });
+
+    expect(stack).to(haveResource('AWS::Glue::Table', {
+      CatalogId: {
+        Ref: "AWS::AccountId"
+      },
+      DatabaseName: {
+        "Fn::ImportValue": "db:ExportsOutputRefDatabaseB269D8BB88F4B1C4"
+      },
+      TableInput: {
+        Description: "table generated by CDK",
+        Name: "table",
+        Parameters: {
+          has_encrypted_data: false
+        },
+        StorageDescriptor: {
+          Columns: [
+            {
+              Name: "col",
+              Type: "string"
+            }
+          ],
+          Compressed: false,
+          InputFormat: "org.apache.hadoop.mapred.TextInputFormat",
+          Location: {
+            "Fn::Join": [
+              "",
+              [
+                "s3://",
+                {
+                  Ref: "ExplicitBucket0AA51A3F"
+                },
+                "/"
+              ]
+            ]
+          },
+          OutputFormat: "org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat",
+          SerdeInfo: {
+            SerializationLibrary: "org.openx.data.jsonserde.JsonSerDe"
+          },
+          StoredAsSubDirectories: false
+        },
+        TableType: "EXTERNAL_TABLE"
+      }
+    }));
+
+    test.done();
+  },
+
   'grants': {
     'read only'(test: Test) {
       const stack = new cdk.Stack();