The following sample code from the MergePerson.java file gets the source row IDs with the MergeCO.BeforeEveryting external call:
package com.informatica.mdm.sample.cs;
import java.util.List;
import java.util.Map;
import com.informatica.mdm.sdo.co.base.BaseObject;
import com.informatica.mdm.sdo.co.base.CompositeObjectBase;
import com.informatica.mdm.sdo.co.base.KeysAndOverrides;
import com.informatica.mdm.sdo.co.base.MergedRecord;
import com.informatica.mdm.sdo.co.base.MergedRecordPager;
import com.informatica.mdm.sdo.co.base.Pager;
import com.informatica.mdm.sdo.cs.base.BusinessEntityKey;
import com.informatica.mdm.sdo.cs.base.Key;
import com.informatica.mdm.spi.cs.StepException;
import com.informatica.mdm.spi.externalcall.CustomLogic;
import commonj.sdo.ChangeSummary;
import commonj.sdo.DataObject;
import commonj.sdo.Property;
import commonj.sdo.helper.HelperContext;
import org.eclipse.persistence.sdo.SDOChangeSummary;
/**
* Call this piece of code before the Person business entity record merge or the previewMerge API call.
*/
public class MergePerson implements CustomLogic {
public static final String KEYS_AND_OVERRIDES = "keysAndOverrides";
public static final String OVERRIDES = "overrides";
public static final String MERGE = "MERGE";
@Override
public DataObject process(HelperContext helperContext, DataObject inputSdo,
Map<String, Object> inParams,
Map<String, Object> outParams) throws StepException {
DataObject keysAndOverrides = (DataObject) inParams.get(KEYS_AND_OVERRIDES);
if (keysAndOverrides != null) {
explainMerge(inParams);
DataObject overrides = keysAndOverrides.getDataObject(OVERRIDES);
if (overrides != null) {
// if "overrides" are provided, then user is not simply merging several records, but
// tryes to merge some child records or provides some winner override
List<DataObject> list = overrides.getList("Person/TelephoneNumbers/item");
if ((list != null) && !list.isEmpty()) {
SDOChangeSummary changeSummary = (SDOChangeSummary) overrides.getChangeSummary();
changeSummary.resumeLogging();
// remove "MERGE" element from all "Telephone" items, this will prevent mering of "Telephone" child records
for (DataObject dataObject : list) {
if (dataObject.isSet(MERGE)) {
dataObject.unset(MERGE);
}
}
// send updated "overrides" back to Hub
outParams.put(KEYS_AND_OVERRIDES, keysAndOverrides);
}
}
}
return inputSdo;
}
private void explainMerge(Map<String, Object> inParams) {
BusinessEntityKey businessEntityKey = (BusinessEntityKey) inParams.get("businessEntityKey");
System.out.println(String.format("%s:%s", businessEntityKey.getName(), businessEntityKey.getKey().getRowid()));
KeysAndOverrides keysAndOverrides = (KeysAndOverrides) inParams.get("keysAndOverrides");
List<Key> keys = keysAndOverrides.getKeys();
for (Key key : keys) {
System.out.println(String.format(" | <- %s", key.getRowid()));
}
CompositeObjectBase overrides = keysAndOverrides.getOverrides();
if(overrides != null) {
DataObject co = (DataObject) overrides;
ChangeSummary changeSummary = co.getChangeSummary();
DataObject root = co.getDataObject(co.getType().getName());
dumpOne("", co.getType().getName(), root, changeSummary);
}
}
private void dumpOne(String prefix, String name, DataObject dataObject, ChangeSummary changeSummary) {
String rowidObject = dataObject.getString("rowidObject");
if(rowidObject != null) {
System.out.println(String.format("%s%s:%s", prefix, name, rowidObject));
}
List<MergedRecord> mergeItems = dataObject.getList("MERGE/item");
if(mergeItems != null) {
for (MergedRecord mergeItem : mergeItems) {
System.out.println(String.format("%s | <- %s", prefix, mergeItem.getKey().getRowid()));
}
}
List<Property> properties = dataObject.getInstanceProperties();
for (Property property : properties) {
Object o = dataObject.get(property);
if((o instanceof Pager) && !(o instanceof MergedRecordPager)) {
DataObject pager = (DataObject) o;
System.out.println(prefix + property.getName());
List<DataObject> items = pager.getList("item");
for (int i = 0; i < items.size(); i++) {
DataObject item = items.get(i);
dumpOne(prefix + " " ,"[" + i + "]", item, changeSummary);
}
}
if(o instanceof BaseObject) {
dumpOne(prefix + " ", property.getName(), (DataObject) o, changeSummary);
}
}
if(changeSummary.isModified(dataObject)) {
List<ChangeSummary.Setting> oldValues = changeSummary.getOldValues(dataObject);
for (ChangeSummary.Setting setting : oldValues) {
Property property = setting.getProperty();
if(!"MERGE".equals(property.getName())) {
Object value = dataObject.get(property);
System.out.println(String.format("%s manual override: %s = %s", prefix, property.getName(), value));
}
}
}
}
}
The inputSDO process method parameter is the merge target. Any keys and overrides are from the merge source.
