这一节描述如何打开、关闭以及切换数据库连接。
使用以下语句连接数据库:
EXEC SQL CONNECT TOtarget[ASconnection-name] [USERuser-name];
其中,target 可以按以下方式指定:
dbname[@hostname][:port]tcp:postgresql://hostname[:port][/dbname][?options]unix:postgresql://hostname[:port][/dbname][?options]DEFAULT如果直接写出连接目标(即不通过变量引用),且未用引号括起该值,就会应用普通 SQL 的大小写不敏感规则。此时,也可以按需分别用双引号括起各个参数。实际使用中,采用单引号括起的字符串字面值或变量引用,可能更不容易出错。连接目标 DEFAULT 会以默认用户名发起到默认数据库的连接,此时不能单独指定用户名或连接名。
也有不同的方法来指定用户名:
usernameusername/passwordusername IDENTIFIED BY passwordusername USING password如上所述,参数username以及password可以是一个 SQL 标识符、一个 SQL 字符串或者一个对字符变量的引用。
如果连接目标包含options, 那么它们由若干个项组成,彼此之间用和号(keyword=value&)分隔。 允许的关键字与libpq识别的关键字相同(见Section 33.1.2)。 在任何keyword或value之前的空格将被忽略,但其中或之后则不会。 请注意,无法将&写入value。
connection-name被用来在一个程序中处理多个连接。如果一个程序只使用一个连接,则可以省略它。最近被打开的连接将成为当前连接,当一个 SQL 语句要被执行时,将默认使用它(见这一章稍后的部分)。
如果不受信任的用户可以访问某个尚未采用模式的安全使用方式的数据库,那么每个会话开始时都应先从search_path中移除公共可写模式。 例如,可以把options=-c search_path=加到中,或在连接后执行optionsEXEC SQL SELECT pg_catalog.set_config('search_path', '', false);。 这一注意事项并非 ECPG 独有;它适用于所有能执行任意 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; /* or EXEC SQL CONNECT TO :target USER :user/:passwd; */
最后一种形式使用了上面提到的字符变量引用。后续章节会说明,如何在 C 变量前加冒号,以便在 SQL 语句中使用它们。
请注意,连接目标的格式并未在 SQL 标准中规定。因此,如果你想开发可移植的应用,最好采用类似上面最后一个示例的方法,把连接目标字符串封装在某个地方。
嵌入式 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)
要关闭连接,请使用以下语句:
EXEC SQL DISCONNECT [connection];
其中,connection 可以按以下方式指定:
connection-nameCURRENTALL如果未指定连接名,则关闭当前连接。
在一个应用中总是显式地从它打开的每一个连接断开是一种好的风格。