获取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