SQLite - Python



在本章中,您將學習如何在 Python 程式中使用 SQLite。

安裝

SQLite3 可以使用 sqlite3 模組與 Python 整合,該模組由 Gerhard Haring 編寫。它提供了一個符合 PEP 249 中描述的 DB-API 2.0 規範的 SQL 介面。您無需單獨安裝此模組,因為它預設隨 Python 2.5.x 及更高版本一起提供。

要使用 sqlite3 模組,您必須首先建立一個表示資料庫的連線物件,然後可以選擇建立一個遊標物件,這將幫助您執行所有 SQL 語句。

Python sqlite3 模組 API

以下是重要的 sqlite3 模組例程,可以滿足您從 Python 程式中使用 SQLite 資料庫的要求。如果您正在尋找更復雜的應用程式,那麼您可以檢視 Python sqlite3 模組的官方文件。

序號 API & 描述
1

sqlite3.connect(database [,timeout ,其他可選引數])

此 API 開啟到 SQLite 資料庫檔案的連線。您可以使用 ":memory:" 開啟到駐留在 RAM 而不是磁碟上的資料庫的資料庫連線。如果資料庫成功開啟,則返回一個連線物件。

當多個連線訪問資料庫,並且其中一個程序修改了資料庫時,SQLite 資料庫將被鎖定,直到該事務提交。timeout 引數指定連線應等待鎖消失多長時間,然後再引發異常。timeout 引數的預設值為 5.0(五秒)。

如果給定的資料庫名稱不存在,則此呼叫將建立資料庫。如果您希望在當前目錄之外的任何其他位置建立資料庫,則也可以指定帶有所需路徑的檔名。

2

connection.cursor([cursorClass])

此例程建立一個遊標,它將在您使用 Python 進行資料庫程式設計的整個過程中使用。此方法接受一個可選引數 cursorClass。如果提供,則它必須是一個擴充套件 sqlite3.Cursor 的自定義遊標類。

3

cursor.execute(sql [, 可選引數])

此例程執行 SQL 語句。SQL 語句可以是引數化的(即使用佔位符而不是 SQL 字面量)。sqlite3 模組支援兩種佔位符:問號和命名佔位符(命名樣式)。

例如 − cursor.execute("insert into people values (?, ?)", (who, age))

4

connection.execute(sql [, 可選引數])

此例程是遊標物件提供的上述 execute 方法的快捷方式,它透過呼叫 cursor 方法建立一箇中間遊標物件,然後使用給定的引數呼叫遊標的 execute 方法。

5

cursor.executemany(sql, seq_of_parameters)

此例程對序列 sql 中找到的所有引數序列或對映執行 SQL 命令。

6

connection.executemany(sql[, parameters])

此例程是一個快捷方式,它透過呼叫 cursor 方法建立一箇中間遊標物件,然後使用給定的引數呼叫 cursor.s executemany 方法。

7

cursor.executescript(sql_script)

此例程一次執行多個 SQL 語句,這些語句以指令碼的形式提供。它首先發出 COMMIT 語句,然後執行它作為引數獲取的 SQL 指令碼。所有 SQL 語句都應以分號 (;) 分隔。

8

connection.executescript(sql_script)

此例程是一個快捷方式,它透過呼叫 cursor 方法建立一箇中間遊標物件,然後使用給定的引數呼叫遊標的 executescript 方法。

9

connection.total_changes()

此例程返回自資料庫連線開啟以來已修改、插入或刪除的資料庫行的總數。

10

connection.commit()

此方法提交當前事務。如果您不呼叫此方法,則自上次呼叫 commit() 以來所做的任何操作都無法從其他資料庫連線中看到。

11

connection.rollback()

此方法回滾自上次呼叫 commit() 以來對資料庫所做的任何更改。

12

connection.close()

此方法關閉資料庫連線。請注意,這不會自動呼叫 commit()。如果您在不首先呼叫 commit() 的情況下關閉資料庫連線,則您的更改將丟失!

13

cursor.fetchone()

此方法獲取查詢結果集的下一行,返回單個序列,或者當沒有更多資料可用時返回 None。

14

cursor.fetchmany([size = cursor.arraysize])

此例程獲取查詢結果的下一組行,返回一個列表。當沒有更多行可用時,將返回一個空列表。該方法嘗試獲取與 size 引數指示的相同數量的行。

15

cursor.fetchall()

此例程獲取查詢結果的所有(剩餘)行,返回一個列表。當沒有行可用時,將返回一個空列表。

連線到資料庫

以下 Python 程式碼顯示瞭如何連線到現有資料庫。如果資料庫不存在,則將建立它,最後將返回一個數據庫物件。

#!/usr/bin/python

import sqlite3

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

print "Opened database successfully";

在這裡,您還可以將資料庫名稱作為特殊名稱:memory:提供,以在 RAM 中建立資料庫。現在,讓我們執行上述程式以在當前目錄中建立我們的資料庫test.db。您可以根據需要更改路徑。將上述程式碼儲存在 sqlite.py 檔案中並按如下所示執行它。如果資料庫成功建立,則它將顯示以下訊息。

