當前位置:首頁 » 數據倉庫 » python資料庫編程實例
擴展閱讀
webinf下怎麼引入js 2023-08-31 21:54:13
堡壘機怎麼打開web 2023-08-31 21:54:11

python資料庫編程實例

發布時間: 2023-02-05 06:33:46

❶ python連接Mysql資料庫實例分析

python連接MySQL資料庫實例分析
本文實例講述了python連接MySQL資料庫的方法。分享給大家供大家參考。具體實現方法如下:
import MySQLdb
conn = MySQLdb.connect(host="localhost",
user="root",
passwd="123456",
db="test")
cursor = conn.cursor()
cursor.execute("select * from hard")
res = cursor.fetchall()
for x in res:
print x
cursor.close()
conn.close()
運行結果如下:
希望本文所述對大家的python程序設計有所幫助。

❷ 如何利用Python標准庫編程

第一步、根據自己的業務需求聲明一個繼承自Python標准庫的模塊
# 接收流量類,繼承自asyncore.dispatcher,class Receiver(asyncore.dispatcher):
def __init__(self,conn):
asyncore.dispatcher.__init__(self,conn)
self.from_remote_buffer='' # 接收數據的緩沖區
self.to_remote_buffer='' # 發送數據的緩存
self.sender=None1234567

第二步、根據文檔,重寫模塊中的方法,這些方法有些像生命周期中的事件,你可以通過在這些事件中自定義代碼,使得在特定時間點執行特定的代碼。
# 接收流量類,繼承自asyncore.dispatcher,class Receiver(asyncore.dispatcher):
def __init__(self,conn):
asyncore.dispatcher.__init__(self,conn)
self.from_remote_buffer='' # 接收數據的緩沖區
self.to_remote_buffer='' # 發送數據的緩存區
self.sender=None

# 當活動opener的套接字真正創建連接時被調用。也許發送一個「歡迎」字元串數據,或者比如,初始化一個遠程端點的協商協議。
def handle_connect(self):
pass

# 當非同步循環檢測到一個在信道套接字上的read()調用時會成功被調用。
def handle_read(self):
read = self.recv(BUFSIZE)
self.from_remote_buffer += read # 每次在非同步循環中被調用來決定是否一個信道的套接字應該被加到寫事件可以發生的列表中。 默認方法簡單地返回 True,顯然,所有的信道會關注於寫事件。
def writable(self):
return (len(self.to_remote_buffer) > 0) # 當非同步循環檢測到一個可寫入的的套接字可以被寫入時被調用。常用這個方法為了性能優化實現必要的緩存。
def handle_write(self):
sent = self.send(self.to_remote_buffer)
self.to_remote_buffer = self.to_remote_buffer[sent:] # 當套接字被關閉的時候調用
def handle_close(self):
self.close() if self.sender:
self.sender.close()

❸ 怎麼用python連接mysql資料庫

在 Python 語言環境下我們這樣連接資料庫。

In [1]: from mysql import connector

In [2]: cnx = connector.connect(host="172.16.192.100",port=3306,user="appuser",password="xxxxxx")

但是連接資料庫的背後發生了什麼呢?


答案

當我們通過驅動程序(mysql-connector-python,pymysql)連接 MySQL 服務端的時候,就是把連接參數傳遞給驅動程序,驅動程序再根據參數會發起到 MySQL 服務端的 TCP 連接。當 TCP 連接建立之後驅動程序與服務端之間會按特定的格式和次序交換數據包,數據包的格式和發送次序由MySQL 協議規定。MySQL 協議:https://dev.mysql.com/doc/internals/en/client-server-protocol.html整個連接的過程中 MySQL 服務端與驅動程序之間,按如下的次序發送了這些包。

  • MySQL 服務端向客戶端發送一個握手包,包里記錄了 MySQL-Server 的版本,默認的授權插件,密碼鹽值(auth-data)。

  • 2. MySQL 客戶端發出 ssl 連接請求包(如果有必要的話)。

    3. MySQL 客戶端發出握手包的響應包,這個包時記錄了用戶名,密碼加密後的串,客戶端屬性,等等其它信息。

    4. MySQL 服務端發出響應包,這個包里記錄了登錄是否成功,如果沒有成功也會給出錯誤信息。

❹ Python能做什麼,能夠開發什麼項目

Python是一種計算機程序設計語言。是一種面向對象的動態類型語言,最初被設計用於編寫自動化腳本(shell),隨著版本的不斷更新和語言新功能的添加,越來越多被用於獨立的、大型項目的開發。

Python是一種解釋型腳本語言,可以應用於Web 和 Internet開發、科學計算和統計、人工智慧、教育、桌面界面開發、軟體開發、後端開發這些領域。

Python的應用

1、系統編程

提供API(Application Programming Interface應用程序編程介面),能方便進行系統維護和管理,Linux下標志性語言之一,是很多系統管理員理想的編程工具。

2、圖形處理

有PIL、Tkinter等圖形庫支持,能方便進行圖形處理。

3、數學處理

NumPy擴展提供大量與許多標准數學庫的介面。

4、文本處理

python提供的re模塊能支持正則表達式,還提供SGML,XML分析模塊,許多程序員利用python進行XML程序的開發。


5、資料庫編程

程序員可通過遵循Python DB-API(資料庫應用程序編程介面)規范的模塊與Microsoft SQL Server,Oracle,Sybase,DB2,MySQL、SQLite等資料庫通信。python自帶有一個Gadfly模塊,提供了一個完整的SQL環境。

6、網路編程

提供豐富的模塊支持sockets編程,能方便快速地開發分布式應用程序。很多大規模軟體開發計劃例如Zope,Mnet 及BitTorrent. Google都在廣泛地使用它。

7、Web編程

應用的開發語言,支持最新的XML技術。

8、多媒體應用

Python的PyOpenGL模塊封裝了「OpenGL應用程序編程介面」,能進行二維和三維圖像處理。PyGame模塊可用於編寫游戲軟體。

9、pymo引擎

PYMO全稱為python memories off,是一款運行於Symbian S60V3,Symbian3,S60V5, Symbian3, Android系統上的AVG游戲引擎。因其基於python2.0平台開發,並且適用於創建秋之回憶(memories off)風格的AVG游戲,故命名為PYMO。

10、黑客編程

python有一個hack的庫,內置了你熟悉的或不熟悉的函數,但是缺少成就感。

❺ python編程例子有哪些

python編程經典例子:

1、畫愛心表白、圖形都是由一系列的點(X,Y)構成的曲線,由於X,Y滿足一定的關系,所以就可以建立模型,建立表達式expression,當滿足時,兩個for循環(for X in range;for Y in range)就會每行每列的列印。

(5)python資料庫編程實例擴展閱讀:

