本页为您介绍创建插件的操作步骤。 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)

本文为您介绍如何管理视图，包括创建视图、删除视图和物化视图使用。 创建视图 teledb create view trangeview as select from trange; CREATE VIEW teledb select from trangeview; f1 f2 f3 ++ 1 20230822 11:06:16.9783 1 2 20230822 11:06:16.9783 50 2 20230822 11:06:16.9783 110 3 20230822 11:06:16.9783 100 (4 rows) 数据类型重定义。 teledb drop view trangeview; DROP VIEW teledb create view trangeview as select f1,f2::date from trange; CREATE VIEW teledb select from trangeview; f1 f2 + 1 20230822 3 20230822 2 20230822 2 20230822 (4 rows) 数据类型重定义，以及取别名。 teledb drop view trangeview; DROP VIEW teledb create view trangeview as select f1,f2::date as mydate from trange; CREATE VIEW teledb select from trangeview; f1 mydate + 1 20230822 2 20230822 2 20230822 3 20230822 (4 rows) TeleDB 支持视图引用表或字段改名联动，不受影响。 teledb d+ trangeview View "teledb.trangeview" Column Type Collation Nullable Default Storage Description ++++++ f1 bigint plain mydate date plain View definition: SELECT trange.f1, trange.f2::date AS mydate FROM trange; teledb

本文为您介绍如何管理分区表全局索引。 支持创建分区表全局索引，目前仅支持btree索引类型 建表 CREATE TABLE parentrangetbl( c1 int not null, c2 int not null, c3 int not null ) PARTITION BY RANGE (c1); CREATE TABLE part0100 PARTITION OF parentrangetbl FOR VALUES FROM (0) TO (100); CREATE TABLE part100200 PARTITION OF parentrangetbl FOR VALUES FROM (100) TO (200); CREATE TABLE partdefault PARTITION OF parentrangetbl DEFAULT; 插入数据 INSERT INTO parentrangetbl(c1,c2,c3) SELECT generateseries(50, 100) AS c1, generateseries(50, 100) AS c2, generateseries(50, 100) AS c3; 创建全局索引 CREATE INDEX c3globalidx ON parentrangetbl(c3) GLOBAL; 设置不使用seq scan set enableseqscan TO off; 通过全局索引查询数据 EXPLAIN SELECT c3 FROM parentrangetbl WHERE c3 > 70 AND c3 Index Only Scan using c3globalidx on parentrangetbl (cost0.12..8.14 rows9 width4) Index Cond: ((c3 > 70) AND (c3 < 75)) (3 rows)

本文为您介绍如何创建唯一索引。 创建唯一索引 teledb create unique index tasiduidx on tas using btree(id); CREATE INDEX 非shard key 字段不能建立唯一索引 teledb create unique index tasiduidx on tas using btree(mc); ERROR: Unique index of partitioned table must contain the hash/modulo distribution column.

本页为您介绍如何使用使用 IF NOT EXISTS关键字。 带IF NOT EXISTS 关键字作用表示表不存在时才创建。 teledb create table t(id int,mc text); CREATE TABLE teledb create table t(id int,mc text); ERROR: relation "t" already exists teledb create table IF NOT EXISTS t(id int,mc text); NOTICE: relation "t" already exists, skipping CREATE TABLE

d+ tnativemullistgd Table "public.tnativemullistgd" Column Type Collation Nullable Default Storage Stats target Description ++++++ + f1 bigint not null nextval('tnativemullistf1seq'::regclass) plain f2 integer plain f3 text extended f4 text extended f5 timestamp(0) without time zone plain Partition of: tnativemullist FOR VALUES IN ('广东') Partition constraint: ((f3 IS NOT NULL) AND (f3 ANY (ARRAY['广东'::text]))) Partition key: RANGE (f5) Partitions: tnativemullistgd201701 FOR VALUES FROM ('20170101 00:00:00') TO ('20170201 00:00:00'), tnativemullistgd201702 FOR VALUES FROM ('20170201 00:00:00') TO ('20170301 00:00:00') Distribute By: SHARD(f1) Location Nodes: ALL DATANODES TeleDB支持存在1级和2级分区混用，大家不需要都平级。

insert into public.t3 values(1,'test'); INSERT 0 1 由于teledb模式在第一顺位，且存在同名表，所以始终是teledb模式下的空表 teledb select from t3; id content + (0 rows) 指定public模式去查询可以查到插入的数据 teledb select from public.t3; id content + 1 test (1 row) 访问不在搜索路径的对象时，需要写全路径。 teledb create table test1.t4 (id int, name char); CREATE TABLE teledb select from t4; ERROR: relation "t4" does not exist LINE 1: select from t4; ^ teledb select from test1.t4; id name + (0 rows) 上面出错是因为模式test1没有配置在searchpath搜索路径中。

