com.oceanbase.jdbc

类 JDBC4ServerPreparedStatement

java.lang.Object

com.oceanbase.jdbc.OceanBaseStatement

com.oceanbase.jdbc.BasePrepareStatement

com.oceanbase.jdbc.JDBC4ServerPreparedStatement

所有已实现的接口:

ObPrepareStatement, AutoCloseable, Cloneable, PreparedStatement, Statement, Wrapper

直接已知子类:

ServerSidePreparedStatement

public class JDBC4ServerPreparedStatement
extends BasePrepareStatement
implements Cloneable

字段概要

字段

限定符和类型	字段和说明
protected Map<Integer,ParameterHolder>	currentParameterHolder
protected boolean	isObFunction
protected List<ParameterHolder[]>	parametersList
protected ServerPrepareResult	serverPrepareResult

从类继承的字段 com.oceanbase.jdbc.BasePrepareStatement

autoGeneratedKeys, hasLongData, indexMap, parameterCount, SPEC_ISO_ZONED_DATE_TIME

从类继承的字段 com.oceanbase.jdbc.OceanBaseStatement

actualSql, addRowid, batchQueries, canUseServerTimeout, connection, exceptionFactory, executing, fetchSize, isFetchSizeSet, isInternal, lock, lockLogger, maxRows, options, originalSql, protocol, queryTimeout, results, resultSetConcurrency, resultSetScrollType, selectEndPos, simpleSql, sqlType, status, STMT_ALTER, STMT_BEGIN, STMT_CALL, STMT_CREATE, STMT_DECLARE, STMT_DELETE, STMT_DROP, STMT_INSERT, STMT_SELECT, STMT_UNINITIALIZED, STMT_UNKNOWN, STMT_UPDATE, tableName, whereEndPos

从接口继承的字段 java.sql.Statement

CLOSE_ALL_RESULTS, CLOSE_CURRENT_RESULT, EXECUTE_FAILED, KEEP_CURRENT_RESULT, NO_GENERATED_KEYS, RETURN_GENERATED_KEYS, SUCCESS_NO_INFO

构造器概要

构造器

构造器和说明
JDBC4ServerPreparedStatement(boolean isObFunction, OceanBaseConnection connection, String sql, int resultSetScrollType, int resultSetConcurrency, int autoGeneratedKeys, ExceptionFactory exceptionFactory) Constructor for creating Server prepared statement.

方法概要

限定符和类型	方法和说明
void	addBatch()
void	addBatch(String sql) Adds the given SQL command to the current list of commands for this Statement object.
void	clearBatch() Empties this Statement object's current list of SQL send.
void	clearParameters()
JDBC4ServerPreparedStatement	clone(OceanBaseConnection connection) Clone statement.
void	close() Releases this Statement object's database and JDBC resources immediately instead of waiting for this to happen when it is automatically closed.
void	closeCursor(int cursorId)
ColumnDefinition[]	cursorFetch(int cursorId, int fetchSize)
ColumnDefinition[]	cursorFetchForOracle(int cursorId, int numRows, byte offsetType, int offset)
boolean	execute()
int[]	executeBatch() Submits a batch of send to the database for execution and if all send execute successfully, returns an array of update counts.
int[]	executeBatchQuerys()
protected boolean	executeInternal(int fetchSize)
long[]	executeLargeBatch() Execute batch, like executeBatch(), with returning results with long[].
long[]	executeLargeBatchQuerys()
long	executeLargeUpdate()
ResultSet	executeQuery()
int	executeUpdate() Executes the SQL statement in this PreparedStatement object, which must be an SQL Data Manipulation Language (DML) statement, such as INSERT, UPDATE or DELETE; or an SQL statement that returns nothing, such as a DDL statement.
ResultSet	getGeneratedKeys() Retrieves any auto-generated keys created as a result of executing this Statement object.
ResultSetMetaData	getMetaData()
ParameterMetaData	getParameterMetaData() Retrieves the number, types and properties of this PreparedStatement object's parameters.
ParameterHolder[]	getParameters()
ResultSet	getReturnResultSet()
long	getServerThreadId() Permit to retrieve current connection thread id, or -1 if unknown.
protected boolean	prepareExecuteInternal(int fetchSize)
void	realClose(boolean calledExplicitly, boolean closeOpenResults)
void	registerReturnAutoGeneratedKey(AutoGeneratedKey autoGeneratedKey)
void	registerReturnParameter(int parameterIndex, int externalType)
void	registerReturnParameter(int parameterIndex, int externalType, int maximumSize)
void	registerReturnParameter(int parameterIndex, int externalType, String internalTypeName)
void	setParameter(int parameterIndex, ParameterHolder holder)
void	setParameters(ParameterHolder[] paramArray)
String	toString() Return sql String value.
protected void	validParameters()

从类继承的方法 com.oceanbase.jdbc.BasePrepareStatement

asSql, getParameterCount, setArray, setAsciiStream, setAsciiStream, setAsciiStream, setBigDecimal, setBINARY_DOUBLE, setBINARY_FLOAT, setBinaryStream, setBinaryStream, setBinaryStream, setBlob, setBlob, setBlob, setBoolean, setByte, setBytes, setCharacterStream, setCharacterStream, setCharacterStream, setClob, setClob, setClob, setDate, setDate, setDouble, setFixedCHAR, setFloat, setIndexMap, setInt, setINTERVALDS, setINTERVALYM, setLobLocator, setLocalDateTime, setLong, setNCharacterStream, setNCharacterStream, setNClob, setNClob, setNClob, setNString, setNull, setNull, setNull, setNUMBER_FLOAT, setNUMBER, setObject, setObject, setObject, setObject, setObject, setParameterCount, setRef, setRowId, setShort, setSQLXML, setString, setStruct, setTime, setTime, setTimestamp, setTIMESTAMP, setTimestamp, setTIMESTAMPLTZ, setTIMESTAMPTZ, setUnicodeStream, setURL

从类继承的方法 com.oceanbase.jdbc.OceanBaseStatement

cancel, checkClose, checkCloseOnCompletion, clearWarnings, closeOnCompletion, enquoteIdentifier, enquoteLiteral, enquoteNCharLiteral, execute, execute, execute, execute, executeBatchEpilogue, executeBatchExceptionEpilogue, executeBatchExceptionEpilogue, executeEpilogue, executeExceptionEpilogue, executeLargeUpdate, executeLargeUpdate, executeLargeUpdate, executeLargeUpdate, executeQuery, executeQueryPrologue, executeUpdate, executeUpdate, executeUpdate, executeUpdate, getActualSql, getConnection, getFetchDirection, getFetchSize, getLargeMaxRows, getLargeUpdateCount, getMaxFieldSize, getMaxRows, getMoreResults, getMoreResults, getQueryTimeout, getResults, getResultSet, getResultSetConcurrency, getResultSetHoldability, getResultSetType, getServerInfo, getSqlType, getSqlType, getUpdateCount, getWarnings, getWhereEndPos, isAddRowid, isClosed, isCloseOnCompletion, isCursorResultSet, isDml, isInternal, isPoolable, isSimpleIdentifier, isWrapperFor, setCursorName, setEscapeProcessing, setFetchDirection, setFetchSize, setInternal, setLargeMaxRows, setLocalInfileInputStream, setMaxFieldSize, setMaxRows, setPoolable, setQueryTimeout, setTimerTask, skipMoreResults, testExecute, unwrap

从类继承的方法 java.lang.Object

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

从接口继承的方法 java.sql.Statement

