複製** **如下:
# -*- 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.__porwww.cppcns.comt=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()cvjmtz #提交事務
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_pwww.cppcns.comarameters(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
pr程式設計客棧int 'nick:%s' % str(row['nick'])
print db.executeupdate(sql='update tb_user set nick=\'test\' where userid=95084397',isautocommit=true)
db.closedb()
'''
本文標題: python連線mysql並提交mysql事務示例
本文位址:
Python高階 連線 Mysql
本篇文章主要用 pymysql 來實現python3 mysql資料的連線。git clone cd pymysql python3 setup.py install 安裝過程如下圖所示 開啟資料庫連線 db pymysql.connect localhost username password t...
python連線MySQL示例
python連線mysql示例一 開啟資料庫連線 connect,connect,connection import pymysql db pymysql.connect host localhost port 3306 user root passwd 123456 db stu charset ...
python 環境搭建 ，連線 mysql
在win7 64位系統上，執行網上的 python 爬蟲原始碼，出現環境錯誤，記錄下解決過程 1.開始機子上安裝的 python 為 3.5.2 版本 由於 print 函式 錯誤，因為 3.x 版本需要 括號 print 於是安裝 2.7 版本，切換下 環境變數即可 但是安裝後並不能使用，又繼續找...