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 "libpq/libpq-be.h"
#include "libpq/libpq-be-fe-helpers.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"
#include "utils/wait_event.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 uint32 | dblink_we_connect = 0 |
static uint32 | dblink_we_get_conn = 0 |
static uint32 | dblink_we_get_result = 0 |
static void PGresult * | res |
static void PGresult const char * | p2 |
typedef struct remoteConn remoteConn |
typedef struct remoteConnHashEnt remoteConnHashEnt |
|
static |
Definition at line 3032 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 2541 of file dblink.c.
References ctl, hash_create(), HASH_ELEM, HASH_STRINGS, NAMEDATALEN, and NUMCONN.
Referenced by createNewConnection(), deleteConnection(), and getConnectionByName().
|
static |
Definition at line 2553 of file dblink.c.
References remoteConn::conn, createConnHash(), ereport, errcode(), ERRCODE_DUPLICATE_OBJECT, errmsg(), ERROR, HASH_ENTER, hash_search(), sort-test::key, libpqsrv_disconnect(), name, pfree(), pstrdup(), remoteConnHashEnt::rconn, remoteConnHash, and truncate_identifier().
Referenced by dblink_connect().
Datum dblink_build_sql_delete | ( | PG_FUNCTION_ARGS | ) |
Definition at line 1713 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 1624 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 1789 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 1347 of file dblink.c.
References conn, cstring_to_text(), dblink_get_named_conn(), dblink_init(), GetCurrentTimestamp(), libpqsrv_cancel(), PG_GETARG_TEXT_PP, PG_RETURN_TEXT_P, text_to_cstring(), and TimestampTzPlusMilliseconds.
Datum dblink_close | ( | PG_FUNCTION_ARGS | ) |
Definition at line 486 of file dblink.c.
References appendStringInfo(), buf, remoteConn::conn, conn, cstring_to_text(), dblink_init(), dblink_res_error(), dblink_we_get_result, get_fn_expr_argtype(), getConnectionByName(), initStringInfo(), libpqsrv_exec(), remoteConn::newXactForCursor, remoteConn::openCursorCount, pconn, PG_GETARG_BOOL, PG_GETARG_TEXT_PP, PG_NARGS, PG_RETURN_TEXT_P, PGRES_COMMAND_OK, PQclear(), PQresultStatus(), res, and text_to_cstring().
Datum dblink_connect | ( | PG_FUNCTION_ARGS | ) |
Definition at line 272 of file dblink.c.
References remoteConn::conn, conn, CONNECTION_BAD, connstr, createNewConnection(), cstring_to_text(), dblink_connstr_check(), dblink_init(), dblink_security_check(), dblink_we_connect, ereport, errcode(), errdetail_internal(), errmsg(), ERROR, get_connect_string(), GetDatabaseEncoding(), GetDatabaseEncodingName(), libpqsrv_connect(), libpqsrv_disconnect(), MemoryContextAlloc(), remoteConn::newXactForCursor, remoteConn::openCursorCount, pchomp(), pconn, pfree(), PG_GETARG_TEXT_PP, PG_NARGS, PG_RETURN_TEXT_P, PQclientEncoding(), PQerrorMessage(), PQsetClientEncoding(), PQstatus(), text_to_cstring(), TopMemoryContext, and WaitEventExtensionNew().
|
static |
Definition at line 2677 of file dblink.c.
References be_gssapi_get_delegation(), connstr, dblink_connstr_has_pw(), ereport, errcode(), errdetail(), errmsg(), ERROR, MyProcPort, and superuser().
Referenced by dblink_connect(), and dblink_get_conn().
|
static |
Definition at line 2642 of file dblink.c.
References connstr, options, PQconninfoFree(), PQconninfoParse(), and option::val.
Referenced by dblink_connstr_check(), and dblink_security_check().
Datum dblink_current_query | ( | PG_FUNCTION_ARGS | ) |
Datum dblink_disconnect | ( | PG_FUNCTION_ARGS | ) |
Definition at line 355 of file dblink.c.
References remoteConn::conn, conn, cstring_to_text(), dblink_init(), deleteConnection(), getConnectionByName(), libpqsrv_disconnect(), pconn, pfree(), PG_GETARG_TEXT_PP, PG_NARGS, PG_RETURN_TEXT_P, and text_to_cstring().
Datum dblink_error_message | ( | PG_FUNCTION_ARGS | ) |
Definition at line 1377 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 1397 of file dblink.c.
References remoteConn::conn, conn, cstring_to_text(), dblink_get_conn(), dblink_init(), dblink_res_error(), dblink_we_get_result, elog(), ereport, errcode(), errmsg(), ERROR, get_fn_expr_argtype(), libpqsrv_disconnect(), libpqsrv_exec(), 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(), PQresultStatus(), res, and text_to_cstring().
Datum dblink_fdw_validator | ( | PG_FUNCTION_ARGS | ) |
Definition at line 1939 of file dblink.c.
References context, DefElem::defname, ereport, errcode(), errdetail(), errhint(), errmsg(), ERROR, getClosestMatch(), initClosestMatch(), is_valid_dblink_option(), _PQconninfoOption::keyword, lfirst, match_state, PG_GETARG_DATUM, PG_GETARG_OID, PG_RETURN_VOID, PQconndefaults(), untransformRelOptions(), and updateClosestMatch().
Datum dblink_fetch | ( | PG_FUNCTION_ARGS | ) |
Definition at line 573 of file dblink.c.
References appendStringInfo(), buf, remoteConn::conn, conn, dblink_init(), dblink_res_error(), dblink_we_get_result, ereport, errcode(), errmsg(), ERROR, get_fn_expr_argtype(), getConnectionByName(), initStringInfo(), libpqsrv_exec(), materializeResult(), pconn, PG_GETARG_BOOL, PG_GETARG_INT32, PG_GETARG_TEXT_PP, PG_NARGS, PGRES_COMMAND_OK, PGRES_TUPLES_OK, PQclear(), PQresultStatus(), prepTuplestoreResult(), res, and text_to_cstring().
|
static |
Definition at line 188 of file dblink.c.
References remoteConn::conn, conn, CONNECTION_BAD, connstr, dblink_connstr_check(), dblink_security_check(), dblink_we_get_conn, ereport, errcode(), errdetail_internal(), errmsg(), ERROR, get_connect_string(), getConnectionByName(), GetDatabaseEncoding(), GetDatabaseEncodingName(), libpqsrv_connect(), libpqsrv_disconnect(), pchomp(), PQclientEncoding(), PQerrorMessage(), PQsetClientEncoding(), PQstatus(), and WaitEventExtensionNew().
Referenced by dblink_exec(), and dblink_record_internal().
Datum dblink_get_connections | ( | PG_FUNCTION_ARGS | ) |
Definition at line 1288 of file dblink.c.
References accumArrayResult(), CStringGetTextDatum, CurrentMemoryContext, hash_seq_init(), hash_seq_search(), makeArrayResult(), remoteConnHashEnt::name, PG_RETURN_DATUM, PG_RETURN_NULL, and remoteConnHash.
|
static |
Definition at line 241 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 1886 of file dblink.c.
References pgNotify::be_pid, remoteConn::conn, conn, CStringGetTextDatum, dblink_get_named_conn(), dblink_init(), DBLINK_NOTIFY_COLS, pgNotify::extra, InitMaterializedSRF(), Int32GetDatum(), pconn, PG_GETARG_TEXT_PP, PG_NARGS, PQconsumeInput(), PQfreemem(), PQnotifies(), pgNotify::relname, ReturnSetInfo::setDesc, ReturnSetInfo::setResult, text_to_cstring(), tuplestore_putvalues(), and values.
Datum dblink_get_pkey | ( | PG_FUNCTION_ARGS | ) |
Definition at line 1500 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_array, 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 699 of file dblink.c.
References dblink_record_internal().
|
static |
Definition at line 253 of file dblink.c.
References remoteConn::conn, dblink_we_get_result, MemoryContextAlloc(), remoteConn::newXactForCursor, remoteConn::openCursorCount, pconn, TopMemoryContext, and WaitEventExtensionNew().
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 1323 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 393 of file dblink.c.
References appendStringInfo(), buf, remoteConn::conn, conn, cstring_to_text(), dblink_init(), dblink_res_error(), dblink_we_get_result, get_fn_expr_argtype(), getConnectionByName(), initStringInfo(), libpqsrv_exec(), remoteConn::newXactForCursor, remoteConn::openCursorCount, pconn, PG_GETARG_BOOL, PG_GETARG_TEXT_PP, PG_NARGS, PG_RETURN_TEXT_P, PGRES_COMMAND_OK, PQclear(), PQresultStatus(), PQTRANS_IDLE, PQtransactionStatus(), res, and text_to_cstring().
Datum dblink_record | ( | PG_FUNCTION_ARGS | ) |
Definition at line 667 of file dblink.c.
References dblink_record_internal().
|
static |
Definition at line 705 of file dblink.c.
References remoteConn::conn, conn, dblink_get_conn(), dblink_get_named_conn(), dblink_init(), dblink_res_error(), dblink_we_get_result, elog(), ERROR, FunctionCallInfoBaseData::flinfo, get_fn_expr_argtype(), libpqsrv_disconnect(), libpqsrv_get_result(), 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, PQresultStatus(), prepTuplestoreResult(), res, and text_to_cstring().
Referenced by dblink_get_result(), and dblink_record().
|
static |
Definition at line 2705 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 2607 of file dblink.c.
References be_gssapi_get_delegation(), conn, connstr, dblink_connstr_has_pw(), ereport, errcode(), errdetail(), errhint(), errmsg(), ERROR, libpqsrv_disconnect(), MyProcPort, pfree(), PQconnectionUsedGSSAPI(), PQconnectionUsedPassword(), and superuser().
Referenced by dblink_connect(), and dblink_get_conn().
Datum dblink_send_query | ( | PG_FUNCTION_ARGS | ) |
Definition at line 674 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 2581 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().
Referenced by dblink_exec(), dblink_record_internal(), dblink_send_query(), materializeResult(), storeQueryResult(), and storeRow().
|
static |
Definition at line 2877 of file dblink.c.
References appendStringInfoChar(), buf, initStringInfo(), and str.
Referenced by get_connect_string().
|
static |
Definition at line 2503 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 2352 of file dblink.c.
References i, and sort-test::key.
Referenced by get_sql_insert(), and get_sql_update().
|
static |
Definition at line 2787 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_aclcheck(), OBJECT_FOREIGN_SERVER, ForeignDataWrapper::options, ForeignServer::options, UserMapping::options, PQconndefaults(), pstrdup(), ForeignServer::serverid, ForeignServer::servername, strVal, and truncate_identifier().
Referenced by dblink_connect(), and dblink_get_conn().
Definition at line 2018 of file dblink.c.
References AccessShareLock, BTEqualStrategyNumber, GETSTRUCT, HeapTupleIsValid, i, ObjectIdGetDatum(), palloc_array, 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 2478 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 2209 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 2129 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 2246 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 2073 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, nitems, palloc_array, PointerGetDatum(), TextDatumGetCString, typalign, and values.
Referenced by dblink_build_sql_delete(), dblink_build_sql_insert(), and dblink_build_sql_update().
|
static |
Definition at line 2367 of file dblink.c.
References appendStringInfo(), appendStringInfoString(), buf, 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 2521 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().
|
static |
Definition at line 2981 of file dblink.c.
References context, _PQconninfoOption::dispchar, and _PQconninfoOption::keyword.
Referenced by dblink_fdw_validator(), and get_connect_string().
|
static |
Definition at line 992 of file dblink.c.
References res, and FunctionCallInfoBaseData::resultinfo.
Referenced by dblink_record_internal().
|
static |
Definition at line 853 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_array, 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().
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 | ) |
PQclear | ( | res | ) |
Referenced by _check_database_version(), _doSetSessionAuth(), _printTableAccessMethodNoStorage(), _selectOutputSchema(), _selectTableAccessMethod(), _selectTablespace(), add_tablespace_footer(), addFooterToPublicationDesc(), advanceConnectionState(), append_depends_on_extension(), appendQualifiedRelation(), BaseBackup(), binary_upgrade_set_type_oids_by_type_oid(), buildMatViewRefreshDependencies(), buildShSecLabels(), check_and_drop_existing_subscriptions(), check_for_connection_status(), check_for_pg_role_prefix(), check_for_prepared_transactions(), check_is_install_user(), check_loadable_libraries(), check_new_cluster_logical_replication_slots(), check_new_cluster_subscription_configuration(), check_old_cluster_subscription_state(), check_prepare_conn(), check_publisher(), check_subscriber(), ClearOrSaveResult(), close_cursor(), cluster_all_databases(), collectBinaryUpgradeClassOids(), collectComments(), collectRoleNames(), collectSecLabels(), collectSequences(), compile_database_list(), compile_relation_list_one_db(), confirm_query_canceled_impl(), connect_database(), ConnectDatabase(), connectDatabase(), connectToServer(), convertTSFunction(), create_cursor(), create_logical_replication_slot(), create_logical_replication_slots(), create_new_objects(), create_publication(), create_subscription(), CreateReplicationSlot(), createViewAsClause(), dblink_close(), dblink_exec(), dblink_fetch(), dblink_open(), dblink_res_error(), deallocate_one(), deallocate_query(), describeAccessMethods(), describeAggregates(), describeConfigurationParameters(), describeFunctions(), describeOneTableDetails(), describeOneTSConfig(), describeOneTSParser(), describeOperators(), describePublications(), DescribeQuery(), describeRoleGrants(), describeRoles(), describeSubscriptions(), describeTableDetails(), describeTablespaces(), describeTypes(), descriptor_free(), discardUntilSync(), do_lo_import(), do_sql_command_end(), drop_existing_subscriptions(), drop_failover_replication_slots(), drop_publication(), drop_replication_slot(), dropDBs(), DropReplicationSlot(), dropRoles(), dropTablespaces(), dumpAgg(), dumpBaseType(), dumpCollation(), dumpCompositeType(), 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(), ecpg_autostart_transaction(), ecpg_check_PQresult(), ecpg_process_output(), ECPGdescribe(), ECPGsetcommit(), ECPGtrans(), enable_subscription(), EndDBCopyMode(), exec_command_password(), execute_foreign_modify(), executeCommand(), executeMaintenanceCommand(), executeQueryOrDie(), ExecuteSqlCommand(), 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(), finish_lo_xact(), generate_object_name(), get_create_object_cmd(), get_db_infos(), get_language_name(), get_loadable_libraries(), get_next_possible_free_pg_type_oid(), get_parallel_object_list(), get_primary_sysid(), get_remote_estimate(), get_returning_data(), get_subscription_count(), get_synchronized_snapshot(), get_tablespace_paths(), get_template0_info(), getAccessMethods(), getAdditionalACLs(), getAggregates(), getCasts(), getCollations(), GetConnection(), getConstraints(), getConversions(), getCopyStart(), getDefaultACLs(), getDependencies(), getDomainConstraints(), getEventTriggers(), getExtendedStatistics(), getExtensionMembership(), getExtensions(), getForeignDataWrappers(), getForeignServers(), getFormattedTypeName(), getFuncs(), getIndexes(), getInherits(), getLOs(), getNamespaces(), getOpclasses(), getOperators(), getOpfamilies(), getParamDescriptions(), getPartitioningInfo(), getPolicies(), getProcLangs(), getPublicationNamespaces(), getPublications(), getPublicationTables(), getRowDescriptions(), getRules(), GetSlotInformation(), getSubscriptions(), getSubscriptionTables(), getTableAttrs(), GetTableInfo(), getTables(), getTransforms(), getTriggers(), getTSConfigurations(), getTSDictionaries(), getTSParsers(), getTSTemplates(), getTypes(), handleCopyIn(), HandleCopyResult(), HandleEndOfCopyStream(), init_libpq_conn(), initPopulateTable(), libpq_fetch_file(), libpq_traverse_files(), libpqrcv_alter_slot(), libpqrcv_connect(), libpqrcv_create_slot(), libpqrcv_endstreaming(), libpqrcv_exec(), libpqrcv_identify_system(), libpqrcv_PQexec(), libpqrcv_readtimelinehistoryfile(), libpqrcv_receive(), libpqrcv_startstreaming(), libpqsrv_get_result_last(), 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(), lockTableForWorker(), lookup_object_oid(), main(), materializeResult(), objectDescription(), old_9_6_invalidate_hash_indexes(), permissionsList(), pgfdw_cancel_query_end(), pgfdw_exec_cleanup_query_end(), pgfdw_finish_pre_commit_cleanup(), pgfdw_get_cleanup_result(), pgfdw_report_error(), pgfdw_xact_callback(), postgresAcquireSampleRowsFunc(), postgresAnalyzeForeignTable(), postgresEndDirectModify(), postgresGetAnalyzeInfoForForeignTable(), postgresImportForeignSchema(), postgresReScanForeignScan(), PQconnectPoll(), PQencryptPasswordConn(), pqEndcopy3(), pqGetErrorNotice3(), PQsetClientEncoding(), prepare_common(), prepare_foreign_modify(), prepareCommand(), process_query_result(), process_queued_fetch_requests(), process_result(), processExtensionTables(), processQueryResult(), readCommandResponse(), ReceiveCopyData(), ReceiveXlogStream(), reindex_all_databases(), RetrieveDataDirCreatePerm(), RetrieveWalSegSize(), run_permutation(), run_simple_command(), run_simple_query(), RunIdentifySystem(), SendQuery(), server_is_in_recovery(), set_frozenxids(), set_locale_and_encoding(), set_replication_progress(), set_restrict_relation_kind(), setup_connection(), setup_publisher(), sql_conn(), sql_exec(), start_lo_xact(), store_returning_result(), storeQueryResult(), StreamLogicalLog(), TableCommandResultHandler(), test_multi_pipelines(), test_nosync(), test_pipeline_abort(), test_pipeline_idle(), test_pipelined_insert(), test_prepared(), test_simple_pipeline(), test_singlerowmode(), test_transaction(), try_complete_step(), tryExecuteStatement(), vacuum_all_databases(), vacuum_one_database(), vacuumlo(), and wait_for_connection_state().
|
static |
Definition at line 825 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 2337 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 3084 of file dblink.c.
References AtEOXact_GUC().
Referenced by materializeResult(), and storeQueryResult().
|
static |
Definition at line 1108 of file dblink.c.
References applyRemoteGucs(), CHECK_FOR_INTERRUPTS, conn, storeInfo::cur_res, dblink_we_get_result, elog(), ERROR, storeInfo::last_res, libpqsrv_get_result(), pchomp(), PGRES_SINGLE_TUPLE, PGRES_TUPLES_OK, PQclear(), PQerrorMessage(), PQresultStatus(), PQsendQuery(), PQsetSingleRowMode(), res, restoreLocalGucs(), and storeRow().
Definition at line 1176 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_array, 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 2910 of file dblink.c.
References int2vector::dim1, ereport, errcode(), errmsg(), ERROR, i, j, Min, TupleDescData::natts, palloc_array, RelationData::rd_att, TupleDescAttr, and int2vector::values.
Referenced by dblink_build_sql_delete(), dblink_build_sql_insert(), and dblink_build_sql_update().
|
static |
|
static |
Definition at line 135 of file dblink.c.
Referenced by dblink_connect().
|
static |
Definition at line 136 of file dblink.c.
Referenced by dblink_get_conn().
|
static |
Definition at line 137 of file dblink.c.
Referenced by dblink_close(), dblink_exec(), dblink_fetch(), dblink_init(), dblink_open(), dblink_record_internal(), and storeQueryResult().
void PGresult const char* p2 |
Definition at line 165 of file dblink.c.
Referenced by BinaryUpgradeClassOidItemCmp(), 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(), rlocator_comparator(), selectColorTrigrams(), SequenceItemCmp(), sort_order_cmp(), TocEntrySizeCompareBinaryheap(), TocEntrySizeCompareQsort(), and wchareq().
|
static |
Definition at line 131 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 132 of file dblink.c.
Referenced by createNewConnection(), dblink_get_connections(), deleteConnection(), and getConnectionByName().
void PGresult* res |
Definition at line 165 of file dblink.c.
Referenced by _bt_binsrch_posting(), _bt_checkkeys(), _bt_merge_arrays(), _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(), _printTableAccessMethodNoStorage(), _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(), cash_div_float8(), cash_mi_cash(), cash_mul_float8(), cash_mul_int64(), cash_pl_cash(), cash_words(), cfb_process(), check_and_drop_existing_subscriptions(), check_field_number(), check_for_pg_role_prefix(), check_for_prepared_transactions(), check_is_install_user(), check_key_cksum(), check_key_sha1(), check_loadable_libraries(), check_locale(), check_locale_name(), check_new_cluster_logical_replication_slots(), check_new_cluster_subscription_configuration(), check_old_cluster_subscription_state(), check_param_number(), check_prepare_conn(), check_publications(), check_publications_origin(), check_publisher(), check_subscriber(), check_tuple_field_number(), checkcondition_str(), CheckForBufferLeaks(), clean_NOT_intree(), clean_stopword_intree(), close_cursor(), cmp_list_len_contents_asc(), cmpEntries(), cmpTheLexeme(), cnt_sml(), coerceJsonFuncExpr(), collectBinaryUpgradeClassOids(), collectComments(), collectMatchesForHeapRow(), collectRoleNames(), collectSecLabels(), collectSequences(), combo_decrypt(), combo_encrypt(), compareItems(), compareJsonbContainers(), comparePairs(), CompareTSQ(), compareWORD(), compile_database_list(), compile_relation_list_one_db(), ConditionalLockDatabaseObject(), ConditionalLockRelation(), ConditionalLockRelationOid(), ConditionalLockSharedObject(), confirm_query_canceled_impl(), connect_database(), contain_context_dependent_node_walker(), convert_charset(), convert_network_to_scalar(), convertToJsonb(), convertTSFunction(), copy_crlf(), copy_messages(), copy_table(), CopyLimitPrintoutLength(), copyTSLexeme(), cpstrdup(), create_cursor(), create_logical_replication_slot(), create_publication(), create_secmsg(), create_subscription(), 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_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(), describeAccessMethods(), describeAggregates(), describeConfigurationParameters(), describeFunctions(), describeOneTableDetails(), describeOneTSConfig(), describeOneTSParser(), describeOperators(), describePublications(), describeRoleGrants(), describeRoles(), describeSubscriptions(), describeTableDetails(), describeTablespaces(), describeTypes(), determineNotNullFlags(), DetermineTimeZoneOffsetInternal(), dintdict_lexize(), discardUntilSync(), dispell_lexize(), do_field(), do_header(), do_lo_import(), do_sql_command_end(), do_watch(), downcase_convert(), drop_existing_subscriptions(), drop_failover_replication_slots(), drop_publication(), drop_replication_slot(), dropDBs(), DropReplicationSlot(), dropRoles(), dropTablespaces(), dsimple_lexize(), dsnowball_lexize(), dsynonym_lexize(), dump_lo_buf(), dumpAgg(), dumpBaseType(), 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(), enable_subscription(), encrypt_and_write_elgamal(), encrypt_and_write_rsa(), encrypt_init(), encrypt_internal(), encrypt_process(), EndDBCopyMode(), evalStandardFunc(), exec_command_password(), ExecEvalJsonConstructor(), ExecEvalJsonIsPredicate(), ExecEvalStepOp(), 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(), finalize_windowaggregate(), find_among(), find_among_b(), find_next_mcelem(), find_provider(), find_window_run_conditions(), FindConflictTuple(), findTheLexeme(), finish_lo_xact(), float4_numeric(), float8_numeric(), 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(), generate_object_name(), generate_series_numeric_support(), 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_primary_sysid(), get_remote_estimate(), get_subscription_count(), get_subscription_list(), get_synchronized_snapshot(), get_tablespace_paths(), getAccessMethods(), getAdditionalACLs(), getAggregates(), getArrayIndex(), getCasts(), getCollations(), GetConnection(), getConstraints(), getConversions(), getDatumCopy(), getDefaultACLs(), getDependencies(), getDomainConstraints(), getEventTriggers(), getExtendedStatistics(), getExtensionMembership(), getExtensions(), getForeignDataWrappers(), getForeignServers(), getFormattedTypeName(), getFuncs(), getIndexes(), getInherits(), getKeyJsonValueFromContainer(), GetLastImportantRecPtr(), getLOs(), getNamespaces(), getNextNearest(), getOpclasses(), getOperators(), getOpfamilies(), getPartitioningInfo(), getPolicies(), GetPrivateRefCountEntry(), getProcLangs(), getPublicationNamespaces(), getPublications(), getPublicationTables(), getRules(), GetSlotInformation(), GetSubscriptionRelations(), getSubscriptions(), getSubscriptionTables(), getTableAttrs(), GetTableInfo(), getTables(), 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(), HandleParallelApplyMessages(), 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(), initPopulateTable(), 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(), json_parse_manifest_incremental_chunk(), 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(), JsonTableResetRowPattern(), keyGetItem(), lca(), lca_inner(), lengthCompareJsonbPair(), LexizeExec(), libpq_fetch_file(), libpq_traverse_files(), libpqrcv_alter_slot(), libpqrcv_connect(), libpqrcv_create_slot(), libpqrcv_endstreaming(), libpqrcv_identify_system(), libpqrcv_readtimelinehistoryfile(), libpqrcv_receive(), libpqrcv_startstreaming(), 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_pa_worker_count(), logicalrep_sync_worker_count(), logicalrep_worker_find(), logicalrep_workers_find(), LogicalRepSyncTableStart(), lookup_object_oid(), LPLRemoveHead(), lquery_in(), 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_in(), ltree_isparent(), ltree_le(), ltree_lt(), ltree_ne(), ltree_recv(), ltree_risparent(), ltree_send(), ltree_strncasecmp(), ltxtq_in(), 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(), 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(), optimize_window_clauses(), 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_neg_u16_overflow(), pg_neg_u32_overflow(), pg_neg_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(), pgconn_bio_ctrl(), pgconn_bio_method(), pgconn_bio_read(), pgconn_bio_write(), pgfdw_finish_pre_commit_cleanup(), pgfdw_get_cleanup_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(), port_bio_ctrl(), port_bio_read(), port_bio_write(), postgresAcquireSampleRowsFunc(), postgresAnalyzeForeignTable(), postgresGetAnalyzeInfoForForeignTable(), postgresImportForeignSchema(), postgresReScanForeignScan(), pqAddTuple(), PQbinaryTuples(), pqBuildErrorMessage3(), PQchangePassword(), 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(), prepareCommand(), PrintManyTest(), PrintResultInCrosstab(), printResultSet(), PrintString(), printTypmod(), process_data_packets(), process_data_type_check(), process_extension_updates(), process_incompat_polymorphics(), process_isn_and_int8_passing_mismatch(), process_loadable_libraries(), process_old_cluster_logical_slot_infos(), process_old_sub_state_check(), process_query_result(), process_queued_fetch_requests(), process_rel_infos(), process_result(), process_secret_key(), process_user_defined_encoding_conversions(), process_user_defined_postfix_ops(), process_with_oids_check(), 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(), random_numeric(), read_pubenc_keyid(), read_pubkey_keyid(), readCommandResponse(), readDatum(), ReadEndOfStreamingResult(), ReadInt(), readTimeLineHistory(), reap_child(), ReceiveCopyData(), ReceiveXlogStream(), RelationFindReplTupleByIndex(), RelationFindReplTupleSeq(), ReleaseManyTestResource(), ReleaseString(), ReplicationSlotDropAtPubNode(), ReservePrivateRefCountEntry(), ResOwnerPrintBufferIO(), ResOwnerPrintBufferPin(), ResOwnerPrintCatCache(), ResOwnerPrintCatCacheList(), ResOwnerPrintDSM(), ResOwnerPrintFile(), ResOwnerPrintRelCache(), ResOwnerPrintTupleDesc(), ResOwnerReleaseBufferIO(), ResOwnerReleaseBufferPin(), ResOwnerReleaseCachedPlan(), ResOwnerReleaseCatCache(), ResOwnerReleaseCatCacheList(), ResOwnerReleaseCryptoHash(), ResOwnerReleaseDSM(), ResOwnerReleaseFile(), ResOwnerReleaseHMAC(), ResOwnerReleaseJitContext(), ResOwnerReleaseOSSLCipher(), ResOwnerReleaseOSSLDigest(), ResOwnerReleaseRelation(), ResOwnerReleaseSnapshot(), ResOwnerReleaseTupleDesc(), ResOwnerReleaseWaitEventSet(), RetrieveDataDirCreatePerm(), RetrieveWalSegSize(), run_crypt_des(), run_crypt_md5(), run_permutation(), run_simple_command(), run_simple_query(), RunIdentifySystem(), runShellCommand(), sampler_random_fract(), server_is_in_recovery(), set_arg(), set_replication_progress(), set_restrict_relation_kind(), setNewTmpRes(), setPath(), setup_publisher(), shm_mq_receive(), shm_mq_sendv(), should_processing_continue(), should_refetch_tuple(), 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(), synchronize_slots(), TableCommandResultHandler(), tarRead(), tarWrite(), test_disallowed_in_pipeline(), test_indoption(), test_multi_pipelines(), test_nosync(), test_pipeline_abort(), test_pipeline_idle(), 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(), 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(), vacuum_one_database(), vacuumlo(), validate_remote_info(), varstr_abbrev_convert(), verify_btree_slot_handler(), verify_heap_slot_handler(), wait_for_connection_state(), 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().