Package org.apache.ofbiz.entity.jdbc

Class SQLProcessor

java.lang.Object

org.apache.ofbiz.entity.jdbc.SQLProcessor

All Implemented Interfaces:

AutoCloseable

public class SQLProcessor
extends Object
implements AutoCloseable

SQLProcessor - provides utility functions to ease database access

Field Summary

Fields

Modifier and Type	Field	Description
static final boolean	ENABLE_TEST
static final int	MAX_CONNECTIONS

Constructor Summary

Constructors

Constructor	Description
SQLProcessor(Delegator delegator, GenericHelperInfo helperInfo)	Construct an object based on the helper/datasource
SQLProcessor(Delegator delegator, GenericHelperInfo helperInfo, Connection connection)	Construct an object with an connection given.

Method Summary

Modifier and Type	Method	Description
void	close()	Commit if required and remove all allocated resources
void	commit()	Commit all modifications
void	execQuery(String sql, ExecQueryCallbackFunctionIF aListener)	Execute a query based on the SQL string given.
ResultSet	executeQuery()	Execute a query based on the prepared statement
ResultSet	executeQuery(String sql)	Execute a query based on the SQL string given
int	executeUpdate()	Execute updates
int	executeUpdate(String sql)	Execute update based on the SQL statement given
Connection	getConnection()	Get a connection from the TransactionFactoryLoader
Delegator	getDelegator()	Gets delegator.
PreparedStatement	getPreparedStatement()	Getter: get the prepared statement
ResultSet	getResultSet()	Getter: get the currently active ResultSet
boolean	next()	Test if there more records available
void	prepareStatement(String sql)	Prepare a statement.
void	prepareStatement(String sql, boolean specifyTypeAndConcur, int resultSetType, int resultSetConcurrency)	Prepare a statement.
void	prepareStatement(String sql, boolean specifyTypeAndConcur, int resultSetType, int resultSetConcurrency, int fetchSize, int maxRows)	Prepare a statement.
void	rollback()	Rollback all modifications
void	setBinaryStream(Object field)	Set the next binding variable of the currently active prepared statement to write the serialized data of 'field' to a BLOB.
void	setBytes(byte[] bytes)	Set the next binding variable of the currently active prepared statement to write the serialized data of 'field' to a Blob with the given bytes.
protected void	setFetchSize(Statement stmt, int fetchSize)	Sets fetch size.
void	setValue(Boolean field)	Set the next binding variable of the currently active prepared statement.
void	setValue(Double field)	Set the next binding variable of the currently active prepared statement.
void	setValue(Float field)	Set the next binding variable of the currently active prepared statement.
void	setValue(Integer field)	Set the next binding variable of the currently active prepared statement.
void	setValue(Long field)	Set the next binding variable of the currently active prepared statement.
void	setValue(Object field)	Set the next binding variable of the currently active prepared statement.
void	setValue(String field)	Set the next binding variable of the currently active prepared statement.
void	setValue(BigDecimal field)	Set the next binding variable of the currently active prepared statement.
void	setValue(Blob field)	Set the next binding variable of the currently active prepared statement
void	setValue(Clob field)	Set the next binding variable of the currently active prepared statement
void	setValue(Date field)	Set the next binding variable of the currently active prepared statement.
void	setValue(Time field)	Set the next binding variable of the currently active prepared statement.
void	setValue(Timestamp field)	Set the next binding variable of the currently active prepared statement.
<T> void	setValue(JdbcValueHandler<T> handler, T field)	Set the next binding variable of the currently active prepared statement.
protected void	testConnection(Connection con)	Test connection.

Methods inherited from class java.lang.Object

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

Field Details

MAX_CONNECTIONS

public static final int MAX_CONNECTIONS

See Also:

• Constant Field Values

ENABLE_TEST

public static final boolean ENABLE_TEST

See Also:

• Constant Field Values

Constructor Details

SQLProcessor

public SQLProcessor(Delegator delegator,
 GenericHelperInfo helperInfo)

Construct an object based on the helper/datasource

Parameters:

helperInfo - The datasource helper (see entityengine.xml <datasource name="..">)

SQLProcessor

public SQLProcessor(Delegator delegator,
 GenericHelperInfo helperInfo,
 Connection connection)

Construct an object with an connection given. The connection will not be closed by this SQLProcessor, but may be by some other.

Parameters:

helperInfo - The datasource helper (see entityengine.xml <datasource name="..">)

connection - The connection to be used

Method Details

getDelegator

public Delegator getDelegator()

Gets delegator.

Returns:

the delegator

commit

public void commit()
            throws GenericDataSourceException

Commit all modifications

Throws:

GenericDataSourceException

rollback

public void rollback()
              throws GenericDataSourceException

Rollback all modifications

Throws:

GenericDataSourceException

close

public void close()
           throws GenericDataSourceException

Commit if required and remove all allocated resources

Specified by:

close in interface AutoCloseable

Throws:

GenericDataSourceException

getConnection

public Connection getConnection()
                         throws GenericDataSourceException,
GenericEntityException

Get a connection from the TransactionFactoryLoader

Returns:

The connection created

Throws:

GenericDataSourceException

GenericEntityException

prepareStatement

public void prepareStatement(String sql)
                      throws GenericDataSourceException,
GenericEntityException

Prepare a statement. In case no connection has been given, allocate a new one.

Parameters:

sql - The SQL statement to be executed

Throws:

GenericDataSourceException

GenericEntityException

prepareStatement

