增量数据同步
说明 配置完解析脚本后，将不再对源端配置的增量字段作解析，直接使用配置脚本在源端查询数据。在页面右侧单击 调度配置，配置任务调度。任务调度支持两种类型，分别为 周期调度 和 一次性调度，本示例选择周期调度，详情内容参考下表。...
查看选项
进入SQL模式，您可以使用SQL语句查询数据 update Update the row in table,it will insert a new row if it is not exist.更新一行数据 update_ts_meta Update attributes for timeseries 更新时间线的属性 use Choose table to use.选择...
MongoDB 6.0新特性概览
可查询加密只允许在客户端查看敏感数据的明文，在查询到达服务器端时会同时包含从KMS获取的加密密钥，然后在服务器端以密文进行查询并返回，最后在客户端利用密钥解密后以明文呈现。可查询加密的特点如下：从客户端加密敏感数据，只有客户...
常见报错
可能原因：由于系统无法连接任务运行的服务器节点，导致无法检测服务器节点到源或目标库的网络是否通畅。解决方法：请 通过钉钉（钉钉通讯客户端下载地址）进入到DTS客户交流钉钉群（群号：68325004196或68640008972），进行咨询。DTS.Msg....
传统型负载均衡CLB的审计事件
传统型负载均衡CLB已与操作审计服务集成，您可以在操作审计中查询用户操作传统型负载均衡产生的管控事件。操作审计支持将管控事件投递到日志服务SLS的LogStore或对象存储OSS的存储空间中，满足实时审计、问题回溯分析等需求。操作审计记录...
SHOW（2.0版）
查询用户的数据库列表。指定 EXTRA 参数，输出关于数据库的更多信息，例如创建者ID、数据库连接信息等。SHOW DATABASES 查询用户的数据库列表。指定 EXTRA 参数，输出关于数据库的更多信息，例如创建者ID、数据库连接信息等。SHOW ...
迁移 PolarDB-X 2.0 数据库的数据至 OceanBase 数据库...
迁移默认按照目标端参数 lower_case_table_names=1 设置，并以小写方式创建目标端数据库对象。源端 PolarDB-X 2.0 数据库所在的服务器需要具备足够的出口带宽，否则会影响数据迁移的效率。全量迁移和增量同步过程中，数据传输会以 Session ...
消息队列Kafka
客户端使用您指定的bootstrap.servers地址连接Kafka服务端，Kafka服务端根据配置向客户端返回集群中各台broker的元信息，包括各台broker的连接地址。客户端使用第一步broker返回的连接地址连接各台broker进行读取或写入。如果Kafka服务端...
计费命令参考
SELECT UDF[NOT COUNT or All]FROM TABLE 查询表数据 收费 SELECT sum(a)FROM table_name;SET FLAG 会话设置 否 SET odps.sql.allow.fullscan=true;JAR MR 运行MapReduce作业 收费 JAR-l ...
如何设计宽表主键
主键的设计限制了数据的查询方式，一条 SELECT 查询语句，Lindorm服务器端会编译为两种查询方式。根据完整的主键查询（get方式），例如 SELECT*FROM table WHERE userid='abc' AND orderid=123。说明 get方式需要知道所有的主键列，即组成...
服务器端加密
文件存储NAS支持服务器端加密功能。当您对文件存储有高安全性或者合规性要求时，建议您开启服务器端加密功能。开启该功能后，NAS会对存储在文件系统中的数据进行加密，访问数据时，NAS自动将加密数据解密后返回给用户。本文介绍服务器端...
Oracle数据源
准备工作5：检查数据库表的数据类型 您可以使用查看表的SQL相关语句（SELECT）查询数据库表的数据类型。示例查看 'tablename' 表数据类型的语句如下。select COLUMN_NAME,DATA_TYPE from all_tab_columns where TABLE_NAME='tablename';...
DB2数据源
否 无 fetchSize 该配置项定义了插件和数据库服务器端每次批量数据获取条数，该值决定了数据同步系统和服务器端的网络交互次数，能够较大的提升数据抽取性能。说明 fetchSize 值过大（>2048）可能造成数据同步进程OOM。否 1024 Writer脚本...
通过外表导入至湖仓版
查询数据。数据表创建成功后，您可以在 AnalyticDB MySQL 中通过SELECT语句查询OSS的数据。SELECT*FROM adb_external_db.person;返回结果如下：+-+-+-+-+|id|name|age|dt|+-+-+-+-+|1|james|10|2023-06-15|2|bond|20|2023-06-15|3|jack|30|...
指定服务器编码格式
您可以指定数据库中服务器的编码格式，作为数据库数据的存储格式。本文以示例的形式介绍 PolarDB 兼容的GBK与GB18030两种编码格式的使用方法。简介 GBK GBK（Chinese Internal Code Specification）即汉字内码扩展规范。GBK共收录21886个...
指定服务器编码格式
您可以指定数据库中服务器的编码格式，作为数据库数据的存储格式。本文以示例的形式介绍 PolarDB 兼容的GBK与GB18030两种编码格式的使用方法。简介 GBK GBK（Chinese Internal Code Specification）即汉字内码扩展规范。GBK共收录21886个...
跨库操作（dblink、postgres_fdw）
postgres=>select dblink_connect('<连接名称>','host=<同一VPC下远端目标数据库所在实例的内网域名>port=<同一VPC下远端目标数据库所在实例的内网监听端口>user=<远端目标数据库用户名>password=<密码>dbname=<远端目标数据库库名>');...
OceanBase 数据库之间的数据迁移
仅适用于 OceanBase 数据库 MySQL 租户的注意事项：OceanBase 数据库 MySQL 租户之间的数据迁移，默认按照目标端参数 lower_case_table_names=1 设置，并以小写方式创建目标端数据库对象。如果源端和目标端的表结构不完全一致，可能会出现...
管理应用（适用于应用镜像）
在 数据库密码 信息后，单击，然后单击 远程连接，在远程连接的命令行中粘贴并运行命令，查询服务器中数据库的管理员登录信息。应用程序安装信息。例如，LAMP镜像中应用程序的安装信息如下图所示。配置应用。例如，您可以在LAMP服务器的...
迁移 Oracle 数据库的数据至 OceanBase 数据库 Oracle...
如果源端存在包含时区信息的数据类型（例如 TIMESTAMP WITH TIME ZONE），请您确保目标端数据库支持并存在源端对应的时区，否则将导致数据迁移过程中产生数据不一致的问题。库表汇聚场景下：建议您使用导入对象或匹配规则的方式映射源端和...
导入数据
本文以导入On Time数据集至clickhouse_demo数据库的分布式表ontime_local_distributed为例，介绍如何使用客户端clickhouse-client工具导入数据到 云数据库ClickHouse。前提条件 已完成快速入门系列的如下步骤。新建集群 创建账号 设置白...
同步 OceanBase 数据库 MySQL 租户的数据至 Analytic...
当源端/目标端中存在 TIMESTAMP 时间类型，且该时间处于夏令时的规定时间范围时，因为源端/目标端对时间格式的处理方式不一致，可能导致源端数据写入目标端产生不一致的问题，存在一个小时的时差。例如，源端/目标端设置 TIMEZONE 为"+8:00...
基础使用
查询数据 SELECT*FROM delta_table;更新数据 给偶数 id 加100。UPDATE delta_table SET id=id+100 WHERE mod(id,2)=0;删除数据 删除偶数 id 的记录。DELETE FROM delta_table WHERE mod(id,2)=0;Merge 创建Source表用于Merge操作。CREATE ...
Flink Table Store与Trino集成
E-MapReduce的Flink Table Store服务支持在Trino中查询数据。本文通过示例为您介绍如何在Trino中查询Flink Table Store中的数据。使用限制 仅EMR-3.45.0版本、EMR-5.11.0版本的集群，支持在Trino中查询Flink Table Store中的数据。操作步骤...
迁移 OceanBase 数据库 Oracle 租户的数据至 Oracle ...
背景信息 在数据传输控制台创建从 OceanBase 数据库 Oracle 租户迁移数据至 Oracle 数据库的数据迁移项目，您可以通过结构迁移、全量迁移和增量同步，无缝迁移源端数据库中的存量业务数据和增量数据至 Oracle 数据库。同时，数据传输支持将...
迁移 RDS PostgreSQL 实例的数据至 OceanBase 数据库 ...
反向增量 反向增量任务开始后，可以实时将业务切换后在目标端数据库产生的变更数据回流至源端数据库。通常反向增量会复用增量同步的配置，您也可以根据实际需求进行自定义配置。单击 下一步。在 选择迁移对象 页面，选择当前数据迁移项目的...
语法兼容性说明
数据库管理语句：表维护语句 ANALYZE TABLE Y CHECK TABLE Y CHECKSUM TABLE Y OPTIMIZE TABLE Y REPAIR TABLE Y 数据库管理语句：组件、插件和可加载函数语句 可加载函数的CREATE FUNCTION语句 Y 拥有MySQL库中表的INSERT或DELETE权限时，...
同步 OceanBase 数据库的数据至 Kafka
背景信息 Kafka 是目前广泛应用的高性能分布式流计算平台，数据传输支持 OceanBase 数据库两种租户与自建 Kafka 数据源之间的数据实时同步，扩展消息处理能力，广泛应用于实时数据仓库搭建、数据查询和报表分流等业务场景。前提条件 数据...
SQL Server数据源
否 无 fetchSize 该配置项定义了插件和数据库服务器端每次批量数据获取条数，该值决定了数据集成和服务器端的网络交互次数，能够提升数据抽取性能。说明 fetchSize 值过大（>2048）可能造成数据同步进程OOM。否 1024 对于您配置的 table、...
将时空数据写入宽表引擎
} } } 查询数据，通过以下方式查询数据流表和宽表的数据。通过流引擎SQL查询数据流表的数据。不使用时空函数查询，在数据流表中执行查询语句时会默认将时空数据转化为WKT格式，有关WKT格式的介绍请参见 空间数据类型。SELECT*FROM gps_data...
CLB健康检查工作原理
负载均衡通过健康检查来判断后端服务器的业务可用性。开启健康检查功能后，当某台后端服务器健康检查出现异常时，负载均衡会自动将新的请求分发到其他健康检查正常的后端服务器上；而当该后端服务器恢复正常运行时，负载均衡会将其自动恢复...
数据加密
服务器端加密 OSS支持在服务器端对上传的数据进行加密（Server-Side Encryption）。上传数据时，OSS对收到的用户数据进行加密，然后再将得到的加密数据持久化保存下来；下载数据时，OSS自动对保存的加密数据进行解密并把原始数据返回给用户...
如何创建Federated表
使用限制 目前仅支持使用公网地址连接远端服务器的数据库。不支持远程连接在ECS上自建的数据库。操作步骤 创建远端Server。语法如下：CREATE SERVER<server_name>FOREIGN DATA WRAPPER mysql OPTIONS(HOST"<host_name>",PORT 3306,USER...
使用Kafka（离线与实时）
通过 使用本地客户端（odpscmd）连接 或其他可以运行MaxCompute SQL的工具，执行如下命令，查询数据写入结果。set odps.sql.allow.fullscan=true;select*from table_text;返回结果如下：#这里由于我们odps-sink-connector.json配置文件中的...
版本发布说明
缺陷修复 修复INFORMATION_SCHEMA中部分视图带IN查询条件导致无法正常查询数据的问题。修复BKA Join在特殊字符场景导致的物理sql语法问题。修复子查询大于等于三个关联项时，关联匹配错乱的问题。修复BKA Join场景下路由计算不正确的问题。...
常见问题（FAQ）
客户提供的加密密钥的服务器端加密 您可以通过将设置spark.databricks.delta.multiClusterWrites.enabled为来禁用多集群写入false。如果禁用它们，对单个表的写入必须来自单个集群。我可以在Databricks Runtime之外访问Delta表吗？有两种...
使用SDK示例代码消费订阅数据
场景 SDK使用模式 查询方法 查询消费位点 ASSIGN模式、SUBSCRIBE模式 由于SDK客户端每5秒保存一次消息位点，并提交至DTS服务器，如需查询最近一次消费位点，您可通过以下路径查询：SDK客户端所在服务器的 localCheckpointStore 文件。...
冷热分离
使用方法 冷存储功能需要HBase增强版服务端升级到2.1.8及以上版本，但无需修改数据读写链路的客户端依赖，只需要选择以下一种方式修改表结构即可：使用Java API：要求AliHBase-Connector 1.0.7/2.0.7以上，请参考 使用Java API访问增强版...
使用SDK示例代码消费订阅数据
场景 SDK使用模式 位点管理方式 查询消费位点 ASSIGN模式、SUBSCRIBE模式 由于SDK客户端每5秒保存一次消息位点，并提交至DTS服务器，如需查询最近一次消费位点，您可通过以下路径查询：SDK客户端所在服务器的 localCheckpointStore 文件。...
使用OSS Foreign Table进行数据湖分析
查询分析OSS数据 查询OSS FDW外表的数据与查询本地表数据方法一样，常见查询如下：键值过滤查询，示例如下：SELECT*FROM ossexample WHERE volume=5;聚合查询，示例如下：SELECT count(*)FROM ossexample WHERE volume=5;过滤、分组和LIMIT...
- 产品推荐
- 这些文档可能帮助您