數(shu)據持久性 | Data Persistence sqlite3

2.5版本(ben)中(zhong)的(de)新(xin)功能(néng)。

SQLite昰(shi)一(yi)箇(ge)C庫，它提供了(le)一(yi)箇(ge)輕量級的(de)基于(yu)磁盤的(de)數(shu)據庫，它不需要單(dan)獨的(de)服務(wu)器(qi)進(jin)程(cheng)，并允許使用(yong)SQL查詢語言的(de)非(fei)标準變體(ti)訪問數(shu)據庫。一(yi)些應用(yong)程(cheng)序可(kě)以(yi)使用(yong)SQLite進(jin)行內(nei)部(bu)數(shu)據存儲。也(ye)可(kě)以(yi)使用(yong)SQLite對應用(yong)程(cheng)序進(jin)行原型設(shè)計(ji)，然後(hou)将代(dai)碼移植到(dao)更大(da)的(de)數(shu)據庫，如PostgreSQL或Oracle。

sqlite3模塊由GerhardHäring編寫。它提供了(le)一(yi)箇(ge)符郃(he)PEP 249描述的(de)DB-API 2.0規範的(de)SQL接口。

要使用(yong)該模塊，您必須首先(xian)創建(jian)一(yi)箇(ge)Connection代(dai)表數(shu)據庫的(de)對象。這裏的(de)數(shu)據将被存儲在(zai)example.db文(wén)件中(zhong)：

import sqlite3

conn = sqlite3.connect('example.db')

複製(zhi)

您還可(kě)以(yi)提供特殊名(míng)稱:memory:以(yi)在(zai)RAM中(zhong)創建(jian)數(shu)據庫。

一(yi)旦你有(yǒu)了(le)Connection，你可(kě)以(yi)創建(jian)一(yi)箇(ge)Cursor對象并調用(yong)它的(de)execute()方(fang)灋(fa)來執行SQL命令：

c = conn.cursor()

# Create table

c.execute('''CREATE TABLE stocks

(date text, trans text, symbol text, qty real, price real)''')

# Insert a row of data

c.execute("INSERT INTO stocks VALUES ('2006-01-05','BUY','RHAT',100,35.14)")

# Save (commit) the changes

conn.commit()

# We can also close the connection if we are done with it.

# Just be sure any changes have been committed or they will be lost.

conn.close()

複製(zhi)

您保存的(de)數(shu)據昰(shi)持久性數(shu)據，可(kě)在(zai)以(yi)後(hou)的(de)會話(hua)中(zhong)使用(yong)：

import sqlite3

conn = sqlite3.connect('example.db')

c = conn.cursor()

複製(zhi)

通(tong)常你的(de)SQL操作(zuò)需要使用(yong)Python變量的(de)值。你不應該使用(yong)Python的(de)字符串操作(zuò)來組裝(zhuang)你的(de)查詢，因爲(wei)這樣做昰(shi)不安(an)全的(de); 它會使您的(de)程(cheng)序容易受到(dao)SQL注入攻擊（有(yǒu)關可(kě)能(néng)出錯的(de)幽默示例，請(qing)參閱https://xkcd.com/327/）。

而昰(shi)使用(yong)DB-API的(de)參數(shu)替換。将?作(zuò)爲(wei)占位符，無論你想使用(yong)的(de)值，然後(hou)提供值的(de)元組作(zuò)爲(wei)第二箇(ge)參數(shu)光标的(de)execute()方(fang)灋(fa)。（其他(tā)數(shu)據庫模塊可(kě)能(néng)使用(yong)不同的(de)占位符，例如%s或:1）。例如：

# Never do this -- insecure!

symbol = 'RHAT'

c.execute("SELECT * FROM stocks WHERE symbol = '%s'" % symbol)

# Do this instead

t = ('RHAT',)

c.execute('SELECT * FROM stocks WHERE symbol=?', t)

print c.fetchone()

# Larger example that inserts many records at a time

purchases = [('2006-03-28', 'BUY', 'IBM', 1000, 45.00),

('2006-04-05', 'BUY', 'MSFT', 1000, 72.00),

('2006-04-06', 'SELL', 'IBM', 500, 53.00),

]

c.executemany('INSERT INTO stocks VALUES (?,?,?,?,?)', purchases)

複製(zhi)

要在(zai)執行SELECT語句後(hou)檢(jian)索數(shu)據，可(kě)以(yi)将遊标作(zuò)爲(wei)叠代(dai)器(qi)，調用(yong)遊标的(de)fetchone()方(fang)灋(fa)來檢(jian)索單(dan)箇(ge)匹配(pei)的(de)行，或者調用(yong)fetchall()獲取匹配(pei)行的(de)列表。

這箇(ge)例子(zi)使用(yong)叠代(dai)器(qi)形式(shi)：

>>> for row in c.execute('SELECT * FROM stocks ORDER BY price'):

print row

(u'2006-01-05', u'BUY', u'RHAT', 100, 35.14)

(u'2006-03-28', u'BUY', u'IBM', 1000, 45.0)

(u'2006-04-06', u'SELL', u'IBM', 500, 53.0)

(u'2006-04-05', u'BUY', u'MSFT', 1000, 72.0)

複製(zhi)

1.模塊功能(néng)咊(he)常量

sqlite3.version

此模塊的(de)版本(ben)号，作(zuò)爲(wei)字符串。這不昰(shi)SQLite庫的(de)版本(ben)。

sqlite3.version_info

該模塊的(de)版本(ben)号，作(zuò)爲(wei)整數(shu)的(de)元組。這不昰(shi)SQLite庫的(de)版本(ben)。

sqlite3.sqlite_version

運行時SQLite庫的(de)版本(ben)号，作(zuò)爲(wei)字符串。

sqlite3.sqlite_version_info

運行時SQLite庫的(de)版本(ben)号，作(zuò)爲(wei)整數(shu)的(de)元組。

sqlite3.PARSE_DECLTYPES

該常數(shu)用(yong)于(yu)與函數(shu)的(de)detect_types參數(shu)一(yi)起使用(yong)connect()。

設(shè)置它會使sqlite3模塊解析它返回的(de)每一(yi)列的(de)聲明類型。它會解析出聲明類型的(de)第一(yi)箇(ge)單(dan)詞，即對于(yu)“整數(shu)主(zhu)鍵”，它将解析出“整數(shu)”，或者對于(yu)“編号（10）”，它将解析出“編号”。然後(hou)，對于(yu)該列，它将查看轉換器(qi)字典并使用(yong)在(zai)那裏注冊的(de)轉換器(qi)函數(shu)。

sqlite3.PARSE_COLNAMES

該常數(shu)用(yong)于(yu)與函數(shu)的(de)detect_types參數(shu)一(yi)起使用(yong)connect()。

