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

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

2017-06-10 1704
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
RDS Agent（兼容OpenClaw），2核4GB
RDS DuckDB + QuickBI 企业套餐，8核32GB + QuickBI 专业版
RDS MySQL DuckDB 分析主实例，基础系列 4核8GB
简介： 一 简介      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数据库
相关实践学习
每个IT人都想学的“Web应用上云经典架构”实战
本实验从Web应用上云这个最基本的、最普遍的需求出发，帮助IT从业者们通过“阿里云Web应用上云解决方案”，了解一个企业级Web应用上云的常见架构，了解如何构建一个高可用、可扩展的企业级应用架构。
MySQL数据库入门学习
本课程通过最流行的开源数据库MySQL带你了解数据库的世界。   相关的阿里云产品：云数据库RDS MySQL 版 阿里云关系型数据库RDS（Relational Database Service）是一种稳定可靠、可弹性伸缩的在线数据库服务，提供容灾、备份、恢复、迁移等方面的全套解决方案，彻底解决数据库运维的烦恼。 了解产品详情: https://www.aliyun.com/product/rds/mysql 
yangyi_dba
目录
相关文章
站大爷
|
7月前
|
SQL 关系型数据库 数据库
Python SQLAlchemy模块：从入门到实战的数据库操作指南
免费提供Python+PyCharm编程环境，结合SQLAlchemy ORM框架详解数据库开发。涵盖连接配置、模型定义、CRUD操作、事务控制及Alembic迁移工具，以电商订单系统为例，深入讲解高并发场景下的性能优化与最佳实践，助你高效构建数据驱动应用。
站大爷
885 7
winx_19970108018
|
8月前
|
数据采集 关系型数据库 MySQL
python爬取数据存入数据库
Python爬虫结合Scrapy与SQLAlchemy，实现高效数据采集并存入MySQL/PostgreSQL/SQLite。通过ORM映射、连接池优化与批量提交，支持百万级数据高速写入，具备良好的可扩展性与稳定性。
winx_19970108018
406 1
蓝易云
|
SQL 数据库 开发者
Python中使用Flask-SQLAlchemy对数据库的增删改查简明示例
这样我们就对Flask-SQLAlchemy进行了一次简明扼要的旅程，阐述了如何定义模型，如何创建表，以及如何进行基本的数据库操作。希望你在阅读后能对Flask-SQLAlchemy有更深入的理解，这将为你在Python世界中从事数据库相关工作提供极大的便利。
蓝易云
945 77
兵临天下19970108016
|
8月前
|
缓存 供应链 芯片
电子元件类商品 item_get - 商品详情接口深度分析及 Python 实现
电子元件商品接口需精准返回型号参数、规格属性、认证及库存等专业数据，支持供应链管理与采购决策。本文详解其接口特性、数据结构与Python实现方案。
兵临天下19970108016
366 0
站大爷
|
8月前
|
存储 数据库 开发者
Python SQLite模块：轻量级数据库的实战指南
本文深入讲解Python内置sqlite3模块的实战应用，涵盖数据库连接、CRUD操作、事务管理、性能优化及高级特性，结合完整案例，助你快速掌握SQLite在小型项目中的高效使用，是Python开发者必备的轻量级数据库指南。
站大爷
710 0
卓伊凡
|
测试技术 Python
【03】做一个精美的打飞机小游戏，规划游戏项目目录-分门别类所有的资源-库-类-逻辑-打包为可玩的exe-练习python打包为可执行exe-优雅草卓伊凡-持续更新-分享源代码和游戏包供游玩-1.0.2版本
【03】做一个精美的打飞机小游戏，规划游戏项目目录-分门别类所有的资源-库-类-逻辑-打包为可玩的exe-练习python打包为可执行exe-优雅草卓伊凡-持续更新-分享源代码和游戏包供游玩-1.0.2版本
卓伊凡
797 31
【03】做一个精美的打飞机小游戏，规划游戏项目目录-分门别类所有的资源-库-类-逻辑-打包为可玩的exe-练习python打包为可执行exe-优雅草卓伊凡-持续更新-分享源代码和游戏包供游玩-1.0.2版本
overmind1980
|
人工智能 Python
[oeasy]python083_类_对象_成员方法_method_函数_function_isinstance
本文介绍了Python中类、对象、成员方法及函数的概念。通过超市商品分类的例子，形象地解释了“类型”的概念，如整型(int)和字符串(str)是两种不同的数据类型。整型对象支持数字求和，字符串对象支持拼接。使用`isinstance`函数可以判断对象是否属于特定类型，例如判断变量是否为整型。此外，还探讨了面向对象编程(OOP)与面向过程编程的区别，并简要介绍了`type`和`help`函数的用法。最后总结指出，不同类型的对象有不同的运算和方法，如字符串有`find`和`index`方法，而整型没有。更多内容可参考文末提供的蓝桥、GitHub和Gitee链接。
overmind1980
348 11
游客kufrkwrbkmpsa
|
数据库 Python
【YashanDB知识库】python驱动查询gbk字符集崖山数据库CLOB字段，数据被驱动截断
【YashanDB知识库】python驱动查询gbk字符集崖山数据库CLOB字段，数据被驱动截断
游客kufrkwrbkmpsa
233 7
技能实验室
|
关系型数据库 MySQL 数据库连接
python脚本：连接数据库，检查直播流是否可用
【10月更文挑战第13天】本脚本使用 `mysql-connector-python` 连接MySQL数据库，检查 `live_streams` 表中每个直播流URL的可用性。通过 `requests` 库发送HTTP请求，输出每个URL的检查结果。需安装 `mysql-connector-python` 和 `requests` 库，并配置数据库连接参数。
技能实验室
391 68
overmind1980
|
存储 C语言 Python
[oeasy]python077_int类型怎么用_整数运算_integer_进制转化_int类
本文主要讲解了Python中`int`类型的应用与特性。首先回顾了`int`词根的溯源，探讨了整型变量的概念及命名规则（如匈牙利命名法）。接着分析了整型变量在内存中的存储位置和地址，并通过`type()`和`id()`函数验证其类型和地址。还介绍了整型变量的运算功能，以及如何通过`int()`函数将字符串转化为整数，支持不同进制间的转换（如二进制转十进制）。此外，文章提及了关键字`del`的使用场景，对比了Python与C语言中`int`的区别，并总结了整型与字符串类型的差异，为后续深入学习奠定基础。
overmind1980
348 1

