public abstract class SQLConnector extends PooledConnector implements SQLConnectableExt
Object newConnection()
should return Object[]
, whereModifier and Type | Class and Description |
---|---|
protected static class |
SQLConnector.Chars |
SQLConnectable.QueryReader
Modifier and Type | Field and Description |
---|---|
protected java.util.Date |
actionStart |
protected SQLConnector.Chars |
columnLabelingOverride |
protected java.sql.Driver |
driver |
protected boolean |
enableScroll |
protected java.lang.String |
initSQL |
protected java.lang.ThreadLocal<java.sql.ResultSet> |
localResultSet |
protected java.lang.ThreadLocal<java.sql.ResultSetMetaData> |
localResultSetMetaData |
protected int |
preparedStatementCacheSize |
protected java.lang.String |
refreshSQL |
protected boolean |
unscaledAsLong |
allConnections, askingBusy, askingDedicated, debug, freeList, maxConnections, maxInactivity, maxLifeTime, maxUseCount
cluster, connectorClass, instance, name, properties, refreshInterval, scheduler, sharedConfiguration, url
Constructor and Description |
---|
SQLConnector(java.lang.String url,
java.util.Properties properties) |
Modifier and Type | Method and Description |
---|---|
void |
commit() |
void |
debugInit() |
static void |
debugSave(java.lang.String query,
java.lang.Object[] params,
long start,
long count,
int resultCount,
long startTime,
java.lang.String option) |
void |
dedicatedCommit() |
void |
dedicatedRollback() |
void |
dedicatedStart() |
void |
dedicatedStop() |
java.lang.Object |
executeFunction(java.lang.String query,
java.lang.Object[] params,
java.lang.String outType) |
java.lang.Object[] |
executePL_SQL(java.lang.String query,
java.lang.Object[] params,
java.lang.Object[] outTypeParams) |
java.lang.Object[] |
executeProcedure(java.lang.String query,
java.lang.Object[] params,
java.lang.Object[] outTypesParams) |
protected boolean |
executeSql(java.lang.String moduleName,
java.lang.String version,
java.util.Properties configProperties,
SQLBatch batch,
boolean pretend,
boolean insert) |
int |
fastRead(SQLConnectable.QueryReader reader,
java.lang.String query,
java.lang.Object... params) |
static java.util.Map<java.lang.Integer,java.lang.String> |
getConnectorTypes() |
java.lang.Object[] |
getInfo() |
java.sql.DatabaseMetaData |
getMetaData() |
static java.lang.String |
getOutTypeParamForClass(java.lang.Class clazz) |
java.sql.ResultSet |
getResultSet() |
java.sql.ResultSetMetaData |
getResultSetMetaData() |
java.lang.Long |
getSequence(java.lang.String sequenceName) |
java.lang.String |
info() |
protected void |
info(java.lang.StringBuilder s) |
void |
init() |
boolean |
isNoTransaction() |
boolean |
isTransaction() |
boolean |
needWriteLob() |
protected palio.connectors.SQLConnection |
newConnection(palio.connectors.PooledConnection oldConn) |
protected void |
newConnectionInit(java.sql.Connection connection) |
int |
read(SQLConnectable.QueryReader reader,
java.lang.String query,
java.lang.Object... params) |
protected java.util.LinkedList |
read(palio.connectors.SQLConnection conn,
java.lang.String query,
java.lang.Object[] params,
java.lang.Object[] outTypeParams,
long start,
int count,
java.lang.String paramNameRowCount,
int resultType) |
java.util.LinkedList |
read(java.lang.String query) |
void |
read(java.lang.String query,
Closure code) |
SQLQueryResult |
read(java.lang.String query,
long start,
int count) |
void |
read(java.lang.String query,
java.lang.Long start,
java.lang.Integer count,
Closure code)
Deprecated.
|
java.util.LinkedList |
read(java.lang.String query,
java.lang.Long start,
java.lang.Integer count,
java.lang.String paramNameRowCount)
Deprecated.
|
java.util.LinkedList |
read(java.lang.String query,
java.lang.Object[] params) |
void |
read(java.lang.String query,
java.lang.Object[] params,
Closure code) |
void |
read(java.lang.String query,
java.lang.Object[] params,
java.lang.Long start,
java.lang.Integer count,
Closure code)
Deprecated.
|
java.util.LinkedList |
read(java.lang.String query,
java.lang.Object[] params,
java.lang.Long start,
java.lang.Integer count,
java.lang.String paramNameRowCount)
Deprecated.
|
java.util.LinkedList |
read(java.lang.String query,
java.lang.Object[] params,
java.lang.Object[] outTypeParams) |
void |
read(java.lang.String query,
java.lang.Object[] params,
java.lang.Object[] outTypeParams,
Closure code) |
void |
read(java.lang.String query,
java.lang.Object[] params,
java.lang.Object[] outTypeParams,
long start,
int count,
Closure code) |
java.util.LinkedList |
read(java.lang.String query,
java.lang.Object[] params,
java.lang.Object[] outTypeParams,
java.lang.Long start,
java.lang.Integer count,
java.lang.String paramNameRowCount)
Deprecated.
|
java.util.LinkedList |
read(java.lang.String query,
java.lang.Object[] params,
java.lang.Object[] outTypeParams,
long start,
int count,
java.lang.String paramNameRowCount) |
void |
read(java.lang.String query,
java.lang.Object[] params,
java.lang.Object[] outTypeParams,
java.lang.Long start,
java.lang.Long count,
Closure code) |
java.util.LinkedList |
read(java.lang.String query,
java.lang.Object[] params,
java.lang.Object[] outTypeParams,
java.lang.Long start,
java.lang.Long count,
java.lang.String paramNameRowCount) |
void |
read(java.lang.String rowParamName,
java.lang.String query,
java.lang.Long start,
java.lang.Integer count,
PalioCode code)
Deprecated.
|
void |
read(java.lang.String rowParamName,
java.lang.String query,
java.lang.Object[] params,
java.lang.Long start,
java.lang.Integer count,
PalioCode code)
Deprecated.
|
void |
read(java.lang.String rowParamName,
java.lang.String query,
java.lang.Object[] params,
java.lang.Object[] outTypeParams,
long start,
int count,
PalioCode code) |
void |
read(java.lang.String rowParamName,
java.lang.String query,
java.lang.Object[] params,
java.lang.Object[] outTypeParams,
java.lang.Long start,
java.lang.Long count,
PalioCode code) |
void |
read(java.lang.String rowParamName,
java.lang.String query,
java.lang.Object[] params,
java.lang.Object[] outTypeParams,
PalioCode code) |
void |
read(java.lang.String rowParamName,
java.lang.String query,
java.lang.Object[] params,
PalioCode code) |
void |
read(java.lang.String rowParamName,
java.lang.String query,
PalioCode code) |
java.util.LinkedList |
readAsMaps(java.lang.String query) |
java.util.LinkedList |
readAsMaps(java.lang.String query,
java.lang.Long start,
java.lang.Integer count,
java.lang.String paramNameRowCount)
Deprecated.
|
java.util.LinkedList |
readAsMaps(java.lang.String query,
java.lang.Object[] params) |
java.util.LinkedList |
readAsMaps(java.lang.String query,
java.lang.Object[] params,
java.lang.Long start,
java.lang.Integer count,
java.lang.String paramNameRowCount)
Deprecated.
|
java.util.LinkedList |
readAsMaps(java.lang.String query,
java.lang.Object[] params,
java.lang.Object[] outTypeParams) |
java.util.LinkedList |
readAsMaps(java.lang.String query,
java.lang.Object[] params,
java.lang.Object[] outTypeParams,
java.lang.Long start,
java.lang.Integer count,
java.lang.String paramNameRowCount) |
java.util.LinkedList |
readAsMaps(java.lang.String query,
java.lang.Object[] params,
java.lang.Object[] outTypeParams,
java.lang.Long start,
java.lang.Long count,
java.lang.String paramNameRowCount) |
protected java.lang.Object[] |
readLine(palio.connectors.SQLConnection conn,
java.lang.String query,
java.lang.Object[] params,
java.lang.Object[] outTypeParams) |
java.lang.Object[] |
readLine(java.lang.String query) |
java.lang.Object[] |
readLine(java.lang.String query,
java.lang.Object[] params) |
java.lang.Object[] |
readLine(java.lang.String query,
java.lang.Object[] params,
java.lang.Object[] outTypeParams) |
java.util.HashMap |
readLineAsMap(java.lang.String query) |
java.util.HashMap |
readLineAsMap(java.lang.String query,
java.lang.Object[] params) |
java.util.HashMap |
readLineAsMap(java.lang.String query,
java.lang.Object[] params,
java.lang.Object[] outTypeParams) |
protected void |
refreshConnection(palio.connectors.PooledConnection connection) |
protected java.lang.Object |
resolveDataValue(java.sql.ResultSet rSet,
int column) |
protected int |
resolveJavaType(java.lang.Class javaClass,
boolean function) |
void |
rollback() |
protected void |
setFetchSize(palio.connectors.SQLConnection conn,
java.sql.Statement stat,
int count) |
void |
transactionStart() |
void |
transactionStop() |
java.lang.Integer[] |
write(java.lang.Object[] queries) |
protected java.lang.Integer |
write(palio.connectors.SQLConnection conn,
java.lang.String query,
java.lang.Object[] params) |
java.lang.Integer |
write(java.lang.String query) |
java.lang.Integer |
write(java.lang.String query,
java.lang.Object[] params) |
protected void |
writeBlob(java.sql.Blob blob,
byte[] body) |
protected void |
writeBlob(java.sql.Blob blob,
java.lang.Object body) |
protected void |
writeClob(java.sql.Clob clob,
java.lang.String body) |
void |
writeLob(java.lang.String selectLob,
java.lang.Object body) |
void |
writeLob(java.lang.String selectLob,
java.lang.Object[] params,
java.lang.Object body) |
BusyChecker, clearThreadResources, close, connect, DedicateChecker, FreeChecker, getConnection, getDedicatedConnection, getFreeConnection, getIntParam, putConnection, reconnect, refresh, setDedicated, unsetDedicated
delete, getAsPalioConnector, getConnector, getConnector, getInstance, getLogConfiguration, getName, getUrl, init, log, logDebug, logError, logError, logWarning, save, scheduler, setDedicatedLogConfiguration, setInstance
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getName, getType, getUrl, setInstance
protected final java.lang.ThreadLocal<java.sql.ResultSet> localResultSet
protected final java.lang.ThreadLocal<java.sql.ResultSetMetaData> localResultSetMetaData
protected java.sql.Driver driver
protected java.lang.String initSQL
protected java.lang.String refreshSQL
protected boolean enableScroll
protected java.util.Date actionStart
protected int preparedStatementCacheSize
protected SQLConnector.Chars columnLabelingOverride
protected boolean unscaledAsLong
public SQLConnector(java.lang.String url, java.util.Properties properties)
public static java.util.Map<java.lang.Integer,java.lang.String> getConnectorTypes()
public void init() throws PalioException
init
in interface SQLConnectable
init
in class PooledConnector
PalioException
public void debugInit()
public static void debugSave(java.lang.String query, java.lang.Object[] params, long start, long count, int resultCount, long startTime, java.lang.String option)
public java.lang.Long getSequence(java.lang.String sequenceName) throws PalioException
getSequence
in interface SQLConnectable
PalioException
protected java.lang.Object resolveDataValue(java.sql.ResultSet rSet, int column) throws java.sql.SQLException
java.sql.SQLException
protected int resolveJavaType(java.lang.Class javaClass, boolean function)
protected void writeBlob(java.sql.Blob blob, byte[] body) throws java.lang.Exception
java.lang.Exception
protected void writeBlob(java.sql.Blob blob, java.lang.Object body) throws java.lang.Exception
java.lang.Exception
protected void writeClob(java.sql.Clob clob, java.lang.String body) throws java.lang.Exception
java.lang.Exception
public boolean needWriteLob()
needWriteLob
in interface SQLConnectable
protected void newConnectionInit(java.sql.Connection connection) throws java.sql.SQLException
java.sql.SQLException
protected palio.connectors.SQLConnection newConnection(palio.connectors.PooledConnection oldConn) throws java.sql.SQLException
newConnection
in class PooledConnector
java.sql.SQLException
protected void setFetchSize(palio.connectors.SQLConnection conn, java.sql.Statement stat, int count) throws java.sql.SQLException
java.sql.SQLException
public static java.lang.String getOutTypeParamForClass(java.lang.Class clazz)
public java.util.LinkedList read(java.lang.String query, java.lang.Object[] params, java.lang.Object[] outTypeParams, java.lang.Long start, java.lang.Long count, java.lang.String paramNameRowCount) throws PalioException
read
in interface SQLConnectable
PalioException
public java.util.LinkedList read(java.lang.String query, java.lang.Object[] params, java.lang.Object[] outTypeParams, long start, int count, java.lang.String paramNameRowCount) throws PalioException
read
in interface SQLConnectable
PalioException
public java.util.LinkedList readAsMaps(java.lang.String query, java.lang.Object[] params, java.lang.Object[] outTypeParams, java.lang.Long start, java.lang.Long count, java.lang.String paramNameRowCount) throws PalioException
readAsMaps
in interface SQLConnectable
PalioException
public final java.lang.Object[] readLine(java.lang.String query, java.lang.Object[] params, java.lang.Object[] outTypeParams) throws PalioException
readLine
in interface SQLConnectable
PalioException
protected final java.lang.Object[] readLine(palio.connectors.SQLConnection conn, java.lang.String query, java.lang.Object[] params, java.lang.Object[] outTypeParams) throws PalioException
PalioException
public final java.util.HashMap readLineAsMap(java.lang.String query, java.lang.Object[] params, java.lang.Object[] outTypeParams) throws PalioException
readLineAsMap
in interface SQLConnectable
PalioException
protected java.util.LinkedList read(palio.connectors.SQLConnection conn, java.lang.String query, java.lang.Object[] params, java.lang.Object[] outTypeParams, long start, int count, java.lang.String paramNameRowCount, int resultType) throws PalioException
PalioException
public final SQLQueryResult read(java.lang.String query, long start, int count) throws PalioException
PalioException
public final int read(SQLConnectable.QueryReader reader, java.lang.String query, java.lang.Object... params) throws PalioException
read
in interface SQLConnectable
PalioException
public final int fastRead(SQLConnectable.QueryReader reader, java.lang.String query, java.lang.Object... params) throws PalioException
fastRead
in interface SQLConnectable
PalioException
public final void read(java.lang.String rowParamName, java.lang.String query, java.lang.Object[] params, java.lang.Object[] outTypeParams, java.lang.Long start, java.lang.Long count, PalioCode code) throws PalioException
read
in interface SQLConnectable
PalioException
public final void read(java.lang.String rowParamName, java.lang.String query, java.lang.Object[] params, java.lang.Object[] outTypeParams, long start, int count, PalioCode code) throws PalioException
PalioException
public final void read(java.lang.String query, java.lang.Object[] params, java.lang.Object[] outTypeParams, java.lang.Long start, java.lang.Long count, Closure code) throws PalioException
read
in interface SQLConnectable
PalioException
public final void read(java.lang.String query, java.lang.Object[] params, java.lang.Object[] outTypeParams, long start, int count, Closure code) throws PalioException
read
in interface SQLConnectable
PalioException
public final java.lang.Integer write(java.lang.String query) throws PalioException
write
in interface SQLConnectable
PalioException
public final java.lang.Integer write(java.lang.String query, java.lang.Object[] params) throws PalioException
write
in interface SQLConnectable
PalioException
protected final java.lang.Integer write(palio.connectors.SQLConnection conn, java.lang.String query, java.lang.Object[] params) throws PalioException
PalioException
public final java.lang.Integer[] write(java.lang.Object[] queries) throws PalioException
write
in interface SQLConnectable
PalioException
public final java.lang.Object[] executePL_SQL(java.lang.String query, java.lang.Object[] params, java.lang.Object[] outTypeParams) throws PalioException
executePL_SQL
in interface SQLConnectable
PalioException
public final java.lang.Object executeFunction(java.lang.String query, java.lang.Object[] params, java.lang.String outType) throws PalioException
executeFunction
in interface SQLConnectable
PalioException
public final java.lang.Object[] executeProcedure(java.lang.String query, java.lang.Object[] params, java.lang.Object[] outTypesParams) throws PalioException
executeProcedure
in interface SQLConnectable
PalioException
public final void dedicatedStart() throws PalioException
dedicatedStart
in interface DedicatedConnectionSupport
PalioException
public final void dedicatedStop()
dedicatedStop
in interface DedicatedConnectionSupport
public void dedicatedCommit() throws PalioException
dedicatedCommit
in interface DedicatedConnectionSupport
PalioException
public void dedicatedRollback()
dedicatedRollback
in interface DedicatedConnectionSupport
public final void transactionStart() throws PalioException
transactionStart
in interface SQLConnectable
PalioException
public final void transactionStop() throws PalioException
transactionStop
in interface SQLConnectable
PalioException
public void commit() throws PalioException
commit
in interface SQLConnectable
PalioException
public void rollback() throws PalioException
rollback
in interface SQLConnectable
PalioException
public boolean isTransaction()
isTransaction
in interface DedicatedConnectionSupport
isTransaction
in interface SQLConnectable
public boolean isNoTransaction()
isNoTransaction
in interface SQLConnectable
public void writeLob(java.lang.String selectLob, java.lang.Object[] params, java.lang.Object body) throws PalioException
writeLob
in interface SQLConnectable
PalioException
public void writeLob(java.lang.String selectLob, java.lang.Object body) throws PalioException
writeLob
in interface SQLConnectable
PalioException
public final java.sql.DatabaseMetaData getMetaData() throws PalioException
getMetaData
in interface SQLConnectable
PalioException
public java.sql.ResultSet getResultSet()
getResultSet
in interface SQLConnectable
public java.sql.ResultSetMetaData getResultSetMetaData()
getResultSetMetaData
in interface SQLConnectable
protected final void refreshConnection(palio.connectors.PooledConnection connection) throws java.sql.SQLException
java.sql.SQLException
public java.lang.Object[] getInfo()
getInfo
in class PooledConnector
public java.lang.String info()
info
in class PooledConnector
protected void info(java.lang.StringBuilder s)
info
in class PooledConnector
protected boolean executeSql(java.lang.String moduleName, java.lang.String version, java.util.Properties configProperties, SQLBatch batch, boolean pretend, boolean insert) throws PalioException
PalioException
public final java.util.LinkedList read(java.lang.String query) throws PalioException
read
in interface SQLConnectable
PalioException
public final java.util.LinkedList read(java.lang.String query, java.lang.Object[] params) throws PalioException
read
in interface SQLConnectable
PalioException
public final java.util.LinkedList read(java.lang.String query, java.lang.Object[] params, java.lang.Object[] outTypeParams) throws PalioException
read
in interface SQLConnectable
PalioException
@Deprecated public final java.util.LinkedList read(java.lang.String query, java.lang.Long start, java.lang.Integer count, java.lang.String paramNameRowCount) throws PalioException
read
in interface SQLConnectable
PalioException
@Deprecated public final java.util.LinkedList read(java.lang.String query, java.lang.Object[] params, java.lang.Long start, java.lang.Integer count, java.lang.String paramNameRowCount) throws PalioException
read
in interface SQLConnectable
PalioException
@Deprecated public final java.util.LinkedList read(java.lang.String query, java.lang.Object[] params, java.lang.Object[] outTypeParams, java.lang.Long start, java.lang.Integer count, java.lang.String paramNameRowCount) throws PalioException
read
in interface SQLConnectable
PalioException
public final void read(java.lang.String rowParamName, java.lang.String query, PalioCode code) throws PalioException
read
in interface SQLConnectable
PalioException
public final void read(java.lang.String rowParamName, java.lang.String query, java.lang.Object[] params, PalioCode code) throws PalioException
read
in interface SQLConnectable
PalioException
public final void read(java.lang.String rowParamName, java.lang.String query, java.lang.Object[] params, java.lang.Object[] outTypeParams, PalioCode code) throws PalioException
read
in interface SQLConnectable
PalioException
@Deprecated public final void read(java.lang.String rowParamName, java.lang.String query, java.lang.Long start, java.lang.Integer count, PalioCode code) throws PalioException
read
in interface SQLConnectable
PalioException
@Deprecated public final void read(java.lang.String rowParamName, java.lang.String query, java.lang.Object[] params, java.lang.Long start, java.lang.Integer count, PalioCode code) throws PalioException
read
in interface SQLConnectable
PalioException
public final void read(java.lang.String query, Closure code) throws PalioException
read
in interface SQLConnectable
PalioException
public final void read(java.lang.String query, java.lang.Object[] params, Closure code) throws PalioException
read
in interface SQLConnectable
PalioException
public final void read(java.lang.String query, java.lang.Object[] params, java.lang.Object[] outTypeParams, Closure code) throws PalioException
read
in interface SQLConnectable
PalioException
@Deprecated public final void read(java.lang.String query, java.lang.Long start, java.lang.Integer count, Closure code) throws PalioException
read
in interface SQLConnectable
PalioException
@Deprecated public final void read(java.lang.String query, java.lang.Object[] params, java.lang.Long start, java.lang.Integer count, Closure code) throws PalioException
read
in interface SQLConnectable
PalioException
public final java.util.LinkedList readAsMaps(java.lang.String query) throws PalioException
readAsMaps
in interface SQLConnectable
PalioException
public final java.util.LinkedList readAsMaps(java.lang.String query, java.lang.Object[] params) throws PalioException
readAsMaps
in interface SQLConnectable
PalioException
public final java.util.LinkedList readAsMaps(java.lang.String query, java.lang.Object[] params, java.lang.Object[] outTypeParams) throws PalioException
readAsMaps
in interface SQLConnectable
PalioException
@Deprecated public final java.util.LinkedList readAsMaps(java.lang.String query, java.lang.Long start, java.lang.Integer count, java.lang.String paramNameRowCount) throws PalioException
readAsMaps
in interface SQLConnectable
PalioException
@Deprecated public final java.util.LinkedList readAsMaps(java.lang.String query, java.lang.Object[] params, java.lang.Long start, java.lang.Integer count, java.lang.String paramNameRowCount) throws PalioException
readAsMaps
in interface SQLConnectable
PalioException
public final java.util.LinkedList readAsMaps(java.lang.String query, java.lang.Object[] params, java.lang.Object[] outTypeParams, java.lang.Long start, java.lang.Integer count, java.lang.String paramNameRowCount) throws PalioException
readAsMaps
in interface SQLConnectable
PalioException
public final java.lang.Object[] readLine(java.lang.String query) throws PalioException
readLine
in interface SQLConnectable
PalioException
public final java.lang.Object[] readLine(java.lang.String query, java.lang.Object[] params) throws PalioException
readLine
in interface SQLConnectable
PalioException
public final java.util.HashMap readLineAsMap(java.lang.String query) throws PalioException
readLineAsMap
in interface SQLConnectable
PalioException
public final java.util.HashMap readLineAsMap(java.lang.String query, java.lang.Object[] params) throws PalioException
readLineAsMap
in interface SQLConnectable
PalioException