Skip to content

Commit 05cff59

Browse files
authored
Fixed primary key handling logic in db_replicator_initial.py. (#204)
1 parent b40ad37 commit 05cff59

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

mysql_ch_replicator/db_replicator_initial.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -170,8 +170,9 @@ def perform_initial_replication_table(self, table_name):
170170

171171
while True:
172172

173-
query_start_values = max_primary_key
174-
if query_start_values is not None:
173+
query_start_values = None
174+
if max_primary_key is not None:
175+
query_start_values = max_primary_key.copy()
175176
for i in range(len(query_start_values)):
176177
key_type = primary_key_types[i]
177178
value = query_start_values[i]

0 commit comments

Comments
 (0)