cancel, clearWarnings, closeOnCompletion, execute, execute, execute, execute, executeLargeUpdate, executeLargeUpdate, executeLargeUpdate, executeLargeUpdate, executeQuery, executeUpdate, executeUpdate, executeUpdate, executeUpdate, getConnection, getFetchDirection, getFetchSize, getLargeMaxRows, getLargeUpdateCount, getMaxFieldSize, getMaxRows, getMoreResults, getMoreResults, getQueryTimeout, getResultSet, getResultSetConcurrency, getResultSetHoldability, getResultSetType, getUpdateCount, getWarnings, isClosed, isCloseOnCompletion, isPoolable, setCursorName, setEscapeProcessing, setFetchDirection, setFetchSize, setLargeMaxRows, setMaxFieldSize, setMaxRows, setPoolable, setQueryTimeout

从接口继承的方法 java.sql.Wrapper

isWrapperFor, unwrap

字段详细资料

isObFunction

protected boolean isObFunction

currentParameterHolder

protected Map<Integer,ParameterHolder> currentParameterHolder

parametersList

protected List<ParameterHolder[]> parametersList

serverPrepareResult

protected ServerPrepareResult serverPrepareResult

构造器详细资料

JDBC4ServerPreparedStatement

public JDBC4ServerPreparedStatement(boolean isObFunction,
                                    OceanBaseConnection connection,
                                    String sql,
                                    int resultSetScrollType,
                                    int resultSetConcurrency,
                                    int autoGeneratedKeys,
                                    ExceptionFactory exceptionFactory)
                             throws SQLException

Constructor for creating Server prepared statement.

参数:

connection - current connection

sql - Sql String to prepare

resultSetScrollType - one of the following ResultSet constants: ResultSet.TYPE_FORWARD_ONLY, ResultSet.TYPE_SCROLL_INSENSITIVE, or ResultSet.TYPE_SCROLL_SENSITIVE

resultSetConcurrency - a concurrency type; one of ResultSet.CONCUR_READ_ONLY or ResultSet.CONCUR_UPDATABLE

autoGeneratedKeys - a flag indicating whether auto-generated keys should be returned; one of Statement.RETURN_GENERATED_KEYS or Statement.NO_GENERATED_KEYS

exceptionFactory - Exception factory

抛出:

SQLException - exception

方法详细资料

clone

public JDBC4ServerPreparedStatement clone(OceanBaseConnection connection)
                                   throws CloneNotSupportedException

Clone statement.

覆盖:

clone 在类中 BasePrepareStatement

参数:

connection - connection

返回:

Clone statement.

抛出:

CloneNotSupportedException - if any error occur.

setParameter

public void setParameter(int parameterIndex,
                         ParameterHolder holder)
                  throws SQLException

指定者:

setParameter 在类中 BasePrepareStatement

抛出:

SQLException

registerReturnParameter

public void registerReturnParameter(int parameterIndex,
                                    int externalType)
                             throws SQLException

抛出:

SQLException

registerReturnParameter

public void registerReturnParameter(int parameterIndex,
                                    int externalType,
                                    int maximumSize)
                             throws SQLException

抛出:

SQLException

registerReturnParameter

public void registerReturnParameter(int parameterIndex,
                                    int externalType,
                                    String internalTypeName)
                             throws SQLException

抛出:

SQLException

registerReturnAutoGeneratedKey

public void registerReturnAutoGeneratedKey(AutoGeneratedKey autoGeneratedKey)
                                    throws SQLException

抛出:

SQLException

getParameterMetaData

public ParameterMetaData getParameterMetaData()
                                       throws SQLException

从类复制的说明: BasePrepareStatement

Retrieves the number, types and properties of this PreparedStatement object's parameters.

指定者:

getParameterMetaData 在接口中 PreparedStatement

指定者:

getParameterMetaData 在类中 BasePrepareStatement

返回:

a ParameterMetaData object that contains information about the number, types and properties for each parameter marker of this PreparedStatement object

抛出:

SQLException - if a database access error occurs or this method is called on a closed PreparedStatement

另请参阅:

ParameterMetaData

getMetaData

public ResultSetMetaData getMetaData()
                              throws SQLException

指定者:

getMetaData 在接口中 PreparedStatement

抛出:

SQLException

getParameters

