PostgreSQL Source Code
git master
|
#include "postgres.h"
#include <limits.h>
#include "access/htup_details.h"
#include "access/relation.h"
#include "access/reloptions.h"
#include "access/table.h"
#include "catalog/namespace.h"
#include "catalog/pg_foreign_data_wrapper.h"
#include "catalog/pg_foreign_server.h"
#include "catalog/pg_type.h"
#include "catalog/pg_user_mapping.h"
#include "executor/spi.h"
#include "foreign/foreign.h"
#include "funcapi.h"
#include "lib/stringinfo.h"
#include "libpq-fe.h"
#include "mb/pg_wchar.h"
#include "miscadmin.h"
#include "parser/scansup.h"
#include "utils/acl.h"
#include "utils/builtins.h"
#include "utils/fmgroids.h"
#include "utils/guc.h"
#include "utils/lsyscache.h"
#include "utils/memutils.h"
#include "utils/rel.h"
#include "utils/varlena.h"
Go to the source code of this file.
Data Structures | |
struct | remoteConn |
struct | storeInfo |
struct | remoteConnHashEnt |
Macros | |
#define | NUMCONN 16 |
#define | DBLINK_NOTIFY_COLS 3 |
Typedefs | |
typedef struct remoteConn | remoteConn |
typedef struct storeInfo | storeInfo |
typedef struct remoteConnHashEnt | remoteConnHashEnt |
Variables | |
PG_MODULE_MAGIC | |
static remoteConn * | pconn = NULL |
static HTAB * | remoteConnHash = NULL |
static void PGresult * | res |
static void PGresult const char * | p2 |
typedef struct remoteConn remoteConn |
typedef struct remoteConnHashEnt remoteConnHashEnt |
|
static |
Definition at line 3037 of file dblink.c.
References Assert(), conn, GetConfigOption(), GUC_ACTION_SAVE, i, lengthof, NewGUCNestLevel(), PGC_S_SESSION, PGC_USERSET, PQparameterStatus(), and set_config_option().
Referenced by materializeResult(), and storeQueryResult().
|
static |
Definition at line 2577 of file dblink.c.
References HASHCTL::entrysize, hash_create(), HASH_ELEM, HASH_STRINGS, HASHCTL::keysize, NAMEDATALEN, and NUMCONN.
Referenced by createNewConnection(), deleteConnection(), and getConnectionByName().
|
static |
Definition at line 2589 of file dblink.c.
References remoteConn::conn, createConnHash(), ereport, errcode(), ERRCODE_DUPLICATE_OBJECT, errmsg(), ERROR, HASH_ENTER, hash_search(), sort-test::key, remoteConnHashEnt::name, name, pfree(), PQfinish(), pstrdup(), remoteConnHashEnt::rconn, ReleaseExternalFD(), remoteConnHash, strlcpy(), and truncate_identifier().
Referenced by dblink_connect().
Datum dblink_build_sql_delete | ( | PG_FUNCTION_ARGS | ) |
Definition at line 1752 of file dblink.c.
References AccessShareLock, ACL_SELECT, cstring_to_text(), ereport, errcode(), errmsg(), ERROR, get_rel_from_relname(), get_sql_delete(), get_text_array_contents(), PG_GETARG_ARRAYTYPE_P, PG_GETARG_INT32, PG_GETARG_POINTER, PG_GETARG_TEXT_PP, PG_RETURN_TEXT_P, relation_close(), and validate_pkattnums().
Datum dblink_build_sql_insert | ( | PG_FUNCTION_ARGS | ) |
Definition at line 1663 of file dblink.c.
References AccessShareLock, ACL_SELECT, cstring_to_text(), ereport, errcode(), errmsg(), ERROR, get_rel_from_relname(), get_sql_insert(), get_text_array_contents(), PG_GETARG_ARRAYTYPE_P, PG_GETARG_INT32, PG_GETARG_POINTER, PG_GETARG_TEXT_PP, PG_RETURN_TEXT_P, relation_close(), and validate_pkattnums().
Datum dblink_build_sql_update | ( | PG_FUNCTION_ARGS | ) |
Definition at line 1828 of file dblink.c.
References AccessShareLock, ACL_SELECT, cstring_to_text(), ereport, errcode(), errmsg(), ERROR, get_rel_from_relname(), get_sql_update(), get_text_array_contents(), PG_GETARG_ARRAYTYPE_P, PG_GETARG_INT32, PG_GETARG_POINTER, PG_GETARG_TEXT_PP, PG_RETURN_TEXT_P, relation_close(), and validate_pkattnums().
Datum dblink_cancel_query | ( | PG_FUNCTION_ARGS | ) |
Definition at line 1380 of file dblink.c.
References conn, cstring_to_text(), dblink_get_named_conn(), dblink_init(), PG_GETARG_TEXT_PP, PG_RETURN_TEXT_P, PQcancel(), PQfreeCancel(), PQgetCancel(), res, and text_to_cstring().
Datum dblink_close | ( | PG_FUNCTION_ARGS | ) |
Definition at line 517 of file dblink.c.
References appendStringInfo(), buf, remoteConn::conn, conn, cstring_to_text(), dblink_init(), dblink_res_error(), get_fn_expr_argtype(), getConnectionByName(), initStringInfo(), remoteConn::newXactForCursor, remoteConn::openCursorCount, pconn, PG_GETARG_BOOL, PG_GETARG_TEXT_PP, PG_NARGS, PG_RETURN_TEXT_P, PGRES_COMMAND_OK, PQclear(), PQexec(), PQresultStatus(), res, and text_to_cstring().
Datum dblink_connect | ( | PG_FUNCTION_ARGS | ) |
Definition at line 280 of file dblink.c.
References AcquireExternalFD(), remoteConn::conn, conn, CONNECTION_BAD, connstr, createNewConnection(), cstring_to_text(), dblink_connstr_check(), dblink_init(), dblink_security_check(), ereport, errcode(), errdetail(), errdetail_internal(), errhint(), errmsg(), ERROR, get_connect_string(), GetDatabaseEncoding(), GetDatabaseEncodingName(), MemoryContextAlloc(), remoteConn::newXactForCursor, remoteConn::openCursorCount, pchomp(), pconn, pfree(), PG_GETARG_TEXT_PP, PG_NARGS, PG_RETURN_TEXT_P, PQclientEncoding(), PQconnectdb(), PQerrorMessage(), PQfinish(), PQsetClientEncoding(), PQstatus(), ReleaseExternalFD(), text_to_cstring(), and TopMemoryContext.
|
static |
Definition at line 2667 of file dblink.c.
References connstr, ereport, errcode(), errdetail(), errmsg(), ERROR, options, PQconninfoFree(), PQconninfoParse(), superuser(), and option::val.
Referenced by dblink_connect(), and dblink_get_conn().
Datum dblink_current_query | ( | PG_FUNCTION_ARGS | ) |
Datum dblink_disconnect | ( | PG_FUNCTION_ARGS | ) |
Definition at line 385 of file dblink.c.
References remoteConn::conn, conn, cstring_to_text(), dblink_init(), deleteConnection(), getConnectionByName(), pconn, pfree(), PG_GETARG_TEXT_PP, PG_NARGS, PG_RETURN_TEXT_P, PQfinish(), ReleaseExternalFD(), and text_to_cstring().
Datum dblink_error_message | ( | PG_FUNCTION_ARGS | ) |
Definition at line 1413 of file dblink.c.
References conn, cstring_to_text(), dblink_get_named_conn(), dblink_init(), pchomp(), PG_GETARG_TEXT_PP, PG_RETURN_TEXT_P, PQerrorMessage(), and text_to_cstring().
Datum dblink_exec | ( | PG_FUNCTION_ARGS | ) |
Definition at line 1433 of file dblink.c.
References remoteConn::conn, conn, cstring_to_text(), dblink_get_conn(), dblink_init(), dblink_res_error(), elog, ereport, errcode(), errmsg(), ERROR, get_fn_expr_argtype(), pconn, PG_END_TRY, PG_FINALLY, PG_GETARG_BOOL, PG_GETARG_TEXT_PP, PG_NARGS, PG_RETURN_TEXT_P, PG_TRY, PGRES_COMMAND_OK, PGRES_TUPLES_OK, PQclear(), PQcmdStatus(), PQexec(), PQfinish(), PQresultStatus(), ReleaseExternalFD(), res, and text_to_cstring().
Datum dblink_fdw_validator | ( | PG_FUNCTION_ARGS | ) |
Definition at line 1978 of file dblink.c.
References appendStringInfo(), buf, DefElem::defname, ereport, errcode(), errdetail(), errhint(), errmsg(), ERROR, initStringInfo(), is_valid_dblink_option(), _PQconninfoOption::keyword, lfirst, PG_GETARG_DATUM, PG_GETARG_OID, PG_RETURN_VOID, PQconndefaults(), and untransformRelOptions().
Datum dblink_fetch | ( | PG_FUNCTION_ARGS | ) |
Definition at line 604 of file dblink.c.
References appendStringInfo(), buf, remoteConn::conn, conn, dblink_init(), dblink_res_error(), ereport, errcode(), errmsg(), ERROR, get_fn_expr_argtype(), getConnectionByName(), initStringInfo(), materializeResult(), pconn, PG_GETARG_BOOL, PG_GETARG_INT32, PG_GETARG_TEXT_PP, PG_NARGS, PGRES_COMMAND_OK, PGRES_TUPLES_OK, PQclear(), PQexec(), PQresultStatus(), prepTuplestoreResult(), res, and text_to_cstring().
|
static |
Definition at line 180 of file dblink.c.
References AcquireExternalFD(), remoteConn::conn, conn, CONNECTION_BAD, connstr, dblink_connstr_check(), dblink_security_check(), ereport, errcode(), errdetail(), errdetail_internal(), errhint(), errmsg(), ERROR, get_connect_string(), getConnectionByName(), GetDatabaseEncoding(), GetDatabaseEncodingName(), pchomp(), PQclientEncoding(), PQconnectdb(), PQerrorMessage(), PQfinish(), PQsetClientEncoding(), PQstatus(), and ReleaseExternalFD().
Referenced by dblink_exec(), and dblink_record_internal().
Datum dblink_get_connections | ( | PG_FUNCTION_ARGS | ) |
Definition at line 1321 of file dblink.c.
References accumArrayResult(), CStringGetTextDatum, CurrentMemoryContext, hash_seq_init(), hash_seq_search(), makeArrayResult(), remoteConnHashEnt::name, PG_RETURN_ARRAYTYPE_P, PG_RETURN_NULL, remoteConnHash, and status().
|
static |
Definition at line 252 of file dblink.c.
References remoteConn::conn, and getConnectionByName().
Referenced by dblink_cancel_query(), dblink_error_message(), dblink_get_notify(), dblink_is_busy(), dblink_record_internal(), and dblink_send_query().
Datum dblink_get_notify | ( | PG_FUNCTION_ARGS | ) |
Definition at line 1925 of file dblink.c.
References pgNotify::be_pid, remoteConn::conn, conn, CStringGetTextDatum, dblink_get_named_conn(), dblink_init(), DBLINK_NOTIFY_COLS, pgNotify::extra, Int32GetDatum, pconn, PG_GETARG_TEXT_PP, PG_NARGS, PQconsumeInput(), PQfreemem(), PQnotifies(), pgNotify::relname, ReturnSetInfo::setDesc, ReturnSetInfo::setResult, SetSingleFuncCall(), text_to_cstring(), tuplestore_putvalues(), and values.
Datum dblink_get_pkey | ( | PG_FUNCTION_ARGS | ) |
Definition at line 1539 of file dblink.c.
References AccessShareLock, ACL_SELECT, FuncCallContext::attinmeta, BuildTupleFromCStrings(), FuncCallContext::call_cntr, CreateTemplateTupleDesc(), get_pkey_attnames(), get_rel_from_relname(), HeapTupleGetDatum, if(), FuncCallContext::max_calls, MemoryContextSwitchTo(), FuncCallContext::multi_call_memory_ctx, palloc(), PG_GETARG_TEXT_PP, psprintf(), relation_close(), SRF_FIRSTCALL_INIT, SRF_IS_FIRSTCALL, SRF_PERCALL_SETUP, SRF_RETURN_DONE, SRF_RETURN_NEXT, TupleDescGetAttInMetadata(), TupleDescInitEntry(), FuncCallContext::user_fctx, and values.
Datum dblink_get_result | ( | PG_FUNCTION_ARGS | ) |
Definition at line 730 of file dblink.c.
References dblink_record_internal().
|
static |
Definition at line 264 of file dblink.c.
References remoteConn::conn, MemoryContextAlloc(), remoteConn::newXactForCursor, remoteConn::openCursorCount, pconn, and TopMemoryContext.
Referenced by dblink_cancel_query(), dblink_close(), dblink_connect(), dblink_disconnect(), dblink_error_message(), dblink_exec(), dblink_fetch(), dblink_get_notify(), dblink_is_busy(), dblink_open(), and dblink_record_internal().
Datum dblink_is_busy | ( | PG_FUNCTION_ARGS | ) |
Definition at line 1356 of file dblink.c.
References conn, dblink_get_named_conn(), dblink_init(), PG_GETARG_TEXT_PP, PG_RETURN_INT32, PQconsumeInput(), PQisBusy(), and text_to_cstring().
Datum dblink_open | ( | PG_FUNCTION_ARGS | ) |
Definition at line 424 of file dblink.c.
References appendStringInfo(), buf, remoteConn::conn, conn, cstring_to_text(), dblink_init(), dblink_res_error(), get_fn_expr_argtype(), getConnectionByName(), initStringInfo(), remoteConn::newXactForCursor, remoteConn::openCursorCount, pconn, PG_GETARG_BOOL, PG_GETARG_TEXT_PP, PG_NARGS, PG_RETURN_TEXT_P, PGRES_COMMAND_OK, PQclear(), PQexec(), PQresultStatus(), PQTRANS_IDLE, PQtransactionStatus(), res, and text_to_cstring().
Datum dblink_record | ( | PG_FUNCTION_ARGS | ) |
Definition at line 698 of file dblink.c.
References dblink_record_internal().
|
static |
Definition at line 736 of file dblink.c.
References remoteConn::conn, conn, dblink_get_conn(), dblink_get_named_conn(), dblink_init(), dblink_res_error(), elog, ERROR, FunctionCallInfoBaseData::flinfo, get_fn_expr_argtype(), materializeQueryResult(), materializeResult(), pconn, PG_END_TRY, PG_FINALLY, PG_GETARG_BOOL, PG_GETARG_TEXT_PP, PG_NARGS, PG_TRY, PGRES_COMMAND_OK, PGRES_TUPLES_OK, PQfinish(), PQgetResult(), PQresultStatus(), prepTuplestoreResult(), ReleaseExternalFD(), res, and text_to_cstring().
Referenced by dblink_get_result(), and dblink_record().
|
static |
Definition at line 2709 of file dblink.c.
References conn, ereport, errcode(), errcontext, errdetail_internal(), errhint(), errmsg(), errmsg_internal(), ERROR, fmt, MAKE_SQLSTATE, NOTICE, pchomp(), PG_DIAG_CONTEXT, PG_DIAG_MESSAGE_DETAIL, PG_DIAG_MESSAGE_HINT, PG_DIAG_MESSAGE_PRIMARY, PG_DIAG_SQLSTATE, PQclear(), PQerrorMessage(), PQresultErrorField(), res, va_end(), va_start(), vsnprintf, and xpstrdup().
Referenced by dblink_close(), dblink_exec(), dblink_fetch(), dblink_open(), and dblink_record_internal().
|
static |
Definition at line 2640 of file dblink.c.
References conn, ereport, errcode(), errdetail(), errhint(), errmsg(), ERROR, pfree(), PQconnectionUsedPassword(), PQfinish(), ReleaseExternalFD(), and superuser().
Referenced by dblink_connect(), and dblink_get_conn().
Datum dblink_send_query | ( | PG_FUNCTION_ARGS | ) |
Definition at line 705 of file dblink.c.
References conn, dblink_get_named_conn(), elog, ERROR, NOTICE, pchomp(), PG_GETARG_TEXT_PP, PG_NARGS, PG_RETURN_INT32, PQerrorMessage(), PQsendQuery(), and text_to_cstring().
|
static |
Definition at line 2619 of file dblink.c.
References createConnHash(), ereport, errcode(), errmsg(), ERROR, HASH_REMOVE, hash_search(), sort-test::key, name, pstrdup(), remoteConnHash, and truncate_identifier().
Referenced by dblink_disconnect().
|
static |
Definition at line 2882 of file dblink.c.
References appendStringInfoChar(), buf, initStringInfo(), and generate_unaccent_rules::str.
Referenced by get_connect_string().
|
static |
Definition at line 2539 of file dblink.c.
References get_namespace_name(), quote_qualified_identifier(), RelationData::rd_rel, RelationGetRelationName, RelationGetRelid, and RelationIsVisible().
Referenced by get_sql_delete(), get_sql_insert(), get_sql_update(), and get_tuple_of_interest().
|
static |
Definition at line 2386 of file dblink.c.
References i, and sort-test::key.
Referenced by get_sql_insert(), and get_sql_update().
|
static |
Definition at line 2792 of file dblink.c.
References ACL_USAGE, aclcheck_error(), ACLCHECK_OK, appendStringInfo(), DefElem::arg, buf, DefElem::defname, ereport, errcode(), errdetail(), errmsg(), ERROR, escape_param_str(), ForeignServer::fdwid, GetForeignDataWrapper(), GetForeignServerByName(), GetUserId(), GetUserMapping(), initStringInfo(), is_valid_dblink_option(), lfirst, OBJECT_FOREIGN_SERVER, ForeignDataWrapper::options, ForeignServer::options, UserMapping::options, pg_foreign_server_aclcheck(), PQconndefaults(), pstrdup(), ForeignServer::serverid, ForeignServer::servername, strVal, and truncate_identifier().
Referenced by dblink_connect(), and dblink_get_conn().
Definition at line 2052 of file dblink.c.
References AccessShareLock, BTEqualStrategyNumber, GETSTRUCT, HeapTupleIsValid, i, ObjectIdGetDatum, palloc(), RelationData::rd_att, RelationGetRelid, ScanKeyInit(), SPI_fname(), systable_beginscan(), systable_endscan(), systable_getnext(), table_close(), and table_open().
Referenced by dblink_get_pkey().
|
static |
Definition at line 2514 of file dblink.c.
References aclcheck_error(), ACLCHECK_OK, get_relkind_objtype(), GetUserId(), makeRangeVarFromNameList(), pg_class_aclcheck(), RelationData::rd_rel, RelationGetRelationName, RelationGetRelid, table_openrv(), and textToQualifiedNameList().
Referenced by dblink_build_sql_delete(), dblink_build_sql_insert(), dblink_build_sql_update(), and dblink_get_pkey().
|
static |
Definition at line 2243 of file dblink.c.
References appendStringInfo(), appendStringInfoString(), buf, generate_relation_name(), i, initStringInfo(), NameStr, quote_ident_cstr(), quote_literal_cstr(), RelationData::rd_att, relname, and TupleDescAttr.
Referenced by dblink_build_sql_delete().
|
static |
Definition at line 2163 of file dblink.c.
References appendStringInfo(), appendStringInfoChar(), appendStringInfoString(), buf, ereport, errcode(), errmsg(), ERROR, generate_relation_name(), get_attnum_pk_pos(), get_tuple_of_interest(), i, initStringInfo(), sort-test::key, NameStr, TupleDescData::natts, pfree(), pstrdup(), quote_ident_cstr(), quote_literal_cstr(), RelationData::rd_att, relname, SPI_getvalue(), TupleDescAttr, and val.
Referenced by dblink_build_sql_insert().
|
static |
Definition at line 2280 of file dblink.c.
References appendStringInfo(), appendStringInfoString(), buf, ereport, errcode(), errmsg(), ERROR, generate_relation_name(), get_attnum_pk_pos(), get_tuple_of_interest(), i, initStringInfo(), sort-test::key, NameStr, TupleDescData::natts, pfree(), pstrdup(), quote_ident_cstr(), quote_literal_cstr(), RelationData::rd_att, relname, SPI_getvalue(), TupleDescAttr, and val.
Referenced by dblink_build_sql_update().
|
static |
Definition at line 2107 of file dblink.c.
References ARR_DATA_PTR, ARR_DIMS, ARR_ELEMTYPE, ARR_NDIM, ARR_NULLBITMAP, ArrayGetNItems(), Assert(), att_addlength_pointer, att_align_nominal, get_typlenbyvalalign(), i, palloc(), PointerGetDatum, TextDatumGetCString, typalign, and values.
Referenced by dblink_build_sql_delete(), dblink_build_sql_insert(), and dblink_build_sql_update().
|
static |
Definition at line 2401 of file dblink.c.
References appendStringInfo(), appendStringInfoString(), buf, elog, ereport, errcode(), errmsg(), ERROR, generate_relation_name(), i, initStringInfo(), NameStr, TupleDescData::natts, pfree(), quote_ident_cstr(), quote_literal_cstr(), RelationData::rd_att, relname, SPI_connect(), SPI_copytuple(), SPI_exec(), SPI_finish(), SPI_OK_SELECT, SPI_processed, SPI_tuptable, TupleDescAttr, and SPITupleTable::vals.
Referenced by get_sql_insert(), and get_sql_update().
|
static |
Definition at line 2557 of file dblink.c.
References createConnHash(), HASH_FIND, hash_search(), sort-test::key, name, pstrdup(), remoteConnHashEnt::rconn, remoteConnHash, and truncate_identifier().
Referenced by dblink_close(), dblink_disconnect(), dblink_fetch(), dblink_get_conn(), dblink_get_named_conn(), and dblink_open().
if | ( | res | ) |
Definition at line 160 of file dblink.c.
Referenced by _bt_check_unique(), _bt_deltasortsplits(), _bt_next(), _bt_parallel_done(), _bt_preprocess_keys(), _bt_readnextpage(), _Clone(), _CloseArchive(), _EndBlob(), _EndBlobs(), _EndData(), _hash_next(), _hash_readnext(), _hash_readprev(), _PrepParallelRestore(), _PrintExtraToc(), _PrintFileData(), _PrintTocData(), _ReadBuf(), _ReadExtraToc(), _ReopenArchive(), _SPI_execute_plan(), _StartBlob(), _tarAddFile(), _WriteBuf(), _WriteByte(), _WriteData(), _WriteExtraToc(), add_paths_to_grouping_rel(), addRangeTableEntryForCTE(), AggGetAggref(), AggStateIsShared(), allocarc(), allocateReloptStruct(), AlterSubscription(), analyzeCTE(), apply_projection_to_path(), are_peers(), array_cmp(), array_eq(), array_fill_internal(), array_in(), array_out(), array_position_common(), array_positions(), array_recv(), array_replace_internal(), array_send(), array_subscript_assign(), array_subscript_assign_slice(), array_subscript_fetch_old(), array_subscript_fetch_old_slice(), array_to_text_internal(), arrayconst_next_fn(), arrayexpr_next_fn(), assign_param_for_placeholdervar(), assign_param_for_var(), ATExecAlterColumnType(), ATRewriteTables(), autoinc(), bbstreamer_gzip_decompressor_new(), bernoulli_nextsampletuple(), blendscan(), blgetbitmap(), bloom_get_procinfo(), BloomFillMetapage(), blrescan(), bms_add_members(), bms_join(), brin_page_items(), btendscan(), btgetbitmap(), btgettuple(), btrescan(), btrestrpos(), build_tlist_index_other_vars(), build_tlist_to_deparse(), BuildIndexInfo(), buildMatViewRefreshDependencies(), cash_out(), check_and_push_window_quals(), check_domain_for_new_tuple(), check_parameter_resolution_walker(), check_primary_key(), check_sql_fn_statements(), check_tuple_attribute(), check_variable_parameters(), checkAllTheSame(), compute_distinct_stats(), compute_function_attributes(), compute_range_stats(), concat_internal(), connectby_text(), connectby_text_serial(), ConstructTupleDescriptor(), CopyReadAttributesText(), count_rowexpr_columns(), create_bitmap_scan_plan(), create_cursor(), CreateRole(), CreateStatistics(), crosstab(), crosstab_hash(), cube_a_f8_f8(), currtid_for_view(), dblink_get_pkey(), deparse_lquery(), deparseAggref(), deparseFromExprForRel(), digest_finish(), digest_reset(), digest_update(), distribute_row_identity_vars(), domain_in(), domain_recv(), DoPortalRunFetch(), DropRelFileNodesAllBuffers(), dumpConstraint(), ecpg_build_params(), enum_cmp_internal(), estimate_rel_size(), eval_const_expressions_mutator(), examine_simple_variable(), examine_variable(), exec_check_rw_parameter(), exec_simple_query(), exec_stmt_case(), exec_stmt_dynexecute(), exec_stmt_execsql(), exec_stmt_fetch(), ExecAlterDefaultPrivilegesStmt(), ExecAppendAsyncEventWait(), ExecBuildProjectionInfo(), ExecEndForeignScan(), ExecForeignScan(), ExecGather(), ExecHashBuildSkewHash(), ExecInitMerge(), ExecInsert(), ExecReScanFunctionScan(), ExecSort(), execute_dml_stmt(), expand_indexqual_rowcompare(), expanded_record_set_tuple(), expandRecordVariable(), ExplainNode(), ExplainQuery(), exprCollation(), exprSetCollation(), exprType(), exprTypmod(), fetch_array_arg_replace_nulls(), FigureColnameInternal(), fileBeginForeignScan(), fileEndForeignScan(), fileGetForeignPaths(), final_cost_mergejoin(), finalize_grouping_exprs_walker(), find_forced_null_var(), fixed_paramref_hook(), fmgr_sql(), foreign_expr_walker(), foreign_grouping_ok(), foreign_join_ok(), GenericXLogFinish(), get_cached_rowtype(), get_fn_opclass_options(), get_multirange_io_data(), get_name_for_var_field(), get_range_io_data(), get_rule_expr(), get_rule_sortgroupclause(), get_setop_query(), get_update_query_targetlist_def(), get_useful_pathkeys_for_relation(), GetExistingLocalJoinPath(), getIthJsonbValueFromContainer(), GetJsonTableContext(), GetMultiXactIdMembers(), getNextNearest(), getSide(), getTables(), gimme_gene(), ginCompressPostingList(), gininsert(), gist_page_items(), gist_page_items_bytea(), gistbuild(), gistgetbitmap(), gistgettuple(), gistindex_keytest(), gistinsert(), gistrescan(), gistSplit(), gtrgm_consistent(), gtrgm_distance(), has_fn_opclass_options(), hash_array(), hash_array_extended(), hash_record(), hash_record_extended(), hashendscan(), hashgettuple(), hashrescan(), heap_beginscan(), heapgettup(), heapgettup_pagemode(), hstore_each(), hstore_from_record(), hstore_populate_record(), hstore_skeys(), hstore_svals(), ImportForeignSchema(), inclusion_get_procinfo(), inclusion_get_strategy_procinfo(), infer_arbiter_indexes(), inline_set_returning_function(), insert_username(), interval_to_char(), intset_flush_buffered_values(), intset_update_upper(), inv_getsize(), is_foreign_expr(), is_foreign_param(), is_foreign_pathkey(), IsBinaryTidClause(), IsCurrentOfClause(), IsPagerNeeded(), IsTidEqualAnyClause(), itm2interval(), itmin2interval(), json_lex(), json_object_keys(), jsonb_object_keys(), jsonb_subscript_assign(), jsonb_subscript_check_subscripts(), list_next_fn(), lo_initialize(), lo_manage(), ltree_concat(), main(), map_variable_attnos_mutator(), match_boolean_index_clause(), match_foreign_keys_to_quals(), match_opclause_to_indexcol(), match_rowcompare_to_indexcol(), match_saopclause_to_indexcol(), MemoizeHash_hash(), minmax_get_strategy_procinfo(), minmax_multi_get_procinfo(), minmax_multi_get_strategy_procinfo(), moddatetime(), multirange_get_typcache(), networkjoinsel_semi(), newstate(), nocachegetattr(), NormalizeSubWord(), ordered_set_startup(), PageIndexTupleDelete(), PageIndexTupleDeleteNoCompact(), pagetable_allocate(), pagetable_free(), paraminfo_get_equal_hashops(), paramlist_param_ref(), parse_one_reloption(), parse_publication_options(), parseqatom(), pg_check_frozen(), pg_check_visible(), pg_event_trigger_ddl_commands(), pg_event_trigger_dropped_objects(), pg_get_catalog_foreign_keys(), pg_get_publication_tables(), pg_logdir_ls_internal(), pg_partition_ancestors(), pg_partition_tree(), pg_regexec(), pg_regprefix(), pg_stat_get_progress_info(), pg_timezone_abbrevs(), pg_visibility_map_rel(), pg_visibility_rel(), pgoutput_message(), pgp_armor_headers(), pgstat_acquire_replslot(), pgstat_relation_delete_pending_cb(), pgstat_report_analyze(), pgstat_report_vacuum(), pgstathashindex(), plperl_func_handler(), plperl_return_next_internal(), plperl_trigger_handler(), plpgsql_compile(), plpgsql_exec_function(), plpgsql_post_column_ref(), plpgsql_pre_column_ref(), plsample_trigger_handler(), pltcl_event_trigger_handler(), pltcl_func_handler(), pltcl_trigger_handler(), PLy_exec_function(), PLy_exec_trigger(), populate_recordset_worker(), postgresBeginDirectModify(), postgresBeginForeignScan(), postgresEndDirectModify(), postgresEndForeignModify(), postgresEndForeignScan(), postgresExecForeignBatchInsert(), postgresExecForeignInsert(), postgresGetForeignPlan(), postgresIterateDirectModify(), postgresIterateForeignScan(), postgresPlanDirectModify(), postgresReScanForeignScan(), pqAddTuple(), prepTuplestoreResult(), process_subquery_nestloop_params(), prs_process_call(), pullup_replace_vars_callback(), qual_is_pushdown_safe(), range_get_typcache(), read_dictionary(), read_whole_file(), ReadNextXLogRecord(), ReadPageInternal(), reconsider_full_join_clause(), record_cmp(), record_eq(), record_image_cmp(), record_image_eq(), record_in(), record_out(), record_recv(), record_send(), regexp_instr(), regexp_matches(), regexp_split_to_table(), regexp_substr(), remove_unused_subquery_outputs(), remove_useless_groupby_columns(), RemoveUserMapping(), ReorderBufferSerializeChange(), ReplaceVarsFromTargetList_callback(), restriction_is_constant_false(), rewriteTargetListIU(), rewriteValuesRTE(), rfree(), ri_CheckTrigger(), RI_Initial_Check(), row_is_in_frame(), satisfies_hash_partition(), scram_init(), search_directory(), set_dummy_tlist_references(), set_output_count(), set_plan_refs(), set_subquery_pathlist(), set_subquery_size_estimates(), setFilePath(), SetSingleFuncCall(), show_agg_keys(), spg_box_quad_inner_consistent(), spggettuple(), SpGistUpdateMetaPage(), spgPrepareScanKeys(), spgrescan(), spool_tuples(), sql_exec_error_callback(), sql_fn_param_ref(), sql_fn_post_column_ref(), startScanKey(), statext_dependencies_build(), storeRow(), sts_parallel_scan_next(), SubTransSetParent(), suppress_redundant_updates_trigger(), system_nextsampletuple(), system_rows_nextsampleblock(), system_rows_nextsampletuple(), system_time_nextsampleblock(), system_time_nextsampletuple(), table_block_parallelscan_nextpage(), table_block_relation_estimate_size(), tarOpen(), test_regex(), thesaurus_lexize(), tlist_member_match_var(), transformCaseExpr(), transformTargetList(), trigger_return_old(), tsvector_unnest(), tsvector_update_trigger(), tt_process_call(), ttdummy(), TupleHashTableHash_internal(), tzparse(), unique_key_recheck(), update_frameheadpos(), update_frametailpos(), update_grouptailpos(), variable_coerce_param_hook(), variable_paramref_hook(), varstrfastcmp_locale(), verify_client_proof(), verify_heapam(), view_col_is_auto_updatable(), width_bucket_array(), WinRowsArePeers(), XLogDecodeNextRecord(), and XLogPrefetcherNextBlock().
|
static |
Definition at line 2986 of file dblink.c.
References _PQconninfoOption::dispchar, and _PQconninfoOption::keyword.
Referenced by dblink_fdw_validator(), and get_connect_string().
|
static |
Definition at line 1026 of file dblink.c.
References res, and FunctionCallInfoBaseData::resultinfo.
Referenced by dblink_record_internal().
|
static |
Definition at line 887 of file dblink.c.
References applyRemoteGucs(), Assert(), BuildTupleFromCStrings(), conn, CreateTemplateTupleDesc(), CreateTupleDescCopy(), ReturnSetInfo::econtext, ExprContext::ecxt_per_query_memory, elog, ereport, errcode(), errmsg(), ERROR, get_call_result_type(), i, MemoryContextSwitchTo(), TupleDescData::natts, palloc(), PG_END_TRY, PG_FINALLY, PG_TRY, PGRES_COMMAND_OK, PGRES_TUPLES_OK, PQclear(), PQcmdStatus(), PQgetisnull(), PQgetvalue(), PQnfields(), PQntuples(), PQresultStatus(), res, restoreLocalGucs(), FunctionCallInfoBaseData::resultinfo, ReturnSetInfo::returnMode, ReturnSetInfo::setDesc, ReturnSetInfo::setResult, SFRM_Materialize, TupleDescGetAttInMetadata(), TupleDescInitEntry(), tuplestore_begin_heap(), tuplestore_puttuple(), TYPEFUNC_COMPOSITE, TYPEFUNC_RECORD, values, and work_mem.
Referenced by dblink_fetch(), and dblink_record_internal().
|
static |
PG_FUNCTION_INFO_V1 | ( | dblink_build_sql_delete | ) |
PG_FUNCTION_INFO_V1 | ( | dblink_build_sql_insert | ) |
PG_FUNCTION_INFO_V1 | ( | dblink_build_sql_update | ) |
PG_FUNCTION_INFO_V1 | ( | dblink_cancel_query | ) |
PG_FUNCTION_INFO_V1 | ( | dblink_close | ) |
PG_FUNCTION_INFO_V1 | ( | dblink_connect | ) |
PG_FUNCTION_INFO_V1 | ( | dblink_current_query | ) |
PG_FUNCTION_INFO_V1 | ( | dblink_disconnect | ) |
PG_FUNCTION_INFO_V1 | ( | dblink_error_message | ) |
PG_FUNCTION_INFO_V1 | ( | dblink_exec | ) |
PG_FUNCTION_INFO_V1 | ( | dblink_fdw_validator | ) |
PG_FUNCTION_INFO_V1 | ( | dblink_fetch | ) |
PG_FUNCTION_INFO_V1 | ( | dblink_get_connections | ) |
PG_FUNCTION_INFO_V1 | ( | dblink_get_notify | ) |
PG_FUNCTION_INFO_V1 | ( | dblink_get_pkey | ) |
PG_FUNCTION_INFO_V1 | ( | dblink_get_result | ) |
PG_FUNCTION_INFO_V1 | ( | dblink_is_busy | ) |
PG_FUNCTION_INFO_V1 | ( | dblink_open | ) |
PG_FUNCTION_INFO_V1 | ( | dblink_record | ) |
PG_FUNCTION_INFO_V1 | ( | dblink_send_query | ) |
|
static |
Definition at line 859 of file dblink.c.
References ReturnSetInfo::allowedModes, ereport, errcode(), errmsg(), ERROR, if(), IsA, FunctionCallInfoBaseData::resultinfo, ReturnSetInfo::returnMode, ReturnSetInfo::setDesc, ReturnSetInfo::setResult, and SFRM_Materialize.
Referenced by dblink_fetch(), and dblink_record_internal().
|
static |
Definition at line 2371 of file dblink.c.
References cstring_to_text(), DatumGetTextPP, DirectFunctionCall1, PointerGetDatum, quote_ident(), and text_to_cstring().
Referenced by get_sql_delete(), get_sql_insert(), get_sql_update(), and get_tuple_of_interest().
|
static |
Definition at line 3089 of file dblink.c.
References AtEOXact_GUC().
Referenced by materializeResult(), and storeQueryResult().
|
static |
Definition at line 1141 of file dblink.c.
References applyRemoteGucs(), CHECK_FOR_INTERRUPTS, conn, storeInfo::cur_res, elog, ERROR, storeInfo::last_res, pchomp(), PGRES_SINGLE_TUPLE, PGRES_TUPLES_OK, PQclear(), PQerrorMessage(), PQgetResult(), PQresultStatus(), PQsendQuery(), PQsetSingleRowMode(), res, restoreLocalGucs(), and storeRow().
Definition at line 1209 of file dblink.c.
References Assert(), storeInfo::attinmeta, BuildTupleFromCStrings(), CreateTupleDescCopy(), storeInfo::cstrs, ReturnSetInfo::econtext, ExprContext::ecxt_per_query_memory, elog, ereport, errcode(), errmsg(), ERROR, storeInfo::fcinfo, get_call_result_type(), i, if(), MemoryContextReset(), MemoryContextSwitchTo(), TupleDescData::natts, palloc(), pfree(), PQgetisnull(), PQgetvalue(), PQnfields(), PQntuples(), res, FunctionCallInfoBaseData::resultinfo, ReturnSetInfo::setDesc, ReturnSetInfo::setResult, storeInfo::tmpcontext, TupleDescGetAttInMetadata(), storeInfo::tuplestore, tuplestore_begin_heap(), tuplestore_end(), tuplestore_puttuple(), TYPEFUNC_COMPOSITE, TYPEFUNC_RECORD, and work_mem.
Referenced by storeQueryResult().
|
static |
Definition at line 2915 of file dblink.c.
References int2vector::dim1, ereport, errcode(), errmsg(), ERROR, i, j, Min, TupleDescData::natts, palloc(), RelationData::rd_att, TupleDescAttr, and int2vector::values.
Referenced by dblink_build_sql_delete(), dblink_build_sql_insert(), and dblink_build_sql_update().
|
static |
void PGresult const char* p2 |
Definition at line 156 of file dblink.c.
Referenced by bit_and(), bit_or(), bitxor(), byteapos(), colorTrgmInfoCmp(), colorTrgmInfoPenaltyCmp(), comp_ptrgm(), compare3(), compare4(), crlf_process(), DOTypeNameCompare(), ecpg_filter_stderr(), gbt_var_node_cp_len(), gist_bbox_zorder_cmp(), inter_lb(), interpt_pp(), library_name_compare(), list_int_cmp(), list_oid_cmp(), oid_cmp(), packArcInfoCmp(), packGraph(), parse_cipher_name(), passwordFromFile(), path_add(), path_distance(), path_inter(), path_n_eq(), path_n_ge(), path_n_gt(), path_n_le(), path_n_lt(), plist_same(), point_add(), point_div(), point_mul(), point_sub(), points_box(), rnode_comparator(), selectColorTrigrams(), sort_order_cmp(), TocEntrySizeCompare(), and wchareq().
|
static |
Definition at line 127 of file dblink.c.
Referenced by dblink_close(), dblink_connect(), dblink_disconnect(), dblink_exec(), dblink_fetch(), dblink_get_notify(), dblink_init(), dblink_open(), and dblink_record_internal().
|
static |
Definition at line 128 of file dblink.c.
Referenced by createNewConnection(), dblink_get_connections(), deleteConnection(), and getConnectionByName().
void PGresult* res |
Definition at line 156 of file dblink.c.
Referenced by _bt_binsrch_posting(), _check_database_version(), _doSetSessionAuth(), _int_contains(), _intbig_alloc(), _lca(), _lt_q_regex(), _ltq_regex(), _ltree_consistent(), _ltree_isparent(), _ltree_risparent(), _ltxtq_exec(), _pgp_read_public_key(), _ReadByte(), _selectOutputSchema(), _selectTableAccessMethod(), _selectTablespace(), _SPI_execute_plan(), _SPI_pquery(), _tarAddFile(), _tarReadRaw(), _tocEntryRequired(), addFooterToPublicationDesc(), addItemPointersToLeafTuple(), advance_windowaggregate(), advance_windowaggregate_base(), advanceConnectionState(), analyze_row_processor(), anybit_typmodout(), anychar_typmodout(), append_depends_on_extension(), appendBoolResult(), appendQualifiedRelation(), appendReloptionsArrayAH(), BaseBackup(), bf_check_supported_key_len(), binary_decode(), binary_encode(), binary_upgrade_set_type_oids_by_type_oid(), blgetbitmap(), BloomFormTuple(), bn_to_mpi(), btgettuple(), btproperty(), buildFreshLeafTuple(), buildMatViewRefreshDependencies(), buildShSecLabels(), byteaSetBit(), byteaSetByte(), calc_key_id(), calc_rank(), calc_rank_and(), calc_rank_or(), cfb_process(), check_field_number(), check_for_data_types_usage(), check_for_isn_and_int8_passing_mismatch(), check_for_pg_role_prefix(), check_for_prepared_transactions(), check_for_tables_with_oids(), check_for_user_defined_encoding_conversions(), check_for_user_defined_postfix_ops(), check_is_install_user(), check_key_cksum(), check_key_sha1(), check_loadable_libraries(), check_locale(), check_locale_name(), check_param_number(), check_prepare_conn(), check_publications(), check_tuple_field_number(), checkcondition_str(), CheckForBufferLeaks(), clean_NOT_intree(), clean_stopword_intree(), close_cursor(), CloseArchive(), cmp_list_len_contents_asc(), cmpEntries(), cmpTheLexeme(), cnt_sml(), coerceJsonFuncExpr(), collectComments(), collectMatchesForHeapRow(), collectRoleNames(), collectSecLabels(), combo_decrypt(), combo_encrypt(), compareItems(), compareJsonbContainers(), comparePairs(), CompareTSQ(), compareWORD(), compile_database_list(), compile_relation_list_one_db(), ConditionalLockRelation(), ConditionalLockRelationOid(), contain_context_dependent_node_walker(), convert_charset(), convert_network_to_scalar(), convertToJsonb(), convertTSFunction(), copy_crlf(), copy_messages(), copy_table(), copyTSLexeme(), cpstrdup(), create_cursor(), create_secmsg(), createPQExpBuffer(), CreateReplicationSlot(), createViewAsClause(), crlf_process(), cube_cmp(), cube_contained(), cube_contains(), cube_eq(), cube_ge(), cube_gt(), cube_le(), cube_lt(), cube_ne(), cube_overlap(), cube_union(), datetime_to_char_body(), datumCopy(), datumIsEqual(), dblink_cancel_query(), dblink_close(), dblink_exec(), dblink_fetch(), dblink_open(), dblink_record_internal(), dblink_res_error(), deallocate_query(), decompose_code(), decrypt_elgamal(), decrypt_internal(), decrypt_key(), decrypt_read(), decrypt_rsa(), defaultNoticeReceiver(), define_custom_variable(), describeAccessMethods(), describeAggregates(), describeConfigurationParameters(), describeFunctions(), describeOneTableDetails(), describeOneTSConfig(), describeOneTSParser(), describeOperators(), describePublications(), describeRoles(), describeSubscriptions(), describeTableDetails(), describeTablespaces(), describeTypes(), DetermineTimeZoneOffsetInternal(), dintdict_lexize(), discardUntilSync(), dispell_lexize(), do_field(), do_header(), do_lo_import(), do_sql_command_end(), do_watch(), downcase_convert(), dropDBs(), DropReplicationSlot(), dropRoles(), dropTablespaces(), dsimple_lexize(), dsnowball_lexize(), dsynonym_lexize(), dump_lo_buf(), dumpAgg(), dumpBaseType(), dumpBlobs(), dumpCollation(), dumpCompositeType(), dumpCompositeTypeColComments(), dumpConversion(), dumpDatabase(), dumpDatabaseConfig(), dumpDatabases(), dumpDomain(), dumpEnumType(), dumpForeignServer(), dumpFunc(), dumpOpclass(), dumpOpfamily(), dumpOpr(), dumpRangeType(), dumpRoleGUCPrivs(), dumpRoleMembership(), dumpRoles(), dumpRule(), dumpSearchPath(), dumpSequence(), dumpSequenceData(), dumpStatisticsExt(), dumpTable(), dumpTableAttach(), dumpTableData_copy(), dumpTableData_insert(), dumpTableSchema(), dumpTablespaces(), dumpTSConfig(), dumpTSDictionary(), dumpUserConfig(), dumpUserMappings(), duplicate_numeric(), dxsyn_lexize(), ecpg_build_compat_sqlda(), ecpg_build_native_sqlda(), ecpg_get_data(), ecpg_process_output(), ecpg_set_compat_sqlda(), ecpg_set_native_sqlda(), ECPGdescribe(), ECPGtrans(), emitShSecLabels(), encrypt_and_write_elgamal(), encrypt_and_write_rsa(), encrypt_init(), encrypt_internal(), encrypt_process(), EndDBCopyMode(), evalStandardFunc(), exec_command_password(), ExecEvalJson(), ExecEvalJsonConstructor(), ExecEvalJsonExpr(), ExecEvalJsonExprCoercion(), ExecEvalJsonExprSubtrans(), ExecEvalJsonIsPredicate(), ExecEvalStepOp(), ExecPrepareJsonItemCoercion(), execute_foreign_modify(), execute_jsp_gin_node(), executeAnyItem(), executeBinaryArithmExpr(), executeBoolItem(), executeCommand(), executeDateTimeMethod(), executeItemOptUnwrapResult(), executeItemOptUnwrapResultNoThrow(), executeItemOptUnwrapTarget(), executeJsonPath(), executeKeyValueMethod(), executeMaintenanceCommand(), executeNestedBoolItem(), executePredicate(), executeQuery(), ExecuteSqlCommand(), ExecuteSqlQuery(), ExecuteSqlQueryForSingleRow(), ExecuteSqlStatement(), executeStatement(), expand_dbname_patterns(), expand_extension_name_patterns(), expand_foreign_server_name_patterns(), expand_schema_name_patterns(), expand_table_name_patterns(), fail_lo_xact(), fetch_more_data(), fetch_remote_table_info(), fetch_table_list(), find_among(), find_among_b(), find_next_mcelem(), find_option(), find_provider(), find_window_run_conditions(), findTheLexeme(), finish_lo_xact(), float4_numeric(), float8_numeric(), freeaddrinfo(), g_cube_consistent(), g_int_union(), g_intbig_compress(), gbt_date_penalty(), gbt_datekey_cmp(), gbt_intvkey_cmp(), gbt_macad8key_cmp(), gbt_macadkey_cmp(), gbt_time_penalty(), gbt_timekey_cmp(), gbt_tskey_cmp(), gbt_uuidkey_cmp(), gbt_var_penalty(), gbt_vsrt_cmp(), gen_ossl_decrypt(), gen_ossl_encrypt(), get_canonical_locale_name(), get_create_object_cmd(), get_db_infos(), get_distance(), get_hex(), get_jsonb_path_all(), get_language_name(), get_loadable_libraries(), get_next_possible_free_pg_type_oid(), get_parallel_object_list(), get_rel_infos(), get_remote_estimate(), get_subscription_list(), get_synchronized_snapshot(), get_tablespace_paths(), getAccessMethods(), getAdditionalACLs(), getaddrinfo(), getAggregates(), getArrayIndex(), getBlobs(), getCasts(), getCollations(), GetConnection(), getConstraints(), getConversions(), getDatumCopy(), getDefaultACLs(), getDependencies(), getDomainConstraints(), getEventTriggers(), getExtendedStatistics(), getExtensionMembership(), getExtensions(), getForeignDataWrappers(), getForeignServers(), getFormattedTypeName(), getFuncs(), getIndexes(), getInherits(), getKeyJsonValueFromContainer(), GetLastImportantRecPtr(), getNamespaces(), getNextNearest(), getOpclasses(), getOperators(), getOpfamilies(), getPolicies(), GetPrivateRefCountEntry(), getProcLangs(), getPublicationNamespaces(), getPublications(), getPublicationTables(), getRules(), GetSlotInformation(), GetSubscriptionNotReadyRelations(), GetSubscriptionRelations(), getSubscriptions(), getTableAttrs(), GetTableInfo(), getTables(), getTokenTypes(), getTransforms(), getTriggers(), getTSConfigurations(), getTSDictionaries(), getTSParsers(), getTSTemplates(), getTypes(), ghstore_alloc(), ghstore_compress(), ghstore_consistent(), gin_btree_compare_prefix(), gin_consistent_hstore(), gin_consistent_jsonb(), gin_consistent_jsonb_path(), gin_enum_cmp(), gin_numeric_cmp(), gin_trgm_consistent(), gin_trgm_triconsistent(), gin_triconsistent_jsonb(), gin_triconsistent_jsonb_path(), gin_tsquery_consistent(), gin_tsquery_triconsistent(), ginarrayconsistent(), ginarraytriconsistent(), ginCombineData(), ginint4_consistent(), ginint4_queryextract(), gintuple_get_attrnum(), gintuple_get_key(), gist_ischild(), gist_tqcmp(), gistFormTuple(), gistproperty(), gistSplit(), gtrgm_alloc(), gtrgm_compress(), gtrgm_consistent(), gtrgm_distance(), gtsvector_alloc(), gtsvector_compress(), handleCopyIn(), handleCopyOut(), HandleCopyStream(), HandleEndOfCopyStream(), HandleParallelMessages(), hashgetbitmap(), hashgettuple(), heap_lock_tuple(), heap_prune_satisfies_vacuum(), heapam_tuple_satisfies_snapshot(), HeapTupleSatisfiesNonVacuumable(), HeapTupleSatisfiesVacuum(), hemdist(), hstore_cmp(), hstore_contains(), hstore_defined(), hstore_each(), hstore_eq(), hstore_exists_all(), hstore_exists_any(), hstore_ge(), hstore_gt(), hstore_le(), hstore_lt(), hstore_ne(), hstore_to_jsonb(), hstore_to_jsonb_loose(), hstoreUniquePairs(), indexam_property(), indexOfColumn(), inetmi(), init_compress(), init_encdata_packet(), init_libpq_conn(), init_litdata_packet(), init_s2k_key(), initGenerateDataClientSide(), inner_subltree(), insertStatEntry(), int64_div_fast_to_numeric(), int64_to_numeric(), internal_read_key(), interval_to_char(), intervaltypmodout(), is_visible_fxid(), IteratorConcat(), itsdir(), join_tsqueries(), jsonb_cmp(), jsonb_concat(), jsonb_delete(), jsonb_delete_array(), jsonb_delete_idx(), jsonb_delete_path(), jsonb_eq(), jsonb_ge(), jsonb_get_element(), jsonb_gt(), jsonb_insert(), jsonb_le(), jsonb_lt(), jsonb_ne(), jsonb_path_exists_internal(), jsonb_set(), jsonb_set_element(), jsonb_strip_nulls(), JsonbExtractScalar(), JsonbValueToJsonb(), JsonItemFromDatum(), JsonPathExists(), jsonPathFromCstring(), JsonPathQuery(), JsonPathValue(), JsonTableResetContextItem(), keyGetItem(), lazy_scan_prune(), lca(), lca_inner(), lengthCompareJsonbPair(), LexizeExec(), libpq_fetch_file(), libpq_traverse_files(), libpqrcv_connect(), libpqrcv_create_slot(), libpqrcv_endstreaming(), libpqrcv_identify_system(), libpqrcv_readtimelinehistoryfile(), libpqrcv_receive(), libpqrcv_startstreaming(), limit_printout_length(), listAllDbs(), listCasts(), listCollations(), listConversions(), listDbRoleSettings(), listDefaultACLs(), listDomains(), listEventTriggers(), listExtendedStats(), listExtensionContents(), listExtensions(), listForeignDataWrappers(), listForeignServers(), listForeignTables(), listLanguages(), listLargeObjects(), listOneExtensionContents(), listOperatorClasses(), listOperatorFamilies(), listOpFamilyFunctions(), listOpFamilyOperators(), listPartitionedTables(), listPublications(), listSchemas(), listTables(), listTSConfigs(), listTSConfigsVerbose(), listTSDictionaries(), listTSParsers(), listTSParsersVerbose(), listTSTemplates(), listUserMappings(), lo_close(), lo_creat(), lo_create(), lo_initialize(), lo_lseek(), lo_lseek64(), lo_open(), lo_read(), lo_tell(), lo_tell64(), lo_truncate(), lo_truncate64(), lo_unlink(), lo_write(), locale_date_order(), LockRelation(), LockRelationId(), LockRelationOid(), lockTableForWorker(), logicalrep_sync_worker_count(), logicalrep_worker_find(), logicalrep_workers_find(), LogicalRepSyncTableStart(), lookup_object_oid(), LPLRemoveHead(), lquery_recv(), lquery_send(), lseg_inside_poly(), lt_q_regex(), ltq_regex(), ltree_cmp(), ltree_compare(), ltree_consistent(), ltree_eq(), ltree_ge(), ltree_gt(), ltree_isparent(), ltree_le(), ltree_lt(), ltree_ne(), ltree_recv(), ltree_risparent(), ltree_send(), ltree_strncasecmp(), ltxtq_recv(), mac8_2_uint64(), mac_2_uint64(), macaddr_abbrev_convert(), main(), make_attrmap(), make_tuple_from_result_row(), makeDefElem(), makeDefElemExtended(), makeStringInfo(), makeSublist(), matchIdSubst(), materializeQueryResult(), materializeResult(), mb_strchr(), mdc_finish(), mdc_flush(), mdc_init(), mdcbuf_finish(), mdcbuf_read(), mdcbuf_refill(), minimal_error_message(), my_sock_read(), my_sock_write(), network_abbrev_convert(), NewPrivateRefCountEntry(), newTParserPosition(), NINormalizeWord(), nlevel(), numeric_abs(), numeric_add(), numeric_add_opt_error(), numeric_ceil(), numeric_div(), numeric_div_opt_error(), numeric_div_trunc(), numeric_exp(), numeric_fac(), numeric_floor(), numeric_gcd(), numeric_in(), numeric_inc(), numeric_lcm(), numeric_ln(), numeric_log(), numeric_mod(), numeric_mod_opt_error(), numeric_mul(), numeric_mul_opt_error(), numeric_poly_stddev_pop(), numeric_poly_stddev_samp(), numeric_poly_sum(), numeric_poly_var_pop(), numeric_poly_var_samp(), numeric_power(), numeric_recv(), numeric_round(), numeric_sqrt(), numeric_stddev_internal(), numeric_stddev_pop(), numeric_stddev_samp(), numeric_sub(), numeric_sub_opt_error(), numeric_trim_scale(), numeric_trunc(), numeric_uminus(), numeric_var_pop(), numeric_var_samp(), numerictypmodout(), objectDescription(), oid_dist(), old_9_6_invalidate_hash_indexes(), p_ishost(), p_isURLPath(), parse_args(), parse_compressed_data(), parse_literal_data(), parse_symenc_data(), parse_symenc_mdc_data(), parse_symenc_sesskey(), permissionsList(), pg_add_s16_overflow(), pg_add_s32_overflow(), pg_add_s64_overflow(), pg_add_u16_overflow(), pg_add_u32_overflow(), pg_add_u64_overflow(), pg_advisory_unlock_int4(), pg_advisory_unlock_int8(), pg_advisory_unlock_shared_int4(), pg_advisory_unlock_shared_int8(), pg_armor(), pg_atomic_fetch_add_u32_impl(), pg_crypt(), pg_dearmor(), pg_decrypt(), pg_decrypt_iv(), pg_digest(), pg_encrypt(), pg_encrypt_iv(), pg_get_constraintdef(), pg_get_constraintdef_ext(), pg_get_indexdef(), pg_get_indexdef_ext(), pg_get_line_append(), pg_get_partkeydef(), pg_get_ruledef(), pg_get_ruledef_ext(), pg_get_statisticsobjdef(), pg_get_statisticsobjdef_columns(), pg_get_triggerdef(), pg_get_triggerdef_ext(), pg_get_viewdef(), pg_get_viewdef_ext(), pg_get_viewdef_name(), pg_get_viewdef_name_ext(), pg_get_viewdef_wrap(), pg_hmac(), pg_lsn_mii(), pg_lsn_pli(), pg_mul_s16_overflow(), pg_mul_s32_overflow(), pg_mul_s64_overflow(), pg_mul_u16_overflow(), pg_mul_u32_overflow(), pg_mul_u64_overflow(), pg_random_bytes(), pg_SASL_continue(), pg_strong_random(), pg_sub_s16_overflow(), pg_sub_s32_overflow(), pg_sub_s64_overflow(), pg_try_advisory_lock_int4(), pg_try_advisory_lock_int8(), pg_try_advisory_lock_shared_int4(), pg_try_advisory_lock_shared_int8(), pg_try_advisory_xact_lock_int4(), pg_try_advisory_xact_lock_int8(), pg_try_advisory_xact_lock_shared_int4(), pg_try_advisory_xact_lock_shared_int8(), pgfdw_finish_pre_commit_cleanup(), pgfdw_get_cleanup_result(), pgfdw_get_result(), pgfdw_report_error(), pgfdw_xact_callback(), pgp_armor_decode(), pgp_armor_encode(), pgp_armor_headers(), pgp_cfb_create(), pgp_create_pkt_reader(), pgp_create_pkt_writer(), pgp_decrypt(), pgp_elgamal_decrypt(), pgp_elgamal_encrypt(), pgp_encrypt(), pgp_expect_packet_end(), pgp_get_keyid(), pgp_key_id_w(), pgp_load_cipher(), pgp_load_digest(), pgp_mpi_create(), pgp_mpi_read(), pgp_mpi_write(), pgp_parse_pkt_hdr(), pgp_parse_pubenc_sesskey(), pgp_pub_decrypt_bytea(), pgp_pub_decrypt_text(), pgp_pub_encrypt_bytea(), pgp_pub_encrypt_text(), pgp_rsa_decrypt(), pgp_rsa_encrypt(), pgp_s2k_fill(), pgp_s2k_process(), pgp_s2k_read(), pgp_set_pubkey(), pgp_skip_packet(), pgp_sym_decrypt_bytea(), pgp_sym_decrypt_text(), pgp_sym_encrypt_bytea(), pgp_sym_encrypt_text(), pgp_write_pubenc_sesskey(), pgwin32_bind(), pgwin32_listen(), pgwin32_putenv(), pgwin32_setenv(), pgwin32_unsetenv(), pgxml_result_to_text(), pkt_stream_flush(), pkt_stream_process(), pktreader_pull(), populate_domain(), populate_record(), populate_scalar(), postgresAcquireSampleRowsFunc(), postgresAnalyzeForeignTable(), postgresImportForeignSchema(), postgresReScanForeignScan(), pqAddTuple(), PQbinaryTuples(), pqBuildErrorMessage3(), PQclear(), PQcmdStatus(), PQcmdTuples(), PQconnectPoll(), PQdisplayTuples(), PQencryptPasswordConn(), PQfformat(), PQfireResultCreateEvents(), PQfmod(), PQfname(), PQfnumber(), PQfsize(), PQftable(), PQftablecol(), PQftype(), pqGetErrorNotice3(), PQgetisnull(), PQgetlength(), PQgetResult(), PQgetvalue(), pqInternalNotice(), PQnfields(), PQnparams(), PQntuples(), PQoidStatus(), PQoidValue(), PQparamtype(), pqPrepareAsyncResult(), PQprint(), PQprintTuples(), PQresultAlloc(), pqResultAlloc(), PQresultErrorField(), PQresultErrorMessage(), PQresultMemorySize(), PQresultStatus(), pqResultStrdup(), PQresultVerboseErrorMessage(), pqRowProcessor(), pqSaveMessageField(), PQsetClientEncoding(), PQsetResultAttrs(), pqSetResultError(), PQsetvalue(), prepare_foreign_modify(), PrintResultInCrosstab(), printResultSet(), printTypmod(), process_data_packets(), process_queued_fetch_requests(), process_result(), process_secret_key(), processExtensionTables(), PSQLexec(), PSQLexecWatch(), pullf_create(), pullf_read(), pullf_read_fixed(), pullf_read_max(), pushf_create(), pushf_create_mbuf_writer(), pushf_flush(), pushf_write(), pushJsonbValue(), px_find_cipher(), px_find_combo(), px_find_digest(), px_find_hmac(), qsortCompareItemPointers(), QTNodeCompare(), quote_postgres(), read_pubenc_keyid(), read_pubkey_keyid(), readCommandResponse(), readDatum(), ReadEndOfStreamingResult(), ReadInt(), readTimeLineHistory(), reap_child(), ReceiveCopyData(), ReceiveXlogStream(), RelationFindReplTupleByIndex(), RelationFindReplTupleSeq(), ReplicationSlotDropAtPubNode(), report_extension_updates(), ReservePrivateRefCountEntry(), ResourceOwnerReleaseAllPlanCacheRefs(), ResourceOwnerReleaseInternal(), RestoreOutput(), RetrieveDataDirCreatePerm(), RetrieveWalSegSize(), run_crypt_des(), run_crypt_md5(), run_permutation(), run_simple_command(), run_simple_query(), RunIdentifySystem(), runShellCommand(), sampler_random_fract(), sendCommand(), set_arg(), setNewTmpRes(), setPath(), shm_mq_receive(), shm_mq_sendv(), should_processing_continue(), show_binary_results(), silly_cmp_tsvector(), similarity(), similarity_dist(), similarity_op(), socket_flush(), socket_flush_if_writable(), socket_putmessage_noblock(), SortAndUniqItems(), spg_quad_leaf_consistent(), spg_range_quad_leaf_consistent(), spg_text_inner_consistent(), spg_text_leaf_consistent(), spgist_name_inner_consistent(), spgist_name_leaf_consistent(), spgproperty(), SPI_execute(), SPI_execute_extended(), SPI_execute_plan(), SPI_execute_plan_extended(), SPI_execute_plan_with_paramlist(), SPI_execute_snapshot(), SPI_execute_with_args(), SPI_finish(), SPI_fnumber(), SPI_register_relation(), SPI_unregister_relation(), sql_conn(), sql_exec(), sqlda_common_total_size(), sqlda_compat_empty_size(), sqlda_compat_total_size(), sqlda_native_empty_size(), sqlda_native_total_size(), start_lo_xact(), store_returning_result(), storeQueryResult(), storeRow(), StreamLogicalLog(), strict_word_similarity(), strict_word_similarity_commutator_op(), strict_word_similarity_dist_commutator_op(), strict_word_similarity_dist_op(), strict_word_similarity_op(), stringlist_to_identifierstr(), strip_trailing_ws(), subltree(), subpath(), sv2cstr(), symencrypt_sesskey(), TableCommandResultHandler(), tarRead(), tarWrite(), test_disallowed_in_pipeline(), test_indoption(), test_multi_pipelines(), test_nosync(), test_pipeline_abort(), test_pipelined_insert(), test_prepared(), test_shm_mq(), test_shm_mq_pipelined(), test_simple_pipeline(), test_singlerowmode(), test_transaction(), test_uniqviol(), textarray_to_stringlist(), thesaurus_lexize(), timestamp_to_char(), timestamptz_to_char(), toast_open_indexes(), transform_jsonb_string_values(), transformJsonTableChildPlan(), transformTargetList(), trgm_contained_by(), trgm_presence_map(), try_complete_step(), tryExecuteStatement(), ts_lexize(), ts_match_tq(), ts_match_tt(), ts_rank_tt(), ts_rank_ttf(), ts_rank_wtt(), ts_rank_wttf(), ts_rankcd_tt(), ts_rankcd_ttf(), ts_rankcd_wtt(), ts_rankcd_wttf(), tsquery_and(), tsquery_cmp(), tsquery_not(), tsquery_or(), tsquery_phrase_distance(), tsquerytree(), tuple_data_split(), unaccent_dict(), unaccent_lexize(), uniqueentry(), uniqueifyJsonbObject(), uniquePos(), uniqueWORD(), uuid_abbrev_convert(), vac_tid_reaped(), vacuum_one_database(), vacuumlo(), varstr_abbrev_convert(), verify_btree_slot_handler(), verify_heap_slot_handler(), WinRowsArePeers(), word_similarity(), word_similarity_commutator_op(), word_similarity_dist_commutator_op(), word_similarity_dist_op(), word_similarity_op(), wrap_process(), write_prefix(), write_symenc_sesskey(), WriteStr(), xpath_bool(), xpath_list(), xpath_nodeset(), xpath_number(), xpath_string(), and xpath_table().