io.nflow.engine.internal.storage.db

Interface SQLVariants

All Known Implementing Classes:

Db2DatabaseConfiguration.Db2SQLVariants, H2DatabaseConfiguration.H2SQLVariants, MySQLVariants, OracleDatabaseConfiguration.OracleSqlVariants, PgDatabaseConfiguration.PostgreSQLVariants, SqlServerDatabaseConfiguration.SQLServerVariants

public interface SQLVariants

Method Summary

Modifier and Type	Method and Description
String	actionType()
String	castToText()
String	currentTimePlusSeconds(int seconds)
default String	dateLtEqDiff(String next_activation, String current_timestamp)
default String	forUpdateSkipLocked()
default org.joda.time.DateTime	getDateTime(ResultSet rs, String columnName)
default Object	getTimestamp(ResultSet rs, String columnName)
boolean	hasUpdateableCTE()
default boolean	hasUpdateReturning()
String	limit(String query, long limit)
int	longTextType()
String	nextActivationUpdate()
default void	setDateTime(PreparedStatement ps, int columnNumber, org.joda.time.DateTime timestamp)
default Object	toTimestampObject(org.joda.time.DateTime timestamp)
default Object	tuneTimestampForDb(Object timestamp)
boolean	useBatchUpdate()
default String	withUpdateSkipLocked()
String	workflowStatus()
String	workflowStatus(WorkflowInstance.WorkflowInstanceStatus status)

Method Detail

currentTimePlusSeconds

String currentTimePlusSeconds(int seconds)

hasUpdateReturning

default boolean hasUpdateReturning()

workflowStatus

String workflowStatus(WorkflowInstance.WorkflowInstanceStatus status)

workflowStatus

String workflowStatus()

actionType

String actionType()

hasUpdateableCTE

boolean hasUpdateableCTE()

nextActivationUpdate

String nextActivationUpdate()

castToText

String castToText()

limit

String limit(String query,
             long limit)

longTextType

int longTextType()

useBatchUpdate

boolean useBatchUpdate()

forUpdateSkipLocked

default String forUpdateSkipLocked()

dateLtEqDiff

default String dateLtEqDiff(String next_activation,
                            String current_timestamp)

getTimestamp

default Object getTimestamp(ResultSet rs,
                            String columnName)
                     throws SQLException

Throws:

SQLException

getDateTime

default org.joda.time.DateTime getDateTime(ResultSet rs,
                                           String columnName)
                                    throws SQLException

Throws:

SQLException

setDateTime

default void setDateTime(PreparedStatement ps,
                         int columnNumber,
                         org.joda.time.DateTime timestamp)
                  throws SQLException

Throws:

SQLException

toTimestampObject

default Object toTimestampObject(org.joda.time.DateTime timestamp)

tuneTimestampForDb

default Object tuneTimestampForDb(Object timestamp)

withUpdateSkipLocked

default String withUpdateSkipLocked()