Deploy Java UDRs through Web services on Informix using Rational Application Developer

                
VPCLASS            jvp,num=1                         # Number of JVPs to start with

JVPJAVAHOME    /usr/informix/ids_10/extend/krakatoa/jre/      

JVPHOME        /usr/informix/ids_10/extend/krakatoa      # Krakatoa installation directory

JVPPROPFILE     /usr/informix/ids_10/extend/krakatoa/.jvpprops       # JVP  property file

JVPLOGFILE    /usr/informix/ids_10/jvp.log                  # JVP log file.

JDKVERSION        1.3                           # JDK version supported by this server

JVMTHREAD       native                          # Java VM thread type(green or native)

# The path to the JRE libraries relative to JVPJAVAHOME
JVPJAVALIB                      /lib/sparc/

# The JRE libraries to use for the Java VM
JVPJAVAVM                      hpi:server:verify:java:net:zip:jpeg

# use JVPARGS to change Java VM configuration
#To display jni call

#JVPARGS    -verbose:jni

# Classpath to use upon Java VM start-up (use _g version for debugging)
                                                     
JVPCLASSPATH   /usr/informix/ids_10/extend/krakatoa/krakatoa.jar:
                 /usr/informix/ids_10/extend/krakatoa/jdbc. jar                    

                

SQLACtions[] = {
    "BEGIN INSTALL
CREATE FUNCTION area (float) RETURNS float 
EXTERNAL NAME 'circle_jar:Circle.area(double)' LANGUAGE 
JAVA NOT VARIANT 
	END FUNCTION
     END INSTALL"
}

                

package customer;
import java.sql.*;
import com.informix.jdbc.IfmxUDTSQLInput;
import com.informix.jdbc.IfmxUDTSQLOutput;
public class Customer implements SQLData
{
	private String type = "customer";
	public int id=101;
	public int tbill;
	public int ebill;
	public int mbill;
	public int monyr;
    public String getSQLTypeName() { return type; }
    public void readSQL(SQLInput stream, String typeName)
        throws SQLException
    {
        IfmxUDTSQLInput in = (IfmxUDTSQLInput) stream;
        id = in.readInt();
        tbill= in.readInt();
        ebill= in.readInt();
        mbill= in.readInt();
        monyr= in.readInt();
    }
    public void writeSQL(SQLOutput stream) throws SQLException
    {
        IfmxUDTSQLOutput out = (IfmxUDTSQLOutput) stream;
        out.writeInt(id);
        out.writeInt(tbill);
        out.writeInt(ebill);
        out.writeInt(mbill);
        out.writeInt(monyr);    
    }
	public static Customer getCustomerDetail ( int cust_id) {
		Customer cust_obj=new Customer();
		try
		{
			Connection conn = null;
			try
			{
				Class.forName("com.informix.jdbc.IfxDriver");
			}
			catch (Exception e)
			{
				System.out.println("Error: failed to load Informix JDBC driver.");
				e.printStackTrace();
				return null;
			} 
			String url="jdbc:informix-sqli://XXX.XXX.XXX.com:7005/testdb:INFORMIXSERVER=ol_ids;
                                user=XXXXX;password=XXXXX";
			try
			{
				conn=DriverManager.getConnection(url);
			}
			catch(SQLException e)
			{
				System.out.println("ERROR: Failed to connect!");
				System.out.println("ERROR:" + e.getMessage());
				e.printStackTrace();
				return null;
			} 
			PreparedStatement pstmt=conn.prepareStatement("Select * from customer where id=?");
			pstmt.setInt(1,cust_id);
			ResultSet rs=pstmt.executeQuery();
			while(rs.next())
			{
				cust_obj.id =rs.getInt(1);
				cust_obj.tbill =rs.getInt(2);
				cust_obj.ebill =rs.getInt(3);
				cust_obj.mbill =rs.getInt(4);
				cust_obj.monyr =rs.getInt(5);
			}			
			rs.close();
			pstmt.close();
		}
		catch(SQLException e)
		{
			System.out.println("ERROR:" + e.getMessage());
			e.printStackTrace();
		}
		return cust_obj;  
	}
}

                

package customer;
import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.Types;
import java.util.Iterator;
import java.util.StringTokenizer;


public class CustSOA {
	public String getBillDetail(int cust_id)
	{
		Customer c_out=new Customer();
		/*===================Connection Block==========*/
		Connection conn = null;
		try
		{
			Class.forName("com.informix.jdbc.IfxDriver");
		}
		catch (Exception e)
		{
			System.out.println("Error: failed to load Informix JDBC driver.");
			e.printStackTrace();
			return null;
		} // End Driver Loading Block
		System.out.println("Informix JDBC driver loaded successfully.");
		// Connect to database
			String url="jdbc:informix-sqli://XXX.XXX.XXX.com:7005/testdb:
                         INFORMIXSERVER=ol_ids;user=XXXXX;password=XXXXX";
		//System.out.println("The url is:-"+url);
		try
		{
			conn=DriverManager.getConnection(url);
		}
		catch(SQLException e)
		{
			System.out.println("ERROR: Failed to connect!");
			System.out.println("ERROR:" + e.getMessage());
			e.printStackTrace();
			return null;
		}
		System.out.println("\nConnection established\n");
		/*=========End of connection Block=============*/
		
		/*============Call the UDR===================*/
        try {
        	 java.util.Map customtypemap = conn.getTypeMap();
             System.out.println("getTypeMap...ok");
             if (customtypemap == null)
             {
                 System.out.println("***ERROR: map is null!");
                 return null;
             }
            customtypemap.put("customer", Class.forName("customer.Customer")); 
        	String s = "select getCustomerDetail("+cust_id+") from customer";
            System.out.println(s);
            Statement stmt = conn.createStatement();
            ResultSet rs = stmt.executeQuery(s);
            if (rs.next())
                {
            		c_out=(Customer) rs.getObject(1);
                    System.out.println("   ID = " + c_out.id);
                    System.out.println("   ID = " + c_out.tbill);
                }
            rs.close();
            stmt.close();
        }
	    catch (Exception e) {
		// TODO Auto-generated catch block
		e.printStackTrace();
	    }
		return c_out.id+":"+c_out.tbill+":"+c_out.mbill+":"+c_out.ebill+":"+c_out.monyr;
	}
}

                

