Creating Permanent Interface based on Model Level

This particular ODI SDK codes creates one source to one target interface and accordingly generate Scenario, based on condition where the Source table is same as Target Table name , under two different Model.

By default the target datastore name is used as the Interface Name.

For this example , Source Model is HR schema and also the Target Model is HR schema.

package odi_sdk;

import java.util.Collection;
import java.util.HashSet;
import java.util.Iterator;

import oracle.odi.core.OdiInstance;
import oracle.odi.core.config.MasterRepositoryDbInfo;
import oracle.odi.core.config.OdiInstanceConfig;
import oracle.odi.core.config.PoolingAttributes;
import oracle.odi.core.config.WorkRepositoryDbInfo;
import oracle.odi.core.exception.OdiRuntimeException;
import oracle.odi.core.persistence.transaction.ITransactionStatus;
import oracle.odi.core.persistence.transaction.support.DefaultTransactionDefinition;
import oracle.odi.core.security.Authentication;
import oracle.odi.domain.model.OdiDataStore;
import oracle.odi.domain.model.finder.IOdiDataStoreFinder;
import oracle.odi.domain.project.OdiCKM;
import oracle.odi.domain.project.OdiFolder;
import oracle.odi.domain.project.OdiIKM;
import oracle.odi.domain.project.OdiInterface;
import oracle.odi.domain.project.OdiLKM;
import oracle.odi.domain.project.ProcedureOption;
import oracle.odi.domain.project.finder.IOdiCKMFinder;
import oracle.odi.domain.project.finder.IOdiFolderFinder;
import oracle.odi.domain.project.finder.IOdiIKMFinder;
import oracle.odi.domain.project.finder.IOdiLKMFinder;
import oracle.odi.domain.project.interfaces.DataSet;
import oracle.odi.domain.project.interfaces.SourceDataStore;
import oracle.odi.domain.project.interfaces.SourceSet;
import oracle.odi.domain.runtime.scenario.OdiScenario;
import oracle.odi.domain.topology.OdiContext;
import oracle.odi.domain.topology.finder.IOdiContextFinder;
import oracle.odi.generation.IOdiScenarioGenerator;
import oracle.odi.generation.support.OdiScenarioGeneratorImpl;
import oracle.odi.interfaces.interactive.support.InteractiveInterfaceHelperWithActions;
import oracle.odi.interfaces.interactive.support.actions.InterfaceActionOnTargetDataStoreComputeAutoMapping;
import oracle.odi.interfaces.interactive.support.actions.InterfaceActionSetKM;
import oracle.odi.interfaces.interactive.support.actions.InterfaceActionSetKM.KMType;
import oracle.odi.interfaces.interactive.support.actions.InterfaceActionSetKMOptionValue;
import oracle.odi.interfaces.interactive.support.actions.InterfaceActionSetTargetDataStore;
import oracle.odi.interfaces.interactive.support.km.optionretainer.KMOptionRetainerHomonymy;
import oracle.odi.interfaces.interactive.support.km.optionretainer.KMOptionRetainerLazy;
import oracle.odi.interfaces.interactive.support.mapping.automap.AutoMappingComputerLazy;
import oracle.odi.interfaces.interactive.support.mapping.matchpolicy.MappingMatchPolicyLazy;
import oracle.odi.interfaces.interactive.support.sourceset.creators.InexistentMappingException;
import oracle.odi.interfaces.interactive.support.targetkeychoosers.TargetKeyChooserPrimaryKey;

public class PermanentInterface {

	private static String Project_Code;
	private static String Folder_Name;
	private static OdiFolder folder;
	private static String Context_Code;
	private static OdiContext context;
	private static OdiDataStore sourceDatastore;
	private static OdiInterface odiInterface;
	private static String target_model_name;
	private static String source_model_name;
	private static String LKM;
	private static String IKM;
	private static String CKM;

