+$Header: /cvsroot/pgsql/contrib/pg_dumplo/Attic/README.pg_dumplo,v 1.2 2000/11/22 00:00:55 tgl Exp $
Welcome to psql, the PostgreSQL interactive terminal.
shows that we have one record in the table.
+for a selective dump.
+directory can hold the dump of multiple databases.
-Welcome to psql, the PostgreSQL interactive terminal.
+the database.
+/* -------------------------------------------------------------------------
+ * pg_dumplo
+ *
+ * Portions Copyright (c) 1999-2000, PostgreSQL, Inc
+ *
+ * $Header: /cvsroot/pgsql/contrib/pg_dumplo/Attic/lo_export.c,v 1.4 2000/11/22 00:00:55 tgl Exp $
+ *
+ * Karel Zak 1999-2000
+ * -------------------------------------------------------------------------
+ */
#include
#include
extern int errno;
-#define LOAD_LOLIST_QUERY "\
- SELECT c.relname, a.attname \
- FROM pg_class c, pg_attribute a, pg_type t \
- WHERE a.attnum > 0 \
- AND a.attrelid = c.oid \
- AND a.atttypid = t.oid \
- AND t.typname = 'oid' \
- AND c.relname NOT LIKE 'pg_%'"
-
void
load_lolist( LODumpMaster *pgLO )
int n;
/* ----------
- * Now find any candidate tables who have columns of type oid (the
- * column oid is ignored, as it has attnum < 1)
+ * Now find any candidate tables who have columns of type oid.
+ *
+ * NOTE: System tables including pg_largeobject will be ignored.
+ * Otherwise we'd end up dumping all LOs, referenced or not.
+ *
+ * NOTE: the system oid column is ignored, as it has attnum < 1.
+ * This shouldn't matter for correctness, but it saves time.
* ----------
*/
- if (!(pgLO->res = PQexec(pgLO->conn, LOAD_LOLIST_QUERY))) {
-
- fprintf(stderr, "%s: Select from pg_class failed.\n", progname);
- exit(RE_ERROR);
- }
-
+ pgLO->res = PQexec(pgLO->conn,
+ "SELECT c.relname, a.attname "
+ "FROM pg_class c, pg_attribute a, pg_type t "
+ "WHERE a.attnum > 0 "
+ " AND a.attrelid = c.oid "
+ " AND a.atttypid = t.oid "
+ " AND t.typname = 'oid' "
+ " AND c.relkind = 'r' "
+ " AND c.relname NOT LIKE 'pg_%'");
+
+ if (PQresultStatus(pgLO->res) != PGRES_TUPLES_OK) {
+ fprintf(stderr, "%s: Failed to get LO OIDs:\n%s", progname,
+ PQerrorMessage(pgLO->conn));
+ exit(RE_ERROR);
+ }
+
if ((n = PQntuples(pgLO->res)) == 0) {
-
- fprintf(stderr, "%s: No large objects in the database.\n", progname);
+ fprintf(stderr, "%s: No OID columns in the database.\n", progname);
exit(RE_ERROR);
}
ll->lo_table = strdup(PQgetvalue(pgLO->res, i, 0));
ll->lo_attr = strdup(PQgetvalue(pgLO->res, i, 1));
}
+ ll->lo_table = ll->lo_attr = (char *) NULL;
PQclear(pgLO->res);
- ll++;
- ll->lo_table = ll->lo_attr = (char *) NULL;
}
void
for(ll=pgLO->lolist; ll->lo_table != NULL; ll++) {
/* ----------
- * Query
+ * Query: find the LOs referenced by this column
* ----------
*/
- sprintf(Qbuff, "SELECT DISTINCT x.\"%s\" FROM \"%s\" x, pg_largeobject l WHERE x.\"%s\" = l.loid",
- ll->lo_attr, ll->lo_table, ll->lo_attr);
+ sprintf(Qbuff, "SELECT DISTINCT l.loid FROM \"%s\" x, pg_largeobject l WHERE x.\"%s\" = l.loid",
+ ll->lo_table, ll->lo_attr);
/* puts(Qbuff); */
pgLO->res = PQexec(pgLO->conn, Qbuff);
-
- if ((tuples = PQntuples(pgLO->res)) == 0) {
-
+
+ if (PQresultStatus(pgLO->res) != PGRES_TUPLES_OK) {
+ fprintf(stderr, "%s: Failed to get LO OIDs:\n%s", progname,
+ PQerrorMessage(pgLO->conn));
+ }
+ else if ((tuples = PQntuples(pgLO->res)) == 0) {
if (!pgLO->quiet && pgLO->action == ACTION_EXPORT_ATTR)
- printf("%s: no large objects in '%s'\n",
- progname, ll->lo_table);
- continue;
-
- } else if (check_res(pgLO)) {
+ printf("%s: no large objects in \"%s\".\"%s\"\n",
+ progname, ll->lo_table, ll->lo_attr);
+ } else {
int t;
char *val;
* Create DIR/FILE
* ----------
*/
- if (tuples && pgLO->action != ACTION_SHOW) {
+ if (pgLO->action != ACTION_SHOW) {
- sprintf(path, "%s/%s/%s", pgLO->space, pgLO->db, ll->lo_table);
+ sprintf(path, "%s/%s/%s", pgLO->space, pgLO->db,
+ ll->lo_table);
if (mkdir(path, DIR_UMASK) == -1) {
if (errno != EEXIST) {
exit(RE_ERROR);
}
}
-
- sprintf(path, "%s/%s", path, ll->lo_attr);
+
+ sprintf(path, "%s/%s/%s/%s", pgLO->space, pgLO->db,
+ ll->lo_table, ll->lo_attr);
if (mkdir(path, DIR_UMASK) == -1) {
if (errno != EEXIST) {
pgLO->counter += tuples;
for(t=0; t
-
- Oid lo = (Oid) 0;
+ Oid lo;
val = PQgetvalue(pgLO->res, t, 0);
- if (!val)
- continue;
- else
- lo = (Oid) atol(val);
+ lo = atooid(val);
if (pgLO->action == ACTION_SHOW) {
- printf("%s.%s: %ld\n", ll->lo_table,
- ll->lo_attr, (long) lo);
+ printf("%s.%s: %u\n", ll->lo_table, ll->lo_attr, lo);
continue;
}
pgLO->db, ll->lo_table, ll->lo_attr, val);
if (lo_export(pgLO->conn, lo, path) < 0)
- fprintf(stderr, "%s: %s\n", PQerrorMessage(pgLO->conn), progname);
+ fprintf(stderr, "%s: lo_export failed:\n%s", progname,
+ PQerrorMessage(pgLO->conn));
else
fprintf(pgLO->index, "%s\t%s\t%s\t%s/%s/%s/%s\n", val,
ll->lo_table, ll->lo_attr, pgLO->db, ll->lo_table, ll->lo_attr, val);
}
}
- }
- }
+ PQclear(pgLO->res);
+ }
+}
+/* -------------------------------------------------------------------------
+ * pg_dumplo
+ *
+ * Portions Copyright (c) 1999-2000, PostgreSQL, Inc
+ *
+ * $Header: /cvsroot/pgsql/contrib/pg_dumplo/Attic/lo_import.c,v 1.2 2000/11/22 00:00:55 tgl Exp $
+ *
+ * Karel Zak 1999-2000
+ * -------------------------------------------------------------------------
+ */
#include
#include
pglo_import(LODumpMaster *pgLO)
{
LOlist loa;
- long new_oid;
+ Oid new_oid;
char tab[MAX_TABLE_NAME], attr[MAX_ATTR_NAME],
path[BUFSIZ], lo_path[BUFSIZ],
Qbuff[QUERY_BUFSIZ];
if (! pgLO->remove && ! pgLO->quiet)
printf(Qbuff);
- sscanf(Qbuff, "%ld\t%s\t%s\t%s\n", &loa.lo_oid, tab, attr, path);
+ sscanf(Qbuff, "%u\t%s\t%s\t%s\n", &loa.lo_oid, tab, attr, path);
loa.lo_table = tab;
loa.lo_attr = attr;
* Import LO
* ----------
*/
- if ((new_oid = lo_import(pgLO->conn, lo_path)) <= 0) {
+ if ((new_oid = lo_import(pgLO->conn, lo_path)) == 0) {
fprintf(stderr, "%s: %s\n", progname, PQerrorMessage(pgLO->conn));
if (pgLO->remove) {
notice(pgLO, FALSE);
- if (lo_unlink(pgLO->conn, (Oid) loa.lo_oid) < 0)
- fprintf(stderr, "%s: can't remove LO: %ld (%s)\n",
+ if (lo_unlink(pgLO->conn, loa.lo_oid) < 0)
+ fprintf(stderr, "%s: can't remove LO %u:\n%s",
progname, loa.lo_oid, PQerrorMessage(pgLO->conn));
else if (!pgLO->quiet)
- printf("remove old %ld and create new %ld\n",
+ printf("remove old %u and create new %u\n",
loa.lo_oid, new_oid);
notice(pgLO, TRUE);
}
* UPDATE oid in tab
* ----------
*/
- sprintf(Qbuff, "UPDATE %s SET %s=%ld WHERE %s=%ld",
+ sprintf(Qbuff, "UPDATE \"%s\" SET \"%s\"=%u WHERE \"%s\"=%u",
loa.lo_table, loa.lo_attr, new_oid, loa.lo_attr, loa.lo_oid);
/*fprintf(stderr, Qbuff);*/
pgLO->res = PQexec(pgLO->conn, Qbuff);
- if (!pgLO->res && PQresultStatus(pgLO->res) != PGRES_COMMAND_OK) {
-
- fprintf(stderr, "%s: %s\n",progname, PQerrorMessage(pgLO->conn));
- PQclear(pgLO->res);
- PQexec(pgLO->conn, "ROLLBACK");
+ if (PQresultStatus(pgLO->res) != PGRES_COMMAND_OK) {
+ fprintf(stderr, "%s: %s\n",progname, PQerrorMessage(pgLO->conn));
+ PQclear(pgLO->res);
+ PQexec(pgLO->conn, "ROLLBACK");
fprintf(stderr, "\n%s: ROLLBACK\n", progname);
exit(RE_ERROR);
- }
+ }
+ PQclear(pgLO->res);
}
}
-
/* -------------------------------------------------------------------------
* pg_dumplo
*
* Portions Copyright (c) 1999-2000, PostgreSQL, Inc
*
- * $Header: /cvsroot/pgsql/contrib/pg_dumplo/Attic/main.c,v 1.3 2000/07/03 16:03:22 momjian Exp $
+ * $Header: /cvsroot/pgsql/contrib/pg_dumplo/Attic/main.c,v 1.4 2000/11/22 00:00:55 tgl Exp $
*
* Karel Zak 1999-2000
* -------------------------------------------------------------------------
*/
-
#include
#include
#include
#include
#include
+/* We import postgres.h mostly to get the HAVE_GETOPT_LONG configure result. */
#ifndef OUT_OF_PG
- #include "postgres.h"
+#include "postgres.h"
#endif
#include
#include
+#include "pg_dumplo.h"
+
#ifdef HAVE_GETOPT_LONG
#include
#define no_argument 0
char *progname = NULL;
-#include "pg_dumplo.h"
-
int main(int argc, char **argv);
static void usage(void);
static void parse_lolist (LODumpMaster *pgLO);
#else
while((arg = getopt(argc, argv, "?aehu:p:qd:l:t:irs:w")) != -1) {
#endif
- switch(arg) {
+ switch(arg) {
case '?':
case 'h':
usage();
- exit(RE_OK);
+ exit(RE_OK);
case 'u':
pgLO->user = strdup(optarg);
break;
break;
case 'e':
case 'a':
- pgLO->action = ACTION_EXPORT_ALL;
- break;
- case 'w':
- pgLO->action = ACTION_SHOW;
- break;
+ pgLO->action = ACTION_EXPORT_ALL;
+ break;
+ case 'w':
+ pgLO->action = ACTION_SHOW;
+ break;
case 'r':
pgLO->remove = TRUE;
break;
pgLO->quiet = TRUE;
break;
default:
- fprintf(stderr, "%s: bad arg!\n", progname);
+ fprintf(stderr, "%s: bad arg -%c\n", progname, arg);
usage();
exit(RE_ERROR);
- }
+ }
}
} else {
usage();
pgLO->conn = PQsetdbLogin(pgLO->host, NULL, NULL, NULL, pgLO->db,
pgLO->user, pwd);
- if (PQstatus(pgLO->conn) == CONNECTION_BAD) {
- fprintf(stderr, "%s (connection): %s\n", progname, PQerrorMessage(pgLO->conn));
- exit(RE_ERROR);
- }
- pgLO->host = PQhost(pgLO->conn) ? PQhost(pgLO->conn) : "localhost";
- pgLO->db = PQdb(pgLO->conn);
+ if (PQstatus(pgLO->conn) == CONNECTION_BAD) {
+ fprintf(stderr, "%s (connection): %s\n", progname, PQerrorMessage(pgLO->conn));
+ exit(RE_ERROR);
+ }
+ pgLO->host = PQhost(pgLO->conn) ? PQhost(pgLO->conn) : "localhost";
+ pgLO->db = PQdb(pgLO->conn);
pgLO->user = PQuser(pgLO->conn);
case ACTION_SHOW:
case ACTION_EXPORT_ALL:
load_lolist(pgLO);
+ /* FALL THROUGH */
case ACTION_EXPORT_ATTR:
pglo_export(pgLO);
+/* -------------------------------------------------------------------------
+ * pg_dumplo
+ *
+ * Portions Copyright (c) 1999-2000, PostgreSQL, Inc
+ *
+ * $Header: /cvsroot/pgsql/contrib/pg_dumplo/Attic/pg_dumplo.h,v 1.2 2000/11/22 00:00:55 tgl Exp $
+ *
+ * Karel Zak 1999-2000
+ * -------------------------------------------------------------------------
+ */
+
+#ifndef PG_DUMPLO_H
+#define PG_DUMPLO_H
-#ifndef _PG_LODUMP_H_
-#define _PG_LODUMP_H_
+#include "postgres_ext.h"
-#define VERSION "0.0.5"
+#define VERSION "7.1.0"
/* ----------
* Define
*/
#define QUERY_BUFSIZ (8*1024)
#define DIR_UMASK 0755
-#define FILE_UMASK 0666
+#define FILE_UMASK 0644
#define TRUE 1
#define FALSE 0
#define MAX_TABLE_NAME 128
#define MAX_ATTR_NAME 128
-extern char *progname;
+#define atooid(x) ((Oid) strtoul((x), NULL, 10))
/* ----------
* LO struct
* ----------
*/
typedef struct {
- char *lo_table,
+ char *lo_table,
*lo_attr;
- long lo_oid;
+ Oid lo_oid;
} LOlist;
typedef struct {
ACTION_IMPORT
} PGLODUMP_ACTIONS;
+extern char *progname;
+
extern void notice (LODumpMaster *pgLO, int set);
-extern int check_res (LODumpMaster *pgLO);
extern void index_file (LODumpMaster *pgLO);
extern void load_lolist (LODumpMaster *pgLO);
extern void pglo_export (LODumpMaster *pgLO);
extern void pglo_import (LODumpMaster *pgLO);
-#endif /* _PG_LODUMP_H */
+#endif /* PG_DUMPLO_H */
+/* -------------------------------------------------------------------------
+ * pg_dumplo
+ *
+ * Portions Copyright (c) 1999-2000, PostgreSQL, Inc
+ *
+ * $Header: /cvsroot/pgsql/contrib/pg_dumplo/Attic/utils.c,v 1.2 2000/11/22 00:00:55 tgl Exp $
+ *
+ * Karel Zak 1999-2000
+ * -------------------------------------------------------------------------
+ */
#include
#include
}
}
-int
-check_res(LODumpMaster *pgLO)
-{
- if (!pgLO->res && PQresultStatus(pgLO->res) != PGRES_COMMAND_OK) {
- fprintf(stderr, "%s: %s\n", progname, PQerrorMessage(pgLO->conn));
- PQclear(pgLO->res);
- return FALSE;
- }
- if (PQresultStatus(pgLO->res) != PGRES_TUPLES_OK) {
- fprintf(stderr, "%s: Tuples is not OK.\n", progname);
- PQclear(pgLO->res);
- return FALSE;
- }
- return TRUE;
-}
-
static
void Dummy_NoticeProcessor(void * arg, const char * message)
{
projects / postgresql.git / commitdiff