本文为您介绍如何修改模式属性。 您可参考如下操作修改模式属性。 修改模式名 teledb alter schema teledbschema rename to teledbschemanew; ALTER SCHEMA 修改所有者 teledb dn teledbschemanew List of schemas Name Owner + teledbschemanew teledb (1 row) teledb alter schema teledbschemanew owner to teledbuser; ALTER SCHEMA teledb dn teledbschemanew List of schemas Name Owner + teledbschemanew teledbuser (1 row)

本文为您介绍如何删除模式。 您可执行如下操作删除模式。 teledb drop schema teledbschemaowner; DROP SCHEMA 当模式中存在对象时，则会删除失败，提示如下。 teledb create table teledbschemanew.test(id int); CREATE TABLE teledb drop schema teledbschemanew; ERROR: cannot drop schema teledbschemanew because other objects depend on it DETAIL: table teledbschemanew.test depends on schema teledbschemanew HINT: Use DROP ... CASCADE to drop the dependent objects too. 您可参考如下操作强制删除，会将模式中的对象也级联删除。 teledb drop schema teledbschemanew cascade; NOTICE: drop cascades to table teledbschemanew.test DROP SCHEMA

本文为您介绍实例主机手动创建了teledbx用户导致开通实例失败的问题原因和解决方案。 问题现象 创建实例开通失败。 原因分析 经过查看错误日志，发现其手动创建teledbx用户。由于在开通创建实例时，系统会自动创建teledbx用户，无需手动创建。 解决方案 1. 执行如下命令删除实例主机teledbx用户。 userdel teledbx 2. 在管控台中选择实例管理> 工单管理 ，单击所创建实例行所在的操作 列的重新施工即可。

广州12345政府服务热线，业务的核心TeleDB服务器部署内网，敏感数据部署在这个核心TeleDB实例中，并涉及到130个部门，8千余个分类，4万余条知识点。该系统要求系统具备高安全性，目前存储了6000+加密表，同时要求通信链路加密，数据脱敏，访问白名单，TeleDB的多级安全策略在该业务系统有了完美的落地。该系统的核心系统结构如下：

本文为您介绍实例开通时，勾选备份机导致开通实例失败的问题现象、原因和解决方案。 问题现象 提交工单后，在工单管理中显示实例施工失败。 原因分析 勾选备份机导致开通实例失败。 解决方案 去勾选备份机，重新提交工单。

当提交工单显示系统错误时，您可以参考本文，查看问题现象、问题原因和解决方案。 问题现象 提交工单显示系统错误。 查看日志发现是sql插入有问题，instmanager的vip列插入失败。 原因分析 开通实例使用到了8个vip，给的varchar字符窜长度不够。 解决方案 执行如下命令增加vip列的varchar长度，将其修改为255。 use dcp desc instmanager alter table instmanager modify column vip varchar(255);

添加主机时，如果硬件联通及测试主机失败，则您需要添加安全组，放通监控插件端口。 问题现象 添加主机时，测试连通及硬件检测失败。 原因分析 监控插件端口未放通。 解决方案 添加安全组，放通端口。出现如下图所示，则表示执行成功。

安装后校验 1. 检查容器状态：docker ps grep E 'dmsdas' 2. 检查启动日志：docker logs f 卸载服务 1. 查看容器ID，docker ps grep E 'dmsdas' 2. 停止容器：docker stop 3. 移除容器：docker rm 4. 查看镜像ID：docker images grep E 'dmsdas' 5. 移除镜像：docker rmi

当导入的teledbx内核版本与实例开通的版本选择不一致时，您可以参考本文查看问题现象、问题原因和解决方案。 问题现象 导入的teledbx内核版本与实例开通的版本选择不一致。 原因分析 导入配置库的sql语句数据错误，dcp的README.md文件是6.11版本的规格。 解决方案 修改dcp库的prodtemplate表数据。 mysql> use dcp mysql> select id ,prodversion from prodtemplate; ++ id prodversion ++ 8 5.7 9 6.11 10 6.11 ++ 3 rows in set (0.00 sec) mysql> update prodtemplate set prodversion'6.13' where id9; Query OK, 1 row affected (0.00 sec) Rows matched: 1 Changed: 1 Warnings: 0 mysql> update prodtemplate set prodversion'6.13' where id10; Query OK, 1 row affected (0.01 sec) Rows matched: 1 Changed: 1 Warnings: 0 mysql> select id ,prodversion from prodtemplate; ++ id prodversion ++ 8 5.7 9 6.13 10 6.13 ++ 3 rows in set (0.00 sec)

