<!--

$Header: /cvsroot/pgsql/doc/src/sgml/ref/pg_dump.sgml,v 1.36 2001/09/03 12:57:50 petere Exp $

$Header: /cvsroot/pgsql/doc/src/sgml/ref/pg_dump.sgml,v 1.37 2001/09/21 21:58:29 petere Exp $

Postgres documentation

-->

<term>--blobs</term>

<listitem>

<para>

Dump data and <acronym>BLOB</acronym> data.

Include large objects in dump.

</para>

</listitem>

</varlistentry>

</para>

<para>

To dump a database called mydb that contains

<acronym>BLOB</acronym>s to a <filename>tar</filename> file:

To dump a database called<literal>mydb</> that contains

large objects to a <filename>tar</filename> file:

<screen>

<prompt>$</prompt> <userinput>pg_dump -Ft -b mydb &gt; db.tar</userinput>

</screen>

</para>

<para>

To reload this database (with<acronym>BLOB</acronym>s) to an

existing database called newdb:

To reload this database (withlarge objects) to an

existing database called<literal>newdb</>:

<screen>

<prompt>$</prompt> <userinput>pg_restore -d newdb db.tar</userinput>

<!-- $Header: /cvsroot/pgsql/doc/src/sgml/ref/pg_restore.sgml,v 1.16 2001/09/13 15:55:24 petere Exp $ -->

<!-- $Header: /cvsroot/pgsql/doc/src/sgml/ref/pg_restore.sgml,v 1.17 2001/09/21 21:58:30 petere Exp $ -->

<refentry id="APP-PGRESTORE">

<docinfo>

<listitem>

<para>

Connect to database <replaceable class="parameter">dbname</replaceable> and restore

directly into the database.BLOBs can only be restored by using a direct database connection.

directly into the database.Large objects can only be restored by using a direct database connection.

</para>

</listitem>

</varlistentry>

<listitem>

<para>

<command>pg_restore</command> will not restoreBLOBs for a single table. If

an archive containsBLOBs, then allBLOBs will be restored.

<command>pg_restore</command> will not restorelarge objects for a single table. If

an archive containslarge objects, then alllarge objects will be restored.

</para>

</listitem>

</para>

<para>

To dump a database called mydb that contains

<acronym>BLOB</acronym>s to a <filename>tar</filename> file:

To dump a database called<literal>mydb</> that contains

large objects to a <filename>tar</filename> file:

<screen>

<prompt>$</prompt> <userinput>pg_dump -Ft -b mydb &gt; db.tar</userinput>

</screen>

</para>

<para>

To reload this database (with<acronym>BLOB</acronym>s) to an

existing database called newdb:

To reload this database (withlarge objects) to an

existing database called<literal>newdb</>:

<screen>

<prompt>$</prompt> <userinput>pg_restore -d newdb db.tar</userinput>

if (!AH->CustomOutPtr)

write_msg(modulename,"WARNING: skippingBLOB restoration\n");

write_msg(modulename,"WARNING: skippinglarge object restoration\n");

}

if ((reqs&2)!=0)/* We loaded the data */

{

ahlog(AH,1,"fixing upBLOBreference for %s\n",te->name);

ahlog(AH,1,"fixing uplarge object cross-reference for %s\n",te->name);

FixupBlobRefs(AH,te->name);

}

}

ahlog(AH,2,"ignoringBLOB cross-references for %s %s\n",te->desc,te->name);

ahlog(AH,2,"ignoringlarge object cross-references for %s %s\n",te->desc,te->name);

te=te->next;

}

ArchiveHandle*AH= (ArchiveHandle*)AHX;

if (!AH->StartBlobPtr)

die_horribly(AH,modulename,"BLOB output not supported in chosen format\n");

die_horribly(AH,modulename,"large object output not supported in chosen format\n");

(*AH->StartBlobPtr) (AH,AH->currToc,oid);

