import com.ibm.as400.access.AS400; //导入依赖的package包/类
/**
 * Test routine for fetching a spooled file list
 *
 * @param args systemName userId password userFilter
 * @see #setUserFilter(java.lang.String)
 */
public static void main(String args[]) {
    String systemName = args[0];
    String userId = args[1];
    String password = args[2];
    String userFilter = args[3];
    try {
        AS400 as400 = AS400Factory.newAS400(systemName, userId, password);
        SpooledFileLister lister = new SpooledFileLister(as400);
        lister.setUserFilter(userFilter);
        Enumeration e = lister.getSynchronously();
        while (e.hasMoreElements()) {
            SpooledFile spf = SpooledFile.class.cast(e.nextElement());
            System.out.println(spf.getName() + " " + spf.getNumber() + " " + spf.getJobName() + " " + spf.getJobUser() + " " + spf.getJobNumber() + " " + spf.getCreateDate() + " " + spf.getCreateTime());
        }
    } catch (AS400SecurityException | ErrorCompletingRequestException | IOException | InterruptedException | PropertyVetoException | RequestNotSupportedException ex) {
        LOG.log(Level.SEVERE, "Exception fetching list of spooled files", ex);
    }
}
 

import com.ibm.as400.access.AS400; //导入依赖的package包/类
/**
 * A test of fetching the transformed spooled file and transforming it.
 *
 * @param args sysName userId password spoolFileName spoolNumber jobName
 * jobUser jobNumber
 */
public static void main(String[] args) {
    String sysName = args[0];
    String userId = args[1];
    String password = args[2];
    String spoolFileName = args[3];
    int spoolNumber = Integer.parseInt(args[4]);
    String jobName = args[5];
    String jobUser = args[6];
    String jobNumber = args[7];

    try {
        AS400 as400 = AS400Factory.newAS400(sysName, userId, password);
        TransformedSpooledFileFetcher fetcher = new TransformedSpooledFileFetcher(as400, spoolFileName, spoolNumber, jobName, jobUser, jobNumber);
        System.out.print(fetcher.fetchSpooledFile());
        System.out.flush();
    } catch (AS400SecurityException | PropertyVetoException | ErrorCompletingRequestException | IOException | InterruptedException | RequestNotSupportedException ex) {
        LOG.log(Level.SEVERE, "Exception fetching spooled file", ex);
    }

}
 

import com.ibm.as400.access.AS400; //导入依赖的package包/类
@Override
public void exceptionOccurred(SignonEvent event)
        throws AS400SecurityException {
    boolean reThrowing = true;
    AS400 as400 = AS400.class
            .cast(event.getSource());
    AS400SecurityException aS400SecurityException = event.getException();
    int asexRc = aS400SecurityException.getReturnCode();
    /* Debug */ Logger.getLogger(SignonHandler.class
            .getName()).log(Level.INFO, "AS400SecurityException retcode is {0}", asexRc);
    switch (asexRc) {
        case AS400SecurityException.PASSWORD_ERROR:
        case AS400SecurityException.PASSWORD_INCORRECT:
            try {
                if (pollForPassword(as400)) {
                    reThrowing = false;
                }
            } catch (IOException ex) {
                Logger.getLogger(SignonHandler.class.getName()).log(Level.SEVERE, null, ex);
            }
            break;
    }
    if (reThrowing) {
        throw aS400SecurityException;
    }
}
 

import com.ibm.as400.access.AS400; //导入依赖的package包/类
/**
 * Polls user for a password and if gotten resets password field of as400
 *
 * @param as400 the system we are trying to get a valid password for
 * @return true if got a password from user
 * @throws IOException
 */
protected boolean pollForPassword(AS400 as400) throws IOException {
    boolean result = false;
    String passwordPrompt = "Please enter a valid password for " + as400.getSystemName() + " (will not echo):";
    char[] password;
    if (System.console() != null) {
        password = System.console().readPassword(passwordPrompt);
    } else {
        if (Ublu.ubluSingleton.isGoubluing()) {
            System.out.println(passwordPrompt);
        } else {
            System.out.print(passwordPrompt);
        }
        password = new BufferedReader(new InputStreamReader(System.in)).readLine().trim().toCharArray();
    }
    String pString = new String(password).trim();
    if (!pString.isEmpty()) {
        as400.setPassword(pString);
        result = true;
    }
    return result;
}
 

