Merge pull request #1172 from MTES-MCT/feat-csv

alexisig · web-flow · commit fcffcc7f7017 · 2025-06-26T17:25:54.000+02:00
fix(csv): always add string quoting
diff --git a/airflow/include/domain/file_handling/SQLToCSVOnS3Handler.py b/airflow/include/domain/file_handling/SQLToCSVOnS3Handler.py
@@ -31,6 +31,7 @@ def export_sql_result_to_csv_on_s3(self, s3_key: str, s3_bucket: str, sql: str)
             f'"{self.db_connection}"',
             "public_ocsge.occupation_du_sol",
             f'-sql "{sql}"',
+            "-lco STRING_QUOTING=ALWAYS",
         ]
         try:
             subprocess.run(" ".join(cmd), shell=True, stderr=subprocess.STDOUT, check=True)

Original file line number	Diff line number	Diff line change
`@@ -31,6 +31,7 @@ def export_sql_result_to_csv_on_s3(self, s3_key: str, s3_bucket: str, sql: str)`
`31`	`31`	`f'"{self.db_connection}"',`
`32`	`32`	`"public_ocsge.occupation_du_sol",`
`33`	`33`	`f'-sql "{sql}"',`
	`34`	`+ "-lco STRING_QUOTING=ALWAYS",`
`34`	`35`	`]`
`35`	`36`	`try:`
`36`	`37`	`subprocess.run(" ".join(cmd), shell=True, stderr=subprocess.STDOUT, check=True)`