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

履行。库存。订单履行。库存。客户履行。库存。产品

{"schema":{…}， "payload": {"source": {"version": "1.7.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": "开云体育官方注册网址DEBEZIUM"， // "ddl": "CREATE TABLE \"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"}}

{"status": "BEGIN"， "id": "5.6.641"， "event_count": null， "data_collections": null} {"status": "END"， "id": "5.6.641"， "event_count": 2， "data_collections": [{"data_collection": "ORCLPDB1.DEBEZ开云体育官方注册网址IUM. debezium . "CUSTOMER"， "event_count": 1}， {"data_collection": "ORCLPDB1.DE开云体育官方注册网址BEZIUM。ORDER"， "event_count": 1}]}

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。开云体育官方注册网址价值", "field": "after" }, { "type": "struct", "fields": [ { "type": "string", "optional": true, "field": "version" }, { "type": "string", "optional": false, "field": "name" }, { "type": "int64", "optional": true, "field": "ts_ms" }, { "type": "string", "optional": true, "field": "txId" }, { "type": "string", "optional": true, "field": "scn" }, { "type": "string", "optional": true, "field": "commit_scn" }, { "type": "boolean", "optional": true, "field": "snapshot" } ], "optional": false, "name": "io.debezium.connector.oracle.Source", "field": "source" }, { "type": "string", "optional": false, "field": "op" }, { "type": "int64", "optional": true, "field": "ts_ms" } ], "optional": false, "name": "server1.DEBEZIUM.CUSTOMERS.Envelope" }, "payload": { "before": null, "after": { "ID": 1004, "FIRST_NAME": "Anne", "LAST_NAME": "Kretchmar", "EMAIL": "annek@noanswer.org" }, "source": { "version": "1.7.2.Final", "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”},“源”:{“版本”:“是1.7.2。Final"， "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”},“后”:空,“源”:{“版本”:“是1.7.2。Final"， "name": "server1"， "ts_ms": 1520085153000， "txId": "6.28.807"， "scn": "2122184"， "commit_scn": "2122184"， "snapshot": false}， "op": "d"， "ts_ms": 1532592105960}}

converters=boolean boolean.type=io.开云体育官方注册网址 debezu .connector.oracle.converters. numberonetobooleanconverter boolean.selector=.*MYTABLE.FLAG，.*. is_archived

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/oradata/recovery_area' scope=spfile;立即关闭数据库启动;开云体育电动老虎机打开数据库开云体育电动老虎机现在“数据库日志模式:存档模式开云体育电动老虎机”存档日志列表退出了吗

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

修改数据库添开云体育电动老虎机加补充日志数据;

/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##dbzuser IDENTIFIED BY dbz DEFAULT TABLESPACE logminer_tbs QUOTA UNLIMITED ON logminer_tbs CONTAINER=ALL;给c##dbzuser CONTAINER创建会话授予c##dbzuser CONTAINER=ALL;dbzuser CONTAINER=A开云体育电动老虎机LL给c##dbzuser CONTAINER=ALL回闪任意表;dbzuser CONTAINER=ALL; GRANT SELECT_CATALOG_ROLE TO c##dbzuser CONTAINER=ALL; GRANT EXECUTE_CATALOG_ROLE TO c##dbzuser CONTAINER=ALL; GRANT SELECT ANY TRANSACTION TO c##dbzuser CONTAINER=ALL; GRANT LOGMINING TO c##dbzuser CONTAINER=ALL; GRANT CREATE TABLE TO c##dbzuser CONTAINER=ALL; GRANT LOCK ANY TABLE TO c##dbzuser CONTAINER=ALL; GRANT CREATE SEQUENCE TO c##dbzuser CONTAINER=ALL; GRANT EXECUTE ON DBMS_LOGMNR TO c##dbzuser CONTAINER=ALL; GRANT EXECUTE ON DBMS_LOGMNR_D TO c##dbzuser CONTAINER=ALL; GRANT SELECT ON V_$LOG TO c##dbzuser CONTAINER=ALL; GRANT SELECT ON V_$LOG_HISTORY TO c##dbzuser CONTAINER=ALL; GRANT SELECT ON V_$LOGMNR_LOGS TO c##dbzuser CONTAINER=ALL; GRANT SELECT ON V_$LOGMNR_CONTENTS TO c##dbzuser CONTAINER=ALL; GRANT SELECT ON V_$LOGMNR_PARAMETERS TO c##dbzuser CONTAINER=ALL; GRANT SELECT ON V_$LOGFILE TO c##dbzuser CONTAINER=ALL; GRANT SELECT ON V_$ARCHIVED_LOG TO c##dbzuser CONTAINER=ALL; GRANT SELECT ON V_$ARCHIVE_DEST_STATUS TO c##dbzuser CONTAINER=ALL; exit;

{"name": "inventory-connector"，(1）"config": {"connector.class": "io.de开云体育官方注册网址bezium.connector.oracle.OracleConnector"，（2）“开云体育电动老虎机数据库。hostname": ""，（3）“开云体育电动老虎机数据库。端口:“1521”，（4）“开云体育电动老虎机数据库。使用r" : "c##dbzuser",（5）“开云体育电动老虎机数据库。密码:“dbz”，(6）“开云体育电动老虎机数据库。dbname" : "ORCLCDB",(7）d开云体育电动老虎机atabase.server.name: "server1"，（8）”任务。Max ": "1"，（9)d开云体育电动老虎机atabase.pdb.name: ORCLPDB1，（10）“开云体育电动老虎机database.history.kafka.bootstrap。服务器:"kafka:9092"，（11）“开云体育电动老虎机database.history.kafka。主题:“模式变化。库存"（12）}}

{"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##dbzuser"， "数据库。开云体育电动老虎机密码:“dbz”，“database.”开云体育电动老虎机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.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"，"数据库。开云体育电动老虎机dbzuser: ##dbzuser“开云体育电动老虎机数据库。密码:“dbz”，“database.”开云体育电动老虎机dbname": "ORCLCDB"，d开云体育电动老虎机atabase.pdb.name: ORCLPDB1，“开云体育电动老虎机database.history.kafka.bootstrap。服务器:"kafka:9092"，“开云体育电动老虎机database.history.kafka。主题:“模式变化。库存"}}

{"config": {"connector.class": "io.deb开云体育官方注册网址ezium.connector.oracle.OracleConnector"， "任务。Max ": "1"， "开云体育电动老虎机database.server.name": "server1"， "database. name"。Hostname ": ""， "开云体育电动老虎机数据库。端口":"1521"，"数据库。开云体育电动老虎机dbzuser: ##dbzuser“开云体育电动老虎机数据库。密码:“dbz”，“database.”开云体育电动老虎机dbname": "ORCLCDB"，“开云体育电动老虎机database.history.kafka.bootstrap。服务器:"kafka:9092"，“开云体育电动老虎机database.history.kafka。主题:“模式变化。库存"}}

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;立即关闭数据库启动;开云体育电动老虎机打开数据库开云体育电动老虎机——应该显示“数据库日志模式:存开云体育电动老虎机档模式”存档日志列表退出;

更改表库存。客户一个DD 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##dbzadmin IDENTIFIED BY dbz DEFAULT TABLESPACE xstream_adm_tbs QUOTA UNLIMITED ON xstream_adm_tbs CONTAINER=ALL;授权创建会话，设置容器为c##dbzadmin容器=ALL;DBMS_XSTREAM_AUTH开始。GRANT_ADMIN_PRIVILEGE(grantee => 'c##dbzadmin'， 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##dbzuser IDENTIFIED BY dbz DEFAULT TABLESPACE xstream_tbs QUOTA UNLIMITED ON xstream_tbs CONTAINER=ALL;给c##dbzuser CONTAINER创建会话授予c##dbzuser CONTAINER=ALL;dbzuser CONTAINER=A开云体育电动老虎机LL给c##dbzuser CONTAINER=ALL回闪任意表;dbzuser CONTAINER=ALL; GRANT EXECUTE_CATALOG_ROLE TO c##dbzuser CONTAINER=ALL; exit;

sqlplus dbzadmin/dbz@//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##dbzuser');结束;/退出;

{"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"，"数据库。开云体育电动老虎机dbzuser: ##dbzuser“开云体育电动老虎机数据库。密码:“dbz”，“database.”开云体育电动老虎机dbname": "ORCLCDB"，d开云体育电动老虎机atabase.pdb.name: ORCLPDB1，“开云体育电动老虎机database.history.kafka.bootstrap。服务器:"kafka:9092"，“开云体育电动老虎机database.history.kafka。主题:“模式变化。库存", "database.connection.adapter": "xstream", "database.out.server.name" : "dbzxout" } }

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

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

          
LogMiner适配器不捕获SYS或SYSTEM所做的更改
          

           
Oracle使用SYS而且系统说明了很多内部更改，因此连接器自动过滤这些用户所做的更改时，从LogMiner获取更改。千万不要使用SYS或系统Debezium Oracle连接器发出的更改的用户帐户。开云体育官方注册网址
          
         
      
      
map