com.caucho.quercus.lib.db

Class JdbcConnectionResource

java.lang.Object

com.caucho.quercus.lib.db.JdbcConnectionResource

All Implemented Interfaces:

EnvCleanup

Direct Known Subclasses:

DataSourceConnection, Mysqli, Oracle, Postgres, SQLite3

public abstract class JdbcConnectionResource
extends java.lang.Object
implements EnvCleanup

Represents a JDBC Connection value.

Field Summary

Fields

Modifier and Type	Field and Description
protected ConnectionEntry	_conn
protected java.lang.String	_driver
protected int	_flags
protected java.lang.String	_host
protected boolean	_isEmulatePrepares
protected int	_port
protected java.lang.String	_socket
protected SqlParseToken	_sqlParseToken
protected java.lang.String	_url

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	JdbcConnectionResource(Env env)

Method Summary

Modifier and Type	Method and Description
void	cleanup() Implements the EnvCleanup interface.
protected void	clearErrors()
protected void	close() Closes the connection.
void	closeStatement(java.sql.Statement stmt)
boolean	commit() commits the transaction of the current connection
protected abstract ConnectionEntry	connectImpl(Env env, java.lang.String host, java.lang.String userName, java.lang.String password, java.lang.String dbname, int port, java.lang.String socket, int flags, java.lang.String driver, java.lang.String url, boolean isNewLink, boolean isEmulatePrepares) Connects to the underlying database.
protected boolean	connectInternal(Env env, java.lang.String host, java.lang.String userName, java.lang.String password, java.lang.String dbname, int port, java.lang.String socket, int flags, java.lang.String driver, java.lang.String url, boolean isNewLink, boolean isEmulatePrepares) Set the current underlying connection and corresponding information: host, port and database name.
protected java.sql.Statement	createJavaStatement(Env env)
protected JdbcResultResource	createResult(java.sql.Statement stmt, java.sql.ResultSet rs) Creates a database-specific result.
protected JdbcStatementResource	createStatement(Env env)
protected JdbcStatementResource	createStatementResource(Env env)
StringValue	error(Env env) Returns the error string for the most recent function call.
int	getAffectedRows() Returns the affected rows from the last query.
boolean	getAutoCommit()
protected java.lang.String	getCatalog()
protected JdbcResultResource	getCatalogs(Env env) Returns JdbcResultResource of available databases
java.lang.String	getCharacterSetName() Returns the client encoding.
java.lang.String	getClientEncoding() Alias for getCharacterSetName
java.lang.String	getClientInfo() Deprecated.
protected java.lang.String	getClientInfo(Env env)
java.sql.Connection	getConnection(Env env) Returns the connection
java.lang.String	getDbName()
java.lang.String	getDriver()
protected java.lang.String	getDriverName()
protected int	getErrorCode() Returns the last error code.
protected java.lang.String	getErrorMessage() Returns the last error message.
protected java.sql.SQLException	getException()
int	getFieldCount()
java.lang.String	getHost()
java.lang.String	getHostInfo() returns the URL string for the given connection IE: jdbc:mysql://localhost:3306/test XXX: PHP returns Localhost via UNIX socket
protected java.sql.Connection	getJavaConnection(Env env) Returns the unwrapped SQL connection associated to this statement.
java.lang.String	getPassword()
int	getPort()
protected JdbcResultResource	getResultResource() Get the current result resource
JdbcResultResource	getResultSet()
protected java.lang.String	getServerInfo() returns the server version
protected Value	getServerStat(Env env)
JdbcTableMetaData	getTableMetaData(Env env, java.lang.String catalog, java.lang.String schema, java.lang.String table) Returns the table metadata.
java.lang.String	getUrl()
protected java.lang.String	getURL() Returns the data source.
java.lang.String	getUserName()
protected java.sql.SQLWarning	getWarnings() This function was added for PostgreSQL pg_last_notice
protected static int	infoToVersion(java.lang.String info)
boolean	isConnected()
boolean	isEmulatePrepares()
protected boolean	isSeekable() Returns true if this connection supports TYPE_SCROLL_INSENSITIVE.
protected void	keepResourceValues(java.sql.Statement stmt) This function is overriden in Postgres to keep result set references for php/430a (see also php/1f33)
protected boolean	keepStatementOpen() This function is overriden in Postgres to keep statement references for php/430a
protected SqlParseToken	parseSqlToken(java.lang.String sql, SqlParseToken prevToken) Parse a token from a string containing a SQL statement.
boolean	ping(Env env) Pings the database
protected JdbcPreparedStatementResource	prepare(Env env, java.lang.String query)
protected StringValue	realEscapeString(Env env, StringValue str) Escape the given string for SQL statements.
protected Value	realQuery(Env env, java.lang.String sql) Execute a single query.
boolean	rollback() rolls the current transaction back NOTE: quercus doesn't seem to support the idea of savepoints
protected void	saveErrors(java.sql.SQLException e)
void	setAffectedRows(int i)
boolean	setAutoCommit(boolean mode) sets auto-commmit to true or false
void	setCatalog(Env env, java.lang.String name) Sets the catalog
boolean	setClientEncoding(java.lang.String encoding) Set encoding on the client side of the connection.
protected void	setResultResource(JdbcResultResource rs) Set the current result resource
protected void	setWarnings(java.sql.SQLWarning warnings) Set the current SQL warnings.
java.lang.Object	toObject() Converts to an object.
java.lang.String	toString() Converts to a string.
JdbcConnectionResource	validateConnection(Env env)

