Package org.compiere.util

Class DBReadReplica

java.lang.Object

org.compiere.util.DBReadReplica

public class DBReadReplica
extends Object

Support class for read only replica DB

Constructor Summary

Constructors

Constructor	Description
DBReadReplica()

Method Summary

Modifier and Type	Method	Description
static void	closeReadReplicaStatement(Statement st)
static Connection	getConnectionRO()	Get read only connection from replica DB
static PreparedStatement	prepareNormalReadReplicaStatement(String sql, int resultSetType, int resultSetConcurrency, String trxName)	Prepare Normal Read Replica Statement

Methods inherited from class java.lang.Object

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

Constructor Details

DBReadReplica

public DBReadReplica()

Method Details

prepareNormalReadReplicaStatement

public static PreparedStatement prepareNormalReadReplicaStatement(String sql,
 int resultSetType,
 int resultSetConcurrency,
 String trxName)

Prepare Normal Read Replica Statement

Parameters:

sql - sql statement

resultSetType - - ResultSet.TYPE_FORWARD_ONLY, ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.TYPE_SCROLL_SENSITIVE

resultSetConcurrency - - ResultSet.CONCUR_READ_ONLY or ResultSet.CONCUR_UPDATABLE

trxName - transaction

Returns:

Prepared Statement (from replica if possible, otherwise null)

closeReadReplicaStatement

public static void closeReadReplicaStatement(Statement st)

getConnectionRO

public static Connection getConnectionRO()

Get read only connection from replica DB

Returns:

connection