AI 助理
备案控制台
开发者社区 数据库 文章 正文

【Python】基于pymysql的数据库操作类

2017-06-10 1532
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
RDS MySQL Serverless 基础系列，0.5-2RCU 50GB
推荐场景：
学生管理系统数据库设计 搭建个人博客
云数据库 RDS MySQL，集群系列 2核4GB
推荐场景：
搭建个人博客
RDS MySQL Serverless 高可用系列，价值2615元额度，1个月
简介： 一 简介      Python和MySQL交互的模块有 MySQLdb 和 PyMySQL(pymysql),MySQLdb是基于C 语言编写的，而且Python3 不在支持MySQLdb 。
一 简介
     Python和MySQL交互的模块有 MySQLdb 和 PyMySQL(pymysql),MySQLdb是基于C 语言编写的，而且Python3 不在支持MySQLdb 。PyMySQL是一个纯Python写的MySQL客户端，它的目标是替代MySQLdb，可以在CPython、PyPy、IronPython和Jython环境下运行,PyMySQL在MIT许可下发布。
    在开发基于Python语言的项目中，为了以后系统能兼容Python3,我们使用了PyMySQL替换了MySQLdb。下面我们来熟悉一下pymysql的使用。
 
二 安装方式
  pymsql的源码 https://github.com/PyMySQL/PyMySQL ，目前还在持续更新。
  1. 安装要求:
  2. Python -- one of the following:
  3.      CPython >= 2.6 or >= 3.3
  4.      PyPy >= 4.0
  5.      IronPython 2.7
  6. MySQL Server -- one of the following:
  7.      MySQL >= 4.1 (tested with only 5.5~)
  8.      MariaDB >= 5.1
  9. 安装
  10.   pip install PyMySQL
  相关文档 , 强烈建议大家仔细阅读一遍。其用法和MySQLdb相差无几，核心用法一致。这样使用pymysql替换mysqldb的成本极小。


三 基于pymysql的数据库交互

  1. #!/usr/bin/env python
  2. # encoding: utf-8
  3. """
  4. author: yangyi@youzan
  5. time: 2015/6/8 上午11:34
  6. func: 基于pymysql的数据库交互类，支持事务提交和回滚，返回结果记录行数，和insert的最新id
  7. """
  8. import pymysql
  9. from warnings import filterwarnings
  10. filterwarnings('ignore', category=pymysql.Warning)
  11. CONNECT_TIMEOUT = 100
  12. IP = 'localhost'
  13. PORT = 3306
  14. USER = 'root'
  15. PASSSWORD = ''

  17. class QueryException(Exception):
  18.     """
  19.     """


  22. class ConnectionException(Exception):
  23.     """
  24.     """

  26. class MySQL_Utils():
  27.     def __init__(
  28.             self, ip=IP, port=PORT, user=USER, password=PASSSWORD,
  29.             connect_timeout=CONNECT_TIMEOUT, remote=False, socket='', dbname='test'):
  30.         self.__conn = None
  31.         self.__cursor = None
  32.         self.lastrowid = None
  33.         self.connect_timeout = connect_timeout
  34.         self.ip = ip
  35.         self.port = port
  36.         self.user = user
  37.         self.password = password
  38.         self.mysocket = socket
  39.         self.remote = remote
  40.         self.db = dbname
  41.         self.rows_affected = 0


  44.     def __init_conn(self):
  45.         try:
  46.             conn = pymysql.connect(
  47.                     host=self.ip,
  48.                     port=int(self.port),
  49.                     user=self.user,
  50.                     db=self.db,
  51.                     connect_timeout=self.connect_timeout,
  52.                     charset='utf8', unix_socket=self.mysocket)
  53.         except pymysql.Error as e:
  54.             raise ConnectionException(e)
  55.         self.__conn = conn


  58.     def __init_cursor(self):
  59.         if self.__conn:
  60.             self.__cursor = self.__conn.cursor(pymysql.cursors.DictCursor)


  63.     def close(self):
  64.         if self.__conn:
  65.             self.__conn.close()
  66.             self.__conn = None

  68.     #专门处理select 语句
  69.     def exec_sql(self, sql, args=None):
  70.         try:
  71.             if self.__conn is None:
  72.                 self.__init_conn()
  73.                 self.__init_cursor()
  74.             self.__conn.autocommit = True
  75.             self.__cursor.execute(sql, args)
  76.             self.rows_affected = self.__cursor.rowcount
  77.             results = self.__cursor.fetchall()
  78.             return results
  79.         except pymysql.Error as e:
  80.             raise pymysql.Error(e)
  81.         finally:
  82.             if self.__conn:
  83.                 self.close()

  85.     # 专门处理dml语句 delete，updete，insert 
  86.     def exec_txsql(self, sql, args=None):
  87.         try:
  88.             if self.__conn is None:
  89.                 self.__init_conn()
  90.                 self.__init_cursor()
  91.             if self.__cursor is None:
  92.                 self.__init_cursor()


  95.             self.rows_affected=self.__cursor.execute(sql, args)
  96.             self.lastrowid = self.__cursor.lastrowid
  97.             return self.rows_affected
  98.         except pymysql.Error as e:
  99.             raise pymysql.Error(e)
  100.         finally:
  101.             if self.__cursor:
  102.                 self.__cursor.close()
  103.                 self.__cursor = None

  105.     # 提交
  106.     def commit(self):
  107.         try:
  108.             if self.__conn:
  109.                 self.__conn.commit()
  110.         except pymysql.Error as e:
  111.             raise pymysql.Error(e)
  112.         finally:
  113.             if self.__conn:
  114.                 self.close()

  116.     #回滚操作
  117.     def rollback(self):
  118.         try:
  119.             if self.__conn:
  120.                 self.__conn.rollback()
  121.         except pymysql.Error as e:
  122.             raise pymysql.Error(e)
  123.         finally:
  124.             if self.__conn:
  125.                 self.close()
  126.     # 适用于需要获取插入记录的主键自增id
  127.     def get_lastrowid(self):
  128.         return self.lastrowid
     #获取dml操作影响的行数
    def get_affectrows(self):
        return self.rows_affected
     #MySQL_Utils初始化的实例销毁之后，自动提交
     def __del__(self):
        self.commit()
