文档章节

python2.7 and python3 操作MySQL数据库类

leeyi
 leeyi
发布于 2017/05/25 17:58
字数 576
阅读 231
收藏 0

python3 mysql.py

pip3 install pymysql

mysql.py

# -*- coding: utf8 -*-
import logging
import pymysql
import pymysql.cursors

from scrapy.utils.project import get_project_settings

settings = get_project_settings()
dbconf = settings['MYSQL_DB']

class _MySQL(object):
    def __init__(self, host, port, user, passwd, db, charset='utf8'):
        self.conn = pymysql.connect(
            host = host,
            port = port,
            user = user,
            passwd = passwd,
            db = db,
            charset = charset,
            cursorclass = pymysql.cursors.DictCursor
        )

    def get_cursor(self):
        return self.conn.cursor()

    def query(self, sql):
        cursor = self.get_cursor()
        try:
            cursor.execute(sql, None)
            result = cursor.fetchall()
        except Exception as e:
            logging.error("mysql query error: %s", e)
            return None
        finally:
            cursor.close()
        return result

    def execute(self, sql, param=None):
        cursor = self.get_cursor()
        try:
            cursor.execute(sql, param)
            self.conn.commit()
            affected_row = cursor.rowcount
        except Exception as e:
            logging.error("mysql execute error: %s", e)
            return 0
        finally:
            cursor.close()
        return affected_row

    def insert(self, sql, param=None):
        cursor = self.get_cursor()
        try:
            cursor.execute(sql, param)
            self.conn.commit()
            lastrowid = cursor.lastrowid
        except Exception as e:
            logging.error("mysql insert error: %s", e)
            return 0
        finally:
            cursor.close()
        return lastrowid

    def executemany(self, sql, params=None):
        cursor = self.get_cursor()
        try:
            cursor.executemany(sql, params)
            self.conn.commit()
            affected_rows = cursor.rowcount
        except Exception as e:
            logging.error("mysql executemany error: %s", e)
            return 0
        finally:
            cursor.close()
        return affected_rows

    def close(self):
        try:
            self.conn.close()
        except:
            pass

    def __del__(self):
        self.close()

mysql = _MySQL(
    host=dbconf['host'],
    user=dbconf['user'],
    passwd=dbconf['password'],
    db=dbconf['name'],
    port=dbconf['port'],
    charset=dbconf['charset'],
)

def create_table():
    table = """
            CREATE TABLE IF NOT EXISTS `watchdog`(
                `id` int(11) NOT NULL AUTO_INCREMENT PRIMARY KEY,
                `name` varchar(100),
                `price` int(11) NOT NULL DEFAULT 0
            ) ENGINE=InnoDB charset=utf8;
            """
    print(mysql.execute(table))

def insert_data():
    params = [('dog_%d' % i, i) for i in range(12)]
    sql = "INSERT INTO `watchdog`(`name`,`price`) VALUES(%s,%s);"
    print(mysql.executemany(sql, params))

def insert():
    params = [('dog_%d' % i, i) for i in range(12)]
    sql = "INSERT INTO `watchdog`(`name`,`price`) VALUES('%s','%s'), ('%s','%s');" % ('name_test', '100', 'name_tes2', '101')
    res = mysql.insert(sql)
    print(res)

def select_data():
    query = "select `id`,`name`,`price` from `watchdog`;";
    li = mysql.query(query)
    print(li)

if __name__ == '__main__':
    # create_table()
    # insert()
    # insert_data()
    # select_data()
    pass

python2.7 mysql.py

pip2 install MySQL-python

mysql.py

# -*- coding: utf8 -*-
import logging
import MySQLdb
import MySQLdb.cursors

from DBConf import db_host
from DBConf import db_port
from DBConf import db_user
from DBConf import db_passwd
from DBConf import db_name

class _MySQL(object):
    def __init__(self, host, port, user, passwd, db, charset='utf8'):
        self.conn = MySQLdb.connect(
            host = host,
            port = port,
            user = user,
            passwd = passwd,
            db = db,
            charset = charset,
            cursorclass = MySQLdb.cursors.DictCursor
        )

    def get_cursor(self):
        return self.conn.cursor()

    def query(self, sql):
        cursor = self.get_cursor()
        try:
            cursor.execute(sql, None)
            result = cursor.fetchall()
        except Exception, e:
            logging.error("mysql query error: %s", e)
            return None
        finally:
            cursor.close()
        return result

    def execute(self, sql, param=None):
        cursor = self.get_cursor()
        try:
            cursor.execute(sql, param)
            self.conn.commit()
            affected_row = cursor.rowcount
        except Exception, e:
            logging.error("mysql execute error: %s", e)
            return 0
        finally:
            cursor.close()
        return affected_row

    def executemany(self, sql, params=None):
        cursor = self.get_cursor()
        try:
            cursor.executemany(sql, params)
            self.conn.commit()
            affected_rows = cursor.rowcount
        except Exception, e:
            logging.error("mysql executemany error: %s", e)
            return 0
        finally:
            cursor.close()
        return affected_rows

    def close(self):
        try:
            self.conn.close()
        except:
            pass

    def __del__(self):
        self.close()

