seatunnel-datasource/seatunnel-datasource-plugins/datasource-plugins-api/src/main/java/org/apache/seatunnel/datasource/plugin/api/utils/JdbcUtils.java [22:31]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public static String replaceDatabase(String jdbcUrl, String databaseName) {
        if (databaseName == null) {
            return jdbcUrl;
        }
        String[] split = jdbcUrl.split("\\?");
        if (split.length == 1) {
            return replaceDatabaseWithoutParameter(jdbcUrl, databaseName);
        }
        return replaceDatabaseWithoutParameter(split[0], databaseName) + "?" + split[1];
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



seatunnel-server/seatunnel-app/src/main/java/org/apache/seatunnel/app/utils/JdbcUtils.java [38:47]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public static String replaceDatabase(String jdbcUrl, String databaseName) {
        if (databaseName == null) {
            return jdbcUrl;
        }
        String[] split = jdbcUrl.split("\\?");
        if (split.length == 1) {
            return replaceDatabaseWithoutParameter(jdbcUrl, databaseName);
        }
        return replaceDatabaseWithoutParameter(split[0], databaseName) + "?" + split[1];
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -