31.4. 异步命令处理

向服务器提交一个命令而不等待结果。如果查询成功发送则返回 1，否则返回 0。 （此时，可以用PQerrorMessage获取关于失败的信息）。

int PQsendQuery(PGconn *conn，const char *command);

在成功调用PQsendQuery后，调用PQgetResult一次或者多次获取结果 。在PQsendQuery返回 NULL 指针，表明命令完成之前， 我们不能再调用PQsendQuery（在同一次连接里）。

给服务器提交一个命令和（命令需要的）分隔的参数，而不等待结果。

int PQsendQueryParams(PGconn *conn，
                      const char *command，
                      int nParams，
                      const Oid *paramTypes，
                      const char * const *paramValues，
                      const int *paramLengths，
                      const int *paramFormats，
                      int resultFormat);

这个等效于PQsendQuery，只是查询参数可以和查询字串分开声明。 函数的参数处理和PQexecParams一样。和PQexecParams类似，它不能在 2.0 版本的协议连接上工作， 并且它只允许在查询字串里出现一条命令。

发送一个请求，创建一个给定参数的准备好语句，而不等待结束。

int PQsendPrepare(PGconn *conn，
                  const char *stmtName，
                  const char *query，
                  int nParams，
                  const Oid *paramTypes);

这是PQprepare的异步版本：如果它能发送这个请求，则返回 1，如果不能，则返回 0。 在成功调用之后，调用PQgetResult判断服务器是否成功创建了准备好语句。 这个函数的参数的处理和PQprepare一样。类似PQprepare， 它不能在 2.0 版本协议的连接上运转。

发送一个执行带有给出参数的准备好的语句的请求，不等待结果。

int PQsendQueryPrepared(PGconn *conn，
                        const char *stmtName，
                        int nParams，
                        const char * const *paramValues，
                        const int *paramLengths，
                        const int *paramFormats，
                        int resultFormat);

这个函数类似PQsendQueryParams，但是要执行的命令是通过给一个前面准备好的语句命名来声明的， 而不是给出一个查询字串。函数的参数处理和PQexecPrepared一样。类似 PPQexecPrepared， 它也不能在 2.0 版本的协议连接上跑。

发送一个执行带有给出参数的准备好的语句的请求，不等待结果。

int PQsendDescribePrepared(PGconn *conn，const char *stmtName);

这个函数类似PQdescribePrepared，但是要执行的命令是通过给一个前面准备好的语句命名来声明的， 而不是给出一个查询字串。函数的参数处理和PQgetResult一样。类似PQdescribePrepared， 它也不能在 2.0 版本的协议连接上跑。

发出请求，以获得关于制定端口的信息，不需要等待完成。

int PQsendDescribePortal(PGconn *conn，const char *portalName);

这是一个PQdescribePortal的异步版本： 如果调度请求，那么返回1，否则返回0。成功调用之后，通过PQgetResult获得结果。 函数参数处理与PQdescribePortal相同。 类似于PQdescribePortal，不能在2.0的协议连接上工作。

等待从前面PQsendQuery， PQsendQueryParams， PQsendPrepare或者PQsendQueryPrepared调用返回的下一个结果，然后返回之。 当命令结束并且没有更多结果后返回 NULL。

PGresult *PQgetResult(PGconn *conn);

必须重复的调用PQgetResult，直到它返回 NULL，表明该命令结束。（如果在没有活跃的命令时调用， PQgetResult将只是立即返回一个空指针。） 每个PQgetResult返回的非 NULL 结 果都应该用前面描述的PGresult访问函数进行分析。不要忘了在结束分析后用PQclear 释放每个结果对象。注意，PQgetResult只是在有一个命令是活跃的而且必须的返回数据还没 有被PQconsumeInput读取时阻塞。

如果存在服务器来的输入可用，则使用之。

int PQconsumeInput(PGconn *conn);

PQconsumeInput通常返回 1 表明"no error"，而返回 0 表明有某种错误发生， （这个时候可以用PQerrorMessage）。注意这个结果并不表明实际上是否收集了数据。 在调用PQconsumeInput，之后，应用可以检查PQisBusy和/或PQnotifies 看一眼它们的状态是否改变。

PQconsumeInput可以在应用还没有做好处理结果或通知的情况下被调用。这个函数将读取可用的数 据并且在一个缓冲区里保存它，这样导致一个select()读准备好标识的生成。这样应用就可以使用 PQconsumeInput立即清掉select()条件，然后在空闲的时候检查结果。

在查询忙的时候返回 1 ，也就是说，PQgetResult将阻塞住等待输入。 一个 0 的返回表明这时调用PQgetResult等以确保不阻塞。

int PQisBusy(PGconn *conn);

PQisBusy本身将不会试图从服务器读取数据；所以必须先调用 PQconsumeInput，否则忙状态将永远不会消除。

把连接的状态设置为非阻塞。

int PQsetnonblocking(PGconn *conn，int arg);

如果arg为 1，把连接状态设置为非阻塞，如果arg为 0，把连接状态设 置为阻塞。如果 OK 返回 0，如果错误返回 -1。

In the nonblocking state，calls to PQsendQuery，PQputline， PQputnbytes，and PQendcopywill not block but instead return an error if they need to be called again. 在非阻塞状态，调用PQsendQuery，PQputline， PQputnbytes，和 PQendcopy的时候不被阻塞， 而是在如果需要再次调用它们时将返回一个错误。

请注意PQexec不会在意任何非阻塞模式；如果调用了PQexec，那么它的行为总是阻塞的。

返回数据库连接的阻塞状态。

int PQisnonblocking(const PGconn *conn);

如果连接设置为非阻塞状态，返回 1，如果是阻塞状态返回 0。

试图把任何正在排队的数据冲刷到服务器，如果成功（或者发送队列为空）返回 0， 如果因某种原因失败返回 -1，或者是在无法把发送队列中的所有数据都发送出去， 返回 1。（这种情况只有在连接不为阻塞模式的时候才会出现）。

int PQflush(PGconn *conn);