本文介绍如何在Python中通过MySQLdb的module连接AnalyticDB MySQL集群。
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
# 打开数据库连接。
# host是AnalyticDB MySQL集群的URL或IP。
# port是AnalyticDB MySQL集群的URL对应的端口。
# user是AnalyticDB MySQL集群的用户账号:高权限账号或者普通账号。
# passwd是AnalyticDB MySQL集群的用户账号对应的密码。
# db是AnalyticDB MySQL集群中的数据库名。
db = MySQLdb.connect(host='am-bp***.ads.aliyuncs.com', port=3306, user='account_name', passwd='account_password', db='db_name')
# 使用cursor()方法获取操作游标。
cursor = db.cursor()
# 使用execute方法执行SQL语句。
cursor.execute("SELECT VERSION()")
# 使用 fetchone() 方法获取一条数据。
data = cursor.fetchone()
# 示例中的print仅适用Python 2。Python 3的print需要加括号,print ("Database version : %s " % data)。
print "Database version : %s " % data
# 关闭数据库连接。
db.close()