Package org.mariadb.jdbc

Class ServerPreparedStatement

java.lang.Object

org.mariadb.jdbc.Statement

org.mariadb.jdbc.BasePreparedStatement

org.mariadb.jdbc.ServerPreparedStatement

All Implemented Interfaces:

java.lang.AutoCloseable, java.sql.PreparedStatement, java.sql.Statement, java.sql.Wrapper

Direct Known Subclasses:

BaseCallableStatement

public class ServerPreparedStatement
extends BasePreparedStatement

Server prepare statement. command will generate COM_STMT_PREPARE + COM_STMT_EXECUTE (+ COM_STMT_CLOSE)

Field Summary

Fields

Modifier and Type	Field	Description
private static java.util.regex.Pattern	PREPARABLE_STATEMENT_PATTERN

Fields inherited from class org.mariadb.jdbc.BasePreparedStatement

batchParameters, canCachePrepStmts, parameters, prepareResult, sql

Fields inherited from class org.mariadb.jdbc.Statement

autoGeneratedKeys, canUseServerMaxRows, canUseServerTimeout, clientParser, closed, closeOnCompletion, con, currResult, escape, fetchSize, lastSql, localInfileInputStream, lock, maxRows, queryTimeout, results, resultSetConcurrency, resultSetType

Fields inherited from interface java.sql.Statement

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

Constructor Summary

Constructors

Constructor	Description
ServerPreparedStatement(java.lang.String sql, Connection con, ClosableLock lock, boolean canUseServerTimeout, boolean canUseServerMaxRows, boolean canCachePrepStmts, int autoGeneratedKeys, int resultSetType, int resultSetConcurrency, int defaultFetchSize)	Server prepare statement constructor

Method Summary

Modifier and Type	Method	Description
void	addBatch()	Adds a set of parameters to this PreparedStatement object's batch of commands.
void	close()	Releases this Statement object's database and JDBC resources immediately instead of waiting for this to happen when it is automatically closed.
private ExceptionFactory	exceptionFactory()
boolean	execute()	Executes the SQL statement in this PreparedStatement object, which may be any kind of SQL statement.
private void	executeBatchPipeline(java.lang.String cmd)	Send COM_STMT_PREPARE + X * COM_STMT_EXECUTE, then read for the all answers
private void	executeBatchStandard(java.lang.String cmd)	Send COM_STMT_PREPARE + read answer, then Send a COM_STMT_EXECUTE + read answer * n time
private java.util.List<Completion>	executeBunch(java.lang.String cmd, int index, int maxCmd)
private java.util.List<Completion>	executeBunchPrepare(java.lang.String cmd, int index, int maxCmd)
protected void	executeInternal()	Execute command with parameters
protected boolean	executeInternalPreparedBatch()
long	executeLargeUpdate()	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.
private void	executePipeline(java.lang.String cmd)	Send COM_STMT_PREPARE + COM_STMT_EXECUTE, then read for the 2 answers
java.sql.ResultSet	executeQuery()	Executes the SQL query in this PreparedStatement object and returns the ResultSet object generated by the query.
private void	executeStandard(java.lang.String cmd)
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.
java.sql.ResultSetMetaData	getMetaData()	Retrieves a ResultSetMetaData object that contains information about the columns of the ResultSet object that will be returned when this PreparedStatement object is executed.
java.sql.ParameterMetaData	getParameterMetaData()	Retrieves the number, types and properties of this PreparedStatement object's parameters.
protected void	handleParameterOutput()	Handle output parameter result-set (only for CallableStatement)
void	setLargeMaxRows(long max)	Sets the limit for the maximum number of rows that any ResultSet object generated by this Statement object can contain to the given number.
void	setMaxRows(int max)	Sets the limit for the maximum number of rows that any ResultSet object generated by this Statement object can contain to the given number.
void	setQueryTimeout(int seconds)	Sets the number of seconds the driver will wait for a Statement object to execute to the given number of seconds.
java.lang.String	toString()
protected void	validParameters()	Validated that all parameters have been set.

Methods inherited from class org.mariadb.jdbc.BasePreparedStatement

