Mysql
There are two flavors of connectors for this destination:
- destination-mysql connector. Supports both SSL and non SSL connections.
- destination-mysql-strict-encrypt connector. Pretty same as connector above, but supports SSL connections only.
Supported sync modes
| Sync mode | Supported? |
|---|---|
| Full Refresh - Overwrite | Yes |
| Full Refresh - Append | Yes |
| Full Refresh - Overwrite + Deduped | Yes |
| Incremental Sync - Append | Yes |
| Incremental Sync - Append + Deduped | Yes |
Getting Started (Calabi Connect)
Calabi Connect only supports connecting to your MySQL instance with TLS encryption. Other than that, you can proceed with the open-source instructions below.
Getting Started (Calabi Connect)
Requirements
To use the MySQL destination, you'll need:
- To sync data to MySQL with typing and deduping: MySQL database 8.0.0 or above
- To sync data to MySQL without typing and deduping: MySQL 5.0 or above.
Troubleshooting
Some users reported that they could not connect to Amazon RDS MySQL or MariaDB. This can be diagnosed with the error message: Cannot create a PoolableConnectionFactory.
To solve this issue add enabledTLSProtocols=TLSv1.2 in the JDBC parameters.
Network Access
Make sure your MySQL database can be accessed by Calabi Connect. If your database is within a VPC, you may need to allow access from the IP you're using to expose Calabi Connect.
Permissions
You need a MySQL user with CREATE, INSERT, SELECT, DROP permissions. We highly recommend creating an Calabi Connect-specific user for this purpose.
Target Database
MySQL doesn't differentiate between a database and schema. A database is essentially a schema where all the tables live in. You will need to choose an existing database or create a new database. This will act as a default database/schema where the tables will be created if the source doesn't provide a namespace.
Setup the MySQL destination in Calabi Connect
Before setting up MySQL destination in Calabi Connect, you need to set the local_infile system variable to true. You can do this by running the query SET GLOBAL local_infile = true with a user with SYSTEM_VARIABLES_ADMIN permission. This is required cause Calabi Connect uses LOAD DATA LOCAL INFILE to load data into table.
You should now have all the requirements needed to configure MySQL as a destination in the UI. You'll need the following information to configure the MySQL destination:
- Host
- Port
- Username
- Password
- Database
- jdbc_url_params (Optional)
Default JDBC URL Parameters
The following JDBC URL parameters are set by Calabi Connect and cannot be overridden by the jdbc_url_params field:
useSSL=true(unlesssslis set to false)requireSSL=true(unlesssslis set to false)verifyServerCertificate=false(unlesssslis set to false)zeroDateTimeBehavior=convertToNull
Known Limitations
Note that MySQL documentation discusses identifiers case sensitivity using the lower_case_table_names system variable. One of their recommendations is:
"It is best to adopt a consistent convention, such as always creating and referring to databases and tables using lowercase names.
This convention is recommended for maximum portability and ease of use."
As a result, Calabi Connect MySQL destination forces all identifier (table, schema and columns) names to be lowercase.
Connection via SSH Tunnel
Calabi Connect has the ability to connect to a MySQl instance via an SSH Tunnel. The reason you might want to do this because it is not possible (or against security policy) to connect to the database directly (e.g. it does not have a public IP address).
When using an SSH tunnel, you are configuring Calabi Connect to connect to an intermediate server (a.k.a. a bastion sever) that does have direct access to the database. Calabi Connect connects to the bastion and then asks the bastion to connect directly to the server.
Using this feature requires additional configuration, when creating the destination. We will talk through what each piece of configuration means.
-
Configure all fields for the destination as you normally would, except
SSH Tunnel Method. -
SSH Tunnel Methoddefaults toNo Tunnel(meaning a direct connection). If you want to use an SSH Tunnel chooseSSH Key AuthenticationorPassword Authentication.- Choose
Key Authenticationif you will be using an RSA private key as your secret for establishing the SSH Tunnel (see below for more information on generating this key). - Choose
Password Authenticationif you will be using a password as your secret for establishing the SSH Tunnel.
warningSince Calabi Connect requires encrypted communication, select SSH Key Authentication or Password Authentication if you selected preferred as the SSL Mode; otherwise, the connection will fail.
- Choose
-
SSH Tunnel Jump Server Hostrefers to the intermediate (bastion) server that Calabi Connect will connect to. This should be a hostname or an IP Address. -
SSH Connection Portis the port on the bastion server with which to make the SSH connection. The default port for SSH connections is22, so unless you have explicitly changed something, go with the default. -
SSH Login Usernameis the username that Calabi Connect should use when connection to the bastion server. This is NOT the MySQl username. -
If you are using
Password Authentication, thenSSH Login Usernameshould be set to the password of the User from the previous step. If you are usingSSH Key Authenticationleave this blank. Again, this is not the MySQl password, but the password for the OS-user that Calabi Connect is using to perform commands on the bastion. -
If you are using
SSH Key Authentication, thenSSH Private Keyshould be set to the RSA Private Key that you are using to create the SSH connection. This should be the full contents of the key file starting with-----BEGIN RSA PRIVATE KEY-----and ending with-----END RSA PRIVATE KEY-----.
Namespace support
This destination supports namespaces. MySQL doesn't differentiate between a database and schema. The configured database acts as the default namespace.