开云体育官方注册网址Debezium连接器用于Oracle

{"schema":{…}， "payload": {"source": {"version": "1.4.2. "Final"， "connector": "oracle"， "name": "server1"， "ts_ms": 1588252618953， "snapshot": "true"， "db": "ORCLPDB1"， "schema": "开云体育官方注册网址DEBEZIUM"， "table": "CUSTOMERS"， "txId": null， "scn": "1513734"， "commit_scn": "1513734"， "lcr_position": nu开云体育电动老虎机ll}， "databaseName": "ORCLPDB1"，(1）:“schemaName DE开云体育官方注册网址BEZIUM”,(1）创建表"DEBEZIUM "。开云体育官方注册网址\"客户" \n ("ID " NUMBER(9,0) NOT NULL ENABLE， \n "FIRST_NAME " VARCHAR2(255)， \n "LAST_NAME" VARCHAR2(255)， \n "EMAIL " VARCHAR2(255)， \n主键("ID ") ENABLE，\n补充日志数据(ALL)列\n)段创建立即\n PCTFREE 10 PCTUSED 40 INITRANS 1 MAXTRANS 255 \n NOCOMPRESS LOGGING\n STORAGE(INITIAL 65536 NEXT 1048576 MINEXTENTS 1 MAXEXTENTS 2147483645\n PCTINCREASE 0 FREELISTS 1 FREELIST GROUPS 1\n BUFFER_POOL DEFAULT FLASH_CACHE DEFAULT CELL_FLASH_CACHE DEFAULT)\n表空间\"USERS\" "，（2）“tableChanges”:(（3）{"type": "CREATE"，（4）“id”:“\”ORCLPDB1 \”,\“开云体育官方注册网址DEBEZIUM \“\”,\“客户,（5）"表":{(6）"defaultCharsetName": null， "primaryKeyColumnNames": [(7）"ID"]， "columns": [（8）{"name": "ID"， "jdbcType": 2， "nativeType": null， "typeName": "NUMBER"， "typeExpression": "NUMBER"， "charsetName": null， "length": 9， "scale": 0， "position": 1， "optional": false， " autoincreated ": false， "generated": false}， {"name": "FIRST_NAME"， "jdbcType": 12， "nativeType": null， "typeName": "VARCHAR2"， "typeExpression": "VARCHAR2"， "charsetName": null， "length": 255， "scale": null， "position": 2， "optional": false， " autoincreated ": false， "generated": false}， {"name": "name": "length": 255， "scale": null， "position": "optional": false， " autoincreated ": false， "generated": false}， {"name":"LAST_NAME"， "jdbcType": 12， "nativeType": null， "typeName": "VARCHAR2"， "typeExpression": "VARCHAR2"， "charsetName": null， "length": 255， "scale": null， "position": 3， "optional": false， " autoincreted ": false， "generated": false}， {"name": "EMAIL"， "jdbcType": 12， "nativeType": null， "typeName": "VARCHAR2"， "typeExpression": "VARCHAR2"， "charsetName": null， "length": 255， "scale": null， "position": 4， "optional": false， " autoincreted ": false， "generated": false}]}}}}}}}}}}}}

{"schema": {"type": "struct"， "fields": [{"type": "string"， "optional": false， "field": "data开云体育电动老虎机baseName"}]， "optional": false， "name": "io. debez开云体育官方注册网址um .connector.oracle. schemachangekey "}， "payload": {"databaseName": "ORCLPDB1"}}

CREATE TABLE customers (id NUMBER(9) GENERATED BY DEFAULT ON NULL AS IDENTITY (START WITH 1001) NOT NULL PRIMARY KEY, first_name VARCHAR2(255) NOT NULL, last_name VARCHAR2(255) NOT NULL, email VARCHAR2(255) NOT NULL UNIQUE);

