用 Enterprise Information Integration 技术构建门户

// This is in the portlet's doView() method
. . . 
// If we haven't already looked up data source, do it now
if(ds==null){
	
 //Retrieve a datasource through the JNDI name service
 java.util.Properties parms = new java.util.Properties();
 parms.setProperty(javax.naming.Context.INITIAL_CONTEXT_FACTORY,
   "com.ibm.websphere.naming.WsnInitialContextFactory");
  try{
    //Create the initial name context
    javax.naming.Context ctx = new javax.naming.InitialContext(parms);
    //Look up the DataSource object
    ds = (javax.sql.DataSource) ctx.lookup(dsName);
    ctx.close();
    . . .
    // 	get a connection to the DataSource
    con = ds.getConnection();
  } catch(Exception e){
    . . .
  }
. . . 
}
. . . 
if(!((Query1)dataBean).connect()){
  System.out.println("Not able to connect to the database");
  log.error("cotton:JDBCPortlet:Could not connect to the database" + 
    "Please check user, password and url");
}
. . . 
// This is in an abstract class used by our DB2 II JavaBean
/ *
* connects to the datasource:
* 1. directly over jdbc
* 2. uses a connection instance from the connection pool
* @return boolean
*/	
. . . 
public boolean connect(){
  if(isDS == false){
    try { 
      Class.forName(driver).newInstance();
      con = DriverManager.getConnection(url,user,pass);
    }catch(Exception e){System.out.println("direct JDBC connection error: " + e);
      return false;
    }
    return true;
    }
    else{
      try{
        con = ds.getConnection();
        return true;
      }catch(Exception e){
        System.out.println("datasource connection error: " + "check jndi setup");
        return false;
      }
  }
}	

// This is in the portlet's doView() method
. . . 
// If we haven't already looked up data source, do it now
if(ds==null){
	
 //Retrieve a datasource through the JNDI name service
 java.util.Properties parms = new java.util.Properties();
 parms.setProperty(javax.naming.Context.INITIAL_CONTEXT_FACTORY,
   "com.ibm.websphere.naming.WsnInitialContextFactory");
  try{
    //Create the initial name context
    javax.naming.Context ctx = new javax.naming.InitialContext(parms);
    //Look up the DataSource object
    ds = (javax.sql.DataSource) ctx.lookup(dsName);
    ctx.close();
    . . .
    // 	get a connection to the DataSource
    con = ds.getConnection();
  } catch(Exception e){
    . . .
  }
. . . 
}
. . . 
if(!db2.connect()){
  System.out.println("Not able to connect to the datasource: DB2");
  log.error("cotton:JDBCPortlet:Could not connect to the database" + 
    "Please check user, password and url");
}
// This is in an abstract class used by our DB2 UDB JavaBean
/ *
* connects to the datasource:
* 1. directly over jdbc
* 2. uses a connection instance from the connection pool
* @return boolean
*/	
. . . 
public boolean connect(){
  if(isDS == false){
    try { 
      Class.forName(driver).newInstance();
      con = DriverManager.getConnection(url,user,pass);
    }catch(Exception e){System.out.println("direct JDBC connection error: " + e);
      return false;
    }
    return true;
    }
    else{
      try{
        con = ds.getConnection();
        return true;
      }catch(Exception e){
        System.out.println("datasource connection error: " + "check jndi setup");
        return false;
      }
  }
}	

// This is in the portlet's doView() method
/* The call to the Notes constructor specifies the database of interest
*  Actual connection to this database will be done as part of the 
*  access() method in the JavaBean
*/
. . .
// getRealPath() provides the fully qualified name of Notes file.
// In our test scenario, this file was stored within our portal project  
// because we wanted to ship the application and most of its data as 
// a single unit.  In a production environment, access to the 
// Notes database would probably need to be specified in a different manner. 
NotesAccess notes = new NotesAccess
  (getPortletConfig().getContext().getRealPath("Data/Claims2.nsf"));