	/**
	 * @param args
	 */
	public static void main(String[] args) {

        /****** Please change these Parameters *********/

		String Url = "jdbc:oracle:thin:@localhost:1521:orcl";
		String Driver="oracle.jdbc.OracleDriver";
		String Master_User="ODI_MASTER_11G";
		String Master_Pass="ODI_MASTER_11G";
		String WorkRep="WORKREP1";
		String Odi_User="SUPERVISOR";
		String Odi_Pass="SUNOPSIS";

                Project_Code="XMT";
		Context_Code="XMT";
		Folder_Name="FOLDER";
		source_model_name = "SRCE_HR";
		target_model_name = "TRGT_HR";
		LKM ="LKM SQL to Oracle";
		IKM ="IKM SQL Control Append";
		CKM ="CKM Oracle";

                /*****************************/

		// Connection
MasterRepositoryDbInfo masterInfo = new MasterRepositoryDbInfo(Url, Driver, Master_User,Master_Pass.toCharArray(), new PoolingAttributes());
WorkRepositoryDbInfo workInfo = new WorkRepositoryDbInfo(WorkRep, new PoolingAttributes());
OdiInstance odiInstance=OdiInstance.createInstance(new OdiInstanceConfig(masterInfo,workInfo));
Authentication auth = odiInstance.getSecurityManager().createAuthentication(Odi_User,Odi_Pass.toCharArray());
odiInstance.getSecurityManager().setCurrentThreadAuthentication(auth);
ITransactionStatus trans = odiInstance.getTransactionManager().getTransaction(new DefaultTransactionDefinition());

		// Find the folder

		Collection fold = ((IOdiFolderFinder) odiInstance.getTransactionalEntityManager().getFinder(OdiFolder.class)).findByName(Folder_Name);
		for (Iterator it = fold.iterator(); it.hasNext();) {
			folder = (OdiFolder) it.next();
		}

		// Find the Context
		context = ((IOdiContextFinder) odiInstance.getTransactionalEntityManager().getFinder(OdiContext.class)).findByCode(Context_Code);

		// Target Data Store
		Object[] trgt_ds = ((IOdiDataStoreFinder) odiInstance.getTransactionalEntityManager().getFinder(OdiDataStore.class)).findAll().toArray();

		// This part of the code is to remove the
		// duplicate datastores present in different Models
		HashSet hs = new HashSet();
		for (Object dt_str : trgt_ds) {
			OdiDataStore ds = (OdiDataStore) dt_str;
			hs.add(ds.getName().toString());
		}

		for (Object ds : hs) {
			// Target Data Store
			OdiDataStore targetDatastore = ((IOdiDataStoreFinder)odiInstance.getTransactionalEntityManager().
                        getFinder(OdiDataStore.class)).
                        findByName(ds.toString(), target_model_name);

			if (targetDatastore != null) {
			// Reading the Source Data Store
			// Find the Data store using the IOdiDataStoreFinder
			sourceDatastore = ((IOdiDataStoreFinder) odiInstance.getTransactionalEntityManager().getFinder(OdiDataStore.class)).
                        findByName(ds.toString(), source_model_name);

			System.out.println("Interface Creation Started for ..."+ ds.toString());
			// Creating a New Interface
			OdiInterface intf = new OdiInterface(folder, ds.toString(), context);

			// Setting the above Context as the Optimization Context
			intf.setOptimizationContext(context);

			// Creating DataSet to automatically assign different
			// Source Data store
			// DataSet(OdiInterface pInterface, java.lang.String pName)

			DataSet dataset = intf.getDataSets().iterator().next();
			SourceSet srcset = new SourceSet("srcset0",dataset);
			SourceDataStore sd=new SourceDataStore(dataset,false,sourceDatastore.getName().
                        toString(),0,sourceDatastore);
			srcset.addSourceDataStore(sd);

			// Helper is to manipulate Odi interfaces in an
			// interactive way

			InteractiveInterfaceHelperWithActions helper = new InteractiveInterfaceHelperWithActions
                        (intf, odiInstance, odiInstance.getTransactionalEntityManager());

			helper.performAction(new InterfaceActionSetTargetDataStore(
					targetDatastore, new MappingMatchPolicyLazy(),
					new AutoMappingComputerLazy(),
					new AutoMappingComputerLazy(),
					new TargetKeyChooserPrimaryKey()));

			helper.performAction(new InterfaceActionOnTargetDataStoreComputeAutoMapping());

			// Add the Filter
			//helper.performAction(new InterfaceActionAddFilter(dataset, sd.getName(),ExecutionLocation.WORK));

			// Start mapping the KM
			// LKM
			Collection lkm1 = ((IOdiLKMFinder) odiInstance.getTransactionalEntityManager().getFinder(OdiLKM.class)).
                        findByName(LKM,Project_Code);

			for (Iterator iterator = lkm1.iterator(); iterator.hasNext();) {
				OdiLKM odiLKM = (OdiLKM) iterator.next();
				helper.performAction(new InterfaceActionSetKM(odiLKM,srcset, KMType.LKM,new KMOptionRetainerHomonymy()));

				// Fetching each option of the LKM
				for (ProcedureOption c : odiLKM.getOptions()) {
					helper.performAction(new InterfaceActionSetKMOptionValue(srcset, KMType.LKM,"DELETE_TEMPORARY_INDEXES", false));
				}
			}

			// IKM
			// Find the IKM using the IOdiIKMFinder

			Collection ikm1 = ((IOdiIKMFinder) odiInstance.getTransactionalEntityManager().getFinder(OdiIKM.class)).findByName(
							IKM,Project_Code);

			for (Iterator iterator = ikm1.iterator(); iterator.hasNext();) {
				OdiIKM odiIKM = (OdiIKM) iterator.next();

				// Setting the IKM in the interface
				helper.performAction(new InterfaceActionSetKM(odiIKM, intf.getTargetDataStore(),KMType.IKM, new KMOptionRetainerLazy()));

				// Fetching each option of the IKM
				for (ProcedureOption c : odiIKM.getOptions()) {

					// Modifying the Options of the IKM in the
					// Interface
					helper.performAction(new InterfaceActionSetKMOptionValue(intf.getTargetDataStore(), KMType.IKM,
							"FLOW_CONTROL", false));

					helper.performAction(new InterfaceActionSetKMOptionValue(intf.getTargetDataStore(), KMType.IKM,
							"STATIC_CONTROL", true));

				}
			}

			// CKM
			Collection ckm1 = ((IOdiCKMFinder) odiInstance.getTransactionalEntityManager().getFinder(OdiCKM.class)).findByName(
					CKM,Project_Code);

			for (Iterator iterator = ckm1.iterator(); iterator.hasNext();) {
				OdiCKM odiCKM = (OdiCKM) iterator.next();
				helper.performAction(new InterfaceActionSetKM(odiCKM, intf.getTargetDataStore(),KMType.CKM, new KMOptionRetainerLazy()));
			}

			// Compute the Interface sourceset

			try {helper.computeSourceSets();}
			catch (InexistentMappingException e) {throw new OdiRuntimeException(e);}

			// Persisting the Interface
			// Called to inform the ODI persistence layer that this
			// interface will be persisted
			try {helper.preparePersist();}
			catch (oracle.odi.interfaces.interactive.exceptions.OdiInterfaceNotReadyForPersistException e) {e.printStackTrace();}

			odiInstance.getTransactionalEntityManager().persist(intf);

			// Generating Scenarios

			System.out.println("Generating Scenario for .."+ ds.toString() );
			IOdiScenarioGenerator gene = new OdiScenarioGeneratorImpl(odiInstance);
			OdiScenario newScen = gene.generateScenario(intf,ds.toString(), "001");
			odiInstance.getTransactionalEntityManager().persist(newScen);
			} }

		// Finally close the Instance
		odiInstance.getTransactionManager().commit(trans);
		odiInstance.close();

		System.out.println("Process Completed");
	}

}

