public void testGenerateDropRecordStatement()

in timescaledb-connector/src/integration-test/java/com/epam/deltix/timebase/connector/service/timescale/TimescaleSqlGeneratorTest.java [355:380]

20 lines of code
1 McCabe index (conditional complexity)


    public void testGenerateDropRecordStatement() {
        TimescaleSchema schema = getValidSchema();

        TimescaleColumn descriptorNameColumn = TimescaleColumn.builder()
                .name("descriptor_name")
                .dataType(TimescaleColumn.TimescaleDataType.VARCHAR)
                .relatedDescriptors(Collections.emptyList())
                .build();

        List<TimescaleColumn> columns = new ArrayList<>();
        columns.add(descriptorNameColumn);
        columns.addAll(schema.getColumns());

        schema.setColumns(columns);

        String createTableStatement = sqlGenerator.generateCreateTableStatement(schema);
        String createHypertableStatement = sqlGenerator.generateHypertableStatement(schema);
        String dropRecordStatement = sqlGenerator.generateDropRecordStatement(schema.getName(),
                descriptorNameColumn.getName(), "prevDescriptorName");

        dataService.executeQuery(createTableStatement);
        dataService.executeQuery(createHypertableStatement);
        dataService.executeQuery(dropRecordStatement);

        assertThat(dropRecordStatement, is("DELETE FROM \"orders-123\" WHERE descriptor_name = 'prevDescriptorName'"));
    }