Escape backslashes in array values

Author: kinghuang

target_postgres/sinks.py

@@ -179,6 +179,14 @@ def bulk_insert_records(  # type: ignore[override]
             column.type.bind_processor(connection.dialect) or str for column in columns
         ]
 
+        # Make translation table for escaping in array values.
+        array_translate_table = str.maketrans(
+            {
+                '"': '\\""',
+                "\\": "\\\\",
+            }
+        )
+
         def process_column_value(data: Any, proc: Callable) -> str:
             # If the data is null, return an unquoted, empty value.
             # Unquoted is important here, for PostgreSQL to interpret as null.
@@ -197,10 +205,15 @@ def process_column_value(data: Any, proc: Callable) -> str:
             # If the value is a list (for ARRAY), escape double-quotes as \" and return
             # a quoted value in literal array format.
             if isinstance(value, list):
+                self.logger.info(f"{value.__class__=}")
+                self.logger.info(f"{value=}")
+
                 # for each member of value, escape double quotes as \".
                 return (
                     '"{'
-                    + ",".join('""' + v.replace('"', r'\""') + '""' for v in value)
+                    + ",".join(
+                        '""' + v.translate(array_translate_table) + '""' for v in value
+                    )
                     + '}"'
                 )