四 小结
   前几天刚刚将我们的系统中的MySQLdb 替换为PyMySQL, 还未遇到问题。欢迎大家使用测试上述脚本，有问题欢迎和我讨论。 如果本文对您有帮助 ，可以赞助 一瓶饮料。




文章标签：
云数据库 RDS MySQL 版
Python
数据库
SQL
关系型数据库
MySQL
关键词：
Python数据库
Python类
Python PyMySQL
pymysql数据库
Python pymysql数据库
相关实践学习
如何在云端创建MySQL数据库
开始实验后，系统会自动创建一台自建MySQL的 源数据库 ECS 实例和一台 目标数据库 RDS。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心，利用清洁计算为万物互联的新世界提供源源不断的能源动力，目前开服的区域包括中国（华北、华东、华南、香港）、新加坡、美国（美东、美西）、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程，来了解阿里云能够为你的业务带来哪些帮助     相关的阿里云产品：云服务器ECS 云服务器 ECS（Elastic Compute Service）是一种弹性可伸缩的计算服务，助您降低 IT 成本，提升运维效率，使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
yangyi_dba
目录
相关文章
技能实验室
|
20天前
|
关系型数据库 MySQL 数据库连接
python脚本：连接数据库，检查直播流是否可用
【10月更文挑战第13天】本脚本使用 `mysql-connector-python` 连接MySQL数据库，检查 `live_streams` 表中每个直播流URL的可用性。通过 `requests` 库发送HTTP请求，输出每个URL的检查结果。需安装 `mysql-connector-python` 和 `requests` 库，并配置数据库连接参数。
技能实验室
120 68
游客sjjs6jgz4gp7m1
|
21天前
|
关系型数据库 MySQL 数据处理
探索Python中的异步编程：从asyncio到异步数据库操作
在这个快节奏的技术世界里，效率和性能是关键。本文将带你深入Python的异步编程世界，从基础的asyncio库开始，逐步探索到异步数据库操作的高级应用。我们将一起揭开异步编程的神秘面纱，探索它如何帮助我们提升应用程序的性能和响应速度。
游客sjjs6jgz4gp7m1
24 3
bruce刘晓伟-18435
|
1月前
|
Web App开发 SQL 数据库
使用 Python 解析火狐浏览器的 SQLite3 数据库
本文介绍如何使用 Python 解析火狐浏览器的 SQLite3 数据库，包括书签、历史记录和下载记录等。通过安装 Python 和 SQLite3，定位火狐数据库文件路径，编写 Python 脚本连接数据库并执行 SQL 查询，最终输出最近访问的网站历史记录。
bruce刘晓伟-18435
29 4
摩诃般若
|
1月前
|
索引 Python
python-类属性操作
【10月更文挑战第11天】 python类属性操作列举
摩诃般若
16 1
摩诃般若
|
1月前
|
Java C++ Python
Python基础---类
【10月更文挑战第10天】Python类的定义
摩诃般若
21 2
1919324350086154
|
1月前
|
SQL 机器学习/深度学习 数据采集
SQL与Python集成：数据库操作无缝衔接22.bijius.com
自动化数据预处理：使用Python库（如Pandas）自动清洗、转换和准备数据，为机器学习模型提供高质量输入。 实时数据处理：集成Apache Kafka或Amazon Kinesis等流处理系统，实现实时数据更新和分析。
1919324350086154
23 5
WK
|
1月前
|
Python
Python类命名
在Python编程中，类命名至关重要，影响代码的可读性和维护性。建议使用大写驼峰命名法（如Employee），确保名称简洁且具描述性，避免使用内置类型名及单字母或数字开头，遵循PEP 8风格指南，保持项目内命名风格一致。
WK
13 0
宋晨明
|
1月前
|
SQL 关系型数据库 MySQL
Python中Pymysql库的常见用法和代码示例
`pymysql` 是一个用于连接 MySQL 数据库的 Python 库，支持 SQL 查询的执行和结果处理。通过 `pip install pymysql` 安装后，可使用 `connect()` 方法建立连接，`cursor()` 创建游标执行查询，包括数据的增删改查，并通过 `commit()` 和 `rollback()` 管理事务，最后需关闭游标和连接以释放资源。
宋晨明
69 0
1919324350086154
|
1月前
|
SQL 机器学习/深度学习 数据采集
SQL与Python集成：数据库操作无缝衔接2a.bijius.com
Python与SQL的集成是现代数据科学和工程实践的核心。通过有效的数据查询、管理与自动化，可以显著提升数据分析和决策过程的效率与准确性。随着技术的不断发展，这种集成的应用场景将更加广泛，为数据驱动的创新提供更强大的支持。
1919324350086154
25 0
1919324350086154
|
1月前
|
SQL 机器学习/深度学习 数据库
SQL与Python集成：数据库操作无缝衔接
1. Python与SQL集成的关键步骤 在开始之前，确保你已经安装了必要的Python库，如`sqlite3`（用于SQLite数据库）或`psycopg2`（用于PostgreSQL数据库）。这些库提供了Python与SQL数据库之间的接口。
1919324350086154
25 0

