Of Partitions: 12 Start With: 20170901 Interval Of Partition: 1 MONTH 说明 partion by range(xx) 代表范围分区， 支持timesamp,int类型，数据分布于那个子表就是根据这个字段值来计算分区。 begin(xx) 表示开始分区的初始值 partition(xx) 代表初始分区数量 step (xx) 代表分区步长

您可以参考本文，配置用户访问模式权限。 普通用户对于某个模式下的对象访问除了访问对象要授权外，模式也需要授权。 plaintext [teledb@localhost bin]$ ./telesql p 11111 U teledb d teledb Password for user teledb: telesql (TeleDB V6) Type "help" for help. 创建shema 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模式，仍然无法访问 plaintext 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表 plaintext 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)

本文为您介绍在线创建索引避免阻塞DML语句的具体操作。 1. 新建索引 推荐使用加关键字concurrently的方式在线创建索引，此方式不阻塞DML、DQL语，不影响表的增、删、改、查操作。 例如，在teledb1表的id字段上创建索引语句如下： teledb create index concurrently teledb1ididx on teledb1(id); 2. 重建索引 TeleDB支持在相同字段上创建多个索引，重建索引推荐使用替换的方式，过程如下： 1. 使用concurrently方式在线创建新的索引。 2. 删除原索引（记得设置locktimeout）。 3. analyze表更新统计信息。 3. 更改主键 更改主键，推荐使用替换的方式，过程如下： 1. 在线创建新的包含主键列的唯一索引。 2. 执行以下SQL替换主键： ALTER TABLE teledb1 DROP CONSTRAINT teledb1pkey, ADD CONSTRAINT teledb1newpkey PRIMARY KEY USING INDEX teledb1iduidx; 3. analyze表更新统计信息。

本页为您介绍如何注册加密算法。 plaintext SELECT MLSTRANSPARENTCRYPTCREATEALGORITHM(algoname, password); 参数描述： algoname采用的加密算法，其中加密算法支持 AES128：采用AES算法加密口令长度128。 AES192：采用AES算法加密口令长度192。 AES256：采用AES算法加密口令长度256。 SM4：采用国密SM4算法加密 password:密钥口令 SM4，密钥口令长度必须为16。 AES128，AES192，AES256，密钥口令长度不可超过64。 返回值：算法ID

本页为您介绍如何修改定时任务的ip和端口。 modifyhostport(jobno bigint,hostname text,port int)：第一个参数是定时任务的jodid；第二个参数是任务的ip；第三个参数是任务的端口。 plaintext select dbmsjob.modifyhostport(20002, 'localhost', 20001); 修改jobid为20002的定时任务连接的ip和端口 期望结果，查询dbmsjob.job表发现jobid为20002的定时任务的nodename字段为'localhost'

本页介绍透明加密功能的使用示例。 plaintext 创建插件 CREATE EXTENSION teledbxmls; 切换为安全管理员用户 c mlsadmin 注册内置的加密算法和对应密钥 使用国测sm4加密算法进行注册，获得对应的算法ID select MLSTRANSPARENTCRYPTCREATEALGORITHM('SM4','0123456789012345'); Select MLSTRANSPARENTCRYPTCREATEALGORITHM('AES128','0123456789012345'); c root create table t1(id int,content int); c mlsadmin 将加密算法绑定到表上,其中1是上面创建的算法ID select MLSTRANSPARENTCRYPTALGORITHMBINDTABLE('public','t1',1); insert into t1 values(1,0), (2,0), (3,0); insert into t1 values(7, 0), (8,0), (9,0);

本页为您介绍如何修改定时任务的间隔时间。 "interval"(jobno bigint,"interval" text)：第一个参数是定时任务的jodid；第二个参数是任务的时间间隔。 plaintext select dbmsjob.interval(20002, '13 '); 每个小时的第13分钟执行作业 期望结果，查询dbmsjob.job表发现jobid为20002的定时任务的schedule字段为'13 '