Python的設計目標之一是讓代碼具備高度的可閱讀性。它設計時盡量使用其它語言經常使用的標點符號和英文單字,讓代碼看起來整潔美觀。它不像其他的靜態語言如C、Pascal那樣需要重復書寫聲明語句,也不像它們的語法那樣經常有特殊情況和意外。

Python開發者有意讓違反了縮進規則的程序不能通過編譯,以此來強製程序員養成良好的編程習慣。並且Python語言利用縮進表示語句塊的開始和退出,而非使用花括弧或者某種關鍵字。增加縮進表示語句塊的開始,而減少縮進則表示語句塊的退出,縮進成為了語法的一部分。

❻ 急!!用python連接資料庫

settings.py
if DEBUG:
DATABASES = {
'default': {
'ENGINE': 'mysql', # Add 'postgresql_psycopg2', 'postgresql', 'mysql', 'sqlite3' or 'oracle'.
'NAME': '庫名', # Or path to database file if using sqlite3.
'USER': 'root', # Not used with sqlite3.
'PASSWORD': '', # Not used with sqlite3.
'HOST': '', # Set to empty string for localhost. Not used with sqlite3.
'PORT': '3306', # Set to empty string for default. Not used with sqlite3.
},
'庫名': {
'ENGINE': 'mysql', # Add 'postgresql_psycopg2', 'postgresql', 'mysql', 'sqlite3' or 'oracle'.
'NAME': '庫名', # Or path to database file if using sqlite3.
'USER': 'root', # Not used with sqlite3.
'PASSWORD': '', # Not used with sqlite3.
'HOST': '', # Set to empty string for localhost. Not used with sqlite3.
'PORT': '3306', # Set to empty string for default. Not used with sqlite3.
}
}

❼ python輸入某年某月某日計算到年底還有多少天

year = int(input("請輸入年份:"))
month = int(input("請輸入月份:"))
day = int(input("請輸入日期:"))

months = [0,31,59,90,120,151,181,212,243,273,304] # months累加記錄1-11月的總天數

if 0 < month < 12: # 假設為非閏年時,當前日期的天數
sum = months[month - 1] + day

flag = 0
if (year % 4 == 0 and year % 100 != 0) or (year % 400 == 0): # 判斷是否為閏年,如果為閏年flag = 1
flag = 1

if flag == 1 and month > 2: # 年份為閏年且月份大於2
sum += 1

print("%d.%d.%d 是 %d 年的第 %d 天" % (year,month,day,year,sum))
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
輸入年月日,判斷今年還剩多少天
此程序和上一個程序其實大同小異,只需要知道今年總天數,然後:
今年剩餘多少天 = 總天數 - 今天是今年的多少天
你就說簡不簡單?

year = int(input("請輸入年份:"))
month = int(input("請輸入月份:"))
day = int(input("請輸入日期:"))

days = 365
months = [0,31,59,90,120,151,181,212,243,273,304]

if 0 < month < 12:
sum = months[month - 1] + day

flag = 0
if (year % 4 == 0 and year % 100 != 0) or (year % 400 == 0):
flag = 1
days += 1

if flag == 1 and month > 2:
sum += 1

surplus_day = days - sum

print("今天是:%d.%d.%d,今年還剩 %d 天" % (year,month,day,surplus_day))
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
兩個程序可以綜合起來,具體步驟就不詳細說明了!!!

加油!O(∩_∩)O

文章知識點與官方知識檔案匹配
Python入門技能樹首頁概覽
200575 人正在系統學習中
打開CSDN,閱讀體驗更佳

《學習記錄》「Python」輸入月份,輸出天數
輸入一個月份,首先判斷是否為1-12,然後判斷返回該月份的天數。
繼續訪問

