Merge pull request #15 from tinybirdco/fix-newline-error

Removed unsuported parameter newline

Author: ygnuss

clickhouse_mysql/writer/csvwriter.py

@@ -136,7 +136,7 @@ def insert(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_MINIMAL)
+            self.writer = csv.DictWriter(self.file, fieldnames=self.fieldnames, quoting=csv.QUOTE_ALL)
             if not self.header_written:
                 self.writer.writeheader()
 
@@ -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_MINIMAL)
+            self.writer = csv.DictWriter(self.file, fieldnames=self.fieldnames, quoting=csv.QUOTE_ALL)
             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_MINIMAL, newline = '')
+            self.writer = csv.DictWriter(self.file, fieldnames=self.fieldnames, quoting=csv.csv.QUOTE_ALL)
             if not self.header_written:
                 self.writer.writeheader()