python操作mysql資料庫
1、環境準備：
Linux
安裝mysql： apt-get install mysql-server
安裝python-mysql子產品：apt-get install python-mysqldb
Windows
下載下傳安裝mysql
python操作mysql子產品：MySQL-python-1.2.3.win32-py2.7.exe 或 MySQL-python-1.2.3.win-amd64-py2.7.exe
下載下傳位址：http://blog.csdn.net/reblue520/article/details/51702485
不安裝python-mysqldb子產品會報錯：
Unused import: MySQLdb，需要安裝pytho-mysqldb
mysql圖形界面：Navicat_for_MySQL 友善觀察資料庫的變化
安裝python開發環境，具體可參考：windows下搭建eclipse關于python的開發環境及初始化參數配置
2、一個簡單連接配接資料庫的例子：
import MySQLdb
try:
conn=MySQLdb.connect(host='localhost',user='root',passwd='root',db='test',port=3306)
cur=conn.cursor()
cur.execute('select user,password from user')
cur.close()
conn.close()
except MySQLdb.Error,e:
print "Mysql Error %d: %s" % (e.args[0], e.args[1])
注意修改你連接配接的資料庫，主機IP，使用者名，密碼。
3、插入資料，批量插入資料，更新資料的例子：
#!/usr/bin/env python
#_*_ coding:utf-8 _*_
import MySQLdb
try:
conn = MySQLdb.Connect(host='192.168.8.40',user='root',passwd='root',db='mysql',port=3306)
cur = conn.cursor()
rs = cur.execute('select user,password,host from user')
rs = cur.execute('create database if not exists python')
conn.select_db('python')
cur.execute('create table test(id int,info varchar(30))')
value = [1,'hi jack']
cur.execute('insert into test values(%s,%s)',value)
values = []
for i in range(20):
values.append((i,'hi jack' + str(i)))
cur.executemany('insert into test values(%s,%s)',values)
cur.execute('update test set info="i am jack" where id=3')
conn.commit()
cur.close()
conn.close()
except MySQLdb.Error,e:
print 'mysql error msg: %d,%s' % (e.args[0],e.args[1])
請注意一定要有conn.commit()這句來送出事務，要不然不能真正的插入資料
4、常用擷取資料的一些方法
#!/usr/bin/env python
#_*_ coding:utf-8 _*_
import MySQLdb
try:
conn = MySQLdb.Connect(host='192.168.8.40',user='root',passwd='root',db='mysql',port=3306,charset='utf8')
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
result2 = cur.fetchmany(3)
for record in result2:
print record
print '=='*10
cur.scroll(0,mode='absolute')
result3 = cur.fetchall()
for record in result3:
print record[0] ,'---',record[1]
conn.commit()
cur.close()
conn.close()
except MySQLdb.Error,e:
print 'mysql error msg: %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條.