org.apache.beam.it.jdbc

Class MySQLResourceManager

java.lang.Object

org.apache.beam.it.testcontainers.TestContainerResourceManager<JdbcDatabaseContainer<?>>

org.apache.beam.it.jdbc.AbstractJDBCResourceManager<MySQLContainer<?>>

org.apache.beam.it.jdbc.MySQLResourceManager

All Implemented Interfaces:

org.apache.beam.it.common.ResourceManager, JDBCResourceManager

public class MySQLResourceManager
extends AbstractJDBCResourceManager<MySQLContainer<?>>

Default class for the MySQL implementation of AbstractJDBCResourceManager abstract class.

The class supports one database, and multiple tables per database object. A database is * created when the container first spins up, if one is not given.

The class is thread-safe.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MySQLResourceManager.Builder Builder for MySQLResourceManager.

Nested classes/interfaces inherited from interface org.apache.beam.it.jdbc.JDBCResourceManager

JDBCResourceManager.JDBCSchema

Field Summary

Fields inherited from class org.apache.beam.it.jdbc.AbstractJDBCResourceManager

databaseName, DEFAULT_JDBC_USERNAME, driver, password, username

Fields inherited from class org.apache.beam.it.testcontainers.TestContainerResourceManager

HOST_IP, port

Method Summary

Modifier and Type	Method and Description
static MySQLResourceManager.Builder	builder(java.lang.String testId)
protected int	getJDBCPort() Return the default port that this JDBC implementation listens on.
java.lang.String	getJDBCPrefix()

Methods inherited from class org.apache.beam.it.jdbc.AbstractJDBCResourceManager

createTable, getDatabaseName, getFirstRow, getPassword, getTableSchema, getUri, getUsername, readTable, runSQLQuery, runSQLUpdate, write

Methods inherited from class org.apache.beam.it.testcontainers.TestContainerResourceManager

cleanupAll, getDockerImageName, getHost, getPort

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.beam.it.common.ResourceManager

cleanupAll

Method Detail

builder

public static MySQLResourceManager.Builder builder(java.lang.String testId)

getJDBCPort

protected int getJDBCPort()

Description copied from class: AbstractJDBCResourceManager

Return the default port that this JDBC implementation listens on.

Specified by:

getJDBCPort in class AbstractJDBCResourceManager<MySQLContainer<?>>

Returns:

the JDBC port.

getJDBCPrefix

public java.lang.String getJDBCPrefix()

Specified by:

getJDBCPrefix in class AbstractJDBCResourceManager<MySQLContainer<?>>