private String getVersion()

in src/main/java/com/epam/digital/data/platform/liquibase/extension/change/core/DdmAddColumnChange.java [209:237]

• 23 lines of code
• 4 McCabe index (conditional complexity)

    private String getVersion(Database database) {
        String version = null;

        Statement statement = null;
        ResultSet resultSet = null;

        if (database.getConnection() instanceof JdbcConnection) {
            try {
                statement = ((JdbcConnection) database.getConnection()).createStatement(
                    ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY);

                String sql = "SELECT count(*) FROM pg_catalog.pg_tables where schemaname='" +
                    ARCHIVE_SCHEMA + "' and tablename like '" + getTableName() + "__%';";

                resultSet = statement.executeQuery(sql);

                if (resultSet.next()) {
                    version = "__" + resultSet.getInt("count");
                }
            } catch (SQLException | DatabaseException e) {
                Scope.getCurrentScope().getLog(database.getClass())
                    .info("Cannot select version", e);
            } finally {
                JdbcUtils.close(resultSet, statement);
            }
        }

        return version;
    }