:Configure data sources for data synchronization from MySQL

Limits

• Real-time synchronization of data from MySQL is performed based on real-time subscription to MySQL binary logs. Real-time data synchronization from MySQL supports only ApsaraDB RDS for MySQL data sources that run MySQL 5.X or 8.X. Real-time data synchronization from MySQL does not support PolarDB-X 1.0 data sources that run MySQL. If you want to synchronize data from a PolarDB-X 1.0 data source that runs MySQL in real time, you can refer to Add a DRDS data source to add a PolarDB-X 1.0 data source and configure a real-time synchronization node for the data source.
• You cannot use the real-time synchronization feature to synchronize data on which XA ROLLBACK statements are executed. For transaction data on which XA PREPARE statements are executed, you can use the real-time synchronization feature to synchronize the data to a destination. If XA ROLLBACK statements are executed later on the data, the rollback changes to the data cannot be synchronized to the destination. If the tables that you want to synchronize contain tables on which XA ROLLBACK statements are executed, you must remove the tables on which XA ROLLBACK statements are executed and add the removed tables again to initialize full data in the source and synchronize incremental data.
• If you add an ApsaraDB RDS for MySQL instance that belongs to a different Alibaba Cloud account from the current workspace to DataWorks as a MySQL data source and you configure a data synchronization node for the MySQL data source, you can use only an exclusive resource group for Data Integration to run the node. If you use the shared resource group for Data Integration to run the node, the resource group cannot access data in the MySQL data source.

Procedure

1. Configure a whitelist for the MySQL database.
   Add the CIDR block of the VPC in which the exclusive resource group resides to the whitelist of the MySQL database.
   1. View and record the elastic IP address (EIP) and CIDR block of the exclusive resource group for Data Integration.
      1. Log on to the DataWorks console.
      2. In the left-side navigation pane, click Resource Groups.
      3. On the Exclusive Resource Groups tab, find the exclusive resource group for Data Integration and click View Information in the Actions column.
      4. In the Exclusive Resource Groups dialog box, view and record the values of the EIPAddress and CIDR Blocks parameters.
      5. On the Exclusive Resource Groups tab, find the exclusive resource group for Data Integration and click Network Settings in the Actions column.
      6. On the VPC Binding tab of the page that appears, view and record the CIDR block of the vSwitch with which the exclusive resource group for Data Integration is associated.
   2. Add the EIP and CIDR block of the exclusive resource group to the whitelist of the MySQL database.
2. Create an account and grant permissions to the account.
   You must create an account to log on to the MySQL database. You must grant the SELECT, REPLICATION SLAVE, and REPLICATION CLIENT permissions to the account.
   1. Create an account.
      For more information, see Create an account to access a MySQL database.
   2. Grant permissions to the account.
      You can run the following command to grant permissions to the account. Alternatively, you can grant the SUPER permission to the account. Replace Account for data synchronization with the created account when you execute the specific statement.

      -- CREATE USER 'Account for data synchronization'@'%' IDENTIFIED BY 'Password'; // Create an account that is used to synchronize data and set a password so that you can use the account and password to access the database from a host. % indicates a host. 
      GRANT SELECT, REPLICATION SLAVE, REPLICATION CLIENT ON *.* TO 'Account for data synchronization'@'%'; // Grant the SELECT, REPLICATION SLAVE, and REPLICATION CLIENT permissions to the account. 

      *.* indicates that the synchronization account is granted the preceding permissions on all tables in all databases. You can also grant the preceding permissions on specified tables in the specified database to the synchronization account. For example, to grant the account the preceding permissions on the user table in the test database, execute the following statement: GRANT SELECT, REPLICATION CLIENT ON test.user TO 'Account for data synchronization'@'%';.

      Note The REPLICATION SLAVE permission is a global permission. You cannot grant this permission on specified tables in the specified database to the synchronization account.
3. Enable the binary logging feature for the MySQL database.
   Perform the following steps to check whether the binary logging feature is enabled and to query the format of binary logs:

   • Execute the following statement to check whether the binary logging feature is enabled:

     show variables like "log_bin";

     If ON is displayed in the returned result, the binary logging feature is enabled.

   • If you use a secondary database to synchronize data, execute the following statement to check whether the binary logging feature is enabled:

     show variables like "log_slave_updates";

     If ON is displayed in the returned result, the binary logging feature is enabled for the secondary database.

   If the returned result is different from the preceding result, follow the instructions described in the MySQL documentation to enable the binary logging feature.
   Execute the following statement to view the format of binary logs:

   show variables like "binlog_format";

   Returned result:

   • ROW: The format of binary logs is row.
   • STATEMENT: The format of binary logs is statement.
   • MIXED: The format of binary logs is mixed.