alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-5044 Introduce respective SchemaFactory for all connectors

Browse Source
This commit is contained in:
Anisha Mohanty 2022-08-23 17:28:42 +05:30 committed by Jiri Pechanec
parent b498368f82
commit 9fd204b383
3 changed files with 64 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/MySQLSchemaFactory.java Normal file
View File

@ -0,0 +1,21 @@
/*
* Copyright Debezium Authors.
*
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
*/
package io.debezium.connector.mysql;
import io.debezium.schema.SchemaFactory;
public class MySQLSchemaFactory extends SchemaFactory {
public MySQLSchemaFactory() {
super();
}
private static final MySQLSchemaFactory mysqlSchemaFactoryObject = new MySQLSchemaFactory();
public static MySQLSchemaFactory get() {
return mysqlSchemaFactoryObject;
}
}

22
debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleSchemaFactory.java Normal file
View File

@ -0,0 +1,22 @@
/*
* Copyright Debezium Authors.
*
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
*/
package io.debezium.connector.oracle;
import io.debezium.schema.SchemaFactory;
public class OracleSchemaFactory extends SchemaFactory {
public OracleSchemaFactory() {
super();
}
private static final OracleSchemaFactory oracleSchemaFactoryObject = new OracleSchemaFactory();
public static OracleSchemaFactory get() {
return oracleSchemaFactoryObject;
}
}

21
debezium-connector-sqlserver/src/main/java/io/debezium/connector/sqlserver/SqlServerSchemaFactory.java Normal file
View File

@ -0,0 +1,21 @@
/*
* Copyright Debezium Authors.
*
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
*/
package io.debezium.connector.sqlserver;
import io.debezium.schema.SchemaFactory;
public class SqlServerSchemaFactory extends SchemaFactory {
public SqlServerSchemaFactory() {
super();
}
private static final SqlServerSchemaFactory sqlServerSchemaFactoryObject = new SqlServerSchemaFactory();
public static SqlServerSchemaFactory get() {
return sqlServerSchemaFactoryObject;
}
}