Uses of Interface
com.continuent.tungsten.replicator.database.Database

Packages that use Database

com.continuent.tungsten.replicator.applier
com.continuent.tungsten.replicator.applier.batch
com.continuent.tungsten.replicator.channel
com.continuent.tungsten.replicator.consistency
com.continuent.tungsten.replicator.database
com.continuent.tungsten.replicator.extractor.oracle
com.continuent.tungsten.replicator.heartbeat
com.continuent.tungsten.replicator.loader
com.continuent.tungsten.replicator.management.tungsten
com.continuent.tungsten.replicator.prefetch
com.continuent.tungsten.replicator.shard
com.continuent.tungsten.replicator.thl

Uses of Database in com.continuent.tungsten.replicator.applier

Fields in com.continuent.tungsten.replicator.applier declared as Database

protected Database	JdbcApplier.conn
protected Database	JdbcPrefetcher.conn

Methods in com.continuent.tungsten.replicator.applier that return Database

Database	JdbcApplier.getDatabase()
Database	JdbcPrefetcher.getDatabase()

Uses of Database in com.continuent.tungsten.replicator.applier.batch

Fields in com.continuent.tungsten.replicator.applier.batch declared as Database

protected Database	SimpleBatchApplier.conn
protected Database	SqlWrapper.connection

Methods in com.continuent.tungsten.replicator.applier.batch with parameters of type Database

void	SqlCsvLoader.load(Database conn, CsvInfo info, LoadMismatch onLoadMismatch) Loads a CSV file to the DBMS using an appropriate mechanism for this DBMS type.
void	CsvLoader.load(Database conn, CsvInfo info, LoadMismatch onLoadMismatch) Loads a CSV file to the DBMS using an appropriate mechanism for this DBMS type.
void	VerticaCsvLoader.load(Database conn, CsvInfo info, LoadMismatch onLoadMismatch) Loads a CSV file to the DBMS using an appropriate mechanism for this DBMS type.
void	NativeScriptExecutor.setConnection(Database connection) Sets the DBMS connection.
void	JavascriptExecutor.setConnection(Database connection) Sets the DBMS connection.
void	ScriptExecutor.setConnection(Database connection) Sets the DBMS connection.

Constructors in com.continuent.tungsten.replicator.applier.batch with parameters of type Database

SqlWrapper(Database connection)
Creates a new instance.

Uses of Database in com.continuent.tungsten.replicator.channel

Methods in com.continuent.tungsten.replicator.channel with parameters of type Database

void	ShardChannelTable.initializeShardTable(Database database, int channels) Set up the channel table.
int	ShardChannelTable.insert(Database database, java.lang.String shardName, int channelNumber) Insert a shard/channel assignment into the database.
java.util.List<java.util.Map<java.lang.String,java.lang.String>>	ShardChannelTable.list(Database conn) Return a list of currently known shard/channel assignments.
int	ShardChannelTable.listMaxChannel(Database conn) Return the maximum assigned channel.
int	ShardChannelTable.reduceAssignments(Database conn, int channels) Drop all channel definitions, but only if there are no channel assignments over the currently configured level.

Uses of Database in com.continuent.tungsten.replicator.consistency

Methods in com.continuent.tungsten.replicator.consistency with parameters of type Database

java.sql.ResultSet	ConsistencyCheckMD5.performConsistencyCheck(Database conn)
abstract java.sql.ResultSet	ConsistencyCheckAbstract.performConsistencyCheck(Database conn)
java.sql.ResultSet	ConsistencyCheck.performConsistencyCheck(Database conn)

Uses of Database in com.continuent.tungsten.replicator.database

Classes in com.continuent.tungsten.replicator.database that implement Database

class	AbstractDatabase Provides a generic implementation for Database interface.
class	DerbyDatabase Implements DBMS-specific operations for the Derby database.
class	DrizzleDatabase Implements DBMS-specific operations for MySQL.
class	GreenplumDatabase Implements DBMS-specific operations for MySQL.
class	MySQLDatabase Implements DBMS-specific operations for MySQL.
class	MySQLDrizzleDatabase
class	OracleDatabase Defines an interface to the Oracle database
class	PostgreSQLDatabase Implements DBMS-specific operations for MySQL.
class	VerticaDatabase Implements DBMS-specific operations for Vertica.

