Package net.avcompris.commons3.dao.impl

Class AbstractDaoInRDS

java.lang.Object

net.avcompris.commons3.dao.impl.AbstractDao

net.avcompris.commons3.dao.impl.AbstractDaoInRDS

public abstract class AbstractDaoInRDS
extends AbstractDao

Nested Class Summary

Nested classes/interfaces inherited from class net.avcompris.commons3.dao.impl.AbstractDao

AbstractDao.Action<T>

Field Summary

Fields

Modifier and Type	Field	Description
static final String	PSQL_FOREIGN_ENTITY_VIOLATION
static final String	PSQL_UNIQUE_VIOLATION
protected static final String	SCHEMA_VERSION_COLUMN_NAME
protected final String	tableName

Fields inherited from class net.avcompris.commons3.dao.impl.AbstractDao

clock

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractDaoInRDS(DataSource dataSource, String tableName, Clock clock)

Method Summary

Modifier and Type	Method	Description
protected static boolean	getBoolean(ResultSet rs, int columnIndex)
protected static boolean	getBoolean(ResultSet rs, String columnName)
protected static byte[]	getBytes(ResultSet rs, int columnIndex)
protected static byte[]	getBytes(ResultSet rs, String columnName)
protected final Connection	getConnection()
protected static org.joda.time.DateTime	getDateTime(ResultSet rs, int columnIndex)
protected static org.joda.time.DateTime	getDateTime(ResultSet rs, String columnName)
protected static <T extends Enum<T>> T	getEnum(ResultSet rs, int columnIndex, Class<T> enumClass)
protected static <T extends Enum<T>> T	getEnum(ResultSet rs, String columnName, Class<T> enumClass)
protected static Integer	getInt(ResultSet rs, int columnIndex)
protected static Integer	getInt(ResultSet rs, String columnName)
protected static Integer	getInteger(ResultSet rs, int columnIndex)
protected static Integer	getInteger(ResultSet rs, String columnName)
protected static Long	getLong(ResultSet rs, int columnIndex)
protected static Long	getLong(ResultSet rs, String columnName)
protected static String	getString(ResultSet rs, int columnIndex)
protected static String	getString(ResultSet rs, String columnName)
static boolean	isPSQLForeignEntityViolation(SQLException e)
static boolean	isPSQLUniqueViolation(SQLException e)
protected static String	joinRefIds(String... refIds)
protected final void	setBinaryStream(PreparedStatement pstmt, int paramIndex, InputStream is)
protected final void	setBoolean(PreparedStatement pstmt, int paramIndex, boolean value)
protected final void	setBytes(PreparedStatement pstmt, int paramIndex, byte[] bytes)
protected final void	setDateTime(PreparedStatement pstmt, int paramIndex, org.joda.time.DateTime dateTime)
protected final void	setDouble(PreparedStatement pstmt, int paramIndex, double value)
protected final void	setInt(PreparedStatement pstmt, int paramIndex, int value)
protected final void	setInteger(PreparedStatement pstmt, int paramIndex, Integer value)
protected final void	setLong(PreparedStatement pstmt, int paramIndex, Long value)
protected final void	setObject(PreparedStatement pstmt, int paramIndex, Object o)
protected final void	setString(PreparedStatement pstmt, int paramIndex, String s)
protected static String	toSQLLimitClause(int start, int limit)
protected static final String	toSQLOrderByDirective(EntitiesDtoQuery.SortBy... sortBys)

Methods inherited from class net.avcompris.commons3.dao.impl.AbstractDao

retryUntil, retryUntil

Methods inherited from class java.lang.Object

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

Field Details

SCHEMA_VERSION_COLUMN_NAME

protected static final String SCHEMA_VERSION_COLUMN_NAME

See Also:

• Constant Field Values

tableName

protected final String tableName

PSQL_UNIQUE_VIOLATION

public static final String PSQL_UNIQUE_VIOLATION

See Also:

• Constant Field Values

PSQL_FOREIGN_ENTITY_VIOLATION

public static final String PSQL_FOREIGN_ENTITY_VIOLATION

See Also:

• Constant Field Values

Constructor Details

AbstractDaoInRDS

protected AbstractDaoInRDS(DataSource dataSource,
 String tableName,
 Clock clock)

Method Details

getConnection

protected final Connection getConnection()
                                  throws SQLException

Throws:

SQLException

toSQLOrderByDirective

protected static final String toSQLOrderByDirective(EntitiesDtoQuery.SortBy... sortBys)

toSQLLimitClause

protected static String toSQLLimitClause(int start,
 int limit)

