home *** CD-ROM | disk | FTP | other *** search
/ CD Actual Thematic 7: Programming / CDAT7.iso / Share / Java / JDesignerPro / Jdp3_0.exe / data1.cab / Program_Files / JDPActiveJob.class (.txt) < prev    next >
Encoding:
Java Class File  |  1999-04-09  |  14.0 KB  |  668 lines
  1. import java.io.BufferedInputStream;
  2. import java.lang.reflect.Constructor;
  3. import java.util.Date;
  4. import java.util.StringTokenizer;
  5. import java.util.Vector;
  6. import javax.ejb.EnterpriseBean;
  7. import javax.ejb.EntityBean;
  8. import javax.ejb.SessionBean;
  9.  
  10. public class JDPActiveJob extends Thread {
  11.    JDPSubsystem subsystem;
  12.    JDPJob job;
  13.    JDPActiveJob target;
  14.    // $FF: renamed from: in java.io.BufferedInputStream
  15.    BufferedInputStream field_0;
  16.    BufferedInputStream err;
  17.    BufferedInputStream thisStream;
  18.    Date jobstartdate;
  19.    long jobstarttime;
  20.    StringBuffer inLog;
  21.    StringBuffer errLog;
  22.    boolean monitorFinished = false;
  23.    JDPJagg jaggSQL;
  24.    Object thisInstance;
  25.    boolean entityBean = false;
  26.  
  27.    public JDPActiveJob(JDPSubsystem var1, JDPJob var2) {
  28.       super(var1.thisThreadGroup, var2.getJobName());
  29.       this.subsystem = var1;
  30.       this.job = var2;
  31.    }
  32.  
  33.    public JDPActiveJob(JDPSubsystem var1, JDPJob var2, JDPActiveJob var3, BufferedInputStream var4) {
  34.       super(var1.thisThreadGroup, var2.getJobName() + var4.toString());
  35.       this.subsystem = var1;
  36.       this.job = var2;
  37.       this.target = var3;
  38.       this.thisStream = var4;
  39.       ((Thread)this).start();
  40.    }
  41.  
  42.    public void run() {
  43.       if (this.target != null) {
  44.          this.monitorActiveJob();
  45.          this.monitorFinished = true;
  46.       } else {
  47.          this.initJob();
  48.          boolean var1 = false;
  49.          var1 = this.startRequest();
  50.          if (this.entityBean || this.job.getObjectType().equals("S")) {
  51.             while(!this.subsystem.manager.shutdownRequested) {
  52.                try {
  53.                   Thread.sleep(5000L);
  54.                } catch (Exception var2) {
  55.                }
  56.             }
  57.          }
  58.  
  59.          this.completeJob(var1);
  60.       }
  61.    }
  62.  
  63.    public void initJob() {
  64.       Date var1 = new Date();
  65.       long var2 = var1.getTime();
  66.       var1.setHours(0);
  67.       var1.setMinutes(0);
  68.       var1.setSeconds(0);
  69.       this.jobstartdate = var1;
  70.       this.jobstarttime = var2 - var1.getTime();
  71.       var2 -= var1.getTime();
  72.       this.job.setStartDate(var1);
  73.       this.job.setStartTime(var2);
  74.    }
  75.  
  76.    public boolean startRequest() {
  77.       boolean var1 = false;
  78.       if (this.job.getObjectType().equals("J")) {
  79.          this.setupJaggConnection();
  80.       }
  81.  
  82.       var1 = this.runRequest(this.job.getObjectType(), this.job.getObject(), this.job.getObjectConstructor(), this.job.getObjectParm());
  83.       return var1;
  84.    }
  85.  
  86.    public void completeJob(boolean var1) {
  87.       if (this.job.getJobStatus() == 9) {
  88.          var1 = false;
  89.       }
  90.  
  91.       if (this.thisInstance != null && this.thisInstance instanceof EnterpriseBean) {
  92.          this.closeEnterpriseBean();
  93.       }
  94.  
  95.       Date var2 = new Date();
  96.       long var3 = var2.getTime();
  97.       var2.setHours(0);
  98.       var2.setMinutes(0);
  99.       var2.setSeconds(0);
  100.       var3 -= var2.getTime();
  101.       this.job.setEndDate(var2);
  102.       this.job.setEndTime(var3);
  103.       this.subsystem.setJobComplete(this.job);
  104.       int var5 = this.job.getNotifyUser();
  105.       String var6 = this.job.getNotifyOn();
  106.       if (var5 >= 0) {
  107.          if ((var6.equals("S") || var6.equals("B")) && var1) {
  108.             this.job.setNotifyNow(true);
  109.          }
  110.  
  111.          if ((var6.equals("F") || var6.equals("B")) && !var1) {
  112.             this.job.setNotifyNow(true);
  113.          }
  114.       }
  115.  
  116.       String var7 = this.job.getLogEvent();
  117.       if ((var7.equals("F") || var7.equals("B")) && !var1 || (var7.equals("S") || var7.equals("B")) && var1) {
  118.          this.job.setLogEventNow(true);
  119.       }
  120.  
  121.       if (var1) {
  122.          this.job.setJobStatus(10);
  123.       } else {
  124.          this.job.appendJobLog("Job failed");
  125.          this.job.setJobStatus(9);
  126.       }
  127.    }
  128.  
  129.    public boolean runRequest(String var1, String var2, String var3, String var4) {
  130.       boolean var5 = false;
  131.  
  132.       try {
  133.          if (var1.equals("C")) {
  134.             var5 = this.createObject(var2, var3, var4);
  135.          } else if (var1.equals("A")) {
  136.             var5 = this.runApplication(var2, var4);
  137.          } else if (var1.equals("J")) {
  138.             var5 = this.runJobStream(var2);
  139.          }
  140.       } catch (Exception var7) {
  141.          this.job.logException(var7);
  142.       }
  143.  
  144.       return var5;
  145.    }
  146.  
  147.    public boolean createObject(String var1, String var2, String var3) {
  148.       if (var1 != null && !var1.equals("")) {
  149.          if (var2 != null && !var2.equals("")) {
  150.             if (!var2.startsWith("(")) {
  151.                var2 = "(" + var2;
  152.             }
  153.  
  154.             if (!var2.endsWith(")")) {
  155.                var2 = var2 + ")";
  156.             }
  157.  
  158.             var2 = this.job.manager.utils.replace(var2, " ", "");
  159.             Constructor var4 = this.getSelectedConstructor(var1, var2);
  160.             if (var4 == null) {
  161.                this.job.appendJobLog("Unknown constructor: " + var2);
  162.                return false;
  163.             } else {
  164.                Class[] var5 = var4.getParameterTypes();
  165.                int var6 = 0;
  166.                String[] var7 = new String[var5.length];
  167.  
  168.                for(int var15 = 0; var15 < var7.length; ++var15) {
  169.                   var7[var15] = "";
  170.                }
  171.  
  172.                StringTokenizer var8 = new StringTokenizer(var3, ",", true);
  173.                var6 = 0;
  174.  
  175.                while(var6 < var7.length && var8.hasMoreTokens()) {
  176.                   String var9 = var8.nextToken();
  177.                   if (var9.equals(",")) {
  178.                      ++var6;
  179.                   } else {
  180.                      var7[var6] = var9;
  181.                      if (var7[var6].startsWith("\"")) {
  182.                         for(var7[var6] = var7[var6].substring(1); !var7[var6].endsWith("\""); var7[var6] = var7[var6] + var8.nextToken()) {
  183.                         }
  184.  
  185.                         var7[var6] = var7[var6].substring(0, var7[var6].length() - 1);
  186.                      }
  187.                   }
  188.                }
  189.  
  190.                Object[] var10 = new Object[var5.length];
  191.  
  192.                for(int var17 = 0; var17 < var10.length; ++var17) {
  193.                   var10[var17] = this.createObject(var5[var17], var7[var17]);
  194.                }
  195.  
  196.                try {
  197.                   this.thisInstance = var4.newInstance(var10);
  198.                   if (this.thisInstance != null && this.thisInstance instanceof EnterpriseBean) {
  199.                      this.handleEnterpriseBean();
  200.                   }
  201.  
  202.                   return true;
  203.                } catch (Exception var13) {
  204.                   this.job.logException(var13);
  205.                   if (var10.length > 0) {
  206.                      this.job.appendJobLog("    with parameters:");
  207.  
  208.                      for(int var12 = 0; var12 < var10.length; ++var12) {
  209.                         this.job.appendJobLog("       > " + var10[var12].toString());
  210.                      }
  211.                   }
  212.  
  213.                   return false;
  214.                }
  215.             }
  216.          } else {
  217.             this.job.appendJobLog("Constructor not defined");
  218.             return false;
  219.          }
  220.       } else {
  221.          this.job.appendJobLog("Class name not defined");
  222.          return false;
  223.       }
  224.    }
  225.  
  226.    void handleEnterpriseBean() {
  227.       try {
  228.          if (this.thisInstance instanceof SessionBean) {
  229.             JDPSessionContext var4 = new JDPSessionContext();
  230.             SessionBean var5 = (SessionBean)this.thisInstance;
  231.             var5.setSessionContext(var4);
  232.             var5.ejbActivate();
  233.             return;
  234.          }
  235.  
  236.          if (this.thisInstance instanceof EntityBean) {
  237.             JDPEntityContext var1 = new JDPEntityContext();
  238.             EntityBean var2 = (EntityBean)this.thisInstance;
  239.             var2.setEntityContext(var1);
  240.             var2.ejbLoad();
  241.             this.entityBean = true;
  242.             return;
  243.          }
  244.       } catch (Exception var3) {
  245.          this.job.logException(var3);
  246.       }
  247.  
  248.    }
  249.  
  250.    void closeEnterpriseBean() {
  251.       try {
  252.          if (this.thisInstance instanceof SessionBean) {
  253.             SessionBean var3 = (SessionBean)this.thisInstance;
  254.             var3.ejbPassivate();
  255.             var3.ejbRemove();
  256.             return;
  257.          }
  258.  
  259.          if (this.thisInstance instanceof EntityBean) {
  260.             EntityBean var1 = (EntityBean)this.thisInstance;
  261.             var1.ejbStore();
  262.             var1.ejbRemove();
  263.             return;
  264.          }
  265.       } catch (Exception var2) {
  266.          this.job.logException(var2);
  267.       }
  268.  
  269.    }
  270.  
  271.    public boolean runApplication(String var1, String var2) {
  272.       int var3 = 1;
  273.       String var4 = var1 + " " + var2;
  274.  
  275.       try {
  276.          Runtime var5 = Runtime.getRuntime();
  277.          Process var6 = var5.exec(var4);
  278.          this.field_0 = new BufferedInputStream(var6.getInputStream());
  279.          this.err = new BufferedInputStream(var6.getErrorStream());
  280.          JDPActiveJob var7 = new JDPActiveJob(this.subsystem, this.job, this, this.field_0);
  281.          JDPActiveJob var8 = new JDPActiveJob(this.subsystem, this.job, this, this.err);
  282.          var3 = var6.waitFor();
  283.  
  284.          while(!var7.monitorFinished) {
  285.             try {
  286.                Thread.sleep(100L);
  287.             } catch (Exception var10) {
  288.             }
  289.          }
  290.  
  291.          while(!var8.monitorFinished) {
  292.             try {
  293.                Thread.sleep(100L);
  294.             } catch (Exception var9) {
  295.             }
  296.          }
  297.  
  298.          if (var7.inLog != null) {
  299.             this.job.appendJobLog(var7.inLog.toString());
  300.          }
  301.  
  302.          if (var8.errLog != null) {
  303.             this.job.appendJobLog(var8.errLog.toString());
  304.          }
  305.  
  306.          var6.destroy();
  307.       } catch (Exception var11) {
  308.          this.job.appendJobLog("Could not execute the following command: " + var4);
  309.          this.job.logException(var11);
  310.       }
  311.  
  312.       return var3 == 0;
  313.    }
  314.  
  315.    public boolean runJobStream(String var1) {
  316.       String var3 = this.jaggSQL.getSEP();
  317.       Vector var4 = new Vector();
  318.       String var5 = "SELECT a.Entry, a.ObjectType, a.Object, a.ObjectParm, a.ObjectCons, a.StopIfFail, b.Restart, b.lastEntry, b.lastStatus FROM JDPJobEn a, JDPJobs b WHERE a.JDPSystem = b.JDPSystem AND a.StreamName = b.StreamName AND a.JDPSystem = '" + this.job.getJDPSystem() + "' " + "AND a.StreamName = '" + var1 + "' " + "ORDER BY a.Entry";
  319.       int var6 = this.jaggSQL.execSQL(var5, var4);
  320.       int var7 = 0;
  321.       if (var6 > 0) {
  322.          StringTokenizer var2 = new StringTokenizer((String)var4.elementAt(0), var3);
  323.          Integer.parseInt(var2.nextToken().trim());
  324.          var2.nextToken().trim();
  325.          var2.nextToken().trim();
  326.          var2.nextToken().trim();
  327.          var2.nextToken().trim();
  328.          var2.nextToken().trim();
  329.          String var8 = var2.nextToken().trim();
  330.          int var9 = Integer.parseInt(var2.nextToken().trim());
  331.          String var10 = var2.nextToken().trim();
  332.          if (var10.equals("F")) {
  333.             this.job.appendJobLog("Job stream failed to complete normally on last run");
  334.             if (var8.equals("F")) {
  335.                var7 = 0;
  336.                this.job.appendJobLog("Restarting at first entry in Job Stream");
  337.             } else if (var8.equals("L")) {
  338.                var7 = var9;
  339.                this.job.appendJobLog("Restarting at entry " + Integer.toString(var9) + " in Job Stream");
  340.             } else if (var8.equals("A")) {
  341.                var7 = var9 + 1;
  342.                this.job.appendJobLog("Restarting after entry " + Integer.toString(var9) + " in Job Stream");
  343.             }
  344.          }
  345.       }
  346.  
  347.       String var33 = "S";
  348.       int var34 = 0;
  349.       Date var35 = new Date();
  350.       long var11 = var35.getTime();
  351.       var35.setHours(0);
  352.       var35.setMinutes(0);
  353.       var35.setSeconds(0);
  354.  
  355.       for(int var13 = 0; var13 < var6; ++var13) {
  356.          StringTokenizer var29 = new StringTokenizer((String)var4.elementAt(var13), var3);
  357.          int var14 = Integer.parseInt(var29.nextToken().trim());
  358.          String var15 = var29.nextToken().trim();
  359.          String var16 = var29.nextToken().trim();
  360.          String var17 = var29.nextToken().trim();
  361.          String var18 = var29.nextToken().trim();
  362.          String var19 = var29.nextToken().trim();
  363.          if (var14 >= var7) {
  364.             Date var20 = new Date();
  365.             long var21 = var20.getTime();
  366.             var20.setHours(0);
  367.             var20.setMinutes(0);
  368.             var20.setSeconds(0);
  369.             int var23 = this.job.getJobLogBuffer().length();
  370.             String var24 = "Starting ";
  371.             if (var15.equals("C")) {
  372.                var24 = var24 + "Class ";
  373.             }
  374.  
  375.             if (var15.equals("A")) {
  376.                var24 = var24 + "Application ";
  377.             }
  378.  
  379.             if (var15.equals("J")) {
  380.                var24 = var24 + "JobStream ";
  381.             }
  382.  
  383.             var24 = var24 + var16;
  384.             var24 = var24 + " (entry " + Integer.toString(var14) + " of jobstream " + var1.trim() + ")...";
  385.             this.job.appendJobLog(var24);
  386.             boolean var25 = this.runRequest(var15, var16, var18, var17);
  387.             if (!var25) {
  388.                var35 = new Date();
  389.                long var26 = var35.getTime() - var21;
  390.                var11 = var35.getTime();
  391.                var35.setHours(0);
  392.                var35.setMinutes(0);
  393.                var35.setSeconds(0);
  394.                var5 = "UPDATE JDPJobEn SET LastStatus = 'F', Duration = " + Long.toString(var26) + ", " + "LastJobLog = '" + this.job.getJobLog().substring(var23) + "' " + "WHERE JDPSystem = '" + this.job.getJDPSystem() + "' " + "AND StreamName = '" + var1 + "' " + "AND Entry = " + Integer.toString(var14);
  395.                Vector var28 = new Vector();
  396.                this.jaggSQL.execSQL(var5, var28);
  397.                if (var19.equals("Y")) {
  398.                   var33 = "F";
  399.                   var34 = var14;
  400.                   var13 = var6 + 1;
  401.                }
  402.             } else {
  403.                long var39 = (new Date()).getTime() - var21;
  404.                var5 = "UPDATE JDPJobEn SET LastStatus = 'S', Duration = " + Long.toString(var39) + ", " + "LastJobLog = '" + this.job.getJobLog().substring(var23) + "' " + "WHERE JDPSystem = '" + this.job.getJDPSystem() + "' " + "AND StreamName = '" + var1 + "' " + "AND Entry = " + Integer.toString(var14);
  405.                Vector var40 = new Vector();
  406.                this.jaggSQL.execSQL(var5, var40);
  407.             }
  408.          }
  409.       }
  410.  
  411.       var5 = "UPDATE JDPJobs SET LastStatus = '" + var33 + "', " + "LastEntry = " + Integer.toString(var34) + ", " + "ActualStrt = " + JDPDate.formatForSql(this.jobstartdate, JDPSubsystemMgr.dbtype) + ", " + "StartTime = " + Long.toString(this.jobstarttime) + ", " + "ActualEnd = " + JDPDate.formatForSql(var35, JDPSubsystemMgr.dbtype) + ", " + "EndTime = " + Long.toString(var11 - var35.getTime()) + " " + "WHERE JDPSystem = '" + this.job.getJDPSystem() + "' " + "AND StreamName = '" + var1 + "' ";
  412.       Vector var36 = new Vector();
  413.       this.jaggSQL.execSQL(var5, var36);
  414.       return true;
  415.    }
  416.  
  417.    public Constructor getSelectedConstructor(String var1, String var2) {
  418.       try {
  419.          Class var3 = null;
  420.          if (var1.equals("int")) {
  421.             var3 = Integer.TYPE;
  422.          }
  423.  
  424.          if (var1.equals("boolean")) {
  425.             var3 = Boolean.TYPE;
  426.          }
  427.  
  428.          if (var1.equals("char")) {
  429.             var3 = Character.TYPE;
  430.          }
  431.  
  432.          if (var1.equals("byte")) {
  433.             var3 = Byte.TYPE;
  434.          }
  435.  
  436.          if (var1.equals("short")) {
  437.             var3 = Short.TYPE;
  438.          }
  439.  
  440.          if (var1.equals("long")) {
  441.             var3 = Long.TYPE;
  442.          }
  443.  
  444.          if (var1.equals("float")) {
  445.             var3 = Float.TYPE;
  446.          }
  447.  
  448.          if (var1.equals("double")) {
  449.             var3 = Double.TYPE;
  450.          }
  451.  
  452.          if (var1.equals("void")) {
  453.             var3 = Void.TYPE;
  454.          }
  455.  
  456.          if (var3 == null) {
  457.             var3 = Class.forName(var1);
  458.          }
  459.  
  460.          Constructor[] var4 = var3.getConstructors();
  461.  
  462.          for(int var5 = 0; var5 < var4.length; ++var5) {
  463.             String var6 = "(";
  464.             Class[] var7 = var4[var5].getParameterTypes();
  465.  
  466.             for(int var8 = 0; var8 < var7.length; ++var8) {
  467.                if (var8 > 0) {
  468.                   var6 = var6 + ",";
  469.                }
  470.  
  471.                var6 = var6 + this.convertParm(var7[var8].getName());
  472.             }
  473.  
  474.             var6 = var6 + ")";
  475.             if (var6.equals(var2)) {
  476.                return var4[var5];
  477.             }
  478.          }
  479.       } catch (Exception var9) {
  480.          this.job.logException(var9);
  481.       }
  482.  
  483.       return null;
  484.    }
  485.  
  486.    public String convertParm(String var1) {
  487.       try {
  488.          if (var1.indexOf("[[L") >= 0) {
  489.             var1 = var1.substring(3, var1.length() - 1) + "[][]";
  490.          } else if (var1.indexOf("[I") >= 0) {
  491.             var1 = "int[]";
  492.          } else if (var1.indexOf("[Z") >= 0) {
  493.             var1 = "boolean[]";
  494.          } else if (var1.indexOf("[C") >= 0) {
  495.             var1 = "char[]";
  496.          } else if (var1.indexOf("[B") >= 0) {
  497.             var1 = "byte[]";
  498.          } else if (var1.indexOf("[") >= 0) {
  499.             var1 = var1.substring(2, var1.length() - 1) + "[]";
  500.          }
  501.  
  502.          if (var1.startsWith("java")) {
  503.             int var2 = var1.lastIndexOf(".");
  504.             if (var2 > 0) {
  505.                var1 = var1.substring(var2 + 1);
  506.             }
  507.          }
  508.       } catch (Exception var3) {
  509.          System.out.println("Parm value: " + var1);
  510.          this.job.logException(var3);
  511.       }
  512.  
  513.       return var1;
  514.    }
  515.  
  516.    Object createObject(Class var1, String var2) {
  517.       try {
  518.          String var3 = var1.getName();
  519.          if (var3.equals("java.lang.String")) {
  520.             return var2;
  521.          }
  522.  
  523.          if (var3.equals("int")) {
  524.             if (var2.equals("")) {
  525.                var2 = "0";
  526.             }
  527.  
  528.             return new Integer(var2);
  529.          }
  530.  
  531.          if (var3.equals("boolean")) {
  532.             if (var2.equals("true")) {
  533.                return new Boolean(true);
  534.             }
  535.  
  536.             return new Boolean(false);
  537.          }
  538.  
  539.          if (var3.equals("char")) {
  540.             return new Character(var2.charAt(0));
  541.          }
  542.  
  543.          if (var3.equals("byte")) {
  544.             return new Byte(var2);
  545.          }
  546.  
  547.          if (var2.equals("")) {
  548.             var2 = "0";
  549.          }
  550.  
  551.          if (var3.equals("short")) {
  552.             return new Short(var2);
  553.          }
  554.  
  555.          if (var3.equals("long")) {
  556.             return new Long(var2);
  557.          }
  558.  
  559.          if (var3.equals("float")) {
  560.             return new Float(var2);
  561.          }
  562.  
  563.          if (var3.equals("double")) {
  564.             return new Double(var2);
  565.          }
  566.  
  567.          if (var2.equals("JDPSubsystemMgr")) {
  568.             return this.subsystem.manager;
  569.          }
  570.  
  571.          if (var2.equals("JDPActiveJob")) {
  572.             return this;
  573.          }
  574.  
  575.          if (var2.equals("JDPJob")) {
  576.             return this.job;
  577.          }
  578.  
  579.          Constructor[] var4 = var1.getConstructors();
  580.          Object var5 = null;
  581.          Object[] var6 = new Object[]{var2};
  582.  
  583.          for(int var7 = 0; var7 < var4.length; ++var7) {
  584.             Class[] var11 = var4[var7].getParameterTypes();
  585.             if (var11.length == 1) {
  586.                try {
  587.                   Object var8 = var4[var7].newInstance(var6);
  588.                   return var8;
  589.                } catch (Exception var9) {
  590.                   this.job.appendJobLog("Failed to instantiate the Object with the given parameters.");
  591.                   this.job.appendJobLog("Check the parameters and resubmit the job.");
  592.                   this.job.logException(var9);
  593.                }
  594.             }
  595.          }
  596.       } catch (Exception var10) {
  597.       }
  598.  
  599.       return null;
  600.    }
  601.  
  602.    public void monitorActiveJob() {
  603.       char[] var1 = null;
  604.       char[] var2 = var1;
  605.       if (var1 == null) {
  606.          var2 = var1 = new char[128];
  607.       }
  608.  
  609.       int var3 = var2.length;
  610.       int var4 = 0;
  611.       boolean var5 = false;
  612.  
  613.       try {
  614.          for(int var8 = this.thisStream.read(); var8 > -1; var8 = this.thisStream.read()) {
  615.             --var3;
  616.             if (var3 < 0) {
  617.                var2 = new char[var4 + 128];
  618.                var3 = var2.length - var4 - 1;
  619.                System.arraycopy(var1, 0, var2, 0, var4);
  620.                var1 = var2;
  621.             }
  622.  
  623.             var2[var4++] = (char)var8;
  624.          }
  625.  
  626.          if (var4 > 0) {
  627.             this.writeLog(String.copyValueOf(var2, 0, var4));
  628.          }
  629.  
  630.          this.thisStream.close();
  631.       } catch (Exception var7) {
  632.          this.job.logException(var7);
  633.       }
  634.    }
  635.  
  636.    public void writeLog(String var1) {
  637.       if (this.target != null) {
  638.          if (this.thisStream == this.target.field_0) {
  639.             if (this.inLog == null) {
  640.                this.inLog = new StringBuffer();
  641.             }
  642.  
  643.             this.inLog.append(var1);
  644.             return;
  645.          }
  646.  
  647.          if (this.errLog == null) {
  648.             this.errLog = new StringBuffer();
  649.          }
  650.  
  651.          this.errLog.append(var1);
  652.       }
  653.  
  654.    }
  655.  
  656.    public void setupJaggConnection() {
  657.       JDPSubsystemMgr var1 = this.subsystem.manager;
  658.       this.jaggSQL = new JDPJagg(var1.JDPJaggPath);
  659.       this.jaggSQL.setDSN(var1.JDPJaggDSN);
  660.       this.jaggSQL.setCSTR(var1.JDPJaggCSTR);
  661.       this.jaggSQL.setJdbcDriver(var1.JDPJaggJdbcDriver);
  662.       this.jaggSQL.setJdbcPrefix(var1.JDPJaggJdbcPrefix);
  663.       this.jaggSQL.setJdbcSuffix(var1.JDPJaggJdbcSuffix);
  664.       this.jaggSQL.setUID(var1.JDPJaggJdbcUserid);
  665.       this.jaggSQL.setPWD(var1.JDPJaggJdbcPassword);
  666.    }
  667. }
  668.