python操作mysql数据库

一、原始代码

#coding=utf-8import MySQLdb
from cProfile import Profileclass MySQLUtils():def __init__(self):self.connect = MySQLdb.connect(host="192.168.111.1", port=3306, user="root", passwd="root", db="test", charset='utf8')self.cursor = self.connect.cursor()self.connect.autocommit(on=True)def finish(self):self.connect.close()def execute(self,sql,values):self.cursor.execute(sql,values)def fetch_one(self):return self.cursor.fetchone()def fetch_all(self):return self.cursor.fetchall()def mysql_execute(sql,values):dbutils = MySQLUtils()dbutils.execute(sql,values)all_result = dbutils.fetch_all()dbutils.finish()return all_resultsql = 'insert into scan_domain(top_level_domain,domain) values(%s,%s)'def execute_test():for i in range(0, 100000):mysql_execute(sql, ['aaa.com', 'hao.aaa.com'])prof = Profile()
prof.enable()
execute_test()
prof.create_stats()
prof.print_stats()

二、改进一版，使用数据库连接池

#coding=utf-8import MySQLdb
from DBUtils.PooledDB import PooledDB
from cProfile import Profileclass MySQLUtils():__pool = Nonedef __init__(self):self.connect = MySQLUtils.__get_connect()self.cursor = self.connect.cursor()@staticmethoddef __get_connect():if MySQLUtils.__pool is None:MySQLUtils.__pool = PooledDB(creator=MySQLdb, mincached=1, maxcached=20,host='127.0.0.1', port=3306, user='root', passwd='root',db='test', use_unicode=False, charset='utf8')return MySQLUtils.__pool.connection()def finish(self):self.cursor.close()self.connect.close()MySQLUtils.__pool.close()def execute(self,sql,values=[]):count = self.cursor.execute(sql,values)self.connect.commit()if count:return list(self.fetch_all())def fetch_one(self):return self.cursor.fetchone()def fetch_all(self):return self.cursor.fetchall()prof = Profile()
sql = 'insert into scan_domain(top_level_domain,domain) values(%s,%s)'
prof.enable()
dbutils = MySQLUtils()def execute_test():for i in range(0,100000):result = dbutils.execute(sql=sql, values=['aaa.com', 'hao.aaa.com'])
execute_test()
dbutils.finish()
prof.create_stats()
prof.print_stats()

三、细节

#coding=utf-8import MySQLdb
from DBUtils.PooledDB import PooledDB
from cProfile import Profileclass MySQLUtils():__pool = Nonedef __init__(self):self.connect = MySQLUtils.__get_connect()self.cursor = self.connect.cursor()@staticmethoddef __get_connect():if MySQLUtils.__pool is None:MySQLUtils.__pool = PooledDB(creator=MySQLdb, mincached=1, maxcached=20,host='127.0.0.1', port=3306, user='root', passwd='root',db='test', use_unicode=False, charset='utf8')return MySQLUtils.__pool.connection()def finish(self):self.connect.commit()self.cursor.close()self.connect.close()MySQLUtils.__pool.close()def execute(self,sql,values=[]):count = self.cursor.execute(sql,values)# self.connect.commit()if count:return list(self.fetch_all())def fetch_one(self):return self.cursor.fetchone()def fetch_all(self):return self.cursor.fetchall()prof = Profile()
sql = 'insert into scan_domain(top_level_domain,domain) values(%s,%s)'
prof.enable()
dbutils = MySQLUtils()def execute_test():for i in range(0,100000):result = dbutils.execute(sql=sql, values=['aaa.com', 'hao.aaa.com'])
execute_test()
dbutils.finish()
prof.create_stats()
prof.print_stats()

python操作mysql数据库—坑吭相关推荐

python操作mysql数据库的常用方法使用详解
python操作mysql数据库 1.环境准备: Linux 安装mysql: apt-get install mysql-server 安装python-mysql模块:apt-get instal ...
Python操作mySql数据库封装类
这是自己在做项目过程中,整理封装的操作mysql数据库封装类,自己可以修改下使用,节省大量时间. myGlobal.py # -*- coding: utf-8 -*-global globalLis ...
python操作mysql数据库(增、删、改、查)_python对 MySQL 数据库进行增删改查的脚本...
# -*- coding: utf-8 -*- import pymysql import xlrd # import codecs #连接数据库 conn = pymysql.connect(hos ...
python 天气预报 mysql_python + docker, 实现天气数据从FTP获取以及持久化（二）-- python操作MySQL数据库...
前言在这一节中,我们主要介绍如何使用python操作MySQL数据库. 准备 MySQL数据库使用的是上一节中的docker容器 "test-mysql". Python 操作 ...
python操作mysql中的表_带你了解什么是Python操作MySQL数据库
写这篇文章主要是为了介绍Python操作MySQL数据库,并结合相应的实例带你更加深入了解.文中的代码实例很详细,对大家有一定的参考学习价值. 1.什么是pymysql? PyMySQL是在Pytho ...
python操作mysql数据库练习
python操作mysql数据库练习本次练习是在windows下,mysql版本为5.7,python版本为2.7.5,集成环境为pycharm. 创建表时,enign在innodb下支持事务,其他 ...
imooc的疯狂的蚂蚁的课程《Python操作MySQL数据库》 python3+pymysql模块来操作mysql数据库
以下代码为imooc的疯狂的蚂蚁的课程<Python操作MySQL数据库>的python3版本的代码,使用的是pymysql模块来操作mysql数据库,代码与原课程有所改动,注意运行时需要 ...
python操作mysql数据库用到的fetchone()函数和fetchall()函数
在用python操作mysql数据库时,碰到了下面这两个函数,标记一下: fetchone() : 返回单个的元组,也就是一条记录(row),如果没有结果则返回 None fetchall() : ...
python操作mysql数据库实现增删改查
Python 标准数据库接口为 Python DB-API,Python DB-API为开发人员提供了数据库应用编程接口. Python 数据库接口支持非常多的数据库,你可以选择适合你项目的数据库: ...

python操作mysql数据库—坑吭

python操作mysql数据库—坑吭相关推荐

最新文章

热门文章