mysql = _MySQL(db_host, db_port, db_user, db_passwd, db_name)

def create_table():
    table = """
            CREATE TABLE IF NOT EXISTS `watchdog`(
                `id` int(11) NOT NULL AUTO_INCREMENT PRIMARY KEY,
                `name` varchar(100),
                `price` int(11) NOT NULL DEFAULT 0
            ) ENGINE=InnoDB charset=utf8;
            """
    print mysql.execute(table)

def insert_data():
    params = [('dog_%d' % i, i) for i in xrange(12)]
    sql = "INSERT INTO `watchdog`(`name`,`price`) VALUES(%s,%s);"
    print mysql.executemany(sql, params)

if __name__ == '__main__':
    # create_table()
    # insert_data()
    pass

© 著作权归作者所有

共有 人打赏支持
leeyi
粉丝 4
博文 46
码字总数 52736
作品 0
深圳
后端工程师
私信 提问
Python学习日记六(Python连接MySql)

一.准备工作(下载MySQL-python和python安装包 ) Python需要连接mysql,需要下载Python MySQLdb模块,这里提供几个链接地址: MySQL-python官网下载地址 :https://pypi.python.org/pypi/My...

HaleyLiu
04/12
0
0
「自动化实战」手把手从python安装到setuptools、pip工具安装

以下为在Ubuntu中python的基础环境安装 一、python安装 1、基础开发库 sudo apt-get install gcc sudo apt-get install openssl libssl-dev 2、安装数据库和开发库 sudo apt-get install mys...

yard521
07/01
0
0
Python2.7 源码编译并集成第三方python模块

由于redhat5的python版本比较低,很多新的第三方python包及新功能都无法使用,所以需要升级系统自带python版本,打算升级到python2.7.4,并集成进去一些业务常用的第三方模块。 python安装 ...

China_OS
2014/09/16
0
0
Python操作小结(mysql、txt\json、crontab、http)

有段时间没有使用python了,对它的语法有点生疏,花了几个小时熟悉,期间发现很多小细节不清楚。为了下次能快速上手,避免重复犯错,我将python使用过程中的一些问题在这篇博文中记录小结一下...

lilugoodjob
07/02
0
0
使用 python 管理 mysql 开发工具箱 - 1

Mysql 是一个比较优秀的开源的数据库,很多公司都在使用。作为运维人员,经常做着一些重复性的工作,比如创建数据库实例,数据库备份等,完全都可以使用 python 编写一个工具来实现。 一、模...

肖邦0526
2016/12/26
0
0

没有更多内容

加载失败,请刷新页面

加载更多

CAS和AQS

CAS(Compare And Swap) 什么是CAS CAS(Compare And Swap),即比较并交换。是解决多线程并行情况下使用锁造成性能损耗的一种机制。 CAS是一种系统原语,原语属于操作系统用语范畴,是由若干条...

狼王黄师傅
30分钟前
2
0
Python利用pandas处理Excel数据的应用

Python利用pandas处理Excel数据的应用 最近迷上了高效处理数据的pandas,其实这个是用来做数据分析的,如果你是做大数据分析和测试的,那么这个是非常的有用的!!但是其实我们平时在做自动化...

上官夏洛特
44分钟前
2
0
100:代码管理平台svn

1:代码管理平台:代码版本管理工具,工作中用于代码更新,代码发布统计,代码版本控制;(频繁更新代码的版本记录),方便查阅历史变更,协同开发及合并; 版本管理工具发展: cvs(编码兼容不太好)...

芬野de博客
45分钟前
1
0
Linux学习-1101(rsync下、log、screen)

10.32/10.33 rsync通过服务同步 10.34 linux系统日志 10.35 screen工具 一、 rsync通过服务同步 rsync 通过服务的方式同步,首先需要开启一个服务。它是C/S架构,开启rsync服务,默认端口是8...

wxy丶
51分钟前
1
0
使用jpmml-sparkml-executable生成PMML模型文件

加载依赖的jar包通过./spark-shell --jars ./jpmml-sparkml-executable-1.2.13.jar 启动spark import org.apache.spark.ml.classification.LogisticRegressionimport org.apache.spark.m......

KYO4321
55分钟前
1
1

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部