import com.ibm.as400.access.AS400; //导入依赖的package包/类
/**
 * Polls user for a userid and if gotten resets userid field of as400
 *
 * @param as400 the system we are trying to get a valid userid for
 * @return true if got a userid from user
 * @throws IOException
 * @throws PropertyVetoException
 */
protected boolean pollForUserId(AS400 as400) throws IOException, PropertyVetoException {
    boolean result = false;
    String useridPrompt = "Please enter a valid userid for " + as400.getSystemName() + ": ";
    if (Ublu.ubluSingleton.isGoubluing()) {
        System.out.println(useridPrompt);
    } else {
        System.out.print(useridPrompt);
    }
    byte[] userid = new byte[16]; // longer than real userid swallows lf
    int numRead = System.in.read(userid);
    if (numRead > 0) {
        String uidString = new String(userid).trim();
        as400.setUserId(uidString);
        result = true;
    }
    return result;
}
 

import com.ibm.as400.access.AS400; //导入依赖的package包/类
/**
 * Translate type into string name of driver class
 *
 * @return Driver name so we can instance it.
 */
public String getDriverName() {
    String driverName = "";
    switch (getDbType()) {
        case AS400:
            driverName = "com.ibm.as400.access.AS400JDBCDriver";
            break;
        case PGSQL:
            driverName = "org.postgresql.Driver";
            break;
        case MSSQL:
            driverName = "com.microsoft.sqlserver.jdbc.SQLServerDriver";
    }
    // /* Debug */ getLogger().log(Level.INFO, "Driver name is " + getDriverName);
    return driverName;
}
 

import com.ibm.as400.access.AS400; //导入依赖的package包/类
/**
 * Translate the driver type for composing the connection url
 *
 * @return the driver string for the connection url
 */
public String getDriverType() {
    String type = "";
    switch (getDbType()) {
        case AS400:
            type = "as400";
            break;
        case PGSQL:
            type = "postgresql";
            break;
        case MSSQL:
            type = "sqlserver";
            break;
    }
    return type;
}
 

import com.ibm.as400.access.AS400; //导入依赖的package包/类
/**
 *
 * @param args
 */
public static void main(String[] args) {
    String sysName = args[0];
    String userId = args[1];
    String password = args[2];
    String spoolFileName = args[3];
    int spoolNumber = Integer.parseInt(args[4]);
    String jobName = args[5];
    String jobUser = args[6];
    String jobNumber = args[7];

    try {
        AS400 as400 = AS400Factory.newAS400(sysName, userId, password);
        SpooledFilePageFetcher fetcher = new SpooledFilePageFetcher(as400, spoolFileName, spoolNumber, jobName, jobUser, jobNumber);
        System.out.print(fetcher.readAllPages());
        System.out.flush();
    } catch (AS400SecurityException | PropertyVetoException | ErrorCompletingRequestException | IOException | InterruptedException | RequestNotSupportedException ex) {
        LOG.log(Level.SEVERE, "Exception fetching spooled file", ex);
    }

}
 

import com.ibm.as400.access.AS400; //导入依赖的package包/类
/**
 *
 * @param args
 */
public static void main(String[] args) {
    String sysName = args[0];
    String userId = args[1];
    String password = args[2];
    String spoolFileName = args[3];
    int spoolNumber = Integer.parseInt(args[4]);
    String jobName = args[5];
    String jobUser = args[6];
    String jobNumber = args[7];

    try {
        AS400 as400 = AS400Factory.newAS400(sysName, userId, password);
        SpooledFileFetcher fetcher = new SpooledFileFetcher(as400, spoolFileName, spoolNumber, jobName, jobUser, jobNumber);
        System.out.print(fetcher.fetchSpooledFile());
        System.out.flush();
    } catch (AS400SecurityException | PropertyVetoException | ErrorCompletingRequestException | IOException | InterruptedException | RequestNotSupportedException ex) {
        LOG.log(Level.SEVERE, "Exception fetching spooled file", ex);
    }

}
 

