当前位置:网站首页>Flink connector Oracle CDC 实时同步数据到MySQL(Oracle12c)
Flink connector Oracle CDC 实时同步数据到MySQL(Oracle12c)
2022-07-29 05:20:00 【Denny辉】
接上一篇文档《Flink connector Oracle CDC 实时同步数据到MySQL(Oracle19c)》上次说的是Oracle19c版的配置方式。在数据同步的过程中遇到了读取数据延迟的情况,需要进行如下配置:
'debezium.log.mining.strategy'='online_catalog',
'debezium.log.mining.continuous.mine'='true'
可是Oracle19c取消了该组件的配置。后面换了Oracle12c版,CDC的配置稍有不同。
不同点在创建用户和授权的地方,需要做一些调整不然在Flink中调用 DBMS_LOGMNR.START_LOGMNR 时出现“用户不存在”的问题。
Error report - ORA-01435: user does not exist ORA-06512: at
“SYS.DBMS_LOGMNR”, line 72 ORA-06512: at line 3
01435. 00000 - “user does not exist”
*Cause:
*Action:
12c的配置如下:
--create C##family user on CDB
CREATE USER C##family IDENTIFIED BY family DEFAULT TABLESPACE LOGMINER_TBS QUOTA UNLIMITED ON LOGMINER_TBS ACCOUNT UNLOCK;
-- allow access to all PDBs to the C##family user
ALTER USER C##family SET CONTAINER_DATA=ALL CONTAINER=CURRENT
-- grant needed permissions
GRANT DBA to C##family ;
GRANT CREATE SESSION TO C##family ;
GRANT CREATE TABLE TO C##family ;
GRANT EXECUTE_CATALOG_ROLE TO C##family ;
GRANT EXECUTE ON DBMS_LOGMNR TO C##family ;
GRANT SELECT ON V_$DATABASE TO C##family ;
GRANT SELECT ON V_$LOGMNR_CONTENTS TO C##family ;
GRANT SELECT ON V_$ARCHIVED_LOG TO C##family ;
GRANT SELECT ON V_$LOG TO C##family ;
GRANT SELECT ON V_$LOGFILE TO C##family ;
GRANT RESOURCE, CONNECT TO C##family ;
12c的坑还挺多,有以下问题:
- 创建用户的时候会提示”空间不存在“,12c和19c不一样,12c的CDB和PDB要分别创建表空间;
在PDB中创建表空间:
查看当前容器:show con_name --查看当前容器;
切换容器到PDB:alter session set container=ORCLSPDB; --转换容器到PDB
切换PDB到容器:alter session set container=CDB$ROOT; --转换容器到CDB
注意:文件名不能和CDB中的一样,如果在不同目录的话没有关系。 - Oracle重启之后连不上了,由于从12开始引入了CDB和PDB,在重启的时候只会默认打开CDB,PDB还处于mount,需要手动开启:
show pdbs; //查询数据库的所有PDB
alter pluggable database orclpdb open; //修改可插拔库orclpdb打开状态
有个一步到位的命令:alter pluggable database all open;–直接打开所有的PDB
贴点命令吧:
删除用户和表空间:
SQL> drop user jack cascade;
SQL> drop tablespace school including contents and datafiles;
边栏推荐
- The difference between link and @import importing external styles
- The completely decentralized programming mode does not need servers or IP, just like a aimless network extending everywhere
- XDFS&空天院HPC集群典型案例
- 性能对比|FASS iSCSI vs NVMe/TCP
- Use QSS to style the form
- xSAN高可用—XDFS与SAN融合焕发新生命力
- Changed crying, and finally solved cannot read properties of undefined (reading 'parsecomponent')
- 改哭了,终于解决了Cannot read properties of undefined (reading ‘parseComponent‘)
- [typescript] learn typescript object types in depth
- 与开源项目同步开发& CodeReview & Pull Request & fork怎么拉取原始仓库
猜你喜欢
随机推荐
Go|gin quickly use swagger
Laravel service container (Application of context binding)
Refresh, swagger UI theme changes
MOVE PROTOCOL全球健康宣言,将健康运动进行到底
Extreme deflation and perpetual motion machine model will promote the outbreak of platofarm
Laravel service container (inheritance and events)
“山东大学移动互联网开发技术教学网站建设”项目实训日志六
DAY15(DAY16拓展):文件包含漏洞
性能对比|FASS iSCSI vs NVMe/TCP
浅谈分布式全闪存储自动化测试平台设计
What is sqlmap and how to use it
Elastic box flex
裸金属云FASS高性能弹性块存储解决方案
Laravel swagger add access password
一文读懂Move2Earn项目——MOVE
农村品牌建设给年轻人的一些机会
JDBC连接数据库详细步骤
量化开发必掌握的30个知识点【什么是分笔逐笔数据】?
记xx公司SQL注入漏洞
重庆大道云行作为软件产业代表受邀参加渝中区重点项目签约仪式