在Python中要連接數據庫,首先我們得先安裝幾個重要的東西,主要有:
(1)Python-dev包
(2)setuptools-0.6c11.tar.gz
(3)MySQL-python-1.2.3.tar.gz
下面分別來說說這三個主要的包的安裝步驟:
(1)Python-dev包
直接yum install python-devel
(2)setuptools-0.6c11.tar.gz
在網上下載后,先解壓:tar zxf setuptools-0.6c11.tar.gz,完畢后cd到解壓后的文件夾,執行:
python setup.py build
python setup.py install
(3)MySQL-python-1.2.3.tar.gz
跟安裝setuptools-0.6c11.tar.gz步驟一樣,先解壓:tar zxfMySQL-python-1.2.3.tar.gz,
完畢后cd到解壓后的文件夾,執行:
python setup.py build
python setup.py install
在執行上述命令之前,最好先修改一個文件,我們先查找mysql_config的位置,使用命令:
find / -name mysql_config
然后我們獲取到它的路徑,我的是:/usr/bin/mysql_config,然后修改MySQL-python-1.2.3目錄下
的site.cfg文件,去掉mysql_config=XXX這行前面的#,改為:
mysql_config = /usr/bin/mysql_config
經過上面的步驟,我們基本就可以MySQLdb安裝好了。
可以測試一下,在Python的交互式命令行,輸入import MySQLdb,如果沒有報錯,就說明已經安裝好。
下面的Python代碼展示了如何連接數據庫,并執行數據庫的一些操作:
import MySQLdbtry: conn = MySQLdb.connect(host='localhost',user='root',passwd='root',port=3306) cur = conn.cursor() cur.execute('create database if not exists PythonDB') conn.select_db('PythonDB') cur.execute('create table Test(id int,name varchar(20),info varchar(20))') value = [1,'ACdreamer','student'] cur.execute('insert into Test values(%s,%s,%s)',value) values = [] for i in range(20): values.append((i,'Hello World!','My number is '+str(i))) cur.executemany('insert into Test values(%s,%s,%s)',values) cur.execute('update Test set name="ACdreamer" where id=3') conn.commit() cur.close() conn.close()except MySQLdb.Error,msg: print "MySQL Error %d: %s" %(msg.args[0],msg.args[1]) 可以看出,連接數據庫大致分為以下步驟:
(1)建立和數據庫系統的連接
(2)獲取操作游標
(3)執行SQL,創建一個數據庫(當然這一步不是必需的,因為我們可以用已經存在的數據庫)
(4)選擇數據庫
(5)進行各種數據庫操作
(6)操作完畢后,提交事務(這一步很重要,因為只有提交事務后,數據才能真正寫進數據庫)
(7)關閉操作游標
(8)關閉數據庫連接
當然,如果我們使用已經存在的數據庫,那么在獲取連接時就可以制定了,比如:
conn = MySQLdb.connect(host='localhost', user='root', passwd='root', db='PythonDB')
如果數據庫中有中文,為了防止亂碼,我們加入屬性charset = 'uft-8'或者'gb2312',charset要跟數據庫的編碼一致。
conn = MySQLdb.connect(host='localhost', user='root',
passwd='root', db='PythonDB',charset='utf8')
下面貼一下常用的函數:
數據庫連接對事務操作的方法: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條。



