python計算今年第幾天_Python三種方法計算指定日期是今年的第幾天
今天早上和騰訊面試官進行了視頻面試,由於音量和網路以及我的垃圾電腦的原因,個人感覺黃了...最後面試官給了我一道簡單的計算題:指定日期是今年的第幾年由於電腦卡到打字都打不動,我勉勉強強寫了一點,雖然面試官知道了我的想法也了解我的設備情況,最後沒讓我寫完但是心裡慚愧還是時候補齊了...話不多說回到主題吧首先是輸入的問題,個人認為分別輸入年月份是一件很初級的要求,就實現了形如「2020-3-26」的字...
繼續訪問
python春節_python計算春節倒計時
先來無聊,想知道今年的春節還有幾天,好久沒寫python代碼了,下面就隨便寫了一個,如有不對之處,還請各位看官不靈賜教,好了,我直接上代碼了:#coding=utf-8#!/usr/bin/env pythonimport datetimespring=datetime.datetime(2014,1,31,0,0,0) #春節日期today=datetime.datetime.now() ...
繼續訪問
python代碼實現「今天是今年的第幾天」
python代碼實現「今天是今年的第幾天」 ** #代碼如下: list_day_runnian = [0,31,29,31,30,31,30,31,31,30,31,30,31] year = int(input(『輸入年份:』)) month = int(input(『輸入月份:』)) day = int(input(『輸入日期:』)) if 1<= month <=12: if (year%400==0)or((year%4 == 0 )and (year%100!=0)): pastmo
繼續訪問
Python 根據輸入的年月日判斷今天是今年的第多少天
year = int(input("請輸入年份:")) month = int(input("請輸入月份:")) day = int(input("請輸入日期:")) sum_day = 0 months=[31,28,31,30,31,30,31,31,30,31,30,31] # 判斷幾月份 然後加到變數里,開頭是0的就不用了 for i in range(month-1): sum_day += months[i] sum_day += day #判斷二月 leap = 0 if (year
繼續訪問
python實現輸入日期判斷這一天是今年多少天
這里寫自定義目錄標題新的改變功能快捷鍵合理的創建標題,有助於目錄的生成如何改變文本的樣式插入鏈接與圖片如何插入一段漂亮的代碼片生成一個適合你的列表創建一個表格設定內容居中、居左、居右SmartyPants創建一個自定義列表如何創建一個注腳注釋也是必不可少的KaTeX數學公式新的甘特圖功能,豐富你的文章UML 圖表FLowchart流程圖導出與導入導出導入 整體思路: 1、輸入日期 2、判斷輸入的日期是否合法 3、計算輸入的日期天數 你好! 這是你第一次使用 Markdown編輯器 所展示的歡迎頁。如果你想學
繼續訪問
用python解:輸入某年某月某日,判斷這一天是這一年的第幾天?
用python解:輸入某年某月某日,判斷這一天是這一年的第幾天?
繼續訪問
熱門推薦 c語言:鍵盤輸入年月日,計算這一天是這一年的第幾天
比如輸入20201010,計算10號這一天是2020年的第幾天首先要考慮這一年是平年還是閏年,其次考慮所有的月份有多少天,最後是考慮怎麼去把所有的天數加在一起。平年的二月份有28天,閏年的二月有29天,所以要判斷這一年是平年還是閏年;而判斷是不是閏年的標准就是這一年除以400能除盡或者這一年除以4和除以100都能除盡,即year%4==0 && year%100!=0 || year%400==...
繼續訪問
python練習題:輸入某年某月某日,判斷這一天是這一年的第幾天?
python練習題
繼續訪問
python輸入年月日,得出已經過了多少天?
# -*- coding: UTF-8 -*- import time def What_day_of_the_year(inputTime): #函數,判斷字元串是否為數字 def is_number(s): try: float(s) return True except ValueError: pass try: import unicodedat
繼續訪問
用python解決題目:輸入某年某月某日,判斷這一天是這一年的第幾天?
一.思路 year = int(input("請輸入年:\n"))#用int()將字元型變數改為整形,以便之後的運算 month = int(input("請輸入月:\n")) day = int(input("請輸入日:\n")) months1 = [0,31,60,91,121,152,182,213,244,274,305,335,366]#閏年 months2 = [0,31,59,90...
繼續訪問
python這天第幾天_Python編程實現輸入某年某月某日計算出這一天是該年第幾天的方法...
此文實例介紹了Python編程實現輸入某年某月某日計算出這一天是該年第幾天的方法。推薦給大夥學習一下,內容如下:#基於 Python3一種做法:def is_leap_year(year): # 判斷閏年,是則返回True,否則返回Falseif (year % 4 == 0 and year % 100 != 0) or year % 400 == 0:return Trueelse:retur...
繼續訪問
python小程序(3)輸入某年某月某日,計算這一天是這一年的第幾天
思路 先判斷是閏年還是平年,再調用相應函數 計算每個月多少天,然後加上前幾個月的所有天數和這個月的天數 import sys #輸入某年某月某日,計算這一天是這一年的第幾天 while True: year=int(input('Year:')) mon=int(input('Month:')) day=int(input('Day:')) if ye...
繼續訪問
C語言實現計算某一天是當年的第幾天,並計算出一年的剩餘天數
這段代碼的實現是很簡單的,用的就是判斷後累加的方法實現的,原理是很簡單的。 第幾天的計算:比如計算的是11月,先將前十個月的天數計算並相加起來,除了二月的天數閏年會有所不同外,其他的都是一樣的,其次就是將輸入的天數加上就可以了。 剩餘多少天的計算:先將輸入進去的這一年的總天數計算出來,再減去上面計算出的第幾天就可以了。 這道題其實主要考的還是閏年的相關計算方法, 判斷任意年份是否為閏年,需要滿足以下條件中的任意一個: ① 該年份能被 4 整除同時不能被 100 整除; ② 該年份能被400整除。
繼續訪問
最新發布 C語言實現輸入某年某月某日,判斷這一天是這一年的第幾天,並輸出今年還剩下多少天?
C語言輸入某年某月某日,判斷這一天是這一年的第幾天,並輸出今年還剩下多少天。
繼續訪問
python 編程實現輸入某年某月某日,輸出它是這一年的第幾天
問題:python 編程實現輸入某年某月某日,輸出它是這一年的第幾天? 解題思路: 1、判斷該年份是閏年還是平年,用 if 分支計算。 2、不同月份的計算:大月,小月,二月,考慮用while循環。 一月 天數=某日 二月 天數=某日+31 三月 天數=某日+31+二月 四月 天數=某日+31+二月+31 五月 天數=某日+31+二月+31+30 ...... def a_1(a, b, c): i=1 #「輸入月份」之前的月份(因為...
繼續訪問

python輸入兩個數,分別代表年份和月份,計算這個月的天數
python輸入兩個數,分別代表年份和月份,計算這個月的天數
繼續訪問
Python實現用戶輸入年月日,程序列印出這是這一年的第多少天
1. 自己造輪子 year=int(input('請輸入年份,如2019>>>')) month=int(input('請輸入月份,如8>>>')) day=int(input('請輸入日期,如25>>>')) #下面這塊代碼是按照閏年計算 if (year%4==0 and year%100!=0) or (year%400==0): ...
繼續訪問
python獲取年末,月末,季末的日期和距指定時間的天數
我們在python日常使用中經常會用到時間的各種計算,這個也是讓人頭疼的地方,下面的方法實現了 年末,月末,季末的日期和距指定時間的天數的計算,要的拿去。自己也做個筆記。後面直接用。 def last_day(any_day): """ 獲取獲得一個月未,季末,年未的天數 的最後一天 :param any_day: 任意日期 :return: <class 'datetime.date'年,月,季末的日期,距年末,月末,季末的天數 """ next_mo
繼續訪問
用days函數算出第幾天c語言,給出年月日 計算該日是該年的第幾天
給出年月日 計算該日是該年的第幾天C語言#include int main(){int sum_day(int month,int day);int leap(int year);int year,month,day,days;printf("input date(year,month,day):");scanf("%d,%d,%d",&year,&month,&day);...
繼續訪問

資料庫課程設計
c語言文件讀寫操作代碼
html+css+js網頁設計
寫評論

1

11

1


❽ 如何用python寫sql

python可以利用pymysql模塊操作資料庫。

什麼是 PyMySQL?

PyMySQL 是在 Python3.x 版本中用於連接 MySQL 伺服器的一個庫,Python2中則使用mysqldb。

PyMySQL 遵循 Python 資料庫 API v2.0 規范,並包含了 pure-Python MySQL 客戶端庫。

PyMySQL 安裝

在使用 PyMySQL 之前,我們需要確保 PyMySQL 已安裝。

PyMySQL 下載地址:https://github.com/PyMySQL/PyMySQL。

如果還未安裝,我們可以使用以下命令安裝最新版的 PyMySQL:

$ pip3 install PyMySQL

如果你的系統不支持 pip 命令,可以使用以下方式安裝:

1、使用 git 命令下載安裝包安裝(你也可以手動下載):

$ git clone https://github.com/PyMySQL/PyMySQL$ cd PyMySQL/$ python3 setup.py install

2、如果需要制定版本號,可以使用 curl 命令來安裝:

$ # X.X 為 PyMySQL 的版本號$ curl -L https://github.com/PyMySQL/PyMySQL/tarball/pymysql-X.X | tar xz$ cd PyMySQL*$ python3 setup.py install
$ # 現在你可以刪除 PyMySQL* 目錄

注意:請確保您有root許可權來安裝上述模塊。

