sql
--connect to database,P as sample
CONNECT strmadmin/password@P
--select all table name,database,dml_handlers mode which using streams,and create a temp table T_TMP
CREATE TABLE T_TMP AS (SELECT distinct OBJECT_OWNER,OBJECT_NAME,USER_PROCEDURE
FROM DBA_APPLY_DML_HANDLERS
WHERE USER_PROCEDURE NOT LIKE '%ERRORS%');
--update mode name to SYNC or APPEND
UPDATE T_TMP SET USER_PROCEDURE = 'APPEND' WHERE USER_PROCEDURE LIKE '%CCD%';
UPDATE T_TMP SET USER_PROCEDURE = 'SYNC' WHERE USER_PROCEDURE LIKE '%COPY_ONLY%';
--display the result
SELECT * FROM T_TMP;
--drop the tmp table
DROP TABLE T_TMP;
使用PL/SQL
DECLARE
v_db DBA_APPLY_DML_HANDLERS.OBJECT_OWNER%TYPE;
v_table DBA_APPLY_DML_HANDLERS.OBJECT_NAME%TYPE;
v_mode DBA_APPLY_DML_HANDLERS.USER_PROCEDURE%TYPE;
t_mode DBA_APPLY_DML_HANDLERS.USER_PROCEDURE%TYPE;
CURSOR han_cur IS
SELECT distinct OBJECT_OWNER,OBJECT_NAME,USER_PROCEDURE
FROM DBA_APPLY_DML_HANDLERS
WHERE USER_PROCEDURE NOT LIKE '%ERRORS%';
BEGIN
DBMS_OUTPUT.ENABLE(1000000);
OPEN han_cur;
FETCH han_cur INTO v_db,v_table,v_mode;
WHILE han_cur%FOUND LOOP
IF v_mode LIKE '%CCD%'
THEN
t_mode := 'APPEND';
ELSE IF v_mode LIKE '%COPY%'
THEN
t_mode := 'SYNC';
ELSE
t_mode := v_mode;
END IF;
END IF;
DBMS_OUTPUT.PUT_LINE(v_db||','||v_table||','||t_mode);
FETCH han_cur INTO v_db,v_table,v_mode;
END LOOP;
CLOSE han_cur;
END;
/
分享到:
相关推荐
与Logical Standby技术相比,Streams具有更为灵活的应用场景和配置方式,例如支持异构数据库之间的数据复制以及只针对特定表或用户的部分数据进行复制等功能。 #### Streams的工作原理 **Streams**的核心工作流程...
在Ntfs文件系统中,一些恶意程序可能隐藏在“Ntfs数据流”这样的特殊"文件"中,一般的文件管理器和工具不能发现和处理;Ntfs数据流处理工具NtfsStreamsEditor提供了强大的搜索扫描能力,帮助找出危险所在;同时Ntfs...
Kafka Streams是一个轻量级的库,可以嵌入到任何Java应用程序中。使用Kafka Streams,开发者可以轻松地构建实时应用程序和微服务。 在上述内容中提到了几个关键词汇,它们是:Kafka Streams,实时应用,微服务,流...
Oracle Streams是一种先进的数据复制解决方案,它允许用户在Oracle数据库之间实时传输数据,从而实现数据库的复制、归档、故障恢复和读写分离等多种功能。在本配置文档中,你将找到有关Oracle Streams的全面信息,...
随着 Oracle 数据库的发展,后续版本中可能会有更多新特性和改进。 #### 八、总结 Oracle Streams 是一个非常实用且强大的数据复制解决方案,它为企业级数据库管理提供了极大的便利。通过对数据的实时捕获、传输和...
例如,`fsutil file querystream filename`可以查询文件的特定数据流,而`dir /R`则会在目录列表中显示隐藏的数据流。 总的来说,理解并掌握NTFS数据流的使用对于提高系统的安全性、解决复杂的技术问题以及在CTF...
Oracle Streams 是Oracle数据库提供的一种强大的数据流和事件流解决方案,它允许在单个数据库内或跨多个数据库之间高效地移动数据和事件。Streams的核心功能包括数据捕获、传播和服务应用,支持显式(通过编程方式)...
`web-streams-polyfill` 是一个开源库,它实现了WHATWG 规范中的大部分 Web Streams API,使得开发者可以在不支持原生 Web Streams 的环境中也能使用这一强大的功能。这个库主要包含以下几个部分: 1. **...
赠送jar包:reactive-streams-1.0.3.jar; 赠送原API文档:reactive-streams-1.0.3-javadoc.jar; 赠送源代码:reactive-streams-1.0.3-...人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译,请放心使用。
NTFS(New Technology File System)是Windows操作系统中的...`ntfsstreamseditor`提供了一个方便的界面,帮助用户更好地理解和控制NTFS文件系统中的这一特性。正确使用这个工具,可以提升对文件系统的理解和维护能力。
《Kafka Streams实战》这本书是了解和掌握Apache Kafka的流处理框架Kafka Streams的重要资源。Kafka Streams是一个轻量级的库,允许开发者在Java或Scala应用中直接处理流数据,无需部署额外的集群服务。它将复杂的...
Get an easy introduction to reactive streams in Java to handle concurrency, data streams, and the propagation of change in today's applications. This compact book includes in-depth introductions to ...
- **流处理与状态管理**:这里讨论了流处理过程中的状态管理问题,以及如何在Kafka Streams中有效地管理和利用状态信息。 - **KTable API详解**:这一章节深入探讨了KTable API的功能和使用方法,帮助读者掌握复杂...
赠送jar包:reactive-streams-1.0.3.jar; 赠送原API文档:reactive-streams-1.0.3-javadoc.jar;...人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译,请放心使用。 双语对照,边学技术、边学英语。
4. SQL支持:通过SQL接口,MapR Streams使得对流数据进行查询和分析变得更加简单。 5. 多用途:MapR Streams不仅支持实时数据处理,还可以用于批处理和历史数据分析。 结合Apache Kafka和MapR Streams,可以构建出...
在实际开发中,Reactive Streams可以应用于各种场景,如网络I/O、数据库查询、消息队列等。例如,在Web服务中,它可以帮助我们构建能够优雅地处理大量并发请求的API,同时保持低内存占用和高响应速度。 总结,...
reactive-streams-1.0.3.jar
4. 多个组件和概念:文件中提到了多个组件如processor、sink、masking、branch、filtering、patterns等,这些是Kafka Streams中用于构建复杂数据处理流程的构建块。例如,processor用于处理数据,sink用于输出数据...
6. **代码实现**:在Spring Boot应用中,添加`spring-kafka`和`kafka-streams`依赖。订单服务需要定义Kafka Topic的bean,以便在启动时自动创建。使用`StreamsBuilder`来定义Kafka流,根据订单ID连接来自支付和库存...