ODIExperts.com

The blog for Oracle Data Integrator ( ODI )

Creating Permanent Interface based on Model Level

Sample Output

One Comment

Leave a Reply Cancel reply

Recent Posts ODI Expert and why there is no new posts… Passing Values to ODI Variables in Packages/Scenarios New Author Arriving… ODI Certification – Approved How to Change ODI Language (Idiom) Recent Comments Ignacio Vega on How to create a Temp Table in ODI Interface (Yellow Interface) R. Moreno on Generate Multiple Scenarios saroj kumar pradhan on ODI Expert and why there is no new posts… Raju Mogulapalli on Hide Unused Technologies shanker paloji on Changed Data Capture ( CDC ) Archives February 2016 April 2015 March 2015 February 2014 November 2013 September 2013 December 2011 November 2011 September 2011 August 2011 June 2011 March 2011 February 2011 January 2011 December 2010 November 2010 October 2010 September 2010 August 2010 July 2010 June 2010 April 2010 March 2010 January 2010 December 2009 November 2009 October 2009 September 2009 August 2009 Categories Administration Architecture Common Errors Drivers How to Java Codes Knowledge Modules Logic ODI ODI Bug Others Reports SDK SQL Technology Tips and Tricks Uncategorized Meta Log in Entries feed Comments feed WordPress.org

