当前位置:   article > 正文

MySQL数据库基础(十五):PyMySQL使用介绍

pymysql使用

文章目录

PyMySQL使用介绍

一、为什么要学习PyMySQL

二、安装PyMySQL模块

三、PyMySQL的使用

1、导入 pymysql 包

2、创建连接对象

3、获取游标对象

4、pymysql完成数据的查询操作

5、pymysql完成对数据的增删改


PyMySQL使用介绍

提前安装MySQL数据库(可以使用Linux系统的,也可以使用Windows版本)

一、为什么要学习PyMySQL

如何实现将100000条数据插入到MySQL数据库?

如果使用之前学习的MySQL客户端来完成这个操作,那么这个工作量无疑是巨大的,我们可以通过使用程序代码的方式去连接MySQL数据库,然后对MySQL数据库进行增删改查的方式,实现100000条数据的插入,像这样使用代码的方式操作数据库就称为数据库编程。

二、安装PyMySQL模块

安装PyMySQL:

pip install pymysql

卸载PyMySQL:

pip uninstall pymysql

三、PyMySQL的使用

1、导入 pymysql 包

 import pymysql

2、创建连接对象

调用pymysql模块中的connect()函数来创建连接对象,代码如下:

  1. conn=connect(参数列表)
  2. * 参数host:连接的mysql主机,如果本机是'localhost'
  3. * 参数port:连接的mysql主机的端口,默认是3306
  4. * 参数user:连接的用户名
  5. * 参数password:连接的密码
  6. * 参数database:数据库的名称
  7. * 参数charset:通信采用的编码方式,推荐使用utf8

连接对象操作说明:

  • 关闭连接 conn.close()

  • 提交数据 conn.commit()

  • 撤销数据 conn.rollback()

3、获取游标对象

获取游标对象的目标就是要执行sql语句,完成对数据库的增、删、改、查操作。代码如下:

  1. # 调用连接对象的cursor()方法获取游标对象
  2. cur =conn.cursor()

游标操作说明:

  • 使用游标执行SQL语句: execute(operation [parameters ]) 执行SQL语句,返回受影响的行数,主要用于执行insert、update、delete、select等语句

  • 获取查询结果集中的一条数据:cur.fetchone()返回一个元组, 如 (1,'张三')

  • 获取查询结果集中的所有数据: cur.fetchall()返回一个元组,如((1,'张三'),(2,'李四'))

  • 关闭游标: cur.close(),表示和数据库操作完成

4、pymysql完成数据的查询操作

  1. import pymysql
  2. # 创建连接对象
  3. conn = pymysql.connect(host='localhost', port=3306, user='root', password='mysql',database='db_lanson', charset='utf8')
  4. # 获取游标对象
  5. cursor = conn.cursor()
  6. # 查询 SQL 语句
  7. sql = "select * from students;"
  8. # 执行 SQL 语句 返回值就是 SQL 语句在执行过程中影响的行数
  9. row_count = cursor.execute(sql)
  10. print("SQL 语句执行影响的行数%d" % row_count)
  11. # 取出结果集中一行数据, 例如:(1, '张三')
  12. # print(cursor.fetchone())
  13. # 取出结果集中的所有数据, 例如:((1, '张三'), (2, '李四'), (3, '王五'))
  14. for line in cursor.fetchall():
  15. print(line)
  16. # 关闭游标
  17. cursor.close()
  18. # 关闭连接
  19. conn.close()

5、pymysql完成对数据的增删改

  1. import pymysql
  2. # 创建连接对象
  3. conn = pymysql.connect(host='localhost', port=3306, user='root', password='mysql',database='db_lanson', charset='utf8')
  4. # 获取游标对象
  5. cursor = conn.cursor()
  6. try:
  7. # 添加 SQL 语句
  8. # sql = "insert into students(name) values('赵云'), ('王昭君');"
  9. # 删除 SQ L语句
  10. # sql = "delete from students where id = 6;"
  11. # 修改 SQL 语句
  12. sql = "update students set name = '王小丽' where id = 8;"
  13. # 执行 SQL 语句
  14. row_count = cursor.execute(sql)
  15. print("SQL 语句执行影响的行数%d" % row_count)
  16. # 提交数据到数据库
  17. conn.commit()
  18. except Exception as e:
  19. # 回滚数据, 即撤销刚刚的SQL语句操作
  20. conn.rollback()
  21. # 关闭游标
  22. cursor.close()
  23. # 关闭连接
  24. conn.close()

注:PyMySQL是基于事务进行操作的,所以在数据库增删改操作时,必须通过conn.commit() 方法将事务操作提交到数据库,如果事务操作没有成功,则可以通过conn.rollback()进行回滚(返回到数据的原始状态)。


推荐阅读
相关标签