public class JDBCConnection extends Object
Modifier and Type | Class and Description |
---|---|
protected class |
JDBCConnection.ExecuteOperationThread |
protected class |
JDBCConnection.JDBCPSResultSet |
protected class |
JDBCConnection.JDBCResultSet |
protected static class |
JDBCConnection.NextResultRowThread |
protected class |
JDBCConnection.PreparedStatementQueryThread |
protected static class |
JDBCConnection.RDynamicRow
Dynamic result row implementation
|
protected class |
JDBCConnection.StatementQueryThread |
protected class |
JDBCConnection.TestConnectionThread |
Modifier and Type | Field and Description |
---|---|
static String |
_rcsid |
protected String |
driverString |
protected String |
jdbcProvider |
protected String |
password |
protected boolean |
useName |
protected String |
userName |
Constructor and Description |
---|
JDBCConnection(String jdbcProvider,
boolean useName,
String host,
String databaseName,
String rawDriverString,
String userName,
String password)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
protected static void |
cleanupDatabaseObject(Object x)
Call this method on every parameter or result object, when we're done with it, if it's possible that the object is a BLOB
or CLOB.
|
protected static void |
cleanupParameters(ArrayList data)
Clean up parameters after query has been triggered.
|
protected static void |
closePS(PreparedStatement ps) |
protected static void |
closeResultset(ResultSet rs) |
protected static void |
closeStmt(Statement stmt) |
protected static void |
discardDatabaseObject(Object x)
Permanently discard database object.
|
protected static IResultSet |
execute(Connection connection,
String query,
ArrayList params,
boolean bResults,
int maxResults,
boolean useName)
Run a query.
|
void |
executeOperation(String query,
ArrayList params)
Execute operation.
|
IDynamicResultSet |
executeUncachedQuery(String query,
ArrayList params,
int maxResults)
Execute query.
|
protected static int |
findColumn(ResultSet rs,
String name) |
protected static Blob |
getBLOB(ResultSet rs,
int col) |
protected static Clob |
getCLOB(ResultSet rs,
int col) |
protected static IResultSet |
getData(ResultSet rs,
int maxResults,
boolean useName) |
protected static Object |
getObject(ResultSet rs,
ResultSetMetaData rsmd,
int col) |
protected static void |
handleIOException(IOException e,
String context) |
protected static boolean |
isBinaryData(ResultSetMetaData rsmd,
int col) |
protected static boolean |
isBLOB(ResultSetMetaData rsmd,
int col) |
protected static boolean |
isCLOB(ResultSetMetaData rsmd,
int col) |
protected static void |
loadPS(PreparedStatement ps,
ArrayList data) |
static String |
readAsString(Object o)
Read object as a string
|
protected static String[] |
readColumnNames(ResultSetMetaData rsmd,
boolean useName) |
protected static IDynamicResultRow |
readNextResultRow(ResultSet rs,
ResultSetMetaData rsmd,
String[] resultCols) |
protected static IDynamicResultRow |
readNextResultRowViaThread(ResultSet rs,
ResultSetMetaData rsmd,
String[] resultCols) |
protected static IDynamicResultRow |
readResultRow(ResultSet rs,
ResultSetMetaData rsmd,
String[] resultCols)
Read the current row from the resultset
|
void |
testConnection()
Test connection.
|
public static final String _rcsid
protected String jdbcProvider
protected boolean useName
protected String driverString
protected String userName
protected String password
public JDBCConnection(String jdbcProvider, boolean useName, String host, String databaseName, String rawDriverString, String userName, String password) throws ManifoldCFException
ManifoldCFException
protected static IDynamicResultRow readNextResultRowViaThread(ResultSet rs, ResultSetMetaData rsmd, String[] resultCols) throws ManifoldCFException, ServiceInterruption
protected static IDynamicResultRow readNextResultRow(ResultSet rs, ResultSetMetaData rsmd, String[] resultCols) throws ManifoldCFException, ServiceInterruption
protected static void closeResultset(ResultSet rs) throws ManifoldCFException, ServiceInterruption
protected static void closeStmt(Statement stmt) throws ManifoldCFException, ServiceInterruption
protected static void closePS(PreparedStatement ps) throws ManifoldCFException, ServiceInterruption
public void testConnection() throws ManifoldCFException, ServiceInterruption
public IDynamicResultSet executeUncachedQuery(String query, ArrayList params, int maxResults) throws ManifoldCFException, ServiceInterruption
public void executeOperation(String query, ArrayList params) throws ManifoldCFException, ServiceInterruption
public static String readAsString(Object o) throws ManifoldCFException
ManifoldCFException
protected static IResultSet execute(Connection connection, String query, ArrayList params, boolean bResults, int maxResults, boolean useName) throws ManifoldCFException, ServiceInterruption
query
- String the query stringmaxResults
- is the maximum number of results to load: -1 if allparams
- ArrayList if params !=null, use preparedStatementManifoldCFException
ServiceInterruption
protected static IDynamicResultRow readResultRow(ResultSet rs, ResultSetMetaData rsmd, String[] resultCols) throws ManifoldCFException, ServiceInterruption
protected static void handleIOException(IOException e, String context) throws ManifoldCFException
ManifoldCFException
protected static String[] readColumnNames(ResultSetMetaData rsmd, boolean useName) throws ManifoldCFException, ServiceInterruption
protected static IResultSet getData(ResultSet rs, int maxResults, boolean useName) throws ManifoldCFException, ServiceInterruption
protected static void loadPS(PreparedStatement ps, ArrayList data) throws SQLException, ManifoldCFException
SQLException
ManifoldCFException
protected static void discardDatabaseObject(Object x) throws ManifoldCFException
ManifoldCFException
protected static void cleanupDatabaseObject(Object x) throws ManifoldCFException
ManifoldCFException
protected static void cleanupParameters(ArrayList data) throws ManifoldCFException
ManifoldCFException
protected static int findColumn(ResultSet rs, String name) throws ManifoldCFException, ServiceInterruption
protected static Blob getBLOB(ResultSet rs, int col) throws ManifoldCFException, ServiceInterruption
protected static Clob getCLOB(ResultSet rs, int col) throws ManifoldCFException, ServiceInterruption
protected static boolean isBLOB(ResultSetMetaData rsmd, int col) throws ManifoldCFException, ServiceInterruption
protected static boolean isBinaryData(ResultSetMetaData rsmd, int col) throws ManifoldCFException, ServiceInterruption
protected static boolean isCLOB(ResultSetMetaData rsmd, int col) throws ManifoldCFException, ServiceInterruption
protected static Object getObject(ResultSet rs, ResultSetMetaData rsmd, int col) throws ManifoldCFException, ServiceInterruption