# 当做一个外部函数
def connect_database(query):
# mysql的连接配置
conn = pymysql.connect(
host='localhost', # 本机地址
port=3306, # mysql的端口号
user='root', # mysql的管理员账号
password='1fcSCyYOFRDxKwd', # 密码 1fcSCyYOFRDxKwd
database='school', # 需要连接的数据库
charset='utf8mb4', # 编码格式
)
cur = conn.cursor()
cur.execute(query)
rows = cur.fetchall()
index = cur.description
result = []
for res in rows:
row = {}
for i in range(len(index) - 1):
row[index[i][0]] = res[i]
result.append(row)
# conn.commit() # 这个对于增删改是必须的,否则事务没提交执行不成功
cur.close()
conn.close()
return result
标签:index,cur,python,获取,result,mysql,conn,row
From: https://www.cnblogs.com/Listener-wy/p/18528729