本页为您介绍闪回查询的注意事项。 1. 闪回查询功能依赖历史数据，仅支持闪回查询最近一次手动vacuum或者autovacuum后的历史数据。 2. 仅超级用户可以使用该功能。

本页为您介绍对表进行更新删除的操作。 plaintext teledb DELETE FROM foo WHERE bar 1; DELETE 1 teledb DELETE FROM foo WHERE bar 2; DELETE 1 teledb update foo set baz 'cccnew' where bar 3; UPDATE 1 teledb update foo set baz 'cccnew2' where bar 3; UPDATE 1 teledb insert into foo(bar, baz) values (5,'eee'); INSERT 0 1 teledb insert into foo(bar, baz) values (6,'fff'); INSERT 0 1 teledb delete from foo where bar 6; DELETE 1 teledb select from foo; bar baz + 5 eee 3 cccnew2 (2 rows)

本页为您介绍查询给定时间点的历史数据的方法。 plaintext teledb SELECT pgxactcommittimestamp(xmin) as xmintime, pgxactcommittimestamp(case xmax when 0 then null else xmax end) as xmaxtime, FROM pgdirtyread('foo') AS t(tableoid oid, ctid tid, xmin xid, xmax xid, cmin cid, cmax cid, dead boolean,bar bigint, baz text) where (pgxactcommittimestamp(xmin) < ' 20231102 16:43:02' and (pgxactcommittimestamp(case xmax when 0 then null else xmax end) < '20231102 16:43:02') is distinct from true ) ; xmintime xmaxtime tableoid ctid xmin xmax cmin cmax dead bar baz ++++++++++ 20231102 16:42:47.230036+08 16432 (0,3) 680 0 0 0 f 5 eee 20231102 16:42:41.46109+08 16432 (0,3) 659 0 0 0 f 3 cccnew2 (2 rows)

本页为您介绍闪回查询的语法。 指用户能够指定某个过去的时间点，以便检索出该时间点时某个表的历史数据。语法: plaintext SELECT col1 type1, col2 type2,... 需查询表的系统字段以及目标字段 FROM pgdirtyread('schema.tablename') AS t(tableoid oid, ctid tid, xmin xid, xmax xid, cmin cid, cmax cid, dead boolean, 系统字段 col1 typei, col2 typei+1，...) 目标字段 where ( pgxactcommittimestamp(xmin) < '$ts' and (pgxactcommittimestamp(case xmax when 0 then null else xmax end) < '$ts') is distinct from true) ; schema.tablename：表名 $ts：查询某个表在ts这个时间点时的数据，ts指一个具体的历史时间。

本页为您介绍如何将表移出回收站。 plaintext ALTER TABLE trash.1 RENAME to t; ALTER TABLE trash.t SET SCHEMA public; dt public. List of relations Schema Name Type Owner +++ public t table teledb (1 row) dt "trash". List of relations Schema Name Type Owner +++ trash 2 table teledb trash trashtable table teledb (2 rows)

在一个块中使用的所有变量必须在该块的声明小节中事先进行声明，PL/pgSQL变量可以是任意SQL数据类型，可以是一个简单数据类型、复合类型、RECORD、已经存在的表行类型、表字段类型、游标。

变量声明语法 name [ CONSTANT ] type [ COLLATE collationname ] [ NOT NULL ] [ { DEFAULT : } expression ]; 如果给定DEFAULT子句，它会指定进入该块时分配给该变量的初始值。如果没有给出DEFAULT子句， 则该变量被初始化为SQL空值。 CONSTANT选项阻止该变量在初始化之后被赋值， 这样它的值在块的持续期内保持不变。 COLLATE选项指定用于该变量的一个排序规则（见 第 41.3.6 节）。如果指定了NOT NULL，对该变量赋值为空值会导致一个运行时错误。所有被声明为NOT NULL的变量必须被指定一个非空默认值。 等号（）可以被用来代替PL/SQL兼容的 :。 定义一个普通变量 teledb CREATE OR REPLACE FUNCTION f25() RETURNS VOID AS teledb $$ teledb$ DECLARE teledb$ 所有变量的声明都要放在这里,建议变量以v开头,参数以a开头 teledb$ vint integer : 1; teledb$ vtext text; teledb$ BEGIN teledb$ vtext 'teledbpg'; teledb$ RAISE NOTICE 'vint %',vint; teledb$ RAISE NOTICE 'vtext %',vtext; teledb$ END; teledb$ $$ teledb LANGUAGE plpgsql; CREATE FUNCTION teledb SELECT f25(); NOTICE: vint 1 NOTICE: vtext teledbpg f25 (1 row) teledb 定义CONSTANT 变量 teledb CREATE OR REPLACE FUNCTION f25() RETURNS VOID AS teledb