本页为您介绍如何修改定时任务首次调度时间。 modifynextdate(jobno bigint, nextdate timestamptz)：第一个参数是定时任务的jodid；第二个参数是任务的调度时间。只有在这个时间之后，定时任务才有可能被调度。 plaintext select dbmsjob.modifynextdate(20002,'20241107 15:00:00'); 修改定时任务的调度时间，在这个时间之前不会调度定时任务。 期望结果：查询dbmsjob.job表中的jobid为20002的定时任务的nextdate字段为20241107 15:00:00

本页介绍全密态的使用示例。 plaintext 创建CMK主秘钥 CREATE CLIENT MASTER KEY cmk12 WITH ( KEYSTORE localkms, KEYPATH "localkms1" , ALGORITHM SM2); CREATE CLIENT MASTER KEY cmk2 WITH ( KEYSTORE localkms, KEYPATH "localkms1" , ALGORITHM SM2); 创建CEK数据秘钥 CREATE COLUMN ENCRYPTION KEY cek1 WITH VALUES ( CLIENTMASTERKEY cmk1, ALGORITHM SM4SM3); CREATE COLUMN ENCRYPTION KEY cek2 WITH VALUES ( CLIENTMASTERKEY cmk2, ALGORITHM SM4SM3); DROP CLIENT MASTER KEY cmk1 CASCADE; 创建加密表，col1未加密，col2使用cek1加密，col3和col4使用cek2加密 CREATE TABLE IF NOT EXISTS tbl1 ( col1 INT, col2 INT ENCRYPTED WITH ( COLUMNSENCRYPTIONKEY cek1, ENCRYPTIONTYPE DETERMINISTIC), col3 TEXT ENCRYPTED WITH ( COLUMNSENCRYPTIONKEY cek2, ENCRYPTIONTYPE DETERMINISTIC), col4 VARCHAR(20) ENCRYPTED WITH ( COLUMNSENCRYPTIONKEY cek2, ENCRYPTIONTYPE DETERMINISTIC) );

本页为您介绍如何禁用或启用定时任务。 broken(jobno bigint,broken bool)：第一个参数是定时任务的jodid；第二个参数是启用、禁用定时任务，true表示启用，false表示禁用。具体表现在job表的active字段。active为false表示禁用。 plaintext select dbmsjob.broken(20002,false); 禁用jobid为20002的定时任务 select dbmsjob.broken(20002, true); 启用jobid为20002的定时任务 期望结果，查询dbmsjob.job表中的jobid为20002的定时任务的active字段为falsetrue 启用定时任务 run(jobno bigint)：第一个参数是定时任务的jodid；具体表现在job表的active字段。 plaintext select dbmsjob.run(25002); 启用jobid为25002的定时任务。

本页为您介绍如何删除定时任务。 unschedule(jobno bigint)：第一个参数是定时任务的jodid。 plaintext select dbmsjob.unschedule(20002); 删除jobid为20002的定时任务 期望结果，查询dbmsjob.job表发现jobid为20002的定时任务不存在

本页为您介绍如何查询定时任务以及执行记录。 plaintext select from dbmsjob.job; 查询定时任务 select from dbmsjob.joblog; 查询定时任务的执行记录

本页为您介绍初始化实例的操作步骤。 1. 通过pgxcctl新建一个双CN、双DN的实例，并开启服务。 2. 通过telesql连接到CN节点。 3. 执行sql “create default node group defaultgroup with(dn01, dn02); create sharding group to group defaultgroup;”。

本页为您介绍创建插件的操作步骤。 1. 通过telesql连接到CN节点。 2. 执行sql “create extension pgtrashcan;” 3. 执行telesql命令dx，查看插件pgtrashcan是否存在。

本页为您介绍创建表并插入数据的方法。 plaintext teledb CREATE TABLE foo (bar bigint, baz text); CREATE TABLE teledb ALTER TABLE foo SET (autovacuumenabled false, toast.autovacuumenabled false); ALTER TABLE teledb INSERT INTO foo VALUES (1, 'aaa'), (2, 'bbb'),(3,'ccc'); INSERT 0 3

