diff --git a/plugins/mysql/index.py b/plugins/mysql/index.py index 595d0d175..059a92c3c 100755 --- a/plugins/mysql/index.py +++ b/plugins/mysql/index.py @@ -3108,8 +3108,7 @@ def syncDatabaseRepair(version=''): # print(len(local_select_data)) # print(len(sync_select_data)) print('local compare sync,',local_select_data == sync_select_data) - diff = sync_count_data[0]['num'] - local_count_data[0]['num'] - print("diff," + str(diff)+' line data!') + if local_select_data == sync_select_data: data_count = len(local_select_data) @@ -3125,6 +3124,10 @@ def syncDatabaseRepair(version=''): if local_count_data[0]['num'] == sync_count_data[0]['num']: is_break = True break + + diff = sync_count_data[0]['num'] - local_count_data[0]['num'] + print("diff," + str(diff)+' line data!') + # print(table_name,data_count) print('pos',local_select_data[data_count-1][pkey_name]) pkey_val = local_select_data[data_count-1][pkey_name] @@ -3136,7 +3139,7 @@ def syncDatabaseRepair(version=''): for insert_data in sync_select_data: # print(insert_data) local_inquery_sql = 'select id from ' + table_name+ ' where ' +pkey_name+' = '+ str(insert_data[pkey_name]) - print(local_inquery_sql) + # print(local_inquery_sql) tdata = local_db.query(local_inquery_sql) print(tdata) if len(tdata) == 0: