5.1 Pymysql库
1 本节要点
- 掌握pymysql库的使用
- 开发思路
2 课前准备
2.1 课程所需库
服务器输入
sudo pip3 install pymysql
本地主机输入
pip install pymysql
3 课程内容
3.1 Pymysql
3.1.1 数据查询
使用数据库管理工具在数据库中创建表单,并随意添加一些数据后,我们尝试在数据库查询表单内所有的数据:
import pymysql
# 连接database
conn = pymysql.connect(host='116.62.221.174',user="user1",password="123456",database="jdy_api",charset="utf8")
# 得到一个可以执行SQL语句的光标对象
cursor = conn.cursor()
sql = "SELECT * FROM personinformation"
try:
# 执行SQL语句
cursor.execute(sql)
conn.commit()
except Exception as e:
print(e)
conn.rollback()
#获得返回的数据
data = cursor.fetchall()
# 关闭光标对象
cursor.close()
# 关闭数据库连接
conn.close()
print(data)
3.1.2 定义插入数据的函数
import pymysql
def insert_into_mysql(a,c,b):
# 连接database
conn = pymysql.connect(host='116.62.221.174',user="user1",password="123456",database="jdy_api",charset="utf8")
# 得到一个可以执行SQL语句的光标对象
cursor = conn.cursor()
sql = "insert into personinformation values ('%s','%s','%s')" % (a,b,c)
print(sql)
try:
# 执行SQL语句
cursor.execute(sql)
conn.commit()
except Exception as e:
print(e)
conn.rollback()
#获得返回的数据
result = cursor.fetchone()
# 关闭光标对象
cursor.close()
# 关闭数据库连接
conn.close()
print(result)
3.2 开发思路
- 模块化思维 (import)
- 异常处理思维
- 异常处理
- 断点调试(Step)
import json
request_data = {"data": [{"aaa": 123, "bbb":234}]}
data_ = request_data['data']
data_0 = data_[0]
_id= data_0["_id"]