cgl.hpsearch.engine.URIBindings
Class DBReadHandler

java.lang.Object
  cgl.hpsearch.engine.URIBindings.DBReadHandler

All Implemented Interfaces:

SystemConstants

public class DBReadHandler

extends Object

implements SystemConstants

Field Summary

Fields inherited from interface cgl.hpsearch.common.SystemConstants

ABANDON_HANDLER, ABANDONED, BROKER_HOST, BROKER_PORT, BUF_SIZE, EOT, EXCEPTION, FAILURE, FILESEPARTOR, FLOW_LOGGING_MANAGER, FLOW_MANAGER, HPSEARCH_CONFIG, HPSEARCH_HOME, HPSEARCH_SHELL, HPSEARCH_WS, MARKER, NB_HOME, NB_PERFORMANCE_DATA_TOPIC, OS_TYPE, OS_UNIX, OS_WIN, PORT, PROTOCOL, READY, RESUME, RUNNING, SCRIPT_ARGS, SCRIPT_PATH, SHELLWS_PORT, START_HANDLER, STREAM_MARKER_DATA, STREAM_MARKER_EOF, STX, SUCCESS, SUSPEND, TASK_DEFINED, TASK_SCHEDULER_ENGINE, TASKSCHEDULER_AUTO_CONNECT_COMM_LINK, TASKSCHEDULER_ENGINE_COMM_LINK, THREAD_SLEEP_INTERVAL, UNKNOWN, WAITING, WSCONTEXT_RESULT_BIN, WSCONTEXT_SERVICE

Constructor Summary

DBReadHandler()

Method Summary

void	close()
void	Connect(String jdbcURI) Connects to the database by specifying a URI.
void	Connect(String host, int port, String tableName, String username, String password) Try and connect to the specified database.
ResultSet	executeQuery(String query, int fetchSize)
void	executeToStream(String query)
String	executeToString(String query)
InputStream	getInputStream() Get the QueryHandler's input stream.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DBReadHandler

public DBReadHandler()

Method Detail

Connect

public void Connect(String jdbcURI)

Connects to the database by specifying a URI. For example
jdbc://156.56.104.155:9761/loanList?username=uname&password=pwd

Parameters:

jdbcURI -

Connect

public void Connect(String host,
                    int port,
                    String tableName,
                    String username,
                    String password)

Try and connect to the specified database.

Parameters:

host -

port -

tableName -

username -

password -

close

public void close()

executeToStream

public void executeToStream(String query)

executeToString

public String executeToString(String query)

executeQuery

public ResultSet executeQuery(String query,
                              int fetchSize)

getInputStream

public InputStream getInputStream()

Get the QueryHandler's input stream.

Returns:

The socket's input stream, Null on error