Skip to content

Commit c45d943

Browse files
committed
Fix order columns csv
1 parent 10ef2a3 commit c45d943

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

clickhouse_mysql/writer/csvwriter.py

+3-3
Original file line numberDiff line numberDiff line change
@@ -126,8 +126,8 @@ def insert(self, event_or_events):
126126
event_converted = self.convert(event)
127127
rows = event_converted.pymysqlreplication_event.rows
128128
headers = list(rows[0]['values'].keys())
129-
headers.append('tb_upd')
130129
headers.append('operation')
130+
headers.append('tb_upd')
131131

132132
# self.fieldnames = sorted(self.convert(copy.copy(event.first_row())).keys())
133133
self.fieldnames = headers
@@ -181,8 +181,8 @@ def delete_row(self, event_or_events):
181181
event_converted = self.convert(event)
182182
rows = event_converted.pymysqlreplication_event.rows
183183
headers = list(rows[0]['values'].keys())
184-
headers.append('tb_upd')
185184
headers.append('operation')
185+
headers.append('tb_upd')
186186

187187
self.fieldnames = headers
188188
if self.dst_schema is None:
@@ -243,8 +243,8 @@ def update(self, event_or_events):
243243
event_converted = self.convert(event)
244244
rows = event_converted.pymysqlreplication_event.rows
245245
headers = list(rows[0]['after_values'].keys())
246-
headers.append('tb_upd')
247246
headers.append('operation')
247+
headers.append('tb_upd')
248248

249249
# self.fieldnames = sorted(headers)
250250
self.fieldnames = headers

0 commit comments

Comments
 (0)