Method IsSqlError

class/database.py:824–880

(cls, mysqlMsg)

    # 检测数据库执行错误
    @classmethod
    def IsSqlError(cls, mysqlMsg):
        err_dict = {
            1045: "数据库用户名或密码错误！请尝试重置密码后再进行操作！",
            1049: "数据库不存在！",
            1044: "没有指定数据库的访问权限，或指定数据库不存在！",
            1062: "数据库已存在！",
            1142: "指定用户权限不足！",
            1010: "数据库异常，没有权限删除此数据库，请检查是否有非数据库文件或权限是否正常",
            1146: "数据表不存在！",
            2002: "本地服务器无法连接！",
            2003: "数据库服务器连接失败！请检查mysql是否正常启动！",
            23000: "外键约束冲突！",
            6: "数据库异常，没有权限删除此数据库，请检查是否有非数据库文件或权限是否正常！"
        }

        import pymysql
        if isinstance(mysqlMsg, pymysql.err.MySQLError):  # 捕获异常
            error_code, error_message = mysqlMsg.args

            err_msg = err_dict.get(error_code)
            if err_msg is not None:
                error_message = err_msg + "<pre>" + error_message + "</pre>"
                if error_code == 1045:
                    user_pattern = re.compile(r"for user '(.+?)'@")
                    user_match = user_pattern.search(error_message)
                    if user_match:
                        user = user_match.group(1)
                        return public.returnMsg(False,"数据库用户名或密码错误 ！请尝试重置{}用户密码后再进行操作".format(user))
                if error_code == 1010 or error_code == 6:
                    dir_pattern = r"'(\./[^']*)'"
                    dir_match= re.search(dir_pattern,error_message)
                    if dir_match:
                        try:
                            matched_dir = dir_match.group(1).strip('.')
                            mycnf = public.readFile("/etc/my.cnf")
                            rep = "datadir\s*=\s*(.+)\n"
                            data_path = re.search(rep, mycnf).groups()[0]
                            return public.returnMsg(False,"数据库文件权限异常！请检查存储目录：{} 是否开启防篡改功能，或包含非数据库文件,确认正常后再进行操作".format(data_path+matched_dir))
                        except:
                            pass

            return public.returnMsg(False, error_message)
        mysqlMsg = str(mysqlMsg)
        if "MySQLdb" in mysqlMsg: return public.returnMsg(False, 'DATABASE_ERR_MYSQLDB')
        if "2002," in mysqlMsg or '2003,' in mysqlMsg: return public.returnMsg(False, 'DATABASE_ERR_CONNECT')
        if "using password:" in mysqlMsg: return public.returnMsg(False, 'DATABASE_ERR_PASS')
        if "Connection refused" in mysqlMsg: return public.returnMsg(False, 'DATABASE_ERR_CONNECT')
        if "1133," in mysqlMsg: return public.returnMsg(False, 'DATABASE_ERR_NOT_EXISTS')
        if "3679," in mysqlMsg: return public.returnMsg(False, '从数据库删除失败，数据目录不存在!')
        if "1141," in mysqlMsg: return public.returnMsg(False, '数据库用户添加失败！')
        if "libmysqlclient" in mysqlMsg:
            self.rep_lnk()
            public.ExecShell("pip uninstall mysql-python -y")
            public.ExecShell("pip install pymysql")
            public.writeFile('data/restart.pl', 'True')
            return public.returnMsg(False, "执行失败，已尝试自动修复，请稍候重试!")
        return None