pymysql操作mysql封装

 1 import pymysql
 2 from lib.logger import logger
 3 from warnings import filterwarnings
 4 filterwarnings("ignore",category=pymysql.Warning) # 忽略mysql警告信息
 5
 6 class MysqlDb():
 7
 8     logger = logger
 9
10     def __init__(self, host, port, user, passwd):
11         # 建立数据库连接
12         self.conn = pymysql.connect(
13             host=host,
14             port=port,
15             user=user,
16             passwd=passwd,
17             charset=‘utf8‘
18         )
19         # 通过 cursor() 创建游标对象,并让查询结果以字典格式输出
20         self.cur = self.conn.cursor(cursor=pymysql.cursors.DictCursor)
21
22     def __del__(self): # 对象资源被释放时触发,在对象即将被删除时的最后操作
23         # 关闭游标
24         self.cur.close()
25         # 关闭数据库连接
26         self.conn.close()
27
28     def select_db(self,db_name):
29         """
30         选择数据库
31         :return:
32         """
33         try:
34             self.conn.select_db(db_name)
35             self.logger.logger.info("选择 {0} 执行成功".format(db_name))
36         except Exception as e:
37             self.logger.logger.exception("操作出现错误:{0}".format(e))
38
39     def query_db(self, sql,state="all"):
40         """
41         查询
42         :param sql:sql语句
43         :param state:all查询所有,outhor查询单条
44         :return:
45         """
46         # 使用 execute() 执行sql
47         self.logger.logger.info(sql)
48         self.cur.execute(sql)
49         if state == "all":
50             # 使用 fetchall() 获取查询结果
51             data = self.cur.fetchall()
52         else:
53             data = self.cur.fetchone()
54         return data
55
56     def execute_db(self, sql):
57         """更新/插入/删除"""
58         try:
59             # 使用 execute() 执行sql
60             self.cur.execute(sql)
61             # 提交事务
62             self.conn.commit()
63             self.logger.logger.info("{0} 执行成功".format(sql))
64         except Exception as e:
65             self.logger.logger.exception("操作出现错误:{}".format(e))
66             # 回滚所有更改
67             self.conn.rollback()
68
69 if __name__ == ‘__main__‘:
70     pass

原文地址:https://www.cnblogs.com/tython/p/12701392.html

时间: 04-14

pymysql操作mysql封装的相关文章

PyMySQL操作mysql数据库(py3必学)

一,安装PyMySQL Python是编程语言,MySQL是数据库,它们是两种不同的技术:要想使Python操作MySQL数据库需要使用驱动.这里选用PyMySQL驱动. 安装方式还是使用pip命令. > pip install  PyMySQL 二,创建MySQL表 执行下面的SQL语句,创建一张users 表. CREATE TABLE `users` ( `id` INT(11) NOT NULL AUTO_INCREMENT, `email` VARCHAR(255) COLLATE u

flask + pymysql操作Mysql数据库

安装flask-sqlalchemy.pymysql模块 pip install flask-sqlalchemy pymysql 安装Mysql数据库 from flask.ext.sqlalchemy import SQLAlchemy from flask import Flask '''配置数据库''' app = Flask(__name__) app.config['SECRET_KEY'] ='hard to guess' # 这里登陆的是root用户,要填上自己的密码,MySQL

python 3.6 +pyMysql 操作mysql数据库

版本信息:python:3.6 mysql:5.7 pyMysql:0.7.11 ################################################################# #author: 陈月白 #_blogs: http://www.cnblogs.com/chenyuebai/ ################################################################# # -*- coding: utf-8

使用PyMySQL操作mysql数据库

适用环境 python版本 >=2.6或3.3 mysql版本>=4.1 安装 可以使用pip安装也可以手动下载安装. 使用pip安装,在命令行执行如下命令: 1 pip install PyMySQL 手动安装,请先下载.下载地址:https://github.com/PyMySQL/PyMySQL/tarball/pymysql-X.X. 其中的X.X是版本(目前可以获取的最新版本是0.6.6). 下载后解压压缩包.在命令行中进入解压后的目录,执行如下的指令: 1 python setup

用pymysql操作MySQL数据库

工具库安装 pip install pymysql 连接关闭数据库与增删改查操作 # 导入pymysql库 import pymysql # 打开数据库连接 # 参数1:数据库服务器所在的主机+端口号 # 参数2:登陆数据库的用户名 # 参数3:登陆数据库的密码 # 参数4:要连接的数据库 # 参数5:字符编码 db = pymysql.connect( 'localhost', 'root', '123456', 'school', charset = 'utf8' ) # 增删改插操作 #

如何使用python中的pymysql操作mysql数据库

操作流程 导入模块 from pymsql import * 创建connect链接 conn = connect(host, port, user, password, database, charset) 获取游标对象 cs1 = conn.cursor() 执行语句 count = cs1.execute(SQL语句) 查看执行的语句 cs1.fetchone() # 返回元组结构的一条数据 查看多条语句 cs1.fetchmany(3) # 取出3个数据元组套元组,不写数量就只取一个 查

(转)Python中操作mysql的pymysql模块详解

原文:https://www.cnblogs.com/wt11/p/6141225.html https://shockerli.net/post/python3-pymysql/----Python 3 进阶 -- 使用 PyMySQL 操作 MySQL 前言 pymsql是Python中操作MySQL的模块,其使用方法和MySQLdb几乎相同.但目前pymysql支持python3.x而后者不支持3.x版本. 本文测试python版本:2.7.11.mysql版本:5.6.24 一.安装 1

exist 存在 Python操作mysql pymysql sql注入问题 # 39

0.补充 exist 存在 了解.py 1 """""" 2 """ 3 '''exist''' 4 EXIST 关键字表示存在 5 在使用EXIST 关键字时 , 6 7 内层查询语句不返回 查询的记录, 8 而是返回一个真假值 ,True|False 9 10 当返回True时,外层语句将进行查询, 11 当返回值为False 外层查询语句不进行查询 12 13 select * from emp where e

Python操作MySQL存储

在Python 2中,连接MySQL的库大多是使用MySQLdb,但是此库的官方并不支持Python 3,所以这里推荐使用的库是PyMySQL. 本节中,我们就来讲解使用PyMySQL操作MySQL数据库的方法. 1. 准备工作 在开始之前,请确保已经安装好了MySQL数据库并保证它能正常运行,而且需要安装好PyMySQL库. 2. 连接数据库 这里,首先尝试连接一下数据库.假设当前的MySQL运行在本地,用户名为root,密码为123456,运行端口为3306.这里利用PyMySQL先连接My

联合分组、子查询、视图、事务、python操作mysql、索引

目录 联合分组.子查询.视图.事务.python操作mysql.索引 一.联合分组 二.子查询 三.all 与any:区间修饰条件 四.视图:view 视图的增删改 五.事务 5.1.事务的概念 5.2.事务的四大特性 六.pymysql 模块:python操作mysql 6.1 安装pymysql 模块 6.2 python用pymysql 操作mysql步骤 6.3 游标操作 6.4 pymysql事务 6.5 sql注入 七.索引 联合分组.子查询.视图.事务.python操作mysql.