java调用datastage的底层实现

import com.sun.jna.Library; import com.sun.jna.Native; import com.sun.jna.Structure; import com.sun.jna.Union; public interface vmdsapi extends Library { public static class time_t extends Structure { public int value; public time_t() {} public time_t(int value) { this.value = value; } } public static class DSPROJECT extends Structure{ public int dsapiVersionNo; public int sessionId; public byte valueMark; public byte fieldMark; } public static class DSJOB extends Structure{ public DSPROJECT hProject; /* Reference to project handle for job */ String serverJobHandle; /* Text of handle to job on server */ String logData; /* Cached log summary data */ int logDataLen; /* Size of log summary data */ int logDataPsn; /* Current position in logData */ } public static class DSparamValue extends Union{ String pString; String pEncrypt; int pInt; float PFloat; String pPath; String pDate; String pTime; } public static class DSPARAM extends Structure{ int paramType; String pString; /* String type */ String pEncrypt; /* Encrypted string */ int pInt; /* Integer */ float pFloat; /* Float */ String pPath; /* Pathname */ String pListValue; /* String from a list */ String pDate; /* Date string */ String pTime; /* Time string */ } public static class DSPARAMINFO extends Structure{ DSPARAM defaultValue; /* Default value of parameter */ String helpText; /* Description of parameter */ String paramPrompt; /* Prompt for the parameter */ int paramType; /* Type of parameter */ DSPARAM desDefaultValue; /* Designer set default value of parameter */ String listValues; /* Set of valid strings for List type parameter */ String desListValues; /* Set of designer set valid strings for list type parameter */ int promptAtRun; /* Flag indicating prompt required at run time. */ } public static class DSPROJECTINFO extends Structure{ int infoType; /* Key indicating type of information */ String jobList; /* List of names of all jobs in the project */ String projectName; /* Name of the current project */ String hostName; /* Host name of the server */ String installTag ; /* Install tag of current server engine */ String tcpPort ; /* TCP port of current server engine */ } public static class DSREPOSINFO extends Structure{ int infoType; DSREPOSJOBINFO jobs; /* linked list of found jobs */ } public static class DSREPOSUSAGEJOB extends Structure{ String jobname; /* Job and cat name */ int jobtype; /* type of job */ DSREPOSUSAGEJOB nextjob; /* next job in linked list of jobs at same level */ DSREPOSUSAGEJOB childjob; /* first child job in linked list */ } public static class DSREPOSUSAGE extends Structure{ int infoType; DSREPOSUSAGEJOB jobs; /* linked list of jobs */ } public static class DSSTAGEINFO extends Structure{ int infoType; /* Key indicating type of information */ DSLOGDETAIL lastError; /* Last error message (log) from a link */ String typeName; /* Name of stage type */ int inRowNum; /* Primary links input row number */ String linkList; /* List of stage link names */ String stageName; /* Name of current stage */ String varList; /* List of stage variable names */ time_t stageStartTime; /* Date and time when stage started */ time_t stageEndTime; /* Date and time when stage finished */ String linkTypes; String stageDesc; String instList; String cpuList; String stageElapsed; String pidList; int stageStatus; String custInfoList; /* List of custom info names */ } public static class DSVARINFO extends Structure{ int infoType; /* Key indicating type of information */ String varValue; String varDesc; } public static class DSCUSTINFO extends Structure{ int infoType; /* Key indicating type of information */ String custInfoValue; String custInfoDesc; } public static class DSREPORTINFO extends Structure{ int reportType; String reportText; } public static class DSREPOSJOBINFO extends Structure{ String jobname; /* Includes category */ int jobtype; /* InfoType constant */ DSREPOSJOBINFO nextjob; /* link to next job */ } public static class DSLOGDETAIL extends Structure{ int eventId; /* Id of this event */ time_t timestamp; /* Data and time event occurred */ int type; /* Type of event */ String username; /* User name associated with event */ String fullMessage; /* Full description of event */ } public static class DSLOGEVENT extends Structure{ int eventId; /* Id of this event */ time_t timestamp; /* Data and time event occurred */ int type; /* Type of event */ String message; /* Short event message */ } public static class DSLINKINFO extends Structure{ int infoType; /* Key indicating type of information */ DSLOGDETAIL lastError; /* Last error message from link */ int rowCount; /* number of rows that have passed down link */ String linkName; /* Name of this link */ String linkSQLState; /* SQL state for last error */ String linkDBMSCode; /* DBMC code for last error */ String linkDesc; String linkedStage; String rowCountList; } public static class DSJOBINFO extends Structure{ int infoType; /* Key indicating type of information */ int jobStatus; /* Current status of job */ String jobController; /* Name of controlling job */ time_t jobStartTime; /* Date and time when job started */ int jobWaveNumber; /* Wave number of current or last run */ String userStatus; /* Last set user status */ String stageList; /* List of stage names in job */ String paramList; /* List of job parameter names */ String jobName; /* Name of this job */ int jobControl; /* Current job control status */ int jobPid; /* Job process id */ time_t jobLastTime; /* Date and time when job finished */ String jobInvocations; /* List of job invocation ids */ int jobInterimStatus; /* Interim status of job */ String jobInvocationId; /* Job invocation id */ String jobDesc; String stageList2; String jobElapsed; int jobDMIService ; /* Job is a DMI (aka WEB) service */ int jobMultiInvokable ; /* Job can be multiply invoked */ String jobFullDesc ; /* Full job description */ int jobRestartable ; /* Job is restartable */ } vmdsapi INSTANCE = (vmdsapi)Native.loadLibrary("vmdsapi",vmdsapi.class); public DSPROJECT DSOpenProjectEx(int serial,String pro); public DSJOB DSOpenJob(DSPROJECT pro,String job); public int DSLockJob(DSJOB job); public int DSServerMessage(String MsgIdStr, String DefMsg, String Prms, String pMessage, int SizeMessage); public int DSGetCustInfo( DSJOB JobHandle,String StageName, String CustinfoName,int InfoType, DSSTAGEINFO ReturnInfo); public int DSGetReposInfo ( DSPROJECT hProject, int ObjectType, int InfoType, String SearchCriteria, String StartingCategory, int Subcategories, DSREPOSINFO ReturnInfo); public String DSGetProjectList(); public DSPROJECT DSOpenProject(String ProjectName); public void DSSetServerParams( String ServerName, String UserName, String Password); public int DSCloseProject( DSPROJECT ProjectHandle); public int DSCloseJob( DSJOB JobHandle); public int DSGetJobInfo( DSJOB JobHandle, int InfoType, DSJOBINFO ReturnInfo); public int DSAddEnvVar( DSPROJECT hProject, String EnvVarName, String Type, String PromptText, String Value); public int DSAddProject( String ProjectName, String ProjectLocation); public int DSDeleteEnvVar( DSPROJECT hProject, String EnvVar); public int DSDeleteProject( String ProjectName); public int DSFindFi