PostgreSQL 教程

Appearance

36.2. 管理数据库连接# ​

36.2.1. 连接到数据库服务器
36.2.2. 选择连接
36.2.3. 关闭连接

本节介绍如何打开、关闭和切换数据库连接。

36.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识别的关键字相同（请参阅第 34.1.2 节）。任何keyword或value之前都会忽略空格，但不会在其中或之后忽略空格。请注意，没有办法在value*中编写&。

请注意，在指定套接字连接（使用unix:前缀）时，主机名必须完全为localhost。要选择非默认套接字目录，请将目录的路径名写入目标的*options*部分中host选项的值。

*connection-name*用于在一个程序中处理多个连接。如果程序只使用一个连接，则可以省略它。最近打开的连接将成为当前连接，在执行 SQL 语句时默认使用它（请参阅本章后面的内容）。

以下是CONNECT语句的一些示例

EXEC SQL CONNECT TO [email protected];

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

EXEC SQL BEGIN DECLARE SECTION;
const char *target = "[email protected]";
const char *user = "john";
const char *passwd = "secret";
EXEC SQL END DECLARE SECTION;
 ...
EXEC SQL CONNECT TO :target USER :user USING :passwd;
/* or EXEC SQL CONNECT TO :target USER :user/:passwd; */

最后一个示例使用了上面提到的字符变量引用功能。您将在后面的章节中了解如何在 SQL 语句中使用 C 变量，方法是在它们前面加上冒号。

请注意，连接目标的格式未在 SQL 标准中指定。因此，如果您想开发可移植的应用程序，您可能希望使用基于上述最后一个示例的内容来封装连接目标字符串。

如果不受信任的用户可以访问尚未采用安全模式使用模式的数据库，请在每个会话开始时从search_path中删除可公开写入的模式。例如，将options=-c search_path=添加到*options*，或在连接后发出EXEC SQL SELECT pg_catalog.set_config('search_path', '', false);。此注意事项不特定于 ECPG；它适用于执行任意 SQL 命令的每个接口。

36.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;

    /* This query would be executed in the last opened database "testdb3". */
    EXEC SQL SELECT current_database() INTO :dbname;
    printf("current=%s (should be testdb3)\n", dbname);

    /* Using "AT" to run a query in "testdb2" */
    EXEC SQL AT con2 SELECT current_database() INTO :dbname;
    printf("current=%s (should be testdb2)\n", dbname);

    /* Switch the current connection to "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

36.2.3. 关闭连接# ​

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

EXEC SQL DISCONNECT [connection];

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

  • connection-name
  • CURRENT
  • ALL

如果没有指定连接名称，则关闭当前连接。

一个好的风格是应用程序始终显式断开与它打开的每个连接。