Package io.debezium.connector.mysql

Class MySqlConnection.MySqlConnectionConfiguration

java.lang.Object

io.debezium.connector.mysql.MySqlConnection.MySqlConnectionConfiguration

Enclosing class:

MySqlConnection

public static class MySqlConnection.MySqlConnectionConfiguration
extends Object

Connection configuration to create a MySqlConnection.

Field Summary

Fields

Modifier and Type	Field	Description
protected static String	JDBC_PROPERTY_CONNECTION_TIME_ZONE
protected static String	JDBC_PROPERTY_LEGACY_DATETIME
protected static String	JDBC_PROPERTY_LEGACY_SERVER_TIME_ZONE

Constructor Summary

Constructors

Constructor	Description
MySqlConnectionConfiguration(io.debezium.config.Configuration config)
MySqlConnectionConfiguration(io.debezium.config.Configuration config, Properties jdbcProperties)

Method Summary

Modifier and Type	Method	Description
io.debezium.jdbc.JdbcConfiguration	config()
io.debezium.config.CommonConnectorConfig.EventProcessingFailureHandlingMode	eventProcessingFailureHandlingMode()
io.debezium.jdbc.JdbcConnection.ConnectionFactory	factory()
java.time.Duration	getConnectionTimeout()
String	getUrlPattern()
String	hostname()
io.debezium.config.CommonConnectorConfig.EventProcessingFailureHandlingMode	inconsistentSchemaHandlingMode()
io.debezium.config.Configuration	originalConfig()
String	password()
int	port()
String	sslKeyStore()
char[]	sslKeyStorePassword()
io.debezium.connector.mysql.MySqlConnectorConfig.SecureConnectionMode	sslMode()
boolean	sslModeEnabled()
String	sslTrustStore()
char[]	sslTrustStorePassword()
String	username()

Methods inherited from class java.lang.Object

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

Field Detail

JDBC_PROPERTY_LEGACY_DATETIME

protected static final String JDBC_PROPERTY_LEGACY_DATETIME

See Also:

Constant Field Values

JDBC_PROPERTY_CONNECTION_TIME_ZONE

protected static final String JDBC_PROPERTY_CONNECTION_TIME_ZONE

See Also:

Constant Field Values

JDBC_PROPERTY_LEGACY_SERVER_TIME_ZONE

protected static final String JDBC_PROPERTY_LEGACY_SERVER_TIME_ZONE

See Also:

Constant Field Values

Constructor Detail

MySqlConnectionConfiguration

public MySqlConnectionConfiguration(io.debezium.config.Configuration config)

MySqlConnectionConfiguration

public MySqlConnectionConfiguration(io.debezium.config.Configuration config,
                                    Properties jdbcProperties)

Method Detail

config

public io.debezium.jdbc.JdbcConfiguration config()

originalConfig

public io.debezium.config.Configuration originalConfig()

factory

public io.debezium.jdbc.JdbcConnection.ConnectionFactory factory()

username

public String username()

password

public String password()

hostname

public String hostname()

port

public int port()

sslMode

public io.debezium.connector.mysql.MySqlConnectorConfig.SecureConnectionMode sslMode()

sslModeEnabled

public boolean sslModeEnabled()

sslKeyStore

public String sslKeyStore()

sslKeyStorePassword

public char[] sslKeyStorePassword()

sslTrustStore

public String sslTrustStore()

sslTrustStorePassword

public char[] sslTrustStorePassword()

getConnectionTimeout

public java.time.Duration getConnectionTimeout()

getUrlPattern

public String getUrlPattern()

eventProcessingFailureHandlingMode

public io.debezium.config.CommonConnectorConfig.EventProcessingFailureHandlingMode eventProcessingFailureHandlingMode()

inconsistentSchemaHandlingMode

public io.debezium.config.CommonConnectorConfig.EventProcessingFailureHandlingMode inconsistentSchemaHandlingMode()