diff options
Diffstat (limited to 'src/interfaces/libpq++/pglobject.cc')
| -rw-r--r-- | src/interfaces/libpq++/pglobject.cc | 176 |
1 files changed, 91 insertions, 85 deletions
diff --git a/src/interfaces/libpq++/pglobject.cc b/src/interfaces/libpq++/pglobject.cc index 0c83b75298e..5db38d74a5d 100644 --- a/src/interfaces/libpq++/pglobject.cc +++ b/src/interfaces/libpq++/pglobject.cc @@ -1,23 +1,24 @@ /*------------------------------------------------------------------------- - * - * FILE - * pglobject.cc - * - * DESCRIPTION - * implementation of the PgLargeObject class. - * PgLargeObject encapsulates a frontend to backend connection - * - * Copyright (c) 1994, Regents of the University of California - * - * IDENTIFICATION - * $Header: /cvsroot/pgsql/src/interfaces/libpq++/Attic/pglobject.cc,v 1.10 2002/06/15 19:30:40 momjian Exp $ - * - *------------------------------------------------------------------------- - */ +* +* FILE +* pglobject.cc +* +* DESCRIPTION +* implementation of the PgLargeObject class. +* PgLargeObject encapsulates a frontend to backend connection +* +* Copyright (c) 1994, Regents of the University of California +* +* IDENTIFICATION +* $Header: /cvsroot/pgsql/src/interfaces/libpq++/Attic/pglobject.cc,v 1.11 2002/07/02 16:32:19 momjian Exp $ +* +*------------------------------------------------------------------------- +*/ #include "pglobject.h" - -extern "C" { + +extern "C" +{ #include "libpq/libpq-fs.h" } @@ -35,140 +36,145 @@ using namespace std; // creates a large object in the default database // See PQconnectdb() for conninfo usage PgLargeObject::PgLargeObject(const char* conninfo) - : PgConnection(conninfo) + : PgConnection(conninfo) { - Init(); - if (! ConnectionBad()) { - Create(); - Open(); - } + Init(); + if (! ConnectionBad()) + { + Create(); + Open(); + } } // constructor // open an existing large object in the default database // See PQconnectdb() for conninfo usage -PgLargeObject::PgLargeObject(Oid lobjId, const char* conninfo) - : PgConnection(conninfo) +PgLargeObject::PgLargeObject(Oid lobjId, const char* conninfo) + : PgConnection(conninfo) { - Init(lobjId); - if (! ConnectionBad()) { - if ( !pgObject ) - Create(); - Open(); - } + Init(lobjId); + if (! ConnectionBad()) + { + if ( !pgObject ) + Create(); + Open(); + } } // destructor -- closes large object PgLargeObject::~PgLargeObject() { - Close(); + Close(); } // PgLargeObject::Init // Initialize the variables void PgLargeObject::Init(Oid lobjId) { - pgFd = -1; - pgObject = lobjId; + pgFd = -1; + pgObject = lobjId; } // PgLargeObject::create // create large object and check for errors void PgLargeObject::Create() { - // Create the object - pgObject = lo_creat(pgConn, INV_READ|INV_WRITE); - - // Check for possible errors - if (!pgObject) - loStatus = "PgLargeObject: can't create large object" ; - else - loStatus = "PgLargeObject: created large object" ; + // Create the object + pgObject = lo_creat(pgConn, INV_READ | INV_WRITE); + + // Check for possible errors + if (!pgObject) + loStatus = "PgLargeObject: can't create large object" ; + else + loStatus = "PgLargeObject: created large object" ; } // PgLargeObject::open // open large object and check for errors void PgLargeObject::Open() { - // Close any prior object - Close(); - // Open the object - pgFd = lo_open(pgConn, pgObject, INV_READ|INV_WRITE); - - // Check for possible errors - string objStr( IntToString(pgObject) ); - if (pgFd < 0) - loStatus = "PgLargeObject: can't open large object " + objStr ; - else - loStatus = "PgLargeObject: created and opened large object " + objStr ; + // Close any prior object + Close(); + // Open the object + pgFd = lo_open(pgConn, pgObject, INV_READ | INV_WRITE); + + // Check for possible errors + string objStr( IntToString(pgObject) ); + if (pgFd < 0) + loStatus = "PgLargeObject: can't open large object " + objStr ; + else + loStatus = "PgLargeObject: created and opened large object " + objStr ; } // PgLargeObject::unlink // destroy large object and delete from it from the database int PgLargeObject::Unlink() { - // Unlink the object - int temp = lo_unlink(pgConn, pgObject); - - // Initialize the large object upon success - if (!temp) { - Close(); - Init(); - } - - // Return the status - return temp; + // Unlink the object + int temp = lo_unlink(pgConn, pgObject); + + // Initialize the large object upon success + if (!temp) + { + Close(); + Init(); + } + + // Return the status + return temp; } void PgLargeObject::Close() -{ - if (pgFd >= 0) lo_close(pgConn, pgFd); - pgFd = -1; +{ + if (pgFd >= 0) + lo_close(pgConn, pgFd); + pgFd = -1; } int PgLargeObject::Read(char* buf, int len) -{ - return lo_read(pgConn, pgFd, buf, len); +{ + return lo_read(pgConn, pgFd, buf, len); } int PgLargeObject::Write(const char* buf, int len) -{ - return lo_write(pgConn, pgFd, (char*)buf, len); +{ + return lo_write(pgConn, pgFd, (char*)buf, len); } int PgLargeObject::LSeek(int offset, int whence) -{ - return lo_lseek(pgConn, pgFd, offset, whence); +{ + return lo_lseek(pgConn, pgFd, offset, whence); } int PgLargeObject::Tell() const -{ - return lo_tell(pgConn, pgFd); +{ + return lo_tell(pgConn, pgFd); } -Oid PgLargeObject::Import(const char* filename) -{ - return pgObject = lo_import(pgConn, filename); +Oid PgLargeObject::Import(const char* filename) +{ + return pgObject = lo_import(pgConn, filename); } -int PgLargeObject::Export(const char* filename) -{ - return lo_export(pgConn, pgObject, filename); +int PgLargeObject::Export(const char* filename) +{ + return lo_export(pgConn, pgObject, filename); } string PgLargeObject::Status() const -{ - return loStatus; +{ + return loStatus; } -Oid PgLargeObject::LOid(){ - return pgObject; +Oid PgLargeObject::LOid() +{ + return pgObject; } |