Package com.zendesk.maxwell.schema

Class AbstractSchemaStore

java.lang.Object

com.zendesk.maxwell.schema.AbstractSchemaStore

Direct Known Subclasses:

MysqlSchemaStore

public abstract class AbstractSchemaStore
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected CaseSensitivity	caseSensitivity
protected ConnectionPool	replicationConnectionPool
protected ConnectionPool	schemaConnectionPool

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractSchemaStore(MaxwellContext context)
protected	AbstractSchemaStore(ConnectionPool replicationConnectionPool, ConnectionPool schemaConnectionPool, CaseSensitivity caseSensitivity, Filter filter)

Method Summary

Modifier and Type	Method	Description
protected Schema	captureSchema()
protected List<ResolvedSchemaChange>	resolveSQL(Schema schema, String sql, String currentDatabase)

Methods inherited from class java.lang.Object

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

Field Detail

replicationConnectionPool

protected final ConnectionPool replicationConnectionPool

schemaConnectionPool

protected final ConnectionPool schemaConnectionPool

caseSensitivity

protected final CaseSensitivity caseSensitivity

Constructor Detail

AbstractSchemaStore

protected AbstractSchemaStore(ConnectionPool replicationConnectionPool,
                              ConnectionPool schemaConnectionPool,
                              CaseSensitivity caseSensitivity,
                              Filter filter)

AbstractSchemaStore

protected AbstractSchemaStore(MaxwellContext context)
                       throws SQLException

Throws:

SQLException

Method Detail

captureSchema

protected Schema captureSchema()
                        throws SQLException

Throws:

SQLException

resolveSQL

protected List<ResolvedSchemaChange> resolveSQL(Schema schema,
                                                String sql,
                                                String currentDatabase)
                                         throws InvalidSchemaError

Throws:

InvalidSchemaError