Sample OIM Java Codes:
Custom scheduler:
package com.blogspot.oraclestack.testdriver;
import Thor.API.Exceptions.tcAPIException;
import Thor.API.Exceptions.tcBulkException;
import Thor.API.Exceptions.tcTaskNotFoundException;
import Thor.API.Operations.tcProvisioningOperationsIntf;
import Thor.API.Security.XLClientSecurityAssociation;
import com.thortech.xl.client.dataobj.tcDataBaseClient;
import com.thortech.xl.dataaccess.tcDataProvider;
import com.thortech.xl.dataaccess.tcDataSet;
import com.thortech.xl.dataaccess.tcDataSetException;
import com.thortech.xl.dataobj.PreparedStatementUtil;
import com.thortech.xl.orb.dataaccess.tcDataAccessException;
import java.util.Arrays;
import java.util.Hashtable;
import oracle.core.ojdl.logging.ODLLevel;
import oracle.core.ojdl.logging.ODLLogger;
import oracle.iam.platform.OIMClient;
/**
* Test Driver to manual complete provisioning tasks.
* @author rayedchan
*/
public class ManualCompleteProvisioningTaskTestDriver
{
// LOGGER
public static final ODLLogger LOGGER = ODLLogger.getODLLogger(ManualCompleteProvisioningTaskTestDriver.class.getName());
// Adjust constant variables according to you OIM environment
public static final String OIM_HOSTNAME = "localhost";
public static final String OIM_PORT = "14000"; // For SSL, use 14001; For non-SSL, use 14000
public static final String OIM_PROVIDER_URL = "t3://"+ OIM_HOSTNAME + ":" + OIM_PORT; // For SSL, use t3s protocol; For non-SSL, use t3 protocol
public static final String AUTHWL_PATH = "lib/config/authwl.conf";
public static final String APPSERVER_TYPE = "wls";
public static final String FACTORY_INITIAL_TYPE = "weblogic.jndi.WLInitialContextFactory";
// Use if using SSL connection for OIMClient
public static final String TRUST_KEYSTORE_FOR_SSL = "/home/oracle/Oracle/Middleware/wlserver_10.3/server/lib/DemoTrust.jks";
// OIM Administrator Credentials
public static final String OIM_ADMIN_USERNAME = "xelsysadm";
public static final String OIM_ADMIN_PASSWORD = "Password1";
public static void main(String[] args) throws Exception
{
OIMClient oimClient = null;
try
{
// Set system properties required for OIMClient
System.setProperty("java.security.auth.login.config", AUTHWL_PATH);
System.setProperty("APPSERVER_TYPE", APPSERVER_TYPE);
System.setProperty("weblogic.security.SSL.trustedCAKeyStore", TRUST_KEYSTORE_FOR_SSL); // Provide if using SSL
// Create an instance of OIMClient with OIM environment information
Hashtable<String, String> env = new Hashtable<String, String>();
env.put(OIMClient.JAVA_NAMING_FACTORY_INITIAL, FACTORY_INITIAL_TYPE);
env.put(OIMClient.JAVA_NAMING_PROVIDER_URL, OIM_PROVIDER_URL);
// Establish an OIM Client
oimClient = new OIMClient(env);
// Login to OIM with System Administrator Credentials
oimClient.login(OIM_ADMIN_USERNAME, OIM_ADMIN_PASSWORD.toCharArray());
// Manual complete provisioning tasks for a given process task in a specific process definition
String processDefinationName = "LDAP User"; // PKG.PKG_NAME
String processTaskName = "Disable User"; // MIL.MIL_NAME
manualCompleteProvisioningTasks(processDefinationName, processTaskName, oimClient); // Call helper method
}
finally
{
// Logout of OIM client
if(oimClient != null)
{
oimClient.logout();
}
}
}
/**
* Manually complete provisioning tasks for a given process definition.
* When a task is marked for manual completion, the value for SCH.SCH_STATUS
* is changed to 'MC'.
* @param processDefinitionName PKG.PKG_NAME
* @param processTaskName MIL.MIL_NAME
* @param oimClient OIM Client
* @throws tcDataSetException
* @throws tcDataAccessException
* @throws tcTaskNotFoundException
* @throws tcBulkException
* @throws tcAPIException
*/
public static void manualCompleteProvisioningTasks(String processDefinitionName, String processTaskName, OIMClient oimClient) throws tcDataSetException, tcDataAccessException, tcTaskNotFoundException, tcBulkException, tcAPIException
{
tcProvisioningOperationsIntf provOps = null;
try
{
// Get OIM tcProvisioningOperations service
provOps = oimClient.getService(tcProvisioningOperationsIntf.class);
// Establish database connection to OIM Schema through the OIMClient
XLClientSecurityAssociation.setClientHandle(oimClient);
tcDataProvider dbProvider = new tcDataBaseClient();
// Setup query to fetch 'Rejected', 'Pending', and 'Uncompleted' provisioning tasks for a given process task and process definition
String query = "select sch.sch_key from sch inner join osi on sch.sch_key = osi.sch_key inner join mil on osi.mil_key = mil.mil_key inner join pkg on pkg.pkg_key = osi.pkg_key where pkg.pkg_name = ? and mil.mil_name = ? and sch_status in ('R', 'P', 'UC') order by sch.sch_key";
PreparedStatementUtil ps = new PreparedStatementUtil();
ps.setStatement(dbProvider, query);
ps.setString(1, processDefinitionName); // PKG_NAME
ps.setString(2, processTaskName); // MIL_NAME
ps.execute(); // Execute query
LOGGER.log(ODLLevel.NOTIFICATION, "Executed Statement: {0}", new Object[]{ps.getStatement()});
// Provisioning Tasks Result set
tcDataSet tasksDataSet = ps.getDataSet();
int numRecords = tasksDataSet.getTotalRowCount();
long[] schKeys = new long[numRecords];
LOGGER.log(ODLLevel.NOTIFICATION, "Total Provisioning Tasks to Update: {0}", new Object[]{numRecords});
// Iterate through each record in result set
for(int i = 0; i < numRecords; i++)
{
tasksDataSet.goToRow(i); // Move cursor to next record in result set
Long id = tasksDataSet.getLong("sch_key"); // Get key from record
schKeys[i] = id; // Add to array
LOGGER.log(ODLLevel.NOTIFICATION, "Provisioning Task ID: {0}", new Object[]{id});
}
LOGGER.log(ODLLevel.NOTIFICATION, "Provisioning Tasks to Complete: {0}", new Object[]{Arrays.toString(schKeys)});
provOps.setTasksCompletedManually(schKeys); // Bulk Manual Complete provisioning tasks
}
finally
{
// Close tc* service
if(provOps != null)
{
provOps.close();
}
// Clear session
XLClientSecurityAssociation.clearThreadLoginSession();
}
}
}