import com.ibm.as400.access.AS400; //导入依赖的package包/类
/**
 * Create a new AS400 object with the correct security type and signon
 * handler using our extenders to have the password at our disposal for use
 * with JTOpenLite classes.
 *
 * @param signon_security_type is this none or ssl?
 * @param signon_handler_type handler type for failed signons
 * @param systemName systemName
 * @param userId userId
 * @param password password
 * @return the new AS400 object
 */
protected static AS400 newAS400(SIGNON_SECURITY_TYPE signon_security_type, SIGNON_HANDLER_TYPE signon_handler_type, String systemName, String userId, String password) {
    AS400 as400
            = signon_security_type == SIGNON_SECURITY_TYPE.NONE
                    ? new AS400(systemName, userId, password)
                    : new SecureAS400(systemName, userId, password);
    switch (signon_handler_type) {
        case CUSTOM:
            as400.setSignonHandler(new SignonHandler());
            break;
        case NULL:
            as400.setSignonHandler(new NullSignonHandler());
            break;
        case BUILTIN:
            break;
    }
    return as400;
}
 

import com.ibm.as400.access.AS400; //导入依赖的package包/类
private SpooledFileLister getSpooledFileListerFromArgs(ArgArray argArray) throws PropertyVetoException, AS400SecurityException {
    SpooledFileLister splflister = null;
    AS400 a = getAs400();
    if (a == null) {
        try {
            setAs400(as400FromArgs(argArray));
        } catch (PropertyVetoException ex) {
            getLogger().log(Level.SEVERE, "Could not instance AS400 system from provided arguments in " + getNameAndDescription(), ex);
        }
    }
    if (a != null) {
        String spoolowner = argArray.nextMaybeQuotationTuplePopStringTrim();
        splflister = new SpooledFileLister(a);
        splflister.setUserFilter(spoolowner);
    }
    return splflister;
}
 

import com.ibm.as400.access.AS400; //导入依赖的package包/类
private SpooledFile getSpooledFileFromArgs(ArgArray argArray) {
    SpooledFile splf = null;
    AS400 a = getAs400();
    if (a == null) {
        try {
            setAs400(as400FromArgs(argArray));
        } catch (PropertyVetoException ex) {
            getLogger().log(Level.SEVERE, "Could not instance AS400 system from provided arguments in " + getNameAndDescription(), ex);
        }
    }
    if (a != null) {
        String name = argArray.nextMaybeQuotationTuplePopStringTrim();
        int number = argArray.nextIntMaybeQuotationTuplePopString();
        String jobName = argArray.nextMaybeQuotationTuplePopStringTrim();
        String jobUser = argArray.nextMaybeQuotationTuplePopStringTrim();
        String jobNumber = argArray.nextMaybeQuotationTuplePopStringTrim();
        splf = new SpooledFile(a, name, number, jobName, jobUser, jobNumber);
    }
    return splf;
}
 

import com.ibm.as400.access.AS400; //导入依赖的package包/类
private String getTextToWrite(AS400 as400, String writeableString) throws FileNotFoundException, IOException {
    String text = null;
    DataSink dsrc = getDataSrc();
    switch (dsrc.getType()) {
        case STD:
            text = writeableString;
            break;
        case FILE:
            File f = new File(dsrc.getName());
            FileReader fr = new FileReader(f);
            int length = new Long(f.length()).intValue();
            char[] in = new char[length];
            fr.read(in);
            text = new String(in);
            break;
        case TUPLE:
            text = getTuple(dsrc.getName()).getValue().toString();
            break;
    }
    return text;
}
 

import com.ibm.as400.access.AS400; //导入依赖的package包/类
private SpooledFileOpenList getSpooledFileOpenListFromArgs(ArgArray argArray) {
    SpooledFileOpenList splfol = null;
    AS400 a = getAs400();
    if (a == null) {
        try {
            setAs400(as400FromArgs(argArray));
        } catch (PropertyVetoException ex) {
            getLogger().log(Level.SEVERE, "Could not instance AS400 system from provided arguments in " + getNameAndDescription(), ex);
            setCommandResult(COMMANDRESULT.FAILURE);
        }
    }
    if (a != null) {
        splfol = new SpooledFileOpenList(a);
    }
    return splfol;
}
 

