Package org.jumpmind.db.platform.kafka

Class KafkaDdlReader

java.lang.Object

org.jumpmind.db.platform.kafka.KafkaDdlReader

All Implemented Interfaces:

IDdlReader

public class KafkaDdlReader
extends Object
implements IDdlReader

Field Summary

Fields

Modifier and Type	Field	Description
protected KafkaPlatform	platform

Constructor Summary

Constructors

Constructor	Description
KafkaDdlReader(KafkaPlatform platform)

Method Summary

Modifier and Type	Method	Description
List<Trigger>	getApplicationTriggersForModel(String catalog, String schema, String tableName, String triggerPrefix)
List<String>	getCatalogNames()
List<String>	getColumnNames(String catalog, String schema, String tableName)
List<TableRow>	getExportedForeignTableRows(ISqlTransaction transaction, List<TableRow> tableRows, Set<TableRow> visited, BinaryEncoding encoding)
Collection<ForeignKey>	getExportedKeys(Table table)
Collection<ForeignKey>	getForeignKeys(String catalog, String schema, String tableName)
List<TableRow>	getImportedForeignTableRows(List<TableRow> tableRows, Set<TableRow> visited, BinaryEncoding encoding)
PlatformTrigger	getPlatformTrigger(IDatabasePlatform platform, Trigger trigger)
List<String>	getSchemaNames(String catalog)
List<String>	getTableNames(String catalog, String schema, String[] tableTypes)
List<String>	getTableTypes()
Trigger	getTriggerFor(Table table, String name)
List<Trigger>	getTriggers(String catalog, String schema, String tableName)
Table	readTable(String catalog, String schema, String tableName)
Table	readTable(ISqlTransaction transaction, String catalog, String schema, String table)
Database	readTables(String catalog, String schema, String[] tableTypes)

Methods inherited from class java.lang.Object

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

Field Details

platform

protected KafkaPlatform platform

Constructor Details

KafkaDdlReader

public KafkaDdlReader(KafkaPlatform platform)

Method Details

readTables

public Database readTables(String catalog,
 String schema,
 String[] tableTypes)

Specified by:

readTables in interface IDdlReader

readTable

public Table readTable(String catalog,
 String schema,
 String tableName)

Specified by:

readTable in interface IDdlReader

readTable

public Table readTable(ISqlTransaction transaction,
 String catalog,
 String schema,
 String table)

Specified by:

readTable in interface IDdlReader

getTableTypes

public List<String> getTableTypes()

Specified by:

getTableTypes in interface IDdlReader

getCatalogNames

public List<String> getCatalogNames()

Specified by:

getCatalogNames in interface IDdlReader

getSchemaNames

public List<String> getSchemaNames(String catalog)

Specified by:

getSchemaNames in interface IDdlReader

getTableNames

public List<String> getTableNames(String catalog,
 String schema,
 String[] tableTypes)

Specified by:

getTableNames in interface IDdlReader

getColumnNames

public List<String> getColumnNames(String catalog,
 String schema,
 String tableName)

Specified by:

getColumnNames in interface IDdlReader

getTriggers

public List<Trigger> getTriggers(String catalog,
 String schema,
 String tableName)

Specified by:

getTriggers in interface IDdlReader

getTriggerFor

public Trigger getTriggerFor(Table table,
 String name)

Specified by:

getTriggerFor in interface IDdlReader

getExportedKeys

public Collection<ForeignKey> getExportedKeys(Table table)

Specified by:

getExportedKeys in interface IDdlReader

getForeignKeys

public Collection<ForeignKey> getForeignKeys(String catalog,
 String schema,
 String tableName)

Specified by:

getForeignKeys in interface IDdlReader

getExportedForeignTableRows

public List<TableRow> getExportedForeignTableRows(ISqlTransaction transaction,
 List<TableRow> tableRows,
 Set<TableRow> visited,
 BinaryEncoding encoding)

Specified by:

getExportedForeignTableRows in interface IDdlReader

getImportedForeignTableRows

public List<TableRow> getImportedForeignTableRows(List<TableRow> tableRows,
 Set<TableRow> visited,
 BinaryEncoding encoding)

Specified by:

getImportedForeignTableRows in interface IDdlReader

getApplicationTriggersForModel

public List<Trigger> getApplicationTriggersForModel(String catalog,
 String schema,
 String tableName,
 String triggerPrefix)

Specified by:

getApplicationTriggersForModel in interface IDdlReader

getPlatformTrigger

public PlatformTrigger getPlatformTrigger(IDatabasePlatform platform,
 Trigger trigger)

Specified by:

getPlatformTrigger in interface IDdlReader