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

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

2017-06-10 1560
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
RDS MySQL Serverless 基础系列，0.5-2RCU 50GB
推荐场景：
学生管理系统数据库设计 搭建个人博客
云数据库 RDS MySQL，集群系列 2核4GB
推荐场景：
搭建个人博客
云数据库 RDS PostgreSQL，集群系列 2核4GB
简介： 一 简介      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数据库
相关实践学习
如何快速连接云数据库RDS MySQL
本场景介绍如何通过阿里云数据管理服务DMS快速连接云数据库RDS MySQL，然后进行数据表的CRUD操作。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心，利用清洁计算为万物互联的新世界提供源源不断的能源动力，目前开服的区域包括中国（华北、华东、华南、香港）、新加坡、美国（美东、美西）、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程，来了解阿里云能够为你的业务带来哪些帮助     相关的阿里云产品：云服务器ECS 云服务器 ECS（Elastic Compute Service）是一种弹性可伸缩的计算服务，助您降低 IT 成本，提升运维效率，使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
yangyi_dba
目录
相关文章
overmind1980
|
19天前
|
人工智能 Python
[oeasy]python083_类_对象_成员方法_method_函数_function_isinstance
本文介绍了Python中类、对象、成员方法及函数的概念。通过超市商品分类的例子，形象地解释了“类型”的概念，如整型(int)和字符串(str)是两种不同的数据类型。整型对象支持数字求和，字符串对象支持拼接。使用`isinstance`函数可以判断对象是否属于特定类型，例如判断变量是否为整型。此外，还探讨了面向对象编程(OOP)与面向过程编程的区别，并简要介绍了`type`和`help`函数的用法。最后总结指出，不同类型的对象有不同的运算和方法，如字符串有`find`和`index`方法，而整型没有。更多内容可参考文末提供的蓝桥、GitHub和Gitee链接。
overmind1980
41 11
游客kufrkwrbkmpsa
|
1月前
|
数据库 Python
【YashanDB知识库】python驱动查询gbk字符集崖山数据库CLOB字段，数据被驱动截断
【YashanDB知识库】python驱动查询gbk字符集崖山数据库CLOB字段，数据被驱动截断
游客kufrkwrbkmpsa
44 7
overmind1980
|
1月前
|
存储 C语言 Python
[oeasy]python077_int类型怎么用_整数运算_integer_进制转化_int类
本文主要讲解了Python中`int`类型的应用与特性。首先回顾了`int`词根的溯源，探讨了整型变量的概念及命名规则（如匈牙利命名法）。接着分析了整型变量在内存中的存储位置和地址，并通过`type()`和`id()`函数验证其类型和地址。还介绍了整型变量的运算功能，以及如何通过`int()`函数将字符串转化为整数，支持不同进制间的转换（如二进制转十进制）。此外，文章提及了关键字`del`的使用场景，对比了Python与C语言中`int`的区别，并总结了整型与字符串类型的差异，为后续深入学习奠定基础。
overmind1980
44 1
卓伊凡
|
3月前
|
测试技术 Python
【03】做一个精美的打飞机小游戏，规划游戏项目目录-分门别类所有的资源-库-类-逻辑-打包为可玩的exe-练习python打包为可执行exe-优雅草卓伊凡-持续更新-分享源代码和游戏包供游玩-1.0.2版本
【03】做一个精美的打飞机小游戏，规划游戏项目目录-分门别类所有的资源-库-类-逻辑-打包为可玩的exe-练习python打包为可执行exe-优雅草卓伊凡-持续更新-分享源代码和游戏包供游玩-1.0.2版本
卓伊凡
198 31
【03】做一个精美的打飞机小游戏，规划游戏项目目录-分门别类所有的资源-库-类-逻辑-打包为可玩的exe-练习python打包为可执行exe-优雅草卓伊凡-持续更新-分享源代码和游戏包供游玩-1.0.2版本
瓴羊Dataphin
|
1月前
|
SQL 关系型数据库 数据库连接
Dataphin功能Tips系列（35）-通过Python脚本连接数据库
通过Python脚本连接数据库
瓴羊Dataphin
36 0
技能实验室
|
5月前
|
关系型数据库 MySQL 数据库连接
python脚本：连接数据库，检查直播流是否可用
【10月更文挑战第13天】本脚本使用 `mysql-connector-python` 连接MySQL数据库，检查 `live_streams` 表中每个直播流URL的可用性。通过 `requests` 库发送HTTP请求，输出每个URL的检查结果。需安装 `mysql-connector-python` 和 `requests` 库，并配置数据库连接参数。
技能实验室
160 68
AIweker
|
4月前
|
关系型数据库 MySQL 数据库
Python处理数据库：MySQL与SQLite详解 | python小知识
本文详细介绍了如何使用Python操作MySQL和SQLite数据库，包括安装必要的库、连接数据库、执行增删改查等基本操作，适合初学者快速上手。
AIweker
563 15
爬虫工程师Azeroth
|
4月前
|
数据采集 存储 XML
python实战——使用代理IP批量获取手机类电商数据
本文介绍了如何使用代理IP批量获取华为荣耀Magic7 Pro手机在电商网站的商品数据，包括名称、价格、销量和用户评价等。通过Python实现自动化采集，并存储到本地文件中。使用青果网络的代理IP服务，可以提高数据采集的安全性和效率，确保数据的多样性和准确性。文中详细描述了准备工作、API鉴权、代理授权及获取接口的过程，并提供了代码示例，帮助读者快速上手。手机数据来源为京东（item.jd.com），代理IP资源来自青果网络（qg.net）。
爬虫工程师Azeroth
283 0
aliyun0641063962-48771
|
6月前
|
关系型数据库 MySQL 数据处理
探索Python中的异步编程：从asyncio到异步数据库操作
在这个快节奏的技术世界里，效率和性能是关键。本文将带你深入Python的异步编程世界，从基础的asyncio库开始，逐步探索到异步数据库操作的高级应用。我们将一起揭开异步编程的神秘面纱，探索它如何帮助我们提升应用程序的性能和响应速度。
aliyun0641063962-48771
310 3
bruce_xiaowei
|
6月前
|
Web App开发 SQL 数据库
使用 Python 解析火狐浏览器的 SQLite3 数据库
本文介绍如何使用 Python 解析火狐浏览器的 SQLite3 数据库，包括书签、历史记录和下载记录等。通过安装 Python 和 SQLite3，定位火狐数据库文件路径，编写 Python 脚本连接数据库并执行 SQL 查询，最终输出最近访问的网站历史记录。
bruce_xiaowei
107 4

