Package org.pgcodekeeper.core.database.base.jdbc

Class JdbcRunner

java.lang.Object

org.pgcodekeeper.core.database.base.jdbc.JdbcRunner

public class JdbcRunner
extends Object

JDBC statement execution runner with progress monitoring and cancellation support. Provides methods for executing SQL statements, prepared statements, and batch operations with progress tracking and interrupt handling.

Constructor Summary

Constructors

Constructor	Description
JdbcRunner()	Creates a new JDBC runner with a null progress monitor.
JdbcRunner(IMonitor monitor)	Creates a new JDBC runner with the specified progress monitor.

Method Summary

Modifier and Type	Method	Description
void	run(PreparedStatement st)	Executes a prepared statement with no return value.
void	run(Statement st, String script)	Executes a statement using the given script with no return value.
void	run(IJdbcConnector connector, String script)	Executes a script using a new connection from the connector.
void	runBatches(IJdbcConnector connector, List<ObjectLocation> batches, IProgressReporter reporter)	Executes statement batches with no return value.
ResultSet	runScript(PreparedStatement st)	Executes a prepared statement and returns the result set.
ResultSet	runScript(Statement st, String script)	Executes a statement using the given script and returns the result set.

Methods inherited from class java.lang.Object

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

Constructor Details

JdbcRunner

public JdbcRunner()

Creates a new JDBC runner with a null progress monitor.

JdbcRunner

public JdbcRunner(IMonitor monitor)

Creates a new JDBC runner with the specified progress monitor.

Parameters:

monitor - the progress monitor for tracking execution and handling cancellation

Method Details

run

public void run(PreparedStatement st)
         throws SQLException,
InterruptedException

Executes a prepared statement with no return value.

Parameters:

st - the prepared statement to execute

Throws:

SQLException - if a database access error occurs

InterruptedException - if execution is interrupted

run

public void run(Statement st,
 String script)
         throws SQLException,
InterruptedException

Executes a statement using the given script with no return value.

Parameters:

st - the statement to execute

script - the SQL script to execute

Throws:

SQLException - if a database access error occurs

InterruptedException - if execution is interrupted

run

public void run(IJdbcConnector connector,
 String script)
         throws SQLException,
IOException,
InterruptedException

Executes a script using a new connection from the connector.

Parameters:

connector - the JDBC connector for database connection

script - the SQL script to execute

Throws:

SQLException - if a database access error occurs

IOException - if connection creation fails

InterruptedException - if execution is interrupted

runBatches

public void runBatches(IJdbcConnector connector,
 List<ObjectLocation> batches,
 IProgressReporter reporter)
                throws SQLException,
IOException,
InterruptedException

Executes statement batches with no return value.

Parameters:

connector - database connection information

batches - list of query batches to execute

reporter - progress and result reporter

Throws:

SQLException - if a database access error occurs

IOException - if connection creation fails

InterruptedException - if execution is interrupted

runScript

public ResultSet runScript(PreparedStatement st)
                    throws InterruptedException,
SQLException

Executes a prepared statement and returns the result set.

Parameters:

st - the prepared statement to execute

Returns:

the result set from the query

Throws:

SQLException - if a database access error occurs

InterruptedException - if execution is interrupted

runScript

public ResultSet runScript(Statement st,
 String script)
                    throws InterruptedException,
SQLException

Executes a statement using the given script and returns the result set.

Parameters:

st - the statement to execute

script - the SQL script to execute

Returns:

the result set from the query

Throws:

SQLException - if a database access error occurs

InterruptedException - if execution is interrupted