热门文章

最新文章

  • 1
    深度 | 带领国产数据库走向世界，POLARDB底层逻辑是什么？ | 10月30号栖夜读
  • 2
    展望云计算新时代数据库计算力的进化
  • 3
    【独家直播】洞见数据库前沿 集结阿里云数据库最强阵容 DTCC 2019 八大亮点抢先看
  • 4
    开源数据库企业应用的探索与实践——云栖技术之旅第1期精彩回顾
  • 5
    微信Windows端IM消息数据库的优化实践：查询慢、体积大、文件损坏等
  • 6
    Oracle数据库访问其他用户下的表,不加表所属的用户名的实现方法
  • 7
    数据库迁移
  • 8
    MySQL数据库进阶第四篇（视图/存储过程/触发器）
  • 9
    关系型数据库表结构设计规范化（Normalization）
  • 10
    对话OceanBase CEO 杨冰: 11 年征程，做数据库我们是认真的!
  • 1
    基于python大数据的台风灾害分析及预测系统
    626
  • 2
    基于Python大数据的热门游戏推荐系统
    567
  • 3
    基于python大数据的青少年网络使用情况分析及预测系统
    625
  • 4
    2026版基于python大数据的电影分析可视化系统
    570
  • 5
    基于Python大数据的的电商用户行为分析系统
    1278
  • 6
    基于python大数据技术的医疗数据分析与研究
    373
  • 7
    基于python大数据深度学习的酒店评论文本情感分析系统
    716
  • 8
    Python SQLAlchemy模块：从入门到实战的数据库操作指南
    885
  • 9
    基于python大数据的的海洋气象数据可视化平台
    377
  • 10
    基于Python大数据的主流汽车价格分析可视化系统
    728

    • 相关课程

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

    • 相关电子书

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

    • 推荐镜像

    更多
  • python-release
    • 下一篇
    阿里云重磅新品：Agent安全中心，全新安全框架下AI Agent一体化防御平台