Python基础学习：Python连接mysql方法封装

最新推荐文章于 2024-08-13 17:47:42 发布

caodingzheng

最新推荐文章于 2024-08-13 17:47:42 发布

阅读量381

点赞数

分类专栏： Python学习文章标签： python

本文链接：https://blog.csdn.net/caodingzheng/article/details/110874943

版权

Python学习专栏收录该内容

16 篇文章

订阅专栏

这篇博客介绍了如何使用Python的mysql-connector库来建立数据库连接，并封装了一个MysqlConnectDatabase类，实现数据库的增删改查操作。通过实例化该类，可以方便地进行数据库交互并确保操作的原子性。

摘要生成于 C知道，由 DeepSeek-R1 满血版支持，前往体验 >

Python基础学习：Python连接mysql普适性方法封装

# 需要下载mysql-connector，mysql-connector是MySQL官方提供的驱动器
# 下载命令：pip install mysql-connector
from mysql import connector


class MysqlConnectDatabase(object):
    # 连接数据库
    def __init__(self, host, port, user, password, db, charset='utf8'):
        self.__host = host
        self.__port = int(port)  # mysql端口
        self.__username = user  # mysql远程连接用户名
        self.__password = password  # mysql远程连接密码
        self.__db = db  # mysql使用的数据库名
        self.__charset = charset  # mysql使用的字符编码,默认为utf8
        try:
            self.__connect_database = connector.connect(host=self.__host, port=self.__port,
                                                        user=self.__username, password=self.__password,
                                                        db=self.__db, charset=self.__charset)
        except:
            print('连接失败')

    # 操作数据库（增删改查等）
    def operate_data(self, sql):
        try:
            cur = self.__connect_database.cursor()
            cur.execute(sql)
            try:
                self.__connect_database.commit() # 增删改
                result1 = ''
                cur.close()
                result2 = 'sql语句："%s"执行成功' % sql
            except Exception:
                try:
                    result1 = cur.fetchall() # 数据库查询返回结果
                    cur.close()
                    result2 = 'sql语句："%s"执行成功' % sql
                except Exception as e:
                    print(e)
                    result1 = ''
                    result2 = 'sql语句："%s"执行失败' % sql
                    self.__connect_database.rollback()
        except Exception as e:
            print('失败', e)
            result1 = ''
            result2 = 'sql语句："%s"执行失败' % sql
            self.__connect_database.rollback()
        if result1 == '':
            return result2
        else:
            return result1, result2

    # 断开数据库连接
    def close_database(self):
        self.__connect_database.close()