PyMysql

什么是PyMysql

   PyMysql是一个纯 Python 实现的 MySQL 客户端库，允许你在 Python 步伐中与 MySQL 数据库进行交互。
  安装PyMysql

PyMysql地址：https://pypi.org/project/PyMySQL/

1. pip install pymysql

复制代码

---

利用PyMysql

毗连mysql

1. import pymysql
3. # 数据库连接参数
4. host = '192.168.189.71'     # 数据库主机地址
5. port = 3306                 # 数据库端口
6. user = 'root'               # 数据库用户名
7. password = '123456'         # 数据库密码
8. database = 'test'           # 数据库名称
9. charset = 'utf8mb4'         # 编码格式
11. # 连接到数据库
12. connection = pymysql.connect(
13.     host=host,
14.     port=port,
15.     user=user,
16.     password=password,
17.     database=database,
18.     charset=charset,
19.     # cursorclass=pymysql.cursors.DictCursor # 使用字典类型游标
20. )
22. print("连接成功")

复制代码

查询数据

1. # 创建游标对象
2. cursor = connection.cursor()
4. # 执行SQL查询
5. sql = "select * from table_test;"
6. cursor.execute(sql)
8. # 获取查询结果
9. results = cursor.fetchall()
10. for row in results:
11.     print(row)
13. # 关闭游标
14. cursor.close()

复制代码

查询打印到的数据

• 元组类型数据
  

• 字典类型数据
  

添加数据

1. try:
2.     # 创建游标对象
3.     cursor = connection.cursor()
4.    
5.     # 编写sql语句
6.     sql = "insert into table_test (id, name, age) VALUES (%s, %s, '22')"
7.     values = (3, 'Spike')  # sql参数
9.     # 执行SQL插入
10.     cursor.execute(sql, values)
11.     # 提交事务
12.     connection.commit()
13.     print("数据插入成功")
14. except Exception as e:
15.     # 出现异常，回滚事务
16.     connection.rollback()
17. finally:
18.     # 关闭游标
19.     cursor.close()
20.     # 关闭连接
21.     connection.close()

复制代码

更新数据

1. try:
2.     # 创建游标对象
3.     cursor = connection.cursor()
4.    
5.     # 编写sql语句
6.     sql = "UPDATE table_test SET age = %s WHERE id = %s"
7.     values = (30, 3)
9.     # 执行SQL
10.     cursor.execute(sql, values)
11.     # 提交事务
12.     connection.commit()
13.     print("数据更新成功")
14. except Exception as e:
15.     # 出现异常，回滚事务
16.     connection.rollback()
17. finally:
18.     # 关闭游标
19.     cursor.close()
20.     # 关闭连接
21.     connection.close()

复制代码

删除数据

1. try:
2.     # 创建游标对象
3.     cursor = connection.cursor()
5.     # 编写sql语句
6.     sql = "DELETE FROM table_test WHERE id = %s"
7.     value = (3,)
9.     # 执行SQL
10.     cursor.execute(sql, value)
11.     # 提交事务
12.     connection.commit()
13.     print("数据删除成功")
14. except Exception as e:
15.     # 出现异常，回滚事务
16.     connection.rollback()
17. finally:
18.     # 关闭游标
19.     cursor.close()
20.     # 关闭连接
21.     connection.close()

复制代码

利用上下文管理器

自动关闭数据库毗连、自动关闭游标

1. import pymysql
3. # 数据库连接参数
4. host = '192.168.xxx.xxx'    # 数据库主机地址
5. port = 3306                 # 数据库端口
6. user = 'root'               # 数据库用户名
7. password = '******'         # 数据库密码
8. database = 'test'           # 数据库名称
9. charset = 'utf8mb4'         # 编码格式
11. # 使用上下文管理器连接到数据库
12. with pymysql.connect(
13.         host=host,
14.         port=port,
15.         user=user,
16.         password=password,
17.         database=database,
18.         charset=charset
19. ) as connection:
20.     with connection.cursor() as cursor:
21.         # 编写sql语句
22.         sql = "insert into table_test (id, name, age) VALUES (%s, %s, '22')"
23.         values = (3, 'Spike')  # sql参数
25.         try:
26.             # 执行SQL
27.             cursor.execute(sql, values)
28.             # 提交事务
29.             connection.commit()
30.             print("执行成功")
31.         except Exception as e:
32.             print("程序异常")
33.             connection.rollback()

复制代码

---

游标常用方法

实行一条sql语句

语法：
   cursor.execute(query, args=None)
  

• query是要实行的SQL语句
  
• args是SQL语句中的参数
  

  示例：

1. cursor.execute("insert into table_test (id, name, age) VALUES (%s, %s, '22')", (3, 'Spike'))

复制代码

实行多条sql语句

语法：
   cursor.executemany(query, args)
  

• query是要实行的SQL语句
  
• args是一个包罗多组参数的列表。
  

  示例：

1. sql = "INSERT INTO table_test (id, name, age) VALUES (%s, %s, %s)"
2. values = [(1, 'Tom', 20), (2, 'Jerry', 18), (3, 'Spike', 25)]
3. cursor.executemany(sql, values)

复制代码

查询一条数据

语法：
   cursor.fetchone()
  示例：

1. result = cursor.fetchone()
2. print(result)

复制代码

查询多条数据

语法：
   cursor.fetchall()
  示例：

1. results = cursor.fetchall()
2. for row in results:
3.     print(row)

复制代码

查询返回效果中指定的行数

语法：
   cursor.fetchmany(size)
  示例：

1. # 获取查询结果中的前两行
2. results = cursor.fetchmany(2)
3. for row in results:
4.     print(row)

复制代码

受影响的行数

语法：
   cursor.rowcount
  

• 比方实行 INSERT、UPDATE 或 DELETE 操作后影响的行数。
  

  示例：

1. cursor.execute(sql, value)
2. # 受影响行数
3. print(cursor.rowcount)

复制代码

获取末了插入行的ID

语法：
   cursor.lastrowid
  

• 获取末了插入行的ID（通常用于 AUTO_INCREMENT 字段）
  

  示例：

1. cursor.execute(sql, value)
2. print(cursor.lastrowid)  # 输出最后插入行的ID

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。