1、mysql數據庫地址文件格式

db:test? 10.10.10.10? 10.10.10.11

db:profile? 10.10.10.12:3306? ?10.10.10.13:3307

2、腳本內容

#!/usr/bin/env python

#_*_coding:utf-8_*_

#user = liuzilong

#email = liuzilong@jiayuan.com

#time = 2019-04-10

import sys,os

import MySQLdb

import re

import time

import logging

#需要排除的db組

db_name_list = ['db:master','db:lvs']

#數據庫配置文件列表

file_list = ['/root/cron/db_list.txt','/root/cron/baihe_db_list.txt']

#數據庫清理權限備份文件

d_time = time.strftime('%Y%m%d_%H_%M_%S',time.localtime(time.time()))

bk_file = '/home/mysql/bk/priv_%s.txt' % (d_time)

#執行日志記錄

# 第一步，創建一個logger

logger = logging.getLogger('priv_delete')

logger.setLevel(logging.DEBUG) # Log等級總開關

# 第二步，創建一個handler，用于寫入日志文件

logfile = '/home/mysql/bk/db_priv_delete.log'

fh = logging.FileHandler(logfile)

fh.setLevel(logging.DEBUG) # 輸出到file的log等級的開關

# 第三步，定義handler的輸出格式

formatter = logging.Formatter("%(asctime)s - %(filename)s[line:%(lineno)d] - %(levelname)s: %(message)s")

fh.setFormatter(formatter)

# 第四步，將logger添加到handler里面

logger.addHandler(fh)

#定義清理權限類

class Priv_Delete(object):

#初始化，獲取數據庫ip和端口

def __init__(self):

ip_port = {}

db_list = []

for file in file_list:

try:

f = open(file,'r')

db_list += f.readlines()

f.close()

except Exception as e:

logger.error("No such file or directory: %s " % (file))

for ip in db_list:

db_name = ip.split()[0]

if db_name not in db_name_list:

for i in range(1,len(ip.split())):

try:

ip_port[ip.split()[i].split(':')[0]] = int(ip.split()[i].split(':')[1])

except Exception as e :

ip_port[ip.split()[i].split(':')[0]] = 3306

self.ip_port = ip_port

#創建數據庫連接

def conn_db(self,ip,port):

ret = {}

db_host = ip

db_port = port

db_user = 'sg'

db_passwd = 'sg109504'

db_name = ''

try:

conn = MySQLdb.connect(host=db_host,port=db_port,user=db_user,passwd=db_passwd,db=db_name,charset='utf8',connect_timeout=10)

return conn

except Exception as e:

logger.error("attempt connection database %s faild！" % (ip))

return None

#定義清理權限方法

def priv_delete(self,hostlist):

#打開權限備份文件

bk_f = open(bk_file,'a+')

for k,v in self.ip_port.items():

db_ip = k

db_port = v

logger.info("Current operational database address is %s:%s" % (db_ip,db_port))

conn = self.conn_db(db_ip,db_port)

if conn:

cursor = conn.cursor()

ip_str = '"' + '","'.join(hostlist) + '"'

valid_s = "select user,host from mysql.user where host in (%s);" % (ip_str)

cursor.execute(valid_s)

rs = cursor.fetchall()

if len(rs) > 0:

bk_f.write(db_ip + ':' + str(db_port) + '\n')

cursor.execute("set sql_log_bin=0;")

for host_ip in hostlist:

logger.info('current remove privilege ip is %s' % (host_ip))

get_priv_cmd = 'select user from mysql.user where host="%s" ' % (host_ip)

cursor.execute(get_priv_cmd)

result = cursor.fetchall()

for row in result:

name = row[0]

logger.info('current remove privilege user is %s@%s' % (name,host_ip))

if name:

get_db_version = 'select version();'

cursor.execute(get_db_version)

result = cursor.fetchone()[0]

st_list = []

if result.startswith('5.7'):

get_priv = 'show grants for %s@%s' % (name,host_ip)

get_pwd = "select authentication_string from mysql.user where user='%s' and host='%s'" % (name,host_ip)

cursor.execute(get_pwd)

pwd = cursor.fetchone()[0]

cursor.execute(get_priv)

result = cursor.fetchall()

for row in result:

s = " IDENTIFIED BY PASSWORD %s" % (pwd)

s = row[0] + s

st_list.append(s)

st = ';\n'.join(st_list) + ';\n'

bk_f.write(st)

else:

get_priv = 'show grants for %s@%s' % (name,host_ip)

cursor.execute(get_priv)

result = cursor.fetchall()

for row in result:

st_list.append(row[0])

st = ';\n'.join(st_list) + ';\n'

bk_f.write(st)

try:

#remove_priv_cmd = 'drop user %s@%s ' % (name,host_ip)

#cursor.execute(remove_priv_cmd)

logger.info('current user %s@%s remove privilege complete!' % (name,host_ip))

except Exception as e:

logger.error('current user %s@%s remove privilege faild!' % (name,host_ip))

cursor.close()

else:

cursor.close()

bk_f.close()

def usage(self):

print "Usage:"

print ""

print "刪除主機授權"

print ""

print " remove_priv ip "

print ""

print " eg: remove_priv ip 10.10.10.10 10.10.10.11"

if __name__ == "__main__":

privobj = Priv_Delete()

if len(sys.argv) < 2:

privobj.usage()

else:

hostlist = list(sys.argv[1:])

privobj.priv_delete(hostlist)

總結

以上是生活随笔為你收集整理的mysql权限清理_mysql清理用户权限的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。