Recent Jobs ODI Expert and why there is no new posts… Passing Values to ODI Variables in Packages/Scenarios New Author Arriving… ODI Certification – Approved How to Change ODI Language (Idiom) Information about the ODI Certification Exam Finally!!!! The Oracle Data Integrator 11g Certified Implementation Exam!!!!!! Interface with Union, Minus Operator using ODI SDK Export and Importing Scenarios based on Project (or)Folder Creating Interface for Single Source and Target Creating Permanent Interface based on Model Level Automatically add Interfaces/Scenarios to new ODIPackage using ODI SDK Creating Package using SDK Handling the “ORDER BY” clause in an interface Creating Temporary Interface using ODI SDK Creating ODI Procedure using SDK ODI SDK Setup and Config in Eclipse Things to be pride of…. CDC CONSISTENT Ordered SQL Killing session in ODI 11g 11g Oracle Data Integrator – Part 8/11g – Table Partitioning supported Jython Scripts fails to recognize the module during scenario run in ODI 11g Scenarios, a lot in the first delivery makes maintenance very simple! Direct load by interface with no work tables (C$, I$) 11g Oracle Data Integrator – Part 7/11g – SUNOPSIS MEMORY ENGINE 11g Oracle Data Integrator – Part 6/11g – Union , Minus, Intersect Jython’s Beginner Guide for ODI Send SQL by Email Security Module – Main concepts and use Drivers Location in ODI 11g 11g Oracle Data Integrator – Standalone Agent but, and about the Windows Service??? 11g Oracle Data Integrator – Part 5/11g – odiConsole, the new Metada Navigator Using one of ODI’s lesser-known secrets: the Common Format Designer (CFD) – by Craig Stewart 11g Oracle Data Integrator – Part 4/11g – Upgrading from 10g 11g Oracle Data Integrator – Upgrading from 10g – Part 4/11g First year of many…. Thank you Friends! 11g Oracle Data Integrator – Part 3/11g – Graphical User Interface Datatypes – Creating what is missing for any technology IS_NUMBER (and IS_CHAR) at Oracle? A workaround… Calling OdiSqlUnload using ODI Procedure with no hardcoded password SNP_EXP_TXT – A “huge” table problem Internal ID SCD Type 2 11g Oracle Data Integrator – Part 2/11g – Creating Repositories 11g Oracle Data Integrator – Creating Repositories – Part 2/11g Regenerate ODI Objects using OdiGenerateAllScen Generate Column_name Header for OdiSqlUnload Error Records Log Get the Error Message of any Failed ODI objects inside Package SCD TYPE 3 Best practice of ODI 11g Oracle Data Integrator – Part 1/11g – First Screen Automated ODI Export Import Scenarios LKM OdiSqlUnload(File) to Oracle ( SQLLDR ) Jython OS bug in Windows 7 Writing SQL counts using Jython Getting one or several unknown files from a directory Interface Parallel Execution – A new solution Displaying SQL results in Operator Flow Control and Static Control Export DWR to EWR [ Common Master Rep ] Scenario Report Asynchronous -Parallel Execution Dropping $ Tables KM FOR UNION BASED ON IKM SQL CNTRL APPEND Installing ODI in Windows 7 Querying in ODI Changed Data Capture ( CDC ) Agent Manual entry in ODI Driver List MINUS IN ODI Variable Detail Query Interface Mapping Query Topology Connection Detail Versioning Get File Length and Header in Operator Find the Value of the Variable in Operator ? Invisible Join Shortcuts Keys Export – Import DWR to EWR having same Master Rep Categorize Scenarios Alignment of objects in Package Duplicate Multiple Objects in Package Smart Search Export – Import DWR to DWR having same Master Repository Procedures (or KM) Steps – Source and Target tab’s Subscribers – An example of how to use Why Creating a separate schema in ODI? How to show Business Messages on Operator and, too, debug variables… Topology – Data Server – Which user should be used to connect? How to use PL/SQL procedures and functions in ODI Context, Logical And Physical Schema – How does it work? Repository Architecture – Work Repository, Development or Execution? When and why uses each one. Removing Special character using Jython script Faster and Easiest way to design Interfaces AUTOMIZE ODI REPOSITORY EXPORTS Informix Connection SQL Server connection Repository Architecture – Two or more Masters – Part 3 Report of list of KMs in each Interface Connecting openLDAP How to call a Web Service that start an ODI Scenario and waits its complete execution Processing multiple Interface through single Package Multiple Files – Single Interface Generate Multiple Scenarios Sequence How to get a constant or pseudo-column from source mapping Lock Windows Layout Hide Unused Technologies Tab at the Top oracle.jdbc.V8Compatible Oracle to Flat file Scheduling using ODI Scheduler Exception – getobjectname schema How to create a Temp Table in ODI Interface (Yellow Interface) Printing report Step by step procedure to Read Excel (*.xls) Importing Knowledge Modules Creating Master and Work Repository Installation Repository Architecture – Just one Master – Part 2 How to refresh ODI variables from file – Part 2 – Getting all lines, once at time How to refresh ODI variables from file – Part 1 – Just one value Repository Architecture – Just one Master – Part 1 Welcome to ODI Experts, this is Cezar Santos.