PyMySQL模块怎么用
admin
2023-07-09 12:23:55
0次

官方教程

import pymysql.cursors

# 连接数据库
connection = pymysql.connect(host='localhost',
                             user='user',
                             password='passwd',
                             db='db',
                             charset='utf8mb4',
                             cursorclass=pymysql.cursors.DictCursor)

try:
    with connection.cursor() as cursor:
        # 增加一条数据
        sql = "INSERT INTO `users` (`email`, `password`) VALUES (%s, %s)"
        cursor.execute(sql, ('webmaster@python.org', 'very-secret'))

    connection.commit()

    with connection.cursor() as cursor:
        # 查询数据
        sql = "SELECT `id`, `password` FROM `users` WHERE `email`=%s"
        cursor.execute(sql, ('webmaster@python.org',))
        result = cursor.fetchone()
        print(result)
finally:
    connection.close()

备查

# 获取输入SQL语句的光标对象，指定返回的数据格式为字典格式
cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)

# 执行sql语句
cursor.execute(sql, (username, pwd))

# 提交事务
conn.commit()

# 获取单条查询数据
ret = cursor.fetchone()

# 返回所有数据
ret = cursor.fetchall()

# 回滚
conn.rollback()

基本使用

# 导入模块
import pymysql

username = input("请输入用户名: ")
pwd = input("请输入密码: ")

# 连接数据库
conn = pymysql.connect(host="localhost",
                       port=3306,
                       database="userinfo",
                       user='root',
                       password="123456",
                       charset="utf8"
                       )

# 获取输入SQL语句的光标对象
cursor = conn.cursor()

# 定义要执行的SQL语句
sql = "select * from info WHERE username=%s and password=%s;"

# 执行sql语句，让pymysql帮我们拼接SQL语句
cursor.execute(sql, (username, pwd))

# 关闭光标对象
cursor.close()

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

返回字典格式的数据

# 获取输入SQL语句的光标对象，指定返回的数据格式为字典格式
cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)

增删改查操作

增

import pymysql

# 获取用户输入
username = input("请输入用户名: ")
pwd = input("请输入密码: ")

# 连接数据库
conn = pymysql.connect(host="localhost",
                       port=3306,
                       database="userinfo",
                       user='root',
                       password="123456",
                       charset="utf8"
                       )

# 获取输入SQL语句的光标对象
cursor = conn.cursor()

# sql语句
sql = "insert into info (username, password) VALUES (%s, %s);"

# 执行sql语句
cursor.execute(sql, [username, pwd])

# 提交
conn.commit()

# 关闭光标对象和连接
cursor.close()
conn.close()

插入数据失败回滚
在执行增删改操作时，如果不想提交前面的操作，可以使用 rollback() 回滚取消操作。

import pymysql

# 获取用户输入
username = input("请输入用户名: ")
pwd = input("请输入密码: ")

# 连接数据库
conn = pymysql.connect(host="localhost",
                       port=3306,
                       database="userinfo",
                       user='root',
                       password="123456",
                       charset="utf8"
                       )

# 获取输入SQL语句的光标对象
cursor = conn.cursor()

# 拼接sql语句
sql = "insert into info (username, password) VALUES (%s, %s);"

# 执行sql语句
# 让pymysql帮我们拼接SQL语句(传入的参数可以是列表也可以是元祖，一定要是一个可迭代对象)

try:
    cursor.execute(sql, [username, pwd])
    # 提交
    conn.commit()
except Exception as e:
    print("报错啦：", str(e))
    conn.rollback() # 回滚

# 关闭光标对象和连接
cursor.close()
conn.close()

获取插入数据的ID(关联操作时会用到)

import pymysql

# 获取用户输入
username = input("请输入用户名: ")
pwd = input("请输入密码: ")

# 连接数据库
conn = pymysql.connect(host="localhost",
                       port=3306,
                       database="userinfo",
                       user='root',
                       password="123456",
                       charset="utf8"
                       )

# 获取输入SQL语句的光标对象
cursor = conn.cursor()

# 拼接sql语句
sql = "insert into info (username, password) VALUES (%s,%s);"

# 执行sql语句
cursor.execute(sql, [username, pwd])

# 提交
conn.commit()

# 提交之后，获取刚插入的数据的ID
last_id = cursor.lastrowid

# 关闭光标对象和连接
cursor.close()
conn.close()

批量执行

import pymysql

# 连接数据库
conn = pymysql.connect(host="localhost",
                       port=3306,
                       database="userinfo",
                       user='root',
                       password="123456",
                       charset="utf8"
                       )

# 获取光标对象
cursor = conn.cursor()

data = [("奔驰哥", 123456), ("小宝宝", 123456), ("教主", 123456)]

# sql语句
sql = "insert into info(username, password) VALUES (%s, %s)"

# 批量插入
cursor.executemany(sql, data)

# 提交
conn.commit()

# 关闭光标对象和连接
cursor.close()
conn.close()

删

import pymysql

