test_copy_callbacks.c File Reference

#include "postgres.h"
#include "access/table.h"
#include "commands/copy.h"
#include "fmgr.h"
#include "utils/rel.h"

Include dependency graph for test_copy_callbacks.c:

Go to the source code of this file.

Functions
static void	to_cb (void *data, int len)
	PG_FUNCTION_INFO_V1 (test_copy_to_callback)
Datum	test_copy_to_callback (PG_FUNCTION_ARGS)

Variables
	PG_MODULE_MAGIC

Function Documentation

PG_FUNCTION_INFO_V1()

PG_FUNCTION_INFO_V1

(

test_copy_to_callback

)

test_copy_to_callback()

Datum test_copy_to_callback

(

PG_FUNCTION_ARGS

)

Definition at line 34 of file test_copy_callbacks.c.

{
    Relation    rel = table_open(PG_GETARG_OID(0), AccessShareLock);
    CopyToState cstate;
    int64       processed;
 
    cstate = BeginCopyTo(NULL, rel, NULL, RelationGetRelid(rel), NULL, false,
                         to_cb, NIL, NIL);
    processed = DoCopyTo(cstate);
    EndCopyTo(cstate);
 
    ereport(NOTICE, (errmsg("COPY TO callback has processed %lld rows",
                            (long long) processed)));
 
    table_close(rel, NoLock);
 
    PG_RETURN_VOID();
}

References AccessShareLock, BeginCopyTo(), DoCopyTo(), EndCopyTo(), ereport, errmsg(), NIL, NoLock, NOTICE, PG_GETARG_OID, PG_RETURN_VOID, RelationGetRelid, table_close(), table_open(), and to_cb().

to_cb()

static void to_cb ( void *  data, int  len  )

static

Definition at line 25 of file test_copy_callbacks.c.

{
    ereport(NOTICE,
            (errmsg("COPY TO callback called with data \"%s\" and length %d",
                    (char *) data, len)));
}

References data, ereport, errmsg(), len, and NOTICE.

Referenced by test_copy_to_callback().

Variable Documentation

PG_MODULE_MAGIC

PG_MODULE_MAGIC

Definition at line 22 of file test_copy_callbacks.c.