↑↓ 选择 ↵ 打开 ⌫ 改范围 完整检索页

pgsql.cc 提供对 postgresql.org 官网内容的中文翻译,由 Pigsty 团队维护。

受支持版本: 当前版本 (18) / 17 / 16 / 15 / 14
测试与开发版本: 19 / devel
不受支持的版本: 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 / 7.2 / 7.1
历史版本PostgreSQL 7.3 已于 2007 年 11 月结束社区维护,本页译文保留供仍在使用旧版本的读者参考。新系统请看当前版本。

1.7. 与 COPY 命令相关的函数 #

PostgreSQL 中的 COPY 命令可以选择从 libpq 所用的网络连接读取或向其写入。因此,需要能直接访问此网络连接的函数,应用才能利用这一能力。

只有在从 PQexec 或 PQgetResult 得到 PGRES_COPY_OUT 或 PGRES_COPY_IN 结果对象之后,才应执行这些函数。

  • PQgetline 把一行由后端服务器传来的以换行符结尾的字符读入大小为 length 的缓冲区字符串。

    int PQgetline(PGconn *conn,
                  char *string,
                  int length)
    

    与 fgets 一样,此例程最多把 length-1 个字符复制到 string 中;但与 gets 相似,它会把结尾的换行符转换为零字节。 PQgetline 在输入结束时返回 EOF,整行已读完返回 0,缓冲区已满但结尾换行符尚未读到返回 1。

    注意,应用必须检查新的一行是否由两个字符 \. 组成,这表示后端服务器已发送完 copy 命令的结果。如果应用可能收到超过 length-1 个字符的行,就需要小心确保正确识别 \. 行(例如,不要把长数据行的结尾误当作终结行)。 src/bin/psql/copy.c 中的代码包含正确处理 copy 协议的例程示例。

  • PQgetlineAsync 把一行由后端服务器传来的以换行符结尾的字符读入缓冲区而不阻塞。

    int PQgetlineAsync(PGconn *conn,
                       char *buffer,
                       int bufsize)
    

    此例程类似于 PQgetline,但可供必须异步(即不阻塞地)读取 COPY 数据的应用使用。发出 COPY 命令并得到 PGRES_COPY_OUT 响应后,应用应交替调用 PQconsumeInput 和 PQgetlineAsync,直到检测到数据结束信号。与 PQgetline 不同,此例程自己负责检测数据结束。 每次调用时,如果 libpq 的输入缓冲区中已有完整的一行以换行符结尾的数据行,或者到来的数据行太长放不进调用者提供的缓冲区,PQgetlineAsync 就会返回数据。否则,在该行剩余部分到达之前不返回数据。

    如果已识别到 copy 数据结束标记,此例程返回 -1;没有可用数据返回 0;返回正数时该数给出所返回数据的字节数。返回 -1 时,调用者接下来必须调用 PQendcopy,然后回到正常处理。返回的数据不会跨过换行符。可能时一次返回整行;但如果调用者提供的缓冲区太小装不下后端发来的一行,就会返回部分数据行。这可以通过检查最后返回的字节是否为 \n 来检测。返回的字符串不以空字符结尾。(如果想加上结尾空字符,务必让传入的 bufsize 比实际可用空间小一。)

  • PQputline 向后台服务器发送一个以空字符结尾的字符串。成功返回 0,无法发送字符串返回 EOF。

    int PQputline(PGconn *conn,
                  const char *string);
    

    注意,应用必须在最后一行显式发送两个字符 \.,以告知后端它已发送完数据。

  • PQputnbytes 向后台服务器发送一个不以空字符结尾的字符串。成功返回 0,无法发送字符串返回 EOF。

    int PQputnbytes(PGconn *conn,
                    const char *buffer,
                    int nbytes);
    

    它与 PQputline 完全一样,只是由于要发送的字节数是直接指定的,数据缓冲区不需要以空字符结尾。

  • PQendcopy 与后端同步。此函数等待后端完成 copy。它应当在用 PQputline 向后端发送完最后一个字符串之后,或用 PGgetline 从后端收到最后一个字符串之后发出。必须发出此函数,否则后端可能与前端“失去同步”。从此函数返回后,后端就准备好接收下一条 SQL 命令了。成功完成时返回值为 0,否则非零。

    int PQendcopy(PGconn *conn);
    

    例如:

    PQexec(conn, "CREATE TABLE foo (a int4, b char(16), d double precision)");
    PQexec(conn, "COPY foo FROM STDIN");
    PQputline(conn, "3\thello world\t4.5\n");
    PQputline(conn,"4\tgoodbye world\t7.11\n");
    ...
    PQputline(conn,"\\.\n");
    PQendcopy(conn);
    

使用 PQgetResult 时,应用对 PGRES_COPY_OUT 结果的响应应是反复执行 PQgetline,看到终结行后再执行 PQendcopy。然后应回到 PQgetResult 循环,直到 PQgetResult 返回 NULL。类似地,PGRES_COPY_IN 结果由一系列 PQputline 调用加 PQendcopy 处理,然后回到 PQgetResult 循环。这样的安排可确保嵌入在一系列 SQL 命令中的 copy in 或 copy out 命令被正确执行。

较老的应用可能通过 PQexec 提交 copy in 或 copy out,并认为 PQendcopy 之后事务就完成了。只有当 copy in/out 是命令字符串中唯一的 SQL 命令时,这样做才是正确的。

提交更正

译文有误、术语不当或页面显示问题,请到译文仓库 pgsty/pgdoc 报告译文问题。 英文原文本身的问题,请在当前版本的对应页面向上游反馈;上游不再修订已结束维护的版本。