openGauss数据库管理系统 v2.0.5.zip

/* ------------------------------------------------------------------------- * * tablecmds.cpp * Commands for creating and altering table structures and settings * * Portions Copyright (c) 2020 Huawei Technologies Co.,Ltd. * Portions Copyright (c) 1996-2012, PostgreSQL Global Development Group * Portions Copyright (c) 1994, Regents of the University of California * Portions Copyright (c) 2010-2012 Postgres-XC Development Group * * * IDENTIFICATION * src/gausskernel/optimizer/commands/tablecmds.cpp * * ------------------------------------------------------------------------- */ #include "postgres.h" #include "knl/knl_variable.h" #include "access/cstore_delete.h" #include "access/cstore_insert.h" #include "access/cstore_rewrite.h" #include "access/dfs/dfs_am.h" #include "access/genam.h" #include "access/heapam.h" #include "access/reloptions.h" #include "access/relscan.h" #include "access/sysattr.h" #include "access/transam.h" #include "access/tuptoaster.h" #include "access/visibilitymap.h" #include "access/xact.h" #include "access/xlog.h" #include "access/tableam.h" #include "catalog/catalog.h" #include "catalog/dependency.h" #include "catalog/dfsstore_ctlg.h" #include "catalog/heap.h" #include "catalog/index.h" #include "catalog/indexing.h" #include "catalog/namespace.h" #include "catalog/objectaccess.h" #include "catalog/pg_attrdef.h" #include "catalog/pg_collation.h" #include "catalog/pg_constraint.h" #include "catalog/pg_depend.h" #include "catalog/pg_foreign_table.h" #include "catalog/pg_inherits.h" #include "catalog/pg_inherits_fn.h" #include "catalog/pg_job.h" #include "catalog/pg_job_proc.h" #include "catalog/pg_namespace.h" #include "catalog/pg_object.h" #include "catalog/pg_opclass.h" #include "catalog/pg_partition.h" #include "catalog/pg_partition_fn.h" #include "catalog/pg_hashbucket.h" #include "catalog/pg_hashbucket_fn.h" #include "catalog/pg_tablespace.h" #include "catalog/pg_trigger.h" #include "catalog/pg_type.h" #include "catalog/pg_type_fn.h" #include "catalog/storage.h" #include "catalog/storage_xlog.h" #include "catalog/toasting.h" #include "catalog/cstore_ctlg.h" #include "catalog/storage_gtt.h" #include "catalog/gs_encrypted_columns.h" #include "catalog/gs_global_config.h" #include "catalog/gs_matview.h" #include "commands/cluster.h" #include "commands/comment.h" #include "commands/defrem.h" #include "commands/dbcommands.h" #include "commands/sequence.h" #include "commands/tablecmds.h" #include "commands/tablespace.h" #include "commands/trigger.h" #include "commands/typecmds.h" #include "commands/vacuum.h" #include "commands/matview.h" #include "executor/executor.h" #include "executor/nodeModifyTable.h" #include "foreign/fdwapi.h" #include "foreign/foreign.h" #include "gssignal/gs_signal.h" #include "gtm/gtm_client.h" #include "miscadmin.h" #include "nodes/makefuncs.h" #include "nodes/nodeFuncs.h" #include "nodes/parsenodes.h" #include "optimizer/clauses.h" #include "optimizer/planner.h" #include "optimizer/var.h" #include "parser/parse_clause.h" #include "parser/parse_coerce.h" #include "parser/parse_collate.h" #include "parser/parse_expr.h" #include "parser/parse_oper.h" #include "parser/parse_relation.h" #include "parser/parse_type.h" #include "parser/parse_utilcmd.h" #include "parser/parser.h" #include "pgxc/route.h" #include "rewrite/rewriteDefine.h" #include "rewrite/rewriteHandler.h" #include "rewrite/rewriteManip.h" #include "rewrite/rewriteRlsPolicy.h" #include "replication/slot.h" #include "storage/buf/bufmgr.h" #include "storage/freespace.h" #include "storage/lmgr.h" #include "storage/lock/lock.h" #include "storage/predicate.h" #include "storage/remote_read.h" #include "storage/smgr.h" #include "streaming/streaming_catalog.h" #include "tcop/utility.h" #include "utils/acl.h" #include "utils/aiomem.h" #include "utils/builtins.h" #include "utils/extended_statistics.h" #include "utils/fmgroids.h" #include "utils/int8.h" #include "utils/inval.h" #include "utils/guc.h" #include "utils/lsyscache.h" #include "utils/memutils.h" #include "utils/partcache.h" #include "utils/partitionmap.h" #include "utils/partitionmap_gs.h" #include "utils/partitionkey.h" #include "utils/relcache.h" #include "utils/sec_rls_utils.h" #include "utils/snapmgr.h" #include "utils/syscache.h" #include "access/heapam.h" #include "utils/typcache.h" #include "utils/numeric.h" #include "utils/timestamp.h" #include "catalog/pg_database.h" #include "catalog/pg_authid.h" #include "catalog/pg_auth_members.h" #include "catalog/pg_proc.h" #include "catalog/pg_job.h" #include "catalog/pg_user_status.h" #include "gaussdb_version.h" #include "workload/workload.h" #include "utils/builtins.h" #include "fmgr.h" #include "pgstat.h" #ifdef ENABLE_MULTIPLE_NODES #include "tsdb/utils/ts_relcache.h" #include "tsdb/common/ts_tablecmds.h" #include "tsdb/common/delta_ctlg.h" #include "tsdb/utils/ctlg_utils.h" #include "tsdb/utils/delta_utils.h" #include "tsdb/utils/ctlg_utils.h" #include "tsdb/storage/delta_merge.h" #include "tsdb/optimizer/policy.h" #endif /* ENABLE_MULTIPLE_NODES */ #ifdef PGXC #include "pgxc/pgxc.h" #include "access/gtm.h" #include "catalog/pgxc_class.h" #include "catalog/pgxc_node.h" #include "commands/sequence.h" #include "optimizer/pgxcship.h" #include "pgxc/execRemote.h" #include "pgxc/redistrib.h" #include "pgxc/groupmgr.h" #endif #include "dfs_adaptor.h" #include "c.h" #include "instruments/generate_report.h" #include "client_logic/client_logic.h" #include "client_logic/cache.h" extern void vacuum_set_xid_limits(Relation rel, int64 freeze_min_age, int64 freeze_table_age, TransactionId* oldestXmin, TransactionId* freezeLimit, TransactionId* freezeTableLimit); /* * ON COMMIT action list */ typedef struct OnCommitItem { Oid relid; /* relid of relation */ OnCommitAction oncommit; /* what to do at end of xact */ /* * If this entry was created during the current transaction, * creating_subid is the ID of the creating subxact; if created in a prior * transaction, creating_subid is zero. If deleted during the current * transaction, deleting_subid is the ID of the deleting subxact; if no * deletion request is pending, deleting_subid is zero. */ SubTransactionId creating_subid; SubTransactionId deleting_subid; } OnCommitItem; static const char* ORCSupportOption[] = {"orientation", "compression", "version", "partial_cluster_rows"}; /* * State information for ALTER TABLE * * The pending-work queue for an ALTER TABLE is a List of AlteredTableInfo * structs, one for each table modified by the operation (the named table * plus any child tables that are affected). We save lists of subcommands * to apply to this table (possibly modified by parse transformation steps); * these lists will be executed in Phase 2. If a Phase 3 step is needed, * necessary information is stored in the constraints and newvals lists. * * Phase 2 is divided into multiple passes; subcommands are executed in * a pass determined by subcommand type. */ #define AT_PASS_DROP 0 /* DROP (all flavors) */ #define AT_PASS_ALTER_TYPE 1 /* ALTER COLUMN TYPE */ #define AT_PASS_OLD_INDEX 2 /* re-add existing indexes */ #define AT_PASS_OLD_CONSTR 3 /* re-add existing constraints */ #define AT_PASS_COL_ATTRS 4 /* set other column attributes */ /* We could support a RENAME COLUMN pass here, but not currently used */ #define AT_PASS_ADD_COL 5 /* ADD COLUMN */ #define AT_PASS_ADD_INDEX 6 /* ADD indexes */ #define AT_PASS_ADD_CONSTR 7 /* ADD constraints, defaults */ #define AT_PASS_ADD_PARTITION 8 #define AT_PASS_MISC 9 /* other stuff */ #ifdef PGXC #define AT_PASS_DISTRIB 10 /* Redistribution pass */ #define AT_NUM_PASSES 11 #else #define AT_NUM_PASSES 10 #endif typedef struct AlteredTableInfo { /* Information saved before any work commences: */ Oid relid; /* Relation to work on */ Oid partid; /* Partition to work on */ char relkind; /* Its relkind *