python連結mysql資料庫詳解

學習了有些基本的python的東西，總想自己動手寫一個程序，但是寫程序不用數據庫，顯得太低端，那麼python鏈接mysql怎麼來操作呢？以下就為大家來詳細介紹下

我採用的是MySQLdb操作的MYSQL資料庫。先來一個簡單的例子：

importMySQLdb
 
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()
exceptMySQLdb.Error,e:
     print"Mysql Error %d: %s"%(e.args[0], e.args[1])

   

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

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

importMySQLdb
 
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=[]
    fori inrange(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()
 
exceptMySQLdb.Error,e:
     print"Mysql Error %d: %s"%(e.args[0], e.args[1])

   

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

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

importMySQLdb
 
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()
    printresult
    print'ID: %s info %s'%result
 
    results=cur.fetchmany(5)
    forr inresults:
        printr
 
    print'=='*10
    cur.scroll(0,mode='absolute')
 
    results=cur.fetchall()
    forr inresults:
        printr[1]
     
 
    conn.commit()
    cur.close()
    conn.close()
 
exceptMySQLdb.Error,e:
     print"Mysql Error %d: %s"%(e.args[0], e.args[1])

查詢後中文會正確顯示，但在資料庫中卻是亂碼的。注意這裡要加入一個參數charset：

在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'。

 

備註：python mysql連結常用函數

commit() 提交
rollback() 回滾

cursor用來執行指令的方法:
callprof(self, procname(Sargs)的參數為預存程序名稱和參數列表,傳回值為受影響的行數
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條.