使用二级索引读取数据
过滤条件为definedcol2列值不等于1且definedcol3列值等于'test'。cond=CompositeColumnCondition(LogicalOperator.AND)cond.add_sub_condition(SingleColumnCondition("definedcol2",1,ComparatorType.NOT_EQUAL))cond.add_sub_condition...
多条件组合查询
param client*/public static void andQuery(SyncClient client){/*查询条件一：RangeQuery，Col_Long的列值大于3。RangeQuery rangeQuery=new RangeQuery();rangeQuery.setFieldName("Col_Long");rangeQuery.greaterThan(ColumnValue....
多条件组合查询
param client*/public static void andQuery(SyncClient client){/*查询条件一：RangeQuery，Col_Long的列值大于3。RangeQuery rangeQuery=new RangeQuery();rangeQuery.setFieldName("Col_Long");rangeQuery.greaterThan(ColumnValue....
过滤器
SingleColumnValueRegexFilter：支持对类型为String的列值，使用正则表达式进行子字符串匹配，然后根据实际将匹配到的子字符串转换为String、Integer或者Double类型，再对子值使用过滤器进行过滤。CompositeColumnValueFilter：根据多个...
配置Kafka输出
键取值列 指定哪些源端列的值拼接后作为Kafka记录Key，如果选择多列，使用逗号作为分隔符拼接列值。如果不选，则Key为空。值取值列 指定哪些源端列的值拼接后作为Kafka记录Value。如果不填写，默认将所有列拼起来作为Value。拼接方式取决于...
数据操作篇
将数据量超出限制的属性列存储到 OSS 中 表格存储限制单个属性列值不超过 2 MB。如需在单个属性列存储超过 2 MB 的数据，如图片、音乐、文件等，可以使用 OSS（Object Storage Service）对其进行存储。OSS 是阿里云提供的开放存储服务，用...
创建表的映射关系
当某属性列值不能为NULL时，请指定该列为NOT NULL。key_part 是 主键列名称。支持设置多个主键列，多个主键列之间用半角逗号（,）分隔。主键列名称必须包含在列名中。ENGINE 否 使用映射表查询数据时的执行引擎。取值范围如下：tablestore...
写入数据
说明 本文示例中的pkValue均表示主键列值，使用时请根据实际填写具体数据。写入方式 表格存储 提供的数据写入接口包括PutRow、UpdateRow和BatchWriteRow。写入数据时，请根据实际场景选择相应写入方式。写入方式 说明 适用场景 插入单行...
过滤器
SingleColumnValueRegexFilter：支持对类型为String的列值，使用正则表达式进行子字符串匹配，然后根据实际将匹配到的子字符串转换为String、Integer或者Double类型，再对子值使用过滤器进行过滤。CompositeColumnValueFilter：根据多个...
系统列
对于一个可见的行版本，该列值也可能为非零。这通常表示删除事务还没有提交，或者一个删除尝试被回滚。cmax 删除事务中的命令标识符，或者为0。ctid 行版本在其表中的物理位置。注意尽管 ctid 可以被用来非常快速地定位行版本，但是一个行...
嵌套类型查询
示例 查询表中Col_Nested.Sub_Col_Keyword列值为"开心"的数据。嵌套数据示例Col_Nested:'[{Sub_Col_Keyword:"开心"},{Sub_Col_Keyword:"晴天"}]'*/client.search({ tableName:TABLE_NAME,indexName:INDEX_NAME,searchQuery:{ offset:0,...
过滤器
SingleColumnCondition：只判断某个参考列的列值。CompositeColumnCondition：根据多个参考列的列值的判断结果进行逻辑组合，决定是否过滤某行。限制 过滤器的条件支持关系运算（=、!和逻辑运算（NOT、AND、OR），最多支持10个条件的...
局部事务
设置属性列的列名、数据类型和列值，请根据需要添加所需属性列。rowPutChange.addColumn(new Column("col1",ColumnValue.fromString("colvalue")));rowPutChange.addColumn(new Column("col2",ColumnValue.fromLong(10)));PutRowRequest ...
删除数据
condition 支持使用条件更新，可以设置原行的存在性条件或者原行中某列的列值条件。更多信息，请参见 条件更新。示例 删除一行数据 以下示例用于删除数据表中的指定行数据。private static void deleteRow(SyncClient client,String ...
UpdateRow
UpdateType的取值范围如下：PUT：此时value必须为有效的属性列值。如果该列不存在，则新增一列；如果该列存在，则覆盖该列。DELETE：此时该value必须为空，需要指定timestamp。表示删除该列特定版本的数据。DELETE_ALL：此时该value和...
写入数据
更新单行数据 调用 UpdateRow 接口更新一行数据，支持增加和删除一行中的属性列，删除属性列指定版本的数据，或者更新已存在的属性列值。如果更新的行不存在，则新增一行数据。适用于更新已写入数据的场景，例如删除属性列、删除某个数据...
pg_stats_ext
n_distinct pg_ndistinct 列值组合的N-不同计数。如果大于零，则为组合中不同值的估计数量。如果小于零，则为不同值数量的负数除以行数。（当 ANALYZE 认为随着表的增长不同值的数量可能会增加时，使用负数形式；当该列似乎具有固定数量的...
聚合函数
ARG_MAX 返回指定列的最大值对应行的列值。ARG_MIN 返回指定列的最小值对应行的列值。AVG 计算平均值。BITWISE_AND_AGG 计算输入Value的bit AND聚合值。BITWISE_OR_AGG 计算输入Value的bit OR聚合值。COUNT 计算记录数。COUNT_IF 计算指定...
虚拟列
point（含数组）Long Keyword Long Text Double Keyword Double Text 虚拟列目前仅支持用在查询语句中，不能用在ColumnsToGet返回列值，如果需要返回列值，可以指定返回该虚拟列的原始列。通过控制台操作虚拟列 通过控制台在创建多元索引时...
ORDER BY 子句
可选的 ORDERBY 子句具有以下形式：ORDER BY expression[ASC|DESC][,.]expression 可以是输出列的名称或序号（SELECT 列表项），也可以是由输入列值组成的任意表达式。ORDER BY 子句使结果行根据指定的表达式进行排序。根据最左边的表达式...
多元索引虚拟列
虚拟列仅支持用在查询语句中，不能用于SELECT返回列值。如果需要返回列值，请指定返回该虚拟列的原始列。如果多元索引映射关系中包含虚拟列 column_virtual，使用 SELECT*不受影响，返回结果中会自动忽略该虚拟列，但不能使用 SELECT ...
写入数据
该行的第一主键列值为"86"，第二主键列值为6771，属性列有name（string类型）和country（string类型）两列。put-pk '["86",6771]'-attr '[{"c":"name","v":"redchen"},{"c":"country","v":"china"}]' 执行 update 命令更新一行数据。更多...
删除数据
condition 使用条件更新，可以设置原行的存在性条件或者原行中某列的列值条件。更多信息，请参见 条件更新。primary_key 行的主键。说明 设置的主键个数和类型必须和数据表的主键个数和类型一致。return_content 表示返回类型。return_type...
写入数据
condition 使用条件更新，可以设置原行的存在性条件或者原行中某列的列值条件。更多信息，请参见 条件更新。说明 RowExistenceExpectation.IGNORE表示无论此行是否存在均会插入新数据，如果之前行已存在，则写入数据时会覆盖原有数据。...
读取数据
过滤条件为name列值等于'John'且address列值等于'China'。cond=CompositeColumnCondition(LogicalOperator.AND)cond.add_sub_condition(SingleColumnCondition("name","John",ComparatorType.EQUAL))cond.add_sub_condition...
从PolarDB MySQL版同步至Datahub
DELETE 当操作类型为DELETE时，增量日志中所有的列值为被删除的值，即列值不变，所以 dts_before_flag 取值为Y，dts_after_flag 取值为N，示例如下。后续操作 配置完数据同步作业后，您可以对同步到DataHub实例中的数据执行计算分析。更多...
pg_statistic
目录 pg_statistic 存储有关数据库内容的统计数据。...stavalues N anyarray 第 N 个“槽位”的类型的列值，如果该槽位类型不存储任何数据值则为 NULL。每个数组的元素值实际上都是指定列的数据类型或者是一个相关类型（如数组元素类型）。
自然语言到SQL语言转义（基于大语言模型的NL2SQL）
同时，尽量将 条件 前置，然后是需要找的 列值 对应的实体，最后是可能的 列名。示例如下：超过1个房间的“房子”或“公寓”的属性名称是什么？其中，超过1个房间 是条件，房子 和 公寓 是列值对应的实体，属性名称是可能的列名。使用说明 ...
过滤器
RelationalCondition：只判断某个参考列的列值。CompositeCondition：根据多个参考列的列值的判断结果进行逻辑组合，决定是否过滤某行。限制 过滤器的条件支持关系运算（=、!和逻辑运算（NOT、AND、OR），最多支持10个条件的组合。...
名词解释
索引可以看作是表中一个或多个列的快速访问入口，可以根据某个特定的列值快速定位到想要访问的数据。宽表引擎支持多种索引，例如二级索引、搜索索引。时序引擎暂不支持自定义索引。DYNAMIC COLUMN 〇 ✖️ Dynamic Column（动态列）是指在...
创建数据表
该表包含pk1（String类型）和pk2（Integer类型）两列主键且包含defcol1（String类型）和defcol2（Integer类型）两个预定义列，属性列值只保留最新版本数据以及数据永不过期。该全局二级索引的主键列为defcol1、pk1和pk2，属性列为defcol2。...
二级索引
示例 读取第一主键列值为“86”，第二主键列值为6771的行数据。get-pk '["86",6771]' 扫描数据 扫描获取整表中所有数据或者获取最多指定个数的行数据。命令格式 scan-limit limit 配置项说明请见下表。配置项 是否必填 示例值 说明-limit ...
从PolarDB MySQL版同步至Datahub
DELETE 当操作类型为DELETE时，增量日志中所有的列值为被删除的值，即列值不变，所以 dts_before_flag 取值为Y，dts_after_flag 取值为N，示例如下。后续操作 配置完数据同步作业后，您可以对同步到DataHub实例中的数据执行计算分析。更多...
Tablestore数据源
列模式会将数据导出为（主键值，列名，时间戳，列值）的四元组格式，列模式下导入的数据也是（主键值，列名，时间戳，列值）的四元组格式。行模式：该模式将用户每次更新的记录，抽取成行的形式导出，即（主键值，列值）的格式。行模式下每...
最佳实践
Delta-Lake根据列值自动布局文件中的数据，并在查询时使用布局信息跳过不相关的数据。有关详细信息，请参见 Z-Ordering（多维集群）。选择正确的分区列 您可以按列对Delta表进行分区。最常用的分区列是date。遵循以下两个经验法则来确定要...
写入数据
Condition 使用条件更新，可以设置原行的存在性条件或者原行中某列的列值条件。更多信息，请参见 条件更新。示例 以下示例用于插入一行数据。putRowRequest:=new(tablestore.PutRowRequest)putRowChange:=new(tablestore.PutRowChange)...
从RDS MySQL同步至DataHub
DELETE 当操作类型为DELETE时，增量日志中所有的列值为被删除的值，即列值不变，所以 dts_before_flag 取值为Y，dts_after_flag 取值为N，示例如下。后续操作 配置完数据同步作业后，您可以对同步到DataHub实例中的数据执行计算分析。更多...
导入中特殊符号处理
以下命令将空格作为null的匹配字符，如果该列为空格，则在使用OSS文件导入的数据中该列值为null。FORMAT 'text'(null ' ')列中存在转义字符。您可以在转义字符前增加ESCAPE符。ESCAPE符在创建外表时指定，CSV模式缺省值为双引号（”），...
从RDS MySQL同步至DataHub
DELETE 当操作类型为DELETE时，增量日志中所有的列值为被删除的值，即列值不变，所以 dts_before_flag 取值为Y，dts_after_flag 取值为N，示例如下。后续操作 配置完数据同步作业后，您可以对同步到DataHub实例中的数据执行计算分析。更多...
概述
如 SELECT*FROM t1，如果 t1 表中包含 name 和 age 列，则查询结果中的这2列值会被脱敏。当应用程序使用 testAcc 连接数据库，并查询某个表中的 name、age 和 hobby 时，Proxy会将 name 和 age 列的数据进行脱敏后再返回，hobby 列的数据则...
- 产品推荐
- 这些文档可能帮助您