Read from DB

import lrapi.lr;
import java.io.File;
import java.util.Date;
import org.jdom.input.SAXBuilder;
import org.jdom.output.XMLOutputter;
import java.sql.*;
import java.util.*;
import java.math.*;
import java.text.*;


public class Actions
{

    SqlReader Sqlr_orch;


    private static String CF1 = "com.clarify.jms.bridge.connectionFactory.boss.LBCF";
    private static String RouterInQ = "com.clarify.jms.boss.router.in";
    private static int sleepTime = 100;

    String OrderId = null;
    public int init()
    {
try
{
   Sqlr_orch = new SqlReader(lr.eval_string("jdbc:oracle:thin:@localhost:1522:SVTORC"), "sax", "sax");
   System.out.print("**** ");
}
catch(Exception e)
{
   System.out.print("in Exp");
   e.printStackTrace();
   lr.exit(lr.EXIT_VUSER, lr.FAIL);
   return 1;
}

return 0;
    }


    public int action()
    {
String sqlResOrch [] = null;
OrderId = lr.eval_string("<OrderId>");
System.out.print("OrderId " + OrderId);
try{
sqlResOrch = Sqlr_orch.RunQuery("SELECT C.OSS_CMP_ORDER_ID "+
"FROM TABLE_ORDER_ACTION oa , TABLE_CONTRACT c, TABLE_ORDER_LINE ol "+
"WHERE c.objid = oa.ORDER_ACTION2CONTRACT and ol.order_line2order_action=oa.objid "+
"and oa.X_FAMILY = 'Mobile' "+
"and c.STATUS = 'Complete' "+
"and C.OSS_CMP_ORDER_ID like ? "+
"and c.START_DATE> to_char('+<date>+') "+
"order by c.START_DATE desc",
"C.OSS_CMP_ORDER_ID",
OrderId);


   System.out.print(" " + sqlResOrch);
   System.out.print("\n" );
}
catch (Exception e)
{
   System.out.print("Error: " + e.getMessage());
}
return 0;
}

    public int end()
    {
return 0;
    }

}
-----------
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;
import java.sql.ResultSet;
import java.sql.PreparedStatement;
import java.sql.SQLException;


public class SqlReader
{
    private Connection con;
    private PreparedStatement ps;
    protected String DbName;
    protected String DbUser;
    protected String DbPass;

    public SqlReader(String DbName, String DbUser, String DbPass) throws Exception
    {
this.DbName = DbName;
this.DbUser = DbUser;
this.DbPass = DbPass;

connect();
    }

    public Connection connect()throws Exception
    {
try
{
   System.out.println("conecting DB..."+DbUser+","+DbPass+"@"+DbName);
   DriverManager.registerDriver(new oracle.jdbc.driver.OracleDriver());
   con = DriverManager.getConnection(DbName,DbUser,DbPass);
   System.out.println("returning con");
   return con;
}
catch (SQLException e)
{
   throw new Exception("Error init sql reader" + e.getMessage(), e);
}
    }

   
    public String[] RunQuery(String str_query, String FieldSelector, String BindParameters)
   throws Exception
    {

System.out.print("str_query" + str_query);
System.out.print("FieldSelector " + FieldSelector);
System.out.print("BindParameters " + BindParameters);


String[] results = new String[100];
String res = null;
        String [] temp = null;
temp = BindParameters.split(";");
String timerecv = null;

try
{
   ResultSet rs = null;
   ps = con.prepareStatement(str_query,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
   ps.setString(1, BindParameters);
   rs = ps.executeQuery();


while (rs.next()) {
res = rs.getString(1);
results[0] = res;

}


}
catch (SQLException e)
{
   throw new Exception("Error in sql run query" + e.getMessage(), e);
}

  ps.close();
return results;

    }

    public void close() throws Exception
    {
try
{
   con.close();
}
catch (SQLException e)
{
   throw new Exception("Error closing sql connection : " + e.getMessage(),e);
}
    }
}
--------