如何通过python连接hive,并对里面的表进行增删改查操作
时间: 2024-02-18 09:00:06 浏览: 145
可以通过Python中的PyHive库来连接Hive,并对其中的表进行增删改查操作。以下是一个简单的示例代码:
```python
from pyhive import hive
# 连接Hive
conn = hive.Connection(host='localhost', port=10000, username='username')
# 创建游标
cursor = conn.cursor()
# 查询表中的数据
cursor.execute('SELECT * FROM my_table')
result = cursor.fetchall()
print(result)
# 插入数据
cursor.execute("INSERT INTO my_table (col1, col2) VALUES ('value1', 'value2')")
# 更新数据
cursor.execute("UPDATE my_table SET col1='new_value' WHERE col2='value2'")
# 删除数据
cursor.execute("DELETE FROM my_table WHERE col2='value2'")
# 关闭游标和连接
cursor.close()
conn.close()
```
需要注意的是,PyHive库默认使用的是Thrift协议连接Hive,因此需要确保HiveServer2已启动,并监听了默认的Thrift端口10000。同时,需要根据具体情况修改连接参数,如hostname、username、password等。
阅读全文