WebSphere JCA Adapter 开发入门

                
package com.ibm.eis.mock; 

public class MockEIS {

  String operation = "+";
    
  public MockEIS(){
       
  }
  /**
   * @param operation The operation to set.
   */
  public void setOperation(String operation) {
    this.operation = operation;
  }
  
  /**
   * Calculate the result.
   * @param x
   * @param y
   * @return
   */
  public float calculate(float x, float y){
    float result = Float.NaN;
    if(operation.equals("+")){
      result = x + y;
    }else if(operation.equals("-")){
      result = x - y;
    }else if(operation.equals("*")){
      result = x * y;
    }else if(operation.equals("/")){
      result = x / y;
    }
    return result;
  }
}
      

      <display-name>IBM Mock Adapter for QA</display-name>
      <vendor-name>IBM CSDL AIA</vendor-name>
      <eis-type>Mock EIS</eis-type>
      <resourceadapter-version>1.0.0</resourceadapter-version>

       <resourceadapter>
          <resourceadapter-class>com.ibm.j2ca.mock.MockAdapter</resourceadapter-class>
          ......
       </resourceadapter>

                
package com.ibm.j2ca.mock;

import javax.resource.ResourceException;
import com.ibm.j2ca.base.WBIResourceAdapter;
import com.ibm.j2ca.base.WBIResourceAdapterMetadata;

public class MockAdapter extends WBIResourceAdapter {
  public MockAdapter() 
    super();
  }
  public WBIResourceAdapterMetadata getResourceAdapterMetadata()
      throws ResourceException {
    return new WBIResourceAdapterMetadata(
            "IBM Mock Adapter", "IBM CSDL ", "1.0.0", false);
  }
}

<outbound-resourceadapter>
    <connection-definition>
        <managedconnectionfactory-class>
             com.ibm.j2ca.mock.MockManagedConnectionFactory
        </managedconnectionfactory-class>
        <config-property>
            <config-property-name>Operation</config-property-name>
            <config-property-type>java.lang.String</config-property-type>
            <config-property-value></config-property-value>
        </config-property>
        <connectionfactory-interface>
            javax.resource.cci.ConnectionFactory
        </connectionfactory-interface>
        <connectionfactory-impl-class>
            com.ibm.j2ca.mock.MockConnectionFactory
        </connectionfactory-impl-class>
        <connection-interface>javax.resource.cci.Connection</connection-interface>
        <connection-impl-class>com.ibm.j2ca.mock.MockConnection</connection-impl-class>
    </connection-definition>
    <transaction-support>NoTransaction</transaction-support>
    <reauthentication-support>false</reauthentication-support>
</outbound-resourceadapter>

                
package com.ibm.j2ca.mock; 

import javax.resource.ResourceException;
import javax.resource.cci.Interaction;
import com.ibm.j2ca.base.WBIConnection;
import com.ibm.j2ca.base.WBIManagedConnection;

public class MockConnection extends WBIConnection {
  public MockConnection(WBIManagedConnection mc) throws ResourceException {
    super(mc);
  }

  public Interaction createInteraction() throws ResourceException {
    return new MockInteraction(this);
  }
}

                
package com.ibm.j2ca.mock;

import javax.resource.ResourceException;
import javax.resource.spi.ManagedConnectionMetaData;
import javax.resource.spi.security.PasswordCredential;
import javax.security.auth.Subject;

import com.ibm.eis.mock.MockEIS;
import com.ibm.j2ca.base.WBIConnectionRequestInfo;
import com.ibm.j2ca.base.WBIManagedConnection;
import com.ibm.j2ca.base.WBIManagedConnectionFactory;
import com.ibm.j2ca.base.WBIManagedConnectionMetaData;

/**
 * @author Donny
 *
 */
public class MockManagedConnection extends WBIManagedConnection {
  
  private MockEIS mockEIS ;

  public MockManagedConnection(WBIManagedConnectionFactory factory,
        Subject sub, WBIConnectionRequestInfo request,MockEIS eis)
        throws ResourceException {
    super(factory, sub, request);
    mockEIS = eis;
  }

  public ManagedConnectionMetaData getMetaData() throws ResourceException {
    return new WBIManagedConnectionMetaData("Mock EIS",
          "1.0.0",10,super.getPasswordCredential().getUserName());
  }

  public Object getWBIConnection(PasswordCredential arg0, boolean arg1)
        throws ResourceException {
    return new MockConnection(this);
  }

  public void destroy() throws ResourceException {

  }
  public MockEIS getMockEIS() {
    return mockEIS;
  }  
}

                 
package com.ibm.j2ca.mock;

import javax.resource.ResourceException;
import javax.resource.spi.ConnectionManager;
import javax.resource.spi.ConnectionRequestInfo;
import javax.resource.spi.ManagedConnection;
import javax.security.auth.Subject;

import com.ibm.j2ca.base.WBIConnectionRequestInfo;
import com.ibm.j2ca.base.WBIManagedConnectionFactory;

public class MockManagedConnectionFactory extends WBIManagedConnectionFactory {
    private String operation = "+";
  public MockManagedConnectionFactory() {
    super();
  }

