-
+
Frontend/Backend Protocol
is being started, and the frontend is just an interested bystander.
It is still possible for the startup attempt
to fail (ErrorResponse), but in the normal case the backend will send
- BackendKeyData, some ParameterStatus messages, and finally ReadyForQuery.
+ some ParameterStatus messages, BackendKeyData, and finally ReadyForQuery.
At present there is a hard-wired set of parameters for which
ParameterStatus will be generated: they are
- version (backend version,
- a pseudo-parameter that cannot change after startup);
- database_encoding (also not presently changeable after start);
+ server_version (a pseudo-parameter that cannot change after
+ startup);
+ server_encoding (also not presently changeable after start);
client_encoding, and
DateStyle.
This set might change in the future, or even become configurable.
whether the COPY operation is text or binary.
+The backend sends ParameterStatus ('S') messages during connection
+startup for all parameters it considers interesting to the client library.
+Subsequently, a ParameterStatus message is sent whenever the active value
+changes for any of these parameters.
+
+
The CursorResponse ('P') message is no longer generated by
the backend.
variable
- A settable run-time parameter.
+ Name of a settable run-time parameter.
The SET command changes run-time configuration
- parameters. Many of the run-time parameters listed in the
- can be changed on-the-fly with SET.
+ parameters. Many of the run-time parameters listed in
+ can be changed on-the-fly with
+ SET.
(But some require superuser privileges to change, and others cannot
be changed after server or session start.) Note that
SET only affects the value used by the current
Choose the date/time representation style. Two separate
- settings are involved: the default date/time output and the
+ settings are involved: the default date/time output format and the
interpretation of ambiguous input.
Use Oracle/Ingres-style dates and times. Note that this
style has nothing to do with SQL (which mandates ISO 8601
- style), the naming of this option is a historical accident.
+ style); the naming of this option is a historical accident.
-
- SERVER_ENCODING
-
- Shows the server-side multibyte encoding. (At present, this
- parameter can be shown but not set, because the encoding is
- determined at
initdb time.)-
-
-
-
TIME ZONE
TIMEZONE
- ERROR: 'name is not a
+ ERROR: 'name' is not a
valid option name
Notes
- The function set_config provides the equivalent
+ The function set_config provides equivalent
capability. See .
See Also
+ ,
+ ,
,
,
Description
- SHOW will display the current setting of a
- run-time parameter. These variables can be set using the
+ SHOW will display the current setting of
+ run-time parameters. These variables can be set using the
SET statement, by editing the
- postgresql.conf, through the
- PGOPTIONS environmental variable, or through a
- command-line flag when starting the
+ postgresql.conf configuration file, through the
+ PGOPTIONS environmental variable (when using libpq
+ or a libpq-based application), or through
+ command-line flags when starting the
does not start a new transaction block. See the
autocommit section in for details.
+
+ Available parameters are documented in
+ and on the
+ reference page.
+ In addition, there are a few parameters that can be shown but not set:
+
+
+
+
+ SERVER_VERSION
+
+ Shows the server's version number.
+
+
+
+
+
+ SERVER_ENCODING
+
+ Shows the server-side multibyte encoding. At present, this
+ parameter can be shown but not set, because the encoding is
+ determined at database creation time.
+
+
+
+
+
+ LC_COLLATE
+
+ Shows the database's locale setting for collation (text ordering).
+ At present, this parameter can be shown but not set, because the
+ setting is determined at
initdb time.+
+
+
+
+
+ LC_CTYPE
+
+ Shows the database's locale setting for character set considerations.
+ At present, this parameter can be shown but not set, because the
+ setting is determined at
initdb time.+
+
+
+
+
+
+
+ Use to set the value
+ of settable parameters.
+
Message returned if name does
- not stand for an existing parameter.
+ not stand for a known parameter.
* Portions Copyright (c) 1996-2002, PostgreSQL Global Development Group
* Portions Copyright (c) 1994, Regents of the University of California
*
- * $Header: /cvsroot/pgsql/src/backend/access/transam/xlog.c,v 1.113 2003/04/18 01:03:41 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/access/transam/xlog.c,v 1.114 2003/04/25 19:45:08 tgl Exp $
*
*-------------------------------------------------------------------------
*/
#include "storage/sinval.h"
#include "storage/spin.h"
#include "utils/builtins.h"
+#include "utils/guc.h"
#include "utils/relcache.h"
#include "miscadmin.h"
"\twhich is not recognized by setlocale().\n"
"\tIt looks like you need to initdb.",
ControlFile->lc_ctype);
+
+ /* Make the fixed locale settings visible as GUC variables, too */
+ SetConfigOption("lc_collate", ControlFile->lc_collate,
+ PGC_INTERNAL, PGC_S_OVERRIDE);
+ SetConfigOption("lc_ctype", ControlFile->lc_ctype,
+ PGC_INTERNAL, PGC_S_OVERRIDE);
}
void
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/commands/variable.c,v 1.73 2003/02/01 18:31:28 tgl Exp $
+ * $Header: /cvsroot/pgsql/src/backend/commands/variable.c,v 1.74 2003/04/25 19:45:08 tgl Exp $
*
*-------------------------------------------------------------------------
*/
}
-const char *
-assign_server_encoding(const char *value, bool doit, bool interactive)
-{
- if (interactive)
- elog(ERROR, "SET SERVER_ENCODING is not supported");
- /* Pretend never to fail in noninteractive case */
- return value;
-}
-
-const char *
-show_server_encoding(void)
-{
- return GetDatabaseEncodingName();
-}
-
-
/*
* SET SESSION AUTHORIZATION
*
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/utils/init/postinit.c,v 1.119 2003/02/19 14:31:26 ishii Exp $
+ * $Header: /cvsroot/pgsql/src/backend/utils/init/postinit.c,v 1.120 2003/04/25 19:45:08 tgl Exp $
*
*
*-------------------------------------------------------------------------
* info out of the pg_database tuple.
*/
SetDatabaseEncoding(dbform->encoding);
+ /* Record it as a GUC internal option, too */
+ SetConfigOption("server_encoding", GetDatabaseEncodingName(),
+ PGC_INTERNAL, PGC_S_OVERRIDE);
/* If we have no other source of client_encoding, use server encoding */
SetConfigOption("client_encoding", GetDatabaseEncodingName(),
PGC_BACKEND, PGC_S_DEFAULT);
/* initialize client encoding */
InitializeClientEncoding();
+ /*
+ * Now all default states are fully set up. Report them to client
+ * if appropriate.
+ */
+ BeginReportingGUCOptions();
+
/*
* Set up process-exit callback to do pre-shutdown cleanup. This
* should be last because we want shmem_exit to call this routine
* command, configuration file, and command line options.
* See src/backend/utils/misc/README for more information.
*
- * $Header: /cvsroot/pgsql/src/backend/utils/misc/guc.c,v 1.118 2003/03/28 20:17:13 tgl Exp $
*
- * Copyright 2000 by PostgreSQL Global Development Group
+ * Copyright 2000-2003 by PostgreSQL Global Development Group
* Written by Peter Eisentraut
.+ *
+ * IDENTIFICATION
+ * $Header: /cvsroot/pgsql/src/backend/utils/misc/guc.c,v 1.119 2003/04/25 19:45:09 tgl Exp $
+ *
*--------------------------------------------------------------------
*/
#include "funcapi.h"
#include "libpq/auth.h"
#include "libpq/pqcomm.h"
+#include "libpq/pqformat.h"
#include "mb/pg_wchar.h"
#include "miscadmin.h"
#include "optimizer/cost.h"
#include "pgstat.h"
-/* XXX these should be in other modules' header files */
+#ifndef PG_KRB_SRVTAB
+#define PG_KRB_SRVTAB ""
+#endif
+
+
+/* XXX these should appear in other modules' header files */
extern bool Log_connections;
extern int PreAuthDelay;
extern int AuthenticationTimeout;
bool doit, bool interactive);
#endif
+static const char *assign_defaultxactisolevel(const char *newval,
+ bool doit, bool interactive);
+static const char *assign_log_min_messages(const char *newval,
+ bool doit, bool interactive);
+static const char *assign_client_min_messages(const char *newval,
+ bool doit, bool interactive);
+static const char *assign_min_error_statement(const char *newval, bool doit,
+ bool interactive);
static const char *assign_msglvl(int *var, const char *newval,
bool doit, bool interactive);
+
/*
* Debugging options
*/
bool Debug_print_parse = false;
bool Debug_print_rewritten = false;
bool Debug_pretty_print = false;
+bool Explain_pretty_print = true;
bool log_parser_stats = false;
bool log_planner_stats = false;
* three above together */
bool log_btree_build_stats = false;
-bool Explain_pretty_print = true;
-
bool SQL_inheritance = true;
bool Australian_timezones = false;
bool Password_encryption = true;
int log_min_error_statement = PANIC;
-char *log_min_error_statement_str = NULL;
-const char log_min_error_statement_str_default[] = "panic";
-
int log_min_messages = NOTICE;
-char *log_min_messages_str = NULL;
-const char log_min_messages_str_default[] = "notice";
-
int client_min_messages = NOTICE;
-char *client_min_messages_str = NULL;
-const char client_min_messages_str_default[] = "notice";
-#ifndef PG_KRB_SRVTAB
-#define PG_KRB_SRVTAB ""
-#endif
-
/*
* These variables are all dummies that don't do anything, except in some
* cases provide the value for SHOW to display. The real state is elsewhere
* and is kept in sync by assign_hooks.
*/
+static char *log_min_error_statement_str;
+static char *log_min_messages_str;
+static char *client_min_messages_str;
static double phony_random_seed;
static char *client_encoding_string;
static char *datestyle_string;
static char *default_iso_level_string;
+static char *locale_collate;
+static char *locale_ctype;
static char *regex_flavor_string;
static char *server_encoding_string;
+static char *server_version_string;
static char *session_authorization_string;
static char *timezone_string;
static char *XactIsoLevel_string;
-static const char *assign_defaultxactisolevel(const char *newval,
- bool doit, bool interactive);
-
/*
* Declarations for GUC tables
#define GUC_LIST_QUOTE 0x0002 /* double-quote list elements */
#define GUC_NO_SHOW_ALL 0x0004 /* exclude from SHOW ALL */
#define GUC_NO_RESET_ALL 0x0008 /* exclude from RESET ALL */
+#define GUC_REPORT 0x0010 /* auto-report changes to client */
/* bit values in status field */
#define GUC_HAVE_TENTATIVE 0x0001 /* tentative value is defined */
ConfigureNamesString[] =
{
{
- {"client_encoding", PGC_USERSET}, &client_encoding_string,
+ {"client_encoding", PGC_USERSET, GUC_REPORT},
+ &client_encoding_string,
"SQL_ASCII", assign_client_encoding, NULL
},
{
{"client_min_messages", PGC_USERSET}, &client_min_messages_str,
- client_min_messages_str_default, assign_client_min_messages, NULL
+ "notice", assign_client_min_messages, NULL
},
{
{"log_min_error_statement", PGC_USERSET}, &log_min_error_statement_str,
- log_min_error_statement_str_default, assign_min_error_statement, NULL
+ "panic", assign_min_error_statement, NULL
},
{
- {"DateStyle", PGC_USERSET, GUC_LIST_INPUT}, &datestyle_string,
+ {"DateStyle", PGC_USERSET, GUC_LIST_INPUT | GUC_REPORT},
+ &datestyle_string,
"ISO, US", assign_datestyle, show_datestyle
},
/* See main.c about why defaults for LC_foo are not all alike */
+ {
+ {"lc_collate", PGC_INTERNAL}, &locale_collate,
+ "C", NULL, NULL
+ },
+
+ {
+ {"lc_ctype", PGC_INTERNAL}, &locale_ctype,
+ "C", NULL, NULL
+ },
+
{
{"lc_messages", PGC_SUSET}, &locale_messages,
"", locale_messages_assign, NULL
},
{
- {"server_encoding", PGC_USERSET}, &server_encoding_string,
- "SQL_ASCII", assign_server_encoding, show_server_encoding
+ {"server_encoding", PGC_INTERNAL, GUC_REPORT},
+ &server_encoding_string,
+ "SQL_ASCII", NULL, NULL
+ },
+
+ {
+ {"server_version", PGC_INTERNAL, GUC_REPORT},
+ &server_version_string,
+ PG_VERSION, NULL, NULL
},
{
{"log_min_messages", PGC_USERSET}, &log_min_messages_str,
- log_min_messages_str_default, assign_log_min_messages, NULL
+ "notice", assign_log_min_messages, NULL
},
{
static bool guc_dirty; /* TRUE if need to do commit/abort work */
+static bool reporting_enabled; /* TRUE to enable GUC_REPORT */
+
static char *guc_string_workspace; /* for avoiding memory leaks */
static int guc_var_compare(const void *a, const void *b);
+static void ReportGUCOption(struct config_generic *record);
static char *_ShowOption(struct config_generic * record);
guc_dirty = false;
+ reporting_enabled = false;
+
guc_string_workspace = NULL;
/*
break;
}
}
+
+ if (gconf->flags & GUC_REPORT)
+ ReportGUCOption(gconf);
}
}
for (i = 0; i < num_guc_variables; i++)
{
struct config_generic *gconf = guc_variables[i];
+ bool changed;
/* Skip if nothing's happened to this var in this transaction */
if (gconf->status == 0)
continue;
+ changed = false;
+
switch (gconf->vartype)
{
case PGC_BOOL:
true, false))
elog(LOG, "Failed to commit %s", conf->gen.name);
*conf->variable = conf->session_val;
+ changed = true;
}
conf->gen.source = conf->gen.session_source;
conf->gen.status = 0;
true, false))
elog(LOG, "Failed to commit %s", conf->gen.name);
*conf->variable = conf->session_val;
+ changed = true;
}
conf->gen.source = conf->gen.session_source;
conf->gen.status = 0;
true, false))
elog(LOG, "Failed to commit %s", conf->gen.name);
*conf->variable = conf->session_val;
+ changed = true;
}
conf->gen.source = conf->gen.session_source;
conf->gen.status = 0;
}
SET_STRING_VARIABLE(conf, str);
+ changed = true;
}
conf->gen.source = conf->gen.session_source;
conf->gen.status = 0;
break;
}
}
+
+ if (changed && (gconf->flags & GUC_REPORT))
+ ReportGUCOption(gconf);
}
guc_dirty = false;
}
+/*
+ * Start up automatic reporting of changes to variables marked GUC_REPORT.
+ * This is executed at completion of backend startup.
+ */
+void
+BeginReportingGUCOptions(void)
+{
+ int i;
+
+ /*
+ * Don't do anything unless talking to an interactive frontend of
+ * protocol 3.0 or later.
+ */
+ if (whereToSendOutput != Remote ||
+ PG_PROTOCOL_MAJOR(FrontendProtocol) < 3)
+ return;
+
+ reporting_enabled = true;
+
+ /* Transmit initial values of interesting variables */
+ for (i = 0; i < num_guc_variables; i++)
+ {
+ struct config_generic *conf = guc_variables[i];
+
+ if (conf->flags & GUC_REPORT)
+ ReportGUCOption(conf);
+ }
+}
+
+/*
+ * ReportGUCOption: if appropriate, transmit option value to frontend
+ */
+static void
+ReportGUCOption(struct config_generic *record)
+{
+ if (reporting_enabled && (record->flags & GUC_REPORT))
+ {
+ char *val = _ShowOption(record);
+ StringInfoData msgbuf;
+
+ pq_beginmessage(&msgbuf, 'S');
+ pq_sendstring(&msgbuf, record->name);
+ pq_sendstring(&msgbuf, val);
+ pq_endmessage(&msgbuf);
+
+ pfree(val);
+ }
+}
+
+
/*
* Try to interpret value as boolean value. Valid values are: true,
* false, yes, no, on, off, 1, 0. If the string parses okay, return
*/
switch (record->context)
{
+ case PGC_INTERNAL:
+ if (context == PGC_SIGHUP)
+ return true;
+ if (context != PGC_INTERNAL)
+ {
+ elog(elevel, "'%s' cannot be changed",
+ name);
+ return false;
+ }
+ break;
case PGC_POSTMASTER:
if (context == PGC_SIGHUP)
return true;
}
}
+ if (DoIt && (record->flags & GUC_REPORT))
+ ReportGUCOption(record);
+
return true;
}
SRF_RETURN_NEXT(funcctx, result);
}
else
-/* do when there is no more left */
+ {
+ /* do when there is no more left */
SRF_RETURN_DONE(funcctx);
+ }
}
static char *
}
-
-#ifdef HAVE_SYSLOG
-
-static const char *
-assign_facility(const char *facility, bool doit, bool interactive)
-{
- if (strcasecmp(facility, "LOCAL0") == 0)
- return facility;
- if (strcasecmp(facility, "LOCAL1") == 0)
- return facility;
- if (strcasecmp(facility, "LOCAL2") == 0)
- return facility;
- if (strcasecmp(facility, "LOCAL3") == 0)
- return facility;
- if (strcasecmp(facility, "LOCAL4") == 0)
- return facility;
- if (strcasecmp(facility, "LOCAL5") == 0)
- return facility;
- if (strcasecmp(facility, "LOCAL6") == 0)
- return facility;
- if (strcasecmp(facility, "LOCAL7") == 0)
- return facility;
- return NULL;
-}
-#endif
-
-
-static const char *
-assign_defaultxactisolevel(const char *newval, bool doit, bool interactive)
-{
- if (strcasecmp(newval, "serializable") == 0)
- {
- if (doit)
- DefaultXactIsoLevel = XACT_SERIALIZABLE;
- }
- else if (strcasecmp(newval, "read committed") == 0)
- {
- if (doit)
- DefaultXactIsoLevel = XACT_READ_COMMITTED;
- }
- else
- return NULL;
- return newval;
-}
-
-
/*
* Handle options fetched from pg_database.datconfig or pg_shadow.useconfig.
* The array parameter must be an array of TEXT (it must not be NULL).
return newarray;
}
-const char *
+
+/*
+ * assign_hook subroutines
+ */
+
+#ifdef HAVE_SYSLOG
+
+static const char *
+assign_facility(const char *facility, bool doit, bool interactive)
+{
+ if (strcasecmp(facility, "LOCAL0") == 0)
+ return facility;
+ if (strcasecmp(facility, "LOCAL1") == 0)
+ return facility;
+ if (strcasecmp(facility, "LOCAL2") == 0)
+ return facility;
+ if (strcasecmp(facility, "LOCAL3") == 0)
+ return facility;
+ if (strcasecmp(facility, "LOCAL4") == 0)
+ return facility;
+ if (strcasecmp(facility, "LOCAL5") == 0)
+ return facility;
+ if (strcasecmp(facility, "LOCAL6") == 0)
+ return facility;
+ if (strcasecmp(facility, "LOCAL7") == 0)
+ return facility;
+ return NULL;
+}
+#endif
+
+
+static const char *
+assign_defaultxactisolevel(const char *newval, bool doit, bool interactive)
+{
+ if (strcasecmp(newval, "serializable") == 0)
+ {
+ if (doit)
+ DefaultXactIsoLevel = XACT_SERIALIZABLE;
+ }
+ else if (strcasecmp(newval, "read committed") == 0)
+ {
+ if (doit)
+ DefaultXactIsoLevel = XACT_READ_COMMITTED;
+ }
+ else
+ return NULL;
+ return newval;
+}
+
+static const char *
assign_log_min_messages(const char *newval,
bool doit, bool interactive)
{
return (assign_msglvl(&log_min_messages, newval, doit, interactive));
}
-const char *
+static const char *
assign_client_min_messages(const char *newval,
bool doit, bool interactive)
{
return (assign_msglvl(&client_min_messages, newval, doit, interactive));
}
-const char *
+static const char *
assign_min_error_statement(const char *newval, bool doit, bool interactive)
{
return (assign_msglvl(&log_min_error_statement, newval, doit, interactive));
return newval; /* OK */
}
+
#include "guc-file.c"
* variable.h
* Routines for handling specialized SET variables.
*
- * $Id: variable.h,v 1.19 2002/09/04 20:31:42 momjian Exp $
+ * $Id: variable.h,v 1.20 2003/04/25 19:45:09 tgl Exp $
*
*/
#ifndef VARIABLE_H
extern const char *show_random_seed(void);
extern const char *assign_client_encoding(const char *value,
bool doit, bool interactive);
-extern const char *assign_server_encoding(const char *value,
- bool doit, bool interactive);
-extern const char *show_server_encoding(void);
extern const char *assign_session_authorization(const char *value,
bool doit, bool interactive);
extern const char *show_session_authorization(void);
* Portions Copyright (c) 1996-2002, PostgreSQL Global Development Group
* Portions Copyright (c) 1994, Regents of the University of California
*
- * $Id: pqcomm.h,v 1.79 2003/04/24 21:16:44 tgl Exp $
+ * $Id: pqcomm.h,v 1.80 2003/04/25 19:45:09 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,103) /* XXX temporary value */
+#define PG_PROTOCOL_LATEST PG_PROTOCOL(3,104) /* XXX temporary value */
typedef uint32 ProtocolVersion; /* FE/BE protocol version number */
-/*
+/*--------------------------------------------------------------------
* guc.h
*
* External declarations pertaining to backend/utils/misc/guc.c and
* backend/utils/misc/guc-file.l
*
- * $Id: guc.h,v 1.26 2002/11/15 00:47:22 momjian Exp $
+ * Copyright 2000-2003 by PostgreSQL Global Development Group
+ * Written by Peter Eisentraut
.+ *
+ * $Id: guc.h,v 1.27 2003/04/25 19:45:09 tgl Exp $
+ *--------------------------------------------------------------------
*/
#ifndef GUC_H
#define GUC_H
* Certain options can only be set at certain times. The rules are
* like this:
*
+ * INTERNAL options cannot be set by the user at all, but only through
+ * internal processes ("server_version" is an example). These are GUC
+ * variables only so they can be shown by SHOW, etc.
+ *
* POSTMASTER options can only be set when the postmaster starts,
* either from the configuration file or the command line.
*
* SIGHUP options can only be set at postmaster startup or by changing
* the configuration file and sending the HUP signal to the postmaster
* or a backend process. (Notice that the signal receipt will not be
- * evaluated immediately. The postmaster and the backend block at a
+ * evaluated immediately. The postmaster and the backend check it at a
* certain point in their main loop. It's safer to wait than to read a
* file asynchronously.)
*
* BACKEND options can only be set at postmaster startup, from the
- * configuration file, or with the PGOPTIONS variable from the client
- * when the connection is initiated. Furthermore, an already-started
- * backend will ignore changes to such an option in the configuration
- * file. The idea is that these options are fixed for a given backend
- * once it's started, but they can vary across backends.
+ * configuration file, or by client request in the connection startup
+ * packet (e.g., from libpq's PGOPTIONS variable). Furthermore, an
+ * already-started backend will ignore changes to such an option in the
+ * configuration file. The idea is that these options are fixed for a
+ * given backend once it's started, but they can vary across backends.
*
* SUSET options can be set at postmaster startup, with the SIGHUP
* mechanism, or from SQL if you're a superuser. These options cannot
- * be set using the PGOPTIONS mechanism, because there is not check as
- * to who does this.
+ * be set in the connection startup packet, because when it is processed
+ * we don't yet know if the user is a superuser.
*
* USERSET options can be set by anyone any time.
*/
typedef enum
{
+ PGC_INTERNAL,
PGC_POSTMASTER,
PGC_SIGHUP,
PGC_BACKEND,
* override the postmaster command line.) Tracking the source allows us
* to process sources in any convenient order without affecting results.
* Sources <= PGC_S_OVERRIDE will set the default used by RESET, as well
- * as the current value.
+ * as the current value. Note that source == PGC_S_OVERRIDE should be
+ * used when setting a PGC_INTERNAL option.
*/
typedef enum
{
PGC_S_ARGV = 3, /* postmaster command line */
PGC_S_DATABASE = 4, /* per-database setting */
PGC_S_USER = 5, /* per-user setting */
- PGC_S_CLIENT = 6, /* from client (PGOPTIONS) */
+ PGC_S_CLIENT = 6, /* from client connection request */
PGC_S_OVERRIDE = 7, /* special case to forcibly set default */
PGC_S_SESSION = 8 /* SET command */
} GucSource;
+
+/* GUC vars that are actually declared in guc.c, rather than elsewhere */
+extern bool log_statement;
+extern bool log_duration;
+extern bool Debug_print_plan;
+extern bool Debug_print_parse;
+extern bool Debug_print_rewritten;
+extern bool Debug_pretty_print;
+extern bool Explain_pretty_print;
+
+extern bool log_parser_stats;
+extern bool log_planner_stats;
+extern bool log_executor_stats;
+extern bool log_statement_stats;
+extern bool log_btree_build_stats;
+
+extern bool SQL_inheritance;
+extern bool Australian_timezones;
+
+extern int log_min_error_statement;
+extern int log_min_messages;
+extern int client_min_messages;
+
+
extern void SetConfigOption(const char *name, const char *value,
GucContext context, GucSource source);
extern const char *GetConfigOption(const char *name);
extern void InitializeGUCOptions(void);
extern void ResetAllOptions(void);
extern void AtEOXact_GUC(bool isCommit);
+extern void BeginReportingGUCOptions(void);
extern void ParseLongOption(const char *string, char **name, char **value);
extern bool set_config_option(const char *name, const char *value,
GucContext context, GucSource source,
extern ArrayType *GUCArrayAdd(ArrayType *array, const char *name, const char *value);
extern ArrayType *GUCArrayDelete(ArrayType *array, const char *name);
-extern const char *assign_min_error_statement(const char *newval, bool doit,
- bool interactive);
-
-extern const char *assign_log_min_messages(const char *newval,
- bool doit, bool interactive);
-extern const char *assign_client_min_messages(const char *newval,
- bool doit, bool interactive);
-extern bool log_statement;
-extern bool log_duration;
-extern bool Debug_print_plan;
-extern bool Debug_print_parse;
-extern bool Debug_print_rewritten;
-extern bool Debug_pretty_print;
-
-extern bool log_parser_stats;
-extern bool log_planner_stats;
-extern bool log_executor_stats;
-extern bool log_statement_stats;
-extern bool log_btree_build_stats;
-
-extern bool Explain_pretty_print;
-
-extern bool SQL_inheritance;
-extern bool Australian_timezones;
-
-extern int log_min_error_statement;
-extern char *log_min_error_statement_str;
-extern const char log_min_error_statement_str_default[];
-
-extern int log_min_messages;
-extern char *log_min_messages_str;
-extern const char log_min_messages_str_default[];
-
-extern int client_min_messages;
-extern char *client_min_messages_str;
-
-extern const char client_min_messages_str_default[];
-
#endif /* GUC_H */
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/interfaces/libpq/fe-connect.c,v 1.236 2003/04/25 01:24:00 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/interfaces/libpq/fe-connect.c,v 1.237 2003/04/25 19:45:09 tgl Exp $
*
*-------------------------------------------------------------------------
*/
static int connectDBStart(PGconn *conn);
static int connectDBComplete(PGconn *conn);
-static bool PQsetenvStart(PGconn *conn);
-static PostgresPollingStatusType PQsetenvPoll(PGconn *conn);
static PGconn *makeEmptyPGconn(void);
static void freePGconn(PGconn *conn);
static void closePGconn(PGconn *conn);
case CONNECTION_MADE:
break;
- case CONNECTION_SETENV:
- /* We allow PQsetenvPoll to decide whether to proceed */
- break;
-
default:
printfPQExpBuffer(&conn->errorMessage,
libpq_gettext(
* message indicates that startup is successful, but we
* might also get an Error message indicating failure.
* (Notice messages indicating nonfatal warnings are also
- * allowed by the protocol, as is a BackendKeyData
- * message.) Easiest way to handle this is to let
- * PQgetResult() read the messages. We just have to fake
- * it out about the state of the connection, by setting
+ * allowed by the protocol, as are ParameterStatus and
+ * BackendKeyData messages.) Easiest way to handle this is
+ * to let PQgetResult() read the messages. We just have to
+ * fake it out about the state of the connection, by setting
* asyncStatus = PGASYNC_BUSY (done above).
*/
}
/*
- * Post-connection housekeeping. Prepare to send
- * environment variables to server.
+ * We are open for business!
*/
- if (!PQsetenvStart(conn))
- goto error_return;
-
- conn->status = CONNECTION_SETENV;
-
- goto keep_going;
- }
-
- case CONNECTION_SETENV:
-
- /*
- * We pretend that the connection is OK for the duration of
- * these queries.
- */
- conn->status = CONNECTION_OK;
-
- switch (PQsetenvPoll(conn))
- {
- case PGRES_POLLING_OK: /* Success */
- conn->status = CONNECTION_OK;
- return PGRES_POLLING_OK;
-
- case PGRES_POLLING_READING: /* Still going */
- conn->status = CONNECTION_SETENV;
- return PGRES_POLLING_READING;
-
- case PGRES_POLLING_WRITING: /* Still going */
- conn->status = CONNECTION_SETENV;
- return PGRES_POLLING_WRITING;
-
- default:
- conn->status = CONNECTION_SETENV;
- goto error_return;
+ conn->status = CONNECTION_OK;
+ return PGRES_POLLING_OK;
}
- /* Unreachable */
default:
printfPQExpBuffer(&conn->errorMessage,
}
-/*
- * PQsetenvStart
- *
- * Starts the process of passing the values of a standard set of environment
- * variables to the backend.
- */
-static bool
-PQsetenvStart(PGconn *conn)
-{
- if (conn == NULL ||
- conn->status == CONNECTION_BAD ||
- conn->setenv_state != SETENV_STATE_IDLE)
- return false;
-
- conn->setenv_state = SETENV_STATE_ENCODINGS_SEND;
-
- return true;
-}
-
-/*
- * PQsetenvPoll
- *
- * Polls the process of passing the values of a standard set of environment
- * variables to the backend.
- */
-static PostgresPollingStatusType
-PQsetenvPoll(PGconn *conn)
-{
- PGresult *res;
-
- if (conn == NULL || conn->status == CONNECTION_BAD)
- return PGRES_POLLING_FAILED;
-
- /* Check whether there are any data for us */
- switch (conn->setenv_state)
- {
- /* These are reading states */
- case SETENV_STATE_ENCODINGS_WAIT:
- {
- /* Load waiting data */
- int n = pqReadData(conn);
-
- if (n < 0)
- goto error_return;
- if (n == 0)
- return PGRES_POLLING_READING;
-
- break;
- }
-
- /* These are writing states, so we just proceed. */
- case SETENV_STATE_ENCODINGS_SEND:
- break;
-
- /* Should we raise an error if called when not active? */
- case SETENV_STATE_IDLE:
- return PGRES_POLLING_OK;
-
- default:
- printfPQExpBuffer(&conn->errorMessage,
- libpq_gettext(
- "invalid setenv state %c, "
- "probably indicative of memory corruption\n"
- ),
- conn->setenv_state);
- goto error_return;
- }
-
- /* We will loop here until there is nothing left to do in this call. */
- for (;;)
- {
- switch (conn->setenv_state)
- {
- case SETENV_STATE_ENCODINGS_SEND:
- {
- const char *env = getenv("PGCLIENTENCODING");
-
- if (!env || *env == '\0')
- {
- /*
- * PGCLIENTENCODING is not specified, so query
- * server for it. We must use begin/commit in
- * case autocommit is off by default.
- */
- if (!PQsendQuery(conn, "begin; select pg_client_encoding(); commit"))
- goto error_return;
-
- conn->setenv_state = SETENV_STATE_ENCODINGS_WAIT;
- return PGRES_POLLING_READING;
- }
- else
- {
- /* otherwise set client encoding in pg_conn struct */
- int encoding = pg_char_to_encoding(env);
-
- if (encoding < 0)
- {
- printfPQExpBuffer(&conn->errorMessage,
- libpq_gettext("invalid encoding name in PGCLIENTENCODING: %s\n"),
- env);
- goto error_return;
- }
- conn->client_encoding = encoding;
-
- /* Move on to setting the environment options */
- conn->setenv_state = SETENV_STATE_IDLE;
- }
- break;
- }
-
- case SETENV_STATE_ENCODINGS_WAIT:
- {
- if (PQisBusy(conn))
- return PGRES_POLLING_READING;
-
- res = PQgetResult(conn);
-
- if (res)
- {
- if (PQresultStatus(res) == PGRES_TUPLES_OK)
- {
- /* set client encoding in pg_conn struct */
- char *encoding;
-
- encoding = PQgetvalue(res, 0, 0);
- if (!encoding) /* this should not happen */
- conn->client_encoding = PG_SQL_ASCII;
- else
- conn->client_encoding = pg_char_to_encoding(encoding);
- }
- else if (PQresultStatus(res) != PGRES_COMMAND_OK)
- {
- PQclear(res);
- goto error_return;
- }
- PQclear(res);
- /* Keep reading until PQgetResult returns NULL */
- }
- else
- {
- /*
- * NULL result indicates that the query is
- * finished
- */
- conn->setenv_state = SETENV_STATE_IDLE;
- }
- break;
- }
-
- case SETENV_STATE_IDLE:
- return PGRES_POLLING_OK;
-
- default:
- printfPQExpBuffer(&conn->errorMessage,
- libpq_gettext("invalid state %c, "
- "probably indicative of memory corruption\n"),
- conn->setenv_state);
- goto error_return;
- }
- }
-
- /* Unreachable */
-
-error_return:
- conn->setenv_state = SETENV_STATE_IDLE;
- return PGRES_POLLING_FAILED;
-}
-
-
-#ifdef NOT_USED
-
-/*
- * PQsetenv
- *
- * Passes the values of a standard set of environment variables to the
- * backend.
- *
- * Returns true on success, false on failure.
- *
- * This function used to be exported for no particularly good reason.
- * Since it's no longer used by libpq itself, let's try #ifdef'ing it out
- * and see if anyone complains.
- */
-static bool
-PQsetenv(PGconn *conn)
-{
- PostgresPollingStatusType flag = PGRES_POLLING_WRITING;
-
- if (!PQsetenvStart(conn))
- return false;
-
- for (;;)
- {
- /*
- * Wait, if necessary. Note that the initial state (just after
- * PQsetenvStart) is to wait for the socket to select for writing.
- */
- switch (flag)
- {
- case PGRES_POLLING_OK:
- return true; /* success! */
-
- case PGRES_POLLING_READING:
- if (pqWait(1, 0, conn))
- {
- conn->status = CONNECTION_BAD;
- return false;
- }
- break;
-
- case PGRES_POLLING_WRITING:
- if (pqWait(0, 1, conn))
- {
- conn->status = CONNECTION_BAD;
- return false;
- }
- break;
-
- default:
- /* Just in case we failed to set it in PQsetenvPoll */
- conn->status = CONNECTION_BAD;
- return false;
- }
-
- /*
- * Now try to advance the state machine.
- */
- flag = PQsetenvPoll(conn);
- }
-}
-#endif /* NOT_USED */
-
-
/*
* makeEmptyPGconn
* - create a PGconn data structure with (as yet) no interesting data
conn->noticeHook = defaultNoticeProcessor;
conn->status = CONNECTION_BAD;
conn->asyncStatus = PGASYNC_IDLE;
- conn->setenv_state = SETENV_STATE_IDLE;
conn->notifyList = DLNewList();
conn->sock = -1;
#ifdef USE_SSL
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/interfaces/libpq/fe-exec.c,v 1.132 2003/04/25 01:24:00 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/interfaces/libpq/fe-exec.c,v 1.133 2003/04/25 19:45:09 tgl Exp $
*
*-------------------------------------------------------------------------
*/
#include "libpq-fe.h"
#include "libpq-int.h"
+#include "mb/pg_wchar.h"
+
#ifdef WIN32
#include "win32.h"
#else
static void handleSyncLoss(PGconn *conn, char id, int msgLength);
static int getRowDescriptions(PGconn *conn);
static int getAnotherTuple(PGconn *conn, int binary);
+static int getParameterStatus(PGconn *conn);
static int getNotify(PGconn *conn);
/* ---------------
*
* However, if the state is IDLE then we got trouble; we need to deal
* with the unexpected message somehow.
+ *
+ * ParameterStatus ('S') messages are a special case: in IDLE state
+ * we must process 'em (this case could happen if a new value was
+ * adopted from config file due to SIGHUP), but otherwise we hold
+ * off until BUSY state.
*/
if (id == 'A')
{
/*
* Unexpected message in IDLE state; need to recover somehow.
* ERROR messages are displayed using the notice processor;
+ * ParameterStatus is handled normally;
* anything else is just dropped on the floor after displaying
* a suitable warning notice. (An ERROR is very possibly the
* backend telling us why it is about to close the connection,
if (pqGetErrorNotice(conn, false /* treat as notice */))
return;
}
+ else if (id == 'S')
+ {
+ if (getParameterStatus(conn))
+ return;
+ }
else
{
snprintf(noticeWorkspace, sizeof(noticeWorkspace),
PGRES_EMPTY_QUERY);
conn->asyncStatus = PGASYNC_READY;
break;
+ case 'S': /* parameter status */
+ if (getParameterStatus(conn))
+ return;
+ break;
case 'K': /* secret key data from the backend */
/*
return EOF;
}
+/*
+ * Attempt to read a ParameterStatus message.
+ * This is possible in several places, so we break it out as a subroutine.
+ * Entry: 'S' message type and length have already been consumed.
+ * Exit: returns 0 if successfully consumed message.
+ * returns EOF if not enough data.
+ */
+static int
+getParameterStatus(PGconn *conn)
+{
+ /* Get the parameter name */
+ if (pqGets(&conn->workBuffer, conn))
+ return EOF;
+ /* Is it one we care about? */
+ if (strcmp(conn->workBuffer.data, "client_encoding") == 0)
+ {
+ if (pqGets(&conn->workBuffer, conn))
+ return EOF;
+ conn->client_encoding = pg_char_to_encoding(conn->workBuffer.data);
+ }
+ else
+ {
+ /* Uninteresting parameter, ignore it */
+ if (pqGets(&conn->workBuffer, conn))
+ return EOF;
+ }
+ return 0;
+}
+
/*
* Attempt to read a Notify response message.
* This is possible in several places, so we break it out as a subroutine.
if (conn->result)
return prepareAsyncResult(conn);
return PQmakeEmptyPGresult(conn, status);
+ case 'S': /* parameter status */
+ if (getParameterStatus(conn))
+ continue;
+ break;
default:
/* The backend violates the protocol. */
printfPQExpBuffer(&conn->errorMessage,
* 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.64 2003/04/24 21:16:44 tgl Exp $
+ * $Id: libpq-int.h,v 1.65 2003/04/25 19:45:10 tgl Exp $
*
*-------------------------------------------------------------------------
*/
* pqcomm.h describe what the backend knows, not what libpq knows.
*/
-#define PG_PROTOCOL_LIBPQ PG_PROTOCOL(3,103) /* XXX temporary value */
+#define PG_PROTOCOL_LIBPQ PG_PROTOCOL(3,104) /* XXX temporary value */
/*
* POSTGRES backend dependent Constants.
PGASYNC_COPY_OUT /* Copy Out data transfer in progress */
} PGAsyncStatusType;
-/* PGSetenvStatusType defines the state of the PQSetenv state machine */
-typedef enum
-{
- SETENV_STATE_ENCODINGS_SEND, /* About to send an "encodings" query */
- SETENV_STATE_ENCODINGS_WAIT, /* Waiting for query to complete */
- SETENV_STATE_IDLE
-} PGSetenvStatusType;
-
/* large-object-access data ... allocated only if large-object code is used. */
typedef struct pgLobjfuncs
{
PGresult *result; /* result being constructed */
PGresAttValue *curTuple; /* tuple currently being read */
- /* Status for sending environment info. Used during PQSetenv only. */
- PGSetenvStatusType setenv_state;
-
#ifdef USE_SSL
bool allow_ssl_try; /* Allowed to try SSL negotiation */
bool require_ssl; /* Require SSL to make connection */
projects / postgresql.git / commitdiff