Working with objects in the database

Provides examples of using the Java™ API to work with objects in the database.

The following examples indicate how you use the classes to work with objects in the database:

Example 1: Adding a workstation to the database

//Object definition
String wksName = "MYWS";
Workstation wks = new Workstation();
wks.setName(wksName);
wks.setType(WorkstationType.FTA);
wks.setOs(OperatingSystem.UNIX);
wks.setAutoLink(true);
wks.setNodeName("node.abc.com");
wks.setSecurityLevel(SecurityLevel.NONE);
		 		 

ConnModel myModel;
//Get an instance of ConnModel interface...
...
		 		 
//Add the object
try 
{    
		 myModel.addTWSObject(wks, null);
}
catch (ConnException e) 
{
		 //Do something to recover...
}

Example 2: Retrieving a workstation from the database

Workstation wksRead = new Workstation();
//Get the same workstation from the DB
try 
{
wksRead = (Workstation) myModel.getTWSObject(Workstation.class, 
						new FlowTargetKey(wksName), false, null);
}
catch (ConnException e) 
{
		 //Do something to recover...
 }

Example 3: Removing a workstation from the database

//Remove a workstation from the DB
 try 
{
		 myModel.removeTWSObject(Workstation.class, wksRead.getId(), null);
}
catch (ConnException exc)
{
		 //Do something to recover...
}

Example 4: Defining a native job definition

//Job Definition creation

jobOk = new DistJobDefinition();
jobOk.setDescription("All values provided");
jobOk.setFlowTargetKey(wks);
jobOk.setName("JOB1");
jobOk.setTaskType("UNIX");
jobOk.setTaskString("ls");
jobOk.setUserLogin("tws_user");
jobOk.setRecoveryOption(RecoveryOption.STOP);

Example 5: Defining a job definition by using Jsdl

//Job Definition creation with Jsdl

jobPred4 = new DistJobDefinition();
jobPred4.setDescription("All values provided");
jobPred4.setFlowTargetKey(wksAgt);
jobPred4.setName("JSDLJOB");
jobPred4.setDefinedByJsdl(true);
jobPred4.setTaskString("<?xml version=\"1.0\" encoding=\"UTF-8\"?>" + "
<jsdl:jobDefinition xmlns:jsdl=\"http://www.abc.com/xmlns/prod/scheduling
  /1.0/jsdl\" " + "xmlns:jsdle=\"http://www.abc.com/xmlns/prod/scheduling/1.0/
  jsdle\">" + "<jsdl:application name=\"executable\">" + 
    "<jsdle:executable interactive=
    \"false\">" + "<jsdle:script>hostname</jsdle:script>" + "</jsdle:executable>" 
    + "</jsdl:application>" + "</jsdl:jobDefinition>");
jobPred4.setRecoveryOption(RecoveryOption.STOP);

Example 6: Adding a job stream definition with dependencies, jobs, and runcycle:

//Job Stream creation

JobStream js = null;
String jsName = "SBSCDBF1_1S";
String alias = "SBSCDBF1_1S";
js = new JobStream();
js.setName(jsName);
js.setFlowTargetKey(wks);
List<Job> joblist = js.getJobs();

//Jobs creation

Job jobPredecessor = new Job();
jobPredecessor.setName(jobPredName);
jobPredecessor.setJobDefinition(jobPred4);
jobPredecessor.setJobStreamKey((JobStreamKey) js.getKey());
Job jobSuccessor1 = new Job();
jobSuccessor1.setName(jobSucc1Name);
jobSuccessor1.setJobDefinition(jobOk);
jobSuccessor1.setJobStreamKey((JobStreamKey) js.getKey());

//Add Jobs into Job Stream

joblist.add(jobPredecessor);
joblist.add(jobSuccessor1);

//Add Dependencies to jobSuccessor1 from jobPredecessor

InternalDependency depend = new InternalDependency();
depend.setJobKey(new JobKey(jobOkName,(JobStreamKey) js.getKey()));
jobSuccessor1.getInternalDependencies().add(depend);

//Add a run cycle

RunCycle rcy = new RunCycle();
rcy.setCalendarKey(null);
rcy.setDescription("runCycleDescription");
rcy.setFreeDaysRule(FreeDaysRule.NEAREST_AFTER);
rcy.setICalendar("iCalendar");
rcy.setInclusive(false);
rcy.setName("runCycleName");
rcy.setOffsetType(null);
rcy.setOffsetValue(0);
rcy.getTimeRestrictions().setTimeDependent(true);
rcy.getTimeRestrictions().setStartOffset(43200000L);
rcy.getTimeRestrictions().setDeadlineOffset(14400000L);
rcy.getTimeRestrictions().setLatestStartOffset(3600000L);
rcy.getTimeRestrictions().setLatestStartAction(LateAction.CONTINUE);
rcy.setType(RunCycleType.SIMPLE);
rcy.setValidFrom(new Date(time - 86400000L));
rcy.setValidTo(new Date(time + 86400000L));
js.getRunCycles().add(rcy);