Python基础教程(十):CGI编程、MySQL数据库
Python CGI編程
什么是CGI
CGI 目前由NCSA維護(hù),NCSA定義CGI如下:
CGI(Common Gateway Interface),通用網(wǎng)關(guān)接口,它是一段程序,運行在服務(wù)器上如:HTTP服務(wù)器,提供同客戶端HTML頁面的接口。
網(wǎng)頁瀏覽
為了更好的了解CGI是如何工作的,我們可以從在網(wǎng)頁上點擊一個鏈接或URL的流程:
- 1、使用你的瀏覽器訪問URL并連接到HTTP web 服務(wù)器。
- 2、Web服務(wù)器接收到請求信息后會解析URL,并查找訪問的文件在服務(wù)器上是否存在,如果存在返回文件的內(nèi)容,否則返回錯誤信息。
- 3、瀏覽器從服務(wù)器上接收信息,并顯示接收的文件或者錯誤信息。
CGI程序可以是Python腳本,PERL腳本,SHELL腳本,C或者C++程序等。
CGI架構(gòu)圖
Web服務(wù)器支持及配置
在你進(jìn)行CGI編程前,確保您的Web服務(wù)器支持CGI及已經(jīng)配置了CGI的處理程序。
Apache 支持CGI 配置:
設(shè)置好CGI目錄:
ScriptAlias /cgi-bin/ /var/www/cgi-bin/所有的HTTP服務(wù)器執(zhí)行CGI程序都保存在一個預(yù)先配置的目錄。這個目錄被稱為CGI目錄,并按照慣例,它被命名為/var/www/cgi-bin目錄。
CGI文件的擴展名為.cgi,python也可以使用.py擴展名。
默認(rèn)情況下,Linux服務(wù)器配置運行的cgi-bin目錄中為/var/www。
如果你想指定其他運行CGI腳本的目錄,可以修改httpd.conf配置文件,如下所示:
<Directory "/var/www/cgi-bin"> ?? AllowOverride None ?? Options +ExecCGI ?? Order allow,deny ?? Allow from all </Directory>在 AddHandler 中添加 .py 后綴,這樣我們就可以訪問 .py 結(jié)尾的 python 腳本文件:
AddHandler cgi-script .cgi .pl .py第一個CGI程序
我們使用Python創(chuàng)建第一個CGI程序,文件名為hello.py,文件位于/var/www/cgi-bin目錄中,內(nèi)容如下,修改文件的權(quán)限為755:
#!/usr/bin/python # -*- coding: UTF-8 -*- ? print "Content-type:text/html\r\n\r\n" print '<html>' print '<head>' print '<title>Hello Word - First CGI Program</title>' print '</head>' print '<body>' print '<h2>Hello Word! This is my first CGI program</h2>' print '</body>' print '</html>'以上程序在瀏覽器訪問顯示結(jié)果如下:
Hello Word! This is my first CGI program這個的hello.py腳本是一個簡單的Python腳本,腳本第一行的輸出內(nèi)容"Content-type:text/html\r\n\r\n"發(fā)送到瀏覽器并告知瀏覽器顯示的內(nèi)容類型為"text/html"。
HTTP頭部
hello.py文件內(nèi)容中的"Content-type:text/html\r\n\r\n"即為HTTP頭部的一部分,它會發(fā)送給瀏覽器告訴瀏覽器文件的內(nèi)容類型。
HTTP頭部的格式如下:
HTTP 字段名: 字段內(nèi)容 ? 例如 Content-type: text/html\r\n\r\n以下表格介紹了CGI程序中HTTP頭部經(jīng)常使用的信息:
| 頭 | 描述 |
| Content-type: | 請求的與實體對應(yīng)的MIME信息。例如: Content-type:text/html |
| Expires: Date | 響應(yīng)過期的日期和時間 |
| Location: URL | 用來重定向接收方到非請求URL的位置來完成請求或標(biāo)識新的資源 |
| Last-modified: Date | 請求資源的最后修改時間 |
| Content-length: N | 請求的內(nèi)容長度 |
| Set-Cookie: String | 設(shè)置Http Cookie |
CGI環(huán)境變量
所有的CGI程序都接收以下的環(huán)境變量,這些變量在CGI程序中發(fā)揮了重要的作用:
| 變量名 | 描述 |
| CONTENT_TYPE | 這個環(huán)境變量的值指示所傳遞來的信息的MIME類型。目前,環(huán)境變量CONTENT_TYPE一般都是:application/x-www-form-urlencoded,他表示數(shù)據(jù)來自于HTML表單。 |
| CONTENT_LENGTH | 如果服務(wù)器與CGI程序信息的傳遞方式是POST,這個環(huán)境變量即使從標(biāo)準(zhǔn)輸入STDIN中可以讀到的有效數(shù)據(jù)的字節(jié)數(shù)。這個環(huán)境變量在讀取所輸入的數(shù)據(jù)時必須使用。 |
| HTTP_COOKIE | 客戶機內(nèi)的 COOKIE 內(nèi)容。 |
| HTTP_USER_AGENT | 提供包含了版本數(shù)或其他專有數(shù)據(jù)的客戶瀏覽器信息。 |
| PATH_INFO | 這個環(huán)境變量的值表示緊接在CGI程序名之后的其他路徑信息。它常常作為CGI程序的參數(shù)出現(xiàn)。 |
| QUERY_STRING | 如果服務(wù)器與CGI程序信息的傳遞方式是GET,這個環(huán)境變量的值即使所傳遞的信息。這個信息經(jīng)跟在CGI程序名的后面,兩者中間用一個問號'?'分隔。 |
| REMOTE_ADDR | 這個環(huán)境變量的值是發(fā)送請求的客戶機的IP地址,例如上面的192.168.1.67。這個值總是存在的。而且它是Web客戶機需要提供給Web服務(wù)器的唯一標(biāo)識,可以在CGI程序中用它來區(qū)分不同的Web客戶機。 |
| REMOTE_HOST | 這個環(huán)境變量的值包含發(fā)送CGI請求的客戶機的主機名。如果不支持你想查詢,則無需定義此環(huán)境變量。 |
| REQUEST_METHOD | 提供腳本被調(diào)用的方法。對于使用 HTTP/1.0 協(xié)議的腳本,僅 GET 和 POST 有意義。 |
| SCRIPT_FILENAME | CGI腳本的完整路徑 |
| SCRIPT_NAME | CGI腳本的的名稱 |
| SERVER_NAME | 這是你的 WEB 服務(wù)器的主機名、別名或IP地址。 |
| SERVER_SOFTWARE | 這個環(huán)境變量的值包含了調(diào)用CGI程序的HTTP服務(wù)器的名稱和版本號。例如,上面的值為Apache/2.2.14(Unix) |
以下是一個簡單的CGI腳本輸出CGI的環(huán)境變量:
#!/usr/bin/python # -*- coding: UTF-8 -*- ? import os ? print "Content-type: text/html\r\n\r\n"; print "<font size=+1>Environment</font><\br>"; for param in os.environ.keys(): ? print "<b>%20s</b>: %s<\br>" % (param, os.environ[param])GET和POST方法
瀏覽器客戶端通過兩種方法向服務(wù)器傳遞信息,這兩種方法就是 GET 方法和 POST 方法。
使用GET方法傳輸數(shù)據(jù)
GET方法發(fā)送編碼后的用戶信息到服務(wù)端,數(shù)據(jù)信息包含在請求頁面的URL上,以"?"號分割, 如下所示:
http://www.test.com/cgi-bin/hello.py?key1=value1&key2=value2有關(guān) GET 請求的其他一些注釋:
- GET 請求可被緩存
- GET 請求保留在瀏覽器歷史記錄中
- GET 請求可被收藏為書簽
- GET 請求不應(yīng)在處理敏感數(shù)據(jù)時使用
- GET 請求有長度限制
- GET 請求只應(yīng)當(dāng)用于取回數(shù)據(jù)
簡單的url實例:GET方法
以下是一個簡單的URL,使用GET方法向hello_get.py程序發(fā)送兩個參數(shù):
/cgi-bin/hello_get.py?first_name=ZARA&last_name=ALI以下為hello_get.py文件的代碼:
#!/usr/bin/python # -*- coding: UTF-8 -*- ? # CGI處理模塊 import cgi, cgitb ? # 創(chuàng)建 FieldStorage 的實例化 form = cgi.FieldStorage() ? # 獲取數(shù)據(jù) first_name = form.getvalue('first_name') last_name? = form.getvalue('last_name') ? print "Content-type:text/html\r\n\r\n" print "<html>" print "<head>" print "<title>Hello - Second CGI Program</title>" print "</head>" print "<body>" print "<h2>Hello %s %s</h2>" % (first_name, last_name) print "</body>" print "</html>"瀏覽器請求輸出結(jié)果:
Hello ZARA ALI簡單的表單實例:GET方法
以下是一個通過HTML的表單使用GET方法向服務(wù)器發(fā)送兩個數(shù)據(jù),提交的服務(wù)器腳本同樣是hello_get.py文件,代碼如下:
<form action="/cgi-bin/hello_get.py" method="get"> First Name: <input type="text" name="first_name">? <br /> ? Last Name: <input type="text" name="last_name" /> <input type="submit" value="Submit" /> </form>使用POST方法傳遞數(shù)據(jù)
使用POST方法向服務(wù)器傳遞數(shù)據(jù)是更安全可靠的,像一些敏感信息如用戶密碼等需要使用POST傳輸數(shù)據(jù)。
以下同樣是hello_get.py ,它也可以處理瀏覽器提交的POST表單數(shù)據(jù):
#!/usr/bin/python # -*- coding: UTF-8 -*- ? # 引入 CGI 模塊 import cgi, cgitb ? # 創(chuàng)建 FieldStorage 實例 form = cgi.FieldStorage() ? # 獲取表單數(shù)據(jù) first_name = form.getvalue('first_name') last_name? = form.getvalue('last_name') ? print "Content-type:text/html\r\n\r\n" print "<html>" print "<head>" print "<title>Hello - Second CGI Program</title>" print "</head>" print "<body>" print "<h2>Hello %s %s</h2>" % (first_name, last_name) print "</body>" print "</html>"以下為表單通過POST方法向服務(wù)器腳本hello_get.py提交數(shù)據(jù):
<form action="/cgi-bin/hello_get.py" method="post"> First Name: <input type="text" name="first_name"><br /> Last Name: <input type="text" name="last_name" /> ? <input type="submit" value="Submit" /> </form>通過CGI程序傳遞checkbox數(shù)據(jù)
checkbox用于提交一個或者多個選項數(shù)據(jù),HTML代碼如下:
<form action="/cgi-bin/checkbox.cgi" method="POST" target="_blank"> <input type="checkbox" name="maths" value="on" /> Maths <input type="checkbox" name="physics" value="on" /> Physics <input type="submit" value="Select Subject" /> </form>以下為 checkbox.cgi 文件的代碼:
#!/usr/bin/python # -*- coding: UTF-8 -*- ? # 引入 CGI 處理模塊 import cgi, cgitb ? # 創(chuàng)建 FieldStorage的實例 form = cgi.FieldStorage() ? # 接收字段數(shù)據(jù) if form.getvalue('maths'): ?? math_flag = "ON" else: ?? math_flag = "OFF" ? if form.getvalue('physics'): ?? physics_flag = "ON" else: ?? physics_flag = "OFF" ? print "Content-type:text/html\r\n\r\n" print "<html>" print "<head>" print "<title>Checkbox - Third CGI Program</title>" print "</head>" print "<body>" print "<h2> CheckBox Maths is : %s</h2>" % math_flag print "<h2> CheckBox Physics is : %s</h2>" % physics_flag print "</body>" print "</html>"通過CGI程序傳遞Radio數(shù)據(jù)
Radio只向服務(wù)器傳遞一個數(shù)據(jù),HTML代碼如下:
<form action="/cgi-bin/radiobutton.py" method="post" target="_blank"> <input type="radio" name="subject" value="maths" /> Maths <input type="radio" name="subject" value="physics" /> Physics <input type="submit" value="Select Subject" /> </form>radiobutton.py 腳本代碼如下:
#!/usr/bin/python # -*- coding: UTF-8 -*- ? # Import modules for CGI handling import cgi, cgitb ? # Create instance of FieldStorage form = cgi.FieldStorage() ? # Get data from fields if form.getvalue('subject'): ?? subject = form.getvalue('subject') else: ?? subject = "Not set" ? print "Content-type:text/html\r\n\r\n" print "<html>" print "<head>" print "<title>Radio - Fourth CGI Program</title>" print "</head>" print "<body>" print "<h2> Selected Subject is %s</h2>" % subject print "</body>" print "</html>"通過CGI程序傳遞 Textarea 數(shù)據(jù)
Textarea向服務(wù)器傳遞多行數(shù)據(jù),HTML代碼如下:
<form action="/cgi-bin/textarea.py" method="post" target="_blank"> <textarea name="textcontent" cols="40" rows="4"> Type your text here... </textarea> <input type="submit" value="Submit" /> </form>textarea.cgi腳本代碼如下:
#!/usr/bin/python # -*- coding: UTF-8 -*- ? # Import modules for CGI handling import cgi, cgitb ? # Create instance of FieldStorage form = cgi.FieldStorage() ? # Get data from fields if form.getvalue('textcontent'): ?? text_content = form.getvalue('textcontent') else: ?? text_content = "Not entered" ? print "Content-type:text/html\r\n\r\n" print "<html>" print "<head>"; print "<title>Text Area - Fifth CGI Program</title>" print "</head>" print "<body>" print "<h2> Entered Text Content is %s</h2>" % text_content print "</body>"通過CGI程序傳遞下拉數(shù)據(jù)
HTML下拉框代碼如下:
<form action="/cgi-bin/dropdown.py" method="post" target="_blank"> <select name="dropdown"> <option value="Maths" selected>Maths</option> <option value="Physics">Physics</option> </select> <input type="submit" value="Submit"/> </form>dropdown.py 腳本代碼如下所示:
#!/usr/bin/python # -*- coding: UTF-8 -*- ? # Import modules for CGI handling import cgi, cgitb ? # Create instance of FieldStorage form = cgi.FieldStorage() ? # Get data from fields if form.getvalue('dropdown'): ??subject = form.getvalue('dropdown') else: ?? subject = "Not entered" ? print "Content-type:text/html\r\n\r\n" print "<html>" print "<head>" print "<title>Dropdown Box - Sixth CGI Program</title>" print "</head>" print "<body>" print "<h2> Selected Subject is %s</h2>" % subject print "</body>" print "</html>"CGI中使用Cookie
在http協(xié)議一個很大的缺點就是不作用戶身份的判斷,這樣給編程人員帶來很大的不便,
而cookie功能的出現(xiàn)彌補了這個缺憾。
所有cookie就是在客戶訪問腳本的同時,通過客戶的瀏覽器,在客戶硬盤上寫入紀(jì)錄數(shù)據(jù) ,當(dāng)下次客戶訪問腳本時取回數(shù)據(jù)信息,從而達(dá)到身份判別的功能,cookie常用在密碼判斷中 。
cookie的語法
http cookie的發(fā)送是通過http頭部來實現(xiàn)的,他早于文件的傳遞,頭部set-cookie的語法如下:
Set-cookie:name=name;expires=date;path=path;domain=domain;secure- name=name: 需要設(shè)置cookie的值(name不能使用";"和","號),有多個name值時用";"分隔例如:name1=name1;name2=name2;name3=name3。
- expires=date: cookie的有效期限,格式: expires="Wdy,DD-Mon-YYYY HH:MM:SS"
- ?
- path=path: 設(shè)置cookie支持的路徑,如果path是一個路徑,則cookie對這個目錄下的所有文件及子目錄生效,例如: path="/cgi-bin/",如果path是一個文件,則cookie指對這個文件生效,例如:path="/cgi-bin /cookie.cgi"。
- domain=domain: 對cookie生效的域名,例如:domain="www.chinalb.com"
- secure: 如果給出此標(biāo)志,表示cookie只能通過SSL協(xié)議的https服務(wù)器來傳遞。
- cookie的接收是通過設(shè)置環(huán)境變量HTTP_COOKIE來實現(xiàn)的,CGI程序可以通過檢索該變量獲取cookie信息。
Cookie設(shè)置
Cookie的設(shè)置非常簡單,cookie會在http頭部單獨發(fā)送。以下實例在cookie中設(shè)置了UserID 和 Password:
<pre> #!/usr/bin/python # -*- coding: UTF-8 -*- ? print "Set-Cookie:UserID=XYZ;\r\n" print "Set-Cookie:Password=XYZ123;\r\n" print "Set-Cookie:Expires=Tuesday, 31-Dec-2007 23:12:40 GMT";\r\n" print "Set-Cookie:Domain=www.w3cschool.cc;\r\n" print "Set-Cookie:Path=/perl;\n" print "Content-type:text/html\r\n\r\n" ...........Rest of the HTML Content....以上實例使用了 Set-Cookie 頭信息來設(shè)置Cookie信息,可選項中設(shè)置了Cookie的其他屬性,如過期時間Expires,域名Domain,路徑Path。這些信息設(shè)置在 "Content-type:text/html\r\n\r\n"之前。
檢索Cookie信息
Cookie信息檢索頁非常簡單,Cookie信息存儲在CGI的環(huán)境變量HTTP_COOKIE中,存儲格式如下:
key1=value1;key2=value2;key3=value3....以下是一個簡單的CGI檢索cookie信息的程序:
#!/usr/bin/python # -*- coding: UTF-8 -*- ? # Import modules for CGI handling from os import environ import cgi, cgitb ? if environ.has_key('HTTP_COOKIE'): ?? for cookie in map(strip, split(environ['HTTP_COOKIE'], ';')): ????? (key, value ) = split(cookie, '='); ????? if key == "UserID": ???????? user_id = value ? ????? if key == "Password": ???????? password = value ? print "User ID? = %s" % user_id print "Password = %s" % password以上腳本輸出結(jié)果如下:
User ID = XYZ Password = XYZ123文件上傳實例:
HTML設(shè)置上傳文件的表單需要設(shè)置enctype 屬性為multipart/form-data,代碼如下所示:
<html> <body> ?? <form enctype="multipart/form-data" ?????????????????????action="save_file.py" method="post"> ?? <p>File: <input type="file" name="filename" /></p> ?? <p><input type="submit" value="Upload" /></p> ?? </form> </body> </html>save_file.py腳本文件代碼如下:
#!/usr/bin/python # -*- coding: UTF-8 -*- ? import cgi, os import cgitb; cgitb.enable() ? form = cgi.FieldStorage() ? # 獲取文件名 fileitem = form['filename'] ? # 檢測文件是否上傳 if fileitem.filename: ?? # 設(shè)置文件路徑 ???fn = os.path.basename(fileitem.filename) ?? open('/tmp/' + fn, 'wb').write(fileitem.file.read()) ? ?? message = 'The file "' + fn + '" was uploaded successfully' ?? else: ?? message = 'No file was uploaded' ?? print """\ Content-Type: text/html\n <html> <body> ?? <p>%s</p> </body> </html> """ % (message,)如果你使用的系統(tǒng)是Unix/Linux,你必須替換文件分隔符,在window下只需要使用open()語句即可:
fn = os.path.basename(fileitem.filename.replace("\\", "/" ))文件下載對話框
我們先在當(dāng)前目錄下創(chuàng)建 foo.txt 文件,用于程序的下載。
文件下載通過設(shè)置HTTP頭信息來實現(xiàn),功能代碼如下:
#!/usr/bin/python # -*- coding: UTF-8 -*- ? # HTTP 頭部 print "Content-Disposition: attachment; filename=\"foo.txt\"\r\n\n"; ? # 打開文件 fo = open("foo.txt", "rb") ? str = fo.read(); print str ? # 關(guān)閉文件 fo.close()?
?
python操作mysql數(shù)據(jù)庫
Python 標(biāo)準(zhǔn)數(shù)據(jù)庫接口為 Python DB-API,Python DB-API為開發(fā)人員提供了數(shù)據(jù)庫應(yīng)用編程接口。
Python 數(shù)據(jù)庫接口支持非常多的數(shù)據(jù)庫,你可以選擇適合你項目的數(shù)據(jù)庫:
- GadFly
- mSQL
- MySQL
- PostgreSQL
- Microsoft SQL Server 2000
- Informix
- Interbase
- Oracle
- Sybase
你可以訪問Python數(shù)據(jù)庫接口及API查看詳細(xì)的支持?jǐn)?shù)據(jù)庫列表。
不同的數(shù)據(jù)庫你需要下載不同的DB API模塊,例如你需要訪問Oracle數(shù)據(jù)庫和Mysql數(shù)據(jù),你需要下載Oracle和MySQL數(shù)據(jù)庫模塊。
DB-API 是一個規(guī)范. 它定義了一系列必須的對象和數(shù)據(jù)庫存取方式, 以便為各種各樣的底層數(shù)據(jù)庫系統(tǒng)和多種多樣的數(shù)據(jù)庫接口程序提供一致的訪問接口 。
Python的DB-API,為大多數(shù)的數(shù)據(jù)庫實現(xiàn)了接口,使用它連接各數(shù)據(jù)庫后,就可以用相同的方式操作各數(shù)據(jù)庫。
Python DB-API使用流程:
- 引入 API 模塊。
- 獲取與數(shù)據(jù)庫的連接。
- 執(zhí)行SQL語句和存儲過程。
- 關(guān)閉數(shù)據(jù)庫連接。
什么是MySQLdb?
MySQLdb 是用于Python鏈接Mysql數(shù)據(jù)庫的接口,它實現(xiàn)了 Python 數(shù)據(jù)庫 API 規(guī)范 V2.0,基于MySQL C API 上建立的。
如何安裝MySQLdb?
為了用DB-API編寫MySQL腳本,必須確保已經(jīng)安裝了MySQL。復(fù)制以下代碼,并執(zhí)行:
#!/usr/bin/python # -*- coding: UTF-8 -*- ? import MySQLdb如果執(zhí)行后的輸出結(jié)果如下所示,意味著你沒有安裝 MySQLdb 模塊:
Traceback (most recent call last): ? File "test.py", line 3, in <module> ??? import MySQLdb ImportError: No module named MySQLdb安裝MySQLdb,請訪問 http://sourceforge.net/projects/mysql-python,(Linux平臺可以訪問:https://pypi.python.org/pypi/MySQL-python)從這里可選擇適合您的平臺的安裝包,分為預(yù)編譯的二進(jìn)制文件和源代碼安裝包。
如果您選擇二進(jìn)制文件發(fā)行版本的話,安裝過程基本安裝提示即可完成。如果從源代碼進(jìn)行安裝的話,則需要切換到MySQLdb發(fā)行版本的頂級目錄,并鍵入下列命令:
$ gunzip MySQL-python-1.2.2.tar.gz $ tar -xvf MySQL-python-1.2.2.tar $ cd MySQL-python-1.2.2 $ python setup.py build $ python setup.py install注意:請確保您有root權(quán)限來安裝上述模塊。
數(shù)據(jù)庫連接
連接數(shù)據(jù)庫前,請先確認(rèn)以下事項:
- 您已經(jīng)創(chuàng)建了數(shù)據(jù)庫 TESTDB.
- 在TESTDB數(shù)據(jù)庫中您已經(jīng)創(chuàng)建了表 EMPLOYEE
- EMPLOYEE表字段為 FIRST_NAME, LAST_NAME, AGE, SEX 和 INCOME。
- 連接數(shù)據(jù)庫TESTDB使用的用戶名為 "testuser" ,密碼為 "test123",你可以可以自己設(shè)定或者直接使用root用戶名及其密碼,Mysql數(shù)據(jù)庫用戶授權(quán)請使用Grant命令。
- 在你的機子上已經(jīng)安裝了 Python MySQLdb 模塊。
- 如果您對sql語句不熟悉,可以訪問我們的 SQL基礎(chǔ)教程
實例:
以下實例鏈接Mysql的TESTDB數(shù)據(jù)庫:
#!/usr/bin/python # -*- coding: UTF-8 -*- ? import MySQLdb ? # 打開數(shù)據(jù)庫連接 db = MySQLdb.connect("localhost","testuser","test123","TESTDB" ) ? # 使用cursor()方法獲取操作游標(biāo) cursor = db.cursor() ? # 使用execute方法執(zhí)行SQL語句 cursor.execute("SELECT VERSION()") ? # 使用 fetchone() 方法獲取一條數(shù)據(jù)庫。 data = cursor.fetchone() ? print "Database version : %s " % data ? # 關(guān)閉數(shù)據(jù)庫連接 db.close()執(zhí)行以上腳本輸出結(jié)果如下:
Database version : 5.0.45創(chuàng)建數(shù)據(jù)庫表
如果數(shù)據(jù)庫連接存在我們可以使用execute()方法來為數(shù)據(jù)庫創(chuàng)建表,如下所示創(chuàng)建表EMPLOYEE:
#!/usr/bin/python # -*- coding: UTF-8 -*- ? import MySQLdb ? # 打開數(shù)據(jù)庫連接 db = MySQLdb.connect("localhost","testuser","test123","TESTDB" ) ? # 使用cursor()方法獲取操作游標(biāo) cursor = db.cursor() ? # 如果數(shù)據(jù)表已經(jīng)存在使用 execute() 方法刪除表。 cursor.execute("DROP TABLE IF EXISTS EMPLOYEE") ? # 創(chuàng)建數(shù)據(jù)表SQL語句 sql = """CREATE TABLE EMPLOYEE ( ???????? FIRST_NAME? CHAR(20) NOT NULL, ???????? LAST_NAME? CHAR(20), ???????? AGE INT,? ?????????SEX CHAR(1), ???????? INCOME FLOAT )""" ? cursor.execute(sql) ? # 關(guān)閉數(shù)據(jù)庫連接 db.close()數(shù)據(jù)庫插入操作
以下實例使用執(zhí)行 SQL INSERT 語句向表 EMPLOYEE 插入記錄:
#!/usr/bin/python # -*- coding: UTF-8 -*- ? import MySQLdb ? # 打開數(shù)據(jù)庫連接 db = MySQLdb.connect("localhost","testuser","test123","TESTDB" ) ? # 使用cursor()方法獲取操作游標(biāo) cursor = db.cursor() ? # SQL 插入語句 sql = """INSERT INTO EMPLOYEE(FIRST_NAME, ???????? LAST_NAME, AGE, SEX, INCOME) ???????? VALUES ('Mac', 'Mohan', 20, 'M', 2000)""" try: ?? # 執(zhí)行sql語句 ?? cursor.execute(sql) ?? # 提交到數(shù)據(jù)庫執(zhí)行 ?? db.commit() except: ?? # Rollback in case there is any error ?? db.rollback() ? # 關(guān)閉數(shù)據(jù)庫連接 db.close()以上例子也可以寫成如下形式:
#!/usr/bin/python # -*- coding: UTF-8 -*- ? import MySQLdb ? # 打開數(shù)據(jù)庫連接 db = MySQLdb.connect("localhost","testuser","test123","TESTDB" ) ? # 使用cursor()方法獲取操作游標(biāo) cursor = db.cursor() ? # SQL 插入語句 sql = "INSERT INTO EMPLOYEE(FIRST_NAME, \ ?????? LAST_NAME, AGE, SEX, INCOME) \ ?????? VALUES ('%s', '%s', '%d', '%c', '%d' )" % \ ?????? ('Mac', 'Mohan', 20, 'M', 2000) try: ?? # 執(zhí)行sql語句 ?? cursor.execute(sql) ?? # 提交到數(shù)據(jù)庫執(zhí)行 ?? db.commit() except: ?? # 發(fā)生錯誤時回滾 ?? db.rollback() ? # 關(guān)閉數(shù)據(jù)庫連接 db.close()實例:
以下代碼使用變量向SQL語句中傳遞參數(shù):
.................................. user_id = "test123" password = "password" ? con.execute('insert into Login values("%s", "%s")' % \ ???????????? (user_id, password)) ..................................數(shù)據(jù)庫查詢操作
Python查詢Mysql使用 fetchone() 方法獲取單條數(shù)據(jù), 使用fetchall() 方法獲取多條數(shù)據(jù)。
- fetchone(): 該方法獲取下一個查詢結(jié)果集。結(jié)果集是一個對象
- fetchall():接收全部的返回結(jié)果行.
- rowcount: 這是一個只讀屬性,并返回執(zhí)行execute()方法后影響的行數(shù)。
實例:
查詢EMPLOYEE表中salary(工資)字段大于1000的所有數(shù)據(jù):
#!/usr/bin/python # -*- coding: UTF-8 -*- ? import MySQLdb ? # 打開數(shù)據(jù)庫連接 db = MySQLdb.connect("localhost","testuser","test123","TESTDB" ) ? # 使用cursor()方法獲取操作游標(biāo) cursor = db.cursor() ? # SQL 查詢語句 sql = "SELECT * FROM EMPLOYEE \ ?????? WHERE INCOME > '%d'" % (1000) try: ?? # 執(zhí)行SQL語句 ?? cursor.execute(sql) ?? # 獲取所有記錄列表 ?? results = cursor.fetchall() ?? for row in results: ????? fname = row[0] ????? lname = row[1] ????? age = row[2] ????? sex = row[3] ??? ??income = row[4] ????? # 打印結(jié)果 ????? print "fname=%s,lname=%s,age=%d,sex=%s,income=%d" % \ ???????????? (fname, lname, age, sex, income ) except: ?? print "Error: unable to fecth data" ? # 關(guān)閉數(shù)據(jù)庫連接 db.close()以上腳本執(zhí)行結(jié)果如下:
fname=Mac, lname=Mohan, age=20, sex=M, income=2000數(shù)據(jù)庫更新操作
更新操作用于更新數(shù)據(jù)表的的數(shù)據(jù),以下實例將 TESTDB表中的 SEX字段全部修改為 'M',AGE 字段遞增1:
#!/usr/bin/python # -*- coding: UTF-8 -*- ? import MySQLdb ? # 打開數(shù)據(jù)庫連接 db = MySQLdb.connect("localhost","testuser","test123","TESTDB" ) ? # 使用cursor()方法獲取操作游標(biāo) cursor = db.cursor() ? # SQL 更新語句 sql = "UPDATE EMPLOYEE SET AGE = AGE + 1 ????????????????????????? WHERE SEX = '%c'" % ('M') try: ?? # 執(zhí)行SQL語句 ?? cursor.execute(sql) ?? # 提交到數(shù)據(jù)庫執(zhí)行 ?? db.commit() except: ?? # 發(fā)生錯誤時回滾 ?? db.rollback() ? # 關(guān)閉數(shù)據(jù)庫連接 db.close()執(zhí)行事務(wù)
事務(wù)機制可以確保數(shù)據(jù)一致性。
事務(wù)應(yīng)該具有4個屬性:原子性、一致性、隔離性、持久性。這四個屬性通常稱為ACID特性。
- 原子性(atomicity)。一個事務(wù)是一個不可分割的工作單位,事務(wù)中包括的諸操作要么都做,要么都不做。
- 一致性(consistency)。事務(wù)必須是使數(shù)據(jù)庫從一個一致性狀態(tài)變到另一個一致性狀態(tài)。一致性與原子性是密切相關(guān)的。
- 隔離性(isolation)。一個事務(wù)的執(zhí)行不能被其他事務(wù)干擾。即一個事務(wù)內(nèi)部的操作及使用的數(shù)據(jù)對并發(fā)的其他事務(wù)是隔離的,并發(fā)執(zhí)行的各個事務(wù)之間不能互相干擾。
- 持久性(durability)。持續(xù)性也稱永久性(permanence),指一個事務(wù)一旦提交,它對數(shù)據(jù)庫中數(shù)據(jù)的改變就應(yīng)該是永久性的。接下來的其他操作或故障不應(yīng)該對其有任何影響。
Python DB API 2.0 的事務(wù)提供了兩個方法 commit或 rollback。
實例:
# SQL刪除記錄語句 sql = "DELETE FROM EMPLOYEE WHERE AGE > '%d'" % (20) try: ?? # 執(zhí)行SQL語句 ?? cursor.execute(sql) ?? # 向數(shù)據(jù)庫提交 ?? db.commit() except: ?? # 發(fā)生錯誤時回滾 ?? db.rollback()對于支持事務(wù)的數(shù)據(jù)庫, 在Python數(shù)據(jù)庫編程中,當(dāng)游標(biāo)建立之時,就自動開始了一個隱形的數(shù)據(jù)庫事務(wù)。
commit()方法游標(biāo)的所有更新操作,rollback()方法回滾當(dāng)前游標(biāo)的所有操作。每一個方法都開始了一個新的事務(wù)。
錯誤處理
DB API中定義了一些數(shù)據(jù)庫操作的錯誤及異常,下表列出了這些錯誤和異常:
| 異常 | 描述 |
| Warning | 當(dāng)有嚴(yán)重警告時觸發(fā),例如插入數(shù)據(jù)是被截斷等等。必須是 StandardError 的子類。 |
| Error | 警告以外所有其他錯誤類。必須是 StandardError 的子類。 |
| InterfaceError | 當(dāng)有數(shù)據(jù)庫接口模塊本身的錯誤(而不是數(shù)據(jù)庫的錯誤)發(fā)生時觸發(fā)。 必須是Error的子類。 |
| DatabaseError | 和數(shù)據(jù)庫有關(guān)的錯誤發(fā)生時觸發(fā)。 必須是Error的子類。 |
| DataError | 當(dāng)有數(shù)據(jù)處理時的錯誤發(fā)生時觸發(fā),例如:除零錯誤,數(shù)據(jù)超范圍等等。 必須是DatabaseError的子類。 |
| OperationalError | 指非用戶控制的,而是操作數(shù)據(jù)庫時發(fā)生的錯誤。例如:連接意外斷開、 數(shù)據(jù)庫名未找到、事務(wù)處理失敗、內(nèi)存分配錯誤等等操作數(shù)據(jù)庫是發(fā)生的錯誤。 必須是DatabaseError的子類。 |
| IntegrityError | 完整性相關(guān)的錯誤,例如外鍵檢查失敗等。必須是DatabaseError子類。 |
| InternalError | 數(shù)據(jù)庫的內(nèi)部錯誤,例如游標(biāo)(cursor)失效了、事務(wù)同步失敗等等。 必須是DatabaseError子類。 |
| ProgrammingError | 程序錯誤,例如數(shù)據(jù)表(table)沒找到或已存在、SQL語句語法錯誤、 參數(shù)數(shù)量錯誤等等。必須是DatabaseError的子類。 |
| NotSupportedError | 不支持錯誤,指使用了數(shù)據(jù)庫不支持的函數(shù)或API等。例如在連接對象上 使用.rollback()函數(shù),然而數(shù)據(jù)庫并不支持事務(wù)或者事務(wù)已關(guān)閉。 必須是DatabaseError的子類。
出處:http://www.runoob.com/python/python-tutorial.html |
總結(jié)
以上是生活随笔為你收集整理的Python基础教程(十):CGI编程、MySQL数据库的全部內(nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: Python基础教程(九):面向对象、正
- 下一篇: Python基础教程(十一):多线程、X