void createTableWithoutPartitionColumn()

in java/clickhouse-connector/src/integration-test/java/com/epam/deltix/timebase/connector/clickhouse/CustomTableSchemaTests.java [149:182]

29 lines of code
2 McCabe index (conditional complexity)


    void createTableWithoutPartitionColumn() {
        TableDeclaration tableDeclaration = null;

        try {
            RecordClassSet classSet = new RecordClassSet(stream.isFixedType() ?
                    new RecordClassDescriptor[]{stream.getFixedType()} :
                    stream.getPolymorphicDescriptors());
            Map<String, String> mapping = new HashMap<>() {{
                put(ALL_TYPES, stream.getKey());
            }};

            tableDeclaration = Util.getTableDeclaration(
                    new SchemaOptions(classSet, mapping, WriteMode.APPEND, ColumnNamingScheme.TYPE_AND_NAME, false)).get(ALL_TYPES);

            assertFalse(tableDeclaration.getColumns().stream().map(ColumnDeclaration::getDbColumnName).anyMatch(SchemaProcessor.PARTITION_COLUMN_NAME::equals));
            assertFalse(clickhouseClient.existsTable(tableDeclaration.getTableIdentity()));
            StreamRequest streamRequest = new StreamRequest();
            streamRequest.setKey(stream.getKey());
            streamRequest.setStream(stream.getKey());
            streamRequest.setColumnNamingScheme(ColumnNamingScheme.TYPE_AND_NAME);
            streamRequest.setIncludePartitionColumn(false);
            startStreamReplication(stream, tableDeclaration.getTableIdentity(), 1, 1, 1, streamRequest);
            assertTrue(clickhouseClient.existsTable(tableDeclaration.getTableIdentity()));

            TableDeclaration actualTable = clickhouseClient.describeTable(tableDeclaration.getTableIdentity());
            assertFalse(actualTable.getColumns().stream().map(ColumnDeclaration::getDbColumnName).anyMatch(SchemaProcessor.PARTITION_COLUMN_NAME::equals));
            assertEquals(10, actualTable.getColumns().size());
            Map<String, Object> values = selectAllValues(tableDeclaration).get(0);
            assertFalse(values.containsKey(SchemaProcessor.PARTITION_COLUMN_NAME));
        } finally {
            clickhouseClient.dropTable(tableDeclaration.getTableIdentity());
        }

    }