↑↓ 选择↵ 打开⌫ 切换范围完整搜索

PG.CENTER 连接 PostgreSQL 文档、百科与生态知识。由 Pigsty 维护。

支持中的版本: 当前版本 (18) / 17 / 16 / 15 / 14
开发中的版本: 19 / 20devel
已结束支持的版本: 13 / 12 / 11 / 10 / 9.6 / 9.5 / 9.4 / 9.3 / 9.2 / 9.1 / 9.0 / 8.4 / 8.3 / 8.2 / 8.1 / 8.0 / 7.4 / 7.3
开发快照。 PostgreSQL 20devel 尚未正式发布,内容仍可能变化。

34.2. 管理数据库连接 #

这一节描述如何打开、关闭以及切换数据库连接。

34.2.1. 连接到数据库服务器 #

我们可以使用下列语句连接到一个数据库:

EXEC SQL CONNECT TO target [AS connection-name] [USER user-name];

target 可以用下列方法指定:

  • dbname[@hostname][:port]
  • tcp:postgresql://hostname[:port][/dbname][?options]
  • unix:postgresql://localhost[:port][/dbname][?options]
  • 包含上述某种形式的 SQL 字符串常量
  • 对包含上述某种形式的字符变量的引用(见示例)
  • DEFAULT

连接目标 DEFAULT 会以默认用户名发起一个到默认数据库的连接。在那种情况中不能指定单独的用户名或连接名。

如果你直接指定连接目标(也就是说,不是字符串常量或变量引用),那么目标中的各个组成部分都会经过常规 SQL 解析;这意味着,例如,hostname 必须看起来像一个或多个由点分隔的 SQL 标识符,并且这些标识符在未加双引号时会被折叠大小写。任何 options 的值都必须是 SQL 标识符、整数或变量引用。当然,你可以用双引号把几乎任何内容放到 SQL 标识符中。在实践中,使用字符串常量(单引号)或变量引用通常比直接写连接目标更不容易出错。

也有不同的方法来指定用户名:

  • username
  • username/password
  • username IDENTIFIED BY password
  • username USING password

如上所述,参数 username 以及 password 可以是一个 SQL 标识符、一个 SQL 字符串常量或者一个对字符变量的引用。

如果连接目标包含 options,那么它们由若干个 keyword=value 项组成,彼此之间用和号(&)分隔。允许的关键字与 libpq 识别的关键字相同(见第 32.1.2 节)。在任何 keyword 或 value 之前的空格将被忽略,但其中或之后则不会。请注意,无法将& 写入 value。

注意,当指定套接字连接(带有 unix:前缀)时,主机名必须严格写成 localhost。如果要选择非默认的套接字目录,可在目标的 options 部分中,把目录路径写成 host 选项的值。

connection-name 被用来在一个程序中处理多个连接。如果一个程序只使用一个连接,则可以省略它。最近被打开的连接将成为当前连接,当一个 SQL 语句要被执行时,将默认使用它(见这一章稍后的部分)。

这里有一些 CONNECT 语句的例子:

EXEC SQL CONNECT TO mydb@sql.mydomain.com;

EXEC SQL CONNECT TO tcp:postgresql://sql.mydomain.com/mydb AS myconnection USER john;

EXEC SQL BEGIN DECLARE SECTION;
const char *target = "mydb@sql.mydomain.com";
const char *user = "john";
const char *passwd = "secret";
EXEC SQL END DECLARE SECTION;
 ...
EXEC SQL CONNECT TO :target USER :user USING :passwd;
/* 或者 EXEC SQL CONNECT TO :target USER :user/:passwd; */

最后一个示例使用了上文所说的字符变量引用特性。后面的各节会展示如何通过在 C 变量前加上冒号,把它们用于 SQL 语句中。

请注意,连接目标的格式并未在 SQL 标准中规定。因此,如果你想开发可移植的应用,最好采用类似上面最后一个示例的方法,把连接目标字符串封装在某个地方。

如果不受信任的用户可以访问某个尚未采用模式的安全使用方式的数据库,那么每个会话开始时都应先从 search_path 中移除公共可写模式。例如,可以把 options=-c search_path=加到 options 中,或在连接后执行 EXEC SQL SELECT pg_catalog.set_config('search_path', '', false);。这一注意事项并非 ECPG 独有;它适用于所有能执行任意 SQL 命令的接口。

