com.ververica.cdc.connectors.mysql.source.connection

Class JdbcConnectionFactory

java.lang.Object

com.ververica.cdc.connectors.mysql.source.connection.JdbcConnectionFactory

All Implemented Interfaces:

io.debezium.jdbc.JdbcConnection.ConnectionFactory

public class JdbcConnectionFactory
extends Object
implements io.debezium.jdbc.JdbcConnection.ConnectionFactory

A factory to create JDBC connection for MySQL.

Constructor Summary

Constructors

Constructor and Description
JdbcConnectionFactory(MySqlSourceConfig sourceConfig)

Method Summary

Modifier and Type	Method and Description
Connection	connect(io.debezium.jdbc.JdbcConfiguration config)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JdbcConnectionFactory

public JdbcConnectionFactory(MySqlSourceConfig sourceConfig)

Method Detail

connect

public Connection connect(io.debezium.jdbc.JdbcConfiguration config)
                   throws SQLException

Specified by:

connect in interface io.debezium.jdbc.JdbcConnection.ConnectionFactory

Throws:

SQLException