addBatch, clearBatch, clearParameters, execute, execute, execute, execute, executeBatch, executeBatchBulk, executeLargeBatch, executeLargeUpdate, executeLargeUpdate, executeLargeUpdate, executeLargeUpdate, executeQuery, executeUpdate, executeUpdate, executeUpdate, executeUpdate, getGeneratedKeys, getLastSql, getMeta, reset, setArray, setAsciiStream, setAsciiStream, setAsciiStream, setBigDecimal, setBinaryStream, setBinaryStream, setBinaryStream, setBlob, setBlob, setBlob, setBoolean, setByte, setBytes, setCharacterStream, setCharacterStream, setCharacterStream, setClob, setClob, setClob, setDate, setDate, setDouble, setFloat, setInt, setLong, setNCharacterStream, setNCharacterStream, setNClob, setNClob, setNClob, setNString, setNull, setNull, setObject, setObject, setObject, setObject, setObject, setParameter, setPrepareResult, setRef, setRowId, setShort, setSQLXML, setString, setTime, setTime, setTimestamp, setTimestamp, setUnicodeStream, setURL, updateMeta

Methods inherited from class org.mariadb.jdbc.Statement

abort, cancel, checkNotClosed, clearWarnings, closeOnCompletion, enquoteIdentifier, enquoteLiteral, enquoteNCharLiteral, escapeTimeout, executeInternalBatchPipeline, executeInternalBatchStandard, fetchRemaining, getConnection, getFetchDirection, getFetchSize, getLargeMaxRows, getLargeUpdateCount, getMaxFieldSize, getMaxRows, getMoreResults, getMoreResults, getQueryTimeout, getResultSet, getResultSetConcurrency, getResultSetHoldability, getResultSetType, getUpdateCount, getWarnings, isClosed, isCloseOnCompletion, isPoolable, isSimpleIdentifier, isWrapperFor, parseCommandIfNeeded, setCursorName, setEscapeProcessing, setFetchDirection, setFetchSize, setLocalInfileInputStream, setMaxFieldSize, setPoolable, unwrap

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.sql.Statement

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

Methods inherited from interface java.sql.Wrapper

isWrapperFor, unwrap

Field Detail

PREPARABLE_STATEMENT_PATTERN

private static final java.util.regex.Pattern PREPARABLE_STATEMENT_PATTERN

Constructor Detail

ServerPreparedStatement

public ServerPreparedStatement(java.lang.String sql,
                               Connection con,
                               ClosableLock lock,
                               boolean canUseServerTimeout,
                               boolean canUseServerMaxRows,
                               boolean canCachePrepStmts,
                               int autoGeneratedKeys,
                               int resultSetType,
                               int resultSetConcurrency,
                               int defaultFetchSize)
                        throws java.sql.SQLException

Server prepare statement constructor

Parameters:

sql - command

con - connection

lock - thread safe lock

canUseServerTimeout - can server use timeout

canUseServerMaxRows - can server use max rows

canCachePrepStmts - can server cache prepared statement

autoGeneratedKeys - must command return automatically generated keys

resultSetType - resultset type

resultSetConcurrency - resultset concurrency

defaultFetchSize - default fetch size

Throws:

java.sql.SQLException - if prepare fails

Method Detail

executeInternal

protected void executeInternal()
                        throws java.sql.SQLException

Execute command with parameters

Throws:

java.sql.SQLException - if any error occurs

executePipeline

private void executePipeline(java.lang.String cmd)
                      throws java.sql.SQLException

Send COM_STMT_PREPARE + COM_STMT_EXECUTE, then read for the 2 answers

Parameters:

cmd - command

Throws:

java.sql.SQLException - if IOException / Command error

executeStandard

private void executeStandard(java.lang.String cmd)
                      throws java.sql.SQLException

Throws:

java.sql.SQLException

executeInternalPreparedBatch

protected boolean executeInternalPreparedBatch()
                                        throws java.sql.SQLException

Specified by:

executeInternalPreparedBatch in class BasePreparedStatement

Throws:

java.sql.SQLException

executeBatchPipeline

private void executeBatchPipeline(java.lang.String cmd)
                           throws java.sql.SQLException

Send COM_STMT_PREPARE + X * COM_STMT_EXECUTE, then read for the all answers

Parameters:

cmd - command

Throws:

java.sql.SQLException - if Command error

executeBunch

