From ef0a9f07e3eb098bd17792bdc458cd19fda96a63 Mon Sep 17 00:00:00 2001 From: midoks Date: Wed, 3 Feb 2021 14:00:55 +0800 Subject: [PATCH] up --- plugins/mysql/index.py | 104 +++++++++++++++++++----------- plugins/mysql/js/mysql.js | 129 ++++++++++++++++++++++---------------- 2 files changed, 143 insertions(+), 90 deletions(-) diff --git a/plugins/mysql/index.py b/plugins/mysql/index.py index 897946191..4c392e689 100755 --- a/plugins/mysql/index.py +++ b/plugins/mysql/index.py @@ -1126,78 +1126,110 @@ def getTotalStatistics(): return mw.returnJson(False, 'fail', data) +def getMasterStatus(version=''): + conf = getConf() + con = mw.readFile(conf) + master_status = False + if con.find('#log-bin') == -1 and con.find('log-bin') > 1: + if con.find('#binlog-do-db') == -1 and con.find('binlog-do-db') > 1: + master_status = True + data = {} + data['status'] = master_status + return mw.returnJson(master_status, '设置成功') + + +def setMasterStatus(version=''): + + conf = getConf() + con = mw.readFile(conf) + + if con.find('#binlog-do-db') != -1: + con = con.replace('#binlog-do-db', 'binlog-do-db') + con = con.replace('#binlog-ignore-db', 'binlog-ignore-db') + restart() + else: + con = con.replace('binlog-do-db', '#binlog-do-db') + con = con.replace('binlog-ignore-db', '#binlog-ignore-db') + restart() + mw.writeFile(conf, con) + return mw.returnJson(True, '设置成功') + if __name__ == "__main__": func = sys.argv[1] version = sys.argv[2] if func == 'status': - print status(version) + print(status(version)) elif func == 'start': - print start(version) + print(start(version)) elif func == 'stop': - print stop(version) + print(top(version)) elif func == 'restart': - print restart(version) + print(restart(version)) elif func == 'reload': - print reload(version) + print(reload(version)) elif func == 'initd_status': - print initdStatus() + print(initdStatus()) elif func == 'initd_install': - print initdInstall() + print(initdInstall()) elif func == 'initd_uninstall': - print initdUinstall() + print(initdUinstall()) elif func == 'run_info': - print runInfo() + print(runInfo()) elif func == 'db_status': - print myDbStatus() + print(myDbStatus()) elif func == 'set_db_status': - print setDbStatus() + print(setDbStatus()) elif func == 'conf': - print getConf() + print(getConf()) elif func == 'bin_log': - print binLog() + print(binLog()) elif func == 'error_log': - print getErrorLog() + print(getErrorLog()) elif func == 'show_log': - print getShowLogFile() + print(getShowLogFile()) elif func == 'my_db_pos': - print getMyDbPos() + print(getMyDbPos()) elif func == 'set_db_pos': - print setMyDbPos() + print(setMyDbPos()) elif func == 'my_port': - print getMyPort() + print(getMyPort()) elif func == 'set_my_port': - print setMyPort() + print(setMyPort()) elif func == 'init_pwd': - print initMysqlPwd() + print(initMysqlPwd()) elif func == 'get_db_list': - print getDbList() + print(getDbList()) elif func == 'add_db': - print addDb() + print(addDb()) elif func == 'del_db': - print delDb() + print(delDb()) elif func == 'sync_get_databases': - print syncGetDatabases() + print(syncGetDatabases()) elif func == 'sync_to_databases': - print syncToDatabases() + print(syncToDatabases()) elif func == 'set_root_pwd': - print setRootPwd() + print(setRootPwd()) elif func == 'set_user_pwd': - print setUserPwd() + print(setUserPwd()) elif func == 'get_db_access': - print getDbAccess() + print(getDbAccess()) elif func == 'set_db_access': - print setDbAccess() + print(setDbAccess()) elif func == 'set_db_ps': - print setDbPs() + print(setDbPs()) elif func == 'get_db_info': - print getDbInfo() + print(getDbInfo()) elif func == 'repair_table': - print repairTable() + print(repairTable()) elif func == 'opt_table': - print optTable() + print(optTable()) elif func == 'alter_table': - print alterTable() + print(alterTable()) elif func == 'get_total_statistics': - print getTotalStatistics() + print(getTotalStatistics()) + elif func == 'get_master_status': + print(getMasterStatus(version)) + elif func == 'set_master_status': + print(setMasterStatus(version)) else: - print 'error' + print('error') diff --git a/plugins/mysql/js/mysql.js b/plugins/mysql/js/mysql.js index 1b0f690f4..f49af1faf 100755 --- a/plugins/mysql/js/mysql.js +++ b/plugins/mysql/js/mysql.js @@ -1104,62 +1104,83 @@ function repTools(db_name, res){ function masterOrSlaveConf(version){ - var _data = {}; - if (typeof(page) =='undefined'){ - var page = 1; - } - - _data['page'] = page; - _data['page_size'] = 10; - if(typeof(search) != 'undefined'){ - _data['search'] = search; - } - myPost('get_db_list', _data, function(data){ - var rdata = $.parseJSON(data.data); - var list = ''; - for(i in rdata.data){ - list += ''; - list += '' + rdata.data[i]['name'] +''; - list += '' + rdata.data[i]['username'] +''; - list += '' + - '***' + - ''+ - ''+ - ''; - list += '' + - '权限 | ' + - '改密 | ' + - '删除' + - ''; - list += ''; + function getDbList(){ + var _data = {}; + if (typeof(page) =='undefined'){ + var page = 1; + } + + _data['page'] = page; + _data['page_size'] = 10; + if(typeof(search) != 'undefined'){ + _data['search'] = search; } - // - var con = '
\ -
\ -
\ - \ - \ - \ - \ - \ - \ - \ - '+ list +'\ -
数据库名用户名密码操作
\ -
\ -
\ -
\ -
'; - - - var limitCon = '

\ - Master[主]配置\ -

\ -

'; + myPost('get_db_list', _data, function(data){ + var rdata = $.parseJSON(data.data); + var list = ''; + for(i in rdata.data){ + list += ''; + list += '' + rdata.data[i]['name'] +''; + list += '' + rdata.data[i]['username'] +''; + list += '' + + '***' + + ''+ + ''+ + ''; + list += '' + + '权限 | ' + + '改密 | ' + + '删除' + + ''; + list += ''; + } - $(".soft-man-con").html(limitCon+con); - $('#databasePage').html(rdata.page); - }); + var con = '
\ +
\ + \ + \ + \ + \ + \ + \ + \ + '+ list +'\ +
数据库名用户名密码操作
\ +
\ +
\ +
'; + $(".table_master_list").html(con); + $('#databasePage').html(rdata.page); + }); + } + function getMasterStatus(){ + myPost('get_master_status', '', function(data){ + var rdata = $.parseJSON(data.data); + var limitCon = '

\ + Master[主]配置\ +

\ +

\ + \ +
\ + '; + + $(".soft-man-con").html(limitCon); + + //设置主服务器配置 + $(".btn-master").click(function () { + // console.log('.....'); + myPost('set_master_status', 'close=change', function(data){ + var rdata = $.parseJSON(data.data); + layer.msg(rdata.msg, { icon: rdata.status ? 1 : 5 }); + setTimeout(function(){ + getMasterStatus(); + }, 2000); + }); + }); + getDbList(); + }); + } + getMasterStatus(); }