python操作MySQL資料庫具體方法

03-17

堅持每天學一點，每天積累一點點，作為自己每天的業餘收穫，這個文章是我在吃飯的期間寫的，利用自己零散的時間學了一下python操作MYSQL，所以整理一下。我採用的是MySQLdb操作的MYSQL資料庫。先來一個簡單的例子吧

代碼如下:

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])

請注意修改你的資料庫，主機名，用戶名，密碼。

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

代碼如下:

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()這句來提交事務，要不然不能真正的插入數據。

運行之後我的MySQL資料庫的結果就不上圖了。

代碼如下:

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])

運行結果就不貼了，太長了。

查詢後中文會正確顯示，但在資料庫中卻是亂碼的。經過我從網上查找，發現用一個屬性有可搞定：

在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是要跟你資料庫的編碼一樣，如果是資料庫是gb2312 ,則寫charset=gb2312。

下面貼一下常用的函數：

然後,這個連接對象也提供了對事務操作的支持,標準的方法

commit() 提交

rollback() 回滾

cursor用來執行命令的方法:

callproc(self, procname, args):用來執行存儲過程,接收的參數為存儲過程名和參數列表,返回值為受影響的行數

execute(self, query, args):執行單條sql語句,接收的參數為sql語句本身和使用的參數列表,返回值為受影響的行數

executemany(self, query, args):執行單挑sql語句,但是重複執行參數列表裡的參數,返回值為受影響的行數

nextset(self):移動到下一個結果集

cursor用來接收返回值的方法:

fetchall(self):接收全部的返回結果行.

fetchmany(self, size=None):接收size條返回結果行.如果size的值大於返回的結果行的數量,則會返回cursor.arraysize條數據.

fetchone(self):返回一條結果行.

scroll(self, value, mode=relative):移動指針到某一行.如果mode=relative,則表示從當前所在行移動value條,如果 mode=absolute,則表示從結果集的第一行移動value條.