import java.sql.*;
import java.lang.reflect.*;
public class CreateCustUdt
{
    String url = null;
    Connection conn = null;
    public static void main ()
    {
        new CreateCustUdt();
    }
    CreateCustUdt() {
	  String url="jdbc:informix-sqli://XXX.XXX.XXX.com:7005/testdb:
                           INFORMIXSERVER=ol_ids;user=XXXXX;password=XXXXX";
        // --------------
        // Loading driver
        // --------------
        try {
            Class.forName("com.informix.jdbc.IfxDriver");
        }
        catch (java.lang.ClassNotFoundException e) {
            System.out.println("\n***ERROR: " + e.getMessage());
            e.printStackTrace();
            return;
        }
         try {
            conn = DriverManager.getConnection(url);
        }
        catch (SQLException e) {
            System.out.println("URL = '" + url + "'");
            System.out.println("\n***ERROR: " + e.getMessage());
            e.printStackTrace();
            return;
        }
        Method getCustomerDetailmethod = null;
        try {
            Class c = Class.forName("Customer");			
            getCustomerDetailmethod = c.getMethod("getCustomerDetail", new Class[]  
                                                             {Integer.TYPE });
        }
        catch (ClassNotFoundException e) {
            System.out.println("Cannot get Class: " + e.toString());
            return;
        }
        catch (NoSuchMethodException e) {
            System.out.println("Cannot get Method: " + e.toString());
            return;
        }
        UDTMetaData mdata = null;
        try {
            System.out.print("Setting mdata...");
            mdata = new UDTMetaData();
            mdata.setSQLName("Customer");
            mdata.setLength(24);
            mdata.setAlignment(UDTMetaData.EIGHT_BYTE);
            mdata.setUDR(getCustomerDetailmethod, "getCustomerDetail");
            mdata.setJarFileSQLName("Customer_jar");
            System.out.println("ok");
        }
        catch (SQLException e) {
            System.out.println("\n***ERROR: " + e.getMessage());
            return;
        }
        UDTManager udtmgr = null;
        try {
            udtmgr = new UDTManager(conn);   
            String jarfilename = udtmgr.createJar(mdata,
                new String[] {"Customer.class"}); // jarfilename = Customer.jar
            udtmgr.setJarTmpPath("/tmp");
            udtmgr.createUDT(mdata,
            "C:\\eclipse\\CUST_TEST\\" + jarfilename, "Customer", 0);
            System.out.println("UDT/UDR Created");
            }
        catch (SQLException e)
            {
            System.out.println("\n***ERROR: " + e.getMessage());
            return;
            }
        System.out.println();
    }
    private void executeUpdate(String s)
    {
        try
            {
            Statement stmt = conn.createStatement();
            stmt.executeUpdate(s);
            stmt.close();
            }
        catch (SQLException e)
            {
            	e.printStackTrace();
            	return;
            }
    }   
}

                
<HTML>
<HEAD>
<TITLE>Customer Detail</TITLE>
</HEAD>
<BODY>
<H1>Inputs</H1>
<FORM METHOD="POST" ACTION="CustSOAResult.jsp">
<INPUT TYPE="HIDDEN" NAME="method" VALUE="18">
<TABLE>
<TR>
<TD COLSPAN="1" ALIGN="LEFT">Enter Customer ID:</TD>
<TD ALIGN="left"><INPUT TYPE="TEXT" NAME="cust_id" SIZE=20></TD>
</TR>
</TABLE>
<BR>
<INPUT TYPE="SUBMIT" VALUE="Invoke">
<INPUT TYPE="RESET" VALUE="Clear">
</FORM>
</BODY>
</HTML>

                
<HTML>
<HEAD> <TITLE>Result</TITLE> </HEAD>
<BODY>
<H1>Result</H1>
<jsp:useBean id="sampleCustSOAProxyid" scope="session" class="customer.CustSOAProxy" />
    <%  String p_id=  request.getParameter("cust_id");
  int p_idTemp  = Integer.parseInt(p_id);
  java.lang.String ret_cust = sampleCustSOAProxyid.getBillDetail(p_idTemp);
if(ret_cust == null)
{    %>
<%=ret_cust%>
<% 
  } else {
String tempResultreturn = webserviceutils.com.ibm.etools.webservice.util.JspUtils.markup
     (String.valueOf(ret_cust));
  %>
        <% StringTokenizer st=new StringTokenizer(tempResultreturn,":");%>
		<b> 	<TABLE>
        	 <tr>
        		<td> Customer ID </td>
		<td> <%= st.nextToken() %> </td>
           	</tr>
	<tr>
            	<td> Telephone Bill </td>
		<td>  	<%= st.nextToken() %> </td>
	</tr>
	<tr>
        		<td> Elect Bill </td>
		<td> <%= st.nextToken() %> </td>
	</tr>
	<tr>
            	<td> Mobile Phone Bill </td>
		<td> <%= st.nextToken() %> </td>
	</tr>
	<tr>
            	<td> Year & Month </td>
		<td> <%= st.nextToken() %> </td>
	</tr>
		</TABLE>   </b>
        <% } %>
</BODY>
</HTML>