Class PostgresDialect

java.lang.Object

org.jobrunr.storage.sql.common.db.AnsiDialect

org.jobrunr.storage.sql.postgres.PostgresDialect

All Implemented Interfaces:

Dialect

public class PostgresDialect
extends AnsiDialect

Constructor Summary

Constructors

Constructor	Description
PostgresDialect()

Method Summary

Modifier and Type	Method	Description
String	selectForUpdateSkipLocked()

Methods inherited from class AnsiDialect

limit, limitAndOffset

Modifier and Type	Method	Description
String	limit()
String	limitAndOffset()

Methods inherited from class Object

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

Methods inherited from interface Dialect

escape, isUniqueConstraintException, setBoolean, setDouble, setDuration, setEnum, setInt, setLong, setNull, setParam, setString, setTimestamp, setUUID

Modifier and Type	Method	Description
default String	escape(String toEscape)
default boolean	isUniqueConstraintException(SQLException e)
default void	setBoolean(PreparedStatement ps, int i, String paramName, boolean boolValue)
default void	setDouble(PreparedStatement ps, int i, String paramName, Double doubleValue)
default void	setDuration(PreparedStatement ps, int i, String paramName, Duration duration)
default void	setEnum(PreparedStatement ps, int i, String paramName, Enum<?> enumValue)
default void	setInt(PreparedStatement ps, int i, String paramName, Integer intValue)
default void	setLong(PreparedStatement ps, int i, String paramName, Long longValue)
default void	setNull(PreparedStatement ps, int i, String paramName)
default void	setParam(PreparedStatement ps, int i, String paramName, Object o)
default void	setString(PreparedStatement ps, int i, String paramName, String stringValue)
default void	setTimestamp(PreparedStatement ps, int i, String paramName, Instant instant)
default void	setUUID(PreparedStatement ps, int i, String paramName, UUID uuidValue)

Constructor Details

PostgresDialect

public PostgresDialect()

Method Details

selectForUpdateSkipLocked

public String selectForUpdateSkipLocked()