org.qbroker.net

Class DBConnector

java.lang.Object

org.qbroker.net.DBConnector

All Implemented Interfaces:

Connector

Direct Known Subclasses:

JDBCMessenger

public class DBConnector
extends java.lang.Object
implements Connector

DBConnector connects to a database specified by URI and initializes the operations of select and update, etc, for SQL statements.

Author:

yannanlu@yahoo.com

Field Summary

Fields

Modifier and Type	Field and Description
protected int	resultType
protected int	sqlExecTimeout
protected java.lang.String	uri

Constructor Summary

Constructors

Constructor and Description
DBConnector(java.util.Map props)

Method Summary

Modifier and Type	Method and Description
void	close()
void	commit()
int	copyStream(int len, java.io.InputStream in, java.lang.String sqlStr) It assumes the SQL statement updating on a single column of BLOB.
int	copyStream(java.lang.String sqlStr, java.io.OutputStream out) It assumes the SQL statement querying on a single column of BLOB.
int	executeQuery(java.lang.String sqlStr) returns the number of rows changed for update, insert and delete only
java.lang.String	getURI()
boolean	isConnected()
java.lang.StringBuffer	list(java.lang.String table, int[] rc) returns a string buffer with info on all columns for a specific table
java.util.List<java.lang.Object>	list(java.lang.String pattern, java.lang.String[] types) returns the list of all objects for the specific types
java.lang.StringBuffer	list(java.lang.String pattern, java.lang.String[] types, int[] rc) returns a string buffer with info on all objects for the types
static void	main(java.lang.String[] args)
java.sql.PreparedStatement	prepareStatement(java.lang.String str) returns the prepared statement
java.lang.String	reconnect() reconnects to the DB and returns null on success or err msg otherwise
void	rollback()
java.lang.StringBuffer	select(java.lang.String sqlStr, int[] rc) returns selected result in string buffer for the query
void	setAutoCommit(boolean ac)

Methods inherited from class java.lang.Object

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

Field Detail

uri

protected java.lang.String uri

resultType

protected int resultType

sqlExecTimeout

protected int sqlExecTimeout

Constructor Detail

DBConnector

public DBConnector(java.util.Map props)

Method Detail

copyStream

public int copyStream(java.lang.String sqlStr,
                      java.io.OutputStream out)
               throws java.io.IOException

It assumes the SQL statement querying on a single column of BLOB. It executes the query and copies the bytes stream into the given out. Upon success, it returns the number of bytes copied.

Throws:

java.io.IOException

copyStream

public int copyStream(int len,
                      java.io.InputStream in,
                      java.lang.String sqlStr)
               throws java.io.IOException

It assumes the SQL statement updating on a single column of BLOB. It executes the query and copies the bytes stream from the given in. Upon success, it returns the number of bytes copied.

Throws:

java.io.IOException

select

public java.lang.StringBuffer select(java.lang.String sqlStr,
                                     int[] rc)
                              throws java.sql.SQLException

returns selected result in string buffer for the query

Throws:

java.sql.SQLException

executeQuery

public int executeQuery(java.lang.String sqlStr)
                 throws java.sql.SQLException

returns the number of rows changed for update, insert and delete only

Throws:

java.sql.SQLException

list

public java.lang.StringBuffer list(java.lang.String pattern,
                                   java.lang.String[] types,
                                   int[] rc)
                            throws java.sql.SQLException

returns a string buffer with info on all objects for the types

Throws:

java.sql.SQLException

list

public java.util.List<java.lang.Object> list(java.lang.String pattern,
                                             java.lang.String[] types)
                                      throws java.sql.SQLException

returns the list of all objects for the specific types

Throws:

java.sql.SQLException

list

public java.lang.StringBuffer list(java.lang.String table,
                                   int[] rc)
                            throws java.sql.SQLException

returns a string buffer with info on all columns for a specific table

Throws:

java.sql.SQLException

getURI

public java.lang.String getURI()

Specified by:

getURI in interface Connector

isConnected

public boolean isConnected()

Specified by:

isConnected in interface Connector

reconnect

public java.lang.String reconnect()

reconnects to the DB and returns null on success or err msg otherwise

Specified by:

reconnect in interface Connector

commit

public void commit()
            throws java.sql.SQLException

Throws:

java.sql.SQLException

rollback

public void rollback()
              throws java.sql.SQLException

Throws:

java.sql.SQLException

setAutoCommit

public void setAutoCommit(boolean ac)
                   throws java.sql.SQLException

Throws:

java.sql.SQLException

prepareStatement

public java.sql.PreparedStatement prepareStatement(java.lang.String str)
                                            throws java.sql.SQLException

returns the prepared statement

Throws:

java.sql.SQLException

close

public void close()

Specified by:

close in interface Connector

main

public static void main(java.lang.String[] args)