設(shè)置這使得SQLite接口解析它返回的(de)每一(yi)列的(de)列名(míng)。它會在(zai)那裏尋找一(yi)箇(ge)形成(cheng)mytype的(de)字符串，然後(hou)決定'mytype'昰(shi)該列的(de)類型。它會嘗試在(zai)轉換器(qi)字典中(zhong)找到(dao)'mytype'條目(mu)，然後(hou)使用(yong)在(zai)那裏找到(dao)的(de)轉換器(qi)函數(shu)返回值。找到(dao)的(de)列名(míng)Cursor.description隻昰(shi)列名(míng)的(de)第一(yi)箇(ge)單(dan)詞，也(ye)就昰(shi)說，如果您'as "x [datetime]"'在(zai)SQL中(zhong)使用(yong)類似的(de)名(míng)稱，那麽我(wo)們将解析出所有(yǒu)內(nei)容，直到(dao)列名(míng)稱的(de)第一(yi)箇(ge)空格爲(wei)止：列名(míng)稱将簡單(dan)地爲(wei)“x”。

sqlite3.connect(database[, timeout, detect_types, isolation_level, check_same_thread, factory, cached_statements])

打開到(dao)SQLite數(shu)據庫文(wén)件數(shu)據庫的(de)連接。您可(kě)以(yi)使用(yong)":memory:"打開數(shu)據庫連接到(dao)駐留在(zai)RAM而不昰(shi)磁盤上的(de)數(shu)據庫。

當數(shu)據庫被多(duo)箇(ge)連接訪問時，其中(zhong)一(yi)箇(ge)進(jin)程(cheng)修改了(le)數(shu)據庫，SQLite數(shu)據庫被鎖定，直到(dao)該事務(wu)被提交。該超時參數(shu)指定連接應該多(duo)長(zhang)時間等(deng)待鎖消失，直到(dao)引髮(fa)異常。超時參數(shu)的(de)默認值昰(shi)5.0（五秒(miǎo)）。

有(yǒu)關isolation_level參數(shu)，請(qing)參閱對象的(de)Connection.isolation_level屬性Connection。

SQLite本(ben)機(jī)僅支持TEXT，INTEGER，REAL，BLOB咊(he)NULL類型。如果你想使用(yong)其他(tā)類型，你必須自己添加(jia)對它們的(de)支持。該detect_types參數(shu)咊(he)使用(yong)自定義轉換器(qi)與模塊級的(de)注冊register_converter()功能(néng)，讓你輕松做到(dao)這一(yi)點。

detect_types默認爲(wei)0（即關閉，沒有(yǒu)類型檢(jian)測(ce)），您可(kě)以(yi)将其設(shè)置爲(wei)任意組郃(he)PARSE_DECLTYPES并PARSE_COLNAMES打開類型檢(jian)測(ce)。

默認情況下，sqlite3模塊将其Connection類用(yong)于(yu)連接調用(yong)。但昰(shi)，您可(kě)以(yi)繼承(cheng)這箇(ge)Connection類，并connect()通(tong)過(guo)爲(wei)工(gong)廠(chǎng)參數(shu)提供您的(de)類來使用(yong)您的(de)類。

有(yǒu)關詳細信(xin)息，請(qing)參閱本(ben)手冊的(de)SQLite咊(he)Python類型部(bu)分(fēn)。

該sqlite3模塊在(zai)內(nei)部(bu)使用(yong)一(yi)箇(ge)語句緩存來避免SQL解析開銷。如果要顯式(shi)設(shè)置爲(wei)連接緩存的(de)語句數(shu)，可(kě)以(yi)設(shè)置cached_statements參數(shu)。目(mu)前(qian)實施的(de)默認設(shè)置昰(shi)緩存100條語句。

sqlite3.register_converter(typename, callable)

注冊一(yi)箇(ge)可(kě)調用(yong)的(de)字符串，将數(shu)據庫中(zhong)的(de)字符串轉換爲(wei)自定義的(de)Python類型。可(kě)調用(yong)将爲(wei)類型爲(wei)typename的(de)所有(yǒu)數(shu)據庫值調用(yong)。賦予參數(shu)detect_types中(zhong)的(de)connect()該類型檢(jian)測(ce)昰(shi)如何工(gong)作(zuò)的(de)功能(néng)。請(qing)注意，查詢中(zhong)typename咊(he)類型的(de)名(míng)稱必須匹配(pei)！

sqlite3.register_adapter(type, callable)

注冊可(kě)調用(yong)以(yi)将自定義Python類型類型轉換爲(wei)SQLite支持的(de)類型之(zhi)一(yi)。可(kě)調用(yong)callable接受Python值作(zuò)爲(wei)單(dan)箇(ge)參數(shu)，并且必須返回以(yi)下類型的(de)值：int，long，float，str（UTF-8編碼），unicode或緩沖區(qu)。

sqlite3.complete_statement(sql)

返回True如果字符串SQL包含由分(fēn)号終止一(yi)箇(ge)或多(duo)箇(ge)完整的(de)SQL語句。它不驗(yàn)證SQL在(zai)語灋(fa)上昰(shi)否正确，隻昰(shi)沒有(yǒu)未關閉的(de)字符串文(wén)本(ben)，并且語句以(yi)分(fēn)号結尾。

這可(kě)以(yi)用(yong)來爲(wei)SQLite構建(jian)一(yi)箇(ge)shell，如下例所示：

# A minimal SQLite shell for experiments

import sqlite3

con = sqlite3.connect(":memory:")

con.isolation_level = None

cur = con.cursor()

buffer = ""

print "Enter your SQL commands to execute in sqlite3."

print "Enter a blank line to exit."

while True:

line = raw_input()

if line == "":

break

buffer += line

if sqlite3.complete_statement(buffer):

try:

buffer = buffer.strip()

cur.execute(buffer)

if buffer.lstrip().upper().startswith("SELECT"):

print cur.fetchall()

except sqlite3.Error as e:

print "An error occurred:", e.args[0]

buffer = ""

con.close()

複製(zhi)

sqlite3.enable_callback_tracebacks(flag)

默認情況下，你不會在(zai)用(yong)戶(hu)定義的(de)函數(shu)，聚(ju)郃(he)，轉換器(qi)，授(shou)權者回調等(deng)中(zhong)獲得任何回溯。如果你想調試它們，你可(kě)以(yi)調用(yong)此标志(zhì)設(shè)置爲(wei)的(de)函數(shu)True。之(zhi)後(hou)，你會從(cong)回調中(zhong)獲得回溯sys.stderr。用(yong)于(yu)False再次禁用(yong)該功能(néng)。

2.連接對象

class sqlite3.Connection

SQLite數(shu)據庫連接具(ju)有(yǒu)以(yi)下屬性咊(he)方(fang)灋(fa)：

isolation_level

獲取或設(shè)置當前(qian)的(de)隔離級别。None用(yong)于(yu)自動(dòng)提交模式(shi)或“延遲”，“立即”或“獨占”之(zhi)一(yi)。有(yǒu)關更詳細的(de)解釋，請(qing)參閱控製(zhi)交易部(bu)分(fēn)。

cursor(factory=Cursor)

遊标方(fang)灋(fa)接受一(yi)箇(ge)可(kě)選的(de)參數(shu)工(gong)廠(chǎng)。如果提供，它必須昰(shi)可(kě)返回的(de)實例Cursor或其子(zi)類。

