Update index.py

pull/577/head
Mr Chen 12 months ago
parent 608b40a110
commit cd2655a6f9
  1. 12
      plugins/mysql/index.py

@ -3206,13 +3206,13 @@ def syncDatabaseRepair(version=''):
ldata = local_db.query(local_inquery_sql) ldata = local_db.query(local_inquery_sql)
print('ldata:',ldata) print('ldata:',ldata)
if len(ldata) == 0: 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 insert_sql = 'insert into ' + table_name
field_str = '' field_str = ''
value_str = '' value_str = ''
for field in insert_data: for field in sync_insert_data:
field_str += '`'+field+'`,' 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(',')+')' field_str = '(' +field_str.strip(',')+')'
value_str = '(' +value_str.strip(',')+')' value_str = '(' +value_str.strip(',')+')'
insert_sql = insert_sql+' '+field_str+' values'+value_str+';' insert_sql = insert_sql+' '+field_str+' values'+value_str+';'
@ -3227,12 +3227,12 @@ def syncDatabaseRepair(version=''):
update_sql = 'update ' + table_name update_sql = 'update ' + table_name
field_str = '' field_str = ''
value_str = '' value_str = ''
for field in insert_data: for field in sync_insert_data:
if field == pkey_name: if field == pkey_name:
continue 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(',') 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) print(update_sql)
r = local_db.execute(update_sql) r = local_db.execute(update_sql)
print(r) print(r)

Loading…
Cancel
Save