暂无图片
暂无图片
暂无图片
暂无图片
暂无图片

MogDB 列存与行存

由迪 2024-02-21
190

原作者:计议

1.列存表限制

1 列存表不支持数组
2 列存表的数量建议不超过1000个
3 列存表的表级约束只支持PARTIAL CLUSTER KEY,不支持主外键等表级约束
4 列存表的字段约束只支持NULL、NOT NULL和DEFAULT常量值
5 列存表不支持alter命令修改字段约束
6 列存表支持delta表,受参数enable_delta_store 控制是否开启,受参数deltarow_threshold控制进入delta表的阀值

2.列存相关参数

cstore_buffers
列存所使用的共享缓冲区的大小,默认值:32768KB

partition_mem_batch
指定缓存个数,为了优化对列存分区表的批量插入,在批量插入过程中会对数据进行缓存后再批量写盘,默认值:256

partition_max_cache_size
指定数据缓存区大小,为了优化对列存分区表的批量插入,在批量插入过程中会对数据进行缓存后再批量写盘。默认值:2GB

enable_delta_store
为了增强列存单条数据导入的性能和解决磁盘冗余问题,是否需要开启列存delta表功能,与参数DELTAROW_THRESHOLD 配合使用,默认值:off

3.建表语法

opengauss 创建普通表默认是未压缩的行存表

解释[omm@mogdb01 ~]$ gsql -d postgres -p 26000 -r
gsql ((MogDB 3.0.2 build 9bc79be5) compiled at 2022-09-18 00:38:16 commit 0 last mr  )
Non-SSL connection (SSL connection is recommended when requiring high-security)
Type "help" for help.

MogDB=# \dt
                             List of relations
 Schema |     Name      | Type  | Owner |             Storage              
--------+---------------+-------+-------+----------------------------------
 public | dump_tables   | table | omm   | {orientation=row,compression=no}
 public | dump_tables_1 | table | omm   | {orientation=row,compression=no}
 public | emp_range     | table | omm   | {orientation=row,compression=no}
(3 rows)

MogDB=# create table test_t(id serial primary key ,col1 varchar(8),col2 decimal(6,2),create_time timestamptz not null default now());
NOTICE:  CREATE TABLE will create implicit sequence "test_t_id_seq" for serial column "test_t.id"
NOTICE:  CREATE TABLE / PRIMARY KEY will create implicit index "test_t_pkey" for table "test_t"
CREATE TABLE
MogDB=# \d+
                                            List of relations
 Schema |     Name      |   Type   | Owner |    Size    |             Storage              | Description 
--------+---------------+----------+-------+------------+----------------------------------+-------------
 public | dump_tables   | table    | omm   | 80 kB      | {orientation=row,compression=no} | 
 public | dump_tables_1 | table    | omm   | 80 kB      | {orientation=row,compression=no} | 
 public | emp_range     | table    | omm   | 0 bytes    | {orientation=row,compression=no} | 
 public | test_t        | table    | omm   | 0 bytes    | {orientation=row,compression=no} | 
 public | test_t_id_seq | sequence | omm   | 8192 bytes |                                  | 
(5 rows)

创建列存表,需要指定orientation=column,默认压缩级别是low

解释MogDB=# \dt+
                                           List of relations
 Schema |     Name      | Type  | Owner |  Size   |               Storage                | Description 
--------+---------------+-------+-------+---------+--------------------------------------+-------------
 public | column_t      | table | omm   | 16 kB   | {orientation=column,compression=low} | 
 public | dump_tables   | table | omm   | 80 kB   | {orientation=row,compression=no}     | 
 public | dump_tables_1 | table | omm   | 80 kB   | {orientation=row,compression=no}     | 
 public | emp_range     | table | omm   | 0 bytes | {orientation=row,compression=no}     | 
 public | test_t        | table | omm   | 0 bytes | {orientation=row,compression=no}     | 
(5 rows)

MogDB=# \d+ column_t
                                                        Table "public.column_t"
   Column    |           Type           |                       Modifiers                       | Storage  | Stats target | Description 
-------------+--------------------------+-------------------------------------------------------+----------+--------------+-------------
 id          | integer                  | not null default nextval('column_t_id_seq'::regclass) | plain    |              | 
 col1        | character varying(8)     |                                                       | extended |              | 
 col2        | numeric(6,2)             |                                                       | main     |              | 
 create_time | timestamp with time zone | not null default now()                                | plain    |              | 
Has OIDs: no
Options: orientation=column, compression=low

列存表添加局部聚簇存储列

解释MogDB=# alter table column_t add PARTIAL CLUSTER KEY(id);
ALTER TABLE
MogDB=# \d+ column_t
                                                        Table "public.column_t"
   Column    |           Type           |                       Modifiers                       | Storage  | Stats target | Description 
-------------+--------------------------+-------------------------------------------------------+----------+--------------+-------------
 id          | integer                  | not null default nextval('column_t_id_seq'::regclass) | plain    |              | 
 col1        | character varying(8)     |                                                       | extended |              | 
 col2        | numeric(6,2)             |                                                       | main     |              | 
 create_time | timestamp with time zone | not null default now()                                | plain    |              | 
Partial Cluster :
    "column_t_cluster" PARTIAL CLUSTER KEY (id)
Has OIDs: no
Options: orientation=column, compression=low

直接创建带局部聚簇存储的列存表

解释NOTICE:  CREATE TABLE will create implicit sequence "column_c_id_seq" for serial column "column_c.id"
CREATE TABLE
MogDB=# \d+ column_c
                                                        Table "public.column_c"
   Column    |           Type           |                       Modifiers                       | Storage  | Stats target | Description
-------------+--------------------------+-------------------------------------------------------+----------+--------------+-------------
 id          | integer                  | not null default nextval('column_c_id_seq'::regclass) | plain    |              |
 col1        | character varying(8)     |                                                       | extended |              |
 col2        | numeric(6,2)             |                                                       | main     |              |
 create_time | timestamp with time zone | not null default now()                                | plain    |              |
Partial Cluster :
    "column_c_cluster" PARTIAL CLUSTER KEY (id)
Has OIDs: no
Options: orientation=column, compression=low

MogDB=#

4 列存与行存对比

4.1 磁盘使用空间

列存表默认大小16K,low压缩级别
行存表默认大小0bytes,非压缩级别
分别向两个表中插入100万条数据,占用磁盘大小对比

解释MogDB=# \dt+
                                          List of relations
 Schema |   Name    | Type  | Owner |  Size   |                 Storage                 | Description
--------+-----------+-------+-------+---------+-----------------------------------------+-------------
 public | column_t  | table | omm   | 16 kB   | {orientation=column,compression=low}    |
 public | test_t    | table | omm   | 0 bytes | {orientation=row,compression=no}        |
(5 rows)

MogDB=# insert into column_t select generate_series(1,1000000),left(md5(random()::text),8),random()::numeric(6,2);
INSERT 0 1000000
Time: 11328.880 ms
MogDB=# insert into test_t select generate_series(1,1000000),left(md5(random()::text),8),random()::numeric(6,2);
INSERT 0 1000000
Time: 17404.945 ms

MogDB=# \dt+
                                           List of relations
 Schema |   Name    | Type  | Owner |   Size   |                 Storage                 | Description
--------+-----------+-------+-------+----------+-----------------------------------------+-------------
 public | column_t  | table | omm   | 12 MB    | {orientation=column,compression=low}    |
 public | test_t    | table | omm   | 58 MB    | {orientation=row,compression=no}        |
(5 rows)

MogDB=#

列存表开启的压缩级别越高,占用磁盘空间越少
行存表开启压缩后,磁盘空间大小占比减少不明显
列存表占用磁盘空间比行存表占用磁盘空间少近6倍

4.2 DML对比

查找单列

解释按范围查找,列存比行存快近20倍
MogDB=# select col1 from test_t where id>=100010 and id<100020;
   col1
----------
 4257a3f3
 3d397284
 64343438
 6eb7bdb7
 d1c9073d
 6aeb037c
 1d424974
 223235ab
 329de235
 2f02adc1
(10 rows)

Time: 77.341 ms
MogDB=# select col1 from column_t where id>=100010 and id<100020;
   col1
----------
 d4837c30
 87a46f7a
 2f42a9c9
 4481c793
 68800204
 613b9205
 9d8f4a0a
 5cc4ff9e
 f948cd10
 f2775cee
(10 rows)

Time: 3.884 ms

随机查找,列存比行存快近35倍

解释MogDB=# select col1 from test_t limit 10;
   col1
----------
 c2780d93
 294be14d
 4e53b761
 2c10f8a2
 ae776743
 7d683c66
 b3b40054
 7e56edf9
 a7b7336e
 ea3d47d9
(10 rows)

Time: 249.887 ms
MogDB=# select col1 from column_t limit 10;
   col1
----------
 a745d77b
 4b6df494
 76fed9c1
 70c9664d
 3384de8a
 4158f3bf
 5d1c3b9f
 341876bb
 f396f4ed
 abfd78bb
(10 rows)

Time: 7.738 ms

select *
行存比列存查询快30%

解释mydb=# select * from test_t limit 10;
 id |   col1   | col2 |          create_time
----+----------+------+-------------------------------
  1 | c2780d93 |  .37 | 2020-10-26 14:27:33.304108+08
  2 | 294be14d |  .57 | 2020-10-26 14:27:33.304108+08
  3 | 4e53b761 |  .98 | 2020-10-26 14:27:33.304108+08
  4 | 2c10f8a2 |  .27 | 2020-10-26 14:27:33.304108+08
  5 | ae776743 |  .97 | 2020-10-26 14:27:33.304108+08
  6 | 7d683c66 |  .58 | 2020-10-26 14:27:33.304108+08
  7 | b3b40054 |  .44 | 2020-10-26 14:27:33.304108+08
  8 | 7e56edf9 |  .43 | 2020-10-26 14:27:33.304108+08
  9 | a7b7336e |  .31 | 2020-10-26 14:27:33.304108+08
 10 | ea3d47d9 |  .42 | 2020-10-26 14:27:33.304108+08
(10 rows)

Time: 6.822 ms

mydb=# select * from column_t limit 10;
 id |   col1   | col2 |          create_time
----+----------+------+-------------------------------
  1 | a745d77b |  .33 | 2020-10-26 14:28:20.633253+08
  2 | 4b6df494 |  .42 | 2020-10-26 14:28:20.633253+08
  3 | 76fed9c1 |  .73 | 2020-10-26 14:28:20.633253+08
  4 | 70c9664d |  .74 | 2020-10-26 14:28:20.633253+08
  5 | 3384de8a |  .48 | 2020-10-26 14:28:20.633253+08
  6 | 4158f3bf |  .59 | 2020-10-26 14:28:20.633253+08
  7 | 5d1c3b9f |  .63 | 2020-10-26 14:28:20.633253+08
  8 | 341876bb |  .97 | 2020-10-26 14:28:20.633253+08
  9 | f396f4ed |  .73 | 2020-10-26 14:28:20.633253+08
 10 | abfd78bb |  .30 | 2020-10-26 14:28:20.633253+08
(10 rows)

Time: 9.982 ms

update

解释MogDB=# update test_t set col1=col1;
UPDATE 1000000
Time: 19779.978 ms
MogDB=# update column_t set col1=col1;
UPDATE 1000000
Time: 2702.339 ms

5.结论

1、列存表比行存表在磁盘空间占用上节省近6倍
2、查询指定字段,列存表比行存表快约20-35倍
3、select * 的方式,列存表比行存表慢30%
4、默认压缩方式批量导入数据,列存表比行存表快40%

「喜欢这篇文章,您的关注和赞赏是给作者最好的鼓励」
关注作者
【版权声明】本文为墨天轮用户原创内容,转载时必须标注文章的来源(墨天轮),文章链接,文章作者等基本信息,否则作者和墨天轮有权追究责任。如果您发现墨天轮中有涉嫌抄袭或者侵权的内容,欢迎发送邮件至:contact@modb.pro进行举报,并提供相关证据,一经查实,墨天轮将立刻删除相关内容。

文章被以下合辑收录

评论