Method SyncGetDatabases

class/database.py:2199–2246

(self, get)

        
    # 从服务器获取数据库
    def SyncGetDatabases(self, get):
        sid = get.get('sid/d', 0)
        db_type = 0
        if sid: db_type = 2
        if not os.path.exists('/usr/bin/mysql'):
            public.install_mysql_client()
        mysql_obj = public.get_mysql_obj_by_sid(sid)
        if not mysql_obj: return public.returnMsg(False, '连接指定数据库失败')
        data = mysql_obj.query("show databases")
        isError = self.IsSqlError(data)
        if isError != None: return isError
        users = mysql_obj.query("select User,Host from mysql.user where User!='root' AND Host!='localhost' AND Host!=''")

        if type(users) == str: return public.returnMsg(False, users)
        if type(users) != list: return public.returnMsg(False, public.GetMySQLError(users))

        sql = public.M('databases')
        nameArr = ['information_schema', 'performance_schema', 'mysql', 'sys']
        n = 0
        for value in data:
            b = False
            for key in nameArr:
                if value[0] == key:
                    b = True
                    break
            if b: continue
            host = self.get_db_host_by_db_name(int(sid))
            if db_type == 0:
                if sql.where("name=? AND LOWER(type)=LOWER('mysql')", (value[0])).count(): continue
            else:
                if sql.where("name=? AND LOWER(type)=LOWER('mysql') AND accept=?", (value[0], host)).count(): continue
            # host = '127.0.0.1'
            # for user in users:
            #     if value[0] == user[0]:
            #         print(user)
            #         host = user[1]
            #         break
            ps = public.getMsg('INPUT_PS')
            if value[0] == 'test':
                ps = public.getMsg('DATABASE_TEST')

            # XSS过虑
            if not re.match("^[\w+\.-]+$", value[0]): continue

            addTime = time.strftime('%Y-%m-%d %X', time.localtime())

            if public.M('databases').add('name,sid,db_type,username,password,accept,ps,addtime', (value[0], sid, db_type, value[0], '', host, ps, addTime)): n += 1
        return public.returnMsg(True, 'DATABASE_GET_SUCCESS', (str(n),))
    
    # 获取数据库权限
    def GetDatabaseAccess(self, get):