getInteger

@Nullable
protected static Integer getInteger(ResultSet rs,
 String columnName)
                             throws SQLException

Throws:

SQLException

getInteger

@Nullable
protected static Integer getInteger(ResultSet rs,
 int columnIndex)
                             throws SQLException

Throws:

SQLException

getInt

@Nullable
protected static Integer getInt(ResultSet rs,
 String columnName)
                         throws SQLException

Throws:

SQLException

getInt

@Nullable
protected static Integer getInt(ResultSet rs,
 int columnIndex)
                         throws SQLException

Throws:

SQLException

getLong

@Nullable
protected static Long getLong(ResultSet rs,
 String columnName)
                       throws SQLException

Throws:

SQLException

getLong

@Nullable
protected static Long getLong(ResultSet rs,
 int columnIndex)
                       throws SQLException

Throws:

SQLException

getDateTime

@Nullable
protected static org.joda.time.DateTime getDateTime(ResultSet rs,
 String columnName)
                                             throws SQLException

Throws:

SQLException

getDateTime

@Nullable
protected static org.joda.time.DateTime getDateTime(ResultSet rs,
 int columnIndex)
                                             throws SQLException

Throws:

SQLException

getBytes

@Nullable
protected static byte[] getBytes(ResultSet rs,
 String columnName)
                          throws SQLException,
IOException

Throws:

SQLException

IOException

getBytes

@Nullable
protected static byte[] getBytes(ResultSet rs,
 int columnIndex)
                          throws SQLException,
IOException

Throws:

SQLException

IOException

getString

@Nullable
protected static String getString(ResultSet rs,
 String columnName)
                           throws SQLException

Throws:

SQLException

getEnum

@Nullable
protected static <T extends Enum<T>> T getEnum(ResultSet rs,
 int columnIndex,
 Class<T> enumClass)
                                        throws SQLException

Throws:

SQLException

getEnum

@Nullable
protected static <T extends Enum<T>> T getEnum(ResultSet rs,
 String columnName,
 Class<T> enumClass)
                                        throws SQLException

Throws:

SQLException

getString

@Nullable
protected static String getString(ResultSet rs,
 int columnIndex)
                           throws SQLException

Throws:

SQLException

getBoolean

@Nullable
protected static boolean getBoolean(ResultSet rs,
 String columnName)
                             throws SQLException

Throws:

SQLException

getBoolean

@Nullable
protected static boolean getBoolean(ResultSet rs,
 int columnIndex)
                             throws SQLException

Throws:

SQLException

setString

protected final void setString(PreparedStatement pstmt,
 int paramIndex,
 @Nullable
 String s)
                        throws SQLException

Throws:

SQLException

setObject

protected final void setObject(PreparedStatement pstmt,
 int paramIndex,
 @Nullable
 Object o)
                        throws SQLException

Throws:

SQLException

setBinaryStream

protected final void setBinaryStream(PreparedStatement pstmt,
 int paramIndex,
 @Nullable
 InputStream is)
                              throws SQLException

Throws:

SQLException

setInteger

protected final void setInteger(PreparedStatement pstmt,
 int paramIndex,
 @Nullable
 Integer value)
                         throws SQLException

Throws:

SQLException

setInt

protected final void setInt(PreparedStatement pstmt,
 int paramIndex,
 int value)
                     throws SQLException

Throws:

SQLException

setDouble

protected final void setDouble(PreparedStatement pstmt,
 int paramIndex,
 double value)
                        throws SQLException

Throws:

SQLException

setBoolean

protected final void setBoolean(PreparedStatement pstmt,
 int paramIndex,
 boolean value)
                         throws SQLException

Throws:

SQLException

setBytes

protected final void setBytes(PreparedStatement pstmt,
 int paramIndex,
 byte[] bytes)
                       throws SQLException

Throws:

SQLException

isPSQLUniqueViolation

public static boolean isPSQLUniqueViolation(@Nullable
 SQLException e)

isPSQLForeignEntityViolation

public static boolean isPSQLForeignEntityViolation(@Nullable
 SQLException e)

setLong

protected final void setLong(PreparedStatement pstmt,
 int paramIndex,
 @Nullable
 Long value)
                      throws SQLException

Throws:

SQLException

setDateTime

protected final void setDateTime(PreparedStatement pstmt,
 int paramIndex,
 @Nullable
 org.joda.time.DateTime dateTime)
                          throws SQLException

Throws:

SQLException

joinRefIds

@Nullable
protected static String joinRefIds(@Nullable
 String... refIds)