|
@@ -141,7 +141,7 @@ class HiveDS(DataSourceBase):
|
|
|
for col in table_schema:
|
|
|
c = col.split(':')
|
|
|
c_list.append(c)
|
|
|
- sql2 = f"SELECT * FROM {table_name} LIMIT {page},{limit}"
|
|
|
+ sql2 = f"SELECT * FROM `{table_name}` LIMIT {page},{limit}"
|
|
|
res = self._execute_sql([ sql2])
|
|
|
logger.info(res)
|
|
|
return {
|
|
@@ -150,7 +150,7 @@ class HiveDS(DataSourceBase):
|
|
|
}
|
|
|
|
|
|
def get_data_num(self, table_name):
|
|
|
- sql2 = f"SELECT 1 FROM {table_name}"
|
|
|
+ sql2 = f"SELECT 1 FROM `{table_name}`"
|
|
|
res = self._execute_sql([sql2])
|
|
|
return len(res[0])
|
|
|
|
|
@@ -162,7 +162,7 @@ class HiveDS(DataSourceBase):
|
|
|
|
|
|
def get_table_schema(self, table_name):
|
|
|
logger.info(self.database_name)
|
|
|
- sql_test = f'desc {self.database_name}.{table_name}'
|
|
|
+ sql_test = f'desc `{self.database_name}`.`{table_name}`'
|
|
|
res_test = self._execute_sql([sql_test])
|
|
|
table_schema = []
|
|
|
if res_test and len(res_test) > 0:
|