  public ManagedConnection createManagedConnection(Subject sub,
      ConnectionRequestInfo info) throws ResourceException {
    //“连接” Mock EIS，创建对MockManagedConnection 
    MockEIS eis = new MockEIS();
    eis.setOperation(this.operation);
    return new MockManagedConnection(this, sub, (WBIConnectionRequestInfo) info,eis);
  }
  
  public Object createConnectionFactory(ConnectionManager arg0)
      throws ResourceException {
    return new MockConnectionFactory(arg0,this);
  }
  public String getOperation(){
      return operation;
  }
  public void setOperation(String operation){
    this.operation = operation;
  }
}

                
package com.ibm.j2ca.mock;

import javax.resource.spi.ConnectionManager;
import com.ibm.j2ca.base.WBIConnectionFactory;
import com.ibm.j2ca.base.WBIManagedConnectionFactory;

public class MockConnectionFactory extends WBIConnectionFactory {
  public MockConnectionFactory(ConnectionManager cm,
       WBIManagedConnectionFactory factory){
    super(cm, factory);
  }
}

                
package com.ibm.j2ca.mock;

import javax.resource.ResourceException;
import javax.resource.cci.InteractionSpec;
import javax.resource.cci.Record;

import com.ibm.eis.mock.MockEIS;
import com.ibm.j2ca.base.AdapterBOUtil;
import com.ibm.j2ca.base.DataObjectRecord;
import com.ibm.j2ca.base.WBIConnection;
import com.ibm.j2ca.base.WBIInteraction;
import com.ibm.j2ca.base.WBIInteractionSpec;
import commonj.sdo.DataObject;

public class MockInteraction extends WBIInteraction {

  public MockInteraction(WBIConnection arg0) {
    super(arg0);
  }

  public Record execute(InteractionSpec ixSpec, Record record)
      throws ResourceException {
    if(!(ixSpec instanceof WBIInteractionSpec)){
      throw new ResourceException("Unknown InteractionSpec type!");
    }
    if(!(record instanceof DataObjectRecord)){
      throw new ResourceException("Invalid Record type!");
    }
    //1. 分析输入的BO，得到运算数
    DataObject bg = ((DataObjectRecord)record).getDataObject();
    DataObject mockBO = bg.getDataObject("MockBO");
    float x = mockBO.getFloat("X");
    float y = mockBO.getFloat("Y");
    //2. 通过相应的连接，得到Mock EIS服务，并计算结果
    MockManagedConnection mcon = (MockManagedConnection)(
        (WBIConnection)this.getConnection()).getManagedConnection();
    MockEIS eis = mcon.getMockEIS();
    float result = eis.calculate(x,y);
    
    //3. 创建输出Record
    DataObject outputBG = AdapterBOUtil.copyBusinessObject(bg);
    outputBG.getDataObject("MockBO").setFloat("Result",result);
    DataObjectRecord outputRecord = new DataObjectRecord();
    outputRecord.setDataObject(outputBG);
    outputRecord.setRecordName(record.getRecordName());
    return outputRecord;
  }
}

                
<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<HTML>
<HEAD>
<%@ page language="java" contentType="text/html; charset=UTF-8"
  pageEncoding="UTF-8"%>
<%@ page import="com.ibm.j2ca.base.*"%> 
<%@ page import="commonj.sdo.*"%> 
<%@ page import="javax.resource.cci.*"%>
<META http-equiv="Content-Type" content="text/html; charset=UTF-8">
<META name="GENERATOR" content="IBM Software Development Platform">
<TITLE>MockTest.jsp</TITLE>
</HEAD>
<BODY>
<%  
  try{
    //Step 1: 获取连接
    //  1.1: 通过JNDI查找ConnetionFactory
    javax.naming.InitialContext initCx = new javax.naming.InitialContext();
    String jndi = "Mock/Mock_Multi";
    ConnectionFactory cxf = (ConnectionFactory) initCx.lookup(jndi);
    
    //  1.2: 创建连接
    Connection connection = null ;
    connection = cxf.getConnection();

    //Step 2: 执行操作
    //  2.1: 创建Interaction
    Interaction interaction = null;
    interaction = connection.createInteraction();
    
    //  2.2: 准备InteractionSpec
    WBIInteractionSpec interactionSpec = new WBIInteractionSpec();
    //  2.3: 准备BO，必须以BG为包装器
    DataObject inputObject = null;
    inputObject = AdapterBOUtil
        .createDataObject(
            "http://MockTest",
            "MockBOBG");
    DataObject bo = inputObject.createDataObject("MockBO");
    bo.set("X", "1.01");
    bo.set("Y", "3.21");

    //  2.4: 准备Record
    DataObjectRecord inputRecord = new DataObjectRecord();
    inputRecord.setDataObject(inputObject);
    //  2.5: 调用执行方法
    Record outputRecord = interaction.execute(interactionSpec,
        inputRecord);
    //  2.6: 获取返回值并输出
    DataObject outputObject = ((DataObjectRecord) outputRecord)
        .getDataObject();
    out.println(AdapterBOUtil.serializeDataObject(outputObject));
    //Step 3: 关闭连接
    connection.close();
  } catch (Exception e) {
    e.printStackTrace();
  }
%></BODY>
</HTML>