mysql基本操作类，mysql基本操作,db.pyimport

mysql基本操作类，mysql基本操作,db.pyimport

db.py

import MySQLdbclass db():    CURSOR_DICT = 0;    CURSOR_DEFAULT = 1;    def __init__(self, *args, **kwargs):        self.__connect = None;        self.__args = args;        self.__kwagrs = kwargs;    def queryAll(self, sql, *args):        cursor = self.__query(db.CURSOR_DICT, sql, *args);        data = cursor.fetchall();        cursor.close();        return data;    def queryRow(self, sql, *args):        cursor = self.__query(db.CURSOR_DICT, sql, *args);        data = cursor.fetchone();        cursor.close();        return data;    def querySize(self, size, sql, *args):        cursor = self.__query(db.CURSOR_DICT, sql, *args);        data = cursor.fetchmany(size);        cursor.close();        return data;    def queryColumn(self, sql, *args):        cursor = self.__query(db.CURSOR_DEFAULT, sql, *args);        data = cursor.fetchall();        cursor.close();        if not data:            return None;        return tuple([row[0] for row in data]);    def queryScalar(self, sql, *args):        cursor = self.__query(db.CURSOR_DEFAULT, sql, *args);        data = cursor.fetchone();        cursor.close();        if not data:            return None;        return data[0];    def __query(self, cursorClass, sql, *args):        connect = self.__getConnect();        if cursorClass == db.CURSOR_DICT:            cursor = connect.cursor(MySQLdb.cursors.DictCursor);        else:            cursor = connect.cursor();        cursor.execute(sql, *args);        return cursor;    def execute(self, sql, *args):        connect = self.__getConnect();        cursor = connect.cursor();        try:            cursor.execute(sql, *args);            connect.commit();            return True;        except:            connect.rollback();            return False;        finally:            cursor.close();    def transations(self, sqlArray, *args):        if len(sqlArray) <= 0:            return False;        connect = self.__getConnect();        cursor = connect.cursor();        try:            for index, sql in enumerate(sqlArray):                arg = args[index] if index in args else ();                cursor.execute(sql, *arg);            connect.commit();            return True;        except:            connect.rollback();            return False;        finally:            cursor.close();    def __getConnect(self):        if self.__connect:            return self.__connect;        self.__connect = MySQLdb.Connect(            *self.__args, **self.__kwagrs        );        return self.__connect;    def __del__(self):        if self.__connect:            self.__connect.close();

test.py

#-*-coding: utf-8 -*-from db import db#初始化db = db(    host = 'localhost', user = 'root', passwd = '123456', port = 3306,    db = 'test', charset = 'utf8');#获取所有结果集合db.queryAll('select * from test where name = "tom"');db.queryAll('select * from test where name = %s', ('tom'));#获取第一行记录db.queryRow('select * from test where name = "tom"');db.queryRow('select * from test where name = %s', ('tom'));#获取第一列记录db.queryColumn('select * from test where name = "tom"');db.queryColumn('select * from test where name = %s', ('tom'));#获取第一行第一列的值db.queryScalar('select COUNT(id) from test where name = "tom"');db.queryScalar('select COUNT(id) from test where name = %s', ('tom'));#获取前n行的记录db.querySize(10, 'select * from where name = "tom"');db.querySize(10, 'select * from where name = %s', ('tom'));#添加（由于编辑、删除跟与添加操作同理，只是SQL语句不同而已，故此不再阐述）db.execute('insert into test set id = 1, name = "tom"');db.execute('insert into test set id = %s, name = %s', (1, 'tom'));#事务db.transations(('delete from test where name = "tom"','insert into test set id = 1, name = "tom"'));db.transations(    ('delete from test where name = %s', 'insert into test set id = %s, name = %s'),    ('tom'), (1, 'tom'));