Methods in com.continuent.tungsten.replicator.database that return Database

static Database	DatabaseFactory.createDatabase(java.lang.String url, java.lang.String user, java.lang.String password) Shorthand method to allocate a non-privileged connection with no vendor identification.
static Database	DatabaseFactory.createDatabase(java.lang.String url, java.lang.String user, java.lang.String password, boolean privileged) Shorthand method to allocate a privileged connection without vendor identification.
static Database	DatabaseFactory.createDatabase(java.lang.String url, java.lang.String user, java.lang.String password, boolean privileged, java.lang.String vendor) Creates a new connection to a database.

Uses of Database in com.continuent.tungsten.replicator.extractor.oracle

Constructors in com.continuent.tungsten.replicator.extractor.oracle with parameters of type Database

OracleParser(Database database)
Creates a new OracleParser object

Uses of Database in com.continuent.tungsten.replicator.heartbeat

Methods in com.continuent.tungsten.replicator.heartbeat with parameters of type Database

void	HeartbeatTable.applyHeartbeat(Database database, java.sql.Timestamp sourceTimestamp, java.lang.String name) Applies a heartbeat update on the slave.
void	HeartbeatTable.completeHeartbeat(Database database, long seqno, java.lang.String eventId) Execute this call to fill in heartbeat data on the slave.
void	HeartbeatTable.initializeHeartbeatTable(Database database) Set up the heartbeat table on the master.
void	HeartbeatTable.startHeartbeat(Database database, java.lang.String name) Execute this call to start a named heartbeat on the master.

Uses of Database in com.continuent.tungsten.replicator.loader

Fields in com.continuent.tungsten.replicator.loader declared as Database

protected Database

JdbcLoader.conn

Uses of Database in com.continuent.tungsten.replicator.management.tungsten

Methods in com.continuent.tungsten.replicator.management.tungsten with parameters of type Database

static Table	TungstenPlugin.findConsistencyTable(Database conn, java.lang.String replicatorSchema) Tries to locate consistency check table.
static int	TungstenPlugin.findNextConsistencyId(Database conn, Table ct) Finds what ID should be used for the next consistency check.

Uses of Database in com.continuent.tungsten.replicator.prefetch

Fields in com.continuent.tungsten.replicator.prefetch declared as Database

protected Database

PrefetchApplier.conn

Methods in com.continuent.tungsten.replicator.prefetch that return Database

Database

PrefetchApplier.getDatabase()

Uses of Database in com.continuent.tungsten.replicator.shard

Methods in com.continuent.tungsten.replicator.shard with parameters of type Database

int	ShardTable.deleleAll(Database database) Drop all shard definitions.
int	ShardTable.delete(Database database, java.lang.String id) Delete a single existing shard definition.
void	ShardTable.initializeShardTable(Database database) Set up the shard table.
int	ShardTable.insert(Database database, Shard shard) Insert a shard definition into the database.
java.util.List<java.util.Map<java.lang.String,java.lang.String>>	ShardTable.list(Database conn) Return a list of currently known shards.
int	ShardTable.update(Database database, Shard shard) Update an existing shard definition.

Uses of Database in com.continuent.tungsten.replicator.thl

Methods in com.continuent.tungsten.replicator.thl with parameters of type Database

boolean

CommitSeqnoTable.reduceTasks(Database conn, int channels) Reduces the trep_commit_seqno table to task 0 entry *provided* there is a task 0 row and provide all rows are at the same sequence number.

Constructors in com.continuent.tungsten.replicator.thl with parameters of type Database

CommitSeqnoTable(Database database, java.lang.String schema, java.lang.String tableType, boolean syncNativeSlaveRequired)
Creates a new instance valid for life of the provided database connection.