Methods inherited from class java.lang.Object

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

Field Detail

_conn

protected ConnectionEntry _conn

_host

protected java.lang.String _host

_port

protected int _port

_driver

protected java.lang.String _driver

_url

protected java.lang.String _url

_flags

protected int _flags

_socket

protected java.lang.String _socket

_isEmulatePrepares

protected boolean _isEmulatePrepares

_sqlParseToken

protected SqlParseToken _sqlParseToken

Constructor Detail

JdbcConnectionResource

protected JdbcConnectionResource(Env env)

Method Detail

prepare

protected JdbcPreparedStatementResource prepare(Env env,
                                                java.lang.String query)

createStatementResource

protected JdbcStatementResource createStatementResource(Env env)
                                                 throws java.sql.SQLException

Throws:

java.sql.SQLException

createStatement

protected final JdbcStatementResource createStatement(Env env)
                                               throws java.sql.SQLException

Throws:

java.sql.SQLException

getDriverName

protected java.lang.String getDriverName()

getServerStat

protected Value getServerStat(Env env)

error

public StringValue error(Env env)

Returns the error string for the most recent function call. This method is not invoked from PHP code.

isConnected

public boolean isConnected()

getHost

public java.lang.String getHost()

getUserName

public java.lang.String getUserName()

getPassword

public java.lang.String getPassword()

getDbName

public java.lang.String getDbName()

getPort

public int getPort()

getDriver

public java.lang.String getDriver()

getUrl

public java.lang.String getUrl()

isEmulatePrepares

public boolean isEmulatePrepares()

connectInternal

protected final boolean connectInternal(Env env,
                                        java.lang.String host,
                                        java.lang.String userName,
                                        java.lang.String password,
                                        java.lang.String dbname,
                                        int port,
                                        java.lang.String socket,
                                        int flags,
                                        java.lang.String driver,
                                        java.lang.String url,
                                        boolean isNewLink,
                                        boolean isEmulatePrepares)

Set the current underlying connection and corresponding information: host, port and database name.

Parameters:

host - server host

port - server port

dbname - database name

connectImpl

protected abstract ConnectionEntry connectImpl(Env env,
                                               java.lang.String host,
                                               java.lang.String userName,
                                               java.lang.String password,
                                               java.lang.String dbname,
                                               int port,
                                               java.lang.String socket,
                                               int flags,
                                               java.lang.String driver,
                                               java.lang.String url,
                                               boolean isNewLink,
                                               boolean isEmulatePrepares)

Connects to the underlying database.

realEscapeString

protected StringValue realEscapeString(Env env,
                                       StringValue str)

Escape the given string for SQL statements.

Parameters:

str - a string

Returns:

the string escaped for SQL statements

getAffectedRows

public int getAffectedRows()

Returns the affected rows from the last query.

setAffectedRows

public void setAffectedRows(int i)

getFieldCount

public int getFieldCount()

Returns:

_fieldCount

getCatalogs

protected JdbcResultResource getCatalogs(Env env)

Returns JdbcResultResource of available databases

getCatalog

protected java.lang.String getCatalog()

getCharacterSetName

public java.lang.String getCharacterSetName()

Returns the client encoding. XXX: stubbed out. has to be revised once we figure out what to do with character encoding

getClientEncoding

public java.lang.String getClientEncoding()

Alias for getCharacterSetName

setClientEncoding

public boolean setClientEncoding(java.lang.String encoding)

Set encoding on the client side of the connection. Return true if the encoding was set, otherwise false.

getClientInfo

protected java.lang.String getClientInfo(Env env)

getClientInfo

public java.lang.String getClientInfo()

Deprecated.

Returns the client version

getConnection

public final java.sql.Connection getConnection(Env env)

Returns the connection

getJavaConnection

protected java.sql.Connection getJavaConnection(Env env)
                                         throws java.sql.SQLException

Returns the unwrapped SQL connection associated to this statement.

Throws:

java.sql.SQLException

getURL

protected java.lang.String getURL()

Returns the data source.

getErrorCode

protected int getErrorCode()

Returns the last error code.

getErrorMessage

protected java.lang.String getErrorMessage()

Returns the last error message.

getException

protected java.sql.SQLException getException()

getHostInfo

public java.lang.String getHostInfo()
                             throws java.sql.SQLException

returns the URL string for the given connection IE: jdbc:mysql://localhost:3306/test XXX: PHP returns Localhost via UNIX socket

Throws:

java.sql.SQLException

getServerInfo

protected java.lang.String getServerInfo()
                                  throws java.sql.SQLException

returns the server version

Throws:

java.sql.SQLException

getTableMetaData

public JdbcTableMetaData getTableMetaData(Env env,
                                          java.lang.String catalog,
                                          java.lang.String schema,
                                          java.lang.String table)
                                   throws java.sql.SQLException

Returns the table metadata.

Throws:

java.sql.SQLException

infoToVersion

protected static int infoToVersion(java.lang.String info)

closeStatement

public void closeStatement(java.sql.Statement stmt)

close

protected void close()

Closes the connection.

cleanup

public void cleanup()

Implements the EnvCleanup interface. This method will deallocate resources associated with this connection. This method can be invoked via a call to close(), or it can be invoked when the environment is being cleaned up after a quercus request has been processed.

Specified by:

cleanup in interface EnvCleanup

validateConnection

public JdbcConnectionResource validateConnection(Env env)

realQuery

protected Value realQuery(Env env,
                          java.lang.String sql)

Execute a single query.

createJavaStatement

protected java.sql.Statement createJavaStatement(Env env)
                                          throws java.sql.SQLException

Throws:

java.sql.SQLException

parseSqlToken

protected SqlParseToken parseSqlToken(java.lang.String sql,
                                      SqlParseToken prevToken)

Parse a token from a string containing a SQL statement. If the prevToken is null, then the first token in parsed. If a SQL token can't be found in the string, then null is returned. If a SQL token is found, data is captured in the returned SqlParseToken result.

createResult

protected JdbcResultResource createResult(java.sql.Statement stmt,
                                          java.sql.ResultSet rs)

Creates a database-specific result.

getResultSet

public JdbcResultResource getResultSet()

getAutoCommit

public boolean getAutoCommit()

setAutoCommit

public boolean setAutoCommit(boolean mode)

sets auto-commmit to true or false

commit

public boolean commit()

commits the transaction of the current connection

rollback

public boolean rollback()

rolls the current transaction back NOTE: quercus doesn't seem to support the idea of savepoints

setCatalog

public void setCatalog(Env env,
                       java.lang.String name)
                throws java.sql.SQLException

Sets the catalog

Throws:

java.sql.SQLException

toObject

public java.lang.Object toObject()

Converts to an object.

toString

public java.lang.String toString()

Converts to a string.

Overrides:

toString in class java.lang.Object

keepResourceValues

protected void keepResourceValues(java.sql.Statement stmt)

This function is overriden in Postgres to keep result set references for php/430a (see also php/1f33)

keepStatementOpen

protected boolean keepStatementOpen()

This function is overriden in Postgres to keep statement references for php/430a

getResultResource

protected JdbcResultResource getResultResource()

Get the current result resource

setResultResource

protected void setResultResource(JdbcResultResource rs)

Set the current result resource

getWarnings

protected java.sql.SQLWarning getWarnings()

This function was added for PostgreSQL pg_last_notice

Returns:

warning messages

ping

public boolean ping(Env env)

Pings the database

setWarnings

protected void setWarnings(java.sql.SQLWarning warnings)

Set the current SQL warnings.

Parameters:

warnings - the new SQL warnings

clearErrors

protected void clearErrors()

saveErrors

protected void saveErrors(java.sql.SQLException e)

isSeekable

protected boolean isSeekable()

Returns true if this connection supports TYPE_SCROLL_INSENSITIVE. http://bugs.caucho.com/view.php?id=3746