复制代码 代码如下:
# -*- coding: utf-8 -*-
import sys
import MySQLdb
reload(sys)
sys.setdefaultencoding(\’utf-8\’)
class DB(object):
def __init__(self,host=\’127.0.0.1\’,port=3306,user=\’root\’,passwd=\’123\’,database=\’\’):
self.__host=host
self.__port=port
self.__user=user
self.__passwd=passwd
self.__database=database
self.__open=False
print \’__init__\’
def __connect__(self):
if self.__open == False:
print \’connect db…\’
self.__conn = MySQLdb.connect(host=self.__host , port=self.__port , user=self.__user , passwd=self.__passwd,charset=\’utf8\’)
self.__open = True
def __executeSql__(self,sql):
self.__connect__()
self.__executor = self.__conn.cursor(cursorclass = MySQLdb.cursors.DictCursor)
self.__executor.execute(\’use \’+self.__database) #切换数据库
return self.__executor.execute(sql)
def executeQueryForObject(self , sql):
self.__executeSql__(sql)
return self.__executor.fetchone()
\’\’\’
返回key=value 字典
\’\’\’
def executeQueryAll(self , sql):
self.__executeSql__(sql)
return self.__executor.fetchall()
def executeUpdate(self ,sql=\’\’ , isAutoCommit=False):
c = self.__executeSql__(sql)
if isAutoCommit == True:
self.commit() #提交事务
return c
\’\’\’
#提交事务
\’\’\’
def commit(self):
self.__conn.commit() #提交事务
\’\’\’
#关闭数据库，释放资源
\’\’\’
def closeDB(self):
if not self.__conn is None:
print \’close db…\’
self.__conn.commit() #提交事务
self.__conn.close()
def print_parameters(self):
print self.__user
print self.__passwd
print self.__host
print self.__port
\’\’\’
if __name__ == \’__main__\’:
db=DB(database=\’tb2013\’)
#db.print_parameters()
#db.executeSql(\’select * from tb_user\’)
print db.executeQueryForObject(\’select count(*) as count from tb_user\’)
_rows = db.executeQueryAll(\’select userid,nick from tb_user limit 10\’);
print _rows
for row in _rows:
print row
print \’nick:%s\’ % str(row[\’nick\’])
print db.executeUpdate(sql=\’update tb_user set nick=\\\’test\\\’ where userid=95084397\’,isAutoCommit=True)
db.closeDB()
\’\’\’