for循环,Postgresql如何触发更新值?
How does trigger update value in for loop, Postgresql?
我有 table 其中包含任务。
每个任务都有一个优先级。
当我插入一个新任务时,如果新任务与旧任务的优先级相同,则优先级较低的旧任务必须降级。
例如,我们有 3 个优先级为 1、2、3 的任务。如果我插入一个优先级为 1 的新任务,所有旧任务必须在插入新任务之前将优先级更改为 2、3、4。
为此,我使用触发器:
CREATE SEQUENCE task_id_seq;
CREATE TABLE task
(
task_id INTEGER NOT NULL DEFAULT nextval('task_id_seq'),
name VARCHAR(255) NOT NULL,
description TEXT,
created_time TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT CURRENT_TIMESTAMP,
deadline TIMESTAMP WITH TIME ZONE,
priority INT2 NOT NULL,
PRIMARY KEY (task_id),
CONSTRAINT task__check_task_name CHECK(CHAR_LENGTH(name) >= 4),
CONSTRAINT task__check_unique_task_name UNIQUE(name),
CONSTRAINT task__check_unique_task_priority UNIQUE(priority)
);
CREATE INDEX priority_index ON task(priority);
CREATE OR REPLACE FUNCTION degrade_task_priorities()
RETURNS trigger AS $degrade_priority_task_trigger$
DECLARE
r task%rowtype;
BEGIN
FOR r in SELECT * FROM task WHERE task.priority >= NEW.priority
LOOP
--r.priority := r.priority + 1;
UPDATE task SET priority = priority + 1;
--WHERE task.priority In (
-- SELECT priority FROM task WHERE task.priority >= NEW.priority ORDER BY task.priority);
--RETURN NEXT r;
END LOOP;
RETURN NEW;
END
$degrade_priority_task_trigger$ LANGUAGE plpgsql;
CREATE TRIGGER insert_new_task_trigger
BEFORE INSERT ON task
FOR EACH ROW
EXECUTE PROCEDURE degrade_task_priorities();
问题是当我尝试插入 4 个具有相同优先级 1 的新任务时,最终结果是 4 个优先级如下的记录:1、4、6、7。
我应该是 1,2,3,4。
我怀疑我不明白循环和触发器一起工作的方式。
我哪里做错了?
我相信你在这里不需要循环:
CREATE OR REPLACE FUNCTION degrade_task_priorities()
RETURNS trigger AS $degrade_priority_task_trigger$
DECLARE
r task%rowtype;
BEGIN
UPDATE task SET priority = priority + 1 WHERE task.priority >= NEW.PRIORITY;
RETURN NEW;
END
$degrade_priority_task_trigger$ LANGUAGE plpgsql;
我有 table 其中包含任务。 每个任务都有一个优先级。 当我插入一个新任务时,如果新任务与旧任务的优先级相同,则优先级较低的旧任务必须降级。
例如,我们有 3 个优先级为 1、2、3 的任务。如果我插入一个优先级为 1 的新任务,所有旧任务必须在插入新任务之前将优先级更改为 2、3、4。
为此,我使用触发器:
CREATE SEQUENCE task_id_seq;
CREATE TABLE task
(
task_id INTEGER NOT NULL DEFAULT nextval('task_id_seq'),
name VARCHAR(255) NOT NULL,
description TEXT,
created_time TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT CURRENT_TIMESTAMP,
deadline TIMESTAMP WITH TIME ZONE,
priority INT2 NOT NULL,
PRIMARY KEY (task_id),
CONSTRAINT task__check_task_name CHECK(CHAR_LENGTH(name) >= 4),
CONSTRAINT task__check_unique_task_name UNIQUE(name),
CONSTRAINT task__check_unique_task_priority UNIQUE(priority)
);
CREATE INDEX priority_index ON task(priority);
CREATE OR REPLACE FUNCTION degrade_task_priorities()
RETURNS trigger AS $degrade_priority_task_trigger$
DECLARE
r task%rowtype;
BEGIN
FOR r in SELECT * FROM task WHERE task.priority >= NEW.priority
LOOP
--r.priority := r.priority + 1;
UPDATE task SET priority = priority + 1;
--WHERE task.priority In (
-- SELECT priority FROM task WHERE task.priority >= NEW.priority ORDER BY task.priority);
--RETURN NEXT r;
END LOOP;
RETURN NEW;
END
$degrade_priority_task_trigger$ LANGUAGE plpgsql;
CREATE TRIGGER insert_new_task_trigger
BEFORE INSERT ON task
FOR EACH ROW
EXECUTE PROCEDURE degrade_task_priorities();
问题是当我尝试插入 4 个具有相同优先级 1 的新任务时,最终结果是 4 个优先级如下的记录:1、4、6、7。 我应该是 1,2,3,4。
我怀疑我不明白循环和触发器一起工作的方式。 我哪里做错了?
我相信你在这里不需要循环:
CREATE OR REPLACE FUNCTION degrade_task_priorities()
RETURNS trigger AS $degrade_priority_task_trigger$
DECLARE
r task%rowtype;
BEGIN
UPDATE task SET priority = priority + 1 WHERE task.priority >= NEW.PRIORITY;
RETURN NEW;
END
$degrade_priority_task_trigger$ LANGUAGE plpgsql;