org.apache.beam.it.jdbc

Class MSSQLResourceManager

java.lang.Object

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

org.apache.beam.it.jdbc.AbstractJDBCResourceManager<org.apache.beam.it.jdbc.MSSQLResourceManager.DefaultMSSQLServerContainer<?>>

org.apache.beam.it.jdbc.MSSQLResourceManager

All Implemented Interfaces:

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

public class MSSQLResourceManager
extends AbstractJDBCResourceManager<org.apache.beam.it.jdbc.MSSQLResourceManager.DefaultMSSQLServerContainer<?>>

Default class for the MS SQL 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	MSSQLResourceManager.Builder Builder for MSSQLResourceManager.

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 MSSQLResourceManager.Builder	builder(java.lang.String testId)
protected java.lang.String	getFirstRow(java.lang.String tableName) Retrieves the first row from the table.
protected int	getJDBCPort() Return the default port that this JDBC implementation listens on.
java.lang.String	getJDBCPrefix()
java.lang.String	getUri() Returns the URI connection string to the JDBC Database.

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

createTable, getDatabaseName, getPassword, getPort, getRowCount, getTableSchema, 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 MSSQLResourceManager.Builder builder(java.lang.String testId)

getUri

public java.lang.String getUri()

Description copied from interface: JDBCResourceManager

Returns the URI connection string to the JDBC Database.

Specified by:

getUri in interface JDBCResourceManager

Overrides:

getUri in class AbstractJDBCResourceManager<org.apache.beam.it.jdbc.MSSQLResourceManager.DefaultMSSQLServerContainer<?>>

getJDBCPrefix

public java.lang.String getJDBCPrefix()

Specified by:

getJDBCPrefix in class AbstractJDBCResourceManager<org.apache.beam.it.jdbc.MSSQLResourceManager.DefaultMSSQLServerContainer<?>>

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<org.apache.beam.it.jdbc.MSSQLResourceManager.DefaultMSSQLServerContainer<?>>

Returns:

the JDBC port.

getFirstRow

protected java.lang.String getFirstRow(java.lang.String tableName)

Description copied from class: AbstractJDBCResourceManager

Retrieves the first row from the table.

Overrides:

getFirstRow in class AbstractJDBCResourceManager<org.apache.beam.it.jdbc.MSSQLResourceManager.DefaultMSSQLServerContainer<?>>

Parameters:

tableName - the name of the table to query.

Returns:

the first row from the table.