热门文章

最新文章

  • 1
    时间序列异常检测：MSET-SPRT组合方法的原理和Python代码实现
  • 2
    手把手教你安装PyCharm 2025：开发者的Python IDE配置全流程+避坑指南
  • 3
    uv安装python及其依赖的加速方法
  • 4
    Python创意爱心代码大全：从入门到高级的7种实现方式
  • 5
    【AI大模型】使用Python调用DeepSeek的API，原来SDK是调用这个，绝对的一分钟上手和使用
  • 6
    [oeasy]python082_变量部分总结_variable_summary
  • 7
    Python错误 - 'list' object is not callable 的问题定位与解决
  • 8
    使用Python实现multipart/form-data文件接收的http服务器
  • 9
    Python实战：搭建短信转发器，实现验证码自动接收与处理
  • 10
    Python + Chrome 爬虫：如何抓取 AJAX 动态加载数据？
  • 1
    JetBrains DataGrip 2025.1 发布 - 数据库和 SQL 跨平台 IDE
    18
  • 2
    【瑶池数据库动手活动及话题本周精选（体验ADB、 SelectDB，参与 RDS 迁移训练营）】（4.21-4.27）
    70
  • 3
    利用Cron表达式实现MySQL数据库的定时备份
    32
  • 4
    大数据新视界--大数据大厂之MySQL 数据库课程设计：MySQL 数据库 SQL 语句调优的进阶策略与实际案例（2-2）
    39
  • 5
    大数据新视界--大数据大厂之MySQL数据库课程设计：MySQL 数据库 SQL 语句调优方法详解（2-1）
    42
  • 6
    大数据新视界--大数据大厂之MySQL 数据库课程设计：数据安全深度剖析与未来展望
    48
  • 7
    JDK、Tomcat、MariaDB数据库和Profile多环境的配置与使用
    46
  • 8
    登顶TPC-C｜云原生数据库PolarDB技术揭秘：弹性并行查询（ePQ）篇
    79
  • 9
    分布式存储数据恢复—hbase和hive数据库数据恢复案例
    48
  • 10
    登顶TPC-C｜云原生数据库PolarDB技术揭秘：弹性并行查询（ePQ）篇
    61

    • 相关课程

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

    • 相关电子书

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

    • 相关实验场景

    更多
  • 使用DAS实现数据库SQL优化
  • 用Python画圣诞树
  • PolarDB for AI：在数据库中通过SQL实现AI能力
  • 快速体验PolarDB开源数据库
  • SQLServer数据库的创建
  • 手把手教你把IoT传感器数据存储到数据库

    • 推荐镜像

    更多
  • python-release
  • nodejs-release
  • NPM
    • 下一篇
    阿里云oss简介和如何对接使用