Fix copyInto files clause

Author: rad-pat

databend_sqlalchemy/databend_dialect.py

@@ -1040,7 +1040,8 @@ def visit_copy_into(self, copy_into, **kw):
 
         result = f"COPY INTO {target}" f" FROM {source}"
         if hasattr(copy_into, "files") and isinstance(copy_into.files, list):
-            result += f"FILES = {', '.join([f for f in copy_into.files])}"
+            quoted_files = [f"'{f}'" for f in copy_into.files]
+            result += f" FILES = ({', '.join(quoted_files)})"
         if hasattr(copy_into, "pattern") and copy_into.pattern:
             result += f" PATTERN = '{copy_into.pattern}'"
         if not isinstance(copy_into.file_format, NoneType):

tests/test_copy_into.py

@@ -162,6 +162,38 @@ def test_copy_into_table_sub_select_column_clauses(self):
             checkparams={"1_1": "xyz", "IF_1": "NULL", "IF_2": "NOTNULL"},
         )
 
+    def test_copy_into_table_files(self):
+        m = MetaData()
+        tbl = Table(
+            "atable",
+            m,
+            Column("id", Integer),
+            schema="test_schema",
+        )
+
+        copy_into = CopyIntoTable(
+            target=tbl,
+            from_=GoogleCloudStorage(
+                uri="gcs://some-bucket/a/path/to/files",
+                credentials="XYZ",
+            ),
+            files=['one','two','three'],
+            file_format=CSVFormat(),
+        )
+
+        self.assert_compile(
+            copy_into,
+            (
+                "COPY INTO test_schema.atable"
+                " FROM 'gcs://some-bucket/a/path/to/files' "
+                "CONNECTION = ("
+                "  ENDPOINT_URL = 'https://storage.googleapis.com' "
+                "  CREDENTIAL = 'XYZ' "
+                ") FILES = ('one', 'two', 'three')"
+                " FILE_FORMAT = (TYPE = CSV)"
+            ),
+        )
+
 
 class CopyIntoResultTest(fixtures.TablesTest):
     run_create_tables = "each"