import com.ibm.as400.access.AS400; //导入依赖的package包/类
@Test
public void testConnectTimeout() throws Exception
{
   As400OriginDataSource ds = new As400OriginDataSource();
   ds.setProperty(As400DataSource.USERNAME, "username");
   ds.setProperty(As400DataSource.PASSWORD, "password");
   ds.setProperty(As400DataSource.HOSTNAME, "10.254.254.254");

   AS400 conn = null;

   ds.setProperty(As400DataSource.CONNECT_TIMEOUT, "1"); // set to one second
   long start = System.nanoTime();
   try {
      conn = ds.getConnection();
      fail("Data Source getConnection should not have had sufficient time to connect");
   } catch(DataSourceException de) {
      long end = System.nanoTime();
      assertEquals("connection.timedout", de.getMessage());
      assertTrue(SECONDS.convert((end - start), NANOSECONDS) < 2);
   } finally {
      if(conn != null) conn.resetAllServices();
   }
}
 

import com.ibm.as400.access.AS400; //导入依赖的package包/类
@Test
public void testAvailable() throws Exception
{
   As400OriginDataSource ds = new As400OriginDataSource();
   ds.setProperty(As400DataSource.USERNAME, "username");
   ds.setProperty(As400DataSource.PASSWORD, "password");
   ds.setProperty(As400DataSource.HOSTNAME, "unknown.man.cox.com");

   AS400 conn = null;
   try {
      conn = ds.getConnection();
   } catch(Exception e) {
      assertEquals("Should have received a connect failure", "connect.failure", e.getMessage());
      assertFalse("Datasource should not be available after conn failure", ds.isAvailable());
   } finally {
      if(conn != null) conn.resetAllServices();
   }

   ds.close();
}
 

import com.ibm.as400.access.AS400; //导入依赖的package包/类
@Test
public void testCreateDateAndLastAccessDate() throws Exception
{
   As400OriginDataSource origin = createOriginDataSource();
   As400PoolingDataSource ds = new As400PoolingDataSource(origin);
   try {
      Assert.assertTrue("Dates don't match", ds.getCreateDate().equals(ds.getLastAccessDate()));
      ThreadUtils.sleep(100); // java system clock only has resolution of 20ms
      AS400 conn = null;
      try {
         conn = ds.getConnection();
      } finally {
         if(conn != null) conn.resetAllServices();
      }
      assertFalse("Dates match", ds.getCreateDate().equals(ds.getLastAccessDate()));
      Assert.assertTrue("Dates wrong", ds.getCreateDate().before(ds.getLastAccessDate()));
   } finally {
      ds.close();
   }
}
 

import com.ibm.as400.access.AS400; //导入依赖的package包/类
@Override
public boolean passwordIncorrect(SignonEvent event) {
    boolean result = false;
    AS400 as400 = AS400.class.cast(event.getSource());
    try {
        result = pollForPassword(as400);
    } catch (IOException ex) {
        Logger.getLogger(SignonHandler.class.getName()).log(Level.SEVERE, null, ex);
    }
    return result;
}
 

import com.ibm.as400.access.AS400; //导入依赖的package包/类
@Override
public boolean userIdUnknown(SignonEvent event) {
    boolean result = false;
    AS400 as400 = AS400.class.cast(event.getSource());
    try {
        result = pollForUserId(as400);
    } catch (IOException | PropertyVetoException ex) {
        Logger.getLogger(SignonHandler.class.getName()).log(Level.SEVERE, null, ex);
    }
    return result;
}
 

import com.ibm.as400.access.AS400; //导入依赖的package包/类
/**
 * Connect to the database passing an AS400 object
 *
 * @param as400
 * @param port jdbc port
 * @param database name of database
 * @param connectionProperties any desired connection properties
 * @return the connection
 * @throws ClassNotFoundException
 * @throws SQLException
 */
public Connection connect(AS400 as400, String port, String database, ConnectionProperties connectionProperties)
        throws ClassNotFoundException, SQLException {
    AS400JDBCDataSource asjdbcds = new AS400JDBCDataSource(as400);
    if (port != null) {
        asjdbcds.setPortNumber(Integer.parseInt(port));
    }
    if (database != null) {
        asjdbcds.setDatabaseName(database);
    }
    asjdbcds.setProperties(connectionProperties);
    setConnection(asjdbcds.getConnection());
    return getConnection();
}