public ParameterHolder[] getParameters()

指定者:

getParameters 在类中 BasePrepareStatement

setParameters

public void setParameters(ParameterHolder[] paramArray)

指定者:

setParameters 在类中 BasePrepareStatement

clearParameters

public void clearParameters()
                     throws SQLException

指定者:

clearParameters 在接口中 PreparedStatement

抛出:

SQLException

validParameters

protected void validParameters()
                        throws SQLException

抛出:

SQLException

addBatch

public void addBatch()
              throws SQLException

指定者:

addBatch 在接口中 PreparedStatement

抛出:

SQLException

addBatch

public void addBatch(String sql)
              throws SQLException

从类复制的说明: OceanBaseStatement

Adds the given SQL command to the current list of commands for this Statement object. The send in this list can be executed as a batch by calling the method executeBatch.

指定者:

addBatch 在接口中 Statement

覆盖:

addBatch 在类中 OceanBaseStatement

参数:

sql - typically this is a SQL INSERT or UPDATE statement

抛出:

SQLException - if a database access error occurs, this method is called on a closed Statement or the driver does not support batch updates

另请参阅:

OceanBaseStatement.executeBatch(), DatabaseMetaData.supportsBatchUpdates()

clearBatch

public void clearBatch()

从类复制的说明: OceanBaseStatement

Empties this Statement object's current list of SQL send.

指定者:

clearBatch 在接口中 Statement

覆盖:

clearBatch 在类中 OceanBaseStatement

另请参阅:

OceanBaseStatement.addBatch(java.lang.String), DatabaseMetaData.supportsBatchUpdates()

executeBatch

public int[] executeBatch()
                   throws SQLException

Submits a batch of send to the database for execution and if all send execute successfully, returns an array of update counts. The int elements of the array that is returned are ordered to correspond to the send in the batch, which are ordered according to the order in which they were added to the batch. The elements in the array returned by the method executeBatch may be one of the following:

1. A number greater than or equal to zero -- indicates that the command was processed successfully and is an update count giving the number of rows in the database that were affected by the command's execution
2. A value of SUCCESS_NO_INFO -- indicates that the command was processed successfully but that the number of rows affected is unknown. If one of the send in a batch update fails to execute properly, this method throws a BatchUpdateException , and a JDBC driver may or may not continue to process the remaining send in the batch. However, the driver's behavior must be consistent with a particular DBMS, either always continuing to process send or never continuing to process send. If the driver continues processing after a failure, the array returned by the method BatchUpdateException.getUpdateCounts will contain as many elements as there are send in the batch, and at least one of the elements will be the following:
3. A value of EXECUTE_FAILED -- indicates that the command failed to execute successfully and occurs only if a driver continues to process send after a command fails

The possible implementations and return values have been modified in the Java 2 SDK, Standard Edition, version 1.3 to accommodate the option of continuing to proccess send in a batch update after a BatchUpdateException object has been thrown.

指定者:

executeBatch 在接口中 Statement

覆盖:

executeBatch 在类中 OceanBaseStatement

返回:

an array of update counts containing one element for each command in the batch. The elements of the array are ordered according to the order in which send were added to the batch.

抛出:

SQLException - if a database access error occurs, this method is called on a closed Statement or the driver does not support batch statements. Throws BatchUpdateException (a subclass of SQLException) if one of the send sent to the database fails to execute properly or attempts to return a result set.

从以下版本开始:

1.3

另请参阅:

addBatch(), DatabaseMetaData.supportsBatchUpdates()

executeBatchQuerys

public int[] executeBatchQuerys()
                         throws SQLException

抛出:

SQLException

executeLargeBatch

public long[] executeLargeBatch()
                         throws SQLException

Execute batch, like executeBatch(), with returning results with long[]. For when row count may exceed Integer.MAX_VALUE.

指定者:

executeLargeBatch 在接口中 Statement

覆盖:

executeLargeBatch 在类中 OceanBaseStatement

返回:

an array of update counts (one element for each command in the batch)

