private void initClickhouse()

in java/clickhouse-connector/src/integration-test/java/com/epam/deltix/timebase/connector/clickhouse/BaseStreamReplicatorTests.java [130:168]

34 lines of code
6 McCabe index (conditional complexity)


    private void initClickhouse() {
        String url = System.getenv(CLICKHOUSE_URL_SYSTEM_VAR_NAME);
        String user = System.getenv(CLICKHOUSE_USER_SYSTEM_VAR_NAME);
        String version = System.getenv(CLICKHOUSE_SERVER_VERSION);
        if (StringUtils.isEmpty(version)){
            version = DEFAULT_CLICKHOUSE_SERVER_VERSION;
        }
        if (StringUtils.isEmpty(url) || StringUtils.isEmpty(user)) {
            ClickHouseContainer ch = DockerClickHouseContainer.getInstance(version).getContainer();
            url = ch.getJdbcUrl();
            user = ch.getUsername();
        }

        final Properties clickHouseProperties = new Properties();
        clickHouseProperties.put(USE_OBJECTS_IN_ARRAYS.getKey(), true);
        clickHouseProperties.put(ClickHouseDefaults.USER.getKey(), user);
        DataSource dataSource;
        try {
            dataSource = new ClickHouseDataSource(url, clickHouseProperties);
        } catch (SQLException e) {
            throw new RuntimeException(e);
        }

        clickhouseClient = new ClickhouseClient(dataSource);

        ClickhouseProperties internalProperties = new ClickhouseProperties();
        internalProperties.setUrl(url);
        internalProperties.setUsername(user);
        internalProperties.setPassword("");
        internalProperties.setDatabase(CLICKHOUSE_DATABASE_NAME);

        this.clickhouseProperties = internalProperties;

        try {
            clickhouseClient.createDatabase(clickhouseProperties.getDatabase(), true);
        } catch (SQLException e) {
            throw new RuntimeException(e);
        }
    }