通过pyodbc向Impala插入数据时遭遇‘unsupported query’错误

针对你遇到的问题，以下是几种可行的排查和解决方法：

1. 明确指定目标表列名 #

Cloudera ODBC驱动对INSERT语句的语法要求比Hue更严格，即使目标表的列顺序和SELECT结果完全匹配，也需要显式列出列名。修改语句如下：

INSERT INTO db_name.tbl_name (field_name, your_time_column_name)
SELECT DISTINCT field_name, now() 
FROM db_name.tbl_name 
WHERE field_name NOT IN (SELECT field_name FROM someothertable)

注意：把your_time_column_name替换成目标表中对应时间字段的实际名称

2. 替换now()为标准时间函数 #

部分旧版本Cloudera ODBC驱动对Hive的now()函数支持不完善，换成标准SQL的current_timestamp()函数试试：

INSERT INTO db_name.tbl_name (field_name, your_time_column_name)
SELECT DISTINCT field_name, current_timestamp() 
FROM db_name.tbl_name 
WHERE field_name NOT IN (SELECT field_name FROM someothertable)

3. 替换NOT IN子查询为LEFT JOIN写法 #

NOT IN子查询在某些ODBC驱动中兼容性较差，改用LEFT JOIN + IS NULL的等价逻辑：

INSERT INTO db_name.tbl_name (field_name, your_time_column_name)
SELECT DISTINCT t.field_name, current_timestamp()
FROM db_name.tbl_name t
LEFT JOIN someothertable s 
  ON t.field_name = s.field_name
WHERE s.field_name IS NULL

4. 检查ODBC驱动版本 #

确保你使用的是最新版的Cloudera ODBC Driver for Apache Hive，旧版本驱动对复杂查询的支持有限，升级到最新版通常能解决很多兼容性问题。

5. 验证语句格式 #

检查读取的SQL语句是否存在多余的空白字符或格式问题，比如可以在读取后手动添加分号结尾：

with open('file/location.iql') as script:
    statement = script.read().strip() + ';'
    crsr = conn.cursor()
    crsr.execute(statement)

内容的提问来源于stack exchange，提问作者Sanchez333