0%

获取clickhouse表的字段类型, 并以返回默认值用于填充

获取clickhouse表的字段类型, 并以返回默认值用于填充

def d_type_change(self, db_name: str, sheet_name: str):
    """
    获取表的字段类型, 并并返回默认值用于填充
    """
    columns_type = self.client.query_dataframe(f"desc `{db_name}`.`{sheet_name}`")[["name", "type"]]
    columns_dict = {n: m for n, m in zip(columns_type["name"], columns_type["type"])}
    for i in columns_dict.keys():
        if 'int' in columns_dict[i].lower():
            columns_dict[i] = -2
        elif 'float' in columns_dict[i].lower():
            columns_dict[i] = -2.0
        elif 'string' in columns_dict[i].lower():
            columns_dict[i] = 'NULL'
    return columns_dict

原文博主: 热衷开源的宝藏Boy
原文链接: http://www.fangzengye.com/article/9e6f15fbdb465109281a09264e65a8ff
版权声明: 自由转载-非商用-禁止演绎-保持署名| CC BY-NC-ND 3.0

微信扫码加入我的星球联系我

评论区