private java.util.List<Completion> executeBunch(java.lang.String cmd,
                                                int index,
                                                int maxCmd)
                                         throws java.sql.SQLException

Throws:

java.sql.SQLException

executeBunchPrepare

private java.util.List<Completion> executeBunchPrepare(java.lang.String cmd,
                                                       int index,
                                                       int maxCmd)
                                                throws java.sql.SQLException

Throws:

java.sql.SQLException

executeBatchStandard

private void executeBatchStandard(java.lang.String cmd)
                           throws java.sql.SQLException

Send COM_STMT_PREPARE + read answer, then Send a COM_STMT_EXECUTE + read answer * n time

Parameters:

cmd - command

Throws:

java.sql.SQLException - if IOException / Command error

execute

public boolean execute()
                throws java.sql.SQLException

Executes the SQL statement in this PreparedStatement object, which may be any kind of SQL statement. Some prepared statements return multiple results; the execute method handles these complex statements as well as the simpler form of statements handled by the methods executeQuery and executeUpdate.

The execute method returns a boolean to indicate the form of the first result. You must call either the method getResultSet or getUpdateCount to retrieve the result; you must call getMoreResults to move to any subsequent result(s).

Specified by:

execute in interface java.sql.PreparedStatement

Specified by:

execute in class BasePreparedStatement

Returns:

true if the first result is a ResultSet object; false if the first result is an update count or there is no result

Throws:

java.sql.SQLException - if a database access error occurs; this method is called on a closed PreparedStatement or an argument is supplied to this method

java.sql.SQLTimeoutException - when the driver has determined that the timeout value that was specified by the setQueryTimeout method has been exceeded and has at least attempted to cancel the currently running Statement

See Also:

Statement.execute(java.lang.String), Statement.getResultSet(), Statement.getUpdateCount(), Statement.getMoreResults()

setMaxRows

public void setMaxRows(int max)
                throws java.sql.SQLException

Description copied from class: Statement

Sets the limit for the maximum number of rows that any ResultSet object generated by this Statement object can contain to the given number. If the limit is exceeded, the excess rows are silently dropped.

Specified by:

setMaxRows in interface java.sql.Statement

Overrides:

setMaxRows in class Statement

Parameters:

max - the new max rows limit; zero means there is no limit

Throws:

java.sql.SQLException - if a database access error occurs, this method is called on a closed Statement or the condition max >= 0 is not satisfied

See Also:

Statement.getMaxRows()

setLargeMaxRows

public void setLargeMaxRows(long max)
                     throws java.sql.SQLException

Description copied from class: Statement

Sets the limit for the maximum number of rows that any ResultSet object generated by this Statement object can contain to the given number. If the limit is exceeded, the excess rows are silently dropped.

Specified by:

setLargeMaxRows in interface java.sql.Statement

Overrides:

setLargeMaxRows in class Statement

Parameters:

max - the new max rows limit; zero means there is no limit

Throws:

java.sql.SQLException - if the condition max >= 0 is not satisfied

setQueryTimeout

public void setQueryTimeout(int seconds)
                     throws java.sql.SQLException

Description copied from class: Statement

Sets the number of seconds the driver will wait for a Statement object to execute to the given number of seconds. By default, there is no limit on the amount of time allowed for a running statement to complete. If the limit is exceeded, an SQLTimeoutException is thrown. A JDBC driver must apply this limit to the execute, executeQuery and executeUpdate methods.

Note: JDBC driver implementations may also apply this limit to ResultSet methods (consult your driver vendor documentation for details).

Note: In the case of Statement batching, it is implementation defined whether the time-out is applied to individual SQL commands added via the addBatch method or to the entire batch of SQL commands invoked by the executeBatch method (consult your driver vendor documentation for details).

Specified by:

setQueryTimeout in interface java.sql.Statement

Overrides:

setQueryTimeout in class Statement

Parameters:

seconds - the new query timeout limit in seconds; zero means there is no limit

Throws:

java.sql.SQLException - if a database access error occurs, this method is called on a closed Statement or the condition seconds >= 0 is not satisfied

See Also:

Statement.getQueryTimeout()

executeQuery

public java.sql.ResultSet executeQuery()
                                throws java.sql.SQLException

