diff --git a/clickhouse_mysql/writer/csvwriter.py b/clickhouse_mysql/writer/csvwriter.py index 58fbffc..3fb7951 100644 --- a/clickhouse_mysql/writer/csvwriter.py +++ b/clickhouse_mysql/writer/csvwriter.py @@ -190,7 +190,7 @@ def delete_row(self, event_or_events): if self.dst_table is None: self.dst_table = event.table - self.writer = csv.DictWriter(self.file, fieldnames=self.fieldnames, quoting=csv.QUOTE_ALL) + self.writer = csv.DictWriter(self.file, fieldnames=self.fieldnames, quoting=csv.QUOTE_MINIMAL) if not self.header_written: self.writer.writeheader() @@ -253,7 +253,7 @@ def update(self, event_or_events): if self.dst_table is None: self.dst_table = event.table - self.writer = csv.DictWriter(self.file, fieldnames=self.fieldnames, quoting=csv.QUOTE_ALL) + self.writer = csv.DictWriter(self.file, fieldnames=self.fieldnames, quoting=csv.QUOTE_MINIMAL) if not self.header_written: self.writer.writeheader()