public void testUpdateMigrationMetadata()

in timescaledb-connector/src/integration-test/java/com/epam/deltix/timebase/connector/service/timescale/TimescaleMigrationMetadataServiceTest.java [60:85]


    public void testUpdateMigrationMetadata() {
        migrationMetadataService.createMigrationTable();

        MigrationMetadata metadata = MigrationMetadata.builder()
                .stream("orders")
                .version(7l)
                .isSuccess(Boolean.TRUE)
                .dateTime(0l)
                .build();

        dataService.saveMigrationMetadata(metadata);

        metadata.setDateTime(7l);
        metadata.setIsSuccess(Boolean.FALSE);
        metadata.setVersion(8l);

        dataService.updateMigrationMetadata(metadata);

        MigrationMetadata updatedMetadata = dataService.getMigrationMetadata("orders").get();

        assertThat(updatedMetadata.getId(), is(1));
        assertThat(updatedMetadata.getDateTime(), is(7l));
        assertThat(updatedMetadata.getStream(), is("orders"));
        assertThat(updatedMetadata.getIsSuccess(), is(Boolean.FALSE));
        assertThat(updatedMetadata.getVersion(), is(8l));
    }