6.python操作数据库

pymysql之增删改查

1.创建一个表

# @AuThor  : frank_lee
import pymysql

# 打开数据库连接
db = pymysql.connect("localhost", "root", "", "test", charset="utf8")

# 使用 cursor() 方法创建一个游标对象 cursor
cursor = db.cursor()

# 使用 execute() 方法执行 SQL，如果表存在则删除
cursor.execute("DROP TABLE IF EXISTS courses")

# 使用预处理语句创建表
sql = """CREATE TABLE  courses (
 student varchar(255) DEFAULT NULL,
  class varchar(255) DEFAULT NULL
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
"""
try:
    # 执行sql语句
    cursor.execute(sql)
    # 提交到数据库执行
    db.commit()
except:
    # 如果发生错误则回滚
    db.rollback()

# 关闭数据库连接
db.close()

2.朝表里增加点东西

# @AuThor  : frank_lee
import pymysql

# 打开数据库连接
db = pymysql.connect("localhost", "root", "", "test", charset="utf8")

# 使用 cursor() 方法创建一个游标对象 cursor
cursor = db.cursor()

# 使用预处理语句创建表
sql = """
INSERT INTO courses(student, class) VALUES ('张三', 'Math'),('李四', 'English');
"""

try:
    # 执行sql语句
    cursor.execute(sql)
    # 提交到数据库执行
    db.commit()
except:
    # 如果发生错误则回滚
    db.rollback()

# 关闭数据库连接
db.close()

3.从表里删除点东西

sql = """
delete from courses where student = "张三"
"""

4.在表里改动点东西

sql = """
update courses set class="Chinese" where student = "李四"
"""

5.查询操作

# -*- coding: utf-8 -*-
# @AuThor  : frank_lee
import pymysql

# 打开数据库连接
db = pymysql.connect("localhost", "root", "", "test", charset="utf8")

# 使用 cursor() 方法创建一个游标对象 cursor
cursor = db.cursor()

# 使用预处理语句创建表
sql = """
select * from courses where student = "李四"
"""

try:
    # 执行sql语句
    cursor.execute(sql)
    # 提交到数据库执行
    print(cursor.fetchall())
except:
    # 如果发生错误则回滚
    db.rollback()

# 关闭数据库连接
db.close()