pymysql简单使用

在 python 中 mysql 数据库的简单使用,此处不介绍 mysql 数据库的使用


1. 下载pymysql软件包

命令行窗口运行pip install pymysql,即可安装pymysql包,注:pip在下载python时已经自带。

下载pymysql软件包

如果 在下载时发现是下载速度较慢可以更换pip的下载的地址 (此处的是清华大学的镜像)

pip config set global.index-url https://pypi.tuna.tsinghua.edu.cn/simple/

输入完上面的代码,设置镜像地址后,再重新安装即可使用镜像下载。

扩展知识:pip config unset global.index-url 表示不设置下载源,即恢复默认下载地址.

更换下载源+下载pymysql软件包

2. 使用pymysql工具

2.1 与数据库建立连接

从pymysql中导入连接对象,并提供连接数据库信息创建连接对象

# 导入pymysql
from pymysql import Connection

# 提供相关参数建立数据库连接
conn = Connection(
    host="localhost",  # 地址
    port=3306,  # 端口号
    user="root",  # 用户名
    password="123456",  # 密码
    autocommit=True  # 自动提交
)

此处的autocommit=True # 自动提交 是设置为默认提交,当然你也可以选择手动提交(默认值为False,即不自动提交),只需要在希望更新数据库时调用conn.commit()即可。其底层就是mysql的事务transaction。

2.2 执行sql语句

要执行sql语句首先需要获取到 cursor 游标对象(鼠标),通过 cursor 的 execute(str) 方法去执行slq语句,具体方式如下:

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

# 执行sql语句
cursor.execute("create database test")  # 创建数据库test

上面执行的语句是创建数据库,并没有指定当前使用的数据库。如果你要对某个数据库内进行操作时,需要先指定当前连接的数据库具体是哪个。这里我们就选择使用刚创建的test的数据库了。

注意:如果创建的数据库已经存在,即sql语句无法正常运行,代码本身是会抛出异常中断的。

如果已经执行了这段代码,你可以选择:

  1. 删除数据库 test
  2. cursor.execute("create database test")暂时注释掉
  3. 在创建数据库的前面添加条件删除语句drop database if exists test

(包括下面create table 创建表 的语句也是如此,后面就不在提示了,这里我就用方法2,直接注释掉了)

# 为连接指定数据库
conn.select_db("test")  # 指定使用数据库为test

# 创建表user
cursor.execute(
    """
    create table user
    (
        id       int primary key auto_increment comment '用户身份标识',
        username varchar(20) comment '用户名',
        password varchar(20) comment '密码'
    ) comment '用户表';
    """
)

2.3 基本 增删改查 示例

基本的 增删改 操作都是直接使用 cursor.execute() 执行相应sql语句即可,对了,如果在创建连接的时候没有设置autocommit=True自动提交的话,在进行完以下操作后,执行conn.commit()提交更改,当然我设置了自动提交,这里就把它注释掉了。

# 增 
cursor.execute("insert into user (username, password) values ('zhangsan', '123')")  # 添加用户1
cursor.execute("insert into user (username, password) values ('lisi', '1234');")  # 添加用户2

# 删
cursor.execute("delete from user where id = 1")  # 删除id为1的用户

# 改
cursor.execute("update user set password = '123456'")  # 设置所有用户密码为123456

# 提交修改
# conn.commit()

对于查询操作有些许特殊,因为他是需要一个返回值的。但基本思路和上面基本一致,只是在执行完查询语句后需要使用cursor.fetchall()方法拿出结果。

# 查
cursor.execute("select * from user")  # 执行sql:获取所有用户信息
# 获取执行结果的返回信息,类型为元组嵌套,即tuple[tuple[Any, ...], ...]
result: tuple = cursor.fetchall()
# 打印查询的结果
for m in result:
    print(m)

注意:如果执行了多条sql查询语句,cursor.fetchall() 只会拿回最近一次的返回数据,而前面的数据都会被覆盖掉。

2.4 关闭连接

这个按道理应该放在开头,但是为了保证代码的正确顺序,而不至于太乱。所有我将其放在最后。就是关闭资源

# 关闭连接
cursor.close()
conn.close()

3 操作完整代码

  • sql代码实现:
# 创建数据库test
create database test;

# 使用数据库test
use test;

# 创建表user
create table user
(
    id       int primary key auto_increment comment '用户身份标识',
    username varchar(20) comment '用户名',
    password varchar(20) comment '密码'
) comment '用户表';

# 增
insert into user (username, password) values ('zhangsan', '123');
insert into user (username, password) values ('lisi', '1234');

# 删
delete from user where id = 1;

# 改
update user set password = '123456';

# 查1
select * from user;

  • python调用实现:
# 导入pymysql
from pymysql import Connection

# 提供相关参数建立数据库连接
conn = Connection(
    host="localhost",  # 地址
    port=3306,  # 端口号
    user="root",  # 用户名
    password="123456",  # 密码
    autocommit=True  # 自动提交
)

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

# # 执行sql语句
# cursor.execute("create database test")  # 创建数据库test

# 为连接指定数据库
conn.select_db("test")  # 指定数据库为test

# # 创建表user
# cursor.execute(
#     """
#     create table user
#     (
#         id       int primary key auto_increment comment '用户身份标识',
#         username varchar(20) comment '用户名',
#         password varchar(20) comment '密码'
#     ) comment '用户表';
#     """
# )

# 增
cursor.execute("insert into user (username, password) values ('zhangsan', '123')")  # 添加用户1
cursor.execute("insert into user (username, password) values ('lisi', '1234');")  # 添加用户2

# 删
cursor.execute("delete from user where id = 1")  # 删除id为1的用户

# 改
cursor.execute("update user set password = '123456'")  # 设置所有用户密码为123456

# 提交修改
# conn.commit()

# 查
cursor.execute("select * from user")  # 获取所有用户信息
result: tuple = cursor.fetchall()  # 获取执行结果的返回值,类型为元组嵌套,即tuple[tuple[Any, ...], ...]
# 打印查询的结果
for m in result:
    print(m)

# 关闭连接
cursor.close()
conn.close()

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 200,612评论 5 471
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 84,345评论 2 377
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 147,625评论 0 332
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,022评论 1 272
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 62,974评论 5 360
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,227评论 1 277
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,688评论 3 392
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,358评论 0 255
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,490评论 1 294
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,402评论 2 317
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,446评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,126评论 3 315
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,721评论 3 303
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,802评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,013评论 1 255
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 42,504评论 2 346
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,080评论 2 341

推荐阅读更多精彩内容