Create a ggadmin user using the following script. Remember to
replace <ggadmin-password> with a valid password:
CREATE USER 'ggadmin' IDENTIFIED BY '<ggadmin-password>';
GRANT SELECT, REPLICATION SLAVE, REPLICATION CLIENT, CREATE,CREATE VIEW, EVENT, INSERT, UPDATE, DROP,EXECUTE, DELETE ON *.* TO 'ggadmin';
Open port 3306, through which OCI GoldenGate can
connect.
In the Oracle Cloud console, locate the subnet that the HeatWave database uses.
In the security list of the subnet, create an Ingress rule for
port TCP/3306.
On the Replicat Information page, under Replicat type, select Classic Replicat, and enter a Process Name.
On the Replicat Options page:
For Trail Name, enter the name of the Trail
from Task 2.
For Target, select a Azure Event Hubs.
For Alias, select the Azure Event Hubs connection created in Task
1.
On the Replicat Parameters page, leave the
default.
On the Properties File page, provide a topic name for
topicMappingTemplate.
Click Create and Run.
Task 5: Verify Data
Replication from HeatWave to Azure Event Hubs 🔗
Perform updates to the source HeatWave database to
verify replication to Azure Event Hubs.
In OCI Bastion, create an SSH port forwarding session using MySQL IP and
port 3306. Add your public SSH key.
Connect to MySQL in Cloud Shell using your private key and port
3306.
After connecting successfully, run the following command:
mysqlsh admin@localhost:3306 --sql
Run the following script to perform inserts into the HeatWave
database:
use SRC_OCIGGLL;
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1000,'Houston',20,743113);
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1001,'Dallas',20,822416);
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1002,'San Francisco',21,157574);
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1003,'Los Angeles',21,743878);
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1004,'San Diego',21,840689);
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1005,'Chicago',23,616472);
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1006,'Memphis',23,580075);
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1007,'New York City',22,124434);
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1008,'Boston',22,275581);
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1009,'Washington D.C.',22,688002);
commit;
In the source MySQL deployment console, select the Change
Data Capture Extract name, and then click Statistics. Verify
that SRC_OCIGGLL.SRC_CITY has 10 inserts.
In target Big Data deployment console, select the Replicat name and then click Statistics. Verify that
SRC_OCIGGLL.SRC_CITY has 10 inserts.
In Azure Event Hubs, you can check the message statistics.