mirror of
https://github.com/postgres/postgres.git
synced 2025-07-22 00:01:40 -04:00
Compare commits
3 Commits
03e749c2b8
...
5a4c21e952
Author | SHA1 | Date | |
---|---|---|---|
|
5a4c21e952 | ||
|
8f4a6b9e4f | ||
|
df73ca3514 |
@ -319,9 +319,13 @@ aminsert (Relation indexRelation,
|
|||||||
modify any columns covered by the index, but nevertheless requires a
|
modify any columns covered by the index, but nevertheless requires a
|
||||||
new version in the index. The index AM may use this hint to decide
|
new version in the index. The index AM may use this hint to decide
|
||||||
to apply bottom-up index deletion in parts of the index where many
|
to apply bottom-up index deletion in parts of the index where many
|
||||||
versions of the same logical row accumulate. Note that updating a
|
versions of the same logical row accumulate. Note that updating a non-key
|
||||||
non-key column does not affect the value of
|
column or a column that only appears in a partial index predicate does not
|
||||||
<literal>indexUnchanged</literal>.
|
affect the value of <literal>indexUnchanged</literal>. The core code
|
||||||
|
determines each tuple's <literal>indexUnchanged</literal> value using a low
|
||||||
|
overhead approach that allows both false positives and false negatives.
|
||||||
|
Index AMs must not treat <literal>indexUnchanged</literal> as an
|
||||||
|
authoritative source of information about tuple visibility or versioning.
|
||||||
</para>
|
</para>
|
||||||
|
|
||||||
<para>
|
<para>
|
||||||
|
@ -376,7 +376,7 @@ WITH ( MODULUS <replaceable class="parameter">numeric_literal</replaceable>, REM
|
|||||||
an <command>UPDATE</command> that changes the partition key value can
|
an <command>UPDATE</command> that changes the partition key value can
|
||||||
cause a row to be moved from a local partition to a foreign-table
|
cause a row to be moved from a local partition to a foreign-table
|
||||||
partition, provided the foreign data wrapper supports tuple routing.
|
partition, provided the foreign data wrapper supports tuple routing.
|
||||||
However it is not currently possible to move a row from a
|
However, it is not currently possible to move a row from a
|
||||||
foreign-table partition to another partition.
|
foreign-table partition to another partition.
|
||||||
An <command>UPDATE</command> that would require doing that will fail
|
An <command>UPDATE</command> that would require doing that will fail
|
||||||
due to the partitioning constraint, assuming that that is properly
|
due to the partitioning constraint, assuming that that is properly
|
||||||
|
@ -2860,10 +2860,10 @@ ExecInitModifyTable(ModifyTable *node, EState *estate, int eflags)
|
|||||||
* must be converted, and
|
* must be converted, and
|
||||||
* - the root partitioned table used for tuple routing.
|
* - the root partitioned table used for tuple routing.
|
||||||
*
|
*
|
||||||
* If it's a partitioned table, the root partition doesn't appear
|
* If it's a partitioned or inherited table, the root partition or
|
||||||
* elsewhere in the plan and its RT index is given explicitly in
|
* appendrel RTE doesn't appear elsewhere in the plan and its RT index is
|
||||||
* node->rootRelation. Otherwise (i.e. table inheritance) the target
|
* given explicitly in node->rootRelation. Otherwise, the target relation
|
||||||
* relation is the first relation in the node->resultRelations list.
|
* is the sole relation in the node->resultRelations list.
|
||||||
*----------
|
*----------
|
||||||
*/
|
*/
|
||||||
if (node->rootRelation > 0)
|
if (node->rootRelation > 0)
|
||||||
@ -2874,6 +2874,7 @@ ExecInitModifyTable(ModifyTable *node, EState *estate, int eflags)
|
|||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
|
Assert(list_length(node->resultRelations) == 1);
|
||||||
mtstate->rootResultRelInfo = mtstate->resultRelInfo;
|
mtstate->rootResultRelInfo = mtstate->resultRelInfo;
|
||||||
ExecInitResultRelation(estate, mtstate->resultRelInfo,
|
ExecInitResultRelation(estate, mtstate->resultRelInfo,
|
||||||
linitial_int(node->resultRelations));
|
linitial_int(node->resultRelations));
|
||||||
|
@ -1725,6 +1725,9 @@ grouping_planner(PlannerInfo *root, double tuple_fraction)
|
|||||||
parse->resultRelation);
|
parse->resultRelation);
|
||||||
int resultRelation = -1;
|
int resultRelation = -1;
|
||||||
|
|
||||||
|
/* Pass the root result rel forward to the executor. */
|
||||||
|
rootRelation = parse->resultRelation;
|
||||||
|
|
||||||
/* Add only leaf children to ModifyTable. */
|
/* Add only leaf children to ModifyTable. */
|
||||||
while ((resultRelation = bms_next_member(root->leaf_result_relids,
|
while ((resultRelation = bms_next_member(root->leaf_result_relids,
|
||||||
resultRelation)) >= 0)
|
resultRelation)) >= 0)
|
||||||
@ -1809,6 +1812,7 @@ grouping_planner(PlannerInfo *root, double tuple_fraction)
|
|||||||
else
|
else
|
||||||
{
|
{
|
||||||
/* Single-relation INSERT/UPDATE/DELETE. */
|
/* Single-relation INSERT/UPDATE/DELETE. */
|
||||||
|
rootRelation = 0; /* there's no separate root rel */
|
||||||
resultRelations = list_make1_int(parse->resultRelation);
|
resultRelations = list_make1_int(parse->resultRelation);
|
||||||
if (parse->commandType == CMD_UPDATE)
|
if (parse->commandType == CMD_UPDATE)
|
||||||
updateColnosLists = list_make1(root->update_colnos);
|
updateColnosLists = list_make1(root->update_colnos);
|
||||||
@ -1818,16 +1822,6 @@ grouping_planner(PlannerInfo *root, double tuple_fraction)
|
|||||||
returningLists = list_make1(parse->returningList);
|
returningLists = list_make1(parse->returningList);
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
|
||||||
* If target is a partition root table, we need to mark the
|
|
||||||
* ModifyTable node appropriately for that.
|
|
||||||
*/
|
|
||||||
if (rt_fetch(parse->resultRelation, parse->rtable)->relkind ==
|
|
||||||
RELKIND_PARTITIONED_TABLE)
|
|
||||||
rootRelation = parse->resultRelation;
|
|
||||||
else
|
|
||||||
rootRelation = 0;
|
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* If there was a FOR [KEY] UPDATE/SHARE clause, the LockRows node
|
* If there was a FOR [KEY] UPDATE/SHARE clause, the LockRows node
|
||||||
* will have dealt with fetching non-locked marked rows, else we
|
* will have dealt with fetching non-locked marked rows, else we
|
||||||
|
@ -3609,7 +3609,7 @@ create_lockrows_path(PlannerInfo *root, RelOptInfo *rel,
|
|||||||
* 'operation' is the operation type
|
* 'operation' is the operation type
|
||||||
* 'canSetTag' is true if we set the command tag/es_processed
|
* 'canSetTag' is true if we set the command tag/es_processed
|
||||||
* 'nominalRelation' is the parent RT index for use of EXPLAIN
|
* 'nominalRelation' is the parent RT index for use of EXPLAIN
|
||||||
* 'rootRelation' is the partitioned table root RT index, or 0 if none
|
* 'rootRelation' is the partitioned/inherited table root RTI, or 0 if none
|
||||||
* 'partColsUpdated' is true if any partitioning columns are being updated,
|
* 'partColsUpdated' is true if any partitioning columns are being updated,
|
||||||
* either from the target relation or a descendent partitioned table.
|
* either from the target relation or a descendent partitioned table.
|
||||||
* 'resultRelations' is an integer list of actual RT indexes of target rel(s)
|
* 'resultRelations' is an integer list of actual RT indexes of target rel(s)
|
||||||
|
@ -1884,7 +1884,7 @@ typedef struct ModifyTablePath
|
|||||||
CmdType operation; /* INSERT, UPDATE, or DELETE */
|
CmdType operation; /* INSERT, UPDATE, or DELETE */
|
||||||
bool canSetTag; /* do we set the command tag/es_processed? */
|
bool canSetTag; /* do we set the command tag/es_processed? */
|
||||||
Index nominalRelation; /* Parent RT index for use of EXPLAIN */
|
Index nominalRelation; /* Parent RT index for use of EXPLAIN */
|
||||||
Index rootRelation; /* Root RT index, if target is partitioned */
|
Index rootRelation; /* Root RT index, if partitioned/inherited */
|
||||||
bool partColsUpdated; /* some part key in hierarchy updated? */
|
bool partColsUpdated; /* some part key in hierarchy updated? */
|
||||||
List *resultRelations; /* integer list of RT indexes */
|
List *resultRelations; /* integer list of RT indexes */
|
||||||
List *updateColnosLists; /* per-target-table update_colnos lists */
|
List *updateColnosLists; /* per-target-table update_colnos lists */
|
||||||
|
@ -204,11 +204,12 @@ typedef struct ProjectSet
|
|||||||
* Apply rows produced by outer plan to result table(s),
|
* Apply rows produced by outer plan to result table(s),
|
||||||
* by inserting, updating, or deleting.
|
* by inserting, updating, or deleting.
|
||||||
*
|
*
|
||||||
* If the originally named target table is a partitioned table, both
|
* If the originally named target table is a partitioned table or inheritance
|
||||||
* nominalRelation and rootRelation contain the RT index of the partition
|
* tree, both nominalRelation and rootRelation contain the RT index of the
|
||||||
* root, which is not otherwise mentioned in the plan. Otherwise rootRelation
|
* partition root or appendrel RTE, which is not otherwise mentioned in the
|
||||||
* is zero. However, nominalRelation will always be set, as it's the rel that
|
* plan. Otherwise rootRelation is zero. However, nominalRelation will
|
||||||
* EXPLAIN should claim is the INSERT/UPDATE/DELETE target.
|
* always be set, as it's the rel that EXPLAIN should claim is the
|
||||||
|
* INSERT/UPDATE/DELETE target.
|
||||||
*
|
*
|
||||||
* Note that rowMarks and epqParam are presumed to be valid for all the
|
* Note that rowMarks and epqParam are presumed to be valid for all the
|
||||||
* table(s); they can't contain any info that varies across tables.
|
* table(s); they can't contain any info that varies across tables.
|
||||||
@ -220,7 +221,7 @@ typedef struct ModifyTable
|
|||||||
CmdType operation; /* INSERT, UPDATE, or DELETE */
|
CmdType operation; /* INSERT, UPDATE, or DELETE */
|
||||||
bool canSetTag; /* do we set the command tag/es_processed? */
|
bool canSetTag; /* do we set the command tag/es_processed? */
|
||||||
Index nominalRelation; /* Parent RT index for use of EXPLAIN */
|
Index nominalRelation; /* Parent RT index for use of EXPLAIN */
|
||||||
Index rootRelation; /* Root RT index, if target is partitioned */
|
Index rootRelation; /* Root RT index, if partitioned/inherited */
|
||||||
bool partColsUpdated; /* some part key in hierarchy updated? */
|
bool partColsUpdated; /* some part key in hierarchy updated? */
|
||||||
List *resultRelations; /* integer list of RT indexes */
|
List *resultRelations; /* integer list of RT indexes */
|
||||||
List *updateColnosLists; /* per-target-table update_colnos lists */
|
List *updateColnosLists; /* per-target-table update_colnos lists */
|
||||||
|
@ -539,6 +539,33 @@ CREATE TEMP TABLE z (b TEXT, PRIMARY KEY(aa, b)) inherits (a);
|
|||||||
INSERT INTO z VALUES (NULL, 'text'); -- should fail
|
INSERT INTO z VALUES (NULL, 'text'); -- should fail
|
||||||
ERROR: null value in column "aa" of relation "z" violates not-null constraint
|
ERROR: null value in column "aa" of relation "z" violates not-null constraint
|
||||||
DETAIL: Failing row contains (null, text).
|
DETAIL: Failing row contains (null, text).
|
||||||
|
-- Check inherited UPDATE with first child excluded
|
||||||
|
create table some_tab (f1 int, f2 int, f3 int, check (f1 < 10) no inherit);
|
||||||
|
create table some_tab_child () inherits(some_tab);
|
||||||
|
insert into some_tab_child select i, i+1, 0 from generate_series(1,1000) i;
|
||||||
|
create index on some_tab_child(f1, f2);
|
||||||
|
-- while at it, also check that statement-level triggers fire
|
||||||
|
create function some_tab_stmt_trig_func() returns trigger as
|
||||||
|
$$begin raise notice 'updating some_tab'; return NULL; end;$$
|
||||||
|
language plpgsql;
|
||||||
|
create trigger some_tab_stmt_trig
|
||||||
|
before update on some_tab execute function some_tab_stmt_trig_func();
|
||||||
|
explain (costs off)
|
||||||
|
update some_tab set f3 = 11 where f1 = 12 and f2 = 13;
|
||||||
|
QUERY PLAN
|
||||||
|
------------------------------------------------------------------------------------
|
||||||
|
Update on some_tab
|
||||||
|
Update on some_tab_child some_tab_1
|
||||||
|
-> Result
|
||||||
|
-> Index Scan using some_tab_child_f1_f2_idx on some_tab_child some_tab_1
|
||||||
|
Index Cond: ((f1 = 12) AND (f2 = 13))
|
||||||
|
(5 rows)
|
||||||
|
|
||||||
|
update some_tab set f3 = 11 where f1 = 12 and f2 = 13;
|
||||||
|
NOTICE: updating some_tab
|
||||||
|
drop table some_tab cascade;
|
||||||
|
NOTICE: drop cascades to table some_tab_child
|
||||||
|
drop function some_tab_stmt_trig_func();
|
||||||
-- Check inherited UPDATE with all children excluded
|
-- Check inherited UPDATE with all children excluded
|
||||||
create table some_tab (a int, b int);
|
create table some_tab (a int, b int);
|
||||||
create table some_tab_child () inherits (some_tab);
|
create table some_tab_child () inherits (some_tab);
|
||||||
|
@ -97,6 +97,25 @@ SELECT relname, d.* FROM ONLY d, pg_class where d.tableoid = pg_class.oid;
|
|||||||
CREATE TEMP TABLE z (b TEXT, PRIMARY KEY(aa, b)) inherits (a);
|
CREATE TEMP TABLE z (b TEXT, PRIMARY KEY(aa, b)) inherits (a);
|
||||||
INSERT INTO z VALUES (NULL, 'text'); -- should fail
|
INSERT INTO z VALUES (NULL, 'text'); -- should fail
|
||||||
|
|
||||||
|
-- Check inherited UPDATE with first child excluded
|
||||||
|
create table some_tab (f1 int, f2 int, f3 int, check (f1 < 10) no inherit);
|
||||||
|
create table some_tab_child () inherits(some_tab);
|
||||||
|
insert into some_tab_child select i, i+1, 0 from generate_series(1,1000) i;
|
||||||
|
create index on some_tab_child(f1, f2);
|
||||||
|
-- while at it, also check that statement-level triggers fire
|
||||||
|
create function some_tab_stmt_trig_func() returns trigger as
|
||||||
|
$$begin raise notice 'updating some_tab'; return NULL; end;$$
|
||||||
|
language plpgsql;
|
||||||
|
create trigger some_tab_stmt_trig
|
||||||
|
before update on some_tab execute function some_tab_stmt_trig_func();
|
||||||
|
|
||||||
|
explain (costs off)
|
||||||
|
update some_tab set f3 = 11 where f1 = 12 and f2 = 13;
|
||||||
|
update some_tab set f3 = 11 where f1 = 12 and f2 = 13;
|
||||||
|
|
||||||
|
drop table some_tab cascade;
|
||||||
|
drop function some_tab_stmt_trig_func();
|
||||||
|
|
||||||
-- Check inherited UPDATE with all children excluded
|
-- Check inherited UPDATE with all children excluded
|
||||||
create table some_tab (a int, b int);
|
create table some_tab (a int, b int);
|
||||||
create table some_tab_child () inherits (some_tab);
|
create table some_tab_child () inherits (some_tab);
|
||||||
|
Loading…
x
Reference in New Issue
Block a user