org.apache.beam.it.jdbc

Class PostgresResourceManager

java.lang.Object

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

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

org.apache.beam.it.jdbc.PostgresResourceManager

All Implemented Interfaces:

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

public class PostgresResourceManager
extends AbstractJDBCResourceManager<PostgreSQLContainer<?>>

Default class for the Postgres 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	PostgresResourceManager.Builder Builder for PostgresResourceManager.

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 PostgresResourceManager.Builder	builder(java.lang.String testId)
java.lang.String	getDockerImageName()
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, getPort, getRowCount, getTableSchema, getUri, getUsername, readTable, runSQLQuery, runSQLUpdate, write

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

cleanupAll, 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 PostgresResourceManager.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<PostgreSQLContainer<?>>

Returns:

the JDBC port.

getJDBCPrefix

public java.lang.String getJDBCPrefix()

Specified by:

getJDBCPrefix in class AbstractJDBCResourceManager<PostgreSQLContainer<?>>

getDockerImageName

public java.lang.String getDockerImageName()

Overrides:

getDockerImageName in class TestContainerResourceManager<JdbcDatabaseContainer<?>>