informatica mapping文件 JAVA SDK开发工具包

/* * Base.java Created on Nov 4, 2005. * * Copyright 2004 Informatica Corporation. All rights reserved. * INFORMATICA PROPRIETARY/CONFIDENTIAL. Use is subject to license terms. */ package com.informatica.powercenter.sdk.mapfwk.samples; import java.io.IOException; import java.io.InputStream; import java.util.Properties; import java.util.Vector; import com.informatica.powercenter.sdk.mapfwk.core.ConnectionInfo; import com.informatica.powercenter.sdk.mapfwk.core.ConnectionPropsConstants; import com.informatica.powercenter.sdk.mapfwk.core.DataTypeConstants; import com.informatica.powercenter.sdk.mapfwk.core.Field; import com.informatica.powercenter.sdk.mapfwk.core.FieldConstants; import com.informatica.powercenter.sdk.mapfwk.core.Folder; import com.informatica.powercenter.sdk.mapfwk.core.MapFwkOutputContext; import com.informatica.powercenter.sdk.mapfwk.core.Mapping; import com.informatica.powercenter.sdk.mapfwk.core.RepoPropsConstant; import com.informatica.powercenter.sdk.mapfwk.core.Repository; import com.informatica.powercenter.sdk.mapfwk.core.Session; import com.informatica.powercenter.sdk.mapfwk.core.Source; import com.informatica.powercenter.sdk.mapfwk.core.SourceTargetTypes; import com.informatica.powercenter.sdk.mapfwk.core.Target; import com.informatica.powercenter.sdk.mapfwk.core.Workflow; /** * * */ public abstract class Base { ///////////////////////////////////////////////////////////////////////////////////// // Instance variables ///////////////////////////////////////////////////////////////////////////////////// protected Repository rep; protected Folder folder; protected Session session; protected Workflow workflow; protected String mapFileName; protected Mapping mapping; protected int runMode = 0; /** * Common execute method */ public void execute() throws Exception { init(); createMappings(); createSession(); createWorkflow(); generateOutput(); } /** * Initialize the method */ protected void init() { createRepository(); createFolder(); createSources(); createTargets(); } /** * Create a repository */ protected void createRepository() { rep = new Repository( "PowerCenter", "PowerCenter", "This repository contains API test samples" ); } /** * Creates a folder */ protected void createFolder() { folder = new Folder( "JavaMappingSamples", "JavaMappingSamples", "This is a folder containing java mapping samples" ); rep.addFolder( folder ); } /** * Create sources */ protected abstract void createSources(); // override in base class to create appropriate sources /** * Create targets */ protected abstract void createTargets(); // override in base class to create appropriate targets /** * Creates a mapping * It needs to be overriddden for the sample * @return Mapping */ protected abstract void createMappings() throws Exception; // override in base class /** * Create session */ protected abstract void createSession() throws Exception; /** * Create workflow */ protected abstract void createWorkflow() throws Exception; /** * Create source for Employee Source */ protected Source createEmployeeSource() { Vector fields = new Vector(); Field field1 = new Field("EmployeeID", "EmployeeID","", DataTypeConstants.INTEGER, "10", "0", FieldConstants.PRIMARY_KEY, Field.FIELDTYPE_SOURCE, true); fields.add(field1); Field field2 = new Field("LastName", "LastName","", DataTypeConstants.STRING, "20", "0", FieldConstants.NOT_A_KEY, Field.FIELDTYPE_SOURCE, false); fields.add(field2); Field field3 = new Field("FirstName", "FirstName","", DataTypeConstants.STRING, "10", "0", FieldConstants.NOT_A_KEY, Field.FIELDTYPE_SOURCE, false); fields.add(field3); Field field4 = new Field("Title", "Title","", DataTypeConstants.STRING, "30", "0", FieldConstants.NOT_A_KEY, Field.FIELDTYPE_SOURCE, false); fields.add(field4); Field field5 = new Field("TitleOfCourtesy", "TitleOfCourtesy","", DataTypeConstants.STRING, "25", "0", FieldConstants.NOT_A_KEY, Field.FIELDTYPE_SOURCE, false); fields.add(field5); Field field6 = new Field("BirthDate", "BirthDate", "",DataTypeConstants.DATE, "19", "0", FieldConstants.NOT_A_KEY, Field.FIELDTYPE_SOURCE, false); fields.add(field6); Field field7 = new Field("HireDate", "HireDate","", DataTypeConstants.DATE, "19", "0", FieldConstants.NOT_A_KEY, Field.FIELDTYPE_SOURCE, false); fields.add(field7); Field field8 = new Field("Address", "Address","", DataTypeConstants.STRING, "60", "0", FieldConstants.NOT_A_KEY, Field.FIELDTYPE_SOURCE, false); fields.add(field8); Field field9 = new Field("City", "City","", DataTypeConstants.STRING, "15", "0", FieldConstants.NOT_A_KEY, Field.FIELDTYPE_SOURCE, false); fields.add(field9); Field field10 = new Field("Region", "Region","", DataTypeConstants.STRING, "15", "0", FieldConstants.NOT_A_KEY, Field.FIELDTYPE_SOURCE, false); fields.add(field10); Field field11 = new Field("PostalCode", "PostalCode","", DataTypeConstants.STRING, "10", "0", FieldConstants.NOT_A_KEY, Field.FIELDTYPE_SOURCE, false); fields.add(field11); Field field12 = new Field("Country", "Country","", DataTypeConstants.STRING, "15", "0", FieldConstants.NOT_A_KEY, Field.FIELDTYPE_SOURCE, false); fields.add(field12); Field field13 = new Field("HomePhone", "HomePhone","", DataTypeConstants.STRING, "24", "0", FieldConstants.NOT_A_KEY, Field.FIELDTYPE_SOURCE, false); fields.add(field13); Field field14 = new Field("Extension", "Extension","", DataTypeConstants.STRING, "4", "0", FieldConstants.NOT_A_KEY, Field.FIELDTYPE_SOURCE, false); fields.add(field14); Field field15 = new Field("Notes", "Notes","", DataTypeConstants.CLOB, "350", "0", FieldConstants.NOT_A_KEY, Field.FIELDTYPE_SOURCE, false); fields.add(field15); Field field16 = new Field("ReportsTo", "ReportsTo","", DataTypeConstants.INTEGER, "10", "0", FieldConstants.NOT_A_KEY, Field.FIELDTYPE_SOURCE, false); fields.add(field16); ConnectionInfo info = getFlatFileConnectionInfo(); info.getConnProps().setProperty(ConnectionPropsConstants.SOURCE_FILENAME,"Employees.csv"); Source employeeSource = new Source( "Employee", "Employee", "This is Employee Table", "Employee", info ); employeeSource.setFields( fields ); return employeeSource; } /** * Create source for Employee Source */ protected Source createOrderDetailSource() { Vector fields = new Vector(); Field field1 = new Field("OrderID", "OrderID","", DataTypeConstants.INTEGER, "10", "0", FieldConstants.FOREIGN_KEY, Field.FIELDTYPE_SOURCE, false); fields.add(field1); Field field2 = new Field("ProductID", "ProductID","", DataTypeConstants.INTEGER, "10", "0", FieldConstants.FOREIGN_KEY, Field.FIELDTYPE_SOURCE, false); fields.add(field2); Field field3 = new Field("UnitPrice", "UnitPrice","", DataTypeConstants.DECIMAL, "28", "4", FieldConstants.NOT_A_KEY, Field.FIELDTYPE_SOURCE, false); fields.add(field3); Field field4 = new Field("Quantity", "Quantity