迁移方案概述 迁移方案是通过源集群的zookeeper 做副本数据同步，架构如下： 前提条件： 要求源、目标集群在同一个网络，源、目标集群的分片数是相同的，另外建议源、目标集群的ck内核版本也一致，避免不同版本使用到的zstd 版本不一致导致merge出错 迁移条件 & 情况： 目标集群必须跟源集群具备相同的分片数，目标集群跟源集群网络相通； 只支持依赖zk的副本表； partitiong同步过程，源集群可正常读写，迁移过程源集群能正常读，但是不能写； 数据同步和迁移过程，不会删除源集群的数据； 数据同步过程源集群下的数据（本地数据 + cos数据）都会同步到目标集群下，因此目标集群下的容量要足够。 迁移步骤： 整体的迁移环节可概括为：创建临时表 （开始同步数据）和正式表 》修改临时表引擎为 MergeTree — 》从临时表把数据转移到正式表 》删除临时表 具体步骤如下： 1、在目标集群的各个分片选择一个节点，加入到tmpcluster里头去（metrika.xml文件中新增tmpcluster），修改目标集群的config.xml文件，把源集群的zk信息配置进来，如果有多个，那分别加入 ip1 2181 ip2 2181 ip3 2181 60000 30000 2、在目标集群上创建临时的副本表，绑定源集群的zk，以ReplicatedMergeTree为例子： CREATE TABLE tablenametmp on cluster tmpcluster ( ... ) ENGINE ReplicatedMergeTree('zookeeper2:path', '{replica}') ... 备注说明： 创建的临时副本表使用临时表名，在正式表后面加tmp。 创建的临时副本表使用的ZooKeeper路径和源端搬迁表的ZooKeeper路径需保持一致。 创建的临时副本表的表结构需和源端搬迁表保持一致。 3、创建完临时副本表之后，集群会自动通过源zk做part同步到目标集群的副本。期间不用做任何处理，可以准备下一步骤工作 （这个过程不要对临时表做任何数据分区操作，因为操作临时表分区就等于操作源集群对应正式表） 4、在目标集群创建正式名字的 副本表，采用默认zookeeper（可直接通过on cluster defaultcluster去创建） 5、同步完成之后，检查源集群和目标集群，各个表数据分布情况，数据准确性校验（查询part数，以及count总数是否匹配，校验数据准确性时最好做到源集群停写） 6、检查无误之后，在目标集群metadata 目录下，修改所有临时表的sql，把Engine均改成MergeTree （这步是为了迁移过程影响到源集群，保证源集群的数据可读），修改完后重启集群 —— 有现成脚本 7、执行DETACH 命令对临时表中的每个partition DETACH，然后登入目标集群，把临时表下detached目录的所有part mv 到对应的目标表的detached 目录下 —— 如果分区多，可用脚本完成，有现成脚本 例如：default 下lineorder表，可以执行 mv /data/clickhouse/clickhouseserver/data/default/lineordertmp/ detached/ /data/clickhouse/clickhouseserver/data/default/lineorder/detached/ 例如：default 下lineordertmp临时表，分区有'1992','1993','1994','1995','1996' 第一步：在studio上执行（也可以通过脚本去完成）: ALTER TABLE default.lineordertmp on cluster tmpcluster DETACH PARTITION '1992'; ALTER TABLE default.lineordertmp on cluster tmpcluster DETACH PARTITION '1993'; ALTER TABLE default.lineordertmp on cluster tmpcluster DETACH PARTITION '1994'; ALTER TABLE default.lineordertmp on cluster tmpcluster DETACH PARTITION '1995'; ALTER TABLE default.lineordertmp on cluster tmpcluster DETACH PARTITION '1996'; 第二步：登入到目标集群在各个节点上，执行: mv /data/clickhouse/clickhouseserver/data/default/lineordertmp/detached/ /data/clickhouse/clickhouseserver/data/default/lineorder/detached/ 8、执行attach 命令，把目标表下detached的part加载到表内 —— 如果分区多，可用脚本完成，有现成脚本（可找作者提供） 例如：default 下lineorder表，可以执行 alter table default.lineorder attach partition 'partitionname'; 依次把所有的partition 加载到正式表 9、所有的表迁移完成之后，删除临时表，再删除config.xml文件中的 auxiliaryzookeepers配置； 说明： 数据副本同步过程因为某种原因导致副本服务中断（可能是网络、bug、人为手工停止），再次重启后支持断点续传，不会影响源数据同步传输。 操作过程会涉及到多个partition的 DETACH和 attach命令，同时还需要登入到目标节点执行mv 操作，为了简化工作提高效率，减少过多人为操作而导致的失误，建议 通过批量工具（天翼云ClickHouse提供） + 脚本方式执行（找作者提供） 批量工具：批量分发文件到目标集群各个节点，批量在目标集群各个节点执行命令脚本等 参考脚本：查询一个表下的所有partition 列表，然后执行 DETACH命令， mv 命令 和最后的 attach命令 注意： 在添加临时表之后，源集群表的part就会自动通过zk做part复制，因为数据量很大，建议分批创建临时副本表，以免对源zk造成负载过高，从而影响业务 在临时表数据同步的过程中，一定不要对临时表做任何数据或是分区操作，操作临时表就等于操作源集群对应的正式表 在临时表数据同步过程，不能有ddl变化 方案优点：可支持对巨量副本表（几百个以上）的数据迁移，数据同步过程通过zk 做到后台自动同步，无需干预；同时支持对cos 数据的迁移； 不足：只能迁移ReplicatedMergeTree 引擎表，其它表不支持这种方案。