{

if (AH->txActive)

{

ahlog(AH,2,"committingBLOB transactions\n");

ahlog(AH,2,"committinglarge object transactions\n");

CommitTransaction(AH);

}

if (AH->blobTxActive)

CommitTransactionXref(AH);

ahlog(AH,1,"restored %dBLOBs\n",AH->blobCount);

ahlog(AH,1,"restored %dlarge objects\n",AH->blobCount);

}

if (!AH->createdBlobXref)

{

if (!AH->connection)

die_horribly(AH,modulename,"cannot restoreBLOBs without a database connection\n");

die_horribly(AH,modulename,"cannot restorelarge objects without a database connection\n");

CreateBlobXrefTable(AH);

AH->createdBlobXref=1;

if (!AH->txActive)

{

ahlog(AH,2,"startingBLOB transactions\n");

ahlog(AH,2,"startinglarge object transactions\n");

StartTransaction(AH);

}

if (!AH->blobTxActive)

StartTransactionXref(AH);

loOid=lo_creat(AH->connection,INV_READ |INV_WRITE);

if (loOid==0)

die_horribly(AH,modulename,"could not createBLOB\n");

die_horribly(AH,modulename,"could not createlarge object\n");

ahlog(AH,2,"restoringBLOB oid %u as %u\n",oid,loOid);

ahlog(AH,2,"restoringlarge object with oid %u as %u\n",oid,loOid);

InsertBlobXref(AH,oid,loOid);

AH->loFd=lo_open(AH->connection,loOid,INV_WRITE);

if (AH->loFd==-1)

die_horribly(AH,modulename,"could not openBLOB\n");

die_horribly(AH,modulename,"could not openlarge object\n");

AH->writingBlob=1;

}

if (((AH->blobCount /BLOB_BATCH_SIZE)*BLOB_BATCH_SIZE)==AH->blobCount)

{

ahlog(AH,2,"committingBLOB transactions\n");

ahlog(AH,2,"committinglarge object transactions\n");

CommitTransaction(AH);

CommitTransactionXref(AH);

}

if (AH->writingBlob)

{

res=lo_write(AH->connection,AH->loFd, (void*)ptr,size*nmemb);

ahlog(AH,5,"wrote %d bytes ofBLOB data (result = %d)\n",size*nmemb,res);

ahlog(AH,5,"wrote %d bytes oflarge object data (result = %d)\n",size*nmemb,res);

if (res<size*nmemb)

die_horribly(AH,modulename,"could not write to large object (result: %d, expected: %d)\n",

res,size*nmemb);

_StartBlob(ArchiveHandle*AH,TocEntry*te,Oidoid)

{

if (oid==0)

die_horribly(AH,modulename,"invalid OID forBLOB\n");

die_horribly(AH,modulename,"invalid OID forlarge object\n");

WriteInt(AH,oid);

_StartDataCompressor(AH,te);

caseBLK_BLOBS:

if (!AH->connection)

die_horribly(AH,modulename,"BLOBs cannot be loaded without a database connection\n");

die_horribly(AH,modulename,"large objects cannot be loaded without a database connection\n");

_LoadBlobs(AH);

break;

{

attr=PQgetvalue(res,i,0);

ahlog(AH,1,"fixingBLOB cross-references for %s.%s\n",tablename,attr);

ahlog(AH,1,"fixinglarge object cross-references for %s.%s\n",tablename,attr);

resetPQExpBuffer(tblQry);

if (!AH->blobConnection)

AH->blobConnection=_connectDB(AH,NULL,NULL);

ahlog(AH,1,"creating table forBLOB cross-references\n");

ahlog(AH,1,"creating table forlarge object cross-references\n");

appendPQExpBuffer(qry,"Create Temporary Table %s(oldOid oid, newOid oid);",BLOB_XREF_TABLE);

ExecuteSqlCommand(AH,qry,"could not createBLOB crossreference table", true);

ExecuteSqlCommand(AH,qry,"could not createlarge object cross-reference table", true);

resetPQExpBuffer(qry);

appendPQExpBuffer(qry,"Create Unique Index %s_ix on %s(oldOid)",BLOB_XREF_TABLE,BLOB_XREF_TABLE);

ExecuteSqlCommand(AH,qry,"could not create index onBLOB crossreference table", true);

ExecuteSqlCommand(AH,qry,"could not create index onlarge object cross-reference table", true);

destroyPQExpBuffer(qry);

}

appendPQExpBuffer(qry,"Insert Into %s(oldOid, newOid) Values (%d, %d);",BLOB_XREF_TABLE,old,new);

ExecuteSqlCommand(AH,qry,"could not createBLOB crossreference entry", true);

ExecuteSqlCommand(AH,qry,"could not createlarge object cross-reference entry", true);

destroyPQExpBuffer(qry);

}

appendPQExpBuffer(qry,"Begin;");

ExecuteSqlCommand(AH,qry,

"could not start transaction forBLOB crossreferences", true);

"could not start transaction forlarge object cross-references", true);