本页为您介绍初始化实例的操作步骤。 1. 通过pgxcctl新建一个双CN、双DN的实例，并开启服务。 2. 通过telesql连接到CN节点。 3. 执行sql “create default node group defaultgroup with(dn01, dn02); create sharding group to group defaultgroup;”。

本文为您介绍如何使用gin索引。 pgtrgm索引 注意 此功能需加载插件 pgtrgm。 teledb drop index ttrgmtrgmidx; DROP INDEX teledb create index ttrgmtrgmidx on ttrgm using gin(trgm gintrgmops); CREATE INDEX jsonb索引 teledb create table tjsonb(id int,fjsonb jsonb); CREATE TABLE teledb create index tjsonbfjsonbidx on tjsonb using gin(fjsonb); CREATE INDEX 数组索引 teledb create table tarray(id int, mc text[]); CREATE TABLE teledb insert into tarray select t,('{'md5(t::text)'}')::text[] from generateseries(1,1000000) as t; INSERT 0 1000000 teledb analyze; ANALYZE teledb timing Timing is on. teledb explain select from tarray where mc @> ('{'md5('1')'}')::text[]; QUERY PLAN Remote Fast Query Execution (cost0.00..0.00 rows0 width0) Node/s: dn01, dn02 > Gather (cost1000.00..13094.09 rows2503 width61) Workers Planned: 2 > Parallel Seq Scan on tarray (cost0.00..11843.79 rows1043 width61) Filter: (mc @> ((('{'::text 'c4ca4238a0b923820dcc509a6f75849b'::text) '}'::text))::text[]) (6 rows) Time: 21.368 ms teledb select from tarray where mc @> ('{'md5('1')'}')::text[]; id mc + 1 {c4ca4238a0b923820dcc509a6f75849b} (1 row) Time: 431.788 ms teledb

本文为您介绍SELECT语法的特殊应用场景，例如多行变成单行和一列变成多行。 多行变成单行 teledb select arraytostring(array(select nickname from teledbpg1),','); arraytostring test,pg (1 row) 一列变成多行 teledb insert into teledbpg1 values(6, 'teledb, teledb1'); INSERT 0 1 teledb select regexpsplittotable((select nickname from teledbpg1 where id6 limit 1), ','); regexpsplittotable teledb teledb1 (2 rows)

本页为您介绍如何查询元数据表。 1. 通过telesql连接到CN节点。 2. 执行psql命令 “dn”，查看schema trash是否存在。 3. 执行psql命令 “dt trash.”，查看元数据表trashtable是否存在 4. 执行sql “select from trash.trashtable;”。

本页为您介绍查询所有历史数据的方法。 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); xmintime xmaxtime tableoid ctid xmin xmax cmin cmax dead bar baz ++++++++++ 20231102 16:42:15.694944+08 20231102 16:42:22.213469+08 16432 (0,1) 677 678 0 0 t 1 aaa 20231102 16:42:15.694944+08 20231102 16:42:28.684133+08 16432 (0,2) 677 679 0 0 t 2 bbb 20231102 16:42:47.230036+08 16432 (0,3) 680 0 0 0 f 5 eee 20231102 16:42:54.18001+08 20231102 16:43:00.369209+08 16432 (0,4) 681 682 0 0 f 6 fff 20231102 16:42:15.694944+08 20231102 16:42:34.764626+08 16432 (0,1) 657 658 0 0 t 3 ccc 20231102 16:42:34.764626+08 20231102 16:42:41.46109+08 16432 (0,2) 658 659 0 0 f 3 cccnew 20231102 16:42:41.46109+08 16432 (0,3) 659 0 0 0 f 3 cccnew2 (7 rows)

本页为您介绍创建插件的操作步骤。 1. 通过telesql连接到CN节点。 2. 执行sql “create extension pgdirtyread;” 3. 执行telesql命令dx，查看插件pgdirtyread是否存在。

