Hash Clustering
SELECT t1.a,t1.b FROM t1 WHERE t1.id=12345;对于普通表，这个通常意味着全表扫描操作，如果表非常大的情况下，资源消耗量是非常大的。但是因为我们已经对 id 做Hash Shuffle，并且对 id 做排序，查询可以极大简化：通过查询值 12345 找到...
建表时创建列存索引的DDL语法
示例：SHOW CREATE TABLE test.t1\G*1.row*Table:t1 Create Table:CREATE TABLE `t1`(`id` int(11)NOT NULL,`col1` int(11)DEFAULT NULL,PRIMARY KEY(`id`))ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='columnar=1' SHOW CREATE TABLE ...
新建及管理质量规则模板
多表查询 select sum(${t1.c1})from${t1} join${t2} on$[t1.id]=$[t2.id]where$[t1.ds]=${bizdate};自定义数据详情校验：通过自定义SQL指定正常、异常数据内容的定义口径，可配置总行数SQL、异常行数SQL、异常数据SQL。总行数SQL：必填，...
重组分区
示例2：重组多个一级LIST分区 假设l_t1与l_t2都采用List分区，建表SQL如下所示：CREATE TABLE `l_t1`(`a` bigint(20)UNSIGNED NOT NULL,`b` bigint(20)UNSIGNED NOT NULL,`c` datetime NOT NULL,`d` varchar(16)NOT NULL,`e` varchar(16)...
ePQ支持分区表查询
segments:6)->Append->Partial Seq Scan on t1_p1 Filter:(id)Optimizer:PolarDB PX Optimizer(5 rows)由于查询的过滤条件 id包含分区键，因此ePQ优化器可以根据分区表的分区边界，在产生执行计划时去掉不符合过滤条件的子分区（t1_p2、t1_...
ePQ支持分区表查询
segments:6)->Append->Partial Seq Scan on t1_p1 Filter:(id)Optimizer:PolarDB PX Optimizer(5 rows)由于查询的过滤条件 id包含分区键，因此ePQ优化器可以根据分区表的分区边界，在产生执行计划时去掉不符合过滤条件的子分区（t1_p2、t1_...
CREATE MATERIALIZED VIEW
create materialized view mv lifecycle 7 partitioned on(ds)clustered by id sorted by value into 1024 buckets as select t1.id,t1.value,t1.ds as ds from t1 join t2 on t1.id=t2.id;示例四：假设有一张页面访问表visit_records，...
Statement Outline
DUPSWEEDOUT)*/|2|0|SELECT*FROM `t1` WHERE `t1`.`col1` IN(SELECT `col1` FROM `t2`)|30|outline_db|b4369611be7ab2d27c85897632576a04bc08f50b928a1d735b62d0a140628c4c|USE INDEX|1|ind_1|3|0|SELECT*FROM `t1` WHERE `t1`.`col1`=?...
表表达式
条件连接 T1 {[INNER]|{ LEFT|RIGHT|FULL }[OUTER]} JOIN T2 ON boolean_expression T1 {[INNER]|{ LEFT|RIGHT|FULL }[OUTER]} JOIN T2 USING(join column list)T1 NATURAL {[INNER]|{ LEFT|RIGHT|FULL }[OUTER]} JOIN T2 INNER 和 OUTER ...
表表达式
条件连接 T1 {[INNER]|{ LEFT|RIGHT|FULL }[OUTER]} JOIN T2 ON boolean_expression T1 {[INNER]|{ LEFT|RIGHT|FULL }[OUTER]} JOIN T2 USING(join column list)T1 NATURAL {[INNER]|{ LEFT|RIGHT|FULL }[OUTER]} JOIN T2 INNER 和 OUTER ...
SELECT
如下两条SQL等价：SELECT*FROM t1 INNER JOIN t2 WHERE t1.id>10 SELECT*FROM t1,t2 WHERE t1.id>10 USING(column_list)指定连接两表中都存在的列名，PolarDB-X 会按照这些列构建等值条件。如下两条SQL等价：a LEFT JOIN b USING(c1,c2)a ...
SELECT
如下两条SQL等价：SELECT*FROM t1 INNER JOIN t2 WHERE t1.id>10 SELECT*FROM t1,t2 WHERE t1.id>10 USING(column_list)指定连接两表中都存在的列名，PolarDB-X 1.0 会按照这些列构建等值条件。如下两条SQL等价：a LEFT JOIN b USING(c1,c2...
pg_hint_plan
示例命令如下：/*+NestLoop(t1 t2)MergeJoin(t1 t2 t3)Leading(t1 t2 t3)*/SELECT*FROM table1 t1 JOIN table table2 t2 ON(t1.key=t2.key)JOIN table table3 t3 ON(t2.key=t3.key);说明 其中 NestLoop(t1 t2)：指定表t1和t2的连接方法。...
pg_hint_plan
示例命令如下：/*+NestLoop(t1 t2)MergeJoin(t1 t2 t3)Leading(t1 t2 t3)*/SELECT*FROM table1 t1 JOIN table table2 t2 ON(t1.key=t2.key)JOIN table table3 t3 ON(t2.key=t3.key);说明 其中 NestLoop(t1 t2)：指定表t1和t2的连接方法。...
告警时间设置说明
概览 告警中涉及到时间设置，在告警流程中的执行时序如下：时间设置 功能 时间设置 含义 应用监控告警规则 检查最近T 1 分钟的指标 告警检查时，对应用监控指标 T 1 分钟内的数据进行聚合计算。Prometheus告警规则 告警规则检查周期T 2 ...
Common Table Expression简介
使用示例 接下来通过几个具体的例子来展示如何使用CTE WITH T_CTE(i1_cte,i2_cte)AS(SELECT i1,i2 FROM t1)SELECT*FROM T_CTE 上图是一个最简单的CTE，在SELECT语句中直接输出了CTE定义的结果集 WITH T_CTE(i1_cte,i2_cte)AS(SELECT i1,i2 ...
Common Table Expresssion（>=3.7.5）简介
使用示例 接下来通过几个具体的例子来展示如何使用CTE WITH T_CTE(i1_cte,i2_cte)AS(SELECT i1,i2 FROM t1)SELECT*FROM T_CTE 上图是一个最简单的CTE，在SELECT语句中直接输出了CTE定义的结果集 WITH T_CTE(i1_cte,i2_cte)AS(SELECT i1,i2 ...
Common Table Expresssion（>=3.7.5）简介
使用示例 接下来通过几个具体的例子来展示如何使用CTE WITH T_CTE(i1_cte,i2_cte)AS(SELECT i1,i2 FROM t1)SELECT*FROM T_CTE 上图是一个最简单的CTE，在SELECT语句中直接输出了CTE定义的结果集 WITH T_CTE(i1_cte,i2_cte)AS(SELECT i1,i2 ...
数据查询最佳实践
在明确t2与t1表都有同样的time和type过滤条件情况下，建议修改为如下SQL：Select count(*)from t1 join t2 on t1.id=t2.id where t1.time between '2017-12-10 00:00:00' and '2017-12-10 23:59:59' and t1.type=100 and t2.time between '...
数据倾斜调优
SELECT t1.ip,t1.is_anon,t1.user_id,t1.user_agent,t1.referer,t2.ssl_ciphers,t3.shop_province_name,t3.shop_city_name FROM<viewtable>t1 LEFT OUTER JOIN<other_viewtable>t2 ON t1.header_eagleeye_traceid=t2.eagleeye_traceid LEFT...
不兼容SQL重写
示例 不推荐写法 select*from t1 join t2 on t1.double_value=t2.string_value;Warning信息 WARNING:[1,48]implicit conversion from STRING to DOUBLE,potential data loss,use CAST function to suppress 推荐改法 select*from t1 join t...
定制执行计划（pg_hint_plan）
示例命令如下：/*+NestLoop(t1 t2)MergeJoin(t1 t2 t3)Leading(t1 t2 t3)*/SELECT*FROM table1 t1 JOIN table table2 t2 ON(t1.key=t2.key)JOIN table table3 t3 ON(t2.key=t3.key);行号纠正提示 行号纠正提示会纠正由于计划器限制而导致的...
WITH
WITH子句可用于多子查询 WITH t1 AS(SELECT a,MAX(b)AS b FROM x GROUP BY a),t2 AS(SELECT a,AVG(d)AS d FROM y GROUP BY a)SELECT t1.*,t2.*FROM t1 JOIN t2 ON t1.a=t2.a;WITH子句中定义的关系可以互相连接 WITH x AS(SELECT a FROM t),...
画像分析-BSI优化方案（Beta）
SELECT sum(kv[1])AS total_gmv,-总GMV sum(kv[1])/sum(kv[2])AS avg_gmv-人均GMV FROM(SELECT bsi_sum(t1.gmv_bsi,t2.crowd)AS kv,t1.bucket FROM(SELECT gmv_bsi,bucket FROM bsi_gmv WHERE category='3C' AND ds=CURRENT_DATE-interval ...
OpenAPI手册
abfb-4f78-9b73-580cc9fd48be","state":"SKIPPED","table":"t1"}]},{"jobName":"workflow-36c61d1240f84ecfbb472751a29b6deb","tableNames":["t1","t2"],"dst":"*.*.*.*","fullJobs":[{"jobName":"fulldata-9014e168fccd433dbd56bcc61ba4...
如何使用HINT（5.2及以下版本适用）
TDDL:t1.id=1 and t2.id=1*/UPDATE t1 SET val=(SELECT val FROM t2 WHERE id=1)WHERE id=1\G*1.row*GROUP_NAME:TEST_DRDS_1485327111630IXLWTEST_DRDS_IGHF_0001_RDS SQL:UPDATE `t1_2` AS `t1` SET `val`=(SELECT val FROM `t2_2` AS `t2...
oss_fdw
QUERY PLAN-Aggregate(cost=6.54.6.54 rows=1 width=8)->Foreign Scan on t1_oss(cost=0.00.6.40 rows=54 width=0)Directory on OSS:archive/Number Of OSS file:1 Total size of OSS file:1292 bytes(5 rows)SELECT COUNT(*)FROM t1_oss;...
oss_fdw
QUERY PLAN-Aggregate(cost=6.54.6.54 rows=1 width=8)->Foreign Scan on t1_oss(cost=0.00.6.40 rows=54 width=0)Directory on OSS:archive/Number Of OSS file:1 Total size of OSS file:1292 bytes(5 rows)SELECT COUNT(*)FROM t1_oss;...
oss_fdw
QUERY PLAN-Aggregate(cost=6.54.6.54 rows=1 width=8)->Foreign Scan on t1_oss(cost=0.00.6.40 rows=54 width=0)Directory on OSS:archive/Number Of OSS file:1 Total size of OSS file:1292 bytes(5 rows)SELECT COUNT(*)FROM t1_oss;...
oss_fdw
QUERY PLAN-Aggregate(cost=6.54.6.54 rows=1 width=8)->Foreign Scan on t1_oss(cost=0.00.6.40 rows=54 width=0)Directory on OSS:archive/Number Of OSS file:1 Total size of OSS file:1292 bytes(5 rows)SELECT COUNT(*)FROM t1_oss;...
CASE WHEN
返回结果如下：+-+|id_t|+-+|t1|t2|t2|t3|t3|t3|t3|t3|t3|+-+格式二：select case id when 1 then 't1' when 2 then 't2' else 't3' end as id_t from mf_casewhen;返回结果如下：+-+|id_t|+-+|t1|t2|t3|t3|t3|t3|t3|t3|t3|+-+相关函数 ...
Time travel
左边图展示了数据变化过程，t1-t5代表了事务的时间版本，分别执行了5次数据写入的事务，生成了5个DeltaFile，在t2和t4时刻分别执行了 COMPACTION 操作，生成了两个BaseFile:b1和b2，可见b1已经消除了历史中间状态记录（2,a），只保留最新...
备份规则说明
根据增量备份还原 增量还原与全量还原类似但稍稍复杂，不是 clone 而是 fetch（pull）操作，假设我们现在拥有三个备份的文件，分别为三个时间点产生（T0/T1/T2/T3）,其中：T0:对应的bundle文件为 alibaba_codeup-full-20210224084658....
基于行级安全策略实现SAAS租户数据隔离解决方案
创建普通用户 CREATE USER t1 WITH PASSWORD 'TestPW123!';CREATE USER t2 WITH PASSWORD 'TestPW123!';为普通用户授权 GRANT ALL ON SCHEMA sh_vip TO t1;GRANT ALL ON TABLE sh_vip.t_user TO t1;GRANT ALL ON SCHEMA sh_vip TO t2;GRANT...
计算成本控制
SELECT COALESCE(t1.id,t2.id)AS id,SUM(t1.col1)AS col1,SUM(t2.col2)AS col2 FROM(SELECT id,col1 FROM table1)t1 FULL OUTER JOIN(SELECT id,col2 FROM table2)t2 ON t1.id=t2.id GROUP BY COALESCE(t1.id,t2.id);可以优化为如下语句。...
NESTED TABLE
ID COL1-1 MY_TAB_T('A')2 MY_TAB_T('B','C')3 MY_TAB_T('D','E','F')取消嵌套子表：SQL>SELECT id,COLUMN_VALUE FROM nested_table t1,TABLE(t1.col1)t2;ID COLUMN_VALUE-1 A 2 B 2 C 3 D 3 E 3 F 6 rows selected.PostgreSQL Nested ...
接入设备品牌列表
Legrand 693015 N/A 设备 人脸 二维码 刷卡 蓝牙 可视对讲 Legrand 693061 Legrand 693041 Legrand 693161 Legrand 693141 Legrand 693261 Legrand 693241 Legrand 693461 Legrand 693441 Shidean KE6017T1 Shidean KE6107T1 Shidean KE...
归档为CSV或ORC格式
修改只读状态下的OSS表时，报错信息如下：1036-Table 't1' is read only 示例 在数据库 oss_test 中将OSS表 t 导回至PolarStore。ALTER TABLE `oss_test`.`t` ENGINE=InnoDB;修改InnoDB表 t 的数据，修改完数据之后，再次将InnoDB引擎中的...
Inventory Hint
Query OK,1 row affected(0.00 sec)Rows matched:1 Changed:1 Warnings:0 UPDATE COMMIT_ON_SUCCESS POLARDB_STATEMENT_CONCURRENT_QUEUE 1 ROLLBACK_ON_FAIL TARGET_AFFECT_ROW 1 t SET col1=col1+1 WHERE id=1;Query OK,1 row affected(0...
Oracle2PolarDB：Polardb-O兼容性之fetchsize
适用于 本文适用平台为公有云、专有云、PolarDB Stack和纯软。PolarDB高度兼容Oracle版本。目的 如何通过JDBC驱动导出大量数据。解决办法 Oracle迁移到Polardb-o后，通过JDBC驱动导出大量数据时出现OOM错误，报错如下。...
- 产品推荐
- 这些文档可能帮助您