import com.sforce.soap.partner.UpsertResult; //导入依赖的package包/类
private static DeployResponse handleMetadataResponse(DeployResponse dr,
    com.sforce.soap.metadata.UpsertResult[] results) throws DeployException
{
    for (com.sforce.soap.metadata.UpsertResult result : results)
    {
        if (result.isSuccess())
        {
            dr.incrementSuccessCount();
        }
        else
        {
            for (com.sforce.soap.metadata.Error e : result.getErrors())
            {
                dr.addError(String.format("Status Code: [%s]\nMessage: [%s]\nFields: [%s]\n",
                    e.getStatusCode().name(), e.getMessage(), String.join(", ", e.getFields())));
                dr.incrementErrorCount();
            }
        }
    }

    return dr;
}
 

import com.sforce.soap.partner.UpsertResult; //导入依赖的package包/类
public DeployResponse upsertData(String IdField, List<SObject> sobjects)
    throws ConnectionException, DeployException, AsyncApiException
{
    DeployResponse dr = new DeployResponse();

    // ensure the partner connection has been initialized
    createPartnerConnection();

    // check if the SObject queue is empty
    if (sobjects == null || sobjects.isEmpty())
    {
        Utils.log("An empty list of SObject was passed to upsertData()!");
    }
    else
    {
        Utils.log(String.format("Upserting %d records with Id field [%s].", +sobjects.size(), IdField));

        // upsert the records
        com.sforce.soap.partner.UpsertResult[] URs = _pConn.upsert(IdField,
            sobjects.toArray(new SObject[] {}));

        // process the results and log errors
        dr = SalesforceService.handleUpsertResponse(dr, URs);
    }
    return dr;
}
 

import com.sforce.soap.partner.UpsertResult; //导入依赖的package包/类
private static DeployResponse handleUpsertResponse(DeployResponse dr, UpsertResult[] results) throws DeployException
{
    boolean foundErrors = false;
    for (UpsertResult ur : results)
    {
        if (ur.getSuccess())
        {
            // Utils.log("'upsert' was successful! [" + ur.getId() + "]");
            dr.incrementSuccessCount();
        }
        else
        {
            for (com.sforce.soap.partner.Error e : ur.getErrors())
            {
                dr.addError(String.format("Status Code: [%s]\nMessage: [%s]\n%s\n", e.getStatusCode().name(),
                    e.getMessage(), (e.getFields() == null || e.getFields().length == 0 ? ""
                        : String.format("Fields: [%s]", String.join(", ", e.getFields())))));
                dr.incrementErrorCount();
            }
            foundErrors = true;
        }
    }

    if (foundErrors)
    {
        Utils.log("'upsert' resulted in errors! See log.");
    }

    return dr;
}
 

import com.sforce.soap.partner.UpsertResult; //导入依赖的package包/类
private void countUpsertResults(UpsertResult[] upsertResults) {
    for (UpsertResult upsertResult : upsertResults) {
        if (upsertResult.isSuccess()) {
            this.numOfSuccess++;
        } else {
            this.numOfError++;
        }
    }
}
 

import com.sforce.soap.partner.UpsertResult; //导入依赖的package包/类
private UpsertResult[] upsert(IndexedRecord input) throws IOException {
    upsertItems.add(input);
    if (upsertItems.size() >= commitLevel) {
        return doUpsert();
    }
    return null;
}
 

import com.sforce.soap.partner.UpsertResult; //导入依赖的package包/类
public UpsertResult[] upsert(String upsertField, SObject[] sfBuffer) throws KettleException
{
 try {
  return getBinding().upsert(upsertField, sfBuffer);
 }catch(Exception e) {
  throw new KettleException(BaseMessages.getString(PKG, "SalesforceInput.ErrorUpsert"), e);
 }
}
 

import com.sforce.soap.partner.UpsertResult; //导入依赖的package包/类
public UpsertResult[] upsert( String upsertField, SObject[] sfBuffer ) throws KettleException {
  try {
    return getBinding().upsert( upsertField, sfBuffer );
  } catch ( Exception e ) {
    throw new KettleException( BaseMessages.getString( PKG, "SalesforceInput.ErrorUpsert", e ) );
  }
}
 

import com.sforce.soap.partner.UpsertResult; //导入依赖的package包/类
public ResultWrapper(SaveResult[] saveResults, 
        UpsertResult[] upsertResults, DeleteResult[] deleteResults) {
    this.saveResult = saveResults;
    this.upsertResult = upsertResults;
    this.deleteResult = deleteResults;
}
 

import com.sforce.soap.partner.UpsertResult; //导入依赖的package包/类
private UpsertResult[] doUpsert() throws IOException {
    if (upsertItems.size() > 0) {
        // Clean the feedback records at each batch write.
        cleanWrites();
        SObject[] upds = new SObject[upsertItems.size()];
        for (int i = 0; i < upsertItems.size(); i++) {
            upds[i] = createSObjectForUpsert(upsertItems.get(i));
        }

        String[] changedItemKeys = new String[upds.length];
        for (int ix = 0; ix < upds.length; ++ix) {
            Object value = upds[ix].getField(upsertKeyColumn);
            if (value != null) {
                changedItemKeys[ix] = String.valueOf(value);
            }
        }
        UpsertResult[] upsertResults;
        try {
            upsertResults = connection.upsert(upsertKeyColumn, upds);
            upds = null;
            if (upsertResults != null && upsertResults.length != 0) {
                int batch_idx = -1;
                for (int i = 0; i < upsertResults.length; i++) {
                    ++batch_idx;
                    if (upsertResults[i].getSuccess()) {
                        if (upsertResults[i].getCreated()) {
                            handleSuccess(upsertItems.get(i), upsertResults[i].getId(), "created");
                        } else {
                            handleSuccess(upsertItems.get(i), upsertResults[i].getId(), "updated");
                        }
                    } else {
                        handleReject(upsertItems.get(0), upsertResults[i].getErrors(), changedItemKeys, batch_idx);
                    }
                }
            }
            upsertItems.clear();
            return upsertResults;
        } catch (ConnectionException e) {
            throw new IOException(e);
        }
    }
    return null;

}