【使用Python操作Mysql数据库】_pymql

提示：文章写完后，目录可以自动生成，如何生成可参考右边的帮助文档

---

前言

随着互联网技术的不断发展，数据库已经成为应用程序中不可或缺的一部分。MySQL作为一种流行的关系型数据库，被广泛应用于各种应用程序中。而PyMySQL则是一个纯Python实现的MySQL客户端，为Python开发者提供了与MySQL服务器进行通信的能力。
本文将介绍PyMySQL的基本概念、安装和使用方法，并通过示例代码演示如何使用PyMySQL进行数据库操作。通过本文的学习，读者将能够了解PyMySQL的基本概念和用法，并能够使用PyMySQL进行数据库连接、查询、插入、更新和删除等操作。

---

提示：以下是本篇文章正文内容，下面案例可供参考

一、Pymsql介绍

PyMySQL是一个纯Python实现的MySQL客户端，它可以直接与MySQL服务器进行通信，并且可以用于Python应用程序中进行数据库操作。

PyMySQL提供了一个类似于Python标准库中的sqlite3模块的API，使用起来比较简单。它支持MySQL C客户端库中的大部分功能，包括连接、查询、插入、更新和删除等操作。

二、安装和使用Pymsql

1.安装PyMySQL

可以通过pip命令进行安装：

pip install pymql

1
2
3

2.连接数据库

代码如下（示例）：

import pymysql
from loguru import logger

  
# 建立数据库连接
class MySql:
    def __init__(self, host, user, password, database, port=3306):
        # 连接数据库
        self.con = pymysql.connect(
            host=host,
            user=user,
            password=password,
            database=database,
            port=port,
            charset="utf8mb4",
            cursorclass=pymysql.cursors.DictCursor)  # sql查询结果以字典类型返回 
            
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

3.创建游标

        # 创建游标
        try:
            self.cour = self.con.cursor()
        except Exception as e:
            logger.error(f"游标创建失败，错误原因为{e}")
            
1
2
3
4
5
6
7

4.增删改查方法

    # sql查询方法
    def select_sql(self, req_sql, args=None, many=1):
        try:
            self.cour.execute(req_sql, args)
            if many == 1:  # 判断many=1,sql只返回一条查询结果
                result = self.cour.fetchone()
            elif many == -1:  # 判断many=-1,sql返回全部查询结果
                result = self.cour.fetchall()
            elif many == 2:  # 判断many=2,sql根据many的值返回查询结果
                result = self.cour.fetchmany()
            else:
                result = "many传值不正确！"
                logger.error("many只能输入1、-1、纯数字；many=1查询1条数据；many=-1查询全部数据；纯数字=指定数字查询指定条数!")
            return result
        except Exception as e:
            logger.error(f"sql语句执行错误，sql是{req_sql}，报错信息是{e}")
            
    # sql更新/删除/新增方法
    def update_sql(self, req_sql, args=None):
        try:
            self.cour.execute(req_sql, args)
            self.con.commit()
        except Exception as ex:
            self.cour.rollback()
            logger.error(f"sql语句执行错误，sql是{req_sql}，报错信息是{ex}")
            
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

5.关闭数据库

    # 关闭数据库
    def close_db(self):
        self.con.close()
        self.cour.close()
  
1
2
3
4
5
6

三、总结

以上就是今天的分享啦！总的来说，PyMySQL是一个非常实用的工具，它使得Python开发者可以轻松地与MySQL数据库进行交互。其强大的功能和简单易用的API设计，使得它在Web开发、数据分析、自动化脚本等场景中都有出色的表现。如果你正在寻找一个高效且易用的Python MySQL客户端，那么PyMySQL绝对是一个值得考虑的选择。