PostgreSQL C 教程 · ZetCode 中文系列教程

# PostgreSQL C 教程 > 原文： [http://zetcode.com/db/postgresqlc/](http://zetcode.com/db/postgresqlc/) 這是 PostgreSQL 數據庫的 C 編程教程。它涵蓋了使用 C API 進行 PostgreSQL 編程的基礎。 ## 關于 PostgreSQL 數據庫 PostgreSQL 是一個功能強大的開源對象關系數據庫系統。它是一個多用戶數據庫管理系統。它可以在多個平臺上運行，包括 Linux，FreeBSD，Solaris，Microsoft Windows 和 Mac OSX。PostgreSQL 由 PostgreSQL 全球開發小組開發。 PostgreSQL 具有復雜的功能，例如多版本并發控制（MVCC），時間點恢復，表空間，異步復制，嵌套事務（保存點），聯機/熱備份，復雜的查詢計劃程序/優化程序以及用于容錯的預寫日志記錄。它支持國際字符集，多字節字符編碼，Unicode，并且對于排序，區分大小寫和格式具有區域設置意識。 ## 安裝我們將安裝 PostgreSQL 數據庫和 C 開發庫。 ```c $ sudo apt-get install postgresql ``` 在基于 Debian 的系統上，我們可以使用上述命令從包中安裝 PostgreSQL 數據庫。 ```c $ sudo update-rc.d -f postgresql remove Removing any system startup links for /etc/init.d/postgresql ... /etc/rc0.d/K21postgresql /etc/rc1.d/K21postgresql /etc/rc2.d/S19postgresql /etc/rc3.d/S19postgresql /etc/rc4.d/S19postgresql /etc/rc5.d/S19postgresql /etc/rc6.d/K21postgresql ``` 如果我們從包中安裝 PostgreSQL 數據庫，它將自動添加到操作系統的啟動腳本中。如果我們僅學習使用數據庫，則不必在每次引導系統時都啟動數據庫。上面的命令刪除 PostgreSQL 數據庫的所有系統啟動鏈接。 ```c $ sudo apt-get install libpq-dev ``` 為了能夠編譯 C 示例，我們需要安裝 PostgreSQL C 開發庫。上面的行顯示了我們如何在基于 Debian 的 Linux 上做到這一點。 ```c $ sudo -u postgres psql postgres psql (9.3.9) Type "help" for help. postgres=# \password postgres ``` 我們為`postgres`用戶設置了密碼。 ## 啟動和停止 PostgreSQL 在下一節中，我們將展示如何啟動 PostgreSQL 數據庫，停止它以及查詢它的狀態。 ```c $ sudo service postgresql start * Starting PostgreSQL 9.3 database server [ OK ] ``` 在基于 Debian 的 Linux 上，我們可以使用`service postgresql start`命令啟動服務器。 ```c $ sudo service postgresql status 9.3/main (port 5432): online ``` 我們使用`service postgresql status`命令檢查 PostgreSQL 是否正在運行。 ```c $ sudo service postgresql stop * Stopping PostgreSQL 9.3 database server [ OK ] ``` 我們使用`service postgresql stop`命令停止 PostgreSQL。 ```c $ service postgresql status 9.3/main (port 5432): down ``` 此時，`service postgresql status`命令報告 PostgreSQL 數據庫已關閉。 ## 創建用戶和數據庫在以下步驟中，我們將創建一個新的數據庫用戶和數據庫。 ```c $ sudo -u postgres createuser janbodnar ``` 我們在 PostgreSQL 系統中創建了一個新角色。我們允許它具有創建新數據庫的能力。角色是數據庫世界中的用戶。角色與操作系統用戶是分開的。 ```c $ sudo -u postgres psql postgres psql (9.3.9) Type "help" for help. postgres=# ALTER USER janbodnar WITH password 'pswd37'; ALTER ROLE postgres=# \q ``` 使用`psql`命令，為新用戶添加密碼。 PostgreSQL 通常在本地連接上使用信任或對等認證策略。在信任認證策略的情況下，PostgreSQL 假定可以連接到服務器的任何人都可以使用他們指定的任何數據庫用戶名（甚至超級用戶名）訪問數據庫。與數據庫建立連接時，不需要密碼。（在數據庫和用戶列中所做的限制仍然適用。）信任認證對于單用戶工作站上的本地連接是適當的，并且非常方便。它通常不適用于多用戶計算機。如果使用對等認證策略，則數據庫用戶名必須與操作系統用戶名匹配。 ```c $ sudo -u postgres createdb testdb --owner janbodnar ``` 使用`createdb`命令，我們創建了一個名為`testdb`的新數據庫。它的所有者是新的數據庫用戶。 ## C99 本教程使用 C99。對于 GNU C 編譯器，我們需要添加`-std=c99`選項。對于 Windows 用戶，強烈建議使用 Pelles C IDE。（MSVC 不支持 C99。） ```c PGconn *conn = PQconnectdb("user=janbodnar dbname=testdb"); ``` 在 C99 中，我們可以將聲明與代碼混合使用。在較早的 C 程序中，我們需要將這一行分成兩行。 ```c for(int i=0; i<rows; i++) { ``` 我們還可以將初始化用于循環聲明。 ## libpq 庫 `libpq`庫是 PostgreSQL 的 C 接口。它是一組庫函數，允許客戶端程序與 PostgreSQL 交互。它也是其他 PostgreSQL 應用接口的基礎引擎，包括為 C++ ，Perl，PHP，Ruby，Python 和 Tcl 編寫的接口。 `lib_version.c` ```c #include <stdio.h> #include <libpq-fe.h> int main() { int lib_ver = PQlibVersion(); printf("Version of libpq: %d\n", lib_ver); return 0; } ``` 該程序將打印`libpq`庫的版本。 ```c #include <libpq-fe.h> ``` `libpq-fe.h`文件包含 C 編程接口的枚舉，結構，常量和函數的定義。 ```c int lib_ver = PQlibVersion(); ``` `PQlibVersion()`函數返回正在使用的`libpq`的版本。 ```c $ pg_config --includedir /usr/include/postgresql $ pg_config --libdir /usr/lib ``` `pg_config`工具用于查找 C 頭文件和目標代碼庫的位置。 ```c $ gcc -o lib_version lib_version.c -I/usr/include/postgresql -lpq -std=c99 ``` 使用上面的命令，我們編譯程序。 ```c $ ./lib_version Version of libpq: 90309 ``` 該庫的版本是 9.3.9。 ## 服務器版本在下面的示例中，我們找到了 PostgreSQL 數據庫的版本。 `server_version.c` ```c #include <stdio.h> #include <stdlib.h> #include <libpq-fe.h> void do_exit(PGconn *conn) { PQfinish(conn); exit(1); } int main() { PGconn *conn = PQconnectdb("user=janbodnar dbname=testdb"); if (PQstatus(conn) == CONNECTION_BAD) { fprintf(stderr, "Connection to database failed: %s\n", PQerrorMessage(conn)); do_exit(conn); } int ver = PQserverVersion(conn); printf("Server version: %d\n", ver); PQfinish(conn); return 0; } ``` 該示例連接到 PostgreSQL 數據庫，執行`PQserverVersion()`函數，打印版本，關閉連接，然后清除。 ```c ... # TYPE DATABASE USER ADDRESS METHOD # "local" is for Unix domain socket connections only local all all peer ... ``` 在`pg_hba.conf`中，我們具有`peer`默認認證方法。在這種方法中，數據庫用戶名必須與操作系統用戶名匹配。無需密碼即可建立連接。 ```c PGconn *conn = PQconnectdb("user=janbodnar dbname=testdb"); ``` 使用`PQconnectdb()`函數，我們可以連接數據庫。在連接字符串中，我們提供用戶名和數據庫名。 ```c if (PQstatus(conn) == CONNECTION_BAD) { fprintf(stderr, "Connection to database failed: %s", PQerrorMessage(conn)); do_exit(conn); } ``` `PQstatus()`函數返回連接狀態。如果連接成功，則返回`CONNECTION_OK`；對于不成功的連接，返回`CONNECTION_BAD`。 `PQerrorMessage()`返回最近生成的錯誤消息。 ```c int ver = PQserverVersion(conn); ``` `PQserverVersion()`函數返回一個表示 PostgreSQL 數據庫版本的整數。它以連接對象為參數。 ```c PQfinish(conn); ``` `PQfinish()`函數關閉與服務器的連接，并釋放`PGconn`對象使用的內存。 ```c $ ./server_version Server version: 90309 ``` 運行程序，我們獲得數據庫服務器版本。 ## 密碼認證接下來，我們將使用密碼對數據庫服務器進行認證。在本教程的所有其他示例中，我們假設使用`peer`或`trust`認證模式。我們將`pg_hba.conf`文件中本地連接的認證類型更改為`md5`。 ```c $ sudo service postgresql restart ``` 要應用更改，必須重新啟動數據庫服務器。 `password_authentication.c` ```c #include <stdio.h> #include <stdlib.h> #include <libpq-fe.h> void do_exit(PGconn *conn) { PQfinish(conn); exit(1); } int main() { PGconn *conn = PQconnectdb("user=janbodnar password=pswd37 dbname=testdb"); if (PQstatus(conn) == CONNECTION_BAD) { fprintf(stderr, "Connection to database failed: %s\n", PQerrorMessage(conn)); do_exit(conn); } char *user = PQuser(conn); char *db_name = PQdb(conn); char *pswd = PQpass(conn); printf("User: %s\n", user); printf("Database name: %s\n", db_name); printf("Password: %s\n", pswd); PQfinish(conn); return 0; } ``` 在示例中，我們使用密碼連接到數據庫。我們打印用戶名，數據庫名稱和當前數據庫連接的密碼。 ```c PGconn *conn = PQconnectdb("user=janbodnar password=pswd37 dbname=testdb"); ``` 在連接字符串中，我們添加了密碼選項。 ```c char *user = PQuser(conn); ``` `PQuser()`函數返回連接的用戶名。 ```c char *db_name = PQdb(conn); ``` `PQdb()`函數返回連接的數據庫名稱。 ```c char *pswd = PQpass(conn); ``` `PQpass()`函數返回連接的密碼。 ```c $ ./password_authentication User: janbodnar Database name: testdb Password: pswd37 ``` 該程序將打印數據庫用戶，數據庫名稱和使用的密碼。 ## 創建數據庫表在本節中，我們將創建一個數據庫表并用數據填充它。 `create_table.c` ```c #include <stdio.h> #include <stdlib.h> #include <libpq-fe.h> void do_exit(PGconn *conn, PGresult *res) { fprintf(stderr, "%s\n", PQerrorMessage(conn)); PQclear(res); PQfinish(conn); exit(1); } int main() { PGconn *conn = PQconnectdb("user=janbodnar dbname=testdb"); if (PQstatus(conn) == CONNECTION_BAD) { fprintf(stderr, "Connection to database failed: %s\n", PQerrorMessage(conn)); PQfinish(conn); exit(1); } PGresult *res = PQexec(conn, "DROP TABLE IF EXISTS Cars"); if (PQresultStatus(res) != PGRES_COMMAND_OK) { do_exit(conn, res); } PQclear(res); res = PQexec(conn, "CREATE TABLE Cars(Id INTEGER PRIMARY KEY," \ "Name VARCHAR(20), Price INT)"); if (PQresultStatus(res) != PGRES_COMMAND_OK) { do_exit(conn, res); } PQclear(res); res = PQexec(conn, "INSERT INTO Cars VALUES(1,'Audi',52642)"); if (PQresultStatus(res) != PGRES_COMMAND_OK) do_exit(conn, res); PQclear(res); res = PQexec(conn, "INSERT INTO Cars VALUES(2,'Mercedes',57127)"); if (PQresultStatus(res) != PGRES_COMMAND_OK) { do_exit(conn, res); } PQclear(res); res = PQexec(conn, "INSERT INTO Cars VALUES(3,'Skoda',9000)"); if (PQresultStatus(res) != PGRES_COMMAND_OK) { do_exit(conn, res); } PQclear(res); res = PQexec(conn, "INSERT INTO Cars VALUES(4,'Volvo',29000)"); if (PQresultStatus(res) != PGRES_COMMAND_OK) { do_exit(conn, res); } PQclear(res); res = PQexec(conn, "INSERT INTO Cars VALUES(5,'Bentley',350000)"); if (PQresultStatus(res) != PGRES_COMMAND_OK) { do_exit(conn, res); } PQclear(res); res = PQexec(conn, "INSERT INTO Cars VALUES(6,'Citroen',21000)"); if (PQresultStatus(res) != PGRES_COMMAND_OK) { do_exit(conn, res); } PQclear(res); res = PQexec(conn, "INSERT INTO Cars VALUES(7,'Hummer',41400)"); if (PQresultStatus(res) != PGRES_COMMAND_OK) { do_exit(conn, res); } PQclear(res); res = PQexec(conn, "INSERT INTO Cars VALUES(8,'Volkswagen',21600)"); if (PQresultStatus(res) != PGRES_COMMAND_OK) { do_exit(conn, res); } PQclear(res); PQfinish(conn); return 0; } ``` 創建的表稱為`Cars`，它具有三列：ID，汽車名稱及其價格。 ```c PGresult *res = PQexec(conn, "DROP TABLE IF EXISTS Cars"); ``` `PQexec()`函數將 SQL 命令提交到服務器并等待結果。 `PGresult`封裝了查詢結果。如果表已經存在，我們的 SQL 命令將刪除該表。 ```c if (PQresultStatus(res) != PGRES_COMMAND_OK) { do_exit(conn, res); } ``` 應該調用`PQresultStatus()`函數以檢查返回值是否有任何錯誤。如果命令已正確執行且未返回數據，則返回`PGRES_COMMAND_OK`。 ```c PQclear(res); ``` 當不再需要每個命令結果時，應使用`PQclear()`函數將其釋放。 ```c $ ./create_table $ psql testdb psql (9.3.9) Type "help" for help. testdb=> SELECT * FROM Cars; id | name | price ----+------------+-------- 1 | Audi | 52642 2 | Mercedes | 57127 3 | Skoda | 9000 4 | Volvo | 29000 5 | Bentley | 350000 6 | Citroen | 21000 7 | Hummer | 41400 8 | Volkswagen | 21600 (8 rows) ``` 我們執行程序，并使用`psql`工具驗證創建的表。 ## 簡單查詢在本節中，我們執行一個簡單的查詢命令。 `query_version.c` ```c #include <stdio.h> #include <stdlib.h> #include <libpq-fe.h> void do_exit(PGconn *conn) { PQfinish(conn); exit(1); } int main() { PGconn *conn = PQconnectdb("user=janbodnar dbname=testdb"); if (PQstatus(conn) == CONNECTION_BAD) { fprintf(stderr, "Connection to database failed: %s\n", PQerrorMessage(conn)); do_exit(conn); } PGresult *res = PQexec(conn, "SELECT VERSION()"); if (PQresultStatus(res) != PGRES_TUPLES_OK) { printf("No data retrieved\n"); PQclear(res); do_exit(conn); } printf("%s\n", PQgetvalue(res, 0, 0)); PQclear(res); PQfinish(conn); return 0; } ``` 該示例獲取數據庫服務器的版本。 ```c PGresult *res = PQexec(conn, "SELECT VERSION()"); ``` `SELECT VERSION()` SQL 語句檢索數據庫的版本。 ```c if (PQresultStatus(res) != PGRES_TUPLES_OK) { printf("No data retrieved\n"); PQclear(res); do_exit(conn); } ``` 對于通過`PQresultStatus()`函數返回數據的查詢，返回`PGRES_TUPLES_OK`。 ```c printf("%s\n", PQgetvalue(res, 0, 0)); ``` `PQgetvalue()`函數返回`PGresult`的一行的單個字段值。 ```c $ ./query_version PostgreSQL 9.3.9 on x86_64-unknown-linux-gnu, compiled by gcc (Ubuntu 4.8.4-2ubuntu1~14.04) 4.8.4, 64-bit ``` 程序將打印此輸出。 ## 檢索多行數據以下示例執行一個查詢，該查詢返回多行數據。 `multiple_rows.c` ```c #include <stdio.h> #include <stdlib.h> #include <libpq-fe.h> void do_exit(PGconn *conn) { PQfinish(conn); exit(1); } int main() { PGconn *conn = PQconnectdb("user=janbodnar dbname=testdb"); if (PQstatus(conn) == CONNECTION_BAD) { fprintf(stderr, "Connection to database failed: %s\n", PQerrorMessage(conn)); do_exit(conn); } PGresult *res = PQexec(conn, "SELECT * FROM Cars LIMIT 5"); if (PQresultStatus(res) != PGRES_TUPLES_OK) { printf("No data retrieved\n"); PQclear(res); do_exit(conn); } int rows = PQntuples(res); for(int i=0; i<rows; i++) { printf("%s %s %s\n", PQgetvalue(res, i, 0), PQgetvalue(res, i, 1), PQgetvalue(res, i, 2)); } PQclear(res); PQfinish(conn); return 0; } ``` 該程序將打印`Cars`表的前五行的數據。 ```c PGresult *res = PQexec(conn, "SELECT * FROM Cars LIMIT 5"); ``` 此 SQL 查詢返回五行數據。 ```c int rows = PQntuples(res); ``` `PQntuples()`返回查詢結果中的行數。 ```c for(int i=0; i<rows; i++) { printf("%s %s %s\n", PQgetvalue(res, i, 0), PQgetvalue(res, i, 1), PQgetvalue(res, i, 2)); } ``` 在`for`循環中，使用`PQgetvalue()`函數獲得一行的所有三個字段。 ```c $ ./multiple_rows 1 Audi 52642 2 Mercedes 57127 3 Skoda 9000 4 Volvo 29000 5 Bentley 350000 ``` 這是`multiple_rows`程序的輸出。 ## 預備語句預備語句可防止 SQL 注入并提高性能。在使用預備語句時，我們使用占位符，而不是直接將值寫入語句中。 `prepared_statement.c` ```c #include <stdio.h> #include <stdlib.h> #include <libpq-fe.h> void do_exit(PGconn *conn) { PQfinish(conn); exit(1); } int main(int argc, char *argv[]) { const int LEN = 10; const char *paramValues[1]; if (argc != 2) { fprintf(stderr, "Usage: prepared_statement rowId\n"); exit(1); } int rowId; int ret = sscanf(argv[1], "%d", &rowId); if (ret != 1) { fprintf(stderr, "The argument must be an integer\n"); exit(1); } if (rowId < 0) { fprintf(stderr, "Error passing a negative rowId\n"); exit(1); } char str[LEN]; snprintf(str, LEN, "%d", rowId); paramValues[0] = str; PGconn *conn = PQconnectdb("user=janbodnar dbname=testdb"); if (PQstatus(conn) == CONNECTION_BAD) { fprintf(stderr, "Connection to database failed: %s\n", PQerrorMessage(conn)); do_exit(conn); } char *stm = "SELECT * FROM Cars WHERE Id=$1"; PGresult *res = PQexecParams(conn, stm, 1, NULL, paramValues, NULL, NULL, 0); if (PQresultStatus(res) != PGRES_TUPLES_OK) { printf("No data retrieved\n"); PQclear(res); do_exit(conn); } printf("%s %s %s\n", PQgetvalue(res, 0, 0), PQgetvalue(res, 0, 1), PQgetvalue(res, 0, 2)); PQclear(res); PQfinish(conn); return 0; } ``` 該程序將一個行 ID 作為其參數。它獲取指定行的數據并進行打印。由于該程序從用戶那里獲取了一個不可信任的值，因此我們必須清除輸入數據。使用`PQexecParams()`函數創建一個預備語句。 ```c int rowId; int ret = sscanf(argv[1], "%d", &rowId); ``` 命令行參數存儲在`rowId`變量中。我們期望一個整數值。 ```c char str[LEN]; snprintf(str, LEN, "%d", rowId); paramValues[0] = str; ``` 該值將轉換為字符串，然后傳遞給字符數組。 `paramValues`是`PQexecParams()`函數的參數。 ```c char *stm = "SELECT * FROM Cars WHERE Id=$1"; ``` 這是我們的 SQL 語句，它返回`Cars`表的一行。 `$1`是一個占位符，稍后會用實際值填充。 ```c PGresult *res = PQexecParams(conn, stm, 1, NULL, paramValues, NULL, NULL, 0); ``` `PQexecParams()`函數創建一個預備語句并執行它。第二個參數是 SQL 語句。第三個參數是傳遞的參數數。將`NULL`傳遞給第四個參數意味著服務器應確定參數類型。第五個參數是指向包含參數的字符串數組的指針。接下來的兩個參數僅與二進制參數相關。將 0 傳遞給最終參數，我們以文本格式獲得結果，以二進制格式獲得 1。 ```c printf("%s %s %s\n", PQgetvalue(res, 0, 0), PQgetvalue(res, 0, 1), PQgetvalue(res, 0, 2)); ``` 我們打印指定行的三個字段。 ```c $ ./prepared_statement 4 4 Volvo 29000 ``` 這是示例的輸出。 ## 元數據元數據是有關數據庫中數據的信息。以下內容屬于元數據：有關存儲數據的表和列的信息，受 SQL 語句影響的行數或結果集中返回的行和列數。 ### 列標題在第一個示例中，我們打印列標題。 `column_headers.c` ```c #include <stdio.h> #include <stdlib.h> #include <libpq-fe.h> void do_exit(PGconn *conn) { PQfinish(conn); exit(1); } int main() { PGconn *conn = PQconnectdb("user=janbodnar dbname=testdb"); if (PQstatus(conn) == CONNECTION_BAD) { fprintf(stderr, "Connection to database failed: %s\n", PQerrorMessage(conn)); do_exit(conn); } PGresult *res = PQexec(conn, "SELECT * FROM Cars WHERE Id=0"); if (PQresultStatus(res) != PGRES_TUPLES_OK) { printf("No data retrieved\n"); PQclear(res); do_exit(conn); } int ncols = PQnfields(res); printf("There are %d columns\n", ncols); printf("The column names are:\n"); for (int i=0; i<ncols; i++) { char *name = PQfname(res, i); printf("%s\n", name); } PQclear(res); PQfinish(conn); return 0; } ``` 該示例將可用列的數量及其名稱打印到控制臺。 ```c PGresult *res = PQexec(conn, "SELECT * FROM Cars WHERE Id=0"); ``` 在 SQL 語句中，我們選擇一行的所有列。 ```c int ncols = PQnfields(res); ``` `PQnfields`函數返回查詢結果行中的列數。 ```c char *name = PQfname(res, i); ``` `PQfname()`函數返回與給定列號關聯的列名。 ```c $ ./column_headers There are 3 columns The column names are: id name price ``` 這是示例的輸出。 ### 表的清單 PostgreSQL 的信息模式由一組視圖組成，這些視圖包含有關當前數據庫中定義的對象的信息。 `tables`視圖包含當前數據庫中定義的所有表和視圖。 `list_tables.c` ```c #include <stdio.h> #include <stdlib.h> #include <libpq-fe.h> void do_exit(PGconn *conn) { PQfinish(conn); exit(1); } int main() { PGconn *conn = PQconnectdb("user=janbodnar dbname=testdb"); if (PQstatus(conn) == CONNECTION_BAD) { fprintf(stderr, "Connection to database failed: %s\n", PQerrorMessage(conn)); do_exit(conn); } PGresult *res = PQexec(conn, "SELECT table_name FROM information_schema.tables " "WHERE table_schema = 'public'"); if (PQresultStatus(res) != PGRES_TUPLES_OK) { printf("No data retrieved\n"); PQclear(res); do_exit(conn); } int rows = PQntuples(res); for(int i=0; i<rows; i++) { printf("%s\n", PQgetvalue(res, i, 0)); } PQclear(res); PQfinish(conn); return 0; } ``` 該示例打印`testdb`數據庫中的所有表。 ```c PGresult *res = PQexec(conn, "SELECT table_name FROM information_schema.tables " "WHERE table_schema = 'public'"); ``` 該 SQL 語句從當前數據庫中選擇所有表。 ```c int rows = PQntuples(res); for(int i=0; i<rows; i++) { printf("%s\n", PQgetvalue(res, i, 0)); } ``` 表將打印到控制臺。 ```c $ ./list_tables cars authors books ``` `list_tables`程序在`testdb`數據庫中打印可用表。 ## 事務事務是針對一個或多個數據庫中數據的數據庫操作的基本單位。事務中的 SQL 語句可以全部提交給數據庫，也可以全部回滾。為了數據安全和完整性，將 SQL 語句放入事務中。 PostgreSQL 在自動提交模式下運行。每個 SQL 語句都在一個事務中執行：每個單獨的語句周圍都包含一個隱式`BEGIN`和（如果成功）`COMMIT`。顯式事務以`BEGIN`命令開始，以`COMMIT`命令結束。 `transaction.c` ```c #include <stdio.h> #include <stdlib.h> #include <libpq-fe.h> void do_exit(PGconn *conn) { PQfinish(conn); exit(1); } int main() { PGconn *conn = PQconnectdb("user=janbodnar dbname=testdb"); if (PQstatus(conn) == CONNECTION_BAD) { fprintf(stderr, "Connection to database failed: %s\n", PQerrorMessage(conn)); do_exit(conn); } PGresult *res = PQexec(conn, "BEGIN"); if (PQresultStatus(res) != PGRES_COMMAND_OK) { printf("BEGIN command failed\n"); PQclear(res); do_exit(conn); } PQclear(res); res = PQexec(conn, "UPDATE Cars SET Price=23700 WHERE Id=8"); if (PQresultStatus(res) != PGRES_COMMAND_OK) { printf("UPDATE command failed\n"); PQclear(res); do_exit(conn); } res = PQexec(conn, "INSERT INTO Cars VALUES(9,'Mazda',27770)"); if (PQresultStatus(res) != PGRES_COMMAND_OK) { printf("INSERT command failed\n"); PQclear(res); do_exit(conn); } res = PQexec(conn, "COMMIT"); if (PQresultStatus(res) != PGRES_COMMAND_OK) { printf("COMMIT command failed\n"); PQclear(res); do_exit(conn); } PQclear(res); PQfinish(conn); return 0; } ``` 在示例中，我們更新了汽車的價格并插入了新汽車。這兩個操作包含在單個事務中。這意味著要么執行兩個操作，要么不執行任何操作。 ```c PGresult *res = PQexec(conn, "BEGIN"); ``` 使用`BEGIN`命令開始事務。 ```c res = PQexec(conn, "UPDATE Cars SET Price=23700 WHERE Id=8"); ``` 我們使用 ID 8 更新汽車的價格。 ```c res = PQexec(conn, "INSERT INTO Cars VALUES(9,'Mazda',27770)"); ``` 將新車插入`Cars`表。 ```c res = PQexec(conn, "COMMIT"); ``` 使用`COMMIT`命令提交事務。 [Tweet](https://twitter.com/share) 這是 PostgreSQL C API 教程。您可能也對 ZetCode 上的 [PostgreSQL Python 教程](/db/postgresqlpythontutorial/)， [PostgreSQL PHP 教程](/db/postgresqlphp/)， [SQLite C 教程](/db/sqlitec/)或 [MySQL C 教程](/db/mysqlc/)感興趣。