热门文章

最新文章

  • 1
    手把手教你用Python实践深度学习
  • 2
    3、Python与设计模式--建造者模式
  • 3
    【Python】已解决：ModuleNotFoundError: No module named ‘PIL’
  • 4
    python开发翻译程序
  • 5
    Python多线程编程之多线程加锁
  • 6
    Python基于Django的电影推荐系统和论坛项目完整源码
  • 7
    假期也要卷，推荐6款 GitHub 上的超级 Python 项目，一起学起来
  • 8
    python类的使用
  • 9
    [PYTHON] 核心编程笔记之二-Python起步
  • 10
    python 合并当天tomcat异常日志
  • 1
    关系型数据库Oracle并行查询的实现方式
    300
  • 2
    关系型数据库Oracle并行查询的应用场景
    74
  • 3
    关系型数据库Oracle并行查询的基本概念
    101
  • 4
    现代数据库系统的性能优化策略与实践
    84
  • 5
    关系型数据库Oracle并行执行
    90
  • 6
    关系型数据库Oracle并行度（Degree of Parallelism, DOP）
    171
  • 7
    关系型数据库Oracle并行查询
    108
  • 8
    高并发场景下，到底先更新缓存还是先更新数据库？
    66
  • 9
    【最佳实践】MySQL数据库迁移到PXC集群
    92
  • 10
    关系型数据库Oracle GoldenGate
    39

    • 相关课程

    更多
  • Python Web开发基础
  • Python爬虫实战
  • Python常用数据科学库
  • Python网络爬虫实战
  • Python完全自学手册图文教程
  • Python基础快速入门实战教程

    • 相关电子书

    更多
  • From Python Scikit-Learn to Sc
  • Data Pre-Processing in Python:
  • 双剑合璧-Python和大数据计算平台的结合

    • 相关实验场景

    更多
  • 数据库实验室挑战任务-高级任务
  • 数据库实验室挑战任务-中级任务
  • 数据库实验室挑战任务-初级任务
  • 阿里云数据库产品实验室
  • MongoDB数据库入门
  • Python入门

    • 推荐镜像

    更多
  • python-release
  • nodejs-release
  • pypi
    • 下一篇
    阿里云OSS设置跨域访问