抛出:

SQLException - if a database error occur.

executeLargeBatchQuerys

public long[] executeLargeBatchQuerys()
                               throws SQLException

抛出:

SQLException

executeQuery

public ResultSet executeQuery()
                       throws SQLException

指定者:

executeQuery 在接口中 PreparedStatement

抛出:

SQLException

executeLargeUpdate

public long executeLargeUpdate()
                        throws SQLException

指定者:

executeLargeUpdate 在接口中 PreparedStatement

覆盖:

executeLargeUpdate 在类中 BasePrepareStatement

抛出:

SQLException

executeUpdate

public int executeUpdate()
                  throws SQLException

Executes the SQL statement in this PreparedStatement object, which must be an SQL Data Manipulation Language (DML) statement, such as INSERT, UPDATE or DELETE; or an SQL statement that returns nothing, such as a DDL statement. Result-set are permitted for historical reason, even if spec indicate to throw exception.

指定者:

executeUpdate 在接口中 PreparedStatement

返回:

either (1) the row count for SQL Data Manipulation Language (DML) statements or (2) 0 for SQL statements that return nothing

抛出:

SQLException - if a database access error occurs; this method is called on a closed PreparedStatement

execute

public boolean execute()
                throws SQLException

指定者:

execute 在接口中 PreparedStatement

抛出:

SQLException

executeInternal

protected boolean executeInternal(int fetchSize)
                           throws SQLException

指定者:

executeInternal 在类中 BasePrepareStatement

抛出:

SQLException

prepareExecuteInternal

protected boolean prepareExecuteInternal(int fetchSize)
                                  throws SQLException

抛出:

SQLException

cursorFetch

public ColumnDefinition[] cursorFetch(int cursorId,
                                      int fetchSize)
                               throws SQLException

抛出:

SQLException

closeCursor

public void closeCursor(int cursorId)
                 throws SQLException

抛出:

SQLException

cursorFetchForOracle

public ColumnDefinition[] cursorFetchForOracle(int cursorId,
                                               int numRows,
                                               byte offsetType,
                                               int offset)
                                        throws SQLException

抛出:

SQLException

close

public void close()
           throws SQLException

Releases this Statement object's database and JDBC resources immediately instead of waiting for this to happen when it is automatically closed. It is generally good practice to release resources as soon as you are finished with them to avoid tying up database resources.

Calling the method close on a Statement object that is already closed has no effect.

Note:When a Statement object is closed, its current ResultSet object, if one exists, is also closed.

指定者:

close 在接口中 AutoCloseable

指定者:

close 在接口中 Statement

覆盖:

close 在类中 OceanBaseStatement

抛出:

SQLException - if a database access error occurs

realClose

public void realClose(boolean calledExplicitly,
                      boolean closeOpenResults)
               throws SQLException

覆盖:

realClose 在类中 OceanBaseStatement

抛出:

SQLException

toString

public String toString()

Return sql String value.

覆盖:

toString 在类中 Object

返回:

String representation

getServerThreadId

public long getServerThreadId()

Permit to retrieve current connection thread id, or -1 if unknown.

返回:

current connection thread id.

getReturnResultSet

public ResultSet getReturnResultSet()
                             throws SQLException

抛出:

SQLException

getGeneratedKeys

public ResultSet getGeneratedKeys()
                           throws SQLException

从类复制的说明: OceanBaseStatement

Retrieves any auto-generated keys created as a result of executing this Statement object. If this Statement object did not generate any keys, an empty ResultSet object is returned.

Note:If the columns which represent the auto-generated keys were not specified, the JDBC driver implementation will determine the columns which best represent the auto-generated keys.

指定者:

getGeneratedKeys 在接口中 Statement

覆盖:

getGeneratedKeys 在类中 OceanBaseStatement

返回:

a ResultSet object containing the auto-generated key(s) generated by the execution of this Statement object

抛出:

SQLException - if a database access error occurs or this method is called on a closed Statement