本文为你介绍合并多个查询结果的方法。 不过滤重复的记录。 teledb create table teledbpg1(id int, nickname varchar); CREATE TABLE teledb insert into teledbpg1 values(3, 'pg'),(5,'test'); COPY 2 teledb select from teledbpg union all select from teledbpg1; id nickname + 1 teledb 1 hello,pgxc 2 TELEDB 3 pg 4 5 test 3 pg (7 rows) 过滤重复的记录。 teledb select from teledbpg union select from teledbpg1; id nickname + 1 teledb 1 hello,pgxc 4 5 test 2 TELEDB 3 pg (6 rows) 每个子查询分布在合并结果中的使用。 teledb select from (select from teledbpg limit 2) as t union all select from (select from teledbpg1 limit 2) teledb ; id nickname + 1 teledb 1 hello,pgxc 5 test 3 pg (4 rows)

本文为您介绍如何管理表达式索引。 teledb create table tupper(id int,mc text); CREATE TABLE teledb create index tuppermc on tupper(mc); CREATE INDEX teledb insert into tupper select t,md5(t::text) from generateseries(1,10000) as t; INSERT 0 10000 teledb analyze tupper; ANALYZE teledb explain select from tupper where upper(mc)md5('1'); QUERY PLAN Remote Fast Query Execution (cost0.00..0.00 rows0 width0) Node/s: dn01, dn02 > Seq Scan on tupper (cost0.00..133.58 rows25 width37) Filter: (upper(mc) 'c4ca4238a0b923820dcc509a6f75849b'::text) (4 rows) teledb create index tuppermc on tupper(upper(mc)); ERROR: relation "tuppermc" already exists teledb create index tuppermc1 on tupper(upper(mc)); CREATE INDEX teledb explain select from tupper where upper(mc)md5('1'); QUERY PLAN Remote Fast Query Execution (cost0.00..0.00 rows0 width0) Node/s: dn01, dn02 > Bitmap Heap Scan on tupper (cost4.48..50.94 rows25 width37) Recheck Cond: (upper(mc) 'c4ca4238a0b923820dcc509a6f75849b'::text) > Bitmap Index Scan on tuppermc1 (cost0.00..4.47 rows25 width0) Index Cond: (upper(mc) 'c4ca4238a0b923820dcc509a6f75849b'::text) (6 rows)

本文介绍使用SELECT语法时，not in中包含了null，结果全为真的场景。 teledb select from teledbpg where id not in (1,3); id nickname + 2 TELEDB 4 (2 rows) teledb select from teledbpg where id not in (1,3,null); id nickname + (0 rows)

本文介绍只查询某个DN数据的操作。 teledb execute direct on (dn01) 'select from teledbpg'; id nickname + 1 teledb 1 hello,pgxc 2 TELEDB (3 rows) teledb execute direct on (dn02) 'select from teledbpg'; id nickname + 3 pg 4 (2 rows)

本文介绍如何在使用SELECT语法时进行聚集查询，例如统计记录数、不重复值的记录表，以及求和等。 统计记录数。 teledb select count(1) from teledbpg; count 5 (1 row) 统计不重复值的记录表。 teledb select count(distinct id) from teledbpg; count 4 (1 row) 求和。 teledb select sum(id) from teledbpg; sum 11 (1 row) 求最大值。 teledb select max(id) from teledbpg; max 4 (1 row) 求最小值。 teledb select min(id) from teledbpg; min 1 (1 row) 求平均值。 teledb select avg(id) from teledbpg; avg 2.2000000000000000 (1 row)

本文介绍如何在使用SELECT语法时添加all条件。 需要大于所有值才为真。 teledb select from teledbpg where id > all (select 1 union select 3); id nickname + 4 (1 row)