本页介绍如何创建、查看和删除列存储表。 创建列存储表 要创建列存储表，需要将表的访问方式(Table Access Method) 设为 PAX，在建表时显式使用 USING PAX 子句指定表访问方式 teledb CREATE TABLE t1(a int, b int, c text) USING PAX; CREATE TABLE teledb d+ t1 Table "public.t1" Column Type Collation Nullable Default Storage Stats target Description +++++++ a integer plain b integer plain c text extended Distribute By: HASH(a) Location Nodes: ALL DATANODES 查看列存储表访问方式 查询系统目录表pgclass 和 pgam 检查列存储表的访问方式 teledb SELECT relname, amname FROM pgclass, pgam WHERE relam pgam.oid AND relname 't1'; relname amname + t1 pax (1 row) 删除列存储表 删除列存储表和行存表语法一致，使用drop table 语句删除 teledb drop table t1; DROP TABLE

CDC是一种用于捕获，处理和同步TeleDBX实例数据变化的工具，允许将实例中的变更数据实时地同步到下游系统。本页为您介绍CDC的使用和管理操作。 初始化插件 1. 通过pgxcctl新建一个双CN、双DN的实例，并开启服务。 2. 通过telesql连接到CN节点。 3. 在配置文件中设置加载sharedpreloadlibraries。 创建插件 1. 通过telesql连接到CN节点。 执行sql “create extension teledbxcdc” 2. 执行telesql命令dx，查看插件teledbxcdc是否存在。 3. 执行sql “select teledbxinitcdcmeta();”对元数据进行初始化。 管理cdc复制槽 1. 执行以下语法在所有数据节点创建逻辑复制槽 plaintext select from teledbxcreatelogicalreplicationslot('cdcdemo','teledbxcdc'); 2. 执行以下语法查看元数据 plaintext select from teledbx.cdcslot; 3. 执行以下语法删除逻辑复制槽 plaintext select from teledbxdroplogicalreplicationslot('cdcdemo'); 读取变更数据 1. 执行以下语法对变更数据进行可重复读，返回结果为text类型 plaintext select from teledbxcdcpeekchanges('slotname', batchcount, optionalvalue); 2. 执行以下语法对变更数据进行可重复读，返回结果为binary类型 plaintext select from teledbxcdcpeekbinarychanges('slotname', batchcount, optionalvalue); 3. 执行以下语法推高逻辑复制槽位点 plaintext teledb 4. 执行以下语法对变更数据进行不可重复读，返回结果为text类型 plaintext select from teledbxcdcgetchanges('slotname', batchcount, optionalvalue); 5. 执行以下语法对变更数据进行不可重复读 plaintext select from teledbxcdcgetbinarychanges('slotname', batchcount, optionalvalue);

本页为您介绍如何将带有依赖项表移出回收站。 plaintext ALTER TABLE trash.5 RENAME to t3; ALTER TABLE trash.t SET SCHEMA public; dt "trash". List of relations Schema Name Type Owner +++ trash 3 table teledb trash 4 table teledb trash trashtable table teledb (3 rows) d+ t3 Table "t3" Column Type Collation Nullable Default Storage Stats target Description +++++++ id integer not null plain Indexes: "5.1" btree (id) Distribute By: SHARD(id) Location Nodes: ALL DATANODES

