代碼如下:

# -*- 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()

'''

本文原創發布php中文網，轉載請注明出處，感謝您的尊重！

總結

以上是生活随笔為你收集整理的python操作mysql事务提交_python连接mysql并提交mysql事务示例的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。