python操作MySQL數(shù)據(jù)庫的方法分享

更新時間：2012年05月29日 19:48:01 作者：

堅持每天學一點，每天積累一點點，作為自己每天的業(yè)余收獲，這個文章是我在吃飯的期間寫的，利用自己零散的時間學了一下python操作MYSQL，所以整理一下

我采用的是MySQLdb操作的MYSQL數(shù)據(jù)庫。先來一個簡單的例子吧：

 
import MySQLdb 

try: 
conn=MySQLdb.connect(host='localhost',user='root',passwd='root',db='test',port=3306) 
cur=conn.cursor() 
cur.execute('select * from user') 
cur.close() 
conn.close() 
except MySQLdb.Error,e: 
print "Mysql Error %d: %s" % (e.args[0], e.args[1]) 

請注意修改你的數(shù)據(jù)庫，主機名，用戶名，密碼。

下面來大致演示一下插入數(shù)據(jù)，批量插入數(shù)據(jù)，更新數(shù)據(jù)的例子吧：

復制代碼代碼如下:

 
import MySQLdb 

try: 
conn=MySQLdb.connect(host='localhost',user='root',passwd='root',port=3306) 
cur=conn.cursor() 

cur.execute('create database if not exists python') 
conn.select_db('python') 
cur.execute('create table test(id int,info varchar(20))') 

value=[1,'hi rollen'] 
cur.execute('insert into test values(%s,%s)',value) 

values=[] 
for i in range(20): 
values.append((i,'hi rollen'+str(i))) 

cur.executemany('insert into test values(%s,%s)',values) 

cur.execute('update test set info="I am rollen" where id=3') 

conn.commit() 
cur.close() 
conn.close() 

except MySQLdb.Error,e: 
print "Mysql Error %d: %s" % (e.args[0], e.args[1]) 

請注意一定要有conn.commit()這句來提交事務，要不然不能真正的插入數(shù)據(jù)。

運行之后我的MySQL數(shù)據(jù)庫的結(jié)果就不上圖了。

復制代碼代碼如下:

 
import MySQLdb 

try: 
conn=MySQLdb.connect(host='localhost',user='root',passwd='root',port=3306) 
cur=conn.cursor() 

conn.select_db('python') 

count=cur.execute('select * from test') 
print 'there has %s rows record' % count 

result=cur.fetchone() 
print result 
print 'ID: %s info %s' % result 

results=cur.fetchmany(5) 
for r in results: 
print r 

print '=='*10 
cur.scroll(0,mode='absolute') 

results=cur.fetchall() 
for r in results: 
print r[1] 


conn.commit() 
cur.close() 
conn.close() 

except MySQLdb.Error,e: 
print "Mysql Error %d: %s" % (e.args[0], e.args[1]) 

運行結(jié)果就不貼了，太長了。

查詢后中文會正確顯示，但在數(shù)據(jù)庫中卻是亂碼的。經(jīng)過我從網(wǎng)上查找，發(fā)現(xiàn)用一個屬性有可搞定：

在Python代碼

conn = MySQLdb.Connect(host='localhost', user='root', passwd='root', db='python') 中加一個屬性：
改為：
conn = MySQLdb.Connect(host='localhost', user='root', passwd='root', db='python',charset='utf8')
charset是要跟你數(shù)據(jù)庫的編碼一樣，如果是數(shù)據(jù)庫是gb2312 ,則寫charset='gb2312'。

下面貼一下常用的函數(shù)：

然后,這個連接對象也提供了對事務操作的支持,標準的方法
commit() 提交
rollback() 回滾

cursor用來執(zhí)行命令的方法:
callproc(self, procname, args):用來執(zhí)行存儲過程,接收的參數(shù)為存儲過程名和參數(shù)列表,返回值為受影響的行數(shù)
execute(self, query, args):執(zhí)行單條sql語句,接收的參數(shù)為sql語句本身和使用的參數(shù)列表,返回值為受影響的行數(shù)
executemany(self, query, args):執(zhí)行單挑sql語句,但是重復執(zhí)行參數(shù)列表里的參數(shù),返回值為受影響的行數(shù)
nextset(self):移動到下一個結(jié)果集

cursor用來接收返回值的方法:
fetchall(self):接收全部的返回結(jié)果行.
fetchmany(self, size=None):接收size條返回結(jié)果行.如果size的值大于返回的結(jié)果行的數(shù)量,則會返回cursor.arraysize條數(shù)據(jù).
fetchone(self):返回一條結(jié)果行.
scroll(self, value, mode='relative'):移動指針到某一行.如果mode='relative',則表示從當前所在行移動value條,如果 mode='absolute',則表示從結(jié)果集的第一行移動value條.

參考資料：

MySQLdb‘s user guide

package MySQLdb

您可能感興趣的文章: