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	setClientInfo
protected SQLInfo	sqlInfo The SQL information.
protected boolean	supportsBatchUpdates
protected XAResource	xaresource

Constructor Summary

Constructors

Constructor and Description
JDBCConnection() for tests only
JDBCConnection(Model model, SQLInfo sqlInfo) 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	countExecute()
static String	getDataSourceName(String repositoryName) Gets the datasource to use for the given repository.
Mapper.Identification	getIdentification()
String	getRepositoryName()
protected void	openBaseConnection(boolean noSharing)
protected void	openConnections(boolean noSharing)

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.

connection

public Connection connection

The actual connection.

supportsBatchUpdates

protected boolean supportsBatchUpdates

xaresource

protected XAResource xaresource

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)

Creates a new Mapper.

Parameters:

model - the model

sqlInfo - the sql info

noSharing - whether to use no-sharing mode for the connection

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()

getDataSourceName

public static String getDataSourceName(String repositoryName)

Gets the datasource to use for the given repository.

Since:

8.4

openConnections

protected void openConnections(boolean noSharing)

openBaseConnection

protected void openBaseConnection(boolean noSharing)
                           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