-
+
Frontend/Backend Protocol
bind step, which creates a portal given a prepared
statement and values for any needed parameters; and an
execute step that runs a portal's query. In the case of
- a SELECT query, the execute step can be told to fetch only
+ a query that returns rows (SELECT, SHOW, etc),
+ the execute step can be told to fetch only
a limited number of rows, so that multiple execute steps may be needed
to complete the operation.
Indicates that rows are about to be returned in response to
- a SELECT or FETCH query.
+ a SELECT, FETCH, etc query.
The message contents describe the layout of the rows. This
will be followed by a DataRow or BinaryRow message (depending on
whether a binary cursor was specified) for each row being returned
- The response to a SELECT, FETCH, or
- SHOW query
+ The response to a SELECT query (or other queries that
+ return rowsets, such as EXPLAIN or SHOW)
normally consists of RowDescription, zero or more
DataRow or BinaryRow messages, and then CommandComplete.
COPY to or from the frontend invokes special protocol
unnamed portal), the desired output format (text or binary), and
a maximum result-row count (zero meaning fetch all rows).
The output format and result-row count are only meaningful for portals
- containing SELECT commands; they are ignored for other types of commands.
- The possible
+ containing commands that return rowsets; they are ignored for other types
+ of commands. The possible
responses to Execute are the same as those described above for queries
issued via simple query protocol, except that Execute doesn't cause
ReadyForQuery to be issued. Also, the choice between text and binary
portal (or an empty string for the unnamed portal). The response is a
RowDescription message describing the rows that will be returned by
executing the portal; or a NoData message if the portal does not contain a
- SELECT-type query; or ErrorResponse if there is no such portal. In most
- situations the frontend will want to issue this message before issuing
- Execute, to obtain a description of the results it will get back.
+ query that will return rows; or ErrorResponse if there is no such portal.
The Describe message (statement variant) specifies the name of an existing
prepared statement (or an empty string for the unnamed prepared
statement). The response is a ParameterDescription message describing the
- parameters needed by the statement. ErrorResponse is issued if there is
- no such prepared statement. This message may be useful if the client
- library is uncertain about the parameters needed by a prepared statement.
+ parameters needed by the statement (if any), followed by a RowDescription
+ message describing the rows that will be returned when the statement is
+ eventually executed (or NoData if the statement will not return rows).
+ ErrorResponse is issued if there is no such prepared statement.
+
+ In most scenarios the frontend should issue one or the other variant
+ of Describe before issuing Execute, to ensure that it knows how to
+ interpret the results it will get back.
+
+
+
The Close message closes an existing prepared statement or portal
and releases resources. It is not an error to issue Close against
Maximum number of rows to return, if portal contains
- a SELECT or FETCH query (ignored otherwise). Zero
+ a query that returns rows (ignored otherwise). Zero
denotes no limit.
* Copyright (c) 2002-2003, PostgreSQL Global Development Group
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/commands/prepare.c,v 1.16 2003/05/06 20:26:26 tgl Exp $
+ * $Header: /cvsroot/pgsql/src/backend/commands/prepare.c,v 1.17 2003/05/06 21:51:41 tgl Exp $
*
*-------------------------------------------------------------------------
*/
return entry->argtype_list;
}
+/*
+ * Given a prepared statement, determine the result tupledesc it will
+ * produce. Returns NULL if the execution will not return tuples.
+ *
+ * Note: the result is created or copied into current memory context.
+ */
+TupleDesc
+FetchPreparedStatementResultDesc(PreparedStatement *stmt)
+{
+ Query *query;
+
+ switch (ChoosePortalStrategy(stmt->query_list))
+ {
+ case PORTAL_ONE_SELECT:
+ query = (Query *) lfirst(stmt->query_list);
+ return ExecCleanTypeFromTL(query->targetList, false);
+
+ case PORTAL_UTIL_SELECT:
+ query = (Query *) lfirst(stmt->query_list);
+ return UtilityTupleDescriptor(query->utilityStmt);
+
+ case PORTAL_MULTI_QUERY:
+ /* will not return tuples */
+ break;
+ }
+ return NULL;
+}
+
/*
* Implements the 'DEALLOCATE' utility statement: deletes the
* specified plan from storage.
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/tcop/postgres.c,v 1.336 2003/05/06 20:26:27 tgl Exp $
+ * $Header: /cvsroot/pgsql/src/backend/tcop/postgres.c,v 1.337 2003/05/06 21:51:41 tgl Exp $
*
* NOTES
* this is the "main" module of the postgres backend and
exec_describe_statement_message(const char *stmt_name)
{
PreparedStatement *pstmt;
+ TupleDesc tupdesc;
List *l;
StringInfoData buf;
if (whereToSendOutput != Remote)
return; /* can't actually do anything... */
+ /*
+ * First describe the parameters...
+ */
pq_beginmessage(&buf, 't'); /* parameter description message type */
pq_sendint(&buf, length(pstmt->argtype_list), 4);
pq_sendint(&buf, (int) ptype, 4);
}
pq_endmessage(&buf);
+
+ /*
+ * Next send RowDescription or NoData to describe the result...
+ */
+ tupdesc = FetchPreparedStatementResultDesc(pstmt);
+ if (tupdesc)
+ {
+ List *targetlist;
+
+ if (ChoosePortalStrategy(pstmt->query_list) == PORTAL_ONE_SELECT)
+ targetlist = ((Query *) lfirst(pstmt->query_list))->targetList;
+ else
+ targetlist = NIL;
+ SendRowDescriptionMessage(tupdesc, targetlist);
+ }
+ else
+ pq_putemptymessage('n'); /* NoData */
+
}
/*
if (!IsUnderPostmaster)
{
puts("\nPOSTGRES backend interactive interface ");
- puts("$Revision: 1.336 $ $Date: 2003/05/06 20:26:27 $\n");
+ puts("$Revision: 1.337 $ $Date: 2003/05/06 21:51:41 $\n");
}
/*
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/tcop/utility.c,v 1.199 2003/05/06 20:26:27 tgl Exp $
+ * $Header: /cvsroot/pgsql/src/backend/tcop/utility.c,v 1.200 2003/05/06 21:51:41 tgl Exp $
*
*-------------------------------------------------------------------------
*/
portal = GetPortalByName(stmt->portalname);
if (!PortalIsValid(portal))
return false; /* not our business to raise error */
- /*
- * Note: if portal contains multiple statements then it's
- * possible some of them will return tuples, but we don't
- * handle that case here.
- */
return portal->tupDesc ? true : false;
}
case PORTAL_UTIL_SELECT:
return true;
case PORTAL_MULTI_QUERY:
- /* can't figure it out, per note above */
+ /* will not return tuples */
break;
}
return false;
{
ExecuteStmt *stmt = (ExecuteStmt *) parsetree;
PreparedStatement *entry;
- Query *query;
if (stmt->into)
return NULL;
entry = FetchPreparedStatement(stmt->name, false);
if (!entry)
return NULL; /* not our business to raise error */
- switch (ChoosePortalStrategy(entry->query_list))
- {
- case PORTAL_ONE_SELECT:
- query = (Query *) lfirst(entry->query_list);
- return ExecCleanTypeFromTL(query->targetList, false);
- case PORTAL_UTIL_SELECT:
- query = (Query *) lfirst(entry->query_list);
- return UtilityTupleDescriptor(query->utilityStmt);
- case PORTAL_MULTI_QUERY:
- break;
- }
- return NULL;
+ return FetchPreparedStatementResultDesc(entry);
}
case T_ExplainStmt:
*
* Copyright (c) 2002-2003, PostgreSQL Global Development Group
*
- * $Id: prepare.h,v 1.5 2003/05/06 20:26:27 tgl Exp $
+ * $Id: prepare.h,v 1.6 2003/05/06 21:51:42 tgl Exp $
*
*-------------------------------------------------------------------------
*/
bool throwError);
extern void DropPreparedStatement(const char *stmt_name, bool showError);
extern List *FetchPreparedStatementParams(const char *stmt_name);
+extern TupleDesc FetchPreparedStatementResultDesc(PreparedStatement *stmt);
#endif /* PREPARE_H */
* Portions Copyright (c) 1996-2002, PostgreSQL Global Development Group
* Portions Copyright (c) 1994, Regents of the University of California
*
- * $Id: pqcomm.h,v 1.82 2003/05/05 00:44:56 tgl Exp $
+ * $Id: pqcomm.h,v 1.83 2003/05/06 21:51:42 tgl Exp $
*
*-------------------------------------------------------------------------
*/
/* The earliest and latest frontend/backend protocol version supported. */
#define PG_PROTOCOL_EARLIEST PG_PROTOCOL(1,0)
-#define PG_PROTOCOL_LATEST PG_PROTOCOL(3,106) /* XXX temporary value */
+#define PG_PROTOCOL_LATEST PG_PROTOCOL(3,107) /* XXX temporary value */
typedef uint32 ProtocolVersion; /* FE/BE protocol version number */
* Portions Copyright (c) 1996-2002, PostgreSQL Global Development Group
* Portions Copyright (c) 1994, Regents of the University of California
*
- * $Id: libpq-int.h,v 1.67 2003/05/05 00:44:56 tgl Exp $
+ * $Id: libpq-int.h,v 1.68 2003/05/06 21:51:42 tgl Exp $
*
*-------------------------------------------------------------------------
*/
* pqcomm.h describe what the backend knows, not what libpq knows.
*/
-#define PG_PROTOCOL_LIBPQ PG_PROTOCOL(3,106) /* XXX temporary value */
+#define PG_PROTOCOL_LIBPQ PG_PROTOCOL(3,107) /* XXX temporary value */
/*
* POSTGRES backend dependent Constants.
projects / postgresql.git / commitdiff