$chmod +x sqlite.py
$./sqlite.py
Open database successfully

建立表

以下 Python 程式將用於在先前建立的資料庫中建立表。

#!/usr/bin/python

import sqlite3

conn = sqlite3.connect('test.db')
print "Opened database successfully";

conn.execute('''CREATE TABLE COMPANY
         (ID INT PRIMARY KEY     NOT NULL,
         NAME           TEXT    NOT NULL,
         AGE            INT     NOT NULL,
         ADDRESS        CHAR(50),
         SALARY         REAL);''')
print "Table created successfully";

conn.close()

執行上述程式時,它將在您的test.db中建立 COMPANY 表,並顯示以下訊息:

Opened database successfully
Table created successfully

INSERT 操作

以下 Python 程式顯示瞭如何在上面示例中建立的 COMPANY 表中建立記錄。

#!/usr/bin/python

import sqlite3

conn = sqlite3.connect('test.db')
print "Opened database successfully";

conn.execute("INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY) \
      VALUES (1, 'Paul', 32, 'California', 20000.00 )");

conn.execute("INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY) \
      VALUES (2, 'Allen', 25, 'Texas', 15000.00 )");

conn.execute("INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY) \
      VALUES (3, 'Teddy', 23, 'Norway', 20000.00 )");

conn.execute("INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY) \
      VALUES (4, 'Mark', 25, 'Rich-Mond ', 65000.00 )");

conn.commit()
print "Records created successfully";
conn.close()

執行上述程式時,它將在 COMPANY 表中建立給定的記錄,並顯示以下兩行:

Opened database successfully
Records created successfully

SELECT 操作

以下 Python 程式顯示瞭如何從上面示例中建立的 COMPANY 表中獲取和顯示記錄。

#!/usr/bin/python

import sqlite3

conn = sqlite3.connect('test.db')
print "Opened database successfully";

cursor = conn.execute("SELECT id, name, address, salary from COMPANY")
for row in cursor:
   print "ID = ", row[0]
   print "NAME = ", row[1]
   print "ADDRESS = ", row[2]
   print "SALARY = ", row[3], "\n"

print "Operation done successfully";
conn.close()

執行上述程式時,將產生以下結果。

Opened database successfully
ID = 1
NAME = Paul
ADDRESS = California
SALARY = 20000.0

ID = 2
NAME = Allen
ADDRESS = Texas
SALARY = 15000.0

ID = 3
NAME = Teddy
ADDRESS = Norway
SALARY = 20000.0

ID = 4
NAME = Mark
ADDRESS = Rich-Mond
SALARY = 65000.0

Operation done successfully

UPDATE 操作

以下 Python 程式碼顯示瞭如何使用 UPDATE 語句更新任何記錄,然後從 COMPANY 表中獲取和顯示更新後的記錄。

#!/usr/bin/python

import sqlite3

conn = sqlite3.connect('test.db')
print "Opened database successfully";

conn.execute("UPDATE COMPANY set SALARY = 25000.00 where ID = 1")
conn.commit()
print "Total number of rows updated :", conn.total_changes

cursor = conn.execute("SELECT id, name, address, salary from COMPANY")
for row in cursor:
   print "ID = ", row[0]
   print "NAME = ", row[1]
   print "ADDRESS = ", row[2]
   print "SALARY = ", row[3], "\n"

print "Operation done successfully";
conn.close()

執行上述程式時,將產生以下結果。

Opened database successfully
Total number of rows updated : 1
ID = 1
NAME = Paul
ADDRESS = California
SALARY = 25000.0

ID = 2
NAME = Allen
ADDRESS = Texas
SALARY = 15000.0

ID = 3
NAME = Teddy
ADDRESS = Norway
SALARY = 20000.0

ID = 4
NAME = Mark
ADDRESS = Rich-Mond
SALARY = 65000.0

Operation done successfully

DELETE 操作

以下 Python 程式碼顯示瞭如何使用 DELETE 語句刪除任何記錄,然後從 COMPANY 表中獲取和顯示剩餘的記錄。

#!/usr/bin/python

import sqlite3

conn = sqlite3.connect('test.db')
print "Opened database successfully";

conn.execute("DELETE from COMPANY where ID = 2;")
conn.commit()
print "Total number of rows deleted :", conn.total_changes

cursor = conn.execute("SELECT id, name, address, salary from COMPANY")
for row in cursor:
   print "ID = ", row[0]
   print "NAME = ", row[1]
   print "ADDRESS = ", row[2]
   print "SALARY = ", row[3], "\n"

print "Operation done successfully";
conn.close()

執行上述程式時,將產生以下結果。

Opened database successfully
Total number of rows deleted : 1
ID = 1
NAME = Paul
ADDRESS = California
SALARY = 20000.0

ID = 3
NAME = Teddy
ADDRESS = Norway
SALARY = 20000.0

ID = 4
NAME = Mark
ADDRESS = Rich-Mond
SALARY = 65000.0

Operation done successfully
廣告