存储过程
存储过程提供了事务提交能力，您可以在存储过程执行过程中对事务进行提交。以下示例，存储过程可以实现在循环任务期间及时回收表空间：CREATE PROCEDURE run_procedure()LANGUAGE plpgsql AS$BEGIN FOR i in 1.10 LOOP INSERT INTO t ...
基本原理
如果在事务提交过程中出错，会出现一些分库提交成功、另一些分库失败回滚，产生数据不一致。因而无法保证事务的原子性。而 PolarDB-X 1.0 柔性事务在涉及多个分库时，将根据SQL语句的含义自动生成相应的补偿操作；一旦发生“一些分库提交...
强一致分布式事务
如果事务内写入的数据涉及多个分区，PolarDB-X 的计算节点将会使用两阶段提交（Two-phase Commit Protocol，简称2PC）方式提交事务，即便在事务提交过程中发生节点宕机等问题，基于2PC的事务恢复机制也能确保事务原子性。MVCC多版本 以上面...
Binlog in Redo
由于每个事务提交会对磁盘进行两次I/O操作，虽然Binlog采用了Group Commit的方式合并I/O来提升效率，但两次I/O等待的本质没有改变，影响事务处理的效率，当使用云盘存储时，影响会更明显。I/O合并的效率是由同时提交的并发事务数量决定的，...
X-Engine简介
但是一组事务提交的过程中，还是有大量等待过程的，例如写入日志到磁盘过程中，除了等待落盘无所事事。X-Engine为了进一步提升事务处理的吞吐，使用流水线技术，把提交阶段分为4个独立的更精细的阶段：拷贝日志到缓冲区（Log Buffer）日志...
Multi-Master关键技术介绍
同时，AnalyticDB PostgreSQL版 提供了本地事务和分布式事务提交缓存，用以帮助快速查询本地事务ID（XID）和分布式全局事务ID（GXID）的映射关系。说明 AnalyticDB PostgreSQL版 会保存全局事务的提交日志，用以判断某个事务是否已经提交。...
使用全局临时表
语法 CREATE GLOBAL TEMPORARY|TEMP TABLE table-name { column-definition[,column-definition]*}[ON COMMIT {DELETE|PRESERVE} ROWS]支持ON COMMIT DELETE ROWS子句，即当前事务提交后清空临时表中的数据。支持ON COMMIT PRESERVE ROWS...
使用全局临时表
语法 CREATE GLOBAL TEMPORARY|TEMP TABLE table-name { column-definition[,column-definition]*}[ON COMMIT {DELETE|PRESERVE} ROWS]支持ON COMMIT DELETE ROWS子句，即当前事务提交后清空临时表中的数据。支持ON COMMIT PRESERVE ROWS...
自动切换可用区
异步模式：在事务提交时，不需要等待此次事务产生的redo日志在跨可用区备份节点完成持久化，只需在RW上完成持久化就可以返回事务提交成功。单击 跨可用区数据复制 右侧的 编辑。在弹出的对话框中，选择 半同步，单击 确定。关闭跨可用区...
创建存储过程
存储过程是作为单个 SPL 程序语句调用的独立 SPL 程序。调用时，存储过程可选择以输入参数的形式从调用方接收值，并可选择以输出参数的形式向调用方返回值。CREATE PROCEDURE 命令可定义并命名一个将存储在数据库中的独立存储过程。如果...
局部事务
在局部事务提交、丢弃或超时后，对应的锁也会被释放。带有局部事务ID的读写请求失败不会影响局部事务本身的存活情况，您可以指定重试规则进行重试或者主动丢弃当前局部事务。接口 对局部事务进行操作的接口说明请参见下表。接口 说明 ...
CREATE PROCEDURE
定义新存储过程。语法 CREATE[OR REPLACE]PROCEDURE name[(parameters)][IMMUTABLE|STABLE|VOLATILE|DETERMINISTIC|[NOT]LEAKPROOF|CALLED ON NULL INPUT|RETURNS NULL ON NULL INPUT|STRICT|[EXTERNAL]SECURITY INVOKER|[EXTERNAL]...
Kafka集群的数据存储格式
posttime 事务提交至目标库的时间。示例如下：插入数据：{"meta":{"time":"2017-06-16T14:24:34","userid":84,"op":"ins","scn":"14589063118712","rowid":"AAATGpAAIAAItcIAAA","trans":"7.0.411499","seq":1,"size":11,"table":"CL_BIZ1....
Kafka集群的数据存储格式
posttime 事务提交至目标库的时间。示例如下：插入数据：{"meta":{"time":"2017-06-16T14:24:34","userid":84,"op":"ins","scn":"14589063118712","rowid":"AAATGpAAIAAItcIAAA","trans":"7.0.411499","seq":1,"size":11,"table":"CL_BIZ1....
事务与Read/Write Concern
在事务提交之前，不会将未提交的写入数据复制到从节点。一旦事务被提交，写入的数据将被复制并自动应用于所有副本集中的从节点。在修改文档时，事务将锁定文档，使文档无法被其他操作更改，直至事务完成。如果一个事务无法获得它需要修改...
租户自定义监控报表
事务 transaction_commit_count 每秒提交事务数。transaction_count 每秒处理事务数。transaction_rollback_count 每秒回滚事务数。transaction_timeout_count 每秒超时事务数。transaction_commit_rt 事务平均提交耗时。transaction_...
基本概念
事务状态（TransactionResolution）云消息队列 RocketMQ 版 中事务消息发送过程中，事务提交的状态标识，服务端通过事务状态控制事务消息是否应该提交和投递。事务状态包括事务提交、事务回滚和事务未决。更多信息，请参见 事务消息。消费...
创建和使用EMR资源
DataWorks支持可视化创建EMR（E-MapReduce）JAR、EMR（E-MapReduce）FILE资源，用于上传提交自定义函数或开源MR示例源码作为资源，便于EMR 计算节点的数据开发过程中引用。本文为您介绍如何创建资源，并上传提交资源，为资源的使用做好前期...
文件存储
Master读写共享存储 Replica本地存放一份 pg_commit_ts 已提交事务的时间。pg_multixact 子事务的信息。pg_version 版本信息。所有节点各自存储一份 postgresql.auto.conf 参数配置文件，优先级大于postgresql.conf。postmaster.opts 记录...
管理存储过程
概述 在 OceanBase 开发者中心（OceanBase Developer Center，ODC）首页单击连接名进入连接后，在左导航栏中单击 存储过程 标签可查看存储过程列表，在存储过程列表中显示当前连接的数据库中存在的存储过程对象。在存储过程列表中，可查看...
非持久设置
持久性是数据库的一个保证已提交事务的记录的特性（即使是发生服务器崩溃或断电）。然而，持久性会明显增加数据库的负荷，因此如果你的站点不需要这个保证，本数据库可以被配置成运行更快。在这种情况下，你可以调整下列配置来提高性能。...
性能监控
计算节点 TPS 展示所选择节点的每秒事务数，包括每秒提交事务数、每秒死锁事务数、每秒回滚事务数等等。CPU使用率 展示所选择节点的CPU使用率。内存使用率 展示所选择节点的内存使用率。连接 展示所选择节点的当前总连接数、活跃连接数和...
性能监控
计算节点 TPS 展示所选择节点的每秒事务数，包括每秒提交事务数、每秒死锁事务数、每秒回滚事务数等等。CPU使用率 展示所选择节点的CPU使用率。内存使用率 展示所选择节点的内存使用率。连接 展示所选择节点的当前总连接数、活跃连接数和...
将Oracle数据同步到表格存储
通过Tapdata Cloud的可视化界面，您可以将Oracle数据实时同步到表格存储（Tablestore）中。前提条件 使用Tapdata Cloud同步Oracle数据到表格存储前，需要完成如下准备工作。已注册 Tapdata Cloud账号。已创建表格存储实例和表。具体操作，...
消息队列Kafka
说明 由于云存储的 云消息队列 Kafka 版 不支持幂等和事务写入，您将无法使用Kafka结果表提供的精确一次语义exactly-once semantic功能，同时您需要在结果表中添加配置项 properties.enable.idempotence=false 以关闭幂等写入功能。...
由于日志文件过多导致集群存储空间被占满的解决办法
PolarDB的只读节点与读写节点共享存储，只读节点上的未提交的大事务同样会影响Undo log的清理，在kill掉事务对应的线程后，Undo会停止继续扩大。如果需要回收Undo文件，您可以通过如下步骤确定Undo history推进情况后，再进行Undo文件的...
创建子存储过程
PRAGMA AUTONOMOUS_TRANSACTION PRAGMA AUTONOMOUS_TRANSACTION是将子存储过程设置为自治事务的指令。declarations declarations是变量、游标、类型或子程序声明。如果包括子程序声明，则它们必须在所有其他变量、游标和类型声明之后。...
Binlog Cache Free Flush
在有大事务的业务场景中，大事务提交时常会出现Binlog耗时过长、实例长时间不可写或夯住（hang）的问题。RDS MySQL引入的Binlog Cache Free Flush功能，对大事务提交写Binlog的阶段做了优化，有效解决了该问题，能够提升实例的稳定性。前提...
分布式事务
二阶段事务会将事务分为以下两个阶段：准备（PREPARE）阶段：在PREPARE阶段，数据节点会准备好所有事务提交所需的资源（例如加锁、写日志等）。提交（COMMIT）阶段：在COMMIT阶段，各个数据节点才会真正提交事务。当提交一个分布式事务时，...
常见问题
柔性事务只有在事务提交阶段因为网络、数据库或实例故障导致意外失败后才产生脏读和回滚覆盖风险。正常事务提交、回滚是不会产生脏读和回滚覆盖风险的。柔性事务能否全局开启？正确使用柔性事务需要对业务流程做一定优化改造，如果全局开启...
LISTEN
第一次设置侦听会话时有一个竞争条件：如果并发提交的事务正在发送通知事件，那么新的侦听会话将接收在事务提交步骤中的一瞬间之后所有提交的事件。但这比事务在查询中可能观察到的任何数据库状态都要晚一些。这将导致使用 LISTEN 的以下...
发起方配置
业务方法正常返回则分布式事务提交，业务方法抛出异常则分布式事务回滚。示例如下：public class YourClass{@DtxTransaction(bizType="yourbizType")public void yourMethod(yourParams){ try{/可以是 FMT 参与者数据源 DAO1;DAO2;DAO N;...
使用 API 开启事务
} try {/业务逻辑/全局事务提交 tx.commit();logger.info("GTS Committed:"+xid);} catch(Throwable ex){ try {/全局事务回滚 tx.rollback();logger.info("GTS Rollbacked:"+xid);} catch(Throwable rollbackFailed){/打印回滚异常并记录...
PolarDB技术内幕
由于整个复制过程不需要等到事务提交后才开始，显著的减少了复制延迟：交易场景优化 针对双十一峰值交易场景，PolarDB 也做了大量优化。Blink Tree 在峰值交易场景中，会有大量涉及热点Page的更新及访问，会导致大量关于这些热点Page的SMO...
CreateLock-创建元数据锁
说明 另外需要注意，lock 有事务语义，只有传入 lock，按照事务隔离性才能获取当前事务的状态，否则看到到是事务提交前的状态。说明 比如一个请求对表已经加了 lock，同时 delete 了改表，但是如果事务没有提交（也就是没有 unlock），这个...
CommitTransaction
如果超过60秒未提交局部事务或丢弃局部事务，则表格存储服务端会认为此局部事务超时，并将局部事务丢弃。未提交的局部事务可能会失效，如果出现此情况，则需要重试该局部事务内的操作。如果未对局部事务范围内的数据进行写操作，则提交局部...
典型场景
PolarDB-X 1.0 支持 balance=balance-100 操作的完美回滚，能够自动生成对应的反向转账语句：UPDATE account SET balance=balance+100 WHERE id='A' 因此即使“分库2”事务提交失败，A的账户金额也可以正确回滚到转账前的状态。优化点：在...
异常事务处理方案
清除异常任务数据 问题现象 事务提交异常，并且业务需求不再需要提交，需要清除异常事务。问题原因 业务代码问题导致事务提交异常。解决方案 进入 dtxserver 的 dtx_remote 库。使用如下命令查询 business_action、business_activity 表中...
TCL语句
1} 参数说明 参数 说明 START TRANSACTION[READ ONLY|READ WRITE]启动新的事务，随后执行的DML语句（即INSERT、UPDATE、DELETE等）直到事务提交时才会生效。READ ONLY子句表示事务以只读方式开启，事务内不允许执行修改操作。READ WRITE...
注意事项
例如，下面就是一个增量更新的SQL语句：UPDATE account SET balance=balance-100 WHERE id='B' AND balance>=100 更新顺序 PolarDB-X 1.0 事务提供的后置执行无法保证后置SQL执行的顺序和事务提交顺序相同。采用增量更新可以避免这一问题，...
- 产品推荐
- 这些文档可能帮助您