in timescaledb-connector/src/main/java/com/epam/deltix/timebase/connector/service/timescale/TimescaleDataService.java [138:152]
public Optional<MigrationMetadata> getMigrationMetadata(String streamName) {
try {
return Optional.of(jdbcTemplate.queryForObject(TimescaleSqlGenerator.GET_MIGRATION_METADATA_STATEMENT, (rs, rowNum) ->
MigrationMetadata.builder()
.dateTime(rs.getTimestamp("MigrationDateTime").getTime())
.id(rs.getInt("Id"))
.isSuccess(rs.getBoolean("IsSuccess"))
.stream(rs.getString("Stream"))
.version(rs.getLong("Version"))
.build()
, streamName));
} catch (EmptyResultDataAccessException ex) {
return Optional.empty();
}
}