34.2.2. 选择一个连接 #

嵌入式 SQL 程序中的 SQL 语句默认是在当前连接(也就是最近打开的那一个)上执行的。如果一个应用需要管理多个连接,那么有三种方法来处理这种需求。

第一种方式是显式地为每一个 SQL 语句选择一个连接,例如:

EXEC SQL AT connection-name SELECT ...;

如果应用需要以混合的顺序使用多个连接,这种方式特别合适。

如果你的应用使用多个线程执行,它们不能并发地共享一个连接。你必须显式地控制对连接的访问(使用互斥量)或者为每个线程使用一个连接。

第二种方式是执行一个语句来切换当前的连接。该语句是:

EXEC SQL SET CONNECTION connection-name;

如果有很多语句要在同一个连接上执行,这种方式尤其方便。

这里有一个管理多个数据库连接的例子程序:

#include <stdio.h>

EXEC SQL BEGIN DECLARE SECTION;
    char dbname[1024];
EXEC SQL END DECLARE SECTION;

int
main()
{
    EXEC SQL CONNECT TO testdb1 AS con1 USER testuser;
    EXEC SQL SELECT pg_catalog.set_config('search_path', '', false); EXEC SQL COMMIT;
    EXEC SQL CONNECT TO testdb2 AS con2 USER testuser;
    EXEC SQL SELECT pg_catalog.set_config('search_path', '', false); EXEC SQL COMMIT;
    EXEC SQL CONNECT TO testdb3 AS con3 USER testuser;
    EXEC SQL SELECT pg_catalog.set_config('search_path', '', false); EXEC SQL COMMIT;

    /* 这个查询将在最近打开的数据库 "testdb3" 中执行。 */
    EXEC SQL SELECT current_database() INTO :dbname;
    printf("current=%s (should be testdb3)\n", dbname);

    /* 使用 "AT" 在 "testdb2" 中运行查询 */
    EXEC SQL AT con2 SELECT current_database() INTO :dbname;
    printf("current=%s (should be testdb2)\n", dbname);

    /* 将当前连接切换到 "testdb1"。 */
    EXEC SQL SET CONNECTION con1;

    EXEC SQL SELECT current_database() INTO :dbname;
    printf("current=%s (should be testdb1)\n", dbname);

    EXEC SQL DISCONNECT ALL;
    return 0;
}

这个例子将产生这样的输出:

current=testdb3 (should be testdb3)
current=testdb2 (should be testdb2)
current=testdb1 (should be testdb1)

第三种方式是声明一个与连接关联的 SQL 标识符,例如:

EXEC SQL AT connection-name DECLARE statement-name STATEMENT;
EXEC SQL PREPARE statement-name FROM :dyn-string;

一旦将某个 SQL 标识符关联到连接,就可以在不写 AT 子句的情况下执行动态 SQL。注意,这种方式的行为类似预处理器指令,因此这种关联只在当前文件中生效。

这里是一个用这种方式的示例程序:

#include <stdio.h>

EXEC SQL BEGIN DECLARE SECTION;
char dbname[128];
char *dyn_sql = "SELECT current_database()";
EXEC SQL END DECLARE SECTION;

int main(){
  EXEC SQL CONNECT TO postgres AS con1;
  EXEC SQL CONNECT TO testdb AS con2;
  EXEC SQL AT con1 DECLARE stmt STATEMENT;
  EXEC SQL PREPARE stmt FROM :dyn_sql;
  EXEC SQL EXECUTE stmt INTO :dbname;
  printf("%s\n", dbname);

  EXEC SQL DISCONNECT ALL;
  return 0;
}

这个示例会产生如下输出,即使默认连接是 testdb:

postgres

34.2.3. 关闭一个连接 #

要关闭连接,请使用以下语句:

EXEC SQL DISCONNECT [connection];

connection 可以通过以下方式指定:

  • connection-name
  • CURRENT
  • ALL

如果未指定连接名称,则关闭当前连接。

应用程序始终显式断开其打开的每个连接,是良好的编程习惯。

报告文档问题

阅读 上游文档. 反馈更正前请先核对 当前版本手册.