import com.sforce.soap.partner.GetDeletedResult; //导入依赖的package包/类
/**
 * For tSalesforceGetDeleted generate SOQL
 */
@Test
public void testGetQueryStringList() throws Throwable {
    SalesforceGetDeletedReader deletedReader =
            new SalesforceGetDeletedReader(null, null, createSalesforceGetDeletedUpdatedProperties(false)) {

                @Override
                protected GetDeletedResult getResult() throws IOException, ConnectionException {
                    GetDeletedResult result = new GetDeletedResult();
                    List<DeletedRecord> records = new ArrayList<>();
                    for (int i = 1000; i < 1999; i++) {
                        DeletedRecord record = new DeletedRecord();
                        record.setId("0019000001fvZV" + i);
                        records.add(record);
                    }
                    result.setDeletedRecords(records.toArray(new DeletedRecord[records.size()]));
                    return result;
                }
            };
    List<String> queryStrings = deletedReader.getQueryStringList(deletedReader.getResult());
    for (String query : queryStrings) {
        assertTrue(query.length() > 0);
        assertTrue(query.length() < deletedReader.soqlCharacterLimit);
    }
    assertEquals(3, queryStrings.size());
}
 

import com.sforce.soap.partner.GetDeletedResult; //导入依赖的package包/类
/**
 * Get the SOQL statements with the SObject Ids which get from the reocord.
 * Because of the SOQL statements have a limitation of the length.
 * So we create new statement when the length reach soqlCharacterLimit
 */
protected List<String> getQueryStringList(GetDeletedResult result) throws IOException {
    String[] ids = getRecordIds(result);
    StringBuilder sb = new StringBuilder();
    List<String> queryStringList = new ArrayList<>();
    String baseQueryString = getQueryString(properties);
    sb.append(baseQueryString);
    sb.append(" where ");
    int recordSize = ids.length;
    String condition = "";
    for (int i = 0; i < recordSize; i++) {
        condition = "Id='" + ids[i] + "'";
        sb.append(condition);
        sb.append(" or ");
        if ((sb.length() + condition.length() > soqlCharacterLimit) || (i == (recordSize - 1))) {
            sb.delete(sb.length() - 4, sb.length());
            queryStringList.add(sb.toString());
            sb.delete(0, sb.length());
            if (i != (recordSize - 1)) {
                sb.append(baseQueryString);
                sb.append(" where ");
            }
        }
    }
    return queryStringList;
}
 

import com.sforce.soap.partner.GetDeletedResult; //导入依赖的package包/类
@Test public void testGetDeleted() throws Exception {
	PartnerConnection pc = Mockito.mock(PartnerConnection.class);
	GetDeletedResult gdr = new GetDeletedResult();
	Calendar c = Calendar.getInstance();
	gdr.setEarliestDateAvailable(c);
	gdr.setLatestDateCovered(c);
	DeletedRecord dr = new DeletedRecord();
	dr.setDeletedDate(c);
	dr.setId("id");
	gdr.setDeletedRecords(new DeletedRecord[] {dr});
	Mockito.stub(pc.getDeleted("x", null, null)).toReturn(gdr);
	SalesforceConnectionImpl sfci = new SalesforceConnectionImpl(pc);
	DeletedResult result = sfci.getDeleted("x", null, null);
	assertEquals(1, result.getResultRecords().size());
}
 

import com.sforce.soap.partner.GetDeletedResult; //导入依赖的package包/类
@Override
protected String[] getRecordIds(GetDeletedResult result) {
    List<String> ids = new ArrayList<>();
    if (result != null) {
        DeletedRecord[] records = result.getDeletedRecords();
        for (DeletedRecord record : records) {
            ids.add(record.getId());
        }
    }
    return ids.toArray(new String[ids.size()]);
}
 

import com.sforce.soap.partner.GetDeletedResult; //导入依赖的package包/类
@Override
protected GetDeletedResult getResult() throws IOException, ConnectionException {
    SalesforceGetDeletedUpdatedProperties props = (SalesforceGetDeletedUpdatedProperties) properties;
    return getConnection().getDeleted(module, startDate, endDate);
}