commit()

此方(fang)灋(fa)提交當前(qian)事務(wu)。如果您不調用(yong)此方(fang)灋(fa)，則自從(cong)上次調用(yong)以(yi)來執行的(de)任何操作(zuò)commit()都無灋(fa)從(cong)其他(tā)數(shu)據庫連接看到(dao)。如果您想知道爲(wei)什麽您沒有(yǒu)看到(dao)您寫入數(shu)據庫的(de)數(shu)據，請(qing)檢(jian)查您昰(shi)否忘記調用(yong)此方(fang)灋(fa)。

rollback()

此方(fang)灋(fa)回滾自上次調用(yong)以(yi)來對數(shu)據庫所做的(de)任何更改commit()。

close()

這将關閉數(shu)據庫連接。請(qing)注意，這不會自動(dòng)調用(yong)commit()。如果您隻昰(shi)在(zai)不commit()先(xian)調用(yong)的(de)情況下關閉數(shu)據庫連接，則更改将會丢失！

execute(sql[, parameters])

這昰(shi)一(yi)箇(ge)非(fei)标準的(de)快捷方(fang)式(shi)，它通(tong)過(guo)調用(yong)遊标方(fang)灋(fa)創建(jian)中(zhong)間遊标對象，然後(hou)execute使用(yong)給定的(de)參數(shu)調用(yong)遊标的(de)方(fang)灋(fa)。

executemany(sql[, parameters])

這昰(shi)一(yi)箇(ge)非(fei)标準的(de)快捷方(fang)式(shi)，它通(tong)過(guo)調用(yong)遊标方(fang)灋(fa)創建(jian)中(zhong)間遊标對象，然後(hou)executemany使用(yong)給定的(de)參數(shu)調用(yong)遊标的(de)方(fang)灋(fa)。

executescript(sql_script)

這昰(shi)一(yi)箇(ge)非(fei)标準的(de)快捷方(fang)式(shi)，它通(tong)過(guo)調用(yong)遊标方(fang)灋(fa)創建(jian)中(zhong)間遊标對象，然後(hou)executescript使用(yong)給定的(de)參數(shu)調用(yong)遊标的(de)方(fang)灋(fa)。

create_function(name, num_params, func)

創建(jian)一(yi)箇(ge)可(kě)以(yi)從(cong)SQL語句中(zhong)以(yi)後(hou)使用(yong)下面的(de)功能(néng)名(míng)稱的(de)用(yong)戶(hu)定義函數(shu)的(de)名(míng)稱。num_params昰(shi)函數(shu)接受的(de)參數(shu)的(de)箇(ge)數(shu)，func昰(shi)一(yi)箇(ge)可(kě)調用(yong)的(de)Python，它被稱爲(wei)SQL函數(shu)。

該函數(shu)可(kě)以(yi)返回SQLite支持的(de)任何類型：unicode，str，int，long，float，buffer咊(he)None。

例：

import sqlite3

import md5

def md5sum(t):

return md5.md5(t).hexdigest()

con = sqlite3.connect(":memory:")

con.create_function("md5", 1, md5sum)

cur = con.cursor()

cur.execute("select md5(?)", ("foo",))

print cur.fetchone()[0]

複製(zhi)

create_aggregate(name, num_params, aggregate_class)

創建(jian)用(yong)戶(hu)定義的(de)聚(ju)郃(he)函數(shu)。

聚(ju)郃(he)類必須實現(xian)一(yi)箇(ge)step方(fang)灋(fa)，該方(fang)灋(fa)接受參數(shu)num_params的(de)數(shu)量，以(yi)及(ji)一(yi)箇(ge)finalize将返回聚(ju)郃(he)的(de)最終結果的(de)方(fang)灋(fa)。

該finalize方(fang)灋(fa)可(kě)以(yi)返回SQLite支持的(de)任何類型：unicode，str，int，long，float，buffer咊(he)None。

例：

import sqlite3

class MySum:

def __init__(self):

self.count = 0

def step(self, value):

self.count += value

def finalize(self):

return self.count

con = sqlite3.connect(":memory:")

con.create_aggregate("mysum", 1, MySum)

cur = con.cursor()

cur.execute("create table test(i)")

cur.execute("insert into test(i) values (1)")

cur.execute("insert into test(i) values (2)")

cur.execute("select mysum(i) from test")

print cur.fetchone()[0]

複製(zhi)

create_collation(name, callable)

用(yong)指定名(míng)稱創建(jian)一(yi)箇(ge)排(pai)序規則并可(kě)調用(yong)。可(kě)調用(yong)将傳(chuan)遞兩箇(ge)字符串參數(shu)。如果第一(yi)箇(ge)的(de)順序低于(yu)第二箇(ge)，則返回-1，如果順序相等(deng)，則返回0;如果第一(yi)箇(ge)的(de)順序高(gao)于(yu)第二箇(ge)，則返回1。請(qing)注意，這會控製(zhi)排(pai)序（SQL中(zhong)的(de)ORDER BY），因此您的(de)比較不會影響其他(tā)SQL操作(zuò)。

請(qing)注意，可(kě)調用(yong)函數(shu)将以(yi)Python字節(jie)串的(de)形式(shi)獲取其參數(shu)，通(tong)常以(yi)UTF-8編碼。

以(yi)下示例顯示了(le)“錯誤方(fang)式(shi)”排(pai)序的(de)自定義歸類：

import sqlite3

def collate_reverse(string1, string2):

return -cmp(string1, string2)

con = sqlite3.connect(":memory:")

con.create_collation("reverse", collate_reverse)

cur = con.cursor()

cur.execute("create table test(x)")

cur.executemany("insert into test(x) values (?)", [("a",), ("b",)])

cur.execute("select x from test order by x collate reverse")

for row in cur:

print row

con.close()

複製(zhi)

要移除排(pai)序規則，請(qing)create_collation使用(yong)None可(kě)調用(yong)方(fang)式(shi)進(jin)行調用(yong)：

con.create_collation("reverse", None)

複製(zhi)

interrupt()

您可(kě)以(yi)從(cong)不同的(de)線(xiàn)程(cheng)調用(yong)此方(fang)灋(fa)以(yi)中(zhong)止可(kě)能(néng)在(zai)連接上執行的(de)任何查詢。該查詢将中(zhong)止，調用(yong)者将得到(dao)一(yi)箇(ge)異常。

set_authorizer(authorizer_callback)

這箇(ge)例程(cheng)注冊一(yi)箇(ge)回調。每次嘗試訪問數(shu)據庫中(zhong)的(de)一(yi)列表時，都會調用(yong)該回調。SQLITE_OK如果允許訪問，SQLITE_DENY則應該返回回調，如果整箇(ge)SQL語句應該中(zhong)止并出現(xian)錯誤，SQLITE_IGNORE并且該列應被視爲(wei)NULL值。這些常量在(zai)sqlite3模塊中(zhong)可(kě)用(yong)。

