这一节描述如何打开、关闭以及切换数据库连接。
我们可以使用下列语句连接到一个数据库:
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
会以默认用户名发起一个到默认数据库的连接。在那种情况中不能指定单独的用户名或连接名。
也有不同的方法来指定用户名:
username
username
/password
username
IDENTIFIED BY password
username
USING password
如上所述,参数username
以及password
可以是一个 SQL 标识符、一个 SQL 字符串或者一个对字符变量的引用。
如果连接目标包含任何options
,
这些由
组成的规范,由表示“和”的符号(keyword
=value
&
)分隔。
允许的关键字与libpq识别的关键字相同(参见第 33.1.2 节)。
在任何keyword
或value
之前的空格将被忽略,但其中或之后则不会。
请注意,无法将&
写入value
。
connection-name
被用来在一个程序中处理多个连接。如果一个程序只使用一个连接,它可以被忽略。最近被打开的连接将成为当前连接,当一个 SQL 语句要被执行时,将默认使用它(见这一章稍后的部分)。
如果不可信用户能够访问一个没有采用安全方案使用模式的数据库,开始每个会话时应该从search_path
中移除公共可写的方案。
例如,把options=-c search_path=
加到
中或者在连接后发出options
EXEC 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; /* 或者 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-name
DEFAULT
CURRENT
ALL
如果没有指定连接名,当前连接将被关闭。
在一个应用中总是显式地从它打开的每一个连接断开是一种好的风格。