large_obj.h File Reference

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Functions
bool	do_lo_export (const char *loid_arg, const char *filename_arg)
bool	do_lo_import (const char *filename_arg, const char *comment_arg)
bool	do_lo_unlink (const char *loid_arg)

Function Documentation

do_lo_export()

bool do_lo_export	(	const char *	loid_arg,
		const char *	filename_arg
	)

Definition at line 142 of file large_obj.c.

{
    int         status;
    bool        own_transaction;
 
    if (!start_lo_xact("\\lo_export", &own_transaction))
        return false;
 
    SetCancelConn(NULL);
    status = lo_export(pset.db, atooid(loid_arg), filename_arg);
    ResetCancelConn();
 
    /* of course this status is documented nowhere :( */
    if (status != 1)
    {
        pg_log_info("%s", PQerrorMessage(pset.db));
        return fail_lo_xact("\\lo_export", own_transaction);
    }
 
    if (!finish_lo_xact("\\lo_export", own_transaction))
        return false;
 
    print_lo_result("lo_export");
 
    return true;
}

References atooid, _psqlSettings::db, fail_lo_xact(), finish_lo_xact(), lo_export(), pg_log_info, PQerrorMessage(), print_lo_result(), pset, ResetCancelConn(), SetCancelConn(), and start_lo_xact().

Referenced by exec_command_lo().

do_lo_import()

bool do_lo_import	(	const char *	filename_arg,
		const char *	comment_arg
	)

Definition at line 176 of file large_obj.c.

{
    PGresult   *res;
    Oid         loid;
    char        oidbuf[32];
    bool        own_transaction;
 
    if (!start_lo_xact("\\lo_import", &own_transaction))
        return false;
 
    SetCancelConn(NULL);
    loid = lo_import(pset.db, filename_arg);
    ResetCancelConn();
 
    if (loid == InvalidOid)
    {
        pg_log_info("%s", PQerrorMessage(pset.db));
        return fail_lo_xact("\\lo_import", own_transaction);
    }
 
    /* insert description if given */
    if (comment_arg)
    {
        char       *cmdbuf;
        char       *bufptr;
        size_t      slen = strlen(comment_arg);
 
        cmdbuf = pg_malloc_extended(slen * 2 + 256, MCXT_ALLOC_NO_OOM);
        if (!cmdbuf)
            return fail_lo_xact("\\lo_import", own_transaction);
        sprintf(cmdbuf, "COMMENT ON LARGE OBJECT %u IS '", loid);
        bufptr = cmdbuf + strlen(cmdbuf);
        bufptr += PQescapeStringConn(pset.db, bufptr, comment_arg, slen, NULL);
        strcpy(bufptr, "'");
 
        if (!(res = PSQLexec(cmdbuf)))
        {
            free(cmdbuf);
            return fail_lo_xact("\\lo_import", own_transaction);
        }
 
        PQclear(res);
        free(cmdbuf);
    }
 
    if (!finish_lo_xact("\\lo_import", own_transaction))
        return false;
 
    print_lo_result("lo_import %u", loid);
 
    sprintf(oidbuf, "%u", loid);
    SetVariable(pset.vars, "LASTOID", oidbuf);
 
    return true;
}

References _psqlSettings::db, fail_lo_xact(), finish_lo_xact(), free, InvalidOid, lo_import(), MCXT_ALLOC_NO_OOM, pg_log_info, pg_malloc_extended(), PQclear(), PQerrorMessage(), PQescapeStringConn(), print_lo_result(), pset, PSQLexec(), res, ResetCancelConn(), SetCancelConn(), SetVariable(), sprintf, start_lo_xact(), and _psqlSettings::vars.

Referenced by exec_command_lo().

do_lo_unlink()

bool do_lo_unlink

(

const char *

loid_arg

)

Definition at line 239 of file large_obj.c.

{
    int         status;
    Oid         loid = atooid(loid_arg);
    bool        own_transaction;
 
    if (!start_lo_xact("\\lo_unlink", &own_transaction))
        return false;
 
    SetCancelConn(NULL);
    status = lo_unlink(pset.db, loid);
    ResetCancelConn();
 
    if (status == -1)
    {
        pg_log_info("%s", PQerrorMessage(pset.db));
        return fail_lo_xact("\\lo_unlink", own_transaction);
    }
 
    if (!finish_lo_xact("\\lo_unlink", own_transaction))
        return false;
 
    print_lo_result("lo_unlink %u", loid);
 
    return true;
}

References atooid, _psqlSettings::db, fail_lo_xact(), finish_lo_xact(), lo_unlink(), pg_log_info, PQerrorMessage(), print_lo_result(), pset, ResetCancelConn(), SetCancelConn(), and start_lo_xact().

Referenced by exec_command_lo().