2000-07-21 13:43:26 +02:00
|
|
|
/*-------------------------------------------------------------------------
|
|
|
|
*
|
2001-01-12 05:32:07 +01:00
|
|
|
* pg_backup_db.c
|
|
|
|
*
|
2001-03-22 05:01:46 +01:00
|
|
|
* Implements the basic DB functions used by the archiver.
|
2001-01-12 05:32:07 +01:00
|
|
|
*
|
|
|
|
* IDENTIFICATION
|
2001-03-23 05:49:58 +01:00
|
|
|
* $Header: /cvsroot/pgsql/src/bin/pg_dump/pg_backup_db.c,v 1.17 2001/03/23 04:49:55 momjian Exp $
|
2001-03-19 03:35:29 +01:00
|
|
|
*
|
|
|
|
* NOTES
|
2001-01-12 05:32:07 +01:00
|
|
|
*
|
|
|
|
* Modifications - 04-Jan-2001 - pjw@rhyme.com.au
|
|
|
|
*
|
2001-03-22 05:01:46 +01:00
|
|
|
* - Check results of PQ routines more carefully.
|
2000-07-21 13:43:26 +02:00
|
|
|
*
|
2001-03-19 03:35:29 +01:00
|
|
|
* Modifications - 19-Mar-2001 - pjw@rhyme.com.au
|
|
|
|
*
|
|
|
|
* - Avoid forcing table name to lower case in FixupBlobXrefs!
|
|
|
|
*
|
UUNET is looking into offering PostgreSQL as a part of a managed web
hosting product, on both shared and dedicated machines. We currently
offer Oracle and MySQL, and it would be a nice middle-ground.
However, as shipped, PostgreSQL lacks the following features we need
that MySQL has:
1. The ability to listen only on a particular IP address. Each
hosting customer has their own IP address, on which all of their
servers (http, ftp, real media, etc.) run.
2. The ability to place the Unix-domain socket in a mode 700 directory.
This allows us to automatically create an empty database, with an
empty DBA password, for new or upgrading customers without having
to interactively set a DBA password and communicate it to (or from)
the customer. This in turn cuts down our install and upgrade times.
3. The ability to connect to the Unix-domain socket from within a
change-rooted environment. We run CGI programs chrooted to the
user's home directory, which is another reason why we need to be
able to specify where the Unix-domain socket is, instead of /tmp.
4. The ability to, if run as root, open a pid file in /var/run as
root, and then setuid to the desired user. (mysqld -u can almost
do this; I had to patch it, too).
The patch below fixes problem 1-3. I plan to address #4, also, but
haven't done so yet. These diffs are big enough that they should give
the PG development team something to think about in the meantime :-)
Also, I'm about to leave for 2 weeks' vacation, so I thought I'd get
out what I have, which works (for the problems it tackles), now.
With these changes, we can set up and run PostgreSQL with scripts the
same way we can with apache or proftpd or mysql.
In summary, this patch makes the following enhancements:
1. Adds an environment variable PGUNIXSOCKET, analogous to MYSQL_UNIX_PORT,
and command line options -k --unix-socket to the relevant programs.
2. Adds a -h option to postmaster to set the hostname or IP address to
listen on instead of the default INADDR_ANY.
3. Extends some library interfaces to support the above.
4. Fixes a few memory leaks in PQconnectdb().
The default behavior is unchanged from stock 7.0.2; if you don't use
any of these new features, they don't change the operation.
David J. MacKenzie
2000-11-13 16:18:15 +01:00
|
|
|
*-------------------------------------------------------------------------
|
2000-07-21 13:43:26 +02:00
|
|
|
*/
|
|
|
|
|
2001-02-10 03:31:31 +01:00
|
|
|
#include "pg_dump.h"
|
|
|
|
#include "pg_backup.h"
|
|
|
|
#include "pg_backup_archiver.h"
|
|
|
|
#include "pg_backup_db.h"
|
|
|
|
|
2000-07-21 13:43:26 +02:00
|
|
|
#include <unistd.h> /* for getopt() */
|
|
|
|
#include <ctype.h>
|
|
|
|
|
|
|
|
#ifdef HAVE_TERMIOS_H
|
|
|
|
#include <termios.h>
|
|
|
|
#endif
|
|
|
|
|
|
|
|
#include "libpq-fe.h"
|
2001-02-10 03:31:31 +01:00
|
|
|
#include "libpq/libpq-fs.h"
|
2000-07-21 13:43:26 +02:00
|
|
|
#ifndef HAVE_STRDUP
|
|
|
|
#include "strdup.h"
|
|
|
|
#endif
|
|
|
|
|
2001-03-22 05:01:46 +01:00
|
|
|
static const char *progname = "Archiver(db)";
|
2000-07-21 13:43:26 +02:00
|
|
|
|
2001-03-22 05:01:46 +01:00
|
|
|
static void _prompt_for_password(char *username, char *password);
|
|
|
|
static void _check_database_version(ArchiveHandle *AH, bool ignoreVersion);
|
|
|
|
static PGconn *_connectDB(ArchiveHandle *AH, const char *newdbname, char *newUser);
|
|
|
|
static int _executeSqlCommand(ArchiveHandle *AH, PGconn *conn, PQExpBuffer qry, char *desc);
|
2000-07-21 13:43:26 +02:00
|
|
|
|
|
|
|
|
|
|
|
static void
|
|
|
|
_prompt_for_password(char *username, char *password)
|
|
|
|
{
|
|
|
|
char buf[512];
|
|
|
|
int length;
|
2000-11-27 04:53:13 +01:00
|
|
|
int buflen;
|
2000-07-21 13:43:26 +02:00
|
|
|
|
|
|
|
#ifdef HAVE_TERMIOS_H
|
|
|
|
struct termios t_orig,
|
2001-03-22 05:01:46 +01:00
|
|
|
t;
|
|
|
|
|
2000-07-21 13:43:26 +02:00
|
|
|
#endif
|
|
|
|
|
2000-07-24 08:24:26 +02:00
|
|
|
/*
|
|
|
|
* Allow for forcing a specific username
|
|
|
|
*/
|
|
|
|
if (strlen(username) == 0)
|
2000-07-21 13:43:26 +02:00
|
|
|
{
|
2000-07-24 08:24:26 +02:00
|
|
|
fprintf(stderr, "Username: ");
|
|
|
|
fflush(stderr);
|
2000-11-27 04:53:13 +01:00
|
|
|
if (fgets(username, 100, stdin) == NULL)
|
|
|
|
username[0] = '\0';
|
2000-07-24 08:24:26 +02:00
|
|
|
length = strlen(username);
|
|
|
|
if (length > 0 && username[length - 1] != '\n')
|
2000-07-21 13:43:26 +02:00
|
|
|
{
|
2000-11-27 04:53:13 +01:00
|
|
|
/* eat rest of the line */
|
2000-07-24 08:24:26 +02:00
|
|
|
do
|
|
|
|
{
|
2000-11-27 04:53:13 +01:00
|
|
|
if (fgets(buf, sizeof(buf), stdin) == NULL)
|
|
|
|
break;
|
|
|
|
buflen = strlen(buf);
|
|
|
|
} while (buflen > 0 && buf[buflen - 1] != '\n');
|
2000-07-24 08:24:26 +02:00
|
|
|
}
|
|
|
|
if (length > 0 && username[length - 1] == '\n')
|
|
|
|
username[length - 1] = '\0';
|
2000-07-21 13:43:26 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
#ifdef HAVE_TERMIOS_H
|
|
|
|
tcgetattr(0, &t);
|
|
|
|
t_orig = t;
|
|
|
|
t.c_lflag &= ~ECHO;
|
|
|
|
tcsetattr(0, TCSADRAIN, &t);
|
|
|
|
#endif
|
|
|
|
fprintf(stderr, "Password: ");
|
|
|
|
fflush(stderr);
|
2000-11-27 04:53:13 +01:00
|
|
|
if (fgets(password, 100, stdin) == NULL)
|
|
|
|
password[0] = '\0';
|
2000-07-21 13:43:26 +02:00
|
|
|
#ifdef HAVE_TERMIOS_H
|
|
|
|
tcsetattr(0, TCSADRAIN, &t_orig);
|
|
|
|
#endif
|
|
|
|
|
|
|
|
length = strlen(password);
|
|
|
|
if (length > 0 && password[length - 1] != '\n')
|
|
|
|
{
|
2000-11-27 04:53:13 +01:00
|
|
|
/* eat rest of the line */
|
2000-07-21 13:43:26 +02:00
|
|
|
do
|
|
|
|
{
|
2000-11-27 04:53:13 +01:00
|
|
|
if (fgets(buf, sizeof(buf), stdin) == NULL)
|
|
|
|
break;
|
|
|
|
buflen = strlen(buf);
|
|
|
|
} while (buflen > 0 && buf[buflen - 1] != '\n');
|
2000-07-21 13:43:26 +02:00
|
|
|
}
|
|
|
|
if (length > 0 && password[length - 1] == '\n')
|
|
|
|
password[length - 1] = '\0';
|
|
|
|
|
|
|
|
fprintf(stderr, "\n\n");
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
static void
|
|
|
|
_check_database_version(ArchiveHandle *AH, bool ignoreVersion)
|
|
|
|
{
|
|
|
|
PGresult *res;
|
2001-03-22 05:01:46 +01:00
|
|
|
double myversion;
|
2000-07-21 13:43:26 +02:00
|
|
|
const char *remoteversion_str;
|
2001-03-22 05:01:46 +01:00
|
|
|
double remoteversion;
|
|
|
|
PGconn *conn = AH->connection;
|
2000-07-21 13:43:26 +02:00
|
|
|
|
|
|
|
myversion = strtod(PG_VERSION, NULL);
|
|
|
|
res = PQexec(conn, "SELECT version()");
|
|
|
|
if (!res ||
|
|
|
|
PQresultStatus(res) != PGRES_TUPLES_OK ||
|
|
|
|
PQntuples(res) != 1)
|
|
|
|
|
|
|
|
die_horribly(AH, "check_database_version(): command failed. "
|
2001-03-22 05:01:46 +01:00
|
|
|
"Explanation from backend: '%s'.\n", PQerrorMessage(conn));
|
2000-07-21 13:43:26 +02:00
|
|
|
|
|
|
|
remoteversion_str = PQgetvalue(res, 0, 0);
|
|
|
|
remoteversion = strtod(remoteversion_str + 11, NULL);
|
|
|
|
if (myversion != remoteversion)
|
|
|
|
{
|
|
|
|
fprintf(stderr, "Database version: %s\n%s version: %s\n",
|
2000-07-22 00:27:29 +02:00
|
|
|
remoteversion_str, progname, PG_VERSION);
|
2000-07-21 13:43:26 +02:00
|
|
|
if (ignoreVersion)
|
|
|
|
fprintf(stderr, "Proceeding despite version mismatch.\n");
|
|
|
|
else
|
|
|
|
die_horribly(AH, "Aborting because of version mismatch.\n"
|
2001-03-22 05:01:46 +01:00
|
|
|
"Use --ignore-version if you think it's safe to proceed anyway.\n");
|
2000-07-21 13:43:26 +02:00
|
|
|
}
|
|
|
|
PQclear(res);
|
|
|
|
}
|
|
|
|
|
2001-03-22 05:01:46 +01:00
|
|
|
/*
|
2000-08-01 17:51:45 +02:00
|
|
|
* Check if a given user is a superuser.
|
|
|
|
*/
|
2001-03-22 05:01:46 +01:00
|
|
|
int
|
|
|
|
UserIsSuperuser(ArchiveHandle *AH, char *user)
|
2000-08-01 17:51:45 +02:00
|
|
|
{
|
2001-03-22 05:01:46 +01:00
|
|
|
PQExpBuffer qry = createPQExpBuffer();
|
|
|
|
PGresult *res;
|
|
|
|
int i_usesuper;
|
|
|
|
int ntups;
|
|
|
|
int isSuper;
|
2000-08-01 17:51:45 +02:00
|
|
|
|
|
|
|
/* Get the superuser setting */
|
|
|
|
appendPQExpBuffer(qry, "select usesuper from pg_user where usename = '%s'", user);
|
|
|
|
res = PQexec(AH->connection, qry->data);
|
|
|
|
|
|
|
|
if (!res)
|
|
|
|
die_horribly(AH, "%s: null result checking superuser status of %s.\n",
|
2001-03-22 05:01:46 +01:00
|
|
|
progname, user);
|
2000-08-01 17:51:45 +02:00
|
|
|
|
|
|
|
if (PQresultStatus(res) != PGRES_TUPLES_OK)
|
|
|
|
die_horribly(AH, "%s: Could not check superuser status of %s. Explanation from backend: %s\n",
|
2001-03-22 05:01:46 +01:00
|
|
|
progname, user, PQerrorMessage(AH->connection));
|
2000-08-01 17:51:45 +02:00
|
|
|
|
|
|
|
ntups = PQntuples(res);
|
|
|
|
|
|
|
|
if (ntups == 0)
|
|
|
|
isSuper = 0;
|
|
|
|
else
|
|
|
|
{
|
|
|
|
i_usesuper = PQfnumber(res, "usesuper");
|
|
|
|
isSuper = (strcmp(PQgetvalue(res, 0, i_usesuper), "t") == 0);
|
|
|
|
}
|
|
|
|
PQclear(res);
|
|
|
|
|
|
|
|
return isSuper;
|
|
|
|
}
|
|
|
|
|
2001-03-22 05:01:46 +01:00
|
|
|
int
|
|
|
|
ConnectedUserIsSuperuser(ArchiveHandle *AH)
|
2000-08-01 17:51:45 +02:00
|
|
|
{
|
|
|
|
return UserIsSuperuser(AH, PQuser(AH->connection));
|
|
|
|
}
|
|
|
|
|
2001-03-22 05:01:46 +01:00
|
|
|
char *
|
|
|
|
ConnectedUser(ArchiveHandle *AH)
|
2000-08-01 17:51:45 +02:00
|
|
|
{
|
|
|
|
return PQuser(AH->connection);
|
|
|
|
}
|
|
|
|
|
|
|
|
/*
|
2001-03-22 05:01:46 +01:00
|
|
|
* Reconnect the DB associated with the archive handle
|
2000-08-01 17:51:45 +02:00
|
|
|
*/
|
2001-03-22 05:01:46 +01:00
|
|
|
int
|
|
|
|
ReconnectDatabase(ArchiveHandle *AH, const char *newdbname, char *newUser)
|
2000-08-01 17:51:45 +02:00
|
|
|
{
|
2001-03-22 05:01:46 +01:00
|
|
|
PGconn *newConn;
|
|
|
|
char *dbname;
|
2000-08-01 17:51:45 +02:00
|
|
|
|
2001-03-22 05:01:46 +01:00
|
|
|
if (!newdbname || (strcmp(newdbname, "-") == 0))
|
2000-08-01 17:51:45 +02:00
|
|
|
dbname = PQdb(AH->connection);
|
|
|
|
else
|
2001-03-22 05:01:46 +01:00
|
|
|
dbname = (char *) newdbname;
|
2000-08-01 17:51:45 +02:00
|
|
|
|
|
|
|
/* Let's see if the request is already satisfied */
|
|
|
|
if (strcmp(PQuser(AH->connection), newUser) == 0 && strcmp(newdbname, PQdb(AH->connection)) == 0)
|
|
|
|
return 1;
|
|
|
|
|
|
|
|
newConn = _connectDB(AH, dbname, newUser);
|
|
|
|
|
|
|
|
PQfinish(AH->connection);
|
|
|
|
AH->connection = newConn;
|
|
|
|
strcpy(AH->username, newUser);
|
|
|
|
|
|
|
|
return 1;
|
|
|
|
}
|
|
|
|
|
|
|
|
/*
|
|
|
|
* Connect to the db again.
|
|
|
|
*/
|
2001-03-22 05:01:46 +01:00
|
|
|
static PGconn *
|
|
|
|
_connectDB(ArchiveHandle *AH, const char *reqdb, char *requser)
|
2000-07-24 08:24:26 +02:00
|
|
|
{
|
|
|
|
int need_pass;
|
2001-03-22 05:01:46 +01:00
|
|
|
PGconn *newConn;
|
2000-07-24 08:24:26 +02:00
|
|
|
char password[100];
|
2001-03-22 05:01:46 +01:00
|
|
|
char *pwparam = NULL;
|
2000-07-24 08:24:26 +02:00
|
|
|
int badPwd = 0;
|
|
|
|
int noPwd = 0;
|
2001-03-22 05:01:46 +01:00
|
|
|
char *newdb;
|
|
|
|
char *newuser;
|
2000-07-24 08:24:26 +02:00
|
|
|
|
2001-03-22 05:01:46 +01:00
|
|
|
if (!reqdb || (strcmp(reqdb, "-") == 0))
|
2000-08-01 17:51:45 +02:00
|
|
|
newdb = PQdb(AH->connection);
|
|
|
|
else
|
2001-03-22 05:01:46 +01:00
|
|
|
newdb = (char *) reqdb;
|
2000-08-01 17:51:45 +02:00
|
|
|
|
|
|
|
if (!requser || (strlen(requser) == 0))
|
|
|
|
newuser = PQuser(AH->connection);
|
|
|
|
else
|
2001-03-22 05:01:46 +01:00
|
|
|
newuser = (char *) requser;
|
2000-08-01 17:51:45 +02:00
|
|
|
|
|
|
|
ahlog(AH, 1, "Connecting to %s as %s\n", newdb, newuser);
|
2000-07-24 08:24:26 +02:00
|
|
|
|
|
|
|
do
|
|
|
|
{
|
2000-08-01 17:51:45 +02:00
|
|
|
need_pass = false;
|
|
|
|
newConn = PQsetdbLogin(PQhost(AH->connection), PQport(AH->connection),
|
2001-03-22 05:01:46 +01:00
|
|
|
NULL, NULL, newdb,
|
|
|
|
newuser, pwparam);
|
2000-08-01 17:51:45 +02:00
|
|
|
if (!newConn)
|
|
|
|
die_horribly(AH, "%s: Failed to reconnect (PQsetdbLogin failed).\n", progname);
|
|
|
|
|
|
|
|
if (PQstatus(newConn) == CONNECTION_BAD)
|
|
|
|
{
|
|
|
|
noPwd = (strcmp(PQerrorMessage(newConn), "fe_sendauth: no password supplied\n") == 0);
|
|
|
|
badPwd = (strncmp(PQerrorMessage(newConn), "Password authentication failed for user", 39)
|
2001-03-22 05:01:46 +01:00
|
|
|
== 0);
|
2000-08-01 17:51:45 +02:00
|
|
|
|
2001-03-22 05:01:46 +01:00
|
|
|
if (noPwd || badPwd)
|
2000-08-01 17:51:45 +02:00
|
|
|
{
|
2000-07-24 08:24:26 +02:00
|
|
|
|
2000-08-01 17:51:45 +02:00
|
|
|
if (badPwd)
|
|
|
|
fprintf(stderr, "Password incorrect\n");
|
2000-07-24 08:24:26 +02:00
|
|
|
|
2000-08-01 17:51:45 +02:00
|
|
|
fprintf(stderr, "Connecting to %s as %s\n", PQdb(AH->connection), newuser);
|
2000-07-24 08:24:26 +02:00
|
|
|
|
2000-08-01 17:51:45 +02:00
|
|
|
need_pass = true;
|
|
|
|
_prompt_for_password(newuser, password);
|
2001-03-22 05:01:46 +01:00
|
|
|
pwparam = password;
|
2000-07-24 08:24:26 +02:00
|
|
|
}
|
2000-08-01 17:51:45 +02:00
|
|
|
else
|
|
|
|
die_horribly(AH, "%s: Could not reconnect. %s\n", progname, PQerrorMessage(newConn));
|
|
|
|
}
|
2000-07-24 08:24:26 +02:00
|
|
|
|
|
|
|
} while (need_pass);
|
|
|
|
|
2000-08-01 17:51:45 +02:00
|
|
|
return newConn;
|
2000-07-24 08:24:26 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
|
2001-03-22 05:01:46 +01:00
|
|
|
PGconn *
|
|
|
|
ConnectDatabase(Archive *AHX,
|
|
|
|
const char *dbname,
|
|
|
|
const char *pghost,
|
|
|
|
const char *pgport,
|
|
|
|
const int reqPwd,
|
|
|
|
const int ignoreVersion)
|
2000-07-21 13:43:26 +02:00
|
|
|
{
|
2001-03-22 05:01:46 +01:00
|
|
|
ArchiveHandle *AH = (ArchiveHandle *) AHX;
|
|
|
|
char connect_string[512] = "";
|
|
|
|
char tmp_string[128];
|
|
|
|
char password[100];
|
2000-07-21 13:43:26 +02:00
|
|
|
|
|
|
|
if (AH->connection)
|
|
|
|
die_horribly(AH, "%s: already connected to database\n", progname);
|
|
|
|
|
2001-03-22 05:01:46 +01:00
|
|
|
if (!dbname && !(dbname = getenv("PGDATABASE")))
|
2000-07-21 13:43:26 +02:00
|
|
|
die_horribly(AH, "%s: no database name specified\n", progname);
|
|
|
|
|
|
|
|
AH->dbname = strdup(dbname);
|
|
|
|
|
|
|
|
if (pghost != NULL)
|
|
|
|
{
|
|
|
|
AH->pghost = strdup(pghost);
|
|
|
|
sprintf(tmp_string, "host=%s ", AH->pghost);
|
|
|
|
strcat(connect_string, tmp_string);
|
|
|
|
}
|
|
|
|
else
|
2001-03-22 05:01:46 +01:00
|
|
|
AH->pghost = NULL;
|
2000-07-21 13:43:26 +02:00
|
|
|
|
|
|
|
if (pgport != NULL)
|
|
|
|
{
|
|
|
|
AH->pgport = strdup(pgport);
|
|
|
|
sprintf(tmp_string, "port=%s ", AH->pgport);
|
|
|
|
strcat(connect_string, tmp_string);
|
|
|
|
}
|
|
|
|
else
|
2001-03-22 05:01:46 +01:00
|
|
|
AH->pgport = NULL;
|
2000-07-21 13:43:26 +02:00
|
|
|
|
|
|
|
sprintf(tmp_string, "dbname=%s ", AH->dbname);
|
|
|
|
strcat(connect_string, tmp_string);
|
|
|
|
|
|
|
|
if (reqPwd)
|
|
|
|
{
|
2000-07-24 08:24:26 +02:00
|
|
|
AH->username[0] = '\0';
|
2000-07-21 13:43:26 +02:00
|
|
|
_prompt_for_password(AH->username, password);
|
|
|
|
strcat(connect_string, "authtype=password ");
|
|
|
|
sprintf(tmp_string, "user=%s ", AH->username);
|
|
|
|
strcat(connect_string, tmp_string);
|
|
|
|
sprintf(tmp_string, "password=%s ", password);
|
|
|
|
strcat(connect_string, tmp_string);
|
|
|
|
MemSet(tmp_string, 0, sizeof(tmp_string));
|
|
|
|
MemSet(password, 0, sizeof(password));
|
|
|
|
}
|
|
|
|
AH->connection = PQconnectdb(connect_string);
|
|
|
|
MemSet(connect_string, 0, sizeof(connect_string));
|
|
|
|
|
|
|
|
/* check to see that the backend connection was successfully made */
|
|
|
|
if (PQstatus(AH->connection) == CONNECTION_BAD)
|
|
|
|
die_horribly(AH, "Connection to database '%s' failed.\n%s\n",
|
2001-03-22 05:01:46 +01:00
|
|
|
AH->dbname, PQerrorMessage(AH->connection));
|
2000-07-21 13:43:26 +02:00
|
|
|
|
|
|
|
/* check for version mismatch */
|
|
|
|
_check_database_version(AH, ignoreVersion);
|
|
|
|
|
2000-08-01 17:51:45 +02:00
|
|
|
/*
|
2001-03-22 05:01:46 +01:00
|
|
|
* AH->currUser = PQuser(AH->connection);
|
|
|
|
*
|
|
|
|
* Removed because it prevented an initial \connect when dumping to SQL
|
|
|
|
* in pg_dump.
|
2000-08-01 17:51:45 +02:00
|
|
|
*/
|
2000-07-24 08:24:26 +02:00
|
|
|
|
2000-07-21 13:43:26 +02:00
|
|
|
return AH->connection;
|
|
|
|
}
|
|
|
|
|
2000-08-01 17:51:45 +02:00
|
|
|
/* Public interface */
|
2000-07-21 13:43:26 +02:00
|
|
|
/* Convenience function to send a query. Monitors result to handle COPY statements */
|
2001-03-22 05:01:46 +01:00
|
|
|
int
|
|
|
|
ExecuteSqlCommand(ArchiveHandle *AH, PQExpBuffer qry, char *desc)
|
2000-08-01 17:51:45 +02:00
|
|
|
{
|
|
|
|
return _executeSqlCommand(AH, AH->connection, qry, desc);
|
|
|
|
}
|
|
|
|
|
2001-03-22 05:01:46 +01:00
|
|
|
/*
|
2000-08-01 17:51:45 +02:00
|
|
|
* Handle command execution. This is used to execute a command on more than one connection,
|
|
|
|
* but the 'pgCopyIn' setting assumes the COPY commands are ONLY executed on the primary
|
|
|
|
* setting...an error will be raised otherwise.
|
|
|
|
*/
|
2001-03-22 05:01:46 +01:00
|
|
|
static int
|
|
|
|
_executeSqlCommand(ArchiveHandle *AH, PGconn *conn, PQExpBuffer qry, char *desc)
|
2000-07-21 13:43:26 +02:00
|
|
|
{
|
2001-03-22 05:01:46 +01:00
|
|
|
PGresult *res;
|
2000-07-21 13:43:26 +02:00
|
|
|
|
|
|
|
/* fprintf(stderr, "Executing: '%s'\n\n", qry->data); */
|
2000-08-01 17:51:45 +02:00
|
|
|
res = PQexec(conn, qry->data);
|
2000-07-21 13:43:26 +02:00
|
|
|
if (!res)
|
|
|
|
die_horribly(AH, "%s: %s. No result from backend.\n", progname, desc);
|
|
|
|
|
2001-03-22 05:01:46 +01:00
|
|
|
if (PQresultStatus(res) != PGRES_COMMAND_OK && PQresultStatus(res) != PGRES_TUPLES_OK)
|
2000-07-21 13:43:26 +02:00
|
|
|
{
|
|
|
|
if (PQresultStatus(res) == PGRES_COPY_IN)
|
2000-08-01 17:51:45 +02:00
|
|
|
{
|
|
|
|
if (conn != AH->connection)
|
|
|
|
die_horribly(AH, "%s: COPY command execute in non-primary connection.\n", progname);
|
|
|
|
|
2000-07-21 13:43:26 +02:00
|
|
|
AH->pgCopyIn = 1;
|
2000-08-01 17:51:45 +02:00
|
|
|
}
|
2001-03-22 05:01:46 +01:00
|
|
|
else
|
2000-07-21 13:43:26 +02:00
|
|
|
die_horribly(AH, "%s: %s. Code = %d. Explanation from backend: '%s'.\n",
|
2001-03-22 05:01:46 +01:00
|
|
|
progname, desc, PQresultStatus(res), PQerrorMessage(AH->connection));
|
2000-07-21 13:43:26 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
PQclear(res);
|
|
|
|
|
|
|
|
return strlen(qry->data);
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Convenience function to send one or more queries. Monitors result to handle COPY statements */
|
2001-03-22 05:01:46 +01:00
|
|
|
int
|
|
|
|
ExecuteSqlCommandBuf(ArchiveHandle *AH, void *qryv, int bufLen)
|
2000-07-21 13:43:26 +02:00
|
|
|
{
|
2001-03-22 05:01:46 +01:00
|
|
|
int loc;
|
|
|
|
int pos = 0;
|
|
|
|
int sPos = 0;
|
|
|
|
char *qry = (char *) qryv;
|
|
|
|
int isEnd = 0;
|
|
|
|
char *eos = qry + bufLen;
|
2000-07-21 13:43:26 +02:00
|
|
|
|
2001-03-22 05:01:46 +01:00
|
|
|
/*
|
|
|
|
* fprintf(stderr, "\n\n*****\n
|
|
|
|
* Buffer:\n\n%s\n*******************\n\n", qry);
|
|
|
|
*/
|
2000-07-21 13:43:26 +02:00
|
|
|
|
|
|
|
/* If we're in COPY IN mode, then just break it into lines and send... */
|
2001-03-22 05:01:46 +01:00
|
|
|
if (AH->pgCopyIn)
|
|
|
|
{
|
|
|
|
for (;;)
|
|
|
|
{
|
2000-07-21 13:43:26 +02:00
|
|
|
|
|
|
|
/* Find a lf */
|
|
|
|
loc = strcspn(&qry[pos], "\n") + pos;
|
|
|
|
pos = 0;
|
|
|
|
|
|
|
|
/* If no match, then wait */
|
2001-03-22 05:01:46 +01:00
|
|
|
if (loc >= (eos - qry)) /* None found */
|
2000-07-21 13:43:26 +02:00
|
|
|
{
|
|
|
|
appendBinaryPQExpBuffer(AH->pgCopyBuf, qry, (eos - qry));
|
|
|
|
break;
|
|
|
|
};
|
|
|
|
|
2001-03-22 05:01:46 +01:00
|
|
|
/*
|
|
|
|
* fprintf(stderr, "Found cr at %d, prev char was %c, next was
|
|
|
|
* %c\n", loc, qry[loc-1], qry[loc+1]);
|
|
|
|
*/
|
|
|
|
|
2000-07-21 13:43:26 +02:00
|
|
|
/* Count the number of preceding slashes */
|
|
|
|
sPos = loc;
|
2001-03-22 05:01:46 +01:00
|
|
|
while (sPos > 0 && qry[sPos - 1] == '\\')
|
2000-07-21 13:43:26 +02:00
|
|
|
sPos--;
|
|
|
|
|
|
|
|
sPos = loc - sPos;
|
|
|
|
|
2001-03-22 05:01:46 +01:00
|
|
|
/*
|
|
|
|
* If an odd number of preceding slashes, then \n was escaped
|
2000-07-21 13:43:26 +02:00
|
|
|
* so set the next search pos, and restart (if any left).
|
|
|
|
*/
|
|
|
|
if ((sPos & 1) == 1)
|
|
|
|
{
|
|
|
|
/* fprintf(stderr, "cr was escaped\n"); */
|
|
|
|
pos = loc + 1;
|
|
|
|
if (pos >= (eos - qry))
|
|
|
|
{
|
|
|
|
appendBinaryPQExpBuffer(AH->pgCopyBuf, qry, (eos - qry));
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
else
|
|
|
|
{
|
|
|
|
/* We got a good cr */
|
|
|
|
qry[loc] = '\0';
|
|
|
|
appendPQExpBuffer(AH->pgCopyBuf, "%s\n", qry);
|
2001-03-22 05:01:46 +01:00
|
|
|
qry += loc + 1;
|
2000-07-21 13:43:26 +02:00
|
|
|
isEnd = (strcmp(AH->pgCopyBuf->data, "\\.\n") == 0);
|
|
|
|
|
2001-03-23 05:49:58 +01:00
|
|
|
/*---------
|
|
|
|
* fprintf(stderr, "Sending '%s' via
|
|
|
|
* COPY (at end = %d)\n\n", AH->pgCopyBuf->data, isEnd);
|
|
|
|
*---------
|
2001-03-22 05:01:46 +01:00
|
|
|
*/
|
|
|
|
|
2001-01-12 05:32:07 +01:00
|
|
|
if (PQputline(AH->connection, AH->pgCopyBuf->data) != 0)
|
|
|
|
die_horribly(AH, "%s: error returned by PQputline\n", progname);
|
2000-07-21 13:43:26 +02:00
|
|
|
|
|
|
|
resetPQExpBuffer(AH->pgCopyBuf);
|
|
|
|
|
2001-03-22 05:01:46 +01:00
|
|
|
/*
|
|
|
|
* fprintf(stderr, "Buffer is '%s'\n",
|
|
|
|
* AH->pgCopyBuf->data);
|
|
|
|
*/
|
2000-07-21 13:43:26 +02:00
|
|
|
|
2001-03-22 05:01:46 +01:00
|
|
|
if (isEnd)
|
|
|
|
{
|
2001-01-12 05:32:07 +01:00
|
|
|
if (PQendcopy(AH->connection) != 0)
|
|
|
|
die_horribly(AH, "%s: error returned by PQendcopy\n", progname);
|
|
|
|
|
2000-07-21 13:43:26 +02:00
|
|
|
AH->pgCopyIn = 0;
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Make sure we're not past the original buffer end */
|
|
|
|
if (qry >= eos)
|
|
|
|
break;
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
/* We may have finished Copy In, and have a non-empty buffer */
|
2001-03-22 05:01:46 +01:00
|
|
|
if (!AH->pgCopyIn)
|
|
|
|
{
|
2000-07-21 13:43:26 +02:00
|
|
|
|
2001-03-22 05:01:46 +01:00
|
|
|
/*
|
|
|
|
* The following is a mini state machine to assess then of of an
|
|
|
|
* SQL statement. It really only needs to parse good SQL, or at
|
|
|
|
* least that's the theory... End-of-statement is assumed to be an
|
|
|
|
* unquoted, un commented semi-colon.
|
2000-07-21 13:43:26 +02:00
|
|
|
*/
|
|
|
|
|
2001-03-22 05:01:46 +01:00
|
|
|
/*
|
|
|
|
* fprintf(stderr, "Buffer at start is: '%s'\n\n",
|
|
|
|
* AH->sqlBuf->data);
|
|
|
|
*/
|
2000-07-21 13:43:26 +02:00
|
|
|
|
2001-03-22 05:01:46 +01:00
|
|
|
for (pos = 0; pos < (eos - qry); pos++)
|
2000-07-21 13:43:26 +02:00
|
|
|
{
|
|
|
|
appendPQExpBufferChar(AH->sqlBuf, qry[pos]);
|
|
|
|
/* fprintf(stderr, " %c",qry[pos]); */
|
|
|
|
|
2001-03-22 05:01:46 +01:00
|
|
|
switch (AH->sqlparse.state)
|
|
|
|
{
|
2000-07-21 13:43:26 +02:00
|
|
|
|
2001-03-22 05:01:46 +01:00
|
|
|
case SQL_SCAN: /* Default state == 0, set in _allocAH */
|
2000-07-21 13:43:26 +02:00
|
|
|
|
2000-09-15 06:35:16 +02:00
|
|
|
if (qry[pos] == ';' && AH->sqlparse.braceDepth == 0)
|
2000-07-21 13:43:26 +02:00
|
|
|
{
|
|
|
|
/* Send It & reset the buffer */
|
2001-03-22 05:01:46 +01:00
|
|
|
|
|
|
|
/*
|
|
|
|
* fprintf(stderr, " sending: '%s'\n\n",
|
|
|
|
* AH->sqlBuf->data);
|
|
|
|
*/
|
2000-07-21 13:43:26 +02:00
|
|
|
ExecuteSqlCommand(AH, AH->sqlBuf, "Could not execute query");
|
|
|
|
resetPQExpBuffer(AH->sqlBuf);
|
|
|
|
AH->sqlparse.lastChar = '\0';
|
2001-03-22 05:01:46 +01:00
|
|
|
}
|
|
|
|
else
|
2000-07-21 13:43:26 +02:00
|
|
|
{
|
|
|
|
if (qry[pos] == '"' || qry[pos] == '\'')
|
2001-03-22 05:01:46 +01:00
|
|
|
{
|
2000-07-21 13:43:26 +02:00
|
|
|
/* fprintf(stderr,"[startquote]\n"); */
|
|
|
|
AH->sqlparse.state = SQL_IN_QUOTE;
|
|
|
|
AH->sqlparse.quoteChar = qry[pos];
|
|
|
|
AH->sqlparse.backSlash = 0;
|
2001-03-22 05:01:46 +01:00
|
|
|
}
|
2000-07-21 13:43:26 +02:00
|
|
|
else if (qry[pos] == '-' && AH->sqlparse.lastChar == '-')
|
|
|
|
AH->sqlparse.state = SQL_IN_SQL_COMMENT;
|
|
|
|
else if (qry[pos] == '*' && AH->sqlparse.lastChar == '/')
|
|
|
|
AH->sqlparse.state = SQL_IN_EXT_COMMENT;
|
2001-03-22 05:01:46 +01:00
|
|
|
else if (qry[pos] == '(')
|
2000-09-15 06:35:16 +02:00
|
|
|
AH->sqlparse.braceDepth++;
|
|
|
|
else if (qry[pos] == ')')
|
|
|
|
AH->sqlparse.braceDepth--;
|
|
|
|
|
2000-07-21 13:43:26 +02:00
|
|
|
AH->sqlparse.lastChar = qry[pos];
|
|
|
|
}
|
|
|
|
|
|
|
|
break;
|
|
|
|
|
|
|
|
case SQL_IN_SQL_COMMENT:
|
|
|
|
|
|
|
|
if (qry[pos] == '\n')
|
|
|
|
AH->sqlparse.state = SQL_SCAN;
|
|
|
|
break;
|
|
|
|
|
|
|
|
case SQL_IN_EXT_COMMENT:
|
|
|
|
|
|
|
|
if (AH->sqlparse.lastChar == '*' && qry[pos] == '/')
|
|
|
|
AH->sqlparse.state = SQL_SCAN;
|
|
|
|
break;
|
|
|
|
|
|
|
|
case SQL_IN_QUOTE:
|
|
|
|
|
|
|
|
if (!AH->sqlparse.backSlash && AH->sqlparse.quoteChar == qry[pos])
|
|
|
|
{
|
|
|
|
/* fprintf(stderr,"[endquote]\n"); */
|
|
|
|
AH->sqlparse.state = SQL_SCAN;
|
2001-03-22 05:01:46 +01:00
|
|
|
}
|
|
|
|
else
|
2000-07-21 13:43:26 +02:00
|
|
|
{
|
|
|
|
|
|
|
|
if (qry[pos] == '\\')
|
|
|
|
{
|
|
|
|
if (AH->sqlparse.lastChar == '\\')
|
|
|
|
AH->sqlparse.backSlash = !AH->sqlparse.backSlash;
|
|
|
|
else
|
|
|
|
AH->sqlparse.backSlash = 1;
|
|
|
|
}
|
2001-03-22 05:01:46 +01:00
|
|
|
else
|
|
|
|
AH->sqlparse.backSlash = 0;
|
2000-07-21 13:43:26 +02:00
|
|
|
}
|
|
|
|
break;
|
|
|
|
|
|
|
|
}
|
|
|
|
AH->sqlparse.lastChar = qry[pos];
|
|
|
|
/* fprintf(stderr, "\n"); */
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
return 1;
|
|
|
|
}
|
|
|
|
|
2001-03-22 05:01:46 +01:00
|
|
|
void
|
|
|
|
FixupBlobRefs(ArchiveHandle *AH, char *tablename)
|
2000-07-21 13:43:26 +02:00
|
|
|
{
|
2001-03-22 05:01:46 +01:00
|
|
|
PQExpBuffer tblQry = createPQExpBuffer();
|
|
|
|
PGresult *res,
|
|
|
|
*uRes;
|
|
|
|
int i,
|
|
|
|
n;
|
|
|
|
char *attr;
|
2000-07-21 13:43:26 +02:00
|
|
|
|
|
|
|
if (strcmp(tablename, BLOB_XREF_TABLE) == 0)
|
|
|
|
return;
|
|
|
|
|
|
|
|
appendPQExpBuffer(tblQry, "SELECT a.attname FROM pg_class c, pg_attribute a, pg_type t "
|
2001-03-22 05:01:46 +01:00
|
|
|
" WHERE a.attnum > 0 AND a.attrelid = c.oid AND a.atttypid = t.oid "
|
|
|
|
" AND t.typname = 'oid' AND c.relname = '%s';", tablename);
|
2000-07-21 13:43:26 +02:00
|
|
|
|
2000-08-01 17:51:45 +02:00
|
|
|
res = PQexec(AH->blobConnection, tblQry->data);
|
2000-07-21 13:43:26 +02:00
|
|
|
if (!res)
|
|
|
|
die_horribly(AH, "%s: could not find OID attrs of %s. Explanation from backend '%s'\n",
|
2001-03-22 05:01:46 +01:00
|
|
|
progname, tablename, PQerrorMessage(AH->connection));
|
2000-07-21 13:43:26 +02:00
|
|
|
|
2001-03-22 05:01:46 +01:00
|
|
|
if ((n = PQntuples(res)) == 0)
|
|
|
|
{
|
2000-07-21 13:43:26 +02:00
|
|
|
/* We're done */
|
|
|
|
ahlog(AH, 1, "No OID attributes in table %s\n", tablename);
|
|
|
|
PQclear(res);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
2001-03-22 05:01:46 +01:00
|
|
|
for (i = 0; i < n; i++)
|
2000-07-21 13:43:26 +02:00
|
|
|
{
|
|
|
|
attr = PQgetvalue(res, i, 0);
|
|
|
|
|
|
|
|
ahlog(AH, 1, " - %s.%s\n", tablename, attr);
|
|
|
|
|
|
|
|
resetPQExpBuffer(tblQry);
|
|
|
|
|
2000-08-05 11:57:46 +02:00
|
|
|
/*
|
2001-03-22 05:01:46 +01:00
|
|
|
* We should use coalesce here (rather than 'exists'), but it
|
|
|
|
* seems to be broken in 7.0.2 (weird optimizer strategy)
|
2000-08-05 11:57:46 +02:00
|
|
|
*/
|
2001-03-22 05:01:46 +01:00
|
|
|
appendPQExpBuffer(tblQry, "UPDATE \"%s\" SET \"%s\" = ", tablename, attr);
|
2000-08-05 11:57:46 +02:00
|
|
|
appendPQExpBuffer(tblQry, " (SELECT x.newOid FROM \"%s\" x WHERE x.oldOid = \"%s\".\"%s\")",
|
2001-03-22 05:01:46 +01:00
|
|
|
BLOB_XREF_TABLE, tablename, attr);
|
2000-08-05 11:57:46 +02:00
|
|
|
appendPQExpBuffer(tblQry, " where exists"
|
2001-03-22 05:01:46 +01:00
|
|
|
"(select * from %s x where x.oldOid = \"%s\".\"%s\");",
|
|
|
|
BLOB_XREF_TABLE, tablename, attr);
|
2000-07-21 13:43:26 +02:00
|
|
|
|
2000-08-05 11:57:46 +02:00
|
|
|
ahlog(AH, 10, " - sql:\n%s\n", tblQry->data);
|
2000-07-21 13:43:26 +02:00
|
|
|
|
2000-08-01 17:51:45 +02:00
|
|
|
uRes = PQexec(AH->blobConnection, tblQry->data);
|
2000-07-21 13:43:26 +02:00
|
|
|
if (!uRes)
|
|
|
|
die_horribly(AH, "%s: could not update attr %s of table %s. Explanation from backend '%s'\n",
|
2001-03-22 05:01:46 +01:00
|
|
|
progname, attr, tablename, PQerrorMessage(AH->blobConnection));
|
2000-07-21 13:43:26 +02:00
|
|
|
|
2001-03-22 05:01:46 +01:00
|
|
|
if (PQresultStatus(uRes) != PGRES_COMMAND_OK)
|
2000-08-05 11:57:46 +02:00
|
|
|
die_horribly(AH, "%s: error while updating attr %s of table %s (result = %d)."
|
2001-03-22 05:01:46 +01:00
|
|
|
" Explanation from backend '%s'\n",
|
|
|
|
progname, attr, tablename, PQresultStatus(uRes),
|
|
|
|
PQerrorMessage(AH->blobConnection));
|
2000-07-21 13:43:26 +02:00
|
|
|
|
|
|
|
PQclear(uRes);
|
|
|
|
}
|
|
|
|
|
|
|
|
PQclear(res);
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
/**********
|
|
|
|
* Convenient SQL calls
|
|
|
|
**********/
|
2001-03-22 05:01:46 +01:00
|
|
|
void
|
|
|
|
CreateBlobXrefTable(ArchiveHandle *AH)
|
2000-07-21 13:43:26 +02:00
|
|
|
{
|
2001-03-22 05:01:46 +01:00
|
|
|
PQExpBuffer qry = createPQExpBuffer();
|
2000-07-21 13:43:26 +02:00
|
|
|
|
2000-08-01 17:51:45 +02:00
|
|
|
/* IF we don't have a BLOB connection, then create one */
|
|
|
|
if (!AH->blobConnection)
|
|
|
|
AH->blobConnection = _connectDB(AH, NULL, NULL);
|
|
|
|
|
2000-07-21 13:43:26 +02:00
|
|
|
ahlog(AH, 1, "Creating table for BLOBS xrefs\n");
|
|
|
|
|
|
|
|
appendPQExpBuffer(qry, "Create Temporary Table %s(oldOid oid, newOid oid);", BLOB_XREF_TABLE);
|
|
|
|
|
2000-08-01 17:51:45 +02:00
|
|
|
_executeSqlCommand(AH, AH->blobConnection, qry, "can not create BLOB xref table '" BLOB_XREF_TABLE "'");
|
2000-07-21 13:43:26 +02:00
|
|
|
|
|
|
|
resetPQExpBuffer(qry);
|
|
|
|
|
|
|
|
appendPQExpBuffer(qry, "Create Unique Index %s_ix on %s(oldOid)", BLOB_XREF_TABLE, BLOB_XREF_TABLE);
|
2000-08-01 17:51:45 +02:00
|
|
|
_executeSqlCommand(AH, AH->blobConnection, qry, "can not create index on BLOB xref table '" BLOB_XREF_TABLE "'");
|
2000-07-21 13:43:26 +02:00
|
|
|
}
|
|
|
|
|
2001-03-22 05:01:46 +01:00
|
|
|
void
|
|
|
|
InsertBlobXref(ArchiveHandle *AH, int old, int new)
|
2000-07-21 13:43:26 +02:00
|
|
|
{
|
2001-03-22 05:01:46 +01:00
|
|
|
PQExpBuffer qry = createPQExpBuffer();
|
2000-07-21 13:43:26 +02:00
|
|
|
|
|
|
|
appendPQExpBuffer(qry, "Insert Into %s(oldOid, newOid) Values (%d, %d);", BLOB_XREF_TABLE, old, new);
|
|
|
|
|
2000-08-01 17:51:45 +02:00
|
|
|
_executeSqlCommand(AH, AH->blobConnection, qry, "can not create BLOB xref entry");
|
2000-07-21 13:43:26 +02:00
|
|
|
}
|
|
|
|
|
2001-03-22 05:01:46 +01:00
|
|
|
void
|
|
|
|
StartTransaction(ArchiveHandle *AH)
|
2000-07-21 13:43:26 +02:00
|
|
|
{
|
2001-03-22 05:01:46 +01:00
|
|
|
PQExpBuffer qry = createPQExpBuffer();
|
2000-07-21 13:43:26 +02:00
|
|
|
|
|
|
|
appendPQExpBuffer(qry, "Begin;");
|
|
|
|
|
|
|
|
ExecuteSqlCommand(AH, qry, "can not start database transaction");
|
2000-10-31 15:20:30 +01:00
|
|
|
AH->txActive = true;
|
|
|
|
}
|
|
|
|
|
2001-03-22 05:01:46 +01:00
|
|
|
void
|
|
|
|
StartTransactionXref(ArchiveHandle *AH)
|
2000-10-31 15:20:30 +01:00
|
|
|
{
|
2001-03-22 05:01:46 +01:00
|
|
|
PQExpBuffer qry = createPQExpBuffer();
|
2000-10-31 15:20:30 +01:00
|
|
|
|
|
|
|
appendPQExpBuffer(qry, "Begin;");
|
|
|
|
|
|
|
|
_executeSqlCommand(AH, AH->blobConnection, qry, "can not start BLOB xref transaction");
|
|
|
|
AH->blobTxActive = true;
|
2000-07-21 13:43:26 +02:00
|
|
|
}
|
|
|
|
|
2001-03-22 05:01:46 +01:00
|
|
|
void
|
|
|
|
CommitTransaction(ArchiveHandle *AH)
|
2000-07-21 13:43:26 +02:00
|
|
|
{
|
2001-03-22 05:01:46 +01:00
|
|
|
PQExpBuffer qry = createPQExpBuffer();
|
2000-07-21 13:43:26 +02:00
|
|
|
|
2001-03-22 05:01:46 +01:00
|
|
|
appendPQExpBuffer(qry, "Commit;");
|
2000-07-21 13:43:26 +02:00
|
|
|
|
2001-03-22 05:01:46 +01:00
|
|
|
ExecuteSqlCommand(AH, qry, "can not commit database transaction");
|
2000-10-31 15:20:30 +01:00
|
|
|
AH->txActive = false;
|
2000-07-21 13:43:26 +02:00
|
|
|
}
|
|
|
|
|
2001-03-22 05:01:46 +01:00
|
|
|
void
|
|
|
|
CommitTransactionXref(ArchiveHandle *AH)
|
2000-10-31 15:20:30 +01:00
|
|
|
{
|
2001-03-22 05:01:46 +01:00
|
|
|
PQExpBuffer qry = createPQExpBuffer();
|
2000-07-21 13:43:26 +02:00
|
|
|
|
2000-10-31 15:20:30 +01:00
|
|
|
appendPQExpBuffer(qry, "Commit;");
|
|
|
|
|
|
|
|
_executeSqlCommand(AH, AH->blobConnection, qry, "can not commit BLOB xref transaction");
|
|
|
|
AH->blobTxActive = false;
|
|
|
|
}
|