public void prepareStatement(String sql,
 boolean specifyTypeAndConcur,
 int resultSetType,
 int resultSetConcurrency)
                      throws GenericDataSourceException,
GenericEntityException

Prepare a statement. In case no connection has been given, allocate a new one.

Parameters:

sql - The SQL statement to be executed

Throws:

GenericDataSourceException

GenericEntityException

prepareStatement

public void prepareStatement(String sql,
 boolean specifyTypeAndConcur,
 int resultSetType,
 int resultSetConcurrency,
 int fetchSize,
 int maxRows)
                      throws GenericDataSourceException,
GenericEntityException

Prepare a statement. In case no connection has been given, allocate a new one.

Parameters:

sql - The SQL statement to be executed

Throws:

GenericDataSourceException

GenericEntityException

executeQuery

public ResultSet executeQuery()
                       throws GenericDataSourceException

Execute a query based on the prepared statement

Returns:

The result set of the query

Throws:

GenericDataSourceException

executeQuery

public ResultSet executeQuery(String sql)
                       throws GenericDataSourceException,
GenericEntityException

Execute a query based on the SQL string given

Parameters:

sql - The SQL string to be executed

Returns:

The result set of the query

Throws:

GenericEntityException

GenericDataSourceException

executeUpdate

public int executeUpdate()
                  throws GenericDataSourceException

Execute updates

Returns:

The number of rows updated

Throws:

GenericDataSourceException

executeUpdate

public int executeUpdate(String sql)
                  throws GenericDataSourceException

Execute update based on the SQL statement given

Parameters:

sql - SQL statement to be executed

Throws:

GenericDataSourceException

next

public boolean next()
             throws GenericDataSourceException

Test if there more records available

Returns:

true, if there more records available

Throws:

GenericDataSourceException

getResultSet

public ResultSet getResultSet()

Getter: get the currently active ResultSet

Returns:

ResultSet

getPreparedStatement

public PreparedStatement getPreparedStatement()

Getter: get the prepared statement

Returns:

PreparedStatement

execQuery

public void execQuery(String sql,
 ExecQueryCallbackFunctionIF aListener)
               throws GenericEntityException

Execute a query based on the SQL string given. For each record of the ResultSet return, execute a callback function

Parameters:

sql - The SQL string to be executed

aListener - The callback function object

Throws:

GenericEntityException

setValue

public <T> void setValue(JdbcValueHandler<T> handler,
 T field)
                  throws SQLException

Set the next binding variable of the currently active prepared statement.

Parameters:

handler -

field -

Throws:

SQLException

setValue

public void setValue(String field)
              throws SQLException

Set the next binding variable of the currently active prepared statement.

Parameters:

field -

Throws:

SQLException

setValue

public void setValue(Timestamp field)
              throws SQLException

Set the next binding variable of the currently active prepared statement.

Parameters:

field -

Throws:

SQLException

setValue

public void setValue(Time field)
              throws SQLException

Set the next binding variable of the currently active prepared statement.

Parameters:

field -

Throws:

SQLException

setValue

public void setValue(Date field)
              throws SQLException

Set the next binding variable of the currently active prepared statement.

Parameters:

field -

Throws:

SQLException

setValue

public void setValue(Integer field)
              throws SQLException

Set the next binding variable of the currently active prepared statement.

Parameters:

field -

Throws:

SQLException

setValue

public void setValue(Long field)
              throws SQLException

Set the next binding variable of the currently active prepared statement.

Parameters:

field -

Throws:

SQLException

setValue

public void setValue(Float field)
              throws SQLException

Set the next binding variable of the currently active prepared statement.

Parameters:

field -

Throws:

SQLException

setValue

public void setValue(Double field)
              throws SQLException

Set the next binding variable of the currently active prepared statement.

Parameters:

field -

Throws:

SQLException

setValue

public void setValue(BigDecimal field)
              throws SQLException

Set the next binding variable of the currently active prepared statement.

Parameters:

field -

Throws:

SQLException

setValue

public void setValue(Boolean field)
              throws SQLException

Set the next binding variable of the currently active prepared statement.

Parameters:

field -

Throws:

SQLException

setValue

public void setValue(Object field)
              throws SQLException

Set the next binding variable of the currently active prepared statement.

Parameters:

field -

Throws:

SQLException

setValue

public void setValue(Blob field)
              throws SQLException

Set the next binding variable of the currently active prepared statement

Parameters:

field -

Throws:

SQLException

setValue

public void setValue(Clob field)
              throws SQLException

Set the next binding variable of the currently active prepared statement

Parameters:

field -

Throws:

SQLException

setBinaryStream

public void setBinaryStream(Object field)
                     throws SQLException

Set the next binding variable of the currently active prepared statement to write the serialized data of 'field' to a BLOB.

Parameters:

field -

Throws:

SQLException

setBytes

public void setBytes(byte[] bytes)
              throws SQLException

Set the next binding variable of the currently active prepared statement to write the serialized data of 'field' to a Blob with the given bytes.

Parameters:

bytes -

Throws:

SQLException

testConnection

protected void testConnection(Connection con)
                       throws GenericEntityException

Test connection.

Parameters:

con - the con

Throws:

GenericEntityException - the generic entity exception

setFetchSize

protected void setFetchSize(Statement stmt,
 int fetchSize)
                     throws SQLException

Sets fetch size.

Parameters:

stmt - the stmt

fetchSize - the fetch size

Throws:

SQLException - the sql exception