in src/main/java/com/epam/digital/data/platform/kafkaapi/core/service/SequenceGenerator.java [45:61]
public Long nextValue(String sequenceName) {
log.info("Generate next value by sequence {}", sequenceName);
try (Connection connection = DataSourceUtils.getConnection(this.dataSource);
var statement = connection.prepareStatement(
String.format(REQUEST_TEMPLATE, sequenceName))
) {
ResultSet resultSet = statement.executeQuery();
if (resultSet.next()) {
return resultSet.getLong(1);
} else {
throw new SequenceGeneratorException("Generation of next value failed. Next value absent");
}
} catch (SQLException e) {
throw SQLExceptionResolverUtil.getDetailedExceptionFromSql(e);
}
}