{"schema": {"type": "struct"， "fields": [{"type": "int32"， "optional": false， "field": "ID"}]， "optional": false， "name": "server1.INVENTORY.CUSTOMERS. "Key"}， "payload": {"ID": 1004}}

{"模式":{“类型”:“结构”、“字段”:[{“类型”:“结构”、“字段”:[{“类型”:“int32”、“可选”:假的,“场”:“ID”},{“类型”:“弦”、“可选”:假的,“场”:“FIRST_NAME”},{“类型”:“弦”、“可选”:假的,“场”:“LAST_NAME”},{“类型”:“弦”、“可选”:假的,“场”:“电子邮件”}],“可选”:真的,“名字”:“server1.DEBEZIUM.CUSTOMERS。开云体育官方注册网址值"，"field": "before"}， {"type": "int32"， "optional": false， "field": "ID"}， {"type": "string"， "optional": false， "field": "FIRST_NAME"}， {"type": "string"， "optional": false， "field": "LAST_NAME"}， {"type": "string"， "optional": false， "field": "EMAIL"}]， "optional": true， "name": "server1. debezum . customers。开云体育官方注册网址值”、“场”:“后”},{“类型”:“结构”、“字段”:[{“类型”:“弦”、“可选”:真的,“场”:“版本”},{“类型”:“弦”、“可选”:假的,“场”:“name”},{“类型”:“int64”、“可选”:真的,“场”:“ts_ms”},{“类型”:“弦”、“可选”:真的,“场”:“txId”},{“类型”:“int64”、“可选”:真的,“场”:“scn”},{“类型”:“int64”、“可选”:真的,“场”:“commit_scn”},{“类型”:“布尔”、“可选”:真的,“场”:“快照”}],“可选”:假的,“名字”:"io.开云体育官方注册网址 debezum .connector.oracle. source"， "field": "source"}， {"type": "string"， "optional": false， "field": "op"}， {"type": "int64"， "optional": true， "field": "ts_ms"}]， "optional": false， "name": "server1. debezum . customers . "信封”},“有效载荷”:{“前”:空,“后”:{" ID ": 1004年,“FIRST_NAME”:“安妮”,“LAST_NAME”:“Kretchmar”、“电子邮件”:“annek@noanswer.org”},“源”:{“版本”:“0.9.0。Alpha1"， "name": "server1"， "ts_ms": 1520085154000， "txId": "6.28.807"， "scn": 2122185， "commit_scn": 2122185， "snapshot": false}， "op": "c"， "ts_ms": 1532592105975}}

{"schema":{…},“有效载荷”:{“前”:{" ID ": 1004年,“FIRST_NAME”:“安妮”,“LAST_NAME”:“Kretchmar”、“电子邮件”:“annek@noanswer.org”},“后”:{" ID ": 1004年,“FIRST_NAME”:“安妮”,“LAST_NAME”:“Kretchmar”、“电子邮件”:“anne@example.com”},“源”:{“版本”:“0.9.0。Alpha1"， "name": "server1"， "ts_ms": 1520085811000， "txId": "6.9.809"， "scn": 2125544， "commit_scn": 2125544， "snapshot": false}， "op": "u"， "ts_ms": 1532592713485}}

{"schema":{…},“有效载荷”:{“前”:{" ID ": 1004年,“FIRST_NAME”:“安妮”,“LAST_NAME”:“Kretchmar”、“电子邮件”:“anne@example.com”},“后”:空,“源”:{“版本”:“0.9.0。Alpha1"， "name": "server1"， "ts_ms": 1520085153000， "txId": "6.28.807"， "scn": 2122184， "commit_scn": 2122184， "snapshot": false}， "op": "d"， "ts_ms": 1532592105960}}

ORACLE_SID=ORCLCDB dbz_oracle sqlplus /nolog CONNECT sys/top_secret AS SYSDBA alter system set db_recovery_file_dest_size = 5G;修改system set db_recovery_file_dest = '/opt/oracle/oradata/recovery_area' scope=spfile;Alter system set enable_goldengate_replication=true;立即关闭数据库启动;开云体育电动老虎机打开数据库开云体育电动老虎机——应该显示“数据库日志模式:存开云体育电动老虎机档模式”存档日志列表退出;

ORACLE_SID=ORACLCDB dbz_oracle sqlplus /nolog CONNECT sys/top_secret AS SYSDBA alter system set db_recovery_file_dest_size = 10G;修改system set db_recovery_file_dest = '/opt/oracle/oradta/recovery_area' scope=spfile;立即关闭数据库启动;开云体育电动老虎机打开数据库开云体育电动老虎机现在“数据库日志模式:存档模式开云体育电动老虎机”存档日志列表退出了吗

更改表库存。客户ADD SUPPLEMENTAL LOG DATA (ALL) COLUMNS;

/opt/oracle/oradata/ORCLCDB/xstream_adm_tbs. sqlplus sys/top_secret@//localhost:1521/ORCLCDB as sysdba CREATE TABLESPACE xstream_adm_tbs DATAFILE '/opt/oracle/oradata/ORCLCDB/xstream_adm_tbs. sqldbf的大小25M重用自动扩展MAXSIZE无限制;退出;/opt/oracle/oradata/ORCLCDB/ORCLPDB1/xstream_adm_tbs DATAFILE . sqlplus sys/top_secret@//localhost:1521/ORCLPDB1 as sysdba CREATE TABLESPACE xstream_adm_tbs DATAFILE '/opt/oracle/oradata/ORCLCDB/ORCLPDB1/xstream_adm_tbs. sqldbf的大小25M重用自动扩展MAXSIZE无限制;退出;sqlplus sys/top_secret@//localhost:1521/ORCLCDB as sysdba CREATE USER c##xstrmadmin IDENTIFIED BY xsa DEFAULT TABLESPACE xstream_adm_tbs QUOTA UNLIMITED ON xstream_adm_tbs CONTAINER=ALL;授权创建会话，设置容器为c##xstrmadmin CONTAINER=ALL;DBMS_XSTREAM_AUTH开始。GRANT_ADMIN_PRIVILEGE(grantee => 'c##xstrmadmin'， privilege_type => 'CAPTURE'， grant_select_privileges => TRUE, container => 'ALL');结束;/退出;

/opt/oracle/oradata/ORCLCDB/xstream_tbs. sqlplus sys/top_secret@//localhost:1521/ORCLCDB as sysdba CREATE TABLESPACE xstream_tbs DATAFILE '/opt/oracle/oradata/ORCLCDB/xstream_tbs. sqldbf的大小25M重用自动扩展MAXSIZE无限制;退出;/opt/oracle/oradata/ORCLCDB/ORCLPDB1/xstream_tbs DATAFILE . sqlplus sys/ top_secrets @//localhost:1521/ORCLPDB1 as sysdba CREATE TABLESPACE xstream_tbs DATAFILE '/opt/oracle/oradata/ORCLCDB/ORCLPDB1/xstream_tbs. sqldbf的大小25M重用自动扩展MAXSIZE无限制;退出;sqlplus sys/top_secret@//localhost:1521/ORCLCDB as sysdba CREATE USER c##xstrm IDENTIFIED BY xs DEFAULT TABLESPACE xstream_tbs QUOTA UNLIMITED ON xstream_tbs CONTAINER=ALL;授予c##xstrm CONTAINER=ALL创建会话权限;授予c##xstrm CONTAINER=ALL;授予V_$DATABASE的SELEC开云体育电动老虎机T权限给c##xstrm CONTAINER=ALL;给c##xstrm CONTAINER=ALL回闪任意表;授予c##xstrm CONTAINER=ALL; GRANT EXECUTE_CATALOG_ROLE TO c##xstrm CONTAINER=ALL; exit;

/opt/oracle/oradata/ORCLCDB/logminer_tbs. sqlplus sys/top_secret@//localhost:1521/ORCLCDB as sysdba CREATE TABLESPACE logminer_tbs DATAFILE '/opt/oracle/oradata/ORCLCDB/logminer_tbs. sqldbf的大小25M重用自动扩展MAXSIZE无限制;退出;/opt/oracle/oradata/ORCLCDB/ORCLPDB1/logminer_tbs. sqlplus sys/top_secret@//localhost:1521/ORCLPDB1 as sysdba CREATE TABLESPACE logminer_tbs DATAFILE '/opt/oracle/oradata/ORCLCDB/ORCLPDB1/logminer_tbs. sqlplus sys/top_secret@//localhost:1521/ORCLPDB1 as sysdba CREATE TABLESPACE logminer_tbs DATAFILE 'dbf的大小25M重用自动扩展MAXSIZE无限制;退出;sqlplus sys/top_secret@//localhost:1521/ORCLCDB as sysdba CREATE USER c##logminer IDENTIFIED BY lm DEFAULT TABLESPACE logminer_tbs QUOTA UNLIMITED ON logminer_tbs CONTAINER=ALL;给logminer CONTAINER创建会话GRANT SET CONTAINER TO c##logminer CONTAINER=ALL;logminer CONTAINER=开云体育电动老虎机ALLGRANT FLASHBACK任意表到c##logminer CONTAINER=ALL;logminer CONTAINER=ALL; GRANT SELECT_CATALOG_ROLE TO c##logminer CONTAINER=ALL; GRANT EXECUTE_CATALOG_ROLE TO c##logminer CONTAINER=ALL; GRANT SELECT ANY TRANSACTION TO c##logminer CONTAINER=ALL; GRANT LOGMINING TO c##logminer CONTAINER=ALL; GRANT CREATE TABLE TO c##logminer CONTAINER=ALL; GRANT LOCK ANY TABLE TO c##logminer CONTAINER=ALL; GRANT ALTER ANY TABLE TO c##logminer CONTAINER=ALL; GRANT CREATE SEQUENCE TO c##logminer CONTAINER=ALL; GRANT EXECUTE ON DBMS_LOGMNR TO c##logminer CONTAINER=ALL; GRANT EXECUTE ON DBMS_LOGMNR_D TO c##logminer CONTAINER=ALL; GRANT SELECT ON V_$LOG TO c##logminer CONTAINER=ALL; GRANT SELECT ON V_$LOG_HISTORY TO c##logminer CONTAINER=ALL; GRANT SELECT ON V_$LOGMNR_LOGS TO c##logminer CONTAINER=ALL; GRANT SELECT ON V_$LOGMNR_CONTENTS TO c##logminer CONTAINER=ALL; GRANT SELECT ON V_$LOGMNR_PARAMETERS TO c##logminer CONTAINER=ALL; GRANT SELECT ON V_$LOGFILE TO c##logminer CONTAINER=ALL; GRANT SELECT ON V_$ARCHIVED_LOG TO c##logminer CONTAINER=ALL; GRANT SELECT ON V_$ARCHIVE_DEST_STATUS TO c##logminer CONTAINER=ALL; exit;

sqlplus c##xstrmadmin/xsa@//localhost:1521/ORCLCDB声明表dbms_utilities . uncl_array;模式DBMS_UTILITY.UNCL_ARRAY;开始表(1):= NULL;schema (1):= 'd开云体育官方注册网址ebezium';DBMS_XSTREAM_ADM。创建_OUTBOUND( server_name => 'dbzxout', table_names => tables, schema_names => schemas); END; / exit;

sqlplus sys/top_secret@//localhost:1521/ORCLCDB as sysdba BEGIN DBMS_XSTREAM_ADM. sqlALTER_OUTBOUND(server_name => 'dbzxout'， connect_user => 'c##xstrm');结束;/退出;

{"name": "inventory-connector"， "config": {"connector.class": "io.deb开云体育官方注册网址ezium.connector.oracle.OracleConnector"， "tasks. debezium.connector.oracle. oracleconnector "， "Max ": "1"， "开云体育电动老虎机database.server.name": "server1"， "database. name"。Hostname ": ""， "开云体育电动老虎机数据库。端口":"1521"，"数据库。开云体育电动老虎机user" : "c##xstrm", "database.password" : "xs", "database.dbname" : "ORCLCDB", "database.pdb.name" : "ORCLPDB1", "database.out.server.name" : "dbzxout", "database.history.kafka.bootstrap.servers" : "kafka:9092", "database.history.kafka.topic": "schema-changes.inventory" } }

{"name": "inventory-connector"， "config": {"connector.class": "io.deb开云体育官方注册网址ezium.connector.oracle.OracleConnector"， "tasks. debezium.connector.oracle. oracleconnector "， "Max ": "1"， "开云体育电动老虎机database.server.name": "server1"， "database. name"。用户":"c##xstrm"， "数据库。开云体育电动老虎机密码“:”xs“，”数据库。开云体育电动老虎机url": "jdbc:oracle:thin:@(DESCRIPTION=(ADDRESS_LIST=(LOAD_BALANCE=OFF)(FAILOVER=ON)(ADDRESS=(PROTOCOL=TCP)(HOST=)(PORT=1521))(ADDRESS=(PROTOCOL=TCP)(HOST=)(PORT=1521)))(CONNECT_DATA=SERVICE_NAME=)(SERVER=DEDICATED)))", "database.dbname" : "ORCLCDB", "database.pdb.name" : "ORCLPDB1", "database.out.server.name" : "dbzxout", "database.history.kafka.bootstrap.servers" : "kafka:9092", "database.history.kafka.topic": "schema-changes.inventory" } }

{"config": {"connector.class": "io.deb开云体育官方注册网址ezium.connector.oracle.OracleConnector"， "任务。Max ": "1"， "开云体育电动老虎机database.server.name": "server1"， "database. name"。Hostname ": ""， "开云体育电动老虎机数据库。端口":"1521"，"数据库。开云体育电动老虎机user" : "c##xstrm", "database.password" : "xs", "database.dbname" : "ORCLCDB", "database.out.server.name" : "dbzxout", "database.history.kafka.bootstrap.servers" : "kafka:9092", "database.history.kafka.topic": "schema-changes.inventory" } }

{"config": {"connector.class": "io.deb开云体育官方注册网址ezium.connector.oracle.OracleConnector"， "任务。Max ": "1"， "开云体育电动老虎机database.server.name": "server1"， "database. name"。Hostname ": ""， "开云体育电动老虎机数据库。端口":"1521"，"数据库。开云体育电动老虎机user" : "c##xstrm", "database.password" : "xs", "database.dbname" : "ORCLCDB", "database.pdb.name" : "ORCLPDB1", "database.out.server.name" : "dbzxout", "database.history.kafka.bootstrap.servers" : "kafka:9092", "database.history.kafka.topic": "schema-changes.inventory" } }

{"name": "inventory-connector"， "config": {"connector.class": "io.deb开云体育官方注册网址ezium.connector.oracle.OracleConnector"， "tasks. debezium.connector.oracle. oracleconnector "， "Max ": "1"， "开云体育电动老虎机database.server.name": "server1"， "database. name"。Hostname ": ""， "开云体育电动老虎机数据库。端口":"1521"，"数据库。开云体育电动老虎机user" : "c##xstrm", "database.password" : "xs", "database.dbname" : "ORCLCDB", "database.pdb.name" : "ORCLPDB1", "database.out.server.name" : "dbzxout", "database.history.kafka.bootstrap.servers" : "kafka:9092", "database.history.kafka.topic": "schema-changes.inventory" "database.connection.adapter": "logminer" } }

SELECT IOT_NAME FROM DBA_TABLES WHERE OWNER='' AND TABLE_NAME='< lot -table-name-that-failed>'

           
连接器的table.include.list或table.exclude.list然后应该调整配置选项，以显式地包括或排除适当的表，以避免连接器试图从子索引组织的表中捕获更改。
          
      
      
map