Executes the SQL query in this PreparedStatement object and returns the ResultSet object generated by the query.

Specified by:

executeQuery in interface java.sql.PreparedStatement

Specified by:

executeQuery in class BasePreparedStatement

Returns:

a ResultSet object that contains the data produced by the query; never null

Throws:

java.sql.SQLException - if a database access error occurs; this method is called on a closed PreparedStatement or the SQL statement does not return a ResultSet object

java.sql.SQLTimeoutException - when the driver has determined that the timeout value that was specified by the setQueryTimeout method has been exceeded and has at least attempted to cancel the currently running Statement

executeUpdate

public int executeUpdate()
                  throws java.sql.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.

Specified by:

executeUpdate in interface java.sql.PreparedStatement

Specified by:

executeUpdate in class BasePreparedStatement

Returns:

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

Throws:

java.sql.SQLException - if a database access error occurs; this method is called on a closed PreparedStatement or the SQL statement returns a ResultSet object

java.sql.SQLTimeoutException - when the driver has determined that the timeout value that was specified by the setQueryTimeout method has been exceeded and has at least attempted to cancel the currently running Statement

executeLargeUpdate

public long executeLargeUpdate()
                        throws java.sql.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.

This method should be used when the returned row count may exceed Integer.MAX_VALUE.

The default implementation will throw UnsupportedOperationException

Specified by:

executeLargeUpdate in interface java.sql.PreparedStatement

Specified by:

executeLargeUpdate in class BasePreparedStatement

Returns:

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

Throws:

java.sql.SQLException - if a database access error occurs; this method is called on a closed PreparedStatement or the SQL statement returns a ResultSet object

java.sql.SQLTimeoutException - when the driver has determined that the timeout value that was specified by the setQueryTimeout method has been exceeded and has at least attempted to cancel the currently running Statement

Since:

1.8

handleParameterOutput

protected void handleParameterOutput()
                              throws java.sql.SQLException

Handle output parameter result-set (only for CallableStatement)

Throws:

java.sql.SQLException - if any error occurs

addBatch

public void addBatch()
              throws java.sql.SQLException

Adds a set of parameters to this PreparedStatement object's batch of commands.

Specified by:

addBatch in interface java.sql.PreparedStatement

Specified by:

addBatch in class BasePreparedStatement

Throws:

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

Since:

1.2

See Also:

Statement.addBatch(java.lang.String)

validParameters

protected void validParameters()
                        throws java.sql.SQLException

Validated that all parameters have been set.

Throws:

java.sql.SQLException - if number of parameters doesn't correspond to expected number

getMetaData

public java.sql.ResultSetMetaData getMetaData()
                                       throws java.sql.SQLException

Retrieves a ResultSetMetaData object that contains information about the columns of the ResultSet object that will be returned when this PreparedStatement object is executed.

Because a PreparedStatement object is precompiled, it is possible to know about the ResultSet object that it will return without having to execute it. Consequently, it is possible to invoke the method getMetaData on a PreparedStatement object rather than waiting to execute it and then invoking the ResultSet.getMetaData method on the ResultSet object that is returned.

NOTE: Using this method may be expensive for some drivers due to the lack of underlying DBMS support.

Specified by:

getMetaData in interface java.sql.PreparedStatement

Specified by:

getMetaData in class BasePreparedStatement

Returns:

the description of a ResultSet object's columns or null if the driver cannot return a ResultSetMetaData object

Throws:

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

java.sql.SQLFeatureNotSupportedException - if the JDBC driver does not support this method

Since:

1.2

getParameterMetaData

public java.sql.ParameterMetaData getParameterMetaData()
                                                throws java.sql.SQLException

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

Specified by:

getParameterMetaData in interface java.sql.PreparedStatement

Specified by:

getParameterMetaData in class BasePreparedStatement

Returns:

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

Throws:

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

Since:

1.4

See Also:

ParameterMetaData

exceptionFactory

private ExceptionFactory exceptionFactory()

close

public void close()
           throws java.sql.SQLException

Description copied from class: Statement

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.

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.sql.Statement

Overrides:

close in class Statement

Throws:

java.sql.SQLException - if a database access error occurs

toString

public java.lang.String toString()

Overrides:

toString in class BasePreparedStatement