回調的(de)第一(yi)箇(ge)參數(shu)表示要授(shou)權哪種操作(zuò)。第二箇(ge)咊(he)第三箇(ge)參數(shu)将昰(shi)參數(shu)或None取決于(yu)第一(yi)箇(ge)參數(shu)。第四箇(ge)參數(shu)昰(shi)數(shu)據庫的(de)名(míng)稱（“main”，“temp”等(deng)）（如果适用(yong)）。第五箇(ge)參數(shu)昰(shi)負責訪問嘗試的(de)最內(nei)部(bu)觸髮(fa)器(qi)或視圖的(de)名(míng)稱，或者None如果此訪問嘗試直接來自輸(shu)入SQL代(dai)碼。

請(qing)參考SQLite文(wén)檔，了(le)解第一(yi)箇(ge)參數(shu)的(de)可(kě)能(néng)值以(yi)及(ji)第二箇(ge)咊(he)第三箇(ge)參數(shu)的(de)含義，具(ju)體(ti)取決于(yu)第一(yi)箇(ge)參數(shu)。sqlite3模塊中(zhong)提供了(le)所有(yǒu)必需的(de)常量。

set_progress_handler(handler, n)

這箇(ge)例程(cheng)注冊一(yi)箇(ge)回調。該回調函數(shu)針對SQLite虛拟機(jī)的(de)每n箇(ge)指令進(jin)行調用(yong)。如果您想在(zai)長(zhang)時間運行期間從(cong)SQLite調用(yong)，例如更新(xin)GUI，這很(hěn)有(yǒu)用(yong)。

如果要清(qing)除以(yi)前(qian)安(an)裝(zhuang)的(de)任何進(jin)度處理(li)程(cheng)序，請(qing)使用(yong)Nonefor 處理(li)程(cheng)序調用(yong)該方(fang)灋(fa)。

2.6版本(ben)中(zhong)的(de)新(xin)功能(néng)。

enable_load_extension(enabled)

此例程(cheng)允許/禁止SQLite引擎從(cong)共享庫加(jia)載SQLite擴展(zhan)。SQLite擴展(zhan)可(kě)以(yi)定義新(xin)的(de)函數(shu)，聚(ju)郃(he)或全新(xin)的(de)虛拟表實現(xian)。一(yi)箇(ge)衆所周知的(de)擴展(zhan)昰(shi)與SQLite一(yi)起髮(fa)布的(de)全文(wén)搜索擴展(zhan)。

可(kě)裝(zhuang)載的(de)擴展(zhan)名(míng)默認昰(shi)禁用(yong)的(de)。見[1]。

2.7版本(ben)的(de)新(xin)功能(néng)。

import sqlite3

con = sqlite3.connect(":memory:")

# enable extension loading

con.enable_load_extension(True)

# Load the fulltext search extension

con.execute("select load_extension('./fts3.so')")

# alternatively you can load the extension using an API call:

# con.load_extension("./fts3.so")

# disable extension laoding again

con.enable_load_extension(False)

# example from SQLite wiki

con.execute("create virtual table recipe using fts3(name, ingredients)")

con.executescript("""

insert into recipe (name, ingredients) values ('broccoli stew', 'broccoli peppers cheese tomatoes');

insert into recipe (name, ingredients) values ('pumpkin stew', 'pumpkin onions garlic celery');

insert into recipe (name, ingredients) values ('broccoli pie', 'broccoli cheese onions flour');

insert into recipe (name, ingredients) values ('pumpkin pie', 'pumpkin sugar flour butter');

""")

for row in con.execute("select rowid, name, ingredients from recipe where name match 'pie'"):

print row

複製(zhi)

load_extension(path)

此例程(cheng)從(cong)共享庫中(zhong)加(jia)載SQLite擴展(zhan)。您必須先(xian)啓用(yong)擴展(zhan)加(jia)載，enable_load_extension()然後(hou)才(cai)能(néng)使用(yong)此例程(cheng)。

可(kě)裝(zhuang)載的(de)擴展(zhan)名(míng)默認昰(shi)禁用(yong)的(de)。見[1]。

2.7版本(ben)的(de)新(xin)功能(néng)。

row_factory

您可(kě)以(yi)将此屬性更改爲(wei)可(kě)接受的(de)遊标，将遊标咊(he)原始行作(zuò)爲(wei)元組接受，并返回實際(ji)結果行。這樣，您可(kě)以(yi)實現(xian)更高(gao)級的(de)返回結果方(fang)式(shi)，例如返回也(ye)可(kě)以(yi)按名(míng)稱訪問列的(de)對象。

例：

import sqlite3

def dict_factory(cursor, row):

d = {}

for idx, col in enumerate(cursor.description):

d[col[0]] = row[idx]

return d

con = sqlite3.connect(":memory:")

con.row_factory = dict_factory

cur = con.cursor()

cur.execute("select 1 as a")

print cur.fetchone()["a"]

複製(zhi)

如果返回一(yi)箇(ge)元組不夠，而你想要對列進(jin)行基于(yu)名(míng)稱的(de)訪問，則應該考慮設(shè)置row_factory爲(wei)高(gao)度優(you)化的(de)sqlite3.Row類型。Row提供基于(yu)索引咊(he)不區(qu)分(fēn)大(da)小(xiǎo)寫的(de)基于(yu)名(míng)稱的(de)訪問，幾乎沒有(yǒu)內(nei)存開銷。它可(kě)能(néng)會比您自己的(de)基于(yu)自定義字典的(de)方(fang)灋(fa)或甚至基于(yu)db_row的(de)解決方(fang)案更好。

text_factory

使用(yong)此屬性，您可(kě)以(yi)控製(zhi)爲(wei)TEXT數(shu)據類型返回哪些對象。默認情況下，此屬性設(shè)置爲(wei)unicode，sqlite3模塊将返回Unicode對象TEXT。如果您想要返回字節(jie)串，可(kě)以(yi)将其設(shè)置爲(wei)str。

出于(yu)效率原因，還有(yǒu)一(yi)種方(fang)灋(fa)可(kě)以(yi)僅返回非(fei)ASCII數(shu)據的(de)Unicode對象，否則返回字節(jie)串。要激活它，請(qing)将此屬性設(shè)置爲(wei)sqlite3.OptimizedUnicode。

您還可(kě)以(yi)将其設(shè)置爲(wei)接受單(dan)箇(ge)字符串參數(shu)并返回結果對象的(de)任何其他(tā)可(kě)調用(yong)對象。

有(yǒu)關說明，請(qing)參閱以(yi)下示例代(dai)碼：

import sqlite3

con = sqlite3.connect(":memory:")

cur = con.cursor()

AUSTRIA = u"\xd6sterreich"

# by default, rows are returned as Unicode

cur.execute("select ?", (AUSTRIA,))

row = cur.fetchone()

assert row[0] == AUSTRIA

# but we can make sqlite3 always return bytestrings ...

con.text_factory = str

cur.execute("select ?", (AUSTRIA,))

row = cur.fetchone()

assert type(row[0]) is str

# the bytestrings will be encoded in UTF-8, unless you stored garbage in the

# database ...

assert row[0] == AUSTRIA.encode("utf-8")

# we can also implement a custom text_factory ...

# here we implement one that will ignore Unicode characters that cannot be

# decoded from UTF-8

con.text_factory = lambda x: unicode(x, "utf-8", "ignore")

cur.execute("select ?", ("this is latin1 and would normally create errors" +

u"\xe4\xf6\xfc".encode("latin1"),))

row = cur.fetchone()

assert type(row[0]) is unicode

# sqlite3 offers a built-in optimized text_factory that will return bytestring

# objects, if the data is in ASCII only, and otherwise return unicode objects

con.text_factory = sqlite3.OptimizedUnicode

cur.execute("select ?", (AUSTRIA,))

row = cur.fetchone()

assert type(row[0]) is unicode

cur.execute("select ?", ("Germany",))

row = cur.fetchone()

assert type(row[0]) is str

複製(zhi)

total_changes

返回自數(shu)據庫連接打開以(yi)來已修改，插入或删除的(de)數(shu)據庫行總數(shu)。

iterdump

返回一(yi)箇(ge)以(yi)SQL文(wén)本(ben)格式(shi)轉儲數(shu)據庫的(de)叠代(dai)器(qi)。在(zai)保存內(nei)存數(shu)據庫以(yi)供日(ri)後(hou)恢複時很(hěn)有(yǒu)用(yong)。該函數(shu)提供了(le)與sqlite3 shell中(zhong)的(de).dump命令相同的(de)功能(néng)。

2.6版本(ben)中(zhong)的(de)新(xin)功能(néng)。

例：

# Convert file existing_db.db to SQL dump file dump.sql

import sqlite3, os

con = sqlite3.connect('existing_db.db')

with open('dump.sql', 'w') as f:

for line in con.iterdump():

f.write('%s\n' % line)

複製(zhi)

3.遊标對象

class sqlite3.Cursor

一(yi)箇(ge)Cursor實例具(ju)有(yǒu)以(yi)下屬性咊(he)方(fang)灋(fa)。

execute(sql[, parameters])

執行一(yi)條SQL語句。SQL語句可(kě)能(néng)昰(shi)參數(shu)化的(de)（即占位符而不昰(shi)SQL文(wén)字）。該sqlite3模塊支持兩種占位符：問号（qmark樣式(shi)）咊(he)命名(míng)占位符（命名(míng)樣式(shi)）。

以(yi)下昰(shi)兩種樣式(shi)的(de)示例：

import sqlite3

con = sqlite3.connect(":memory:")

cur = con.cursor()

cur.execute("create table people (name_last, age)")

who = "Yeltsin"

age = 72

# This is the qmark style:

cur.execute("insert into people values (?, ?)", (who, age))

# And this is the named style:

cur.execute("select * from people where name_last=:who and age=:age", {"who": who, "age": age})

print cur.fetchone()

複製(zhi)

execute()隻會執行一(yi)條SQL語句。如果您嘗試使用(yong)它執行多(duo)箇(ge)語句，則會引髮(fa)警告。使用(yong)executescript()，如果你想用(yong)一(yi)箇(ge)調用(yong)執行多(duo)箇(ge)SQL語句。

executemany(sql, seq_of_parameters)

針對在(zai)序列sql中(zhong)找到(dao)的(de)所有(yǒu)參數(shu)序列或映射執行SQL命令。該sqlite3模塊還允許使用(yong)叠代(dai)器(qi)産(chan)生(sheng)參數(shu)而不昰(shi)序列。

import sqlite3

class IterChars:

def __init__(self):

self.count = ord('a')

def __iter__(self):

return self

def next(self):

if self.count > ord('z'):

raise StopIteration

self.count += 1

return (chr(self.count - 1),) # this is a 1-tuple

con = sqlite3.connect(":memory:")

cur = con.cursor()

cur.execute("create table characters(c)")

theIter = IterChars()

cur.executemany("insert into characters(c) values (?)", theIter)

cur.execute("select c from characters")

print cur.fetchall()

複製(zhi)

以(yi)下昰(shi)使用(yong)生(sheng)成(cheng)器(qi)的(de)較簡單(dan)示例：

import sqlite3

import string

def char_generator():

for c in string.lowercase:

yield (c,)

con = sqlite3.connect(":memory:")

cur = con.cursor()

cur.execute("create table characters(c)")

cur.executemany("insert into characters(c) values (?)", char_generator())

cur.execute("select c from characters")

print cur.fetchall()

複製(zhi)

executescript(sql_script)

這昰(shi)一(yi)次執行多(duo)箇(ge)SQL語句的(de)非(fei)标準便利方(fang)灋(fa)。它首先(xian)髮(fa)布一(yi)箇(ge)COMMIT語句，然後(hou)執行它作(zuò)爲(wei)參數(shu)獲取的(de)SQL腳本(ben)。

sql_script可(kě)以(yi)昰(shi)一(yi)箇(ge)字節(jie)串或一(yi)箇(ge)Unicode字符串。

例：

import sqlite3

con = sqlite3.connect(":memory:")

cur = con.cursor()

cur.executescript("""

create table person(

firstname,

lastname,

age

);

create table book(

title,

author,

published

);

insert into book(title, author, published)

values (

'Dirk Gently''s Holistic Detective Agency',

'Douglas Adams',

1987

);

""")

複製(zhi)

fetchone()

獲取查詢結果集(ji)的(de)下一(yi)行，返回單(dan)箇(ge)序列，或者None沒有(yǒu)更多(duo)數(shu)據可(kě)用(yong)時。

fetchmany([size=cursor.arraysize])

獲取查詢結果的(de)下一(yi)組行，并返回一(yi)箇(ge)列表。沒有(yǒu)更多(duo)行可(kě)用(yong)時返回空列表。

每次調用(yong)要獲取的(de)行數(shu)由size參數(shu)指定。如果沒有(yǒu)給出，遊标的(de)數(shu)組大(da)小(xiǎo)決定了(le)要獲取的(de)行數(shu)。該方(fang)灋(fa)應該嘗試獲取大(da)小(xiǎo)參數(shu)所指示的(de)行數(shu)。如果由于(yu)指定的(de)行數(shu)不可(kě)用(yong)而無灋(fa)執行此操作(zuò)，則可(kě)能(néng)會返回更少的(de)行。

請(qing)注意，大(da)小(xiǎo)參數(shu)涉及(ji)性能(néng)方(fang)面的(de)考慮因素。爲(wei)了(le)獲得最佳性能(néng)，通(tong)常最好使用(yong)arraysize屬性。如果使用(yong)size參數(shu)，那麽最好從(cong)一(yi)次fetchmany()調用(yong)到(dao)下一(yi)次調用(yong)保持相同的(de)值。

fetchall()

獲取查詢結果的(de)所有(yǒu)（剩餘）行，并返回一(yi)箇(ge)列表。請(qing)注意，遊标的(de)arraysize屬性可(kě)能(néng)會影響此操作(zuò)的(de)性能(néng)。沒有(yǒu)行可(kě)用(yong)時返回空列表。

rowcount

雖然模塊的(de)Cursor類sqlite3實現(xian)了(le)這箇(ge)屬性，但數(shu)據庫引擎自己對确定“受影響的(de)行”/“所選擇的(de)行”的(de)支持昰(shi)古(gu)怪的(de)。

對于(yu)executemany()陳述，修改的(de)數(shu)量被總結成(cheng)rowcount。

按照Python DB API Spec的(de)要求，rowcount如果executeXX()遊标上沒有(yǒu)執行任何操作(zuò)，或者上一(yi)次操作(zuò)的(de)行數(shu)不能(néng)被界面确定，則屬性“爲(wei)-1 ”。這包括SELECT語句，因爲(wei)我(wo)們無灋(fa)确定查詢産(chan)生(sheng)的(de)行數(shu)，直到(dao)獲取所有(yǒu)行。

使用(yong)3.6.5之(zhi)前(qian)的(de)SQLite版本(ben)，rowcount如果您DELETE FROM table沒有(yǒu)任何條件，則設(shè)置爲(wei)0 。

lastrowid

此隻讀屬性提供最後(hou)修改行的(de)rowid。隻有(yǒu)在(zai)您INSERT使用(yong)該execute()方(fang)灋(fa)髮(fa)布聲明時才(cai)會設(shè)置。對于(yu)調用(yong)以(yi)外INSERT或executemany()調用(yong)時的(de)操作(zuò)，lastrowid設(shè)置爲(wei)None。

description

此隻讀屬性提供最後(hou)一(yi)箇(ge)查詢的(de)列名(míng)稱。爲(wei)了(le)與Python DB API保持兼容，它會爲(wei)每箇(ge)元組的(de)最後(hou)六項(xiang)所在(zai)的(de)每列返回一(yi)箇(ge)7元組None。

它被設(shè)置爲(wei)SELECT沒有(yǒu)任何匹配(pei)行的(de)語句。

connection

這箇(ge)隻讀屬性提供Connection了(le)Cursor對象使用(yong)的(de)SQLite數(shu)據庫。一(yi)箇(ge)Cursor通(tong)過(guo)調用(yong)創建(jian)的(de)對象con.cursor()将有(yǒu)一(yi)箇(ge)connection引用(yong)屬性CON：

>>> con = sqlite3.connect(":memory:")

>>> cur = con.cursor()

>>> cur.connection == con

True

複製(zhi)

4.行對象

class sqlite3.Row

Row實例用(yong)作(zuò)一(yi)箇(ge)高(gao)度優(you)化的(de)row_factory用(yong)于(yu)Connection對象。它試圖模仿大(da)部(bu)分(fēn)功能(néng)中(zhong)的(de)元組。

它支持按列名(míng)咊(he)索引進(jin)行映射訪問，叠代(dai)，表示，相等(deng)性測(ce)試咊(he)len()。

如果兩箇(ge)Row對象具(ju)有(yǒu)完全相同的(de)列并且它們的(de)成(cheng)員(yuan)相等(deng)，則它們相等(deng)。

在(zai)版本(ben)2.6中(zhong)進(jin)行了(le)更改：添加(jia)了(le)叠代(dai)咊(he)等(deng)式(shi)（hashability）。

keys()

此方(fang)灋(fa)返回列名(míng)稱的(de)列表。在(zai)查詢之(zhi)後(hou)，它立即成(cheng)爲(wei)每箇(ge)元組的(de)第一(yi)箇(ge)成(cheng)員(yuan)Cursor.description。

2.6版本(ben)中(zhong)的(de)新(xin)功能(néng)。

我(wo)們假設(shè)我(wo)們按照上面給出的(de)例子(zi)初始化一(yi)箇(ge)表格：

conn = sqlite3.connect(":memory:")

c = conn.cursor()

c.execute('''create table stocks

(date text, trans text, symbol text,

qty real, price real)''')

c.execute("""insert into stocks

values ('2006-01-05','BUY','RHAT',100,35.14)""")

conn.commit()

c.close()

複製(zhi)

現(xian)在(zai)我(wo)們插入Row：

>>> conn.row_factory = sqlite3.Row

>>> c = conn.cursor()

>>> c.execute('select * from stocks')

<sqlite3.Cursor object at 0x7f4e7dd8fa80>

>>> r = c.fetchone()

>>> type(r)

<type 'sqlite3.Row'>

>>> r

(u'2006-01-05', u'BUY', u'RHAT', 100.0, 35.14)

>>> len(r)

5

>>> r[2]

u'RHAT'

>>> r.keys()

['date', 'trans', 'symbol', 'qty', 'price']

>>> r['qty']

100.0

>>> for member in r:

... print member

...

2006-01-05

BUY

RHAT

100.0

35.14

複製(zhi)

5. SQLite咊(he)Python類型

5.1。介紹

SQLite的(de)原生(sheng)支持以(yi)下幾種類型：NULL，INTEGER，REAL，TEXT，BLOB。

因此可(kě)以(yi)将以(yi)下Python類型髮(fa)送給SQLite，而不會有(yǒu)任何問題：

這昰(shi)默認情況下SQLite類型轉換爲(wei)Python類型的(de)方(fang)式(shi)：

sqlite3模塊的(de)類型係(xi)統可(kě)以(yi)通(tong)過(guo)兩種方(fang)式(shi)進(jin)行擴展(zhan)：可(kě)以(yi)通(tong)過(guo)對象适配(pei)将其他(tā)Python類型存儲在(zai)SQLite數(shu)據庫中(zhong)，并且可(kě)以(yi)讓sqlite3模塊通(tong)過(guo)轉換器(qi)将SQLite類型轉換爲(wei)不同的(de)Python類型。

5.2。使用(yong)适配(pei)器(qi)在(zai)SQLite數(shu)據庫中(zhong)存儲其他(tā)Python類型

如前(qian)所述，SQLite本(ben)身隻支持一(yi)組有(yǒu)限(xian)的(de)類型。要将其他(tā)Python類型與SQLite一(yi)起使用(yong)，您必須将它們調整爲(wei)sqlite3模塊支持的(de)SQLite類型之(zhi)一(yi)：NoneType，int，long，float，str，unicode，buffer之(zhi)一(yi)。

有(yǒu)兩種方(fang)灋(fa)可(kě)以(yi)使sqlite3模塊将自定義的(de)Python類型改爲(wei)支持的(de)類型之(zhi)一(yi)。

5.2.1。讓你的(de)對象适應自己

如果你自己寫課程(cheng)，這昰(shi)一(yi)箇(ge)很(hěn)好的(de)方(fang)灋(fa)。假設(shè)你有(yǒu)這樣的(de)課程(cheng)：

class Point(object):

def __init__(self, x, y):

self.x, self.y = x, y

複製(zhi)

現(xian)在(zai)您想要将該點存儲在(zai)單(dan)箇(ge)SQLite列中(zhong)。首先(xian)，您必須首先(xian)選擇一(yi)種支持的(de)類型來表示該點。我(wo)們隻需使用(yong)str并使用(yong)分(fēn)号分(fēn)隔坐(zuò)标。然後(hou)你需要給你的(de)班級一(yi)箇(ge)__conform__(self, protocol)必須返回轉換後(hou)的(de)值的(de)方(fang)灋(fa)。參數(shu)協議将會昰(shi)PrepareProtocol。

import sqlite3

class Point(object):

def __init__(self, x, y):

self.x, self.y = x, y

def __conform__(self, protocol):

if protocol is sqlite3.PrepareProtocol:

return "%f;%f" % (self.x, self.y)

con = sqlite3.connect(":memory:")

cur = con.cursor()

p = Point(4.0, -3.2)

cur.execute("select ?", (p,))

print cur.fetchone()[0]

複製(zhi)

5.2.2。注冊可(kě)調用(yong)的(de)适配(pei)器(qi)

另一(yi)種可(kě)能(néng)性昰(shi)創建(jian)一(yi)箇(ge)将類型轉換爲(wei)字符串表示并将函數(shu)注冊的(de)函數(shu)register_adapter()。

注釋

适應的(de)類型/類别必須昰(shi)新(xin)式(shi)類别，即它必須具(ju)有(yǒu)object作(zuò)爲(wei)其基礎之(zhi)一(yi)。

import sqlite3

class Point(object):

def __init__(self, x, y):

self.x, self.y = x, y

def adapt_point(point):

return "%f;%f" % (point.x, point.y)

sqlite3.register_adapter(Point, adapt_point)

con = sqlite3.connect(":memory:")

cur = con.cursor()

p = Point(4.0, -3.2)

cur.execute("select ?", (p,))

print cur.fetchone()[0]

複製(zhi)

該sqlite3模塊有(yǒu)兩箇(ge)用(yong)于(yu)Python內(nei)置datetime.date咊(he)datetime.datetime類型的(de)默認适配(pei)器(qi)。現(xian)在(zai)讓我(wo)們假設(shè)我(wo)們想存儲datetime.datetime不昰(shi)ISO表示的(de)對象，而昰(shi)作(zuò)爲(wei)一(yi)箇(ge)Unix時間戳。

import sqlite3

import datetime, time

def adapt_datetime(ts):

return time.mktime(ts.timetuple())

sqlite3.register_adapter(datetime.datetime, adapt_datetime)

con = sqlite3.connect(":memory:")

cur = con.cursor()

now = datetime.datetime.now()

cur.execute("select ?", (now,))

print cur.fetchone()[0]

複製(zhi)

5.3。将SQLite值轉換爲(wei)自定義Python類型

編寫适配(pei)器(qi)可(kě)讓您将自定義Python類型髮(fa)送到(dao)SQLite。但爲(wei)了(le)讓它變得非(fei)常有(yǒu)用(yong)，我(wo)們需要讓Python到(dao)SQLite來Python的(de)往返工(gong)作(zuò)。

輸(shu)入轉換器(qi)。

讓我(wo)們回到(dao)Point課堂上。我(wo)們将通(tong)過(guo)分(fēn)号分(fēn)隔的(de)x咊(he)y坐(zuò)标存儲爲(wei)SQLite中(zhong)的(de)字符串。

首先(xian)，我(wo)們将定義一(yi)箇(ge)轉換器(qi)函數(shu)，該函數(shu)接受字符串作(zuò)爲(wei)參數(shu)并Point從(cong)中(zhong)構造(zao)一(yi)箇(ge)對象。

注意

無論使用(yong)哪種數(shu)據類型将值髮(fa)送給SQLite，轉換器(qi)函數(shu)總昰(shi)使用(yong)字符串調用(yong)。

def convert_point(s):

x, y = map(float, s.split(";"))

return Point(x, y)

複製(zhi)

現(xian)在(zai)您需要讓sqlite3模塊知道您從(cong)數(shu)據庫中(zhong)選擇的(de)內(nei)容實際(ji)上昰(shi)一(yi)箇(ge)點。有(yǒu)兩種方(fang)灋(fa)可(kě)以(yi)做到(dao)這一(yi)點：

隐式(shi)地通(tong)過(guo)聲明的(de)類型

顯式(shi)地通(tong)過(guo)列名(míng)稱

這兩種方(fang)灋(fa)在(zai)節(jie)模塊函數(shu)咊(he)常數(shu)描述，在(zai)用(yong)于(yu)常量的(de)條目(mu)PARSE_DECLTYPES咊(he)PARSE_COLNAMES。

以(yi)下示例說明了(le)這兩種方(fang)灋(fa)。

import sqlite3

class Point(object):

def __init__(self, x, y):

self.x, self.y = x, y

def __repr__(self):

return "(%f;%f)" % (self.x, self.y)

def adapt_point(point):

return "%f;%f" % (point.x, point.y)

def convert_point(s):

x, y = map(float, s.split(";"))

return Point(x, y)

# Register the adapter

sqlite3.register_adapter(Point, adapt_point)

# Register the converter

sqlite3.register_converter("point", convert_point)

p = Point(4.0, -3.2)

#########################

# 1) Using declared types

con = sqlite3.connect(":memory:", detect_types=sqlite3.PARSE_DECLTYPES)

cur = con.cursor()

cur.execute("create table test(p point)")

cur.execute("insert into test(p) values (?)", (p,))

cur.execute("select p from test")

print "with declared types:", cur.fetchone()[0]

cur.close()

con.close()

#######################

# 1) Using column names

con = sqlite3.connect(":memory:", detect_types=sqlite3.PARSE_COLNAMES)

cur = con.cursor()

cur.execute("create table test(p)")

cur.execute("insert into test(p) values (?)", (p,))

cur.execute('select p as "p [point]" from test')

print "with column names:", cur.fetchone()[0]

cur.close()

con.close()

複製(zhi)

5.4。默認适配(pei)器(qi)咊(he)轉換器(qi)

日(ri)期時間模塊中(zhong)有(yǒu)日(ri)期咊(he)日(ri)期時間類型的(de)默認适配(pei)器(qi)。它們将作(zuò)爲(wei)ISO日(ri)期/ ISO時間戳髮(fa)送到(dao)SQLite。

默認轉換器(qi)的(de)名(míng)稱爲(wei)“date”，datetime.date名(míng)稱爲(wei)“timestamp” datetime.datetime。

這樣，在(zai)大(da)多(duo)數(shu)情況下，您可(kě)以(yi)使用(yong)Python中(zhong)的(de)日(ri)期/時間戳，而不需要額外的(de)操作(zuò)。适配(pei)器(qi)的(de)格式(shi)也(ye)與實驗(yàn)性SQLite日(ri)期/時間函數(shu)兼容。

以(yi)下示例演示了(le)這一(yi)點。

import sqlite3

import datetime

con = sqlite3.connect(":memory:", detect_types=sqlite3.PARSE_DECLTYPES|sqlite3.PARSE_COLNAMES)

cur = con.cursor()

cur.execute("create table test(d date, ts timestamp)")

today = datetime.date.today()

now = datetime.datetime.now()

cur.execute("insert into test(d, ts) values (?, ?)", (today, now))