AH->blobTxActive= true;

destroyPQExpBuffer(qry);

appendPQExpBuffer(qry,"Commit;");

ExecuteSqlCommand(AH,qry,"could not commit transaction forBLOB crossreferences", true);

ExecuteSqlCommand(AH,qry,"could not commit transaction forlarge object cross-references", true);

AH->blobTxActive= false;

destroyPQExpBuffer(qry);

ctx->blobToc=fopen("blobs.toc",PG_BINARY_R);

if (ctx->blobToc==NULL)

die_horribly(AH,modulename,"could not openBLOB TOC for input: %s\n",strerror(errno));

die_horribly(AH,modulename,"could not openlarge object TOC for input: %s\n",strerror(errno));

_getBlobTocEntry(AH,&oid,fname);

}

if (fclose(ctx->blobToc)!=0)

die_horribly(AH,modulename,"could not closeBLOB TOC file: %s\n",strerror(errno));

die_horribly(AH,modulename,"could not closelarge object TOC file: %s\n",strerror(errno));

EndRestoreBlobs(AH);

}

if (ctx->blobToc==NULL)

die_horribly(AH,modulename,

"could not openBLOB TOC for output: %s\n",strerror(errno));

"could not openlarge object TOC for output: %s\n",strerror(errno));

}

char*sfx;

if (oid==0)

die_horribly(AH,modulename,"invalid OID forBLOB (%u)\n",oid);

die_horribly(AH,modulename,"invalid OID forlarge object (%u)\n",oid);

if (AH->compression!=0)

sfx=".gz";

if (tctx->FH==NULL)

die_horribly(AH,modulename,"could not openBLOB file\n");

die_horribly(AH,modulename,"could not openlarge object file\n");

}

lclTocEntry*tctx= (lclTocEntry*)te->formatData;

if (GZCLOSE(tctx->FH)!=0)

die_horribly(AH,modulename,"could not closeBLOB file\n");

die_horribly(AH,modulename,"could not closelarge object file\n");

}

if (fclose(ctx->blobToc)!=0)

die_horribly(AH,modulename,"could not closeBLOB TOC file: %s\n",strerror(errno));

die_horribly(AH,modulename,"could not closelarge object TOC file: %s\n",strerror(errno));

}

if (strncmp(th->targetFile,"blob_",5)==0&&oid!=0)

{

ahlog(AH,1,"restoringBLOB oid %u\n",oid);

ahlog(AH,1,"restoringlarge object OID %u\n",oid);

StartRestoreBlob(AH,oid);

char*sfx;

if (oid==0)

die_horribly(AH,modulename,"invalid OID forBLOB (%u)\n",oid);

die_horribly(AH,modulename,"invalid OID forlarge object (%u)\n",oid);

if (AH->compression!=0)

sfx=".gz";