Redrock Postgres 搜索 英文
版本: 9.3 / 9.4 / 9.5 / 9.6 / 10 / 11 / 12 / 13 / 14 / 15 / 16

35.2. 管理数据库连接

35.2.1. 连接到数据库服务器
35.2.2. 选择一个连接
35.2.3. 关闭一个连接

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

35.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://hostname[:port][/dbname][?options]
  • 一个包含上述形式之一的 SQL 字符串
  • 到一个包含上述形式之一(参见例子)的字符变量的引用
  • DEFAULT

如果你用字面(也就是不通过一个变量引用)指定连接目标并且你没有引用该值,那么将会应用普通 SQL 的大小写不敏感性规则。在那种情况中,你也能够按照需要单独将个体参数放置在双引号中。实际上,使用一个(单引号引用)的字符串或一个变量引用出错的可能性更小。连接目标DEFAULT会以默认用户名发起一个到默认数据库的连接。在那种情况中不能指定单独的用户名或连接名。

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

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

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

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

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

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

EXEC SQL CONNECT TO unix: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 标准中说明。因此如果你想要开发可移植的应用,你可能想要使用某种基于上述最后一个例子的方法来把连接目标字符串封装在某个地方。

35.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 CONNECT TO testdb2 AS con2 USER testuser;
    EXEC SQL CONNECT TO testdb3 AS con3 USER testuser;

    /* 这个查询将在最近打开的数据库 "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)

35.2.3. 关闭一个连接

要关闭一个连接,使用下列语句:

EXEC SQL DISCONNECT [connection];

connection可以用下列方法指定:

  • connection-name
  • DEFAULT
  • CURRENT
  • ALL

如果没有指定连接名,当前连接将被关闭。

在一个应用中总是显式地从它打开的每一个连接断开是一种好的风格。