与 Hive 的 Python 连接

Posted 2023-02-15

【中文标题】与 Hive 的 Python 连接

【英文标题】：Python Connection to Hive

【发布时间】：2015-06-22 06:12:27

【问题描述】：

我安装了 Hortonworks Hive ODBC 驱动程序并在数据源中创建了一个连接。我测试了它，它成功了。

我安装了 PyODBC 并编写了以下代码

import os, sys, pyodbc;
con = pyodbc.connect("DSN=MyCon")

我有错误

Traceback (most recent call last):
  File "<stdin>", line 1, in <module>
pyodbc.Error: ('HYC00', '[HYC00] [Hortonworks][ODBC] (11470) Transactions are not supported. (11470) (SQLSetConnnectAttr(SQL_ATTR_AUTOCOMMIT))')

我也试过

import pyodbc, sys, os
pyodbc.pooling = False
pyodbc.autocommit = False
con = pyodbc.connect("DSN=MyCon")

Traceback (most recent call last):
  File "<stdin>", line 1, in <module>
pyodbc.Error: ('HYC00', '[HYC00] [Hortonworks][ODBC] (11470) Transactions are not supported. (11470) (SQLSetConnnectAttr(SQL_ATTR_AUTOCOMMIT))')

也试过了

con = pyodbc.connect("DSN=Tenet", autocommit=False)


Traceback (most recent call last):
  File "<stdin>", line 1, in <module>
pyodbc.Error: ('HYC00', '[HYC00] [Hortonworks][ODBC] (11470) Transactions are not supported. (11470) (SQLSetConnnectAttr(SQL_ATTR_AUTOCOMMIT))')

【参考方案1】：

我解决了.....我不会删除我的问题并将答案放在这里

pyodbc.autocommit = True
con = pyodbc.connect("DSN=MyCon", autocommit=True)

这是根据本文的建议完成的

https://code.google.com/p/pyodbc/issues/detail?id=162

** 感谢下面 Kyle Porter 的建议......现在完全有道理了 **

【讨论】：

稍微澄清一下，您实际上并没有关闭自动提交，而是指定 pyodbc 保持自动提交。 ODBC 说默认情况下应该打开自动提交，Python 说它应该关闭，所以 pyodbc 作为第一步尝试关闭自动提交。当驱动程序/数据库不支持事务（如 Hive）时，这会失败，这就是您收到此错误的原因。告诉 pyodbc 它应该保持自动提交功能意味着它不会向驱动程序发出关闭自动提交功能的调用，然后一切都会正常工作。

出色的答案。正在苦苦挣扎，发现这很有用。