From 478e03bca18e081e3c4204b6570a9c92669b4e65 Mon Sep 17 00:00:00 2001 From: Mr Chen Date: Wed, 15 May 2024 04:42:42 +0800 Subject: [PATCH] Update index.py --- plugins/mysql/index.py | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/plugins/mysql/index.py b/plugins/mysql/index.py index 98e37fb4f..cf9c4b140 100755 --- a/plugins/mysql/index.py +++ b/plugins/mysql/index.py @@ -3081,7 +3081,11 @@ def syncDatabaseRepair(version=''): # 数据对齐 for table_name in inconsistent_table: - data_select_sql = 'select * from '+table_name + ' where id > 0 limit 1' + primary_key_sql = "SHOW INDEX FROM "+table_name+" WHERE Key_name = 'PRIMARY';"; + primary_key_data = local_db.query(primary_key_sql) + pkey_name = primary_key_data[0]['Column_name'] + data_select_sql = 'select * from '+table_name + ' where '+pkey_name+' > 0 limit 1' + print(data_select_sql) local_select_data = local_db.query(data_select_sql) sync_select_data = sync_db.query(data_select_sql)