Package com.github.kagkarlsson.scheduler.jdbc

Interface JdbcCustomization

All Known Implementing Classes:

AutodetectJdbcCustomization, DefaultJdbcCustomization, MariaDBJdbcCustomization, MssqlJdbcCustomization, MySQL8JdbcCustomization, MySQLJdbcCustomization, OracleJdbcCustomization, PostgreSqlJdbcCustomization

public interface JdbcCustomization

Method Summary

Modifier and Type	Method	Description
String	createGenericSelectForUpdateQuery(String tableName, int limit, String requiredAndCondition, boolean orderByPriority)
String	createSelectDueQuery(String tableName, int limit, String andCondition, boolean orderByPriority)
Instant	getInstant(ResultSet rs, String columnName)
String	getName()
String	getQueryLimitPart(int limit)
byte[]	getTaskData(ResultSet rs, String columnName)
List<Execution>	lockAndFetchSingleStatement(JdbcTaskRepositoryContext ctx, Instant now, int limit, boolean orderByPriority)
void	setInstant(PreparedStatement p, int index, Instant value)
void	setTaskData(PreparedStatement p, int index, byte[] value)
boolean	supportsExplicitQueryLimitPart()
boolean	supportsGenericLockAndFetch()
boolean	supportsSingleStatementLockAndFetch()

Method Details

getName

String getName()

setInstant

void setInstant(PreparedStatement p,
 int index,
 Instant value)
         throws SQLException

Throws:

SQLException

getInstant

Instant getInstant(ResultSet rs,
 String columnName)
            throws SQLException

Throws:

SQLException

setTaskData

void setTaskData(PreparedStatement p,
 int index,
 byte[] value)
          throws SQLException

Throws:

SQLException

getTaskData

byte[] getTaskData(ResultSet rs,
 String columnName)
            throws SQLException

Throws:

SQLException

supportsExplicitQueryLimitPart

boolean supportsExplicitQueryLimitPart()

getQueryLimitPart

String getQueryLimitPart(int limit)

supportsSingleStatementLockAndFetch

boolean supportsSingleStatementLockAndFetch()

lockAndFetchSingleStatement

List<Execution> lockAndFetchSingleStatement(JdbcTaskRepositoryContext ctx,
 Instant now,
 int limit,
 boolean orderByPriority)

supportsGenericLockAndFetch

boolean supportsGenericLockAndFetch()

createGenericSelectForUpdateQuery

String createGenericSelectForUpdateQuery(String tableName,
 int limit,
 String requiredAndCondition,
 boolean orderByPriority)

createSelectDueQuery

String createSelectDueQuery(String tableName,
 int limit,
 String andCondition,
 boolean orderByPriority)