# 连接数据库
conn = pymysql.connect(host="localhost",
                       port=3306,
                       database="userinfo",
                       user='root',
                       password="123456",
                       charset="utf8"
                       )

# 获取光标对象
cursor = conn.cursor()

# sql语句
sql = "delete from info where id=%s"

# 执行SQL语句
cursor.execute(sql, [1])

# 提交事务
conn.commit()

# 关闭光标对象和连接
cursor.close()
conn.close()

改

import pymysql

# 连接数据库
conn = pymysql.connect(host="localhost",
                       port=3306,
                       database="userinfo",
                       user='root',
                       password="123456",
                       charset="utf8"
                       )

# 获取输入SQL语句的光标对象
cursor = conn.cursor()

# sql语句
sql = "update info set password=%s where id=%s"

password = "654321"
id = 2

cursor.execute(sql, [password, id])
conn.commit()

cursor.close()
conn.close()

查

查询单条数据

import pymysql

# 连接数据库
conn = pymysql.connect(host="localhost",
                       port=3306,
                       database="userinfo",
                       user='root',
                       password="123456",
                       charset="utf8"
                       )

# 获取输入SQL语句的光标对象，指定返回的数据格式为字典格式
cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)

sql = "select * from info"

# 提交事务
cursor.execute(sql)

# 获取单条查询数据
ret = cursor.fetchone()

# 返回所有数据
ret = cursor.fetchall() 

# 关闭光标和连接
cursor.close()
conn.close()

进阶用法

查询后光标就会移动，下次查询就会再上次查询的数据之后开始新的查询

# 可以获取指定数量的数据
cursor.fetchmany(3)

# 光标按绝对位置移动1
cursor.scroll(1, mode="absolute")

# 光标按照相对位置(当前位置)移动1
cursor.scroll(1, mode="relative")

错误处理

异常描述
Warning当有严重警告时触发，例如插入数据是被截断等等。
Error警告以外所有其他错误类。
InterfaceError当有数据库接口模块本身的错误（而不是数据库的错误）发生时触发。
DatabaseError和数据库有关的错误发生时触发。
DataError当有数据处理时的错误发生时触发，例如：除零错误，数据超范围等等。
OperationalError指非用户控制的，而是操作数据库时发生的错误。例如：连接意外断开、 数据库名未找到、事务处理失败、内存分配错误等等操作数据库是发生的错误。
IntegrityError完整性相关的错误，例如外键检查失败等。
InternalError数据库的内部错误，例如游标（cursor）失效了、事务同步失败等等。
ProgrammingError程序错误，例如数据表（table）没找到或已存在、SQL语句语法错误、 参数数量错误等等。
NotSupportedError不支持错误，指使用了数据库不支持的函数或API等。例如在连接对象上 使用.rollback()函数，然而数据库并不支持事务或者事务已关闭。

上一篇：三元运算符,文件处理的可读可写

下一篇：告诉必备一起宁德钓蟹辅助器-到底可以开挂不

相关内容

热门资讯

美前副总统：共和党失去了方向，... 2026年是美国的中期选举年，共和党选情不利，可能在年底的选举中遭遇挫败。美国前副总统彭斯5月31日...
南枝原来去过中国？《给阿嬷的情... 《给阿嬷的情书》票房口碑双丰收，目前票房已突破13亿。凤凰卫视最新一期《问答神州》专访了该片导演蓝鸿...
法国海军扣押一艘俄“影子舰队”... 近日，法国海军在大西洋海域扣押了一艘据称从俄罗斯摩尔曼斯克出发的油轮，引发俄方强烈不满。俄新社6月1...
凤凰晚报丨面粉染头模仿黄仁勋，... 今日人物【面粉染头模仿黄仁勋，农村青年走红后称遭“法务”警告】“先赔偿5000元肖像侵权使用费，再删...
亲特朗普极右派候选人领跑哥伦比... 【文/观察者网 熊超然】当地时间5月31日，哥伦比亚总统选举拉开帷幕，首轮投票计票工作已完成逾99%...
2026年度网络举报系列宣传活... 5月28日至29日，以“每一件举报，都是共治的力量——豫你e行 同心护网”为主题的2026年度网络举...
中原首例帝企鹅DNA性别鉴定！... 近日，郑州海昌海洋公园正式对外公布中原首对人工繁育的帝企鹅萌宝的DNA性别鉴定报告。这是中原首个将 ...
我国科学家为细胞信号“导航”开... 新华社济南5月31日电（记者张力元）人体细胞犹如一座精密的通信城市，每天都有大量“指令”穿梭传递，调...
极端大风突袭哈尔滨！过山车停摆... 极目新闻记者 詹钘5月31日，受强对流天气影响，哈尔滨国际会展中心体育场相关设施受到损坏，原计划当晚...
三原电缆取得电缆接头连接用防护... 国家知识产权局信息显示，上海三原电缆附件有限公司取得一项名为“一种电缆接头连接用防护结构”的专利，授...