Superset 兼容 ADB（AnalyticDB-MySQL）

Error while saving dataset:Table [xxx] could not be found,xxxxxxxx

/data/project/superset/env/lib/python3.8/site-packages/sqlalchemy/dialects/mysql/reflection.py:64: SAWarning: Unknown schema content: 'Create Table `t_d_id` ('  util.warn("Unknown schema content: %r" % line)/data/project/superset/env/lib/python3.8/site-packages/sqlalchemy/dialects/mysql/reflection.py:64: SAWarning: Unknown schema content: ' `id` int NOT NULL,'  util.warn("Unknown schema content: %r" % line)/data/project/superset/env/lib/python3.8/site-packages/sqlalchemy/dialects/mysql/reflection.py:64: SAWarning: Unknown schema content: ' primary key (`id`)'  util.warn("Unknown schema content: %r" % line)) DISTRIBUTE BY BROADCAST INDEX_ALL='Y' STORAGE_POLICY='COLD' BLOCK_SIZE=4096 COMMENT='自增id表'Got an error t_d_id validating table: t_d_idWARNING:superset.datasets.dao:Got an error t_d_id validating table: t_d_id

@log.class_loggerclass MySQLTableDefinitionParser(object):    """Parses the results of a SHOW CREATE TABLE statement."""
    def __init__(self, dialect, preparer):        self.dialect = dialect        self.preparer = preparer        self._prep_regexes()
    def parse(self, show_create, charset):        state = ReflectedState()        state.charset = charset        for line in re.split(r"\r?\n", show_create):            if line.startswith("  " + self.preparer.initial_quote):                self._parse_column(line, state)            # a regular table options line            elif line.startswith(") "):                self._parse_table_options(line, state)            # an ANSI-mode table options line            elif line == ")":                pass            elif line.startswith("CREATE "):                self._parse_table_name(line, state)            # Not present in real reflection, but may be if            # loading from a file.            elif not line:                pass            else:                type_, spec = self._parse_constraints(line)                if type_ is None:                    util.warn("Unknown schema content: %r" % line)                elif type_ == "key":                    state.keys.append(spec)                elif type_ == "fk_constraint":                    state.fk_constraints.append(spec)                elif type_ == "ck_constraint":                    state.ck_constraints.append(spec)                else:                    pass        return state

@log.class_loggerclass MySQLTableDefinitionParser(object):    """Parses the results of a SHOW CREATE TABLE statement."""
    def __init__(self, dialect, preparer):        self.dialect = dialect        self.preparer = preparer        self._prep_regexes()
    def parse(self, show_create, charset):        state = ReflectedState()        state.charset = charset
        for line in re.split(r"\r?\n", show_create):            if (line.startswith("  " + self.preparer.initial_quote)):                self._parse_column(line, state)            #  后面兼容ADB            elif (line.startswith(" " + self.preparer.initial_quote)):                self._parse_column(" " +line, state)            # a regular table options line            elif line.startswith(") "):                self._parse_table_options(line, state)            # an ANSI-mode table options line            elif line == ")":                pass            # 后面兼容ADB            elif (line.startswith("CREATE ")) or (line.startswith("Create ")):                self._parse_table_name(line, state)            # Not present in real reflection, but may be if            # loading from a file.            elif not line:                pass            else:                # 兼容ADB                if not line.startswith("  "):                    line = " " + line                # 兼容ADB 把key ix_job_name(`job_name`) 替换成KEY `ix_job_name` (`job_name`) ，要兼顾primary key 和 其他xxx key                line=line.replace("(","` (")                line=line.replace("  key ","  KEY `")                line=line.replace("key `","key ")                line=line.replace("  primary ","  PRIMARY ")
                type_, spec = self._parse_constraints(line)                if type_ is None:                    util.warn("Unknown schema content: %r" % line)                elif type_ == "key":                    state.keys.append(spec)                elif type_ == "fk_constraint":                    state.fk_constraints.append(spec)                elif type_ == "ck_constraint":                    state.ck_constraints.append(spec)                else:                    pass        return state

# 参考一个匹配字段的正则，改这个也可以，就是第一个方案，看了下，有点难度，放弃了。      """
        # `colname` <type> [type opts]        #  (NOT NULL | NULL)        #   DEFAULT ('value' | CURRENT_TIMESTAMP...)        #   COMMENT 'comment'        #  COLUMN_FORMAT (FIXED|DYNAMIC|DEFAULT)        #  STORAGE (DISK|MEMORY)        self._re_column = _re_compile(            r"  "            r"%(iq)s(?P<name>(?:%(esc_fq)s|[^%(fq)s])+)%(fq)s +"            r"(?P<coltype>\w+)"            r"(?:\((?P<arg>(?:\d+|\d+,\d+|"            r"(?:'(?:''|[^'])*',?)+))\))?"            r"(?: +(?P<unsigned>UNSIGNED))?"            r"(?: +(?P<zerofill>ZEROFILL))?"            r"(?: +CHARACTER SET +(?P<charset>[\w_]+))?"            r"(?: +COLLATE +(?P<collate>[\w_]+))?"            r"(?: +(?P<notnull>(?:NOT )?NULL))?"            r"(?: +DEFAULT +(?P<default>"            r"(?:NULL|'(?:''|[^'])*'|[\-\w\.\(\)]+"            r"(?: +ON UPDATE [\-\w\.\(\)]+)?)"            r"))?"            r"(?: +(?:GENERATED ALWAYS)? ?AS +(?P<generated>\("            r".*\))? ?(?P<persistence>VIRTUAL|STORED)?)?"            r"(?: +(?P<autoincr>AUTO_INCREMENT))?"            r"(?: +COMMENT +'(?P<comment>(?:''|[^'])*)')?"            r"(?: +COLUMN_FORMAT +(?P<colfmt>\w+))?"            r"(?: +STORAGE +(?P<storage>\w+))?"            r"(?: +(?P<extra>.*))?"            r",?$" % quotes        )
"""