yan/mdserver-web
1
0
Fork 0
mirror of https://github.com/midoks/mdserver-web.git synced 2026-10-10 04:19:26 +08:00
Code Issues Packages Projects Releases Wiki Activity

Update index.py

Browse Source
This commit is contained in:
Mr Chen
2024-05-15 04:57:51 +08:00
parent 478e03bca1
commit c6a742a932
1 changed files with 28 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
plugins/mysql/index.py
+28 -10
View File
@@ -3080,17 +3080,35 @@ def syncDatabaseRepair(version=''):
mw.execShell("echo 'ok' > "+table_check_file)
# 数据对齐
for table_name in inconsistent_table:
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)
while True:
for table_name in inconsistent_table:
print("正在校验表,"+table_name)
table_name_pos = 0
table_name_pos_file = tmp_dir+'/'+table_name+'.pos.txt'
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+' > '+str(table_name_pos)+' limit 1'
local_select_data = local_db.query(data_select_sql)
sync_select_data = sync_db.query(data_select_sql)
print(local_select_data)
print(sync_select_data)
print(local_select_data)
print(sync_select_data)
print(local_select_data == sync_select_data)
if local_select_data == sync_select_data:
data_count = len(local_select_data)
print(local_select_data[data_count-1][pkey_name])
pkey_val = local_select_data[data_count-1][pkey_name]
print(pkey_val)
mw.writeFile(table_name_pos_file, str(pkey_val))
time.sleep(1)