本页为您介绍如何禁用或启用定时任务。 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的定时任务。

创建客户端CMK主密钥，用于加密CEK数据密钥。 plaintext CREATE CLIENT MASTER KEY clientmasterkeyname WITH ( KEYSTORE keystorename, KEYPATH "keypathvalue", ALGORITHM algorithmtype ); 参数描述： clientmasterkeyname：密钥对象名，在同一命名空间中满足唯一性约束,长度[1, 64] KEYSTORE：指定管理CMK的密钥工具或组件，取值如下： localkms： 本地KMS netcakms：网证通KMS,数据库内核连接管控的URL来连接KMS。其中，URL通过teledbxmanagerurl GUC配置进行设置，如果更改URL需要断开原有连接重新建立连接。 KEYPATH：KEYSTORE负责管理多个CMK密钥，KEYPATH选项用于在KEYSTORE中唯一标识CMK。其支持的字符范围包括09, az, AZ, 下划线'', 圆点'.'和短横线''。 ALGORITHM：由本语法创建的用于加密CEK，该参数用于指定加密算法的类型，支持 SM2：表示采用国密SM2算法 RSA2048，表示采用RSA算法密码长度为2048位。 RSA3072，表示采用RSA算法密码长度为3072位。

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

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

将创建的算法绑定到schema，表和列上，实现加密算法和数据库对象建立关联。 加密算法绑定到Schema 将创建的算法绑定到schema，实现加密算法和数据库对象建立关联。 plaintext SELECT MLSTRANSPARENTCRYPTALGORITHMBINDSCHEMA( schemaname, algoid) 参数描述： schemaname：要绑定的schema名称 algoid：要绑定的算法ID 加密算法绑定到表 将创建的算法绑定到表上，实现加密算法和数据库对象建立关联。 plaintext SELECT MLSTRANSPARENTCRYPTALGORITHMBINDTABLE( schemaname, tablename, algoid) 参数描述： schemaname：表所属的schema名称 tablename：表名称 algoid：要绑定的算法ID 加密算法绑定到列 将创建的算法绑定到列上，实现加密算法和数据库对象建立关联。 plaintext SELECT MLSTRANSPARENTCRYPTALGORITHMBINDTABLE( schemaname, tablename, attrname, algoid) 参数描述： schemaname：表所属的schema名称 tablename：表名称 attrname：列名称 algoid：要绑定的算法ID

本页为您介绍初始化实例的操作步骤。 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 CREATE TABLE tablename ( 非加密列 noencryptcolumn datatype, 加密列 encryptcolumn1 datatype ENCRYPTED WITH ( COLUMNSENCRYPTIONKEY columnencryptionkeyname1, ENCRYPTIONTYPE DETERMINISTIC ), ...... ); 参数描述： ENCRYPTED WITH列约束： columnencryptionkey：指定加密该列的CEK名称。 encryptiontype：ENCRYPTED WITH约束中的加密类型，可能取 DETERMINISTIC：确定性加密，iv基于明文生成。 RANDOMIZED：随机性加密，iv随机生成。

本页为您介绍全密态的使用和开启说明。 全密态基于数据库不可信，数据库后端是密文，在前端进行数据的加解密操作。Teledb支持psql开启全密态，psql添加C开启全密态可信环境，例如： plaintext psql使用C开启全密态 psql p xxxx d postgres U root C 查询GUC参数验证开启情况 SHOW enablefullencrypt; 查询执行结果为开启： enablefullencrypt on (1 row)

本页为您介绍创建表并插入数据的方法。 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)

本页为您介绍Xcopy的简介和使用方法。 Xcopy模块是支持数据迁移功能的重要组成部分。该模块不仅支持元数据的迁移，还支持表数据的迁移，并提供四种不同的迁移粒度，包括集群级别、数据库级别、Schema级别和表级别的数据迁移。 初始化实例 通过pgxcctl新建一个双CN、双DN的实例，并开启服务。 使用Xcopy进行数据迁移 表级别数据迁移。 plaintext ./Xcopy sourcehost 源库host sourceport 源库端口 sourceuser 源库用户 sourcepassword '源库密码' desthost 目标库host destport 目标库端口 destuser 目标库用户 destpassword '目标库密码' includetable 表名 truncate 模式级别数据迁移。 plaintext ./Xcopy sourcehost 源库host sourceport 源库端口 sourceuser 源库用户 sourcepassword '源库密码' desthost 目标库host destport 源库端口 destuser 目标库用户 destpassword '目标库密码' schema schema名 destschema schema名 truncate 数据库级别数据迁移。 plaintext ./Xcopy sourcehost 源库host sourceport 源库端口 sourceuser 源库用户 sourcepassword '源库密码' desthost 目标库host destport 源库端口 destuser 目标库用户 destpassword '目标库密码' dbname "xcopydb" destdbname "xcopydb" truncatecascade 实例级别数据迁移。 plaintext ./Xcopy sourcehost 源库host sourceport 源库端口 sourceuser 源库用户 sourcepassword '源库密码' desthost 目标库host destport 源库端口 destuser 目标库用户 destpassword '目标库密码'truncatecascade

本页为您介绍如何查询元数据表。 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

创建json 类型字段表 teledb create table tjson(id int,fjson json); CREATE TABLE 插入数据 teledb insert into tjson values(1,'{"col1":1,"col2":"teledb"}'); INSERT 0 1 teledb insert into tjson values(2,'{"col1":1,"col2":"teledb","col3":"pgxz"}'); INSERT 0 1 teledb select from tjson; id fjson + 1 {"col1":1,"col2":"teledb"} 2 {"col1":1,"col2":"teledb","col3":"pgxz"} (2 rows) 通过键获得json对象域 teledb select fjson >'col2' as col2 ,fjson > 'col3' as col3 from tjson; col2 col3 + "teledb" "teledb" "pgxz" (2 rows) 以文本形式获取对象值 teledb select fjson >>'col2' as col2 ,fjson >> 'col3' as col3 from tjson; col2 col3 + teledb teledb pgxz (2 rows) teledb select fjson >>'col2' as col2 ,fjson >> 'col3' as col3 from tjson where fjson >> 'col3' is not null; col2 col3 + teledb pgxz (1 row)

本文介绍如何在使用SELECT语法时进行聚合函数并发计算。 teledb set maxparallelworkerspergather to 0; SET Time: 0.214 ms teledb select count(1) from tcount; count 20000000 (1 row) Time: 2700.569 ms (00:02.701) teledb set maxparallelworkerspergather to 2; SET Time: 0.269 ms teledb select count(1) from tcount; count 20000000 (1 row) Time: 1867.719 ms (00:01.868)

本文介绍如何在使用SELECT语法时，返回两个结果的交集。 teledb select from teledbpg intersect select from teledbpg1; id nickname + 3 pg (1 row)

本文介绍如何在使用SELECT语法时，返回两个结果的差集。 teledb select from teledbpg except select from teledbpg1; id nickname + 2 TELEDB 4 1 teledb 1 hello,pgxc (4 rows)