本页为您介绍如何删除带有依赖项的表。 plaintext view CREATE TABLE t1(id int); CREATE VIEW v1 AS SELECT FROM t1; DROP TABLE t1; ERROR: cannot drop table t1 because other objects depend on it DETAIL: view v1 depends on table t1 HINT: Use DROP ... CASCADE to drop the dependent objects too. DROP TABLE t1 CASCADE; NOTICE: drop cascades to view v1 dt "trash". List of relations Schema Name Type Owner +++ trash 3 table teledb trash trashtable table teledb (2 rows) dv "trash". List of relations Schema Name Type Owner +++ trash 3.1 view teledb (1 row) SELECT orgrelname, newrelname, orgnspname, relowner FROM trash.trashtable; orgrelname newrelname orgnspname relowner +++ test1 1 public teledb test2 2 public teledb t1 3 public teledb (3 rows) matview CREATE TABLE t2(id int); CREATE MATERIALIZED VIEW mv1 AS SELECT FROM t2; DROP TABLE t2; ERROR: cannot drop table t2 because other objects depend on it DETAIL: materialized view mv1 depends on table t2 HINT: Use DROP ... CASCADE to drop the dependent objects too. DROP TABLE t2 CASCADE; NOTICE: drop cascades to materialized view mv1 dt "trash". List of relations Schema Name Type Owner +++ trash 3 table teledb trash 4 table teledb trash trashtable table teledb (3 rows) dmv "trash". List of relations Schema Name Type Owner +++ trash 3.1 view teledb trash 4.1 materialized view teledb (2 rows) SELECT orgrelname, newrelname, orgnspname, relowner FROM trash.trashtable; orgrelname newrelname orgnspname relowner +++ test1 1 public teledb test2 2 public teledb t1 3 public teledb t2 4 public teledb (4 rows) index CREATE TABLE t3(id int); CREATE INDEX i1 ON t3(id); DROP TABLE t3; dt "trash". List of relations Schema Name Type Owner +++ trash 3 table teledb trash 4 table teledb trash 5 table teledb trash trashtable table teledb (4 rows) d+ "trash".5 Table "trash.5" Column Type Collation Nullable Default Storage Stats target Description +++++++ id integer not null plain Indexes: "5.1" btree (id) Distribute By: SHARD(id) Location Nodes: ALL DATANODES SELECT orgrelname, newrelname, orgnspname, relowner FROM trash.trashtable; orgrelname newrelname orgnspname relowner +++ test1 1 public teledb test2 2 public teledb t1 3 public teledb t2 4 public teledb t3 5 public teledb (5 rows)

本文为您介绍使用SELECT语法查询记录所在的DN。 teledb select xcnodeid, from teledbpg1; xcnodeid id nickname ++ 1085152094 5 test 1085152094 6 teledb, teledb1 506537247 3 pg (3 rows) teledb select t1.xcnodeid, pgxcnode.nodename, t1. from teledbpg1 t1, pgxcnode where t1.xcnodeid pgxcnode.nodeid; xcnodeid nodename id nickname +++ 1085152094 dn01 5 test 1085152094 dn01 6 teledb, teledb1 506537247 dn02 3 pg (3 rows)

您可以参考本文，配置用户访问模式权限。 当普通用户访问某个模式下的对象时，需要对对象授权，也需要对模式授权。 [teledb@localhost bin]$ ./telesql p 11111 U teledb d teledb Password for user teledb: telesql (TeleDB V6) Type "help" for help. 创建schema teledb create schema test; CREATE SCHEMA 创建表 teledb create table test.t1(id int); CREATE TABLE 创建用户user1 teledb create role user1 with login password 'User@184'; CREATE ROLE 给用户user1授权表访问权限 teledb grant select on test.t1 to user1; GRANT 示例： 切换至普通用户user1，尝试访问test.t1表。由于没有授权test模式，仍然无法访问。 teledb c user1 Password for user user1: You are now connected to database "teledb" as user "user1". teledb> select from test.t1; ERROR: permission denied for schema test LINE 1: select from test.t1; ^ 切换至teledb用户，将test模式的访问权限授权给user1，重新用user1访问t1表。 teledb> c teledb Password for user teledb: You are now connected to database "teledb" as user "teledb". 授权schema teledb grant usage on schema test to user1; GRANT teledb c user1 Password for user user1: You are now connected to database "teledb" as user "user1". teledb> select from test.t1; id (0 rows)

d t Table "public.t" Column Type Collation Nullable Default ++++ id integer not null mc text Indexes: "tpkey" PRIMARY KEY, btree (id) 添加外键 teledb create table tp(f1 int not null,f2 int ,primary key(f1)); CREATE TABLE teledb create table tf(f1 int not null,f2 int ); CREATE TABLE teledb ALTER TABLE tf ADD CONSTRAINT tff1fkey FOREIGN KEY (f1) REFERENCES tp (f1); ALTER TABLE teledb d+ tf Table "public.tf" Column Type Collation Nullable Default Storage Stats target Description +++++++ f1 integer not null plain f2 integer plain Foreignkey constraints: "tff1fkey" FOREIGN KEY (f1) REFERENCES tp(f1) Distribute By: SHARD(f1) Location Nodes: ALL DATANODES 外键使用限制： 外键只是同一个节点内约束有效果，所以外键字段和对应主键字段必需都是表的分布键，否则由于数据分布于不同的节点内会导致更新失败。 分区表和冷热分区表也不支持外键，数据分区后位于不同的物理文件中，无法约束。 删除外键 teledb ALTER TABLE tf DROP CONSTRAINT tff1fkey; ALTER TABL 修改表所属模式 teledb create schema teledb; CREATE SCHEMA teledb dt t List of relations Schema Name Type Owner +++ public t table teledb (1 row) teledb

explain select from tmulidx where f11 or f22 or f33 ; QUERY PLAN Remote Fast Query Execution (cost0.00..0.00 rows0 width0) Node/s: dn001, dn002 > Seq Scan on tmulidx (cost0.00..12966.87 rows3 width16) Filter: ((f1 1) OR (f2 2) OR (f3 3)) (4 rows) Time: 3.153 ms 如果返回字段全部在索引文件中，则只需要扫描索引，IO 开销会更少。 teledb explain select f1,f2,f3 from tmulidx where f11 ; QUERY PLAN Remote Fast Query Execution (cost0.00..0.00 rows0 width0) Node/s: dn01 > Index Only Scan using tmulidxidx on tmulidx (cost0.42..8.44 rows1 width12) Index Cond: (f1 1) (4 rows) Time: 2.630 ms 更新性能比单字段多索引文件要好。 多字段 teledb truncate table tmulidx; TRUNCATE TABLE Time: 44.930 ms teledb insert into tmulidx select t,t,t,t from generateseries(1,1000000) as t; INSERT 0 1000000 Time: 1985.901 ms (00:01.986) 单字段 teledb create table tsimpleidx (f1 int,f2 int,f3 int,f4 int); CREATE TABLE teledb create index tsimpleidxidx on tsimpleidx(f1); CREATE INDEX teledb create index tsimpleidxidx1 on tsimpleidx(f2); CREATE INDEX teledb create index tsimpleidxidx2 on tsimpleidx(f3); CREATE INDEX teledb insert into tsimpleidx select t,t,t,t from generateseries(1,1000000) as t; INSERT 0 1000000 Time: 4186.401 ms (00:04.186) 多字段索引走非第一字段查询时性能比独立的单字段差。 多字段 teledb

本文为您介绍如何使用gist 索引。 注意 此功能需加载插件 pgtrgm。 teledb create extension pgtrgm; CREATE EXTENSION teledb create table ttrgm (id int,trgm text,notrgm text) ; ERROR: relation "ttrgm" already exists teledb create index ttrgmtrgmidx on ttrgm using gist(trgm gisttrgmops); CREATE INDEX

本文介绍如何在使用SELECT语法时添加any条件。 只需要大于其中一个值即为真。 teledb select from teledbpg where id > any (select 1 union select 3); id nickname + 3 pg 4 2 TELEDB (3 rows)

本文为您介绍如何在使用SELECT语法时进行排序。 按某一列排序 teledb create table teledbpg(id int, nickname text); CREATE TABLE teledb insert into teledbpg values(1,'teledb'),(3,'pg'),(1,'hello,pgxc'); COPY 3 teledb select from teledbpg order by nickname; id nickname + 1 hello,pgxc 3 pg 1 teledb (3 rows) 按第一列排序 teledb select from teledbpg order by 1; id nickname + 1 teledb 1 hello,pgxc 3 pg 按ID 升级排序，再按 nickname 降序排序 teledb select from teledbpg order by id,nickname desc; id nickname + 1 teledb 1 hello,pgxc 3 pg (3 rows) 效果与上面的语句一样。 teledb select from teledbpg order by 1,2 desc; id nickname + 1 teledb 1 hello,pgxc 3 pg (3 rows) 随机排序 teledb select from teledbpg order by random(); id nickname + 1 teledb 3 pg 1 hello,pgxc (3 rows) teledb select from teledbpg order by random(); id nickname + 1 hello,pgxc 1 teledb 3 pg (3 rows) 计算排序 teledb select from teledbpg order by md5(nickname); id nickname + 1 hello,pgxc 3 pg 1 teledb (3 rows) 排序也能用子查询。 teledb

使用delimiter指定列与列之间的分隔符 teledb copy t to '/home/teledb/t.txt' with delimiter '@'; COPY 3 teledb ! cat /home/teledb/t.txt 1@张三@20001201 00:00:00@北京 2@李四@19970324 00:00:00@上海 3@王五@20040901 00:00:00@广州 teledb copy t to '/home/teledb/t.txt' with csv delimiter '@'; COPY 3 teledb ! cat /home/teledb/t.txt 1@张三@20001201 00:00:00@北京 2@李四@19970324 00:00:00@上海 3@王五@20040901 00:00:00@广州 teledb copy t to '/home/teledb/t.txt' with csv delimiter '@@'; ERROR: COPY delimiter must be a single onebyte character teledb copy t to '/home/teledb/t.txt' with binary delimiter '@'; ERROR: cannot specify DELIMITER in BINARY mode 指定分隔文件各列的字符。文本格式中默认是一个制表符， 而CSV格式中默认是一个逗号。分隔符必须是一个单一的单字节字符，即汉字是不支持的。使用binary格式时不允许这个选项。 NULL 值的处理 teledb insert into t(name, birth, city) values('赵六','20001201', null); INSERT 0 1 teledb copy t to '/home/teledb/t.txt' with csv null 'NULL'; COPY 4 teledb ! cat /home/teledb/t.txt 1,张三,20001201 00:00:00,北京 2,李四,19970324 00:00:00,上海 3,王五,20040901 00:00:00,广州 4,赵六,20001201 00:00:00,NULL 记录值为NULL时导出为NULL字符。使用binary格式时不允许这个选项。

drop node group defaultgroup; DROP NODE GROUP 修改存储组 修改存储组只能将存储组定义为默认存储组，语法如下： alter node group groupname set to default; 当已存在默认存储组的情况下，此语句无法生效。 teledb create node group group1 with (dn01); CREATE NODE GROUP teledb create node group group2 with (dn02); CREATE NODE GROUP teledb alter node group group1 set to default; ALTER NODE GROUP teledb alter node group group2 set to default; ERROR: default group already exists, groupoid:57352 查看存储组相关信息 teledb select oid, from pgxcgroup; oid groupname defaultgroup groupmembers +++ 57353 group2 0 16386 57352 group1 1 16385

本文为您介绍如何创建分区表。 创建范围分区表 teledb create table trange (f1 bigint,f2 timestamp default now(), f3 integer) partition by range (f3) begin (1) step (50) partitions (3) distribute by shard(f1); CREATE TABLE teledb insert into trange(f1,f3) values(1,1),(2,50),(3,100),(2,110); COPY 4 teledb insert into trange(f1,f3) values(1,1),(2,50),(3,100),(2,110); COPY 4 teledb d+ trange; Table "public.trange" Column Type Collation Nullable Default Storage Stats target Description +++++++ f1 bigint plain f2 timestamp without time zone now() plain f3 integer plain Distribute By: SHARD(f1) Location Nodes: ALL DATANODES Partition By: RANGE(f3) Of Partitions: 3 Start With: 1 Interval Of Partition: 50 创建时间范围分区表 teledb create table ttimerange (f1 bigint, f2 timestamp ,f3 bigint) partition by range (f2) begin (timestamp without time zone '20170901 0:0:0') step (interval '1 month') partitions (12) distribute by shard(f1); CREATE TABLE teledb d+ ttimerange Table "public.ttimerange" Column Type Collation Nullable Default Storage Stats target Description +++++++ f1 bigint plain f2 timestamp without time zone plain f3 bigint plain Distribute By: SHARD(f1) Location Nodes: ALL DATANODES Partition By: RANGE(f2)

本文为您介绍如何在使用SELECT语法时进行分页查询。 默认从第一条开始，返回一条记录。 teledb select from teledbpg limit 1; id nickname + 1 teledb (1 row) 使用offset指定从第几条开始，0表示第一条开始，返回1条记录。 teledb select from teledbpg limit 1 offset 0; id nickname + 1 teledb (1 row) 从第3条开始，返回二条记录。 teledb select from teledbpg limit 2 offset 2; id nickname + 2 TELEDB 3 pg (2 rows) 上面的语句没有使用排序，返回结果不可预知，使用order by 可以获得一个有序的结果。 teledb select from teledbpg order by nickname; id nickname + 1 hello,pgxc 3 pg 1 teledb 2 TELEDB 4 (5 rows) teledb select from teledbpg order by nickname limit 2 offset 2; id nickname + 1 teledb 2 TELEDB (2 rows)

本文为您介绍如何通过SELECT语法访问函数。 teledb select md5(random()::text); md5 ed5b356234979a63efc6c4f6537c4853 (1 row)

select from ttimerange; f1 f2 f3 ++ 1 20171001 00:00:00 100 1 20171101 00:00:00 100 (2 rows) truncate 一个数字分区表。 teledb select from trange; f1 f2 f3 ++ 1 20230823 10:29:46.263768 1 2 20230823 10:29:46.263768 50 2 20230823 10:29:46.263768 110 3 20230823 10:29:46.263768 100 (4 rows) teledb d+ trange Table "public.trange" Column Type Collation Nullable Default Storage Stats target Description +++++++ f1 bigint plain f2 timestamp without time zone now() plain f3 integer plain Distribute By: SHARD(f1) Location Nodes: ALL DATANODES Partition By: RANGE(f3) Of Partitions: 3 Start With: 1 Interval Of Partition: 50 teledb truncate trange partition for (1); TRUNCATE TABLE teledb truncate trange partition for (2); TRUNCATE TABLE teledb select from trange; f1 f2 f3 ++ 2 20230823 10:29:46.263768 110 3 20230823 10:29:46.263768 100 (2 rows)

本文为您介绍如何删除索引。 teledb drop index tmulidxidx; DROP INDEX

本文为您介绍如何使用条件索引。 teledb create table tsex(id int,sex text) ; CREATE TABLE teledb teledb create index tsexsexidx on tsex (sex); CREATE INDEX teledb insert into tsex select t,'男' from generateseries(1,1000000) as t; INSERT 0 1000000 teledb insert into tsex select t,'女' from generateseries(1,100) as t; INSERT 0 100 teledb analyze tsex ; ANALYZE teledb explain select from tsex where sex '女'; QUERY PLAN Remote Fast Query Execution (cost0.00..0.00 rows0 width0) Node/s: dn01, dn02 > Index Scan using tsexsexidx on tsex (cost0.42..9.30 rows50 width8) Index Cond: (sex '女'::text) (4 rows) 索引对于条件在性别为男的情况下无效。 teledb explain select from tsex where sex '男'; QUERY PLAN Remote Fast Query Execution (cost0.00..0.00 rows0 width0) Node/s: dn01, dn02 > Seq Scan on tsex (cost0.00..9966.58 rows500556 width8) Filter: (sex '男'::text) (4 rows) 连接DN 节点查看索引占用空间大，而且度数也高。 teledb di+ tsexsexidx List of relations Schema Name Type Owner Table Size Allocated Size Description +++++++ public tsexsexidx index teledb tsex 14 MB 14 MB (1 row) teledb q [teledb@localhost bin]$ ./telesql p 11111 U teledb d teledb Password for user teledb: telesql (TeleDB V6) Type "help" for help. teledb

本文为您介绍如何添加分区子表。 teledb d+ trange Table "public.trange" Column Type Collation Nullable Default Storage Stats target Description +++++++ f1 bigint plain f2 timestamp without time zone now() plain f3 integer plain Distribute By: SHARD(f1) Location Nodes: ALL DATANODES Partition By: RANGE(f3) Of Partitions: 3 Start With: 1 Interval Of Partition: 50 teledb alter table trange add partitions 2; ALTER TABLE teledb d+ trange Table "public.trange" Column Type Collation Nullable Default Storage Stats target Description +++++++ f1 bigint plain f2 timestamp without time zone now() plain f3 integer plain Distribute By: SHARD(f1) Location Nodes: ALL DATANODES Partition By: RANGE(f3) Of Partitions: 5 Start With: 1 Interval Of Partition: 50

本文为您介绍如何管理普通索引。 teledb create index tididx on t1 using btree(id); CREATE INDEX

本文为您介绍如何使用查询结果创建数据表。 teledb insert into t values(1,'teledb'); INSERT 0 1 teledb create table tas as select from t; INSERT 0 1 teledb select from tas; id mc + 1 teledb (1 row)

本文为您介绍如何指定模式创建表。 teledb create table public.t1(id int,mc text); CREATE TABLE

本文为您介绍如何创建shard表。 不指定shard key 建表方式 不指定shard key 建表方法，系统默认使用第一个字段作为表的 shard key。 teledb create table test(id int, name varchar, birth date); CREATE TABLE teledb d+ test Table "public.test" Column Type Collation Nullable Default Storage Stats target Description +++++++ id integer plain name character varying extended birth timestamp(0) without time zone plain Distribute By: SHARD(id) Location Nodes: ALL DATANODES 分布键选择原则： 分布键只能选择一个字段。 如果有主键，则选择主键做分布键。 如果主键是复合字段组合，则选择字段值选择性多的字段做分布键。 也可以把复合字段拼接成一个新的字段来做分布键。 没有主键的可以使用UUID 来做分布键。 总之一定要让数据尽可能的分布得足够散。 指定shard key 建表方式 teledb create table testshard(id serial not null, name text) distribute by shard(name) to group defaultgroup; CREATE TABLE teledb d+ testshard Table "public.testshard" Column Type Collation Nullable Default Storage Stats target Description +++++++ id integer not null nextval('testshardidseq'::regclass) plain name text extended Distribute By: SHARD(name) Location Nodes: ALL DATANODES distribute by shard(x) 用于指定分布键，数据分布于那个节点就是根据这个字段值来计算分片。 to group xxx 用于指定存储组（每个存储组可以有多个节点）。 分布键字段值不能修改，字段长度不能修改，字段类型不能修改。

本文为您介绍如何创建模式。 您可参考如下操作创建模式。 标准语法 teledb create schema teledbschema; CREATE SCHEMA 注意 当标准语法不存在时，才创建扩展语法。 扩展语法 teledb create schema if not exists teledbschema; NOTICE: schema "teledbschema" already exists, skipping CREATE SCHEMA 指定所属用户 teledb create schema teledbschemaowner AUTHORIZATION teledbuser; CREATE SCHEMA teledb dn teledbschemaowner List of schemas Name Owner + teledbschemaowner teledbuser (1 row)