代码如下:
# -*- 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()
”’
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至253000106@qq.com举报，一经查实，本站将立刻删除。
发布者：PHP中文网，转转请注明出处：https://www.chuangxiangniao.com/p/2304376.html
