Package org.pgcodekeeper.core.database.ch.loader

Class ChJdbcLoader

java.lang.Object

org.pgcodekeeper.core.database.base.loader.AbstractLoader<T>

org.pgcodekeeper.core.database.base.loader.AbstractJdbcLoader<ChDatabase>

org.pgcodekeeper.core.database.ch.loader.ChJdbcLoader

All Implemented Interfaces:

IJdbcLoader, ILoader

public final class ChJdbcLoader
extends AbstractJdbcLoader<ChDatabase>

JDBC-based database schema loader for ClickHouse databases. Reads database schemas, functions, relations, policies, users, roles, and privileges from a ClickHouse database. Extends JdbcLoaderBase to provide ClickHouse-specific loading functionality.

Constructor Summary

Constructors

Constructor	Description
ChJdbcLoader(IJdbcConnector connector, DiffSettings diffSettings)	Creates a new ClickHouse JDBC loader with the specified parameters.

Method Summary

Modifier and Type	Method	Description
String	getSchemas()	Returns a string representation of loaded schemas.
ChDatabase	loadInternal()
void	preLoad()	Pre loads the required items, do nothing by default
<T> void	submitChAntlrTask(String sql, Function<CHParser,T> parserCtxReader, Consumer<T> finalizer)

Methods inherited from class org.pgcodekeeper.core.database.base.loader.AbstractJdbcLoader

getConnection, getCurrentLocation, getRunner, getSchema, getStatement, getVersion, putSchema, setComment, setCurrentObject, setCurrentOperation, setOwner, setVersion

Methods inherited from class org.pgcodekeeper.core.database.base.loader.AbstractLoader

addError, getDatabase, getDatabaseName, getDiffSettings, getErrors, getMonitor, getSettings, isAllowedSchema, load, loadAndAnalyze

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.pgcodekeeper.core.database.api.loader.ILoader

getDatabase, getDatabaseName, getDiffSettings, getErrors, getSettings, load, loadAndAnalyze

Constructor Details

ChJdbcLoader

public ChJdbcLoader(IJdbcConnector connector,
 DiffSettings diffSettings)

Creates a new ClickHouse JDBC loader with the specified parameters.

Parameters:

connector - the JDBC connector for establishing database connections

diffSettings - unified context object containing settings, ignore list, and error accumulator

Method Details

preLoad

public void preLoad()

Description copied from interface: ILoader

Pre loads the required items, do nothing by default

loadInternal

public ChDatabase loadInternal()
                        throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

getSchemas

public String getSchemas()

Description copied from class: AbstractJdbcLoader

Returns a string representation of loaded schemas.

Overrides:

getSchemas in class AbstractJdbcLoader<ChDatabase>

Returns:

string containing schema information

submitChAntlrTask

public <T> void submitChAntlrTask(String sql,
 Function<CHParser,T> parserCtxReader,
 Consumer<T> finalizer)