python 操作MySQL

mysql 表数据

Python安装pymysql:pip install PyMySQL

import pymysql
# 打开数据库连接
connect = pymysql.Connect(
    host='localhost',
    port=3306,
    user='root',
    passwd='123456',
    db='test',
    charset='utf8'
)

# 使用cursor()方法获取操作游标
cur = connect.cursor()
# 增加
sql = "INSERT INTO student VALUES ('%s','%s','%s','%s')" % (6, "李思思", 9, "女")
try:
    cur.execute(sql)
    connect.commit()
except:
    connect.rollback()

# 查询
sql = "SELECT * FROM student"
cur.execute(sql)
# 获取所有记录列表
result = cur.fetchall()
for row in result:
    Sn0 = row[0]
    Sname = row[1]
    Sage = row[2]
    Ssex = row[3]
    print("Sno=%s,Sname=%s,Sage=%s,Ssex=%s" % (Sn0, Sname, Sage, Ssex))

# 删除
sql = "DELETE FROM student WHERE Sno='%s'" % 6
try:
    cur.execute(sql)

    # 提交到数据库执行
    connect.commit()
except:
    # 发生错误时回滚
    connect.rollback()

sql = "SELECT * FROM student"
cur.execute(sql)
result = cur.fetchall()
for row in result:
    Sn0 = row[0]
    Sname = row[1]
    Sage = row[2]
    Ssex = row[3]
    print("Sno=%s,Sname=%s,Sage=%s,Ssex=%s" % (Sn0, Sname, Sage, Ssex))

# 更新
sql = "UPDATE student SET Sage = '%s' WHERE Sno = '%s'" % (19,4)
try:
    cur.execute(sql)

    # 提交到数据库执行
    connect.commit()
except:
    # 发生错误时回滚
    connect.rollback()

sql = "SELECT * FROM student"
cur.execute(sql)
result = cur.fetchall()
for row in result:
    Sn0 = row[0]
    Sname = row[1]
    Sage = row[2]
    Ssex = row[3]
    print("Sno=%s,Sname=%s,Sage=%s,Ssex=%s" % (Sn0, Sname, Sage, Ssex))
# 关闭数据库连接
connect.close()