IT数码 购物 网址 头条 软件 日历 阅读 图书馆
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
图片批量下载器
↓批量下载图片,美女图库↓
图片自动播放器
↓图片自动播放器↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁
 
   -> 大数据 -> Flink connector Oracle CDC 实时同步数据到MySQL(Oracle12c) -> 正文阅读

[大数据]Flink connector Oracle CDC 实时同步数据到MySQL(Oracle12c)

接上一篇文档《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的坑还挺多,有以下问题:

  1. 创建用户的时候会提示”空间不存在“,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中的一样,如果在不同目录的话没有关系。
  2. 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;
  大数据 最新文章
实现Kafka至少消费一次
亚马逊云科技:还在苦于ETL?Zero ETL的时代
初探MapReduce
【SpringBoot框架篇】32.基于注解+redis实现
Elasticsearch:如何减少 Elasticsearch 集
Go redis操作
Redis面试题
专题五 Redis高并发场景
基于GBase8s和Calcite的多数据源查询
Redis——底层数据结构原理
上一篇文章      下一篇文章      查看所有文章
加:2022-08-06 10:50:33  更:2022-08-06 10:54:05 
 
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁

360图书馆 购物 三丰科技 阅读网 日历 万年历 2024年11日历 -2024/11/23 13:24:05-

图片自动播放器
↓图片自动播放器↓
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
图片批量下载器
↓批量下载图片,美女图库↓
  网站联系: qq:121756557 email:121756557@qq.com  IT数码