org.objectweb.cjdbc.driver.Connection Class Reference

Collaboration diagram for org.objectweb.cjdbc.driver.Connection:

[legend]List of all members.

Public Member Functions
	Connection ()
	Connection (Driver driver, Socket socket, CJDBCInputStream in, CJDBCOutputStream out, String url, String userName, String password, boolean sqlSkeletonNeeded, AbstractBlobFilter filter)
String	getURL ()
String	getUserName ()
String	getPassword ()
String	getConnectedController ()
void	clearWarnings () throws SQLException
void	close () throws SQLException
void	commit () throws SQLException
java.sql.Statement	createStatement () throws SQLException
java.sql.Statement	createStatement (int resultSetType, int resultSetConcurrency) throws SQLException
boolean	getAutoCommit () throws SQLException
java.sql.DatabaseMetaData	getMetaData () throws SQLException
String	getCatalog () throws SQLException
ResultSet	getCatalogs () throws SQLException
int	getTransactionIsolation () throws SQLException
java.util.Map	getTypeMap () throws SQLException
SQLWarning	getWarnings () throws SQLException
boolean	isClosed () throws SQLException
boolean	isReadOnly () throws SQLException
String	nativeSQL (String query) throws SQLException
java.sql.CallableStatement	prepareCall (String sql) throws SQLException
java.sql.CallableStatement	prepareCall (String sql, int resultSetType, int resultSetConcurrency) throws SQLException
java.sql.PreparedStatement	prepareStatement (String sql) throws SQLException
java.sql.PreparedStatement	prepareStatement (String sql, int resultSetType, int resultSetConcurrency) throws SQLException
void	rollback () throws SQLException
void	setAutoCommit (boolean autoCommit) throws SQLException
void	setCatalog (String catalog) throws SQLException
void	setReadOnly (boolean readOnly) throws SQLException
void	setTransactionIsolation (int level) throws SQLException
void	setTypeMap (java.util.Map map) throws SQLException
ResultSet	execReadStoredProcedure (StoredProcedure proc) throws SQLException
Object	getStaticMetadata (String key) throws SQLException
String	getControllerVersionNumber () throws SQLException
void	setHoldability (int holdability) throws SQLException
int	getHoldability () throws SQLException
Savepoint	setSavepoint () throws SQLException
Savepoint	setSavepoint (String name) throws SQLException
void	rollback (Savepoint savepoint) throws SQLException
void	releaseSavepoint (Savepoint savepoint) throws SQLException
java.sql.Statement	createStatement (int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException
java.sql.PreparedStatement	prepareStatement (String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException
java.sql.CallableStatement	prepareCall (String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException
java.sql.PreparedStatement	prepareStatement (String sql, int autoGeneratedKeys) throws SQLException
java.sql.PreparedStatement	prepareStatement (String sql, int columnIndexes[]) throws SQLException
java.sql.PreparedStatement	prepareStatement (String sql, String columnNames[]) throws SQLException
AbstractBlobFilter	getBlobFilter ()
ResultSet	getTableTypes () throws SQLException
ResultSet	getTablePrivileges (String catalog, String schemaPattern, String tableNamePattern) throws SQLException
ResultSet	getSchemas () throws SQLException
String	getDatabaseProductName () throws SQLException
void	fetchNextData (String cursorName, int fetchSize, DriverResultSet drsToUpdate) throws SQLException
void	closeRemoteResultSet (String cursorName) throws SQLException
String	getPreparedStatementBooleanFalse ()
void	setPreparedStatementBooleanFalse (String booleanFalse)
String	getPreparedStatementBooleanTrue ()
void	setPreparedStatementBooleanTrue (String booleanTrue)
boolean	isEscapeBackslash ()
void	setEscapeBackslash (boolean escapeBackslash)
boolean	isEscapeSingleQuote ()
void	setEscapeSingleQuote (boolean escapeSingleQuote)
void	setDriverProcessed (boolean processedByDriver)
boolean	isDriverProcessed ()
void	setEscapeChar (String escapeChar)
String	getEscapeChar ()
Static Public Attributes
final String	TAG_MARKER = "!%"
final String	TAG_MARKER_ESCAPE = TAG_MARKER + ";"
final String	START_PARAM_TAG = "<" + TAG_MARKER
final String	END_PARAM_TAG = "|" + TAG_MARKER + ">"
Protected Member Functions
void	finalize () throws Throwable
java.sql.ResultSet	getProcedures (String catalog, String schemaPattern, String procedureNamePattern) throws SQLException
java.sql.ResultSet	getProcedureColumns (String catalog, String schemaPattern, String procedureNamePattern, String columnNamePattern) throws SQLException
void	setConnectionParametersOnRequest (AbstractRequest request)
java.sql.ResultSet	execReadRequest (SelectRequest request) throws SQLException
void	setCloseSocketOnGC (boolean closeSocketOnGC)
int	execWriteRequest (AbstractWriteRequest request) throws SQLException
ResultSet	execWriteRequestWithKeys (AbstractWriteRequest request) throws SQLException
int	execWriteStoredProcedure (StoredProcedure proc) throws SQLException
ResultSet	getColumns (String catalog, String schemaPattern, String tableNamePattern, String columnNamePattern) throws SQLException
ResultSet	getPrimaryKeys (String catalog, String schemaPattern, String tableNamePattern) throws SQLException
ResultSet	getTables (String catalog, String schemaPattern, String tableNamePattern, String[] types) throws SQLException
Protected Attributes
boolean	autoCommit = true
boolean	isClosed = false
boolean	readOnly = false
int	isolationLevel = java.sql.Connection.TRANSACTION_READ_COMMITTED
long	transactionId = 0
boolean	needSqlSkeleton = false
SQLWarning	firstWarning = null
DatabaseMetaData	metaData = null
Driver	driver = null
String	url = null
String	vdbUser = null
String	vdbPassword = null
Socket	socket
CJDBCInputStream	socketInput
CJDBCOutputStream	socketOutput
boolean	escapeBackslash = true
boolean	escapeSingleQuote = true
boolean	driverProcessed = true
String	preparedStatementBooleanTrue = "'1'"
String	preparedStatementBooleanFalse = "'0'"
String	escapeChar = "\'"
Static Protected Attributes
final String	LINE_SEPARATOR
Package Attributes
boolean	writeExecutedInTransaction = false

---

Detailed Description

This Connection class implements a virtual connection that is just used to store the needed information when the real connection will have to be established by the Controller to execute a query.

This code has been inspired from the PostgreSQL JDBC driver by Peter T. Mount.

Author:

Emmanuel Cecchet

Julie Marguerite

Vadim Kassin

Duncan Smith

Nicolas Modrzyk

Jaco Swart

Version:

1.0

Definition at line 67 of file Connection.java.

---

Constructor & Destructor Documentation

org.objectweb.cjdbc.driver.Connection.Connection (   )

Creates a new Connection instance. Definition at line 159 of file Connection.java. { }

org.objectweb.cjdbc.driver.Connection.Connection (  Driver  driver, Socket  socket, CJDBCInputStream  in, CJDBCOutputStream  out, String  url, String  userName, String  password, boolean  sqlSkeletonNeeded, AbstractBlobFilter  filter )

Creates a new Connection instance. Parameters: driver  calling driver socket  connection with the controller in  socket input stream out  socket output stream url  C-JDBC URL of the database userName  user login password  user password sqlSkeletonNeeded  true if SQL skeletons must be sent to the controller filter  to use to encode and decode blobs Definition at line 177 of file Connection.java. { this.driver = driver; this.socket = socket; this.socketInput = in; this.socketOutput = out; this.url = url; this.vdbUser = userName; this.vdbPassword = password; this.needSqlSkeleton = sqlSkeletonNeeded; this.blobFilter = filter; }

---

Member Function Documentation

void org.objectweb.cjdbc.driver.Connection.clearWarnings (   )  throws SQLException

After this call, getWarnings() returns null until a new warning is reported for this connection. Exceptions: SQLException  if a database access error occurs Definition at line 281 of file Connection.java. References org.objectweb.cjdbc.driver.Connection.firstWarning. { firstWarning = null; }

void org.objectweb.cjdbc.driver.Connection.close (   )  throws SQLException

Releases the connection. In fact, the connection is marked to be released but will be effectively closed by the ConnectionClosingThread if the connection has not been reused before. Exceptions: SQLException  if an error occurs Definition at line 293 of file Connection.java. References org.objectweb.cjdbc.driver.Connection.autoCommit, org.objectweb.cjdbc.driver.Driver.connectionClosingThreadisAlive, org.objectweb.cjdbc.driver.Connection.driver, org.objectweb.cjdbc.driver.Connection.isClosed, org.objectweb.cjdbc.driver.Driver.pendingConnectionClosing, org.objectweb.cjdbc.driver.Connection.readOnly, and org.objectweb.cjdbc.driver.Connection.socketOutput. Referenced by org.objectweb.cjdbc.driver.Statement.close(), org.objectweb.cjdbc.driver.Statement.executeQuery(), org.objectweb.cjdbc.driver.Statement.executeUpdateWithSkeleton(), org.objectweb.cjdbc.driver.Connection.finalize(), and org.objectweb.cjdbc.driver.Statement.getMoreResults(). { // We synchronize here in the case 2 threads try to call close() // concurrently on this connection. synchronized (this) { if (isClosed) return; else isClosed = true; } try { autoCommit = true; readOnly = false; socketOutput.writeInt(Commands.Reset); socketOutput.flush(); } catch (Exception e) { throw new SQLException("Error while closing the connection: " + e); } synchronized (driver.pendingConnectionClosing) { if (!driver.connectionClosingThreadisAlive) { // First connection to close, start a new closing thread ConnectionClosingThread t = new ConnectionClosingThread(driver); t.start(); } // Add to the list driver.pendingConnectionClosing.add(this); } }

void org.objectweb.cjdbc.driver.Connection.closeRemoteResultSet (  String  cursorName  )  throws SQLException

Closes the remote ResultSet given its cursor name. Parameters: cursorName  cursor name of the ResultSet to close. Exceptions: SQLException  if an error occurs Definition at line 2202 of file Connection.java. References org.objectweb.cjdbc.driver.Connection.socketInput, and org.objectweb.cjdbc.driver.Connection.socketOutput. Referenced by org.objectweb.cjdbc.driver.DriverResultSet.close(). { try { socketOutput.writeInt(Commands.CloseRemoteResultSet); socketOutput.writeUTF(cursorName); socketOutput.flush(); Object data = socketInput.readObject(); if (data instanceof CommandCompleted) return; else if (data instanceof SQLException) throw (SQLException) data; else throw new SQLException( "Connection.closeRemoteResultSet: Unexpected response (" + data + ")"); } catch (Exception e) { throw new SQLException( "Connection.closeRemoteResultSet: Error occured while request was processed by C-JDBC Controller (" + e + ")"); } }

void org.objectweb.cjdbc.driver.Connection.commit (   )  throws SQLException

Makes all changes made since the previous commit/rollback permanent and releases any database locks currently held by the Connection. This method should only be used when auto-commit has been disabled. (If autoCommit==true, then we throw an SQLException). Exceptions: SQLException  if a database access error occurs or the connection is in autocommit mode See also: Connection.setAutoCommit Definition at line 340 of file Connection.java. References org.objectweb.cjdbc.driver.Connection.driver, org.objectweb.cjdbc.driver.Connection.socketInput, org.objectweb.cjdbc.driver.Connection.socketOutput, org.objectweb.cjdbc.driver.Connection.transactionId, and org.objectweb.cjdbc.driver.Connection.writeExecutedInTransaction. { if (autoCommit) throw new SQLException("Trying to commit a connection in autocommit mode"); if (driver == null) throw new SQLException("No driver to send the commit request"); try { socketOutput.writeInt(Commands.Commit); socketOutput.flush(); // Commit is followed by a BEGIN Object r = socketInput.readObject(); writeExecutedInTransaction = false; if (r instanceof Long) transactionId = ((Long) r).longValue(); else throw new SQLException( "Error occured while trying to start transaction after commit on C-JDBC Controller (" + r + ")"); } catch (Exception e) { throw new SQLException("Error occured while commit of transaction '" + transactionId + "' was processed by C-JDBC Controller (" + e + ")"); } }

java.sql.Statement org.objectweb.cjdbc.driver.Connection.createStatement (  int  resultSetType, int  resultSetConcurrency, int  resultSetHoldability )  throws SQLException

Creates a Statement object that will generate ResultSet objects with the given type, concurrency, and holdability. This method is the same as the createStatement method above, but it allows the default result set type, concurrency, and holdability to be overridden. Parameters: resultSetType  one of the following ResultSet constants: ResultSet.TYPE_FORWARD_ONLY, ResultSet.TYPE_SCROLL_INSENSITIVE, or ResultSet.TYPE_SCROLL_SENSITIVE resultSetConcurrency  one of the following ResultSet constants: ResultSet.CONCUR_READ_ONLY or ResultSet.CONCUR_UPDATABLE resultSetHoldability  one of the following ResultSet constants: ResultSet.HOLD_CURSORS_OVER_COMMIT or ResultSet.CLOSE_CURSORS_AT_COMMIT Returns: a new Statement object that will generate ResultSet objects with the given type, concurrency, and holdability Exceptions: SQLException  if a database access error occurs or the given parameters are not ResultSet constants indicating type, concurrency, and holdability See also: ResultSet Since: JDK 1.4 Definition at line 1803 of file Connection.java. { throw new NotImplementedException("createStatement"); }

java.sql.Statement org.objectweb.cjdbc.driver.Connection.createStatement (  int  resultSetType, int  resultSetConcurrency )  throws SQLException

SQL statements without parameters are normally executed using Statement objects. If the same SQL statement is executed many times, it is more efficient to use a PreparedStatement. Parameters: resultSetType  resultSetType to use resultSetConcurrency  resultSetConcurrency to use Returns: a new Statement object Exceptions: SQLException  passed through from the constructor Definition at line 393 of file Connection.java. References org.objectweb.cjdbc.driver.Statement.setResultSetConcurrency(), and org.objectweb.cjdbc.driver.Statement.setResultSetType(). { Statement s = new Statement(this); s.setResultSetType(resultSetType); s.setResultSetConcurrency(resultSetConcurrency); return s; }

java.sql.Statement org.objectweb.cjdbc.driver.Connection.createStatement (   )  throws SQLException

SQL statements without parameters are normally executed using Statement objects. If the same SQL statement is executed many times, it is more efficient to use a PreparedStatement. The ResultSet will be TYPE_FORWARD_ONLY</cde>/CONCUR_READ_ONLY. * Returns: a new Statement object Exceptions: SQLException  passed through from the constructor Definition at line 378 of file Connection.java. { return new Statement(this); }

java.sql.ResultSet org.objectweb.cjdbc.driver.Connection.execReadRequest (  SelectRequest  request  )  throws SQLException [protected]

Performs a read request and return the reply. Parameters: request  the read request to execute Returns: a java.sql.ResultSet value Exceptions: SQLException  if an error occurs Definition at line 930 of file Connection.java. References org.objectweb.cjdbc.driver.Connection.driver, org.objectweb.cjdbc.driver.Driver.getControllerConfig(), org.objectweb.cjdbc.driver.Connection.setConnectionParametersOnRequest(), org.objectweb.cjdbc.driver.Connection.socketInput, and org.objectweb.cjdbc.driver.Connection.socketOutput. Referenced by org.objectweb.cjdbc.driver.Statement.executeQuery(). { if (driver == null) throw new SQLException("No driver to send the request '" + request.getSQLShortForm(Constants.SQL_SHORT_FORM_LENGTH) + "'"); try { setConnectionParametersOnRequest(request); socketOutput.writeInt(Commands.ExecReadRequest); readRequestOnStream(request); socketOutput.flush(); Object in = socketInput.readObject(); if (in instanceof NoMoreBackendException) { try { // If there is only one controller available rethrow the exception if (driver.getControllerConfig().size() == 1) throw (SQLException) in; else { // otherwise try to connect to an other controller and re-execute // the query reconnect(); return execReadRequest(request); } } catch (SQLException e1) { // We deal with this exception in the follwoing if block in = e1; } } if (in instanceof IOException) { reconnect(); return execReadRequest(request); } else if (in instanceof SQLException) { throw (SQLException) in; } else if (in instanceof Field[]) { // Get the ResultSet metadata the row data Field[] fields = (Field[]) in; ArrayList data = null; boolean hasMoreData; String cursorName = null; try { data = (ArrayList) socketInput.readObject(); hasMoreData = socketInput.readBoolean(); if (hasMoreData) cursorName = socketInput.readUTF(); } catch (IOException e) { reconnect(); return execReadRequest(request); } catch (Exception e1) { throw new SQLException( "Connection.execReadRequest: Unexpected response (" + e1 + ") for request " + request.getSQLShortForm(Constants.SQL_SHORT_FORM_LENGTH)); } return new org.objectweb.cjdbc.driver.DriverResultSet(fields, data, hasMoreData, cursorName); } else { throw new SQLException( "Connection.execReadRequest: Unexpected response (" + in + ") for request " + request.getSQLShortForm(Constants.SQL_SHORT_FORM_LENGTH)); } } catch (RuntimeException e) { e.printStackTrace(); throw new SQLException( "Connection.execReadRequest: Error occured while request '" + request.getSQLShortForm(Constants.SQL_SHORT_FORM_LENGTH) + "' was processed by C-JDBC Controller (" + e + ")"); } catch (IOException e) { // Connection failed, try to reconnect and re-exec the query try { reconnect(); return execReadRequest(request); } catch (SQLException e1) { throw new SQLException("Connection lost while executing request '" + request.getSQLShortForm(Constants.SQL_SHORT_FORM_LENGTH) + "' and automatic reconnect failed (" + e1 + ")"); } } catch (ClassNotFoundException e) { e.printStackTrace(); throw new SQLException( "Connection.execReadRequest: Unexpected response (" + e + ") for request " + request.getSQLShortForm(Constants.SQL_SHORT_FORM_LENGTH)); } }

ResultSet org.objectweb.cjdbc.driver.Connection.execReadStoredProcedure (  StoredProcedure  proc  )  throws SQLException

Call a stored procedure that returns a ResultSet. Parameters: proc  the stored procedure call Returns: a java.sql.ResultSet value Exceptions: SQLException  if an error occurs Definition at line 1388 of file Connection.java. References org.objectweb.cjdbc.driver.Connection.driver, org.objectweb.cjdbc.common.stream.CJDBCOutputStream.flush(), org.objectweb.cjdbc.driver.Connection.setConnectionParametersOnRequest(), org.objectweb.cjdbc.driver.Connection.socketInput, org.objectweb.cjdbc.driver.Connection.socketOutput, and org.objectweb.cjdbc.common.stream.CJDBCOutputStream.writeInt(). Referenced by org.objectweb.cjdbc.driver.Statement.executeQuery(). { if (driver == null) throw new SQLException("No driver to send the request '" + proc.getSQLShortForm(Constants.SQL_SHORT_FORM_LENGTH) + "'"); try { setConnectionParametersOnRequest(proc); socketOutput.writeInt(Commands.ExecReadStoredProcedure); procedureOnStream(proc, true); socketOutput.flush(); Object in = socketInput.readObject(); if (in instanceof SQLException) throw (SQLException) in; else if (in instanceof Field[]) { // Get the ResultSet metadata the row data Field[] fields = (Field[]) in; ArrayList data = null; boolean hasMoreData; String cursorName = null; try { data = (ArrayList) socketInput.readObject(); hasMoreData = socketInput.readBoolean(); if (hasMoreData) cursorName = socketInput.readUTF(); } catch (Exception e1) { throw new SQLException( "Connection.execReadStoredProcedure: Unexpected response (" + e1 + ") for request " + proc.getSQLShortForm(Constants.SQL_SHORT_FORM_LENGTH)); } return new org.objectweb.cjdbc.driver.DriverResultSet(fields, data, hasMoreData, cursorName); } else throw new SQLException( "Connection.execReadStoredProcedure: Unexpected response (" + in + ") for request " + proc.getSQLShortForm(Constants.SQL_SHORT_FORM_LENGTH)); } catch (RuntimeException e) { throw new SQLException( "Connection.execReadStoredProcedure: Error occured while request '" + proc.getSQLShortForm(Constants.SQL_SHORT_FORM_LENGTH) + "' was processed by C-JDBC Controller (" + e + ")"); } catch (IOException e) { // Connection failed, try to reconnect and re-exec the query try { reconnect(); return execReadStoredProcedure(proc); } catch (SQLException e1) { throw new SQLException("Connection lost while executing request'" + proc.getSQLShortForm(Constants.SQL_SHORT_FORM_LENGTH) + "' and automatic reconnect failed (" + e1 + ")"); } } catch (ClassNotFoundException e) { throw new SQLException( "Connection.execReadStoredProcedure: Unexpected response (" + e + ") for request " + proc.getSQLShortForm(Constants.SQL_SHORT_FORM_LENGTH)); } }

int org.objectweb.cjdbc.driver.Connection.execWriteRequest (  AbstractWriteRequest  request  )  throws SQLException [protected]

Performs a write request and return the number of rows affected. Parameters: request  the write request to execute Returns: number of rows affected Exceptions: SQLException  if an error occurs Definition at line 1121 of file Connection.java. References org.objectweb.cjdbc.driver.Connection.driver, org.objectweb.cjdbc.driver.Connection.setConnectionParametersOnRequest(), org.objectweb.cjdbc.driver.Connection.socketInput, and org.objectweb.cjdbc.driver.Connection.socketOutput. Referenced by org.objectweb.cjdbc.driver.Statement.executeUpdateWithSkeleton(). { if (driver == null) throw new SQLException("No driver to send the request '" + request.getSQLShortForm(Constants.SQL_SHORT_FORM_LENGTH) + "'"); try { setConnectionParametersOnRequest(request); socketOutput.writeInt(Commands.ExecWriteRequest); writeRequestOnStream(request, false); socketOutput.flush(); Object r = socketInput.readObject(); if (r instanceof Integer) return ((Integer) r).intValue(); else if (r instanceof SQLException) throw (SQLException) r; else throw new SQLException( "Connection.execWriteRequest: Unexpected response (" + r + ") for request " + request.getSQLShortForm(Constants.SQL_SHORT_FORM_LENGTH)); } catch (SQLException e) { throw e; } catch (IOException e) { // Connection failed, try to reconnect and re-exec the query try { reconnect(); return execWriteRequest(request); } catch (SQLException e1) { throw new SQLException("Connection lost while executing request'" + request.getSQLShortForm(Constants.SQL_SHORT_FORM_LENGTH) + "' and automatic reconnect failed (" + e1 + ")"); } } catch (Exception e) { throw new SQLException("execWriteRequest: Error occured while request '" + request.getSQLShortForm(Constants.SQL_SHORT_FORM_LENGTH) + "' was processed by C-JDBC Controller (" + e + ")"); } }

ResultSet org.objectweb.cjdbc.driver.Connection.execWriteRequestWithKeys (  AbstractWriteRequest  request  )  throws SQLException [protected]

Performs a write request and return the number of rows affected. Parameters: request  the write request to execute Returns: auto generated keys Exceptions: SQLException  if an error occurs Definition at line 1327 of file Connection.java. References org.objectweb.cjdbc.driver.Connection.driver, org.objectweb.cjdbc.common.stream.CJDBCOutputStream.flush(), org.objectweb.cjdbc.driver.Connection.setConnectionParametersOnRequest(), org.objectweb.cjdbc.driver.Connection.socketInput, org.objectweb.cjdbc.driver.Connection.socketOutput, and org.objectweb.cjdbc.common.stream.CJDBCOutputStream.writeInt(). Referenced by org.objectweb.cjdbc.driver.Statement.executeUpdateWithSkeleton(). { if (driver == null) throw new SQLException("No driver to send the request '" + request.getSQLShortForm(Constants.SQL_SHORT_FORM_LENGTH) + "'"); try { setConnectionParametersOnRequest(request); socketOutput.writeInt(Commands.ExecWriteRequestWithKeys); writeRequestOnStream(request, true); socketOutput.flush(); Object in = socketInput.readObject(); if (in instanceof SQLException) throw (SQLException) in; else if (in instanceof Field[]) { // Get the ResultSet metadata the row data Field[] fields = (Field[]) in; ArrayList data = null; boolean hasMoreData; String cursorName = null; try { data = (ArrayList) socketInput.readObject(); hasMoreData = socketInput.readBoolean(); if (hasMoreData) cursorName = socketInput.readUTF(); } catch (Exception e1) { throw new SQLException( "Connection.execWriteRequestWithKeys: Unexpected response (" + e1 + ") for request " + request.getSQLShortForm(Constants.SQL_SHORT_FORM_LENGTH)); } return new org.objectweb.cjdbc.driver.DriverResultSet(fields, data, hasMoreData, cursorName); } else throw new SQLException( "Connection.execWriteRequestWithKeys: Unexpected response (" + in + ") for request " + request.getSQLShortForm(Constants.SQL_SHORT_FORM_LENGTH)); } catch (Exception e) { throw new SQLException( "execWriteRequestWithKeys: Error occured while request '" + request.getSQLShortForm(Constants.SQL_SHORT_FORM_LENGTH) + "' was processed by C-JDBC Controller (" + e + ")"); } }

int org.objectweb.cjdbc.driver.Connection.execWriteStoredProcedure (  StoredProcedure  proc  )  throws SQLException [protected]

Call a stored procedure that performs an update. Parameters: proc  the stored procedure call Returns: number of rows affected Exceptions: SQLException  if an error occurs Definition at line 1470 of file Connection.java. References org.objectweb.cjdbc.driver.Connection.driver, org.objectweb.cjdbc.common.stream.CJDBCOutputStream.flush(), org.objectweb.cjdbc.driver.Connection.setConnectionParametersOnRequest(), org.objectweb.cjdbc.driver.Connection.socketInput, org.objectweb.cjdbc.driver.Connection.socketOutput, and org.objectweb.cjdbc.common.stream.CJDBCOutputStream.writeInt(). Referenced by org.objectweb.cjdbc.driver.Statement.executeUpdateWithSkeleton(). { if (driver == null) throw new SQLException("No driver to send the request '" + proc.getSQLShortForm(Constants.SQL_SHORT_FORM_LENGTH) + "'"); try { setConnectionParametersOnRequest(proc); socketOutput.writeInt(Commands.ExecWriteStoredProcedure); procedureOnStream(proc, false); socketOutput.flush(); Object r = socketInput.readObject(); if (r instanceof Integer) return ((Integer) r).intValue(); else if (r instanceof SQLException) throw (SQLException) r; else throw new SQLException( "Connection.execWriteStoredProcedure: Unexpected response (" + r + ") for request " + proc.getSQLShortForm(Constants.SQL_SHORT_FORM_LENGTH)); } catch (Exception e) { throw new SQLException( "execWriteStoredProcedure: Error occured while request '" + proc.getSQLShortForm(Constants.SQL_SHORT_FORM_LENGTH) + "' was processed by C-JDBC Controller (" + e + ")"); } }

void org.objectweb.cjdbc.driver.Connection.fetchNextData (  String  cursorName, int  fetchSize, DriverResultSet  drsToUpdate )  throws SQLException

Fetch next fetchSize rows of data and update the given ResultSet. Parameters: cursorName  name of the ResultSet cursor fetchSize  number of rows to fetch drsToUpdate  DriverResultSet to update Exceptions: SQLException  if an error occurs Definition at line 2165 of file Connection.java. References org.objectweb.cjdbc.driver.Connection.socketInput, and org.objectweb.cjdbc.driver.Connection.socketOutput. Referenced by org.objectweb.cjdbc.driver.DriverResultSet.next(). { try { socketOutput.writeInt(Commands.FetchNextResultSetRows); socketOutput.writeUTF(cursorName); socketOutput.writeInt(fetchSize); socketOutput.flush(); Object data = socketInput.readObject(); if (data instanceof ArrayList) { boolean hasMoreData = socketInput.readBoolean(); drsToUpdate.setData((ArrayList) data); drsToUpdate.setHasMoreData(hasMoreData); } else if (data instanceof SQLException) throw (SQLException) data; else throw new SQLException( "Connection.fetchNextData: Unexpected response (" + data + ")"); } catch (Exception e) { throw new SQLException( "Connection.fetchNextData: Error occured while request was processed by C-JDBC Controller (" + e + ")"); } }

void org.objectweb.cjdbc.driver.Connection.finalize (   )  throws Throwable [protected]

See also: java.lang.Object#finalize() Definition at line 195 of file Connection.java. References org.objectweb.cjdbc.driver.Connection.close(), and org.objectweb.cjdbc.driver.Connection.rollback(). { if (this.closeSocketOnGC) { Throwable t = null; try { rollback(); } catch (Exception e) { t = e; } try { close(); } catch (Exception e) { t = e; } if (t != null) { throw t; } } super.finalize(); }

boolean org.objectweb.cjdbc.driver.Connection.getAutoCommit (   )  throws SQLException

Gets the current auto-commit state. Returns: current state of the auto-commit mode Exceptions: SQLException  (why?) See also: Connection.setAutoCommit Definition at line 409 of file Connection.java. { return this.autoCommit; }

AbstractBlobFilter org.objectweb.cjdbc.driver.Connection.getBlobFilter (   )

Returns the blobFilter value. Returns: Returns the blobFilter. Definition at line 2009 of file Connection.java. Referenced by org.objectweb.cjdbc.driver.DriverResultSet.getBytes(), org.objectweb.cjdbc.driver.DriverResultSet.getObject(), and org.objectweb.cjdbc.driver.PreparedStatement.setBytes(). { if (blobFilter == null) blobFilter = new HexaBlobFilter(); return blobFilter; }

String org.objectweb.cjdbc.driver.Connection.getCatalog (   )  throws SQLException

Return current catalog name. Returns: name of the current VirtualDatabase Exceptions: SQLException  if any error occurs See also: java.sql.Connection#getCatalog() Definition at line 439 of file Connection.java. References org.objectweb.cjdbc.driver.Connection.driver, org.objectweb.cjdbc.driver.Connection.socketInput, and org.objectweb.cjdbc.driver.Connection.socketOutput. { if (driver == null) throw new SQLException("No driver to get the catalog."); try { socketOutput.writeInt(Commands.ConnectionGetCatalog); socketOutput.flush(); Object rs = socketInput.readObject(); if (rs instanceof String) { return (String) rs; } else if (rs instanceof SQLException) throw (SQLException) rs; else throw new SQLException("Connection.getCatalog: Unexpected response (" + rs + ")"); } catch (Exception e) { throw new SQLException( "Connection.getCatalog: Error occured while request was processed by C-JDBC Controller (" + e + ")"); } }

ResultSet org.objectweb.cjdbc.driver.Connection.getCatalogs (   )  throws SQLException

getCatalogs definition. Returns: instace of ResultSet Exceptions: SQLException  if fails (include ANY exception that can be thrown in the code) Definition at line 473 of file Connection.java. References org.objectweb.cjdbc.driver.Connection.driver, org.objectweb.cjdbc.driver.Connection.socketInput, and org.objectweb.cjdbc.driver.Connection.socketOutput. Referenced by org.objectweb.cjdbc.driver.DatabaseMetaData.getCatalogs(). { if (driver == null) throw new SQLException("No driver to get the catalogs."); try { socketOutput.writeInt(Commands.ConnectionGetCatalogs); socketOutput.flush(); Object rs = socketInput.readObject(); if (rs instanceof ResultSet) return (ResultSet) rs; else if (rs instanceof SQLException) throw (SQLException) rs; else throw new SQLException("Connection.getCatalogs: Unexpected response (" + rs + ")"); } catch (Exception e) { throw new SQLException( "Connection.getCatalogs: Error occured while request was processed by C-JDBC Controller (" + e + ")"); } }

String org.objectweb.cjdbc.driver.Connection.getConnectedController (   )

Get the controller description to which this connection is connected to Returns: String like localhost:25322 or null if not connected Definition at line 262 of file Connection.java. References org.objectweb.cjdbc.driver.Connection.socket. { if (socket == null) return null; else return socket.getInetAddress().getHostName() + ":" + socket.getPort(); }

String org.objectweb.cjdbc.driver.Connection.getControllerVersionNumber (   )  throws SQLException

Get the C-JDBC controller version number. Returns: a String containing the controller version Exceptions: SQLException  if an error occurs Definition at line 1645 of file Connection.java. References org.objectweb.cjdbc.common.stream.CJDBCInputStream.readObject(), org.objectweb.cjdbc.driver.Connection.socketInput, and org.objectweb.cjdbc.driver.Connection.socketOutput. Referenced by org.objectweb.cjdbc.driver.DatabaseMetaData.getDatabaseProductVersion(). { try { socketOutput.writeInt(Commands.GetControllerVersionNumber); socketOutput.flush(); Object s = socketInput.readObject(); if (s instanceof String) return (String) s; else throw new SQLException( "Connection.getControllerVersionNumber: Unexpected response (" + s + ")"); } catch (Exception e) { throw new SQLException( "Connection.getControllerVersionNumber: Error occured while request was processed by C-JDBC Controller (" + e + ")"); } }

String org.objectweb.cjdbc.driver.Connection.getDatabaseProductName (   )  throws SQLException

See also: DatabaseMetaData.getDatabaseProductName() Definition at line 2134 of file Connection.java. References org.objectweb.cjdbc.driver.Connection.socketInput, and org.objectweb.cjdbc.driver.Connection.socketOutput. Referenced by org.objectweb.cjdbc.driver.DatabaseMetaData.getDatabaseProductName(). { try { socketOutput.writeInt(Commands.DatabaseMetaDataGetDatabaseProductName); socketOutput.flush(); Object s = socketInput.readObject(); if (s instanceof String) return (String) s; else throw new SQLException( "Connection.GetDatabaseProductName: Unexpected response (" + s + ")"); } catch (Exception e) { throw new SQLException( "Connection.getDatabaseProductName: Error occured while request was processed by C-JDBC Controller (" + e + ")"); } }

String org.objectweb.cjdbc.driver.Connection.getEscapeChar (   )

Returns: Returns the escapeChar. Definition at line 2342 of file Connection.java. Referenced by org.objectweb.cjdbc.driver.PreparedStatement.doEscapeProcessing(). { return escapeChar; }

int org.objectweb.cjdbc.driver.Connection.getHoldability (   )  throws SQLException

Retrieves the current holdability of ResultSet objects created using this Connection object. Returns: the holdability, one of ResultSet.HOLD_CURSORS_OVER_COMMIT or ResultSet.CLOSE_CURSORS_AT_COMMIT Exceptions: SQLException  if a database access occurs See also: setHoldability ResultSet Since: JDK 1.4 Definition at line 1701 of file Connection.java. { throw new NotImplementedException("getHoldability"); }

java.sql.DatabaseMetaData org.objectweb.cjdbc.driver.Connection.getMetaData (   )  throws SQLException

A connection's database is able to provide information describing its tables, its supported SQL grammar, its stored procedures, the capabilities of this connection, etc. This information is made available through a DatabaseMetaData object. Returns: a DatabaseMetaData object for this connection Exceptions: SQLException  if a database access error occurs Definition at line 423 of file Connection.java. References org.objectweb.cjdbc.driver.Connection.metaData. { if (metaData == null) { metaData = new DatabaseMetaData(this); } return metaData; }

String org.objectweb.cjdbc.driver.Connection.getPassword (   )

Gets the password used to login to the database. Returns: password Definition at line 251 of file Connection.java. Referenced by org.objectweb.cjdbc.driver.Driver.connect(). { return vdbPassword; }

String org.objectweb.cjdbc.driver.Connection.getPreparedStatementBooleanFalse (   )

Returns the booleanFalse value. Returns: Returns the booleanFalse. Definition at line 2233 of file Connection.java. Referenced by org.objectweb.cjdbc.driver.DriverResultSet.getBoolean(), and org.objectweb.cjdbc.driver.PreparedStatement.setBoolean(). { return preparedStatementBooleanFalse; }

String org.objectweb.cjdbc.driver.Connection.getPreparedStatementBooleanTrue (   )

Returns the booleanTrue value. Returns: Returns the booleanTrue. Definition at line 2253 of file Connection.java. Referenced by org.objectweb.cjdbc.driver.DriverResultSet.getBoolean(), and org.objectweb.cjdbc.driver.PreparedStatement.setBoolean(). { return preparedStatementBooleanTrue; }

ResultSet org.objectweb.cjdbc.driver.Connection.getPrimaryKeys (  String  catalog, String  schemaPattern, String  tableNamePattern )  throws SQLException [protected]

See also: java.sql.DatabaseMetaData#getPrimaryKeys Definition at line 1539 of file Connection.java. References org.objectweb.cjdbc.driver.Connection.driver, org.objectweb.cjdbc.common.stream.CJDBCInputStream.readObject(), org.objectweb.cjdbc.driver.Connection.socketInput, and org.objectweb.cjdbc.driver.Connection.socketOutput. Referenced by org.objectweb.cjdbc.driver.DatabaseMetaData.getPrimaryKeys(). { if (driver == null) throw new SQLException("No driver to get the tables."); try { socketOutput.writeInt(Commands.DatabaseMetaDataGetPrimaryKeys); socketOutput.writeUTF(catalog); socketOutput.writeUTF(schemaPattern); socketOutput.writeUTF(tableNamePattern); socketOutput.flush(); Object rs = socketInput.readObject(); if (rs == null) return null; if (rs instanceof ResultSet) return (ResultSet) rs; else if (rs instanceof SQLException) throw (SQLException) rs; else throw new SQLException( "Connection.getPrimaryKeys: Unexpected response (" + rs + ")"); } catch (Exception e) { throw new SQLException( "Connection.getPrimaryKeys: Error occured while request was processed by C-JDBC Controller (" + e + ")"); } }

ResultSet org.objectweb.cjdbc.driver.Connection.getSchemas (   )  throws SQLException

See also: java.sql.DatabaseMetaData#getSchemas() Definition at line 2103 of file Connection.java. References org.objectweb.cjdbc.driver.Connection.driver, org.objectweb.cjdbc.driver.Connection.socketInput, and org.objectweb.cjdbc.driver.Connection.socketOutput. Referenced by org.objectweb.cjdbc.driver.DatabaseMetaData.getSchemas(). { if (driver == null) throw new SQLException("No driver to get the schemas."); try { socketOutput.writeInt(Commands.DatabaseMetaDataGetSchemas); socketOutput.flush(); Object rs = socketInput.readObject(); if (rs == null) return null; if (rs instanceof ResultSet) return (ResultSet) rs; else if (rs instanceof SQLException) throw (SQLException) rs; else throw new SQLException("Connection.getSchemas: Unexpected response (" + rs + ")"); } catch (Exception e) { throw new SQLException( "Connection.getSchemas: Error occured while request was processed by C-JDBC Controller (" + e + ")"); } }

Object org.objectweb.cjdbc.driver.Connection.getStaticMetadata (  String  key  )  throws SQLException

Retrieve a metadata from the controller Parameters: key  the name of the metadata to retrieve Returns: an Object that will be an Integer or Boolean or String Exceptions: SQLException  if fails Definition at line 1616 of file Connection.java. References org.objectweb.cjdbc.common.stream.CJDBCInputStream.readObject(), org.objectweb.cjdbc.driver.Connection.socketInput, and org.objectweb.cjdbc.driver.Connection.socketOutput. { try { socketOutput.writeInt(Commands.DatabaseStaticMetadata); socketOutput.writeUTF(key); socketOutput.flush(); Object s = socketInput.readObject(); if (s instanceof SQLException) throw (SQLException) s; else return s; } catch (Exception e) { throw new SQLException( "Connection.getStaticMetadata: Error occured while request was processed by C-JDBC Controller (" + e + ")"); } }

ResultSet org.objectweb.cjdbc.driver.Connection.getTablePrivileges (  String  catalog, String  schemaPattern, String  tableNamePattern )  throws SQLException

Gets a description of the access rights for each table available in a catalog. Note that a table privilege applies to one or more columns in the table. It would be wrong to assume that this priviledge applies to all columns (this may be true for some systems but is not true for all.) Only privileges matching the schema and table name criteria are returned. They are ordered by TABLE_SCHEM, TABLE_NAME, and PRIVILEGE. Parameters: catalog  a catalog name; "" retrieves those without a catalog; null means drop catalog name from the selection criteria schemaPattern  a schema name pattern; "" retrieves those without a schema tableNamePattern  a table name pattern Returns: ResultSet each row is a table privilege description Exceptions: SQLException  if a database access error occurs Definition at line 2068 of file Connection.java. References org.objectweb.cjdbc.driver.Connection.driver, org.objectweb.cjdbc.driver.Connection.socketInput, and org.objectweb.cjdbc.driver.Connection.socketOutput. Referenced by org.objectweb.cjdbc.driver.DatabaseMetaData.getTablePrivileges(). { if (driver == null) throw new SQLException("No driver to get the table privileges."); try { socketOutput.writeInt(Commands.DatabaseMetaDataGetTablePrivileges); socketOutput.writeUTF(catalog); socketOutput.writeUTF(schemaPattern); socketOutput.writeUTF(tableNamePattern); socketOutput.flush(); Object rs = socketInput.readObject(); if (rs == null) return null; if (rs instanceof ResultSet) return (ResultSet) rs; else if (rs instanceof SQLException) throw (SQLException) rs; else throw new SQLException( "Connection.getTablePrivileges: Unexpected response (" + rs + ")"); } catch (Exception e) { throw new SQLException( "Connection.getTablePrivileges: Error occured while request was processed by C-JDBC Controller (" + e + ")"); } }

ResultSet org.objectweb.cjdbc.driver.Connection.getTables (  String  catalog, String  schemaPattern, String  tableNamePattern, String[]  types )  throws SQLException [protected]

See also: org.objectweb.cjdbc.driver.DatabaseMetaData.getTables(String, String, String, String[]) Definition at line 1575 of file Connection.java. References org.objectweb.cjdbc.driver.Connection.driver, org.objectweb.cjdbc.common.stream.CJDBCInputStream.readObject(), org.objectweb.cjdbc.driver.Connection.socketInput, and org.objectweb.cjdbc.driver.Connection.socketOutput. Referenced by org.objectweb.cjdbc.driver.DatabaseMetaData.getTables(). { if (driver == null) throw new SQLException("No driver to get the tables."); try { socketOutput.writeInt(Commands.DatabaseMetaDataGetTables); socketOutput.writeUTF(catalog); socketOutput.writeUTF(schemaPattern); socketOutput.writeUTF(tableNamePattern); socketOutput.writeObject(types); socketOutput.flush(); Object rs = socketInput.readObject(); if (rs == null) return null; if (rs instanceof ResultSet) return (ResultSet) rs; else if (rs instanceof SQLException) throw (SQLException) rs; else throw new SQLException("Connection.getTables: Unexpected response (" + rs + ")"); } catch (Exception e) { throw new SQLException( "Connection.getTables: Error occured while request was processed by C-JDBC Controller (" + e + ")"); } }

ResultSet org.objectweb.cjdbc.driver.Connection.getTableTypes (   )  throws SQLException

Gets the table types available in this database. The results are ordered by table type. Returns: ResultSet each row has a single String column that is a catalog name Exceptions: SQLException  if a database error occurs Definition at line 2024 of file Connection.java. References org.objectweb.cjdbc.driver.Connection.driver, org.objectweb.cjdbc.driver.Connection.socketInput, and org.objectweb.cjdbc.driver.Connection.socketOutput. Referenced by org.objectweb.cjdbc.driver.DatabaseMetaData.getTableTypes(). { if (driver == null) throw new SQLException("No driver to get the table types."); try { socketOutput.writeInt(Commands.DatabaseMetaDataGetTableTypes); socketOutput.flush(); Object rs = socketInput.readObject(); if (rs == null) return null; if (rs instanceof ResultSet) return (ResultSet) rs; else if (rs instanceof SQLException) throw (SQLException) rs; else throw new SQLException( "Connection.getTableTypes: Unexpected response (" + rs + ")"); } catch (Exception e) { throw new SQLException( "Connection.getTableTypes: Error occured while request was processed by C-JDBC Controller (" + e + ")"); } }

int org.objectweb.cjdbc.driver.Connection.getTransactionIsolation (   )  throws SQLException

Gets this Connection's current transaction isolation mode. Returns: the current TRANSACTION_* mode value Exceptions: SQLException  if a database access error occurs Definition at line 568 of file Connection.java. { return isolationLevel; }

java.util.Map org.objectweb.cjdbc.driver.Connection.getTypeMap (   )  throws SQLException

C-JDBC does NOT support type map. Returns: an exception Exceptions: SQLException  not supported Definition at line 579 of file Connection.java. { throw new NotImplementedException("getTypeMap()"); }

String org.objectweb.cjdbc.driver.Connection.getURL (   )

Gets the C-JDBC URL of the database of the connection. Returns: value of url. Definition at line 231 of file Connection.java. Referenced by org.objectweb.cjdbc.driver.Driver.connect(), and org.objectweb.cjdbc.driver.DatabaseMetaData.getURL(). { return url; }

String org.objectweb.cjdbc.driver.Connection.getUserName (   )

Gets the user name used to login to the database. Returns: login name Definition at line 241 of file Connection.java. Referenced by org.objectweb.cjdbc.driver.Driver.connect(), and org.objectweb.cjdbc.driver.DatabaseMetaData.getUserName(). { return vdbUser; }

SQLWarning org.objectweb.cjdbc.driver.Connection.getWarnings (   )  throws SQLException

The first warning reported by calls on this connection is returned. Note: Sebsequent warnings will be changed to this SQLWarning Returns: the first SQLWarning or null Exceptions: SQLException  if a database access error occurs Definition at line 591 of file Connection.java. { return firstWarning; }

boolean org.objectweb.cjdbc.driver.Connection.isClosed (   )  throws SQLException

Returns true if the connection is closed (no real meaning from C-JDBC point of view) Returns: true if connection has never been opened or close() has been called Exceptions: SQLException  if an error occurs Definition at line 604 of file Connection.java. { return isClosed; }

boolean org.objectweb.cjdbc.driver.Connection.isDriverProcessed (   )

Returns the driverProcessed value. Returns: Returns the driverProcessed. Definition at line 2324 of file Connection.java. Referenced by org.objectweb.cjdbc.driver.Statement.executeQuery(), org.objectweb.cjdbc.driver.Statement.executeUpdateWithSkeleton(), org.objectweb.cjdbc.driver.PreparedStatement.setBigDecimal(), org.objectweb.cjdbc.driver.PreparedStatement.setBlob(), org.objectweb.cjdbc.driver.PreparedStatement.setBoolean(), org.objectweb.cjdbc.driver.PreparedStatement.setByte(), org.objectweb.cjdbc.driver.PreparedStatement.setBytes(), org.objectweb.cjdbc.driver.PreparedStatement.setClob(), org.objectweb.cjdbc.driver.PreparedStatement.setDate(), org.objectweb.cjdbc.driver.PreparedStatement.setDouble(), org.objectweb.cjdbc.driver.PreparedStatement.setFloat(), org.objectweb.cjdbc.driver.PreparedStatement.setInt(), org.objectweb.cjdbc.driver.PreparedStatement.setLong(), org.objectweb.cjdbc.driver.PreparedStatement.setNull(), org.objectweb.cjdbc.driver.PreparedStatement.setObject(), org.objectweb.cjdbc.driver.PreparedStatement.setShort(), org.objectweb.cjdbc.driver.PreparedStatement.setString(), org.objectweb.cjdbc.driver.PreparedStatement.setTime(), and org.objectweb.cjdbc.driver.PreparedStatement.setTimestamp(). { return driverProcessed; }

boolean org.objectweb.cjdbc.driver.Connection.isEscapeBackslash (   )

Returns the escapeBackslash value. Returns: Returns the escapeBackslash. Definition at line 2273 of file Connection.java. Referenced by org.objectweb.cjdbc.driver.PreparedStatement.doEscapeProcessing(), and org.objectweb.cjdbc.driver.PreparedStatement.setString(). { return escapeBackslash; }

boolean org.objectweb.cjdbc.driver.Connection.isEscapeSingleQuote (   )

Returns the escapeSingleQuote value. Returns: Returns the escapeSingleQuote. Definition at line 2293 of file Connection.java. Referenced by org.objectweb.cjdbc.driver.PreparedStatement.doEscapeProcessing(), and org.objectweb.cjdbc.driver.PreparedStatement.setString(). { return escapeSingleQuote; }

boolean org.objectweb.cjdbc.driver.Connection.isReadOnly (   )  throws SQLException

Tests to see if the connection is in read only Mode. Note that we cannot really put the database in read only mode, but we pretend we can by returning the value of the readOnly flag. Returns: true if the connection is read only Exceptions: SQLException  if a database access error occurs Definition at line 617 of file Connection.java. Referenced by org.objectweb.cjdbc.driver.DatabaseMetaData.isReadOnly(). { return readOnly; }

String org.objectweb.cjdbc.driver.Connection.nativeSQL (  String  query  )  throws SQLException

As we can't know for sure which database will execute this request (now or later), we can't translate it in the native query language of the underlying DBMS. Therefore the query is returned unchanged. Parameters: query  the query to change Returns: the original query Exceptions: SQLException  never Definition at line 631 of file Connection.java. { return query; }

java.sql.CallableStatement org.objectweb.cjdbc.driver.Connection.prepareCall (  String  sql, int  resultSetType, int  resultSetConcurrency, int  resultSetHoldability )  throws SQLException

Creates a CallableStatement object that will generate ResultSet objects with the given type and concurrency. This method is the same as the prepareCall method above, but it allows the default result set type, result set concurrency type and holdability to be overridden. Parameters: sql  a String object that is the SQL statement to be sent to the database; may contain on or more ? parameters resultSetType  one of the following ResultSet constants: ResultSet.TYPE_FORWARD_ONLY, ResultSet.TYPE_SCROLL_INSENSITIVE, or ResultSet.TYPE_SCROLL_SENSITIVE resultSetConcurrency  one of the following ResultSet constants: ResultSet.CONCUR_READ_ONLY or ResultSet.CONCUR_UPDATABLE resultSetHoldability  one of the following ResultSet constants: ResultSet.HOLD_CURSORS_OVER_COMMIT or ResultSet.CLOSE_CURSORS_AT_COMMIT Returns: a new CallableStatement object, containing the pre-compiled SQL statement, that will generate ResultSet objects with the given type, concurrency, and holdability Exceptions: SQLException  if a database access error occurs or the given parameters are not ResultSet constants indicating type, concurrency, and holdability See also: ResultSet Since: JDK 1.4 Definition at line 1876 of file Connection.java. { throw new NotImplementedException("prepareCall"); }

java.sql.CallableStatement org.objectweb.cjdbc.driver.Connection.prepareCall (  String  sql, int  resultSetType, int  resultSetConcurrency )  throws SQLException

Stored procedure call are not yet supported by C-JDBC. Parameters: sql  a String value resultSetType  an int value resultSetConcurrency  an int value Returns: nothing Exceptions: SQLException  not supported Definition at line 659 of file Connection.java. References org.objectweb.cjdbc.driver.Statement.setResultSetConcurrency(), and org.objectweb.cjdbc.driver.Statement.setResultSetType(). { CallableStatement c = new CallableStatement(this, sql); c.setResultSetType(resultSetType); c.setResultSetConcurrency(resultSetConcurrency); return c; }

java.sql.CallableStatement org.objectweb.cjdbc.driver.Connection.prepareCall (  String  sql  )  throws SQLException

Creates a CallableStatement that contains sql and produces a ResultSet that is TYPE_SCROLL_INSENSITIVE and CONCUR_READ_ONLY. Parameters: sql  SQL request Returns: nothing Exceptions: SQLException  not supported Definition at line 644 of file Connection.java. { return prepareCall(sql, java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE, java.sql.ResultSet.CONCUR_READ_ONLY); }

java.sql.PreparedStatement org.objectweb.cjdbc.driver.Connection.prepareStatement (  String  sql, String  columnNames[] )  throws SQLException

Creates a default PreparedStatement object capable of returning the auto-generated keys designated by the given array. This array contains the names of the columns in the target table that contain the auto-generated keys that should be returned. This array is ignored if the SQL statement is not an INSERT statement. An SQL statement with or without IN parameters can be pre-compiled and stored in a PreparedStatement object. This object can then be used to efficiently execute this statement multiple times. Note: This method is optimized for handling parametric SQL statements that benefit from precompilation. If the driver supports precompilation, the method prepareStatement will send the statement to the database for precompilation. Some drivers may not support precompilation. In this case, the statement may not be sent to the database until the PreparedStatement object is executed. This has no direct effect on users; however, it does affect which methods throw certain SQLExceptions. Result sets created using the returned PreparedStatement object will by default be type TYPE_FORWARD_ONLY and have a concurrency level of CONCUR_READ_ONLY. Parameters: sql  an SQL statement that may contain one or more '?' IN parameter placeholders columnNames  an array of column names indicating the columns that should be returned from the inserted row or rows Returns: a new PreparedStatement object, containing the pre-compiled statement, that is capable of returning the auto-generated keys designated by the given array of column names Exceptions: SQLException  if a database access error occurs Since: JDK 1.4 Definition at line 1998 of file Connection.java. { throw new NotImplementedException("prepareStatement"); }

java.sql.PreparedStatement org.objectweb.cjdbc.driver.Connection.prepareStatement (  String  sql, int  columnIndexes[] )  throws SQLException

Creates a default PreparedStatement object capable of returning the auto-generated keys designated by the given array. This array contains the indexes of the columns in the target table that contain the auto-generated keys that should be made available. This array is ignored if the SQL statement is not an INSERT statement. An SQL statement with or without IN parameters can be pre-compiled and stored in a PreparedStatement object. This object can then be used to efficiently execute this statement multiple times. Note: This method is optimized for handling parametric SQL statements that benefit from precompilation. If the driver supports precompilation, the method prepareStatement will send the statement to the database for precompilation. Some drivers may not support precompilation. In this case, the statement may not be sent to the database until the PreparedStatement object is executed. This has no direct effect on users; however, it does affect which methods throw certain SQLExceptions. Result sets created using the returned PreparedStatement object will by default be type TYPE_FORWARD_ONLY and have a concurrency level of CONCUR_READ_ONLY. Parameters: sql  an SQL statement that may contain one or more '?' IN parameter placeholders columnIndexes  an array of column indexes indicating the columns that should be returned from the inserted row or rows Returns: a new PreparedStatement object, containing the pre-compiled statement, that is capable of returning the auto-generated keys designated by the given array of column indexes Exceptions: SQLException  if a database access error occurs Since: JDK 1.4 Definition at line 1958 of file Connection.java. { throw new NotImplementedException("prepareStatement"); }

java.sql.PreparedStatement org.objectweb.cjdbc.driver.Connection.prepareStatement (  String  sql, int  autoGeneratedKeys )  throws SQLException

Creates a default PreparedStatement object that has the capability to retrieve auto-generated keys. The given constant tells the driver whether it should make auto-generated keys available for retrieval. This parameter is ignored if the SQL statement is not an INSERT statement. Note: This method is optimized for handling parametric SQL statements that benefit from precompilation. If the driver supports precompilation, the method prepareStatement will send the statement to the database for precompilation. Some drivers may not support precompilation. In this case, the statement may not be sent to the database until the PreparedStatement object is executed. This has no direct effect on users; however, it does affect which methods throw certain SQLExceptions. Result sets created using the returned PreparedStatement object will by default be type TYPE_FORWARD_ONLY and have a concurrency level of CONCUR_READ_ONLY. Parameters: sql  an SQL statement that may contain one or more '?' IN parameter placeholders autoGeneratedKeys  a flag indicating whether auto-generated keys should be returned; one of Statement.RETURN_GENERATED_KEYS or Statement.NO_GENERATED_KEYS Returns: a new PreparedStatement object, containing the pre-compiled SQL statement, that will have the capability of returning auto-generated keys Exceptions: SQLException  if a database access error occurs or the given parameter is not a Statement constant indicating whether auto-generated keys should be returned Since: JDK 1.4 Definition at line 1916 of file Connection.java. References org.objectweb.cjdbc.driver.PreparedStatement.setGeneratedKeysFlag(). { PreparedStatement ps = new PreparedStatement(this, sql); ps.setGeneratedKeysFlag(autoGeneratedKeys); return ps; }

java.sql.PreparedStatement org.objectweb.cjdbc.driver.Connection.prepareStatement (  String  sql, int  resultSetType, int  resultSetConcurrency, int  resultSetHoldability )  throws SQLException

Creates a PreparedStatement object that will generate ResultSet objects with the given type, concurrency, and holdability. This method is the same as the prepareStatement method above, but it allows the default result set type, concurrency, and holdability to be overridden. Parameters: sql  a String object that is the SQL statement to be sent to the database; may contain one or more ? IN parameters resultSetType  one of the following ResultSet constants: ResultSet.TYPE_FORWARD_ONLY, ResultSet.TYPE_SCROLL_INSENSITIVE, or ResultSet.TYPE_SCROLL_SENSITIVE resultSetConcurrency  one of the following ResultSet constants: ResultSet.CONCUR_READ_ONLY or ResultSet.CONCUR_UPDATABLE resultSetHoldability  one of the following ResultSet constants: ResultSet.HOLD_CURSORS_OVER_COMMIT or ResultSet.CLOSE_CURSORS_AT_COMMIT Returns: a new PreparedStatement object, containing the pre-compiled SQL statement, that will generate ResultSet objects with the given type, concurrency, and holdability Exceptions: SQLException  if a database access error occurs or the given parameters are not ResultSet constants indicating type, concurrency, and holdability See also: ResultSet Since: JDK 1.4 Definition at line 1840 of file Connection.java. { throw new NotImplementedException("prepareStatement"); }

java.sql.PreparedStatement org.objectweb.cjdbc.driver.Connection.prepareStatement (  String  sql, int  resultSetType, int  resultSetConcurrency )  throws SQLException

A SQL statement with or without IN parameters can be pre-compiled and stored in a PreparedStatement object. This object can then be used to efficiently execute this statement multiple times. Parameters: sql  a SQL statement that may contain one or more '?' IN resultSetType  ResultSetType to use resultSetConcurrency  ResultSetConcurrency to use Returns: a new PreparedStatement object Exceptions: SQLException  passed through from the constructor Definition at line 696 of file Connection.java. References org.objectweb.cjdbc.driver.Statement.setResultSetConcurrency(), and org.objectweb.cjdbc.driver.Statement.setResultSetType(). { PreparedStatement s = new PreparedStatement(this, sql); s.setResultSetType(resultSetType); s.setResultSetConcurrency(resultSetConcurrency); return s; }

java.sql.PreparedStatement org.objectweb.cjdbc.driver.Connection.prepareStatement (  String  sql  )  throws SQLException

A SQL statement with or without IN parameters can be pre-compiled and stored in a PreparedStatement object. This object can then be used to efficiently execute this statement multiple times. Parameters: sql  a SQL statement that may contain one or more '?' IN * parameter placeholders Returns: a new PreparedStatement object containing the pre-compiled statement. Exceptions: SQLException  if a database access error occurs. Definition at line 679 of file Connection.java. { return new PreparedStatement(this, sql); }

void org.objectweb.cjdbc.driver.Connection.releaseSavepoint (  Savepoint  savepoint  )  throws SQLException

Removes the given Savepoint object from the current transaction. Any reference to the savepoint after it have been removed will cause an SQLException to be thrown. Parameters: savepoint  the Savepoint object to be removed Exceptions: SQLException  if a database access error occurs or the given Savepoint object is not a valid savepoint in the current transaction Since: JDK 1.4 Definition at line 1770 of file Connection.java. { throw new NotImplementedException("releaseSavepoint"); }

void org.objectweb.cjdbc.driver.Connection.rollback (  Savepoint  savepoint  )  throws SQLException

Undoes all changes made after the given Savepoint object was set. This method should be used only when auto-commit has been disabled. Parameters: savepoint  the Savepoint object to roll back to Exceptions: SQLException  if a database access error occurs, the Savepoint object is no longer valid, or this Connection object is currently in auto-commit mode See also: Savepoint rollback() Since: JDK 1.4 Definition at line 1754 of file Connection.java. { throw new NotImplementedException("rollback"); }

void org.objectweb.cjdbc.driver.Connection.rollback (   )  throws SQLException

Drops all changes made since the previous commit/rollback and releases any database locks currently held by this connection. If the connection was in autocommit mode, we throw a SQLException. Exceptions: SQLException  if a database access error occurs or the connection is in autocommit mode See also: Connection.commit Definition at line 714 of file Connection.java. References org.objectweb.cjdbc.driver.Connection.driver, org.objectweb.cjdbc.driver.Connection.socketInput, org.objectweb.cjdbc.driver.Connection.socketOutput, org.objectweb.cjdbc.driver.Connection.transactionId, and org.objectweb.cjdbc.driver.Connection.writeExecutedInTransaction. Referenced by org.objectweb.cjdbc.driver.Connection.finalize(). { if (autoCommit) throw new SQLException( "Trying to rollback a connection in autocommit mode"); if (driver == null) throw new SQLException("No driver to send the rollback request"); try { socketOutput.writeInt(Commands.Rollback); socketOutput.flush(); // Rollback is followed by a BEGIN writeExecutedInTransaction = false; Object r = socketInput.readObject(); if (r instanceof Long) transactionId = ((Long) r).longValue(); else throw new SQLException( "Error occured while trying to start transaction after rollback on C-JDBC Controller (" + r + ")"); } catch (Exception e) { throw new SQLException("Error occured while rollback of transaction '" + transactionId + "' was processed by C-JDBC Controller (" + e + ")"); } }

void org.objectweb.cjdbc.driver.Connection.setAutoCommit (  boolean  autoCommit  )  throws SQLException

If a connection is in auto-commit mode, then all its SQL statements will be executed and committed as individual transactions. Otherwise, its SQL statements are grouped into transactions that are terminated by either commit()or rollback(). By default, new connections are in auto-commit mode. The commit occurs when the statement completes or the next execute occurs, whichever comes first. In the case of statements returning a ResultSet, the statement completes when the last row of the ResultSet has been retrieved or the ResultSet has been closed. In advanced cases, a single statement may return multiple results as well as output parameter values. Here the commit occurs when all results and output param values have been retrieved. Parameters: autoCommit  true enables auto-commit; false disables it Exceptions: SQLException  if a database access error occurs Definition at line 762 of file Connection.java. References org.objectweb.cjdbc.driver.Connection.driver, org.objectweb.cjdbc.driver.Connection.socketInput, org.objectweb.cjdbc.driver.Connection.socketOutput, org.objectweb.cjdbc.driver.Connection.transactionId, and org.objectweb.cjdbc.driver.Connection.writeExecutedInTransaction. { if (this.autoCommit == autoCommit) return; this.autoCommit = autoCommit; if (driver == null) throw new SQLException("No driver to get a transaction id"); if (autoCommit) { transactionId = 0; try { socketOutput.writeInt(Commands.SetAutoCommit); socketOutput.flush(); Object r = socketInput.readObject(); writeExecutedInTransaction = false; if (r instanceof Boolean || ((Boolean) r).booleanValue()) return; else throw new SQLException( "Error occured while trying to change autocommit value on C-JDBC Controller (" + r + ")"); } catch (Exception e) { throw new SQLException( "Error occured while trying to change autocommit value on C-JDBC Controller (" + e + ")"); } } else { try { socketOutput.writeInt(Commands.Begin); socketOutput.flush(); Object r = socketInput.readObject(); if (r instanceof Long) transactionId = ((Long) r).longValue(); else throw new SQLException( "Error occured while trying to start transaction on C-JDBC Controller (" + r + ")"); this.autoCommit = false; } catch (Exception e) { throw new SQLException( "Error occured while trying to start transaction on C-JDBC Controller (" + e + ")"); } } }

void org.objectweb.cjdbc.driver.Connection.setCatalog (  String  catalog  )  throws SQLException

Change the current catalog Parameters: catalog  a String value Exceptions: SQLException  if fails or if catalog name is invalid Definition at line 825 of file Connection.java. References org.objectweb.cjdbc.driver.Connection.driver, org.objectweb.cjdbc.driver.Driver.getUrlFromProperties(), org.objectweb.cjdbc.driver.Driver.parseURL(), org.objectweb.cjdbc.driver.Connection.socketInput, org.objectweb.cjdbc.driver.Connection.socketOutput, and org.objectweb.cjdbc.driver.Connection.url. { if (catalog == null) throw new SQLException("Invalid Catalog"); Hashtable properties = driver.parseURL(url); properties.put(Driver.DATABASE_PROPERTY, catalog); url = driver.getUrlFromProperties(properties); if (driver == null) throw new SQLException("No driver to set the catalog."); try { socketOutput.writeInt(Commands.ConnectionSetCatalog); socketOutput.writeUTF(catalog); socketOutput.flush(); Object rs = socketInput.readObject(); if (rs instanceof Boolean) { if (((Boolean) rs).booleanValue() == false) throw new SQLException("Invalid Catalog"); } else throw new SQLException("Connection.setCatalog: Unexpected response (" + rs + ")"); } catch (Exception e) { throw new SQLException( "Connection.setCatalog: Error occured while request was processed by C-JDBC Controller (" + e + ")"); } }

void org.objectweb.cjdbc.driver.Connection.setCloseSocketOnGC (  boolean  closeSocketOnGC  )  [protected]

Sets the closeSocketOnGC value. Parameters: closeSocketOnGC  The closeSocketOnGC to set. Definition at line 1109 of file Connection.java. { this.closeSocketOnGC = closeSocketOnGC; }

void org.objectweb.cjdbc.driver.Connection.setConnectionParametersOnRequest (  AbstractRequest  request  )  [protected]

Set the autocommit mode and read-only status on this request. Parameters: request  The request to set Definition at line 916 of file Connection.java. References org.objectweb.cjdbc.driver.Connection.autoCommit, org.objectweb.cjdbc.driver.Connection.readOnly, org.objectweb.cjdbc.common.sql.AbstractRequest.setDriverProcessed(), org.objectweb.cjdbc.common.sql.AbstractRequest.setIsAutoCommit(), and org.objectweb.cjdbc.common.sql.AbstractRequest.setIsReadOnly(). Referenced by org.objectweb.cjdbc.driver.Connection.execReadRequest(), org.objectweb.cjdbc.driver.Connection.execReadStoredProcedure(), org.objectweb.cjdbc.driver.Connection.execWriteRequest(), org.objectweb.cjdbc.driver.Connection.execWriteRequestWithKeys(), and org.objectweb.cjdbc.driver.Connection.execWriteStoredProcedure(). { request.setIsAutoCommit(autoCommit); request.setIsReadOnly(readOnly); request.setDriverProcessed(driverProcessed); }

void org.objectweb.cjdbc.driver.Connection.setDriverProcessed (  boolean  processedByDriver  )

Sets the driverProcessed value Parameters: processedByDriver  true if the PreparedStatement are processed by the C-JDBC driver. Definition at line 2314 of file Connection.java. { this.driverProcessed = processedByDriver; }

void org.objectweb.cjdbc.driver.Connection.setEscapeBackslash (  boolean  escapeBackslash  )

Sets the escapeBackslash value. Parameters: escapeBackslash  The escapeBackslash to set. Definition at line 2283 of file Connection.java. { this.escapeBackslash = escapeBackslash; }

void org.objectweb.cjdbc.driver.Connection.setEscapeChar (  String  escapeChar  )

Sets the escapeCharacter value Parameters: escapeChar  the escapeChar value to set Definition at line 2334 of file Connection.java. { this.escapeChar = escapeChar; }

void org.objectweb.cjdbc.driver.Connection.setEscapeSingleQuote (  boolean  escapeSingleQuote  )

Sets the escapeSingleQuote value. Parameters: escapeSingleQuote  The escapeSingleQuote to set. Definition at line 2303 of file Connection.java. { this.escapeSingleQuote = escapeSingleQuote; }

void org.objectweb.cjdbc.driver.Connection.setHoldability (  int  holdability  )  throws SQLException

Changes the holdability of ResultSet objects created using this Connection object to the given holdability. Parameters: holdability  a ResultSet holdability constant; one of ResultSet.HOLD_CURSORS_OVER_COMMIT or ResultSet.CLOSE_CURSORS_AT_COMMIT Exceptions: SQLException  if a database access occurs, the given parameter is not a ResultSet constant indicating holdability, or the given holdability is not supported See also: getHoldability ResultSet Since: JDK 1.4 Definition at line 1684 of file Connection.java. { throw new NotImplementedException("setHoldability"); }

void org.objectweb.cjdbc.driver.Connection.setPreparedStatementBooleanFalse (  String  booleanFalse  )

Sets the booleanFalse value. Parameters: booleanFalse  The booleanFalse to set. Definition at line 2243 of file Connection.java. { this.preparedStatementBooleanFalse = booleanFalse; }

void org.objectweb.cjdbc.driver.Connection.setPreparedStatementBooleanTrue (  String  booleanTrue  )

Sets the booleanTrue value. Parameters: booleanTrue  The booleanTrue to set. Definition at line 2263 of file Connection.java. { this.preparedStatementBooleanTrue = booleanTrue; }

void org.objectweb.cjdbc.driver.Connection.setReadOnly (  boolean  readOnly  )  throws SQLException

You can put a connection in read-only mode as a hint to enable database optimizations Note: setReadOnly cannot be called while in the middle of a transaction with write requests. Parameters: readOnly  true enables read-only mode; false disables it Exceptions: SQLException  if a database access error occurs Definition at line 870 of file Connection.java. References org.objectweb.cjdbc.driver.Connection.autoCommit. { if ((autoCommit == false) && writeExecutedInTransaction) throw new SQLException( "setReadOnly cannot be called in a transaction that has executed write requests."); this.readOnly = readOnly; }

Savepoint org.objectweb.cjdbc.driver.Connection.setSavepoint (  String  name  )  throws SQLException

Creates a savepoint with the given name in the current transaction and returns the new Savepoint object that represents it. Parameters: name  a String containing the name of the savepoint Returns: the new Savepoint object Exceptions: SQLException  if a database access error occurs or this Connection object is currently in auto-commit mode See also: Savepoint Since: JDK 1.4 Definition at line 1734 of file Connection.java. { throw new NotImplementedException("setSavepoint"); }

Savepoint org.objectweb.cjdbc.driver.Connection.setSavepoint (   )  throws SQLException

Creates an unnamed savepoint in the current transaction and returns the new Savepoint object that represents it. Returns: the new Savepoint object Exceptions: SQLException  if a database access error occurs or this Connection object is currently in auto-commit mode See also: Savepoint Since: JDK 1.4 Definition at line 1717 of file Connection.java. { throw new NotImplementedException("setSavepoint"); }

void org.objectweb.cjdbc.driver.Connection.setTransactionIsolation (  int  level  )  throws SQLException

You can call this method to try to change the transaction isolation level using one of the TRANSACTION_* values. Note: this method cannot be called while in the middle of a transaction. Parameters: level  one of the TRANSACTION_* isolation values with * the exception of TRANSACTION_NONE; some databases may * not support other values Exceptions: SQLException  if a database access error occurs See also: java.sql.DatabaseMetaData#supportsTransactionIsolationLevel Definition at line 891 of file Connection.java. References org.objectweb.cjdbc.driver.Connection.isolationLevel. { isolationLevel = level; }

void org.objectweb.cjdbc.driver.Connection.setTypeMap (  java.util.Map  map  )  throws SQLException

C-JDBC does NOT support type map. Parameters: map  ignored Exceptions: SQLException  not supported Definition at line 902 of file Connection.java. { throw new NotImplementedException("setTypeMap()"); }

---

Member Data Documentation

boolean org.objectweb.cjdbc.driver.Connection.autoCommit = true [protected]

Commit mode of the connection (true= automatic). Definition at line 72 of file Connection.java. Referenced by org.objectweb.cjdbc.driver.Connection.close(), org.objectweb.cjdbc.driver.Connection.setConnectionParametersOnRequest(), and org.objectweb.cjdbc.driver.Connection.setReadOnly().

Driver org.objectweb.cjdbc.driver.Connection.driver = null [protected]

Driver that created us. Definition at line 99 of file Connection.java. Referenced by org.objectweb.cjdbc.driver.Connection.close(), org.objectweb.cjdbc.driver.Connection.commit(), org.objectweb.cjdbc.driver.Connection.execReadRequest(), org.objectweb.cjdbc.driver.Connection.execReadStoredProcedure(), org.objectweb.cjdbc.driver.Connection.execWriteRequest(), org.objectweb.cjdbc.driver.Connection.execWriteRequestWithKeys(), org.objectweb.cjdbc.driver.Connection.execWriteStoredProcedure(), org.objectweb.cjdbc.driver.Connection.getCatalog(), org.objectweb.cjdbc.driver.Connection.getCatalogs(), org.objectweb.cjdbc.driver.Connection.getPrimaryKeys(), org.objectweb.cjdbc.driver.Connection.getSchemas(), org.objectweb.cjdbc.driver.Connection.getTablePrivileges(), org.objectweb.cjdbc.driver.Connection.getTables(), org.objectweb.cjdbc.driver.Connection.getTableTypes(), org.objectweb.cjdbc.driver.Connection.rollback(), org.objectweb.cjdbc.driver.Connection.setAutoCommit(), and org.objectweb.cjdbc.driver.Connection.setCatalog().

final String org.objectweb.cjdbc.driver.Connection.END_PARAM_TAG = "|" + TAG_MARKER + ">" [static]

Tag for PreparedStatement parameters end delimiter Definition at line 138 of file Connection.java.

SQLWarning org.objectweb.cjdbc.driver.Connection.firstWarning = null [protected]

List of Warnings for this connection. Definition at line 93 of file Connection.java. Referenced by org.objectweb.cjdbc.driver.Connection.clearWarnings().

boolean org.objectweb.cjdbc.driver.Connection.isClosed = false [protected]

Status of the connection. Definition at line 75 of file Connection.java. Referenced by org.objectweb.cjdbc.driver.Connection.close(), and org.objectweb.cjdbc.driver.Driver.connect().

int org.objectweb.cjdbc.driver.Connection.isolationLevel = java.sql.Connection.TRANSACTION_READ_COMMITTED [protected]

Isolation level. Definition at line 84 of file Connection.java. Referenced by org.objectweb.cjdbc.driver.Connection.setTransactionIsolation().

final String org.objectweb.cjdbc.driver.Connection.LINE_SEPARATOR [static, protected]

Initial value: System .getProperty("line.separator") Definition at line 146 of file Connection.java.

DatabaseMetaData org.objectweb.cjdbc.driver.Connection.metaData = null [protected]

Meta-data of C-JDBC connections. Definition at line 96 of file Connection.java. Referenced by org.objectweb.cjdbc.driver.Connection.getMetaData().

boolean org.objectweb.cjdbc.driver.Connection.needSqlSkeleton = false [protected]

Does the controller require the SQL skeleton? Definition at line 90 of file Connection.java. Referenced by org.objectweb.cjdbc.driver.Statement.executeQuery(), and org.objectweb.cjdbc.driver.Statement.executeUpdateWithSkeleton().

boolean org.objectweb.cjdbc.driver.Connection.readOnly = false [protected]

Is the connection in read-only mode ? Definition at line 78 of file Connection.java. Referenced by org.objectweb.cjdbc.driver.Connection.close(), and org.objectweb.cjdbc.driver.Connection.setConnectionParametersOnRequest().

Socket org.objectweb.cjdbc.driver.Connection.socket [protected]

Connection with the controller. Definition at line 109 of file Connection.java. Referenced by org.objectweb.cjdbc.driver.Connection.getConnectedController().

CJDBCInputStream org.objectweb.cjdbc.driver.Connection.socketInput [protected]

Socket input stream. Definition at line 112 of file Connection.java. Referenced by org.objectweb.cjdbc.driver.Connection.closeRemoteResultSet(), org.objectweb.cjdbc.driver.Connection.commit(), org.objectweb.cjdbc.driver.Connection.execReadRequest(), org.objectweb.cjdbc.driver.Connection.execReadStoredProcedure(), org.objectweb.cjdbc.driver.Connection.execWriteRequest(), org.objectweb.cjdbc.driver.Connection.execWriteRequestWithKeys(), org.objectweb.cjdbc.driver.Connection.execWriteStoredProcedure(), org.objectweb.cjdbc.driver.Connection.fetchNextData(), org.objectweb.cjdbc.driver.Connection.getCatalog(), org.objectweb.cjdbc.driver.Connection.getCatalogs(), org.objectweb.cjdbc.driver.Connection.getControllerVersionNumber(), org.objectweb.cjdbc.driver.Connection.getDatabaseProductName(), org.objectweb.cjdbc.driver.Connection.getPrimaryKeys(), org.objectweb.cjdbc.driver.Connection.getSchemas(), org.objectweb.cjdbc.driver.Connection.getStaticMetadata(), org.objectweb.cjdbc.driver.Connection.getTablePrivileges(), org.objectweb.cjdbc.driver.Connection.getTables(), org.objectweb.cjdbc.driver.Connection.getTableTypes(), org.objectweb.cjdbc.driver.Connection.rollback(), org.objectweb.cjdbc.driver.Connection.setAutoCommit(), and org.objectweb.cjdbc.driver.Connection.setCatalog().

CJDBCOutputStream org.objectweb.cjdbc.driver.Connection.socketOutput [protected]

Socket output stream. Definition at line 115 of file Connection.java. Referenced by org.objectweb.cjdbc.driver.Connection.close(), org.objectweb.cjdbc.driver.Connection.closeRemoteResultSet(), org.objectweb.cjdbc.driver.Connection.commit(), org.objectweb.cjdbc.driver.Connection.execReadRequest(), org.objectweb.cjdbc.driver.Connection.execReadStoredProcedure(), org.objectweb.cjdbc.driver.Connection.execWriteRequest(), org.objectweb.cjdbc.driver.Connection.execWriteRequestWithKeys(), org.objectweb.cjdbc.driver.Connection.execWriteStoredProcedure(), org.objectweb.cjdbc.driver.Connection.fetchNextData(), org.objectweb.cjdbc.driver.Connection.getCatalog(), org.objectweb.cjdbc.driver.Connection.getCatalogs(), org.objectweb.cjdbc.driver.Connection.getControllerVersionNumber(), org.objectweb.cjdbc.driver.Connection.getDatabaseProductName(), org.objectweb.cjdbc.driver.Connection.getPrimaryKeys(), org.objectweb.cjdbc.driver.Connection.getSchemas(), org.objectweb.cjdbc.driver.Connection.getStaticMetadata(), org.objectweb.cjdbc.driver.Connection.getTablePrivileges(), org.objectweb.cjdbc.driver.Connection.getTables(), org.objectweb.cjdbc.driver.Connection.getTableTypes(), org.objectweb.cjdbc.driver.Connection.rollback(), org.objectweb.cjdbc.driver.Connection.setAutoCommit(), and org.objectweb.cjdbc.driver.Connection.setCatalog().

final String org.objectweb.cjdbc.driver.Connection.START_PARAM_TAG = "<" + TAG_MARKER [static]

Tag for PreparedStatement parameters start delimiter Definition at line 136 of file Connection.java.

final String org.objectweb.cjdbc.driver.Connection.TAG_MARKER = "!%" [static]

Tag maker for PreparedStatement parameters Definition at line 132 of file Connection.java.

final String org.objectweb.cjdbc.driver.Connection.TAG_MARKER_ESCAPE = TAG_MARKER + ";" [static]

Escape for tag maker Definition at line 134 of file Connection.java.

long org.objectweb.cjdbc.driver.Connection.transactionId = 0 [protected]

transaction identifier. Definition at line 87 of file Connection.java. Referenced by org.objectweb.cjdbc.driver.Connection.commit(), org.objectweb.cjdbc.driver.Connection.rollback(), and org.objectweb.cjdbc.driver.Connection.setAutoCommit().

String org.objectweb.cjdbc.driver.Connection.url = null [protected]

C-JDBC URL of the database. Definition at line 102 of file Connection.java. Referenced by org.objectweb.cjdbc.driver.Connection.setCatalog().

String org.objectweb.cjdbc.driver.Connection.vdbUser = null [protected]

Virtual database user used for this connection. Definition at line 105 of file Connection.java.

boolean org.objectweb.cjdbc.driver.Connection.writeExecutedInTransaction = false [package]

Has a write request been executed in the current transaction? Definition at line 81 of file Connection.java. Referenced by org.objectweb.cjdbc.driver.Connection.commit(), org.objectweb.cjdbc.driver.Connection.rollback(), and org.objectweb.cjdbc.driver.Connection.setAutoCommit().

---

The documentation for this class was generated from the following file:

• Connection.java

---