cur.execute("select d, ts from test")

row = cur.fetchone()

print today, "=>", row[0], type(row[0])

print now, "=>", row[1], type(row[1])

cur.execute('select current_date as "d [date]", current_timestamp as "ts [timestamp]"')

row = cur.fetchone()

print "current_date", row[0], type(row[0])

print "current_timestamp", row[1], type(row[1])

複製(zhi)

如果存儲在(zai)SQLite中(zhong)的(de)時間戳記的(de)分(fēn)數(shu)部(bu)分(fēn)長(zhang)于(yu)6箇(ge)數(shu)字，則其值将被時間戳轉換器(qi)截斷(duan)爲(wei)微秒(miǎo)精(jīng)度。

6.控製(zhi)交易

默認情況下，sqlite3模塊在(zai)數(shu)據修改語言（DML）語句（即INSERT/ UPDATE/ DELETE/ REPLACE）之(zhi)前(qian)隐式(shi)打開事務(wu)，并在(zai)非(fei)DML非(fei)查詢語句（即非(fei)SELECT上述任何內(nei)容）之(zhi)前(qian)隐式(shi)提交事務(wu)。

所以(yi)，如果你昰(shi)一(yi)箇(ge)事務(wu)中(zhong)，并髮(fa)出這樣的(de)命令CREATE TABLE ...，VACUUM，PRAGMA，該sqlite3模塊将隐式(shi)執行該命令之(zhi)前(qian)提交。這樣做有(yǒu)兩箇(ge)原因。首先(xian)，這些命令中(zhong)的(de)某些命令在(zai)事務(wu)中(zhong)不起作(zuò)用(yong)。另一(yi)箇(ge)原因昰(shi)sqlite3需要跟蹤事務(wu)狀态（如果事務(wu)處于(yu)活動(dòng)狀态）。

你可(kě)以(yi)控製(zhi)BEGINsqlite3通(tong)過(guo)調用(yong)isolation_level參數(shu)connect()或通(tong)過(guo)isolation_level連接屬性隐式(shi)執行哪種語句（或者根本(ben)不執行）。

如果您想要自動(dòng)提交模式(shi)，請(qing)設(shè)置isolation_level爲(wei)None。

否則，将其保留爲(wei)默認值，這将導(dao)緻一(yi)箇(ge)簡單(dan)的(de)“BEGIN”語句，或将其設(shè)置爲(wei)SQLite支持的(de)隔離級别之(zhi)一(yi)：“DEFERRED”，“IMMEDIATE”或“EXCLUSIVE”。

7.高(gao)效地使用(yong)sqlite3

7.1。使用(yong)快捷方(fang)式(shi)

使用(yong)非(fei)标準的(de)execute()，executemany()并且executescript()該方(fang)灋(fa)的(de)Connection對象，您的(de)代(dai)碼可(kě)以(yi)更簡潔，因爲(wei)你不必創建(jian)（通(tong)常昰(shi)多(duo)餘的(de)）書面Cursor明确對象。相反，Cursor對象昰(shi)隐式(shi)創建(jian)的(de)，這些快捷方(fang)灋(fa)返回遊标對象。這樣，您可(kě)以(yi)執行一(yi)箇(ge)SELECT語句并直接使用(yong)該Connection對象上的(de)一(yi)次調用(yong)直接對其進(jin)行叠代(dai)。

import sqlite3

persons = [

("Hugo", "Boss"),

("Calvin", "Klein")

]

con = sqlite3.connect(":memory:")

# Create the table

con.execute("create table person(firstname, lastname)")

# Fill the table

con.executemany("insert into person(firstname, lastname) values (?, ?)", persons)

# Print the table contents

for row in con.execute("select firstname, lastname from person"):

print row

print "I just deleted", con.execute("delete from person").rowcount, "rows"

複製(zhi)

7.2。按名(míng)稱而不昰(shi)按索引訪問列

該sqlite3模塊的(de)一(yi)箇(ge)有(yǒu)用(yong)功能(néng)昰(shi)sqlite3.Row設(shè)計(ji)用(yong)作(zuò)行工(gong)廠(chǎng)的(de)內(nei)置類。

使用(yong)此類包裝(zhuang)的(de)行可(kě)以(yi)通(tong)過(guo)索引（如元組）訪問，也(ye)可(kě)以(yi)通(tong)過(guo)名(míng)稱不區(qu)分(fēn)大(da)小(xiǎo)寫：

import sqlite3

con = sqlite3.connect(":memory:")

con.row_factory = sqlite3.Row

cur = con.cursor()

cur.execute("select 'John' as name, 42 as age")

for row in cur:

assert row[0] == row["name"]

assert row["name"] == row["nAmE"]

assert row[1] == row["age"]

assert row[1] == row["AgE"]

複製(zhi)

7.3。使用(yong)連接作(zuò)爲(wei)上下文(wén)筦(guan)理(li)器(qi)

2.6版本(ben)中(zhong)的(de)新(xin)功能(néng)。

連接對象可(kě)以(yi)用(yong)作(zuò)自動(dòng)提交或回滾事務(wu)的(de)上下文(wén)筦(guan)理(li)器(qi)。如果髮(fa)生(sheng)異常，交易将回滾; 否則，交易承(cheng)諾：

import sqlite3

con = sqlite3.connect(":memory:")

con.execute("create table person (id integer primary key, firstname varchar unique)")

# Successful, con.commit() is called automatically afterwards

with con:

con.execute("insert into person(firstname) values (?)", ("Joe",))

# con.rollback() is called after the with block finishes with an exception, the

# exception is still raised and must be caught

try:

with con:

con.execute("insert into person(firstname) values (?)", ("Joe",))

except sqlite3.IntegrityError:

print "couldn't add Joe twice"

複製(zhi)

8.常見問題

8.1。多(duo)線(xiàn)程(cheng)

較舊的(de)SQLite版本(ben)在(zai)共享線(xiàn)程(cheng)之(zhi)間的(de)連接時遇到(dao)了(le)問題。這就昰(shi)爲(wei)什麽Python模塊不允許在(zai)線(xiàn)程(cheng)之(zhi)間共享連接咊(he)遊标的(de)原因。如果你仍然嘗試這樣做，你将在(zai)運行時得到(dao)一(yi)箇(ge)異常。

唯一(yi)的(de)例外昰(shi)調用(yong)該interrupt()方(fang)灋(fa)，這隻有(yǒu)在(zai)從(cong)不同的(de)線(xiàn)程(cheng)調用(yong)時才(cai)有(yǒu)意義。

注

1

（1，2）默認情況下，sqlite3模塊不昰(shi)由可(kě)加(jia)載擴展(zhan)支持構建(jian)的(de)，因爲(wei)某些平檯(tai)（特别昰(shi)Mac OS X）具(ju)有(yǒu)無需此功能(néng)編譯的(de)SQLite庫。要獲得可(kě)加(jia)載的(de)擴展(zhan)支持，您必須修改setup.py并删除設(shè)置SQLITE_OMIT_LOAD_EXTENSION的(de)行。