ソースを参照

Merge branch 'master' of http://gogsb.soaringnova.com/sxwl_DL/datax-admin

Zhang Li 2 年 前
コミット
e0d1eeb96f
1 ファイル変更3 行追加3 行削除
  1. 3 3
      app/core/datasource/hive.py

+ 3 - 3
app/core/datasource/hive.py

@@ -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: