org.nuxeo.ecm.core.storage.sql.jdbc

Class JDBCConnection

java.lang.Object

org.nuxeo.ecm.core.storage.sql.jdbc.JDBCConnection

Direct Known Subclasses:

JDBCRowMapper

public class JDBCConnection
extends Object

Holds a connection to a JDBC database.

Field Summary

Fields

Modifier and Type	Field and Description
Connection	connection The actual connection.
boolean	countExecutes
protected Dialect	dialect The dialect.
int	executeCount
JDBCLogger	logger
protected Model	model The model used to do the mapping.
protected boolean	noSharing Whether this connection must never be shared (long-lived).
protected boolean	setClientInfo
protected SQLInfo	sqlInfo The SQL information.
protected boolean	supportsBatchUpdates
protected XADataSource	xadatasource The xa datasource.
protected XAResource	xaresource

Constructor Summary

Constructors

Constructor and Description
JDBCConnection() for tests only
JDBCConnection(Model model, SQLInfo sqlInfo, XADataSource xadatasource, boolean noSharing) Creates a new Mapper.

Method Summary

Modifier and Type	Method and Description
protected void	checkConcurrentUpdate(Throwable e) Checks the SQL error we got and determine if a concurrent update happened.
void	close()
void	closeConnections()
protected void	closeStatement(Statement s)
protected void	closeStatement(Statement s, ResultSet r)
protected void	countExecute()
Mapper.Identification	getIdentification()
String	getRepositoryName()
protected void	openBaseConnection()
protected void	openConnections()

Methods inherited from class java.lang.Object

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

Field Detail

model

protected final Model model

The model used to do the mapping.

sqlInfo

protected final SQLInfo sqlInfo

The SQL information.

dialect

protected final Dialect dialect

The dialect.

xadatasource

protected final XADataSource xadatasource

The xa datasource.

connection

public Connection connection

The actual connection.

supportsBatchUpdates

protected boolean supportsBatchUpdates

xaresource

protected XAResource xaresource

noSharing

protected final boolean noSharing

Whether this connection must never be shared (long-lived).

countExecutes

public boolean countExecutes

executeCount

public int executeCount

logger

public final JDBCLogger logger

setClientInfo

protected boolean setClientInfo

Constructor Detail

JDBCConnection

public JDBCConnection(Model model,
                      SQLInfo sqlInfo,
                      XADataSource xadatasource,
                      boolean noSharing)

Creates a new Mapper.

Parameters:

model - the model

sqlInfo - the sql info

xadatasource - the XA datasource to use to get connections

JDBCConnection

public JDBCConnection()

for tests only

Since:

5.9.3

Method Detail

getRepositoryName

public String getRepositoryName()

getIdentification

public Mapper.Identification getIdentification()

countExecute

protected void countExecute()

openConnections

protected void openConnections()

openBaseConnection

protected void openBaseConnection()
                           throws SQLException

Throws:

SQLException

close

public void close()

closeConnections

public void closeConnections()

checkConcurrentUpdate

protected void checkConcurrentUpdate(Throwable e)
                              throws ConcurrentUpdateException

Checks the SQL error we got and determine if a concurrent update happened. Throws if that's the case.

Parameters:

e - the exception

Throws:

ConcurrentUpdateException

Since:

5.8

closeStatement

protected void closeStatement(Statement s)
                       throws SQLException

Throws:

SQLException

closeStatement

protected void closeStatement(Statement s,
                              ResultSet r)
                       throws SQLException

Throws:

SQLException