python读写hive数据库

在Python中，可以使用PyHive库来连接和操作Apache Hive数据库。以下是基本步骤：

1. **安装PyHive**：
首先，需要通过pip安装PyHive，以及它依赖的 thrift（如果未安装）：

   pip install pyhive[mysql] thrift

如果你使用的是Hadoop HDFS，还需要安装hms（Hive Metastore）客户端。

2. **连接到Hive服务器**：

   from pyhive import hive

   conn = hive.Connection(host='your_host', port=port, username='your_username', database='your_database')
   cursor = conn.cursor()

3. **执行SQL查询**：

   cursor.execute("SELECT * FROM your_table")
   results = cursor.fetchall()
   for row in results:
       print(row)

4. **写入数据**：

   query = "INSERT INTO TABLE your_table (column1, column2) VALUES (%s, %s)"
   cursor.execute(query, ('value1', 'value2'))
   conn.commit()  # 确保数据保存

5. **关闭连接**：

   cursor.close()
   conn.close()