教你识别一些 sequence 的相关问题
- 2022 年 3 月 28 日
本文字数:3441 字
阅读完需:约 11 分钟
本文分享自华为云社区《GaussDB(DWS)运维 -- sequence常见运维操作》,作者: 譡里个檔。
GaussDB(DWS)是一个 share nothing 架构的产品,seqeunce 编号需要通过 GTM 统一分配。集群规模越大、节点数越多、sequence 调用越频繁,sequnce 对 GTM 的压力就越大。对于 seqeunce 的使用一般有如下建议
建议业务中不要大量使用 sequence,建议不要超过 50 个
如果业务允许,建议使用 uuid 替换 sequence
使用 sequence 的时候,需要定义 cache 值不小于 100
【序列相关信息查询】
建议定义如下视图进行查询
CREATE OR REPLACE FUNCTION public.dfm_get_seqence_info( OUT namespace text, -- 序列的schema OUT sequencename text, -- 序列名称 OUT min_value bigint, -- 序列最小值 OUT max_value bigint, -- 序列最大值 OUT start_value bigint, -- 起始值 OUT increment_by bigint, -- 增加步长 OUT cache_value bigint, -- cache值 OUT is_cycled boolean -- 是否可以循环使用) RETURNS SETOF record LANGUAGE plpgsql NOT FENCED NOT SHIPPABLEAS $function$DECLARE rowObject record; rowDetail record; queryObjectStr text; queryDetailStr text;BEGIN --Get all the node names queryObjectStr := 'SELECT c.oid, relname, n.nspname FROM pg_class c INNER JOIN pg_namespace n on c.relnamespace = n.oid WHERE c.relkind = ''S'''; FOR rowObject IN EXECUTE(queryObjectStr) LOOP queryDetailStr := 'SELECT start_value, increment_by, max_value, min_value, cache_value, is_cycled FROM ' || quote_ident(rowObject.nspname) || '.' || quote_ident(rowObject.relname); FOR rowDetail IN EXECUTE(queryDetailStr) LOOP namespace = rowObject.nspname; sequencename = rowObject.relname; start_value = rowDetail.start_value; increment_by = rowDetail.increment_by; max_value = rowDetail.max_value; min_value = rowDetail.min_value; cache_value = rowDetail.cache_value; is_cycled = rowDetail.is_cycled; RETURN next; END LOOP; END LOOP; RETURN;END; $function$;
CREATE VIEW public.dfm_get_seqence_info AS SELECT * FROM public.dfm_get_seqence_info();示例
postgres=# CREATE SEQUENCE public.test_seq;CREATE SEQUENCETime: 13.917 mspostgres=# CREATE TABLE public.test_serial(a bigserial, b int) DISTRIBUTE BY ROUNDROBIN;NOTICE: CREATE TABLE will create implicit sequence "test_serial_a_seq" for serial column "test_serial.a"SQLSTATE: 00000LOCATION: CreateSeqOwnedByTable, parse_utilcmd.cpp:144CREATE TABLETime: 16.572 mspostgres=# CREATE SEQUENCE public.test_seq_1;CREATE SEQUENCETime: 13.412 mspostgres=# CREATE TABLE public.test_serial_default(a bigint default nextval('public.test_seq_1'::regclass), b int) DISTRIBUTE BY ROUNDROBIN;CREATE TABLETime: 12.006 mspostgres=# SELECT * FROM public.dfm_get_seqence_info; namespace | sequencename | min_value | max_value | start_value | increment_by | cache_value | is_cycled-----------+-------------------+-----------+---------------------+-------------+--------------+-------------+----------- public | test_seq | 1 | 9223372036854775807 | 1 | 1 | 1 | f public | test_serial_a_seq | 1 | 9223372036854775807 | 1 | 1 | 1 | f public | test_seq_1 | 1 | 9223372036854775807 | 1 | 1 | 1 | f(3 rows)
【序列和表的 bind 关系查询】
查询 sequence 和表的 bind 关系,主要场景有两个
表的字段类型为 bigserial 或者 serial 类型,内置生成一个序列
表的字段的默认值为序列的序列号
这两个场景在上述里面都有 case
postgres=# SELECTpostgres-# pg_get_userbyid(c1.relowner) AS seqowner, -- sequence的用户postgres-# n1.nspname AS seqschema, -- sequence的schemapostgres-# c1.relname AS seqname, -- -- sequence的名称postgres-# (pg_sequence_parameters(c1.oid)).minimum_value AS minvalue, -- sequence的最小值postgres-# (pg_sequence_parameters(c1.oid)).maximum_value AS maxvalue, -- sequence的最大值postgres-# (pg_sequence_parameters(c1.oid)).increment AS incrementby, -- sequence的步长postgres-# pg_get_userbyid(c.relowner) AS tableowner, -- 关联的表的ownerpostgres-# n.nspname AS tableschema, -- 关联的表的schemapostgres-# c.relname AS tablename,-- 关联的表的名称postgres-# a.attname, -- -- 关联的表的列的名称postgres-# d.adsrc as defaultexpression -- 关联的sequence的表达式postgres-# FROM pg_catalog.pg_class cpostgres-# INNER JOIN pg_catalog.pg_namespace n ON n.oid = c.relnamespacepostgres-# INNER JOIN pg_catalog.pg_attribute a ON a.attrelid = c.oidpostgres-# INNER JOIN pg_catalog.pg_attrdef d ON d.adrelid = c.oid AND d.adnum = a.attnumpostgres-# INNER JOIN pg_catalog.pg_depend p ON p.objid = d.oidpostgres-# INNER JOIN pg_catalog.pg_class c1 ON c1.oid = p.refobjidpostgres-# INNER JOIN pg_catalog.pg_namespace n1 ON n1.oid = c1.relnamespacepostgres-# WHERE c.relkind = 'r'::"char" AND c.oid > 16384postgres-# AND n.nspname not in ('pg_toast', 'cstore', 'pg_catalog')postgres-# AND a.attnum > 0postgres-# AND p.classid='pg_catalog.pg_attrdef'::regclasspostgres-# AND refclassid = 'pg_catalog.pg_class'::regclasspostgres-# AND p.refobjsubid = 0postgres-# AND c1.relkind = 'S'::"char"postgres-# ; seqowner | seqschema | seqname | minvalue | maxvalue | incrementby | tableowner | tableschema | tablename | attname | defaultexpression-----------+-----------+-------------------+----------+---------------------+-------------+------------+-------------+---------------------+---------+---------------------------------------- j00565968 | public | test_serial_a_seq | 1 | 9223372036854775807 | 1 | j00565968 | public | test_serial | a | nextval('test_serial_a_seq'::regclass) j00565968 | public | test_seq_1 | 1 | 9223372036854775807 | 1 | j00565968 | public | test_serial_default | a | nextval('test_seq_1'::regclass)(2 rows)
【替换方案】
实际业务中使用 sequence 一般有两个场景
保证表数据均匀分布。这种场景可以把 sequence 字段替换为 uuid
postgres=# DROP TABLE public.test_serial;DROP TABLETime: 19.871 mspostgres=# CREATE TABLE public.test_serial(a text DEFAULT sys_guid(), b int) DISTRIBUTE BY HASH(a);CREATE TABLETime: 19.245 ms或者使用 roundrobin 分布替换,然后删除 sequence 相关列
postgres=# ALTER TABLE public.test_serial DISTRIBUTE BY ROUNDROBIN;ALTER TABLETime: 218.796 mspostgres=# ALTER TABLE public.test_serial DROP COLUMN a;ALTER TABLETime: 9.509 ms保证字段数据的唯一性。这种场景可以使用 uuid()+主键的方式实现
postgres=# DROP TABLE public.test_serial;DROP TABLETime: 18.786 mspostgres=# CREATE TABLE public.test_serial(a text DEFAULT sys_guid(), b int, primary key(a)) DISTRIBUTE BY HASH(a);NOTICE: CREATE TABLE / PRIMARY KEY will create implicit index "test_serial_pkey" for table "test_serial"CREATE TABLE注:理论上一个集群内的 uuid 不会重复,但还是建议表上增加主键约束。
版权声明: 本文为 InfoQ 作者【华为云开发者社区】的原创文章。
原文链接:【http://xie.infoq.cn/article/be551d798bc2d5cf0c521ac5f】。文章转载请联系作者。
华为云开发者社区
提供全面深入的云计算技术干货 2020.07.14 加入
华为云开发者社区,提供全面深入的云计算前景分析、丰富的技术干货、程序样例,分享华为云前沿资讯动态,方便开发者快速成长与发展,欢迎提问、互动,多方位了解云计算! 传送门:https://bbs.huaweicloud.com/











评论