public Connection getOrEstablishConnection()

in src/main/java/org/apache/doris/kafka/connector/connection/JdbcConnectionProvider.java [49:68]

• 20 lines of code
• 6 McCabe index (conditional complexity)

    public Connection getOrEstablishConnection() throws ClassNotFoundException, SQLException {
        if (connection != null && !connection.isClosed() && connection.isValid(10)) {
            return connection;
        }
        try {
            Class.forName(CJ_DRIVER_NAME);
        } catch (ClassNotFoundException ex) {
            LOG.warn(
                    "can not found class com.mysql.cj.jdbc.Driver, use class com.mysql.jdbc.Driver");
            Class.forName(DRIVER_NAME);
        }
        String jdbcUrl = String.format(JDBC_URL_TEMPLATE, options.getQueryUrl());
        if (!Objects.isNull(options.getUser())) {
            connection =
                    DriverManager.getConnection(jdbcUrl, options.getUser(), options.getPassword());
        } else {
            connection = DriverManager.getConnection(jdbcUrl);
        }
        return connection;
    }