private static Connection establishDatabaseConnection(String url, String user, String password) throws Exception {
        Connection conn;
        if (StringUtils.isBlank(url) || !url.startsWith(OCEANBASE_JDBC_PREFIX)) {
            throw new Exception("OceanusBase URL is invalid, it should start with jdbc:oceanbase");
        }
        try {
            UrlVerificationUtils.extractHostAndValidatePortFromJdbcUrl(url, OCEANBASE_JDBC_PREFIX);
            url = MySQLSensitiveUrlUtils.filterSensitive(url);
            Class.forName(OCEANBASE_DRIVER_CLASS);
            conn = DriverManager.getConnection(url, user, password);
        } catch (Exception e) {
            String errorMsg =
                    "Failed to get OceanBase connection, please check OceanBase JDBC URL, username, or password!";
            LOGGER.error(errorMsg, e);
            throw new Exception(errorMsg + " Other error message: " + e.getMessage());
        }
        if (conn == null) {
            throw new Exception("get OceanBase connection failed, please contact administrator");
        }
        LOGGER.info("get OceanBase connection success for url={}", url);
        return conn;
    }
Establishes a database connection using the provided URL, username, and password.

@param url      The JDBC URL
@param user     The username
@param password The user's password
@return A {@link Connection} object representing the database connection
@throws Exception If an error occurs while obtaining the connection
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/oceanbase/OceanBaseJdbcUtils.java