安裝的過程中可能會出現"ImportError: No mole named setuptools"的錯誤提示,意思是你沒有安裝setuptools,你可以訪問https://pypi.python.org/pypi/setuptools找到各個系統的安裝方法。

Linux 系統安裝實例:

$ wget https://bootstrap.pypa.io/ez_setup.py$ python3 ez_setup.py

資料庫連接

連接資料庫前,請先確認以下事項:

  • 您已經創建了資料庫 TESTDB.

  • 在TESTDB資料庫中您已經創建了表 EMPLOYEE

  • EMPLOYEE表欄位為 FIRST_NAME, LAST_NAME, AGE, SEX 和 INCOME。

  • 連接資料庫TESTDB使用的用戶名為 "testuser" ,密碼為 "test123",你可以可以自己設定或者直接使用root用戶名及其密碼,Mysql資料庫用戶授權請使用Grant命令。

  • 在你的機子上已經安裝了 Python MySQLdb 模塊。

  • 如果您對sql語句不熟悉,可以訪問我們的SQL基礎教程

  • 實例:

    以下實例鏈接 Mysql 的 TESTDB 資料庫:

    實例(Python 3.0+)

    #!/usr/bin/python3
    import pymysql
    # 打開資料庫連接db = pymysql.connect("localhost","testuser","test123","TESTDB" )
    # 使用 cursor() 方法創建一個游標對象 cursorcursor = db.cursor()
    # 使用 execute() 方法執行 SQL 查詢 cursor.execute("SELECT VERSION()")
    # 使用 fetchone() 方法獲取單條數據.data = cursor.fetchone()
    print ("Database version : %s " % data)
    # 關閉資料庫連接db.close()

    執行以上腳本輸出結果如下:

  • Database version : 5.5.20-log

  • 創建資料庫表

    如果資料庫連接存在我們可以使用execute()方法來為資料庫創建表,如下所示創建表EMPLOYEE:

    實例(Python 3.0+)

    #!/usr/bin/python3
    import pymysql
    # 打開資料庫連接db = pymysql.connect("localhost","testuser","test123","TESTDB" )
    # 使用 cursor() 方法創建一個游標對象 cursorcursor = db.cursor()
    # 使用 execute() 方法執行 SQL,如果表存在則刪除cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")
    # 使用預處理語句創建表sql = """CREATE TABLE EMPLOYEE (
    FIRST_NAME CHAR(20) NOT NULL,
    LAST_NAME CHAR(20),
    AGE INT,
    SEX CHAR(1),
    INCOME FLOAT )"""
    cursor.execute(sql)
    # 關閉資料庫連接db.close()

    資料庫插入操作

    以下實例使用執行 SQL INSERT 語句向表 EMPLOYEE 插入記錄:

    實例(Python 3.0+)

    #!/usr/bin/python3
    import pymysql
    # 打開資料庫連接db = pymysql.connect("localhost","testuser","test123","TESTDB" )
    # 使用cursor()方法獲取操作游標 cursor = db.cursor()
    # SQL 插入語句sql = """INSERT INTO EMPLOYEE(FIRST_NAME,
    LAST_NAME, AGE, SEX, INCOME)
    VALUES ('Mac', 'Mohan', 20, 'M', 2000)"""try: # 執行sql語句
    cursor.execute(sql)
    # 提交到資料庫執行
    db.commit()except: # 如果發生錯誤則回滾
    db.rollback()
    # 關閉資料庫連接db.close()

    以上例子也可以寫成如下形式:

    實例(Python 3.0+)

    #!/usr/bin/python3
    import pymysql
    # 打開資料庫連接db = pymysql.connect("localhost","testuser","test123","TESTDB" )
    # 使用cursor()方法獲取操作游標 cursor = db.cursor()
    # SQL 插入語句sql = "INSERT INTO EMPLOYEE(FIRST_NAME,
    LAST_NAME, AGE, SEX, INCOME)
    VALUES ('%s', '%s', %s, '%s', %s)" % ('Mac', 'Mohan', 20, 'M', 2000)try: # 執行sql語句
    cursor.execute(sql)
    # 執行sql語句
    db.commit()except: # 發生錯誤時回滾
    db.rollback()
    # 關閉資料庫連接db.close()

    以下代碼使用變數向SQL語句中傳遞參數:

  • ..................................user_id = "test123"password = "password"con.execute('insert into Login values( %s, %s)' % (user_id, password))..................................

  • 資料庫查詢操作

    Python查詢Mysql使用 fetchone() 方法獲取單條數據, 使用fetchall() 方法獲取多條數據。

  • fetchone():該方法獲取下一個查詢結果集。結果集是一個對象

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

  • rowcount:這是一個只讀屬性,並返回執行execute()方法後影響的行數。

  • 實例:

    查詢EMPLOYEE表中salary(工資)欄位大於1000的所有數據:

    實例(Python 3.0+)

    #!/usr/bin/python3
    import pymysql
    # 打開資料庫連接db = pymysql.connect("localhost","testuser","test123","TESTDB" )
    # 使用cursor()方法獲取操作游標 cursor = db.cursor()
    # SQL 查詢語句sql = "SELECT * FROM EMPLOYEE
    WHERE INCOME > %s" % (1000)try: # 執行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]
    # 列印結果
    print ("fname=%s,lname=%s,age=%s,sex=%s,income=%s" % (fname, lname, age, sex, income ))except: print ("Error: unable to fetch data")
    # 關閉資料庫連接db.close()

    以上腳本執行結果如下:

  • fname=Mac, lname=Mohan, age=20, sex=M, income=2000

  • 資料庫更新操作

    更新操作用於更新數據表的的數據,以下實例將 TESTDB 表中 SEX 為 'M' 的 AGE 欄位遞增 1:

    實例(Python 3.0+)

    #!/usr/bin/python3
    import pymysql
    # 打開資料庫連接db = pymysql.connect("localhost","testuser","test123","TESTDB" )
    # 使用cursor()方法獲取操作游標 cursor = db.cursor()
    # SQL 更新語句sql = "UPDATE EMPLOYEE SET AGE = AGE + 1 WHERE SEX = '%c'" % ('M')try: # 執行SQL語句
    cursor.execute(sql)
    # 提交到資料庫執行
    db.commit()except: # 發生錯誤時回滾
    db.rollback()
    # 關閉資料庫連接db.close()

    刪除操作

    刪除操作用於刪除數據表中的數據,以下實例演示了刪除數據表 EMPLOYEE 中 AGE 大於 20 的所有數據:

    實例(Python 3.0+)

    #!/usr/bin/python3
    import pymysql
    # 打開資料庫連接db = pymysql.connect("localhost","testuser","test123","TESTDB" )
    # 使用cursor()方法獲取操作游標 cursor = db.cursor()
    # SQL 刪除語句sql = "DELETE FROM EMPLOYEE WHERE AGE > %s" % (20)try: # 執行SQL語句
    cursor.execute(sql)
    # 提交修改
    db.commit()except: # 發生錯誤時回滾
    db.rollback()
    # 關閉連接db.close()

    執行事務

    事務機制可以確保數據一致性。

    事務應該具有4個屬性:原子性、一致性、隔離性、持久性。這四個屬性通常稱為ACID特性。

  • 原子性(atomicity)。一個事務是一個不可分割的工作單位,事務中包括的諸操作要麼都做,要麼都不做。

  • 一致性(consistency)。事務必須是使資料庫從一個一致性狀態變到另一個一致性狀態。一致性與原子性是密切相關的。

  • 隔離性(isolation)。一個事務的執行不能被其他事務干擾。即一個事務內部的操作及使用的數據對並發的其他事務是隔離的,並發執行的各個事務之間不能互相干擾。

  • 持久性(rability)。持續性也稱永久性(permanence),指一個事務一旦提交,它對資料庫中數據的改變就應該是永久性的。接下來的其他操作或故障不應該對其有任何影響。

  • Python DB API 2.0 的事務提供了兩個方法 commit 或 rollback。

    實例

    實例(Python 3.0+)

    # SQL刪除記錄語句sql = "DELETE FROM EMPLOYEE WHERE AGE > %s" % (20)try: # 執行SQL語句
    cursor.execute(sql)
    # 向資料庫提交
    db.commit()except: # 發生錯誤時回滾
    db.rollback()

    對於支持事務的資料庫, 在Python資料庫編程中,當游標建立之時,就自動開始了一個隱形的資料庫事務。

    commit()方法游標的所有更新操作,rollback()方法回滾當前游標的所有操作。每一個方法都開始了一個新的事務。

    錯誤處理

    DB API中定義了一些資料庫操作的錯誤及異常,下表列出了這些錯誤和異常:

    異常

    描述

    Warning 當有嚴重警告時觸發,例如插入數據是被截斷等等。必須是 StandardError 的子類。

    Error 警告以外所有其他錯誤類。必須是 StandardError 的子類。

    InterfaceError 當有資料庫介面模塊本身的錯誤(而不是資料庫的錯誤)發生時觸發。 必須是Error的子類。

    DatabaseError 和資料庫有關的錯誤發生時觸發。 必須是Error的子類。

    DataError 當有數據處理時的錯誤發生時觸發,例如:除零錯誤,數據超范圍等等。 必須是DatabaseError的子類。

    OperationalError 指非用戶控制的,而是操作資料庫時發生的錯誤。例如:連接意外斷開、 資料庫名未找到、事務處理失敗、內存分配錯誤等等操作資料庫是發生的錯誤。 必須是DatabaseError的子類。

    IntegrityError 完整性相關的錯誤,例如外鍵檢查失敗等。必須是DatabaseError子類。

    InternalError 資料庫的內部錯誤,例如游標(cursor)失效了、事務同步失敗等等。 必須是DatabaseError子類。

    ProgrammingError 程序錯誤,例如數據表(table)沒找到或已存在、SQL語句語法錯誤、 參數數量錯誤等等。必須是DatabaseError的子類。

    NotSupportedError 不支持錯誤,指使用了資料庫不支持的函數或API等。例如在連接對象上 使用.rollback()函數,然而資料庫並不支持事務或者事務已關閉。 必須是DatabaseError的子類。

❾ 後端編程Python3-資料庫編程

對大多數軟體開發者而言,術語資料庫通常是指RDBMS(關系資料庫管理系統), 這些系統使用表格(類似於電子表格的網格),其中行表示記錄,列表示記錄的欄位。表格及其中存放的數據是使用SQL (結構化査詢語言)編寫的語句來創建並操縱的。Python提供了用於操縱SQL資料庫的API(應用程序介面),通常與作為標準的SQLite 3資料庫一起發布。

另一種資料庫是DBM (資料庫管理器),其中存放任意數量的鍵-值項。Python 的標准庫提供了幾種DBM的介面,包括某些特定於UNIX平台的。DBM的工作方式 與Python中的字典類似,區別在於DBM通常存放於磁碟上而不是內存中,並且其鍵與值總是bytes對象,並可能受到長度限制。本章第一節中講解的shelve模塊提供了方便的DBM介面,允許我們使用字元串作為鍵,使用任意(picklable)對象作為值。

如果可用的 DBM 與 SQLite 資料庫不夠充分,Python Package Index, pypi.python.org/pypi中提供了大量資料庫相關的包,包括bsddb DBM ("Berkeley DB"),對象-關系映射器,比如SQLAlchemy (www.sqlalchemy.org),以及流行的客戶端/伺服器數據的介面,比如 DB2、Informix、Ingres、MySQL、ODBC 以及 PostgreSQL。

本章中,我們將實現某程序的兩個版本,該程序用於維護一個DVD列表,並追蹤每個DVD的標題、發行年份、時間長度以及發行者。該程序的第一版使用DBM (通過shelve模塊)存放其數據,第二版則使用SQLite資料庫。兩個程序都可以載入與保存簡單的XML格式,這使得從某個程序導出DVD數據並將其導入到其他程序成為可能。與DBM版相比,基於SQL的程序提供了更多一些的功能,並且其數據設計也稍干凈一些。

12.1 DBM資料庫

shelve模塊為DBM提供了一個wrapper,藉助於此,我們在與DBM交互時,可以將其看做一個字典,這里是假定我們只使用字元串鍵與picklable值,實際處理時, shelve模塊會將鍵與值轉換為bytes對象(或者反過來)。

由於shelve模塊使用的是底層的DBM,因此,如果其他計算機上沒有同樣的DBM,那麼在某台計算機上保存的DBM文件在其他機器上無法讀取是可能的。為解決這一問題,常見的解決方案是對那些必須在機器之間可傳輸的文件提供XML導入與導出功能,這也是我們在本節的DVD程序dvds-dbm.py中所做的。

對鍵,我們使用DVD的標題;對值,則使用元組,其中存放發行者、發行年份以及時間。藉助於shelve模塊,我們不需要進行任何數據轉換,並可以把DBM對象當做一個字典進行處理。

程序在結構上類似於我們前面看到的那種菜單驅動型的程序,因此,這里主要展示的是與DBM程序設計相關的那部分。下面給出的是程序main()函數中的一部分, 忽略了其中菜單處理的部分代碼。

db = None

try:

db = shelve.open(filename, protocol=pickle.HIGHEST_PROTOCOL)

finally:

if db is not None:

db.dose()

這里我們已打開(如果不存在就創建)指定的DBM文件,以便於對其進行讀寫操作。每一項的值使用指定的pickle協議保存為一個pickle,現有的項可以被讀取, 即便是使用更底層的協議保存的,因為Python可以計算出用於讀取pickle的正確協議。最後,DBM被關閉——其作用是清除DBM的內部緩存,並確保磁碟文件可以反映出已作的任何改變,此外,文件也需要關閉。

該程序提供了用於添加、編輯、列出、移除、導入、導出DVD數據的相應選項。除添加外,我們將忽略大部分用戶介面代碼,同樣是因為已經在其他上下文中進行了展示。

def add_dvd(db):

title = Console.get_string("Title", "title")

if not title:

return

director = Console.get_string("Director", "director")

if not director:

return

year = Console.get_integer("Year", "year",minimum=1896,

maximum=datetime,date.today().year)

ration = Console.get_integer("Duration (minutes)", "minutes「, minimum=0, maximum=60*48)

db[title] = (director, year, ration)

db.sync()

像程序菜單調用的所有函數一樣,這一函數也以DBM對象(db)作為其唯一參數。該函數的大部分工作都是獲取DVD的詳細資料,在倒數第二行,我們將鍵-值項存儲在DBM文件中,DVD的標題作為鍵,發行者、年份以及時間(由shelve模塊pickled在一起)作為值。

為與Python通常的一致性同步,DBM提供了與字典一樣的API,因此,除了 shelve.open() 函數(前面已展示)與shelve.Shelf.sync()方法(該方法用於清除shelve的內部緩存,並對磁碟上文件的數據與所做的改變進行同步——這里就是添加一個新項),我們不需要學習任何新語法。

def edit_dvd(db):

old_title = find_dvd(db, "edit")

if old_title is None:

return

title = Console.get.string("Title", "title", old_title)

if not title:

return

director, year, ration = db[old_title]

...

db[title]= (director, year, ration)

if title != old_title:

del db[old_title]

db.sync()

為對某個DVD進行編輯,用戶必須首先選擇要操作的DVD,也就是獲取DVD 的標題,因為標題用作鍵,值則用於存放其他相關數據。由於必要的功能在其他場合 (比如移除DVD)也需要使用,因此我們將其實現在一個單獨的find_dvd()函數中,稍後將査看該函數。如果找到了該DVD,我們就獲取用戶所做的改變,並使用現有值作為默認值,以便提高交互的速度。(對於這一函數,我們忽略了大部分用戶介面代碼, 因為其與添加DVD時幾乎是相同的。)最後,我們保存數據,就像添加時所做的一樣。如果標題未作改變,就重寫相關聯的值;如果標題已改變,就創建一個新的鍵-值對, 並且需要刪除原始項。

def find_dvd(db, message):

message = "(Start of) title to " + message

while True:

matches =[]

start = Console.get_string(message, "title")

if not start:

return None

for title in db:

if title.lower().startswith(start.lower()):

matches.append(title)

if len(matches) == 0:

print("There are no dvds starting with", start)

continue

elif len(matches) == 1:

return matches[0]

elif len(matches) > DISPLAY_LIMIT:

print("Too many dvds start with {0}; try entering more of the title".format(start)

continue

else:

matches = sorted(matches, key=str.lower)

for i, match in enumerate(matches):

print("{0}: {1}".format(i+1, match))

which = Console.get_integer("Number (or 0 to cancel)",

"number", minimum=1, maximum=len(matches))

return matches[which - 1] if which != 0 else None

為盡可能快而容易地發現某個DVD,我們需要用戶只輸入其標題的一個或頭幾個字元。在具備了標題的起始字元後,我們在DBM中迭代並創建一個匹配列表。如果只有一個匹配項,就返回該項;如果有幾個匹配項(但少於DISPLAY_LIMIT, 一個在程序中其他地方設置的整數),就以大小寫不敏感的順序展示所有這些匹配項,並為每一項設置一個編號,以便用戶可以只輸入編號就可以選擇某個標題。(Console.get_integer()函數可以接受0,即便最小值大於0,以便0可以用作一個刪除值。通過使用參數allow_zero=False, 可以禁止這種行為。我們不能使用Enter鍵,也就是說,沒有什麼意味著取消,因為什麼也不輸入意味著接受默認值。)

def list_dvds(db):

start =」"

if len(db)> DISPLAY.LIMIT:

start = Console.get_string(「List those starting with [Enter=all]」, "start」)

print()

for title in sorted(db, key=str.lower):

if not start or title.Iower().startswith(start.lower()):

director, year, ration = db[title]

print("{title} ({year}) {ration} minute{0}, by "

"{director}".format(Util.s(ration),**locals()))

列出所有DVD (或者那些標題以某個子字元串引導)就是對DBM的所有項進行迭代。

Util.s()函數就是簡單的s = lambda x: "" if x == 1 else "s",因此,如果時間長度不是1分鍾,就返回"s"。

def remove_dvd(db):

title = find_dvd(db, "remove")

if title is None:

return

ans = Console.get_bool("Remove {0}?".format(title), "no")

if ans:

del db[title]

db.sync()

要移除一個DVD,首先需要找到用戶要移除的DVD,並請求確認,獲取後從DBM中刪除該項即可。

到這里,我們展示了如何使用shelve模塊打開(或創建)一個DBM文件,以及如何向其中添加項、編輯項、對其項進行迭代以及移除某個項。

遺憾的是,在我們的數據設計中存在一個瑕疵。發行者名稱是重復的,這很容易導致不一致性,比如,發行者Danny DeVito可能被輸入為"Danny De Vito",用於 一個電影;也可以輸入為「Danny deVito",用於另一個。為解決這一問題,可以使用兩個DBM文件,主DVD文件使用標題鍵與(年份,時間長度,發行者ID)值; 發行者文件使用發行者ID (整數)鍵與發行者名稱值。下一節展示的SQL資料庫 版程序將避免這一瑕疵,這是通過使用兩個表格實現的,一個用於DVD,另一個用於發行者。

12.2 SQL資料庫

大多數流行的SQL資料庫的介面在第三方模塊中是可用的,Python帶有sqlite3 模塊(以及SQLite 3資料庫),因此,在Python中,可以直接開始資料庫程序設計。SQLite是一個輕量級的SQL資料庫,缺少很多諸如PostgreSQL這種資料庫的功能, 但非常便於構造原型系統,並且在很多情況下也是夠用的。

為使後台資料庫之間的切換盡可能容易,PEP 249 (Python Database API Specification v2.0)提供了稱為DB-API 2.0的API規范。資料庫介面應該遵循這一規范,比如sqlite3模塊就遵循這一規范,但不是所有第三方模塊都遵循。API規范中指定了兩種主要的對象,即連接對象與游標對象。表12-1與表12-2中分別列出了這兩種對象必須支持的API。在sqlite3模塊中,除DB-API 2.0規范必需的之外,其連接對象與游標對象都提供了很多附加的屬性與方法。

DVD程序的SQL版本為dvds.sql.py,該程序將發行者與DVD數據分開存儲,以 避免重復,並提供一個新菜單,以供用戶列出發行者。該程序使用的兩個表格在圖12-1

def connect(filename):

create= not os.path.exists(filename)

db = sqlite3.connect(filename)

if create:

cursor = db.cursor()

cursor.execute("CREATE TABLE directors ("

"id INTEGER PRIMARY KEY AUTOINCREMENT UNIQUE NOT NULL, "

"name TEXT UNIQUE NOT NULL)")

cursor.execute("CREATE TABLE dvds ("

"id INTEGER PRIMARY KEY AUTOINCREMENT UNIQUE NOT NULL, "

"title TEXT NOT NULL, "

"year INTEGER NOT NULL,"

"ration INTEGER NOT NULL, "

"director_id INTEGER NOT NULL, 」

"FOREIGN KEY (director_id) REFERENCES directors)")

db.commit()

return db

sqlite3.connect()函數會返回一個資料庫對象,並打開其指定的資料庫文件。如果該文件不存在,就創建一個空的資料庫文件。鑒於此,在調用sqlite3.connect()之前,我們要注意資料庫是否是准備從頭開始創建,如果是,就必須創建該程序要使用的表格。所有査詢都是通過一個資料庫游標完成的,可以從資料庫對象的cursor()方法獲取。

注意,兩個表格都是使用一個ID欄位創建的,ID欄位有一個AUTOINCREMENT 約束——這意味著SQLite會自動為ID欄位賦予唯一性的數值,因此,在插入新記錄時,我們可以將這些欄位留給SQLite處理。

SQLite支持有限的數據類型——實際上就是布爾型、數值型與字元串——但使用數據'『適配器」可以對其進行擴展,或者是擴展到預定義的數據類型(比如那些用於日期與datetimes的類型),或者是用於表示任意數據類型的自定義類型。DVD程序並不需要這一功能,如果需要,sqlite3模塊的文檔提供了很多詳細解釋。我們使用的外部鍵語法可能與用於其他資料庫的語法不同,並且在任何情況下,只是記錄我們的意圖,因為SQLite不像很多其他資料庫那樣需要強制關系完整性,sqlite3另一點與眾不同的地方在於其默認行為是支持隱式的事務處理,因此,沒有提供顯式的「開始事務」 方法。

def add_dvd(db):

title = Console.get_string("Title", "title")

if not title:

return

director = Console.get_string("Director", "director")

if not director:

return

year = Console.get_integer("Year", "year」, minimum=1896,

maximum=datetime.date.today().year)

ration = Console.get_integer("Duration (minutes)", "minutes",

minimum=0,maximum=60*48)

director_id = get_and_set_director(db, director)

cursor = db.cursor()

cursor.execute("INSERT INTO dvds 」

"(title, year, ration, director_id)"

"VALUES (?, ?, ?, ?)",

(title, year, ration, director_id))

db.commit()

這一函數的開始代碼與dvds-dbm.py程序中的對應函數一樣,但在完成數據的收集後,與原來的函數有很大的差別。用戶輸入的發行者可能在也可能不在directors表格中,因此,我們有一個get_and_set_director()函數,在資料庫中尚無某個發行者時, 該函數就將其插入到其中,無論哪種情況都返回就緒的發行者ID,以便在需要的時候插入到dvds表。在所有數據都可用後,我們執行一條SQL INSERT語句。我們不需要指定記錄ID,因為SQLite會自動為我們提供。

在査詢中,我們使用問號(?)作為佔位符,每個?都由包含SQL語句的字元串後面的序列中的值替代。命名的佔位符也可以使用,後面在編輯記錄時我們將看到。盡管避免使用佔位符(而只是簡單地使用嵌入到其中的數據來格式化SQL字元串)也是可能的,我們建議總是使用佔位符,並將數據項正確編碼與轉義的工作留給資料庫模塊來完成。使用佔位符的另一個好處是可以提高安全性,因為這可以防止任意的SQL 被惡意地插入到一個査詢中。

def get_and_set_director(db, director):

director_id = get_director_id(db, director)

if directorjd is not None:

return director_id

cursor = db.cursor()

cursor.execute("lNSERT INTO directors (name) VALUES (?)」,(director,))

db.commit()

return get_director_id(db, director)

這一函數返回給定發行者的ID,並在必要的時候插入新的發行者記錄。如果某個記錄被插入,我們首先嘗試使用get_director_id()函數取回其ID。

def get_director_id(db, director):

cursor = db.cursor()

cursor.execute("SELECT id FROM directors WHERE name=?",(director,))

fields = cursor.fetchone()

return fields[0] if fields is not None else None

get_director_id()函數返回給定發行者的ID,如果資料庫中沒有指定的發行者,就返回None。我們使用fetchone()方法,因為或者有一個匹配的記錄,或者沒有。(我們知道,不會有重復的發行者,因為directors表格的名稱欄位有一個UNIQUE約束,在任何情況下,在添加一個新的發行者之前,我們總是先檢査其是否存在。)這種取回方法總是返回一個欄位序列(如果沒有更多的記錄,就返回None)。即便如此,這里我們只是請求返回一個單獨的欄位。

def edit_dvd(db):

title, identity = find_dvd(db, "edit")

if title is None:

return

title = Console.get_string("Title","title", title)

if not title:

return

cursor = db.cursor()

cursor.execute("SELECT dvds.year, dvds.ration, directors.name"

「FROM dvds, directors "

"WHERE dvds.director_id = directors.id AND "

"dvds.id=:id", dict(id=identity))

year, ration, director = cursor.fetchone()

director = Console.get_string("Director", "director", director)

if not director:

return

year = Console,get_integer("Year","year", year, 1896,datetime.date.today().year)

ration = Console.get_integer("Duration (minutes)", "minutes",

ration, minimum=0, maximum=60*48)

director_id = get_and_set_director(db, director)

cursor.execute("UPDATE dvds SET title=:title, year=:year,"

"ration=:ration, director_id=:directorjd "

"WHERE id=:identity", locals())

db.commit()

要編輯DVD記錄,我們必須首先找到用戶需要操縱的記錄。如果找到了某個記錄,我們就給用戶修改其標題的機會,之後取回該記錄的其他欄位,以便將現有值作為默認值,將用戶的輸入工作最小化,用戶只需要按Enter鍵就可以接受默認值。這里,我們使用了命名的佔位符(形式為:name),並且必須使用映射來提供相應的值。對SELECT語句,我們使用一個新創建的字典;對UPDATE語句,我們使用的是由 locals()返回的字典。

我們可以同時為這兩個語句都使用新字典,這種情況下,對UPDATE語句,我們可以傳遞 dict(title=title, year=year, ration=ration, director_id=director_id, id=identity)),而非 locals()。

在具備所有欄位並且用戶已經輸入了需要做的改變之後,我們取回相應的發行者ID (如果必要就插入新的發行者記錄),之後使用新數據對資料庫進行更新。我們採用了一種簡化的方法,對記錄的所有欄位進行更新,而不僅僅是那些做了修改的欄位。

在使用DBM文件時,DVD標題被用作鍵,因此,如果標題進行了修改,我們就需要創建一個新的鍵-值項,並刪除原始項。不過,這里每個DVD記錄都有一個唯一性的ID,該ID是記錄初次插入時創建的,因此,我們只需要改變任何其他欄位的值, 而不需要其他操作。

def find_dvd(db, message):

message = "(Start of) title to " + message

cursor = db.cursor()

while True: .

start = Console.get_stnng(message, "title")

if not start:

return (None, None)

cursor.execute("SELECT title, id FROM dvds "

"WHERE title LIKE ? ORDER BY title」,

(start +"%",))

records = cursor.fetchall()

if len(records) == 0:

print("There are no dvds starting with", start)

continue

elif len(records) == 1:

return records[0]

elif len(records) > DISPLAY_LIMIT:

print("Too many dvds ({0}) start with {1}; try entering "

"more of the title".format(len(records),start))

continue

else:

for i, record in enumerate(records):

print("{0}:{1}".format(i + 1, record[0]))

which = Console.get_integer("Number (or 0 to cancel)",

"number", minimum=1, maximum=len(records))

return records[which -1] if which != 0 else (None, None)

這一函數的功能與dvdsdbm.py程序中的find_dvd()函數相同,並返回一個二元組 (DVD標題,DVD ID)或(None, None),具體依賴於是否找到了某個記錄。這里並不需要在所有數據上進行迭代,而是使用SQL通配符(%),因此只取回相關的記錄。

由於我們希望匹配的記錄數較小,因此我們一次性將其都取回到序列的序列中。如果有不止一個匹配的記錄,但數量上又少到可以顯示,我們就列印記錄,並將每條記錄附帶一個數字編號,以便用戶可以選擇需要的記錄,其方式與在dvds-dbm.py程序中所做的類似:

def list_dvds(db):

cursor = db.cursor()

sql = ("SELECT dvds.title, dvds.year, dvds.ration, "

"directors.name FROM dvds, directors "

"WHERE dvds.director_id = directors.id")

start = None

if dvd_count(db) > DISPLAY_LIMIT:

start = Console.get_string("List those starting with [Enter=all]", "start")

sql += " AND dvds.title LIKE ?"

sql += 」 ORDER BY dvds.title"

print()

if start is None:

cursor.execute(sql)

else:

cursor.execute(sql, (start +"%",))

for record in cursor:

print("{0[0]} ({0[1]}) {0[2]} minutes, by {0[3]}".format(record))

要列出每個DVD的詳細資料,我們執行一個SELECT査詢。該査詢連接兩個表,如果記錄(由dvd_count()函數返回)數量超過了顯示限制值,就將第2個元素添加到WHERE 分支,之後執行該査詢,並在結果上進行迭代。每個記錄都是一個序列,其欄位是與 SELECT査詢相匹配的。

def dvd_count(db):

cursor = db.cursor()

cursor.execute("SELECT COUNT(*) FROM dvds")

return cursor.fetchone()[0]

我們將這幾行代碼放置在一個單獨的函數中,因為我們在幾個不同的函數中都需要使用這幾行代碼。

我們忽略了 list_directors()函數的代碼,因為該函數在結構上與list_dvds()函數非常類似,只不過更簡單一些,因為本函數只列出一個欄位(name)。

def remove_dvd(db):

title, identity = find_dvd(db, "remove")

if title is None:

return

ans = Console.get_bool("Remove {0}?".format(title), "no")

if ans:

cursor = db.cursor()

cursor.execute("DELETE FROM dvds WHERE id=?", (identity,))

db.commit()

在用戶需要刪除一個記錄時,將調用本函數,並且本函數與dvds-dbm.py程序中 相應的函數是非常類似的。

到此,我們完全查閱了 dvds-sql.py程序,並且了解了如何創建資料庫表格、選取 記錄、在選定的記錄上進行迭代以及插入、更新與刪除記錄。使用execute()方法,我們可以執行底層資料庫所支持的任意SQL語句。

SQLite提供了比我們這里使用的多得多的功能,包括自動提交模式(以及任意其他類型的事務控制),以及創建可以在SQL查詢內執行的函數的能力。提供一個工廠函數並用於控制對每個取回的記錄返回什麼(比如,一個字典或自定義類型,而不是欄位序列)也是可能的。此外,通過傳遞「:memory:」作為文件名,創建內存中的SQLite 資料庫也是可能的。

以上內容部分摘自視頻課程05後端編程Python22 資料庫編程,更多實操示例請參照視頻講解。跟著張員外講編程,學習更輕松,不花錢還能學習真本領。

❿ 學python如何學

python要怎麼學?讓我們一起了解一下吧!
首先選擇好python方向,比如說數據採集方向(爬蟲),Web開發方向,人工智慧方向等;接著學習python必學的內容,如Python的基礎語言、學習Python的資料庫編程;然後就可以根據書籍或教學視頻,一步步來學習Python;最後去尋找合適的python項目實例,查漏補缺的同時提升自己的能力。如果是零基礎的初學者,建議選擇培訓班進行系統化學習,才能更快上手。
拓展:python必學的具體內容
1、Python的基礎語言
從Python的基礎語法開始學習,了解什麼是Python的變數,什麼是循環,什麼是函數,什麼是模塊類等等。
2、Python的文件操作
學習完基礎之後,進行一些簡單的聯系,如文件的操作。學習文件操作的時候,要學習文件的寫入和讀取以及了解各種文件之間的讀寫不同知識點。
3、Python的資料庫編程
一般學習Mysql資料庫的操作,包括資料庫的增加數據,刪除數據,以及查詢數據以及對應的SQL語句等都是學習的重點。
4、Python的網路編程
要學習網路編程,一般需要了解三個方面:
1.寫出基本的TCP連接,知道編寫TCP的各個步驟,例如創建socket、綁定port、埠復用等,對TCP稍微做了解,知道協議的每個欄位,了解三次握手。
2.了解基本的伺服器並發模型,例如多進程、多線程、IO復。
3.了解一些網路庫例如twisted。
今天的分享就是這些,希望能幫助到大家!