obhbasewriter/src/main/java/com/alibaba/datax/plugin/writer/obhbasewriter/ext/ServerConnectInfo.java [71:110]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
		int tenantIndex = fullUserName.indexOf("@");
		int clusterIndex = fullUserName.indexOf("#");
		// 适用于jdbcUrl以||_dsc_ob10_dsc_开头的场景
		if (fullUserName.contains(":") && tenantIndex < 0) {
			String[] names = fullUserName.split(":");
			if (names.length != 3) {
				throw new RuntimeException("invalid argument: " + fullUserName);
			} else {
				this.clusterName = names[0];
				this.tenantName = names[1];
				this.userName = names[2];
			}
		} else if (tenantIndex < 0) {
			// 适用于short jdbcUrl，且username中不含租户名（主要是公有云场景，此场景下不计算分区）
			this.userName = fullUserName;
			this.clusterName = EMPTY;
			this.tenantName = EMPTY;
		} else {
			// 适用于short jdbcUrl，且username中含租户名
			this.userName = fullUserName.substring(0, tenantIndex);
			if (clusterIndex < 0) {
				this.clusterName = EMPTY;
				this.tenantName = fullUserName.substring(tenantIndex + 1);
			} else {
				this.clusterName = fullUserName.substring(clusterIndex + 1);
				this.tenantName = fullUserName.substring(tenantIndex + 1, clusterIndex);
			}
		}
	}

	@Override
	public String toString() {
		return "ServerConnectInfo{" +
				"clusterName='" + clusterName + '\'' +
				", tenantName='" + tenantName + '\'' +
				", userName='" + userName + '\'' +
				", password='" + password + '\'' +
				", databaseName='" + databaseName + '\'' +
				", ipPort='" + ipPort + '\'' +
				", jdbcUrl='" + jdbcUrl + '\'' +
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/ext/ServerConnectInfo.java [51:90]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        int tenantIndex = fullUserName.indexOf("@");
        int clusterIndex = fullUserName.indexOf("#");
        // 适用于jdbcUrl以||_dsc_ob10_dsc_开头的场景
        if (fullUserName.contains(":") && tenantIndex < 0) {
            String[] names = fullUserName.split(":");
            if (names.length != 3) {
                throw new RuntimeException("invalid argument: " + fullUserName);
            } else {
                this.clusterName = names[0];
                this.tenantName = names[1];
                this.userName = names[2];
            }
        } else if (tenantIndex < 0) {
            // 适用于short jdbcUrl，且username中不含租户名（主要是公有云场景，此场景下不计算分区）
            this.userName = fullUserName;
            this.clusterName = EMPTY;
            this.tenantName = EMPTY;
        } else {
            // 适用于short jdbcUrl，且username中含租户名
            this.userName = fullUserName.substring(0, tenantIndex);
            if (clusterIndex < 0) {
                this.clusterName = EMPTY;
                this.tenantName = fullUserName.substring(tenantIndex + 1);
            } else {
                this.clusterName = fullUserName.substring(clusterIndex + 1);
                this.tenantName = fullUserName.substring(tenantIndex + 1, clusterIndex);
            }
        }
    }

    @Override
    public String toString() {
        return "ServerConnectInfo{" +
                "clusterName='" + clusterName + '\'' +
                ", tenantName='" + tenantName + '\'' +
                ", userName='" + userName + '\'' +
                ", password='" + password + '\'' +
                ", databaseName='" + databaseName + '\'' +
                ", ipPort='" + ipPort + '\'' +
                ", jdbcUrl='" + jdbcUrl + '\'' +
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -