Python 连接 MySQL 和 Phoenix 数据库示例
import pymysql
import phoenixdb.cursor
from datetime import datetime
# 建立MySQL数据库连接
mysql_connection = pymysql.connect(
host='localhost',
user='root',
password='root',
database='test',
charset='utf8mb4'
)
# 建立Phoenix数据库连接
phoenix_connection = phoenixdb.connect('http://192.168.126.100:8765/', autocommit=True)
phoenix_cursor = phoenix_connection.cursor()
try:
# 创建MySQL游标对象
mysql_cursor = mysql_connection.cursor()
代码解读内容:
- 引入
pymysql和phoenixdb.cursor模块,以及datetime模块。 - 建立 MySQL 数据库连接,连接到本地的
test数据库,使用utf8mb4编码。 - 建立 Phoenix 数据库连接,连接到 IP 为
192.168.126.100,端口为8765的 Phoenix 数据库,设置自动提交。 - 创建 MySQL 游标对象。
- 异常处理。
原文地址: https://www.cveoy.top/t/topic/oHce 著作权归作者所有。请勿转载和采集!