# Python 连接 Mysql 并且是实现增删改
- 源码如下
import pymysql
# 连接数据库函数
def conn_db():
conn = pymysql.connect(
host=localhost,
user=root,
passwd=1234,
db=product,
charset=utf8)
cur = conn.cursor()
return conn, cur
def exe_update(cur, sql): # 更新语句，可执行update,insert语句
sta = cur.execute(sql)
return sta
def exe_commit(cur):
cur.connection.commit() # 执行commit操作，插入语句才能生效
def conn_close(conn, cur): # 关闭所有连接
cur.close()
conn.close()
name = lisi
yuanliao = Hellow wewrqo
pic = "D://one.txt"
merchants = "第一家店铺"
# 调用连接数据库的函数
conn, cur = conn_db()
sta = exe_update(cur, "insert into product(name, yuanliao, pic,merchants) ""values(%s,%s,%s,%s)" % (
name, yuanliao, pic, merchants))
if sta == 1:
print(插入成功)
else:
print(插入失败)
exe_commit(cur) # 注意！！ 一定要记得commit，否则操作成功了，但是并没有添加到数据库中
conn_close(conn, cur)
上一篇：
多线程四大经典案例