From cd2655a6f9ee53f6a638068cfd9be78d6ac08c94 Mon Sep 17 00:00:00 2001 From: Mr Chen Date: Fri, 17 May 2024 01:47:40 +0800 Subject: [PATCH] Update index.py --- plugins/mysql/index.py | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/plugins/mysql/index.py b/plugins/mysql/index.py index 0bb688fca..f1589f7ac 100755 --- a/plugins/mysql/index.py +++ b/plugins/mysql/index.py @@ -3206,13 +3206,13 @@ def syncDatabaseRepair(version=''): ldata = local_db.query(local_inquery_sql) print('ldata:',ldata) if len(ldata) == 0: - print("id:"+ str(insert_data[pkey_name])+ " no exists, insert") + print("id:"+ str(sync_insert_data[pkey_name])+ " no exists, insert") insert_sql = 'insert into ' + table_name field_str = '' value_str = '' - for field in insert_data: + for field in sync_insert_data: field_str += '`'+field+'`,' - value_str += '\''+escape_string(str(insert_data[field]))+'\',' + value_str += '\''+escape_string(str(sync_insert_data[field]))+'\',' field_str = '(' +field_str.strip(',')+')' value_str = '(' +value_str.strip(',')+')' insert_sql = insert_sql+' '+field_str+' values'+value_str+';' @@ -3227,12 +3227,12 @@ def syncDatabaseRepair(version=''): update_sql = 'update ' + table_name field_str = '' value_str = '' - for field in insert_data: + for field in sync_insert_data: if field == pkey_name: continue - field_str += '`'+field+'`=\''+escape_string(str(insert_data[field]))+'\',' + field_str += '`'+field+'`=\''+escape_string(str(sync_insert_data[field]))+'\',' field_str = field_str.strip(',') - update_sql = update_sql+' set '+field_str+' where '+pkey_name+'=\''+str(insert_data[pkey_name])+'\';' + update_sql = update_sql+' set '+field_str+' where '+pkey_name+'=\''+str(sync_insert_data[pkey_name])+'\';' print(update_sql) r = local_db.execute(update_sql) print(r)