notes.access(CUSTOMER_ID,incidents);
. . . 
				
// This is part of the access() method in the Domino Notes JavaBean
. . . 
try{
  // Initialize a notes session
  NotesThread.sinitThread();
  }
catch (Exception e){   // cannot create Domino thread
  . . .
}
try{
  Session s = NotesFactory.createSession();
  // Connect to the database
  Database claims = s.getDatabase(null,notesurl);
  // Test if we could open the database
  if (!claims.isOpen()){
    System.out.println("Not able to connect to the server notes database");
    . . .
  }
  . . .
catch (Exception e) {
  . . .
}

// This is in the portlet's doView() method  
/* The call to the XML JavaBean constructor specifies the file of interest
*  The JavaBean's access() method includes code to prepare for searching the file
*/
. . . 
// getRealPath() provides the fully qualified name of the XML file.
// In our test scenario, this file was stored within our portal project
// because we wanted to ship the application and most of its data as 
// a single unit.     
XMLAccess xml = new XMLAccess
  (getPortletConfig().getContext().getRealPath("Data/PoliceReports.xml"));
xml.access(incidents);
. . . 
// This is in the XML JavaBean's access() method
// Shown below is only the code to prepare for search of the file
. . . 
// Create a DOM parser
DOMParser parser= new DOMParser();
try{
  // Parse the file and get it as a tree
  parser.parse(fileURL);
  Document doc = parser.getDocument();
  // Establish elements of the tree
  Node reports = doc.getDocumentElement();
  NodeList reportList = reports.getChildNodes();
  NodeList reportElemList;
  . . .
}
catch (Exception e) {
  . . .
}

//try to execute the SQL query
if(!((Query1)dataBean).executeQuery()){	
  System.out.println("Not able to execute the query");
  log.error("cotton:SQLPortlet: Could not execute the sql query");
}

// This code is in our DB2 II JavaBean
. . .
public boolean executeQuery( . . .) {
. . .
if(!cust_id.equals(""))
// ***********************************************************************************************
// Execute the following query to get all reports, claims and customer info based on policy#
// ***********************************************************************************************
  return super.executeQuery("
    SELECT
       DEMO.CUSTOMER_DB2.CUSTOMER_ID, DEMO.CUSTOMER_DB2.FIRST_NAME || ' ' ||
       DEMO.CUSTOMER_DB2.LAST_NAME, DEMO.CUSTOMER_DB2.ADDRESS, DEMO.CUSTOMER_DB2.CITY,
       DEMO.CUSTOMER_DB2.STATE, DEMO.CUSTOMER_DB2.POLICY_TYPE, DEMO.CUSTOMER_DB2.POLICY_PREMIUM,
       DEMO.CLAIMS_DOMINO.ODATE, DEMO.CLAIMS_DOMINO.CDATE, DEMO.CLAIMS_DOMINO.INCIDENT_ID,
       DEMO.CLAIMS_DOMINO.DOC_ID,
       DEMO.REPORTS_XML.OFFICERNAME, DEMO.REPORTS_XML.INCIDENTDESC
    FROM
       DEMO.CLAIMS_DOMINO, DEMO.REPORTS_XML,DEMO.CUSTOMER_DB2
    WHERE
       DEMO.CLAIMS_DOMINO.INCIDENT_ID = DEMO.REPORTS_XML.INCIDENTID AND
       DEMO.CUSTOMER_DB2.CUSTOMER_ID = INTEGER(DEMO.CLAIMS_DOMINO.CUSTOMER_ID) AND
       (DEMO.CLAIMS_DOMINO.INCIDENT_TYPE = 'Fault' OR DEMO.CLAIMS_DOMINO.INCIDENT_TYPE = 'No Fault') AND
       DEMO.CUSTOMER_DB2.CUSTOMER_ID=" + cust_id
    );
else return false;
. . .
public String getCustID(){
  try{
    return rs_c.getString(1);
  }catch(SQLException e){ . . . }
}
public String getName(){
  try{
    return rs_c.getString(2);
  }catch(SQLException e){. . . }
}
. . .
}
// This code is included in another class (an abstract class used by our JavaBean).
// After a SQL query string is defined, this method is called to execute it.
protected boolean executeQuery(String sql){
  try{
    stmt_c = con.prepareStatement(sql,ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_READ_ONLY);
    rs_c = stmt_c.executeQuery();
    }
  catch(SQLException e){
       . . .
  }
       . . .
}

//Execute the query without ii:
// Create an Hashtable to store the results
Hashtable incidents = new Hashtable();
// Connect to DB2 UDB, execute the query and get the result
// using the DB2 access class		
. . . 
			
db2.setCust_id(((Query1)dataBean).getCust_id());
//try to execute the queries against each data source
if(!db2.executeQuery()){	
  System.out.println("Not able to execute the query");
  log.error("cotton:SQLPortlet: Could not execute the sql query");
}
db2.getNextResult();
String CUSTOMER_ID = db2.getCustID();
String CUSTOMER_NAME = db2.getName();
String ADDRESS = db2.getAddr(); 
String CITY = db2.getCity();
String STATE = db2.getState();
String POLICY_TYPE = db2.getType();
String POLICY_PREMIUM = db2.getCost();
			
// Get the results from Notes and store all the matching
// incidents from notes into the hashtable 
NotesAccess notes = new NotesAccess
  (getPortletConfig().getContext().getRealPath("Data/Claims2.nsf"));
notes.access(CUSTOMER_ID,incidents);
// Include the XML data in the hashtable
XMLAccess xml = new XMLAccess
  (getPortletConfig().getContext().getRealPath("Data/PoliceReports.xml"));
xml.access(incidents);
// Put the result in a bean to pass it to the jsp page ...
JoinBean join = new JoinBean
  (incidents.values(),CUSTOMER_ID,CUSTOMER_NAME,ADDRESS,CITY,STATE,POLICY_TYPE,POLICY_PREMIUM);
        
		s.setAttribute(dataBeanName,join);
. . . 
      

// This code is in the DB2 UDB JavaBean
. . .
private String sql = "
  SELECT DEMO.CUSTOMER_DB2.CUSTOMER_ID,DEMO.CUSTOMER_DB2.FIRST_NAME || 
    ' ' || DEMO.CUSTOMER_DB2.LAST_NAME, DEMO.CUSTOMER_DB2.ADDRESS, 
    DEMO.CUSTOMER_DB2.CITY, DEMO.CUSTOMER_DB2.STATE, DEMO.CUSTOMER_DB2.POLICY_TYPE, 
    DEMO.CUSTOMER_DB2.POLICY_PREMIUM 
  FROM 
    DEMO.CUSTOMER_DB2 
  WHERE DEMO.CUSTOMER_DB2.CUSTOMER_ID =";
. . . 
/**
 * executes the query
 * @return boolean
 */	
public boolean executeQuery(){
  return super.executeQuery(sql + cust_id);
}		
	
public String getCustID(){
  try{
    return rs_c.getString(1);
  }catch(SQLException e){return "";}
}
public String getName(){
  try{
    return rs_c.getString(2);
  }catch(SQLException e){return "";}
}
. . . 
// This code is included in another class (an abstract class used by our JavaBean).
// After a SQL query string is defined, this method is called to execute it.
protected boolean executeQuery(String sql){
  try{
    stmt_c = con.prepareStatement(sql,ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_READ_ONLY);
    rs_c = stmt_c.executeQuery();
    }
  catch(SQLException e){
       . . .
  }
       . . .
}

// establish a connection to the database 
. . .
Item it;
DateTime dt=null;
// Get a view (List of the documents)
View v = claims.getView("By Policy");
			
// Take all the documents one by one to check the  Customer_ID
Document doc = v.getFirstDocument();
while(doc!=null){
  if(doc.isValid()){   // if:  level 1
    
    // Check if the doc has a matching cust id, 
    // get the values needed if it is the case
    if(doc.hasItem("Customer_ID")){     // if:  level 2
      
      if(doc.getFirstItem("Customer_ID").getValueString().equals(cust_id)){  // if:  level 3
        Incident incident = new Incident(doc.getFirstItem("Incident_ID")getValueString());
							
        if(doc.hasItem("ODate")){
          it = doc.getFirstItem("ODate");			
          if(it!=null) { dt = it.getDateTimeValue();  }
          if(dt instanceof DateTime) { incident.setODate(dt.toString()); }
        }
        
        if(doc.hasItem("CDate")){
          it=doc.getFirstItem("CDate");
          if(it!=null){
             dt = it.getDateTimeValue();
             if(dt instanceof DateTime) incident.setCDate(dt.toString());
          }
        }
        
        incident.setDoc_id("");
        incidents.put(incident.getIncident_id(),incident);
    
      }  // end if level 3 
    }  // end if level 2
					
  }   // end if level 1
doc = v.getNextDocument(doc);
}  // end while loop
. . . 
        

. . .
// Walk the DOM tree to search for data of interest
for (int i=0;i<reportList.getLength();i++){
   Node report = reportList.item(i);
   reportElemList = report.getChildNodes();
  // Go through each report from the tree
  for (int j=0;j<reportElemList.getLength();j++){
     Node elem = reportElemList.item(j);
     // If we have an incidentID TAG
     if(elem.getNodeName().equals("IncidentID")){
        // Check the hashtable to see if we have to add it
        if(ht.containsKey(elem.getFirstChild().getNodeValue())){
           Incident inc = (Incident) ht.get(elem.getFirstChild().getNodeValue());
           // Copy the data
           for (int k=0;k<reportElemList.getLength();k++){
             Node elem2 = reportElemList.item(k);
             if(elem2.getNodeName().equals("OfficerName"))
                inc.setOfficername(elem2.getFirstChild().getNodeValue());
             if(elem2.getNodeName().equals("IncidentDesc"))
        
								                
             inc.setIncidentdesc(elem2.getFirstChild().getNodeValue());
            }  // end for loop
        }   // end inner if
    }  // end outer if
  }  // end inner for loop
}  // end outer for loop
      

. . .
**
 * @author IBM
 *
 * This bean contains the data stored as the same format
 * as Query1.class. This bean is used in the native case.
 * It gives the capacity to send this bean instead of
 * the other one to the jsp page
 */
public class JoinBean implements ShowCustBean{
	String CUSTOMER_ID="";
	String CUSTOMER_NAME="";
	String ADDRESS=""; 
	String CITY="";
	String STATE="";
	String POLICY_TYPE="";
	String POLICY_PREMIUM="";
	Iterator i;
	Incident inc = null;
	Collection c = null;
}
/* Method JoinBean.constructor to instantiate a bean instance, 
* in which all necessary customer information is stored.
* @param c: hashtable, which contains Incident instances. 
* For each incident of the customer, one incident instance is stored in the hashtable
*/
public JoinBean(Collection c,String CUSTOMER_ID,
  String CUSTOMER_NAME,String ADDRESS,
  String CITY,String STATE,String POLICY_TYPE,
  String POLICY_PREMIUM){
    this.CUSTOMER_ID = CUSTOMER_ID;
    this.CUSTOMER_NAME = CUSTOMER_NAME;
    this.ADDRESS = ADDRESS; 
    this.CITY = CITY;
    this.STATE = STATE;
    this.POLICY_TYPE = POLICY_TYPE;
    this.POLICY_PREMIUM = POLICY_PREMIUM;
    this.c = c;
    this.i = c.iterator();	
}
. . .