Package org.pgcodekeeper.core.loader.callables

Class QueriesBatchCallable

java.lang.Object

org.pgcodekeeper.core.loader.callables.StatementCallable<String>

org.pgcodekeeper.core.loader.callables.QueriesBatchCallable

All Implemented Interfaces:

Callable<String>

public class QueriesBatchCallable
extends StatementCallable<String>

Executable callable for processing batches of SQL queries with progress monitoring and error reporting. Handles database-specific batch execution for PostgreSQL, ClickHouse, and Microsoft SQL databases. Provides detailed error reporting with position information and supports both single statements and batch operations.

Constructor Summary

Constructors

Constructor	Description
QueriesBatchCallable(Statement st, List<PgObjLocation> batches, IMonitor monitor, IProgressReporter reporter, Connection connection, DatabaseType dbType)	Creates a new queries batch callable with the specified parameters.

Method Summary

Modifier and Type	Method	Description
String	call()

Methods inherited from class org.pgcodekeeper.core.loader.callables.StatementCallable

cancel

Methods inherited from class java.lang.Object

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

Constructor Details

QueriesBatchCallable

public QueriesBatchCallable(Statement st,
 List<PgObjLocation> batches,
 IMonitor monitor,
 IProgressReporter reporter,
 Connection connection,
 DatabaseType dbType)

Creates a new queries batch callable with the specified parameters.

Parameters:

st - the SQL statement to execute

batches - list of SQL query locations to process in batch

monitor - progress monitor for tracking execution progress

reporter - progress reporter for writing execution results and errors

connection - database connection for batch operations

dbType - database type to determine execution strategy

Method Details

call

public String call()
            throws Exception

Throws:

Exception