|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object | +--net.sourceforge.jtds.jdbc.ConnectionJDBC2
jTDS implementation of the java.sql.Connection interface.
Implementation notes:
Inner Class Summary | |
protected static class |
ConnectionJDBC2.ProcEntry
Class used to describe a cached stored procedure for prepared statements. |
Field Summary | |
private java.lang.String |
appName
The application name. |
private boolean |
autoCommit
Default auto commit state. |
private TdsCore |
baseTds
The cored TDS protocol object. |
private int |
batchSize
The maximum size of a batch. |
private CharsetInfo |
charsetInfo
Java charset for encoding. |
private boolean |
charsetSpecified
True if user specifies an explicit charset. |
private boolean |
closed
True if this connection is closed. |
private byte[] |
collation
SQL Server 2000 collation. |
private java.lang.String |
currentDatabase
The current database name. |
private int |
databaseMajorVersion
The major version number eg 11. |
private int |
databaseMinorVersion
The minor version number eg 92. |
private java.lang.String |
databaseName
The requested database name. |
private java.lang.String |
databaseProductName
The database product name eg SQL SERVER. |
private java.lang.String |
databaseProductVersion
The product version eg 11.92. |
private java.lang.String |
domainName
The Windows Domain name. |
private java.lang.String |
instanceName
The SQL Server instance. |
private java.lang.String |
language
The server message language. |
private boolean |
lastUpdateCount
Only return the last update count. |
private long |
lobBuffer
The amount of LOB data to buffer in memory. |
private int |
loginTimeout
Login timeout value in seconds or 0. |
private java.lang.String |
macAddress
The client MAC Address. |
private int |
maxPrecision
Maximum decimal precision. |
private int |
maxStatements
The maximum number of statements to keep open. |
private SQLDiagnostic |
messages
Diagnostc messages for this connection. |
private Semaphore |
mutex
Mutual exclusion lock to control access to connection. |
private boolean |
namedPipe
Use named pipe IPC instead of TCP/IP sockets. |
private int |
netPacketSize
The initial network packet size. |
private int |
packetSize
User requested packet size. |
private java.lang.String |
password
The user password. |
private int |
portNumber
The server port number. |
private int |
prepareSql
Method for preparing SQL used in Prepared Statements. |
private java.util.ArrayList |
procInTran
Procedures in this transaction. |
private java.lang.String |
progName
The program name. |
private boolean |
readOnly
True if this connection is read only. |
private int |
rowCount
Connection's current rowcount limit. |
private java.lang.String |
serverCharset
The server character set. |
private java.lang.String |
serverName
The server host name. |
private int |
serverType
The make of SQL Server (sybase/microsoft). |
private SharedSocket |
socket
The network TCP/IP socket. |
private int |
spSequenceNo
Stored procedure unique ID number. |
private static java.lang.String |
SQL_SERVER_65_CHARSET_QUERY
SQL query to determine the server charset on MS SQL Server 6.5. |
private java.lang.String |
SQL_SERVER_INITIAL_SQL
SQL Server initial connection string. |
private java.lang.String |
ssl
SSL setting. |
private StatementCache |
statementCache
Statement cache. |
private java.util.ArrayList |
statements
List of statements associated with this connection. |
private java.lang.String |
SYBASE_INITIAL_SQL
Sybase initial connection string. |
private static java.lang.String |
SYBASE_SERVER_CHARSET_QUERY
SQL query to determine the server charset on Sybase. |
private int |
sybaseInfo
Sybase capability mask. |
private boolean |
tcpNoDelay
TCP_NODELAY |
private int |
tdsVersion
The server protocol version. |
private int |
textSize
Connection's current maximum field size limit. |
private int |
transactionIsolation
Default transaction isolation level. |
private java.lang.String |
url
The orginal connection URL. |
private java.lang.String |
user
The database user ID. |
private boolean |
useUnicode
Send parameters as unicode. |
private java.lang.String |
wsid
Workstation ID. |
private boolean |
xaEmulation
True if driver should emulate distributed transactions. |
private int |
xaState
Current emulated XA State eg start/end/prepare etc. |
private boolean |
xaTransaction
True if running distributed transaction. |
private java.lang.Object |
xid
Current XA Transaction ID. |
Fields inherited from interface java.sql.Connection |
TRANSACTION_NONE, TRANSACTION_READ_COMMITTED, TRANSACTION_READ_UNCOMMITTED, TRANSACTION_REPEATABLE_READ, TRANSACTION_SERIALIZABLE |
Constructor Summary | |
private |
ConnectionJDBC2()
Default constructor. |
(package private) |
ConnectionJDBC2(java.lang.String url,
java.util.Properties info)
Create a new database connection. |
Method Summary | |
(package private) void |
addCachedProcedure(java.lang.String key,
ConnectionJDBC2.ProcEntry proc)
Add a stored procedure to the cache. |
(package private) void |
addStatement(JtdsStatement statement)
Add a statement object to the list maintained by the connection. |
(package private) void |
checkLocal(java.lang.String method)
Check that this connection is in local transaction mode. |
(package private) void |
checkOpen()
Check that this connection is still open. |
(package private) void |
clearSavepoints()
Releases all savepoints. |
void |
clearWarnings()
|
void |
close()
Releases this Connection object's database and JDBC
resources immediately instead of waiting for them to be automatically
released. |
void |
commit()
|
java.sql.Statement |
createStatement()
|
java.sql.Statement |
createStatement(int type,
int concurrency)
|
java.sql.Statement |
createStatement(int type,
int concurrency,
int holdability)
|
private java.lang.String |
determineServerCharset()
Discovers the server charset for server versions that do not send ENVCHANGE packets on login ack, by executing a DB
vendor/version specific query. |
(package private) void |
enlistConnection(byte[] oleTranID)
Enlist the current connection in a distributed transaction. |
boolean |
getAutoCommit()
|
(package private) int |
getBatchSize()
Retrieves the batch size to be used internally. |
java.lang.String |
getCatalog()
|
protected java.lang.String |
getCharset()
Retrieve the Java charset to use for encoding. |
protected CharsetInfo |
getCharsetInfo()
Retrieve the CharsetInfo instance used by this connection. |
(package private) byte[] |
getCollation()
Retrieve the SQL Server 2000 default collation. |
(package private) int |
getDatabaseMajorVersion()
Retrive the DBMS major version. |
(package private) int |
getDatabaseMinorVersion()
Retrive the DBMS minor version. |
(package private) java.lang.String |
getDatabaseProductName()
Retrive the DBMS product name. |
(package private) java.lang.String |
getDatabaseProductVersion()
Retrive the DBMS proeuct version. |
int |
getHoldability()
|
(package private) long |
getLobBuffer()
Retrieves the LOB buffer size. |
(package private) int |
getMaxPrecision()
Retrieves the maximum decimal precision. |
java.sql.DatabaseMetaData |
getMetaData()
|
(package private) Semaphore |
getMutex()
Retrieve the connection mutex. |
(package private) int |
getNetPacketSize()
Retrieves the network packet size. |
(package private) int |
getPrepareSql()
Retrieves the Prepared SQL method. |
(package private) java.lang.String |
getProcName()
Retrieve the next unique stored procedure name. |
java.lang.String |
getRmHost()
Retrieve the host and port for this connection. |
(package private) int |
getRowCount()
Retrieves the current row count on this connection. |
(package private) int |
getServerType()
Retrieves the server type. |
(package private) SharedSocket |
getSocket()
Retrive the shared socket. |
protected boolean |
getSybaseInfo(int flag)
Retrieve the Sybase capability data. |
(package private) int |
getTdsVersion()
Retrieve the TDS protocol version. |
int |
getTextSize()
Retrieves the current maximum textsize on this connection. |
int |
getTransactionIsolation()
|
java.util.Map |
getTypeMap()
|
(package private) java.lang.String |
getURL()
Retrieve the original connection URL. |
java.sql.SQLWarning |
getWarnings()
|
(package private) int |
getXaState()
Retrieve the XA state variable. |
(package private) java.lang.Object |
getXid()
Get the XA transaction ID when running in emulation mode. |
(package private) boolean |
isCharsetSpecified()
Retrieves whether a specific charset was requested on creation. |
boolean |
isClosed()
|
(package private) boolean |
isLastUpdateCount()
Retrieves the status of the lastUpdateCount flag. |
boolean |
isReadOnly()
|
protected boolean |
isUseUnicode()
Retrieve the sendParametersAsUnicode flag. |
protected boolean |
isWideChar()
Retrieve the multibyte status of the current character set. |
(package private) boolean |
isXaEmulation()
Retrieve the XA Emulation flag. |
private void |
loadCharset(CharsetInfo ci,
java.lang.String ref)
Load the Java charset to match the server character set. |
private void |
loadCharset(java.lang.String charset)
Load the Java charset to match the server character set. |
java.lang.String |
nativeSQL(java.lang.String sql)
|
(package private) void |
notImplemented(java.lang.String method)
Report that user tried to call a method which has not been implemented. |
private int |
parseIntegerProperty(java.util.Properties info,
java.lang.String key)
Parse a string property value into an integer value. |
private long |
parseLongProperty(java.util.Properties info,
java.lang.String key)
Parse a string property value into a long value. |
java.sql.CallableStatement |
prepareCall(java.lang.String sql)
|
java.sql.CallableStatement |
prepareCall(java.lang.String sql,
int type,
int concurrency)
|
java.sql.CallableStatement |
prepareCall(java.lang.String sql,
int type,
int concurrency,
int holdability)
|
(package private) java.lang.String |
prepareSQL(JtdsPreparedStatement pstmt,
java.lang.String sql,
ParamInfo[] params,
boolean returnKeys)
Try to convert the SQL statement into a stored procedure. |
java.sql.PreparedStatement |
prepareStatement(java.lang.String sql)
|
java.sql.PreparedStatement |
prepareStatement(java.lang.String sql,
int autoGeneratedKeys)
|
java.sql.PreparedStatement |
prepareStatement(java.lang.String sql,
int[] columnIndexes)
|
java.sql.PreparedStatement |
prepareStatement(java.lang.String sql,
int type,
int concurrency)
|
java.sql.PreparedStatement |
prepareStatement(java.lang.String sql,
int type,
int concurrency,
int holdability)
|
java.sql.PreparedStatement |
prepareStatement(java.lang.String sql,
java.lang.String[] columnNames)
|
void |
releaseSavepoint(java.sql.Savepoint savepoint)
|
(package private) void |
removeCachedProcedure(java.lang.String key)
Remove a stored procedure from the cache. |
(package private) void |
removeStatement(JtdsStatement statement)
Remove a statement object from the list maintained by the connection and clean up the statement cache if necessary. |
void |
rollback()
|
void |
rollback(java.sql.Savepoint savepoint)
|
(package private) byte[][] |
sendXaPacket(int[] args,
byte[] data)
Invoke the xp_jtdsxa extended stored procedure on the server. |
void |
setAutoCommit(boolean autoCommit)
|
void |
setCatalog(java.lang.String catalog)
|
(package private) void |
setClosed()
Used to force the closed status on the statement if an IO error has occurred. |
(package private) void |
setCollation(byte[] collation)
Set the default collation for this connection. |
protected void |
setDatabase(java.lang.String newDb,
java.lang.String oldDb)
Called by the protcol to change the current database context. |
protected void |
setDBServerInfo(java.lang.String databaseProductName,
int databaseMajorVersion,
int databaseMinorVersion,
int buildNumber)
Update the connection instance with information about the server. |
void |
setHoldability(int holdability)
|
(package private) void |
setNetPacketSize(int size)
Sets the network packet size. |
void |
setReadOnly(boolean readOnly)
|
(package private) void |
setRowCount(int count)
Sets the current row count on this connection. |
java.sql.Savepoint |
setSavepoint()
|
java.sql.Savepoint |
setSavepoint(java.lang.String name)
|
protected void |
setServerCharset(java.lang.String charset)
Called by the protocol to change the current character set. |
protected void |
setSybaseInfo(int mask)
Set the Sybase capability data. |
void |
setTextSize(int textSize)
Sets the current maximum textsize on this connection. |
void |
setTransactionIsolation(int level)
|
void |
setTypeMap(java.util.Map map)
|
(package private) void |
setXaState(int value)
Set the XA state variable. |
(package private) void |
setXid(java.lang.Object xid)
Set the XA transaction ID when running in emulation mode. |
protected void |
unpackProperties(java.util.Properties info)
Transfers the properties to the local instance variables. |
Methods inherited from class java.lang.Object |
|
Field Detail |
private static final java.lang.String SYBASE_SERVER_CHARSET_QUERY
private static final java.lang.String SQL_SERVER_65_CHARSET_QUERY
private java.lang.String SYBASE_INITIAL_SQL
private java.lang.String SQL_SERVER_INITIAL_SQL
SELECT
private java.lang.String url
private java.lang.String serverName
private int portNumber
private int serverType
private java.lang.String instanceName
private java.lang.String databaseName
private java.lang.String currentDatabase
private java.lang.String domainName
private java.lang.String user
private java.lang.String password
private java.lang.String serverCharset
private java.lang.String appName
private java.lang.String progName
private java.lang.String wsid
private java.lang.String language
private java.lang.String macAddress
private int tdsVersion
private SharedSocket socket
private TdsCore baseTds
private int netPacketSize
private int packetSize
private byte[] collation
private boolean charsetSpecified
private java.lang.String databaseProductName
private java.lang.String databaseProductVersion
private int databaseMajorVersion
private int databaseMinorVersion
private boolean closed
private boolean readOnly
private java.util.ArrayList statements
private int transactionIsolation
private boolean autoCommit
private SQLDiagnostic messages
private int rowCount
private int textSize
private int maxPrecision
private int spSequenceNo
private java.util.ArrayList procInTran
private CharsetInfo charsetInfo
private int prepareSql
private long lobBuffer
private int maxStatements
private StatementCache statementCache
private boolean useUnicode
private boolean namedPipe
private boolean lastUpdateCount
private boolean tcpNoDelay
private int loginTimeout
private int sybaseInfo
private boolean xaTransaction
private int xaState
private java.lang.Object xid
private boolean xaEmulation
private Semaphore mutex
private java.lang.String ssl
private int batchSize
Constructor Detail |
private ConnectionJDBC2()
ConnectionJDBC2(java.lang.String url, java.util.Properties info) throws java.sql.SQLException
url
- The connection URL starting jdbc:jtds:.info
- The additional connection properties.java.sql.SQLException
- Method Detail |
SharedSocket getSocket()
SharedSocket
object.int getTdsVersion()
int
.java.lang.String getProcName()
Notes:
String
.java.lang.String prepareSQL(JtdsPreparedStatement pstmt, java.lang.String sql, ParamInfo[] params, boolean returnKeys) throws java.sql.SQLException
Synchronized because it accesses the procedure cache and the
baseTds
, but the method call also needs to made in a
synchronized (connection)
block together with the execution
(if the prepared statement is actually executed) to ensure the
transaction isn't rolled back between this method call and the actual
execution.
sql
- the SQL statement to prepareparams
- the parametersString
or null if the
SQL cannot be preparedvoid addCachedProcedure(java.lang.String key, ConnectionJDBC2.ProcEntry proc)
Not explicitly synchronized because it's only called by synchronized methods.
key
- The signature of the procedure to cache.proc
- The stored procedure descriptor.void removeCachedProcedure(java.lang.String key)
Not explicitly synchronized because it's only called by synchronized methods.
key
- The signature of the procedure to remove from the cache.int getServerType()
int
where 1 == SQLSERVER and
2 == SYBASE.void setNetPacketSize(int size)
size
- the new packet sizeint getNetPacketSize()
int
int getRowCount()
int
void setRowCount(int count)
count
- the new row countpublic int getTextSize()
int
public void setTextSize(int textSize)
textSize
- the new maximum textsizeboolean isLastUpdateCount()
boolean
int getMaxPrecision()
int
long getLobBuffer()
long
int getPrepareSql()
int getBatchSize()
int
protected void unpackProperties(java.util.Properties info) throws java.sql.SQLException
info
- The connection properties Object.java.sql.SQLException
- If an invalid property value is found.private int parseIntegerProperty(java.util.Properties info, java.lang.String key) throws java.sql.SQLException
info
- The connection properties object.key
- The message key used to retrieve the property name.java.sql.SQLException
- If the property value can't be parsed.private long parseLongProperty(java.util.Properties info, java.lang.String key) throws java.sql.SQLException
info
- The connection properties object.key
- The message key used to retrieve the property name.java.sql.SQLException
- If the property value can't be parsed.protected java.lang.String getCharset()
String
protected boolean isWideChar()
boolean
true if a multi byte character setprotected CharsetInfo getCharsetInfo()
CharsetInfo
instance used by this connection.CharsetInfo
for this connectionprotected boolean isUseUnicode()
boolean
true if parameters should be sent as unicode.protected boolean getSybaseInfo(int flag)
int
.protected void setSybaseInfo(int mask)
mask
- The capability bit mask.protected void setServerCharset(java.lang.String charset) throws java.sql.SQLException
charset
- the server character set nameprivate void loadCharset(java.lang.String charset) throws java.sql.SQLException
charset
- the server character setprivate void loadCharset(CharsetInfo ci, java.lang.String ref) throws java.sql.SQLException
ci
- the CharsetInfo
to loadprivate java.lang.String determineServerCharset() throws java.sql.SQLException
ENVCHANGE
packets on login ack, by executing a DB
vendor/version specific query.
Will throw an SQLException
if used on SQL Server 7.0 or
2000; the idea is that the charset should already be determined from
ENVCHANGE
packets for these DB servers.
Should only be called from the constructor.
java.sql.SQLException
- if an error condition occursvoid setCollation(byte[] collation) throws java.sql.SQLException
Set by a SQL Server 2000 environment change packet. The collation consists of the following fields:
collation
- The new collation.byte[] getCollation()
byte[5]
.boolean isCharsetSpecified()
protected void setDatabase(java.lang.String newDb, java.lang.String oldDb) throws java.sql.SQLException
newDb
- The new database selected on the server.oldDb
- The old database as known by the server.java.sql.SQLException
- protected void setDBServerInfo(java.lang.String databaseProductName, int databaseMajorVersion, int databaseMinorVersion, int buildNumber)
databaseProductName
- The server name eg SQL Server.databaseMajorVersion
- The major version eg 11databaseMinorVersion
- The minor version eg 92buildNumber
- The server build number.void removeStatement(JtdsStatement statement) throws java.sql.SQLException
Synchronized because it accesses the statement list, the statement cache
and the baseTds
.
statement
- the statement to removevoid addStatement(JtdsStatement statement)
WeakReferences are used so that statements can still be closed and garbage collected even if not explicitly closed by the connection.
statement
- The statement to add.void checkOpen() throws java.sql.SQLException
java.sql.SQLException
- if connection closed.void checkLocal(java.lang.String method) throws java.sql.SQLException
method
- The method name being tested.java.sql.SQLException
- if in XA distributed transaction modevoid notImplemented(java.lang.String method) throws java.sql.SQLException
method
- The method name to report in the error message.java.sql.SQLException
- int getDatabaseMajorVersion()
int
.int getDatabaseMinorVersion()
int
.java.lang.String getDatabaseProductName()
String
.java.lang.String getDatabaseProductVersion()
String
.java.lang.String getURL()
String
.public java.lang.String getRmHost()
Used to identify same resource manager in XA transactions.
String
.void setClosed()
byte[][] sendXaPacket(int[] args, byte[] data) throws java.sql.SQLException
xp_jtdsxa
extended stored procedure on the server.
Synchronized because it accesses the baseTds
.
args
- the arguments eg cmd, rmid, flags etc.data
- option byte data eg open string xid etc.java.sql.SQLException
- if an error condition occursvoid enlistConnection(byte[] oleTranID) throws java.sql.SQLException
oleTranID
- the OLE transaction cookie or null to delistjava.sql.SQLException
- if an error condition occursvoid setXid(java.lang.Object xid)
xid
- the XA Transaction IDjava.lang.Object getXid()
Object
void setXaState(int value)
value
- the XA state valueint getXaState()
int
boolean isXaEmulation()
Semaphore getMutex()
Semaphore
public int getHoldability() throws java.sql.SQLException
public int getTransactionIsolation() throws java.sql.SQLException
getTransactionIsolation
in interface java.sql.Connection
public void clearWarnings() throws java.sql.SQLException
clearWarnings
in interface java.sql.Connection
public void close() throws java.sql.SQLException
Connection
object's database and JDBC
resources immediately instead of waiting for them to be automatically
released.
Calling the method close on a Connection
object that is
already closed is a no-op.
Note: A Connection
object is automatically closed
when it is garbage collected. Certain fatal errors also close a
Connection
object.
Synchronized because it accesses the statement list and the
baseTds
.
close
in interface java.sql.Connection
java.sql.SQLException
- if a database access error occurspublic void commit() throws java.sql.SQLException
commit
in interface java.sql.Connection
public void rollback() throws java.sql.SQLException
rollback
in interface java.sql.Connection
public boolean getAutoCommit() throws java.sql.SQLException
getAutoCommit
in interface java.sql.Connection
public boolean isClosed() throws java.sql.SQLException
isClosed
in interface java.sql.Connection
public boolean isReadOnly() throws java.sql.SQLException
isReadOnly
in interface java.sql.Connection
public void setHoldability(int holdability) throws java.sql.SQLException
public void setTransactionIsolation(int level) throws java.sql.SQLException
setTransactionIsolation
in interface java.sql.Connection
public void setAutoCommit(boolean autoCommit) throws java.sql.SQLException
setAutoCommit
in interface java.sql.Connection
public void setReadOnly(boolean readOnly) throws java.sql.SQLException
setReadOnly
in interface java.sql.Connection
public java.lang.String getCatalog() throws java.sql.SQLException
getCatalog
in interface java.sql.Connection
public void setCatalog(java.lang.String catalog) throws java.sql.SQLException
setCatalog
in interface java.sql.Connection
public java.sql.DatabaseMetaData getMetaData() throws java.sql.SQLException
getMetaData
in interface java.sql.Connection
public java.sql.SQLWarning getWarnings() throws java.sql.SQLException
getWarnings
in interface java.sql.Connection
public java.sql.Savepoint setSavepoint() throws java.sql.SQLException
public void releaseSavepoint(java.sql.Savepoint savepoint) throws java.sql.SQLException
public void rollback(java.sql.Savepoint savepoint) throws java.sql.SQLException
public java.sql.Statement createStatement() throws java.sql.SQLException
createStatement
in interface java.sql.Connection
public java.sql.Statement createStatement(int type, int concurrency) throws java.sql.SQLException
createStatement
in interface java.sql.Connection
public java.sql.Statement createStatement(int type, int concurrency, int holdability) throws java.sql.SQLException
public java.util.Map getTypeMap() throws java.sql.SQLException
getTypeMap
in interface java.sql.Connection
public void setTypeMap(java.util.Map map) throws java.sql.SQLException
setTypeMap
in interface java.sql.Connection
public java.lang.String nativeSQL(java.lang.String sql) throws java.sql.SQLException
nativeSQL
in interface java.sql.Connection
public java.sql.CallableStatement prepareCall(java.lang.String sql) throws java.sql.SQLException
prepareCall
in interface java.sql.Connection
public java.sql.CallableStatement prepareCall(java.lang.String sql, int type, int concurrency) throws java.sql.SQLException
prepareCall
in interface java.sql.Connection
public java.sql.CallableStatement prepareCall(java.lang.String sql, int type, int concurrency, int holdability) throws java.sql.SQLException
public java.sql.PreparedStatement prepareStatement(java.lang.String sql) throws java.sql.SQLException
prepareStatement
in interface java.sql.Connection
public java.sql.PreparedStatement prepareStatement(java.lang.String sql, int autoGeneratedKeys) throws java.sql.SQLException
public java.sql.PreparedStatement prepareStatement(java.lang.String sql, int type, int concurrency) throws java.sql.SQLException
prepareStatement
in interface java.sql.Connection
public java.sql.PreparedStatement prepareStatement(java.lang.String sql, int type, int concurrency, int holdability) throws java.sql.SQLException
public java.sql.PreparedStatement prepareStatement(java.lang.String sql, int[] columnIndexes) throws java.sql.SQLException
public java.sql.Savepoint setSavepoint(java.lang.String name) throws java.sql.SQLException
public java.sql.PreparedStatement prepareStatement(java.lang.String sql, java.lang.String[] columnNames) throws java.sql.SQLException
void clearSavepoints()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |