python 使用mysql.connector 查询数据
使用mysql.connector 操作mysql数据库，首先需要创建连接，第二步是获得cursor，想要执行sql语句，需要调用cursor的execute方法。在上一篇教程中，我们已经向city表里写入了几条数据，现在演示如何获取这些数据
1. fetchall获取查询的全部数据
import mysql.connector
# 第一步，创建连接
mydb = mysql.connector.connect(
host="10.110.30.3", # 数据库主机地址
user="flink_user", # 数据库用户名
passwd="123456", # 数据库密码
port=6606,
database='flink_db'
)
sql = "select * from city"
mycursor = mydb.cursor() # 第二步，创建cursor
mycursor.execute(sql) # 第三步，执行sql
datas = mycursor.fetchall() # 第四步， fetchall 获取全部数据
for data in datas:
print(data)
程序输出结果
(11, '北京')
(12, '上海')
(13, '广州')
(14, '深圳')
2. fetchone 和 fetchmany
fetchone 从查询获取到的数据集合中取出一条数据
data = mycursor.fetchone() # fetchone 获取集合中的一条
print(data) # (11, '北京')
fetchmany 可以获取多条数据，需要指定获取数据条目的数量
data = mycursor.fetchmany(2) # fetchmany 获取2两条数据
print(data) # [(11, '北京'), (12, '上海')]
3. 获取字典形式的返回值
前面的例子里，查询获得数据都是以元组的形式返回的，这种格式不利于查看和处理，最受欢迎的格式是字典格式，这种格式需要在创建cursor时指定dictionary
sql = "select * from city"
mycursor = mydb.cursor(dictionary=True) # 第二步，创建cursor
mycursor.execute(sql) # 第三步，执行sql
data = mycursor.fetchone() # fetchone 获取集合中的一条
print(data) # {'id': 11, 'name': '北京'}
除了字典格式，还可以使用named_tuple格式
sql = "select * from city"
mycursor = mydb.cursor(named_tuple=True) # 第二步，创建cursor
mycursor.execute(sql) # 第三步，执行sql
data = mycursor.fetchone() # fetchone 获取集合中的一条
print(data) # Row(id=11, name='北京')评论