mirror of
https://git.postgresql.org/git/postgresql.git
synced 2026-02-11 02:37:40 +08:00
344d62fb9a
Add support for unlogged sequences. Unlike for unlogged tables, this is not a performance feature. It allows sequences associated with unlogged tables to be excluded from replication. A new subcommand ALTER SEQUENCE ... SET LOGGED/UNLOGGED is added. An identity/serial sequence now automatically gets and follows the persistence level (logged/unlogged) of its owning table. (The sequences owned by temporary tables were already temporary through the separate mechanism in RangeVarAdjustRelationPersistence().) But you can still change the persistence of an owned sequence separately. Also, pg_dump and pg_upgrade preserve the persistence of existing sequences. Discussion: https://www.postgresql.org/message-id/flat/04e12818-2f98-257c-b926-2845d74ed04f%402ndquadrant.com
417 lines
12 KiB
PL/PgSQL
417 lines
12 KiB
PL/PgSQL
--
|
|
-- CREATE SEQUENCE
|
|
--
|
|
|
|
-- various error cases
|
|
CREATE SEQUENCE sequence_testx INCREMENT BY 0;
|
|
CREATE SEQUENCE sequence_testx INCREMENT BY -1 MINVALUE 20;
|
|
CREATE SEQUENCE sequence_testx INCREMENT BY 1 MAXVALUE -20;
|
|
CREATE SEQUENCE sequence_testx INCREMENT BY -1 START 10;
|
|
CREATE SEQUENCE sequence_testx INCREMENT BY 1 START -10;
|
|
CREATE SEQUENCE sequence_testx CACHE 0;
|
|
|
|
-- OWNED BY errors
|
|
CREATE SEQUENCE sequence_testx OWNED BY nobody; -- nonsense word
|
|
CREATE SEQUENCE sequence_testx OWNED BY pg_class_oid_index.oid; -- not a table
|
|
CREATE SEQUENCE sequence_testx OWNED BY pg_class.relname; -- not same schema
|
|
CREATE TABLE sequence_test_table (a int);
|
|
CREATE SEQUENCE sequence_testx OWNED BY sequence_test_table.b; -- wrong column
|
|
DROP TABLE sequence_test_table;
|
|
|
|
-- sequence data types
|
|
CREATE SEQUENCE sequence_test5 AS integer;
|
|
CREATE SEQUENCE sequence_test6 AS smallint;
|
|
CREATE SEQUENCE sequence_test7 AS bigint;
|
|
CREATE SEQUENCE sequence_test8 AS integer MAXVALUE 100000;
|
|
CREATE SEQUENCE sequence_test9 AS integer INCREMENT BY -1;
|
|
CREATE SEQUENCE sequence_test10 AS integer MINVALUE -100000 START 1;
|
|
CREATE SEQUENCE sequence_test11 AS smallint;
|
|
CREATE SEQUENCE sequence_test12 AS smallint INCREMENT -1;
|
|
CREATE SEQUENCE sequence_test13 AS smallint MINVALUE -32768;
|
|
CREATE SEQUENCE sequence_test14 AS smallint MAXVALUE 32767 INCREMENT -1;
|
|
CREATE SEQUENCE sequence_testx AS text;
|
|
CREATE SEQUENCE sequence_testx AS nosuchtype;
|
|
|
|
CREATE SEQUENCE sequence_testx AS smallint MAXVALUE 100000;
|
|
CREATE SEQUENCE sequence_testx AS smallint MINVALUE -100000;
|
|
|
|
ALTER SEQUENCE sequence_test5 AS smallint; -- success, max will be adjusted
|
|
ALTER SEQUENCE sequence_test8 AS smallint; -- fail, max has to be adjusted
|
|
ALTER SEQUENCE sequence_test8 AS smallint MAXVALUE 20000; -- ok now
|
|
ALTER SEQUENCE sequence_test9 AS smallint; -- success, min will be adjusted
|
|
ALTER SEQUENCE sequence_test10 AS smallint; -- fail, min has to be adjusted
|
|
ALTER SEQUENCE sequence_test10 AS smallint MINVALUE -20000; -- ok now
|
|
|
|
ALTER SEQUENCE sequence_test11 AS int; -- max will be adjusted
|
|
ALTER SEQUENCE sequence_test12 AS int; -- min will be adjusted
|
|
ALTER SEQUENCE sequence_test13 AS int; -- min and max will be adjusted
|
|
ALTER SEQUENCE sequence_test14 AS int; -- min and max will be adjusted
|
|
|
|
---
|
|
--- test creation of SERIAL column
|
|
---
|
|
|
|
CREATE TABLE serialTest1 (f1 text, f2 serial);
|
|
|
|
INSERT INTO serialTest1 VALUES ('foo');
|
|
INSERT INTO serialTest1 VALUES ('bar');
|
|
INSERT INTO serialTest1 VALUES ('force', 100);
|
|
INSERT INTO serialTest1 VALUES ('wrong', NULL);
|
|
|
|
SELECT * FROM serialTest1;
|
|
|
|
SELECT pg_get_serial_sequence('serialTest1', 'f2');
|
|
|
|
-- test smallserial / bigserial
|
|
CREATE TABLE serialTest2 (f1 text, f2 serial, f3 smallserial, f4 serial2,
|
|
f5 bigserial, f6 serial8);
|
|
|
|
INSERT INTO serialTest2 (f1)
|
|
VALUES ('test_defaults');
|
|
|
|
INSERT INTO serialTest2 (f1, f2, f3, f4, f5, f6)
|
|
VALUES ('test_max_vals', 2147483647, 32767, 32767, 9223372036854775807,
|
|
9223372036854775807),
|
|
('test_min_vals', -2147483648, -32768, -32768, -9223372036854775808,
|
|
-9223372036854775808);
|
|
|
|
-- All these INSERTs should fail:
|
|
INSERT INTO serialTest2 (f1, f3)
|
|
VALUES ('bogus', -32769);
|
|
|
|
INSERT INTO serialTest2 (f1, f4)
|
|
VALUES ('bogus', -32769);
|
|
|
|
INSERT INTO serialTest2 (f1, f3)
|
|
VALUES ('bogus', 32768);
|
|
|
|
INSERT INTO serialTest2 (f1, f4)
|
|
VALUES ('bogus', 32768);
|
|
|
|
INSERT INTO serialTest2 (f1, f5)
|
|
VALUES ('bogus', -9223372036854775809);
|
|
|
|
INSERT INTO serialTest2 (f1, f6)
|
|
VALUES ('bogus', -9223372036854775809);
|
|
|
|
INSERT INTO serialTest2 (f1, f5)
|
|
VALUES ('bogus', 9223372036854775808);
|
|
|
|
INSERT INTO serialTest2 (f1, f6)
|
|
VALUES ('bogus', 9223372036854775808);
|
|
|
|
SELECT * FROM serialTest2 ORDER BY f2 ASC;
|
|
|
|
SELECT nextval('serialTest2_f2_seq');
|
|
SELECT nextval('serialTest2_f3_seq');
|
|
SELECT nextval('serialTest2_f4_seq');
|
|
SELECT nextval('serialTest2_f5_seq');
|
|
SELECT nextval('serialTest2_f6_seq');
|
|
|
|
-- basic sequence operations using both text and oid references
|
|
CREATE SEQUENCE sequence_test;
|
|
CREATE SEQUENCE IF NOT EXISTS sequence_test;
|
|
|
|
SELECT nextval('sequence_test'::text);
|
|
SELECT nextval('sequence_test'::regclass);
|
|
SELECT currval('sequence_test'::text);
|
|
SELECT currval('sequence_test'::regclass);
|
|
SELECT setval('sequence_test'::text, 32);
|
|
SELECT nextval('sequence_test'::regclass);
|
|
SELECT setval('sequence_test'::text, 99, false);
|
|
SELECT nextval('sequence_test'::regclass);
|
|
SELECT setval('sequence_test'::regclass, 32);
|
|
SELECT nextval('sequence_test'::text);
|
|
SELECT setval('sequence_test'::regclass, 99, false);
|
|
SELECT nextval('sequence_test'::text);
|
|
DISCARD SEQUENCES;
|
|
SELECT currval('sequence_test'::regclass);
|
|
|
|
DROP SEQUENCE sequence_test;
|
|
|
|
-- renaming sequences
|
|
CREATE SEQUENCE foo_seq;
|
|
ALTER TABLE foo_seq RENAME TO foo_seq_new;
|
|
SELECT * FROM foo_seq_new;
|
|
SELECT nextval('foo_seq_new');
|
|
SELECT nextval('foo_seq_new');
|
|
-- log_cnt can be higher if there is a checkpoint just at the right
|
|
-- time, so just test for the expected range
|
|
SELECT last_value, log_cnt IN (31, 32) AS log_cnt_ok, is_called FROM foo_seq_new;
|
|
DROP SEQUENCE foo_seq_new;
|
|
|
|
-- renaming serial sequences
|
|
ALTER TABLE serialtest1_f2_seq RENAME TO serialtest1_f2_foo;
|
|
INSERT INTO serialTest1 VALUES ('more');
|
|
SELECT * FROM serialTest1;
|
|
|
|
--
|
|
-- Check dependencies of serial and ordinary sequences
|
|
--
|
|
CREATE TEMP SEQUENCE myseq2;
|
|
CREATE TEMP SEQUENCE myseq3;
|
|
CREATE TEMP TABLE t1 (
|
|
f1 serial,
|
|
f2 int DEFAULT nextval('myseq2'),
|
|
f3 int DEFAULT nextval('myseq3'::text)
|
|
);
|
|
-- Both drops should fail, but with different error messages:
|
|
DROP SEQUENCE t1_f1_seq;
|
|
DROP SEQUENCE myseq2;
|
|
-- This however will work:
|
|
DROP SEQUENCE myseq3;
|
|
DROP TABLE t1;
|
|
-- Fails because no longer existent:
|
|
DROP SEQUENCE t1_f1_seq;
|
|
-- Now OK:
|
|
DROP SEQUENCE myseq2;
|
|
|
|
--
|
|
-- Alter sequence
|
|
--
|
|
|
|
ALTER SEQUENCE IF EXISTS sequence_test2 RESTART WITH 24
|
|
INCREMENT BY 4 MAXVALUE 36 MINVALUE 5 CYCLE;
|
|
|
|
ALTER SEQUENCE serialTest1 CYCLE; -- error, not a sequence
|
|
|
|
CREATE SEQUENCE sequence_test2 START WITH 32;
|
|
CREATE SEQUENCE sequence_test4 INCREMENT BY -1;
|
|
|
|
SELECT nextval('sequence_test2');
|
|
SELECT nextval('sequence_test4');
|
|
|
|
ALTER SEQUENCE sequence_test2 RESTART;
|
|
SELECT nextval('sequence_test2');
|
|
|
|
ALTER SEQUENCE sequence_test2 RESTART WITH 0; -- error
|
|
ALTER SEQUENCE sequence_test4 RESTART WITH 40; -- error
|
|
|
|
-- test CYCLE and NO CYCLE
|
|
ALTER SEQUENCE sequence_test2 RESTART WITH 24
|
|
INCREMENT BY 4 MAXVALUE 36 MINVALUE 5 CYCLE;
|
|
SELECT nextval('sequence_test2');
|
|
SELECT nextval('sequence_test2');
|
|
SELECT nextval('sequence_test2');
|
|
SELECT nextval('sequence_test2');
|
|
SELECT nextval('sequence_test2'); -- cycled
|
|
|
|
ALTER SEQUENCE sequence_test2 RESTART WITH 24
|
|
NO CYCLE;
|
|
SELECT nextval('sequence_test2');
|
|
SELECT nextval('sequence_test2');
|
|
SELECT nextval('sequence_test2');
|
|
SELECT nextval('sequence_test2');
|
|
SELECT nextval('sequence_test2'); -- error
|
|
|
|
ALTER SEQUENCE sequence_test2 RESTART WITH -24 START WITH -24
|
|
INCREMENT BY -4 MINVALUE -36 MAXVALUE -5 CYCLE;
|
|
SELECT nextval('sequence_test2');
|
|
SELECT nextval('sequence_test2');
|
|
SELECT nextval('sequence_test2');
|
|
SELECT nextval('sequence_test2');
|
|
SELECT nextval('sequence_test2'); -- cycled
|
|
|
|
ALTER SEQUENCE sequence_test2 RESTART WITH -24
|
|
NO CYCLE;
|
|
SELECT nextval('sequence_test2');
|
|
SELECT nextval('sequence_test2');
|
|
SELECT nextval('sequence_test2');
|
|
SELECT nextval('sequence_test2');
|
|
SELECT nextval('sequence_test2'); -- error
|
|
|
|
-- reset
|
|
ALTER SEQUENCE IF EXISTS sequence_test2 RESTART WITH 32 START WITH 32
|
|
INCREMENT BY 4 MAXVALUE 36 MINVALUE 5 CYCLE;
|
|
|
|
SELECT setval('sequence_test2', -100); -- error
|
|
SELECT setval('sequence_test2', 100); -- error
|
|
SELECT setval('sequence_test2', 5);
|
|
|
|
CREATE SEQUENCE sequence_test3; -- not read from, to test is_called
|
|
|
|
|
|
-- Information schema
|
|
SELECT * FROM information_schema.sequences
|
|
WHERE sequence_name ~ ANY(ARRAY['sequence_test', 'serialtest'])
|
|
ORDER BY sequence_name ASC;
|
|
|
|
SELECT schemaname, sequencename, start_value, min_value, max_value, increment_by, cycle, cache_size, last_value
|
|
FROM pg_sequences
|
|
WHERE sequencename ~ ANY(ARRAY['sequence_test', 'serialtest'])
|
|
ORDER BY sequencename ASC;
|
|
|
|
|
|
SELECT * FROM pg_sequence_parameters('sequence_test4'::regclass);
|
|
|
|
|
|
\d sequence_test4
|
|
\d serialtest2_f2_seq
|
|
|
|
|
|
-- Test comments
|
|
COMMENT ON SEQUENCE asdf IS 'won''t work';
|
|
COMMENT ON SEQUENCE sequence_test2 IS 'will work';
|
|
COMMENT ON SEQUENCE sequence_test2 IS NULL;
|
|
|
|
-- Test lastval()
|
|
CREATE SEQUENCE seq;
|
|
SELECT nextval('seq');
|
|
SELECT lastval();
|
|
SELECT setval('seq', 99);
|
|
SELECT lastval();
|
|
DISCARD SEQUENCES;
|
|
SELECT lastval();
|
|
|
|
CREATE SEQUENCE seq2;
|
|
SELECT nextval('seq2');
|
|
SELECT lastval();
|
|
|
|
DROP SEQUENCE seq2;
|
|
-- should fail
|
|
SELECT lastval();
|
|
|
|
-- unlogged sequences
|
|
-- (more tests in src/test/recovery/)
|
|
CREATE UNLOGGED SEQUENCE sequence_test_unlogged;
|
|
ALTER SEQUENCE sequence_test_unlogged SET LOGGED;
|
|
\d sequence_test_unlogged
|
|
ALTER SEQUENCE sequence_test_unlogged SET UNLOGGED;
|
|
\d sequence_test_unlogged
|
|
DROP SEQUENCE sequence_test_unlogged;
|
|
|
|
-- Test sequences in read-only transactions
|
|
CREATE TEMPORARY SEQUENCE sequence_test_temp1;
|
|
START TRANSACTION READ ONLY;
|
|
SELECT nextval('sequence_test_temp1'); -- ok
|
|
SELECT nextval('sequence_test2'); -- error
|
|
ROLLBACK;
|
|
START TRANSACTION READ ONLY;
|
|
SELECT setval('sequence_test_temp1', 1); -- ok
|
|
SELECT setval('sequence_test2', 1); -- error
|
|
ROLLBACK;
|
|
|
|
-- privileges tests
|
|
|
|
CREATE USER regress_seq_user;
|
|
|
|
-- nextval
|
|
BEGIN;
|
|
SET LOCAL SESSION AUTHORIZATION regress_seq_user;
|
|
CREATE SEQUENCE seq3;
|
|
REVOKE ALL ON seq3 FROM regress_seq_user;
|
|
GRANT SELECT ON seq3 TO regress_seq_user;
|
|
SELECT nextval('seq3');
|
|
ROLLBACK;
|
|
|
|
BEGIN;
|
|
SET LOCAL SESSION AUTHORIZATION regress_seq_user;
|
|
CREATE SEQUENCE seq3;
|
|
REVOKE ALL ON seq3 FROM regress_seq_user;
|
|
GRANT UPDATE ON seq3 TO regress_seq_user;
|
|
SELECT nextval('seq3');
|
|
ROLLBACK;
|
|
|
|
BEGIN;
|
|
SET LOCAL SESSION AUTHORIZATION regress_seq_user;
|
|
CREATE SEQUENCE seq3;
|
|
REVOKE ALL ON seq3 FROM regress_seq_user;
|
|
GRANT USAGE ON seq3 TO regress_seq_user;
|
|
SELECT nextval('seq3');
|
|
ROLLBACK;
|
|
|
|
-- currval
|
|
BEGIN;
|
|
SET LOCAL SESSION AUTHORIZATION regress_seq_user;
|
|
CREATE SEQUENCE seq3;
|
|
SELECT nextval('seq3');
|
|
REVOKE ALL ON seq3 FROM regress_seq_user;
|
|
GRANT SELECT ON seq3 TO regress_seq_user;
|
|
SELECT currval('seq3');
|
|
ROLLBACK;
|
|
|
|
BEGIN;
|
|
SET LOCAL SESSION AUTHORIZATION regress_seq_user;
|
|
CREATE SEQUENCE seq3;
|
|
SELECT nextval('seq3');
|
|
REVOKE ALL ON seq3 FROM regress_seq_user;
|
|
GRANT UPDATE ON seq3 TO regress_seq_user;
|
|
SELECT currval('seq3');
|
|
ROLLBACK;
|
|
|
|
BEGIN;
|
|
SET LOCAL SESSION AUTHORIZATION regress_seq_user;
|
|
CREATE SEQUENCE seq3;
|
|
SELECT nextval('seq3');
|
|
REVOKE ALL ON seq3 FROM regress_seq_user;
|
|
GRANT USAGE ON seq3 TO regress_seq_user;
|
|
SELECT currval('seq3');
|
|
ROLLBACK;
|
|
|
|
-- lastval
|
|
BEGIN;
|
|
SET LOCAL SESSION AUTHORIZATION regress_seq_user;
|
|
CREATE SEQUENCE seq3;
|
|
SELECT nextval('seq3');
|
|
REVOKE ALL ON seq3 FROM regress_seq_user;
|
|
GRANT SELECT ON seq3 TO regress_seq_user;
|
|
SELECT lastval();
|
|
ROLLBACK;
|
|
|
|
BEGIN;
|
|
SET LOCAL SESSION AUTHORIZATION regress_seq_user;
|
|
CREATE SEQUENCE seq3;
|
|
SELECT nextval('seq3');
|
|
REVOKE ALL ON seq3 FROM regress_seq_user;
|
|
GRANT UPDATE ON seq3 TO regress_seq_user;
|
|
SELECT lastval();
|
|
ROLLBACK;
|
|
|
|
BEGIN;
|
|
SET LOCAL SESSION AUTHORIZATION regress_seq_user;
|
|
CREATE SEQUENCE seq3;
|
|
SELECT nextval('seq3');
|
|
REVOKE ALL ON seq3 FROM regress_seq_user;
|
|
GRANT USAGE ON seq3 TO regress_seq_user;
|
|
SELECT lastval();
|
|
ROLLBACK;
|
|
|
|
-- setval
|
|
BEGIN;
|
|
SET LOCAL SESSION AUTHORIZATION regress_seq_user;
|
|
CREATE SEQUENCE seq3;
|
|
REVOKE ALL ON seq3 FROM regress_seq_user;
|
|
SAVEPOINT save;
|
|
SELECT setval('seq3', 5);
|
|
ROLLBACK TO save;
|
|
GRANT UPDATE ON seq3 TO regress_seq_user;
|
|
SELECT setval('seq3', 5);
|
|
SELECT nextval('seq3');
|
|
ROLLBACK;
|
|
|
|
-- ALTER SEQUENCE
|
|
BEGIN;
|
|
SET LOCAL SESSION AUTHORIZATION regress_seq_user;
|
|
ALTER SEQUENCE sequence_test2 START WITH 1;
|
|
ROLLBACK;
|
|
|
|
-- Sequences should get wiped out as well:
|
|
DROP TABLE serialTest1, serialTest2;
|
|
|
|
-- Make sure sequences are gone:
|
|
SELECT * FROM information_schema.sequences WHERE sequence_name IN
|
|
('sequence_test2', 'serialtest2_f2_seq', 'serialtest2_f3_seq',
|
|
'serialtest2_f4_seq', 'serialtest2_f5_seq', 'serialtest2_f6_seq')
|
|
ORDER BY sequence_name ASC;
|
|
|
|
DROP USER regress_seq_user;
|
|
DROP SEQUENCE seq;
|
|
|
|
-- cache tests
|
|
CREATE SEQUENCE test_seq1 CACHE 10;
|
|
SELECT nextval('test_seq1');
|
|
SELECT nextval('test_seq1');
|
|
SELECT nextval('test_seq1');
|
|
|
|
DROP SEQUENCE test_seq1;
|