本文为您介绍如何删除数据表。 删除当前模式下的数据表。 teledb drop table t; DROP TABLE 删除某个模式下数据表。 teledb d+ t Table "public.t" Column Type Collation Nullable Default Storage Stats target Description +++++++ id integer plain mc text extended Distribute By: SHARD(id) Location Nodes: ALL DATANODES teledb d+ tas Table "public.tas" Column Type Collation Nullable Default Storage Stats target Description +++++++ id integer plain mc text extended Distribute By: SHARD(id) Location Nodes: ALL DATANODES teledb drop table public.test; DROP TABLE 删除数据表，当表不存在时不执行该操作，也不会报错。 teledb drop table IF EXISTS t; NOTICE: table "t" does not exist, skipping DROP TABLE 使用CASCADE无条件删除数据表。 teledb create view shardview as select from testshard; CREATE VIEW teledb drop table testshard; ERROR: cannot drop table testshard because other objects depend on it DETAIL: view shardview depends on table testshard HINT: Use DROP ... CASCADE to drop the dependent objects too. teledb drop table testshard cascade; NOTICE: drop cascades to view shardview DROP TABLE

本文为您介绍SELECT语法中多表关联的使用方法。 内连接 teledb select from teledbpg inner join teledbpg1 on teledbpg.id teledbpg1.id; id nickname id nickname +++ 3 pg 3 pg (1 row) 左外连接 teledb select from teledbpg left join teledbpg1 on teledbpg.id teledbpg1.id; id nickname id nickname +++ 1 teledb 1 hello,pgxc 2 TELEDB 3 pg 3 pg 4 (5 rows) 右外连接 teledb select from teledbpg right join teledbpg1 on teledbpg.id teledbpg1.id; id nickname id nickname +++ 5 test 3 pg 3 pg (2 rows) 全连接 teledb select from teledbpg full join teledbpg1 on teledbpg.id teledbpg1.id; id nickname id nickname +++ 1 teledb 3 pg 3 pg 4 1 hello,pgxc 2 TELEDB 5 test (6 rows)

exists 只要有记录返回就为真 teledb select from teledbpg where exists(select from person where person.id teledbpg.id); id nickname + 1 teledb 1 hello,pgxc 2 TELEDB 3 pg (4 rows) exists 等价写法 teledb select teledbpg. from teledbpg, (select distinct id from person) as t where t.id teledbpg.id; id nickname + 1 teledb 1 hello,pgxc 2 TELEDB 3 pg (4 rows)

本文为您介绍如何增加一个复合类型。 增加一个复合类型 teledb create type mytype as (f1 int,f2 varchar(10)); CREATE TYPE

创建jsonb类型字段表 teledb create table tjsonb(id int,fjsonb jsonb); CREATE TABLE 插入数据 teledb insert into tjsonb values(1,'{"col1":1,"col2":"teledb"}'); INSERT 0 1 teledb insert into tjsonb values(2,'{"col1":1,"col2":"teledb","col3":"pgxz"}'); INSERT 0 1 teledb select from tjsonb; id fjsonb + 1 {"col1": 1, "col2": "teledb"} 2 {"col1": 1, "col2": "teledb", "col3": "pgxz"} (2 rows jsonb插入时会移除重复的键，如下所示。 teledb insert into tjsonb values(3,'{"col1":1,"col2":"teledb","col2":"pgxz"}'); INSERT 0 1 teledb select from tjsonb; id fjsonb + 1 {"col1": 1, "col2": "teledb"} 2 {"col1": 1, "col2": "teledb", "col3": "pgxz"} 3 {"col1": 1, "col2": "pgxz"} (3 rows) 更新数据 增加元素。 teledb update tjsonb set fjsonb fjsonb '{"col3":"pgxz"}'::jsonb where id1; UPDATE 1 teledb select from tjsonb; id fjsonb + 2 {"col1": 1, "col2": "teledb", "col3": "pgxz"} 1 {"col1": 1, "col2": "teledb", "col3": "pgxz"} 3 {"col1": 1, "col2": "pgxz"} (3 rows) 更新原来的元素。 teledb