diff options
Diffstat (limited to 'contrib/dblink/dblink.h')
| -rw-r--r-- | contrib/dblink/dblink.h | 79 |
1 files changed, 77 insertions, 2 deletions
diff --git a/contrib/dblink/dblink.h b/contrib/dblink/dblink.h index 8c5a5bdc287..9be48ead2e3 100644 --- a/contrib/dblink/dblink.h +++ b/contrib/dblink/dblink.h @@ -3,7 +3,8 @@ * * Functions returning results from a remote database * - * Copyright (c) Joseph Conway <joe.conway@mail.com>, 2001; + * Copyright (c) Joseph Conway <mail@joeconway.com>, 2001, 2002, + * ALL RIGHTS RESERVED; * * Permission to use, copy, modify, and distribute this software and its * documentation for any purpose, without fee, and without a written agreement @@ -33,10 +34,31 @@ #include "libpq-int.h" #include "fmgr.h" #include "access/tupdesc.h" +#include "access/heapam.h" +#include "catalog/catname.h" +#include "catalog/pg_index.h" +#include "catalog/pg_type.h" #include "executor/executor.h" +#include "executor/spi.h" +#include "lib/stringinfo.h" #include "nodes/nodes.h" #include "nodes/execnodes.h" +#include "nodes/pg_list.h" +#include "parser/parse_type.h" +#include "tcop/tcopprot.h" #include "utils/builtins.h" +#include "utils/fmgroids.h" +#include "utils/array.h" +#include "utils/syscache.h" + +#ifdef NamespaceRelationName +#include "catalog/namespace.h" +#endif /* NamespaceRelationName */ + +/* + * Max SQL statement size + */ +#define DBLINK_MAX_SQLSTATE_SIZE 16384 /* * This struct holds the results of the remote query. @@ -50,21 +72,74 @@ typedef struct int tup_num; /* + * resource index number for this context + */ + int res_id_index; + + /* * the actual query results */ PGresult *res; - } dblink_results; + +/* + * This struct holds results in the form of an array. + * Use fn_extra to hold a pointer to it across calls + */ +typedef struct +{ + /* + * elem being accessed + */ + int elem_num; + + /* + * number of elems + */ + int num_elems; + + /* + * the actual array + */ + void *res; + +} dblink_array_results; + /* * External declarations */ extern Datum dblink(PG_FUNCTION_ARGS); extern Datum dblink_tok(PG_FUNCTION_ARGS); +extern Datum dblink_strtok(PG_FUNCTION_ARGS); +extern Datum dblink_get_pkey(PG_FUNCTION_ARGS); +extern Datum dblink_last_oid(PG_FUNCTION_ARGS); +extern Datum dblink_build_sql_insert(PG_FUNCTION_ARGS); +extern Datum dblink_build_sql_delete(PG_FUNCTION_ARGS); +extern Datum dblink_build_sql_update(PG_FUNCTION_ARGS); +extern Datum dblink_current_query(PG_FUNCTION_ARGS); +extern Datum dblink_replace_text(PG_FUNCTION_ARGS); /* * Internal declarations */ dblink_results *init_dblink_results(MemoryContext fn_mcxt); +dblink_array_results *init_dblink_array_results(MemoryContext fn_mcxt); +char **get_pkey_attnames(Oid relid, int16 *numatts); +char *get_strtok(char *fldtext, char *fldsep, int fldnum); +char *getvalue(HeapTuple tuple, TupleDesc tupdesc, int fnumber); +char *get_sql_insert(Oid relid, int16 *pkattnums, int16 pknumatts, char **src_pkattvals, char **tgt_pkattvals); +char *get_sql_delete(Oid relid, int16 *pkattnums, int16 pknumatts, char **tgt_pkattvals); +char *get_sql_update(Oid relid, int16 *pkattnums, int16 pknumatts, char **src_pkattvals, char **tgt_pkattvals); +static char *quote_literal_cstr(char *rawstr); +static char *quote_ident_cstr(char *rawstr); +int16 get_attnum_pk_pos(int16 *pkattnums, int16 pknumatts, int16 key); +HeapTuple get_tuple_of_interest(Oid relid, int16 *pkattnums, int16 pknumatts, char **src_pkattvals); +Oid get_relid_from_relname(char *relname); +dblink_results *get_res_ptr(int32 res_id_index); +void append_res_ptr(dblink_results *results); +void remove_res_ptr(dblink_results *results); + +extern char *debug_query_string; #endif /* DBLINK_H */ |