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	load()	Loads the database schema.
<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, getErrors, getMonitor, getSettings, isAllowedSchema, 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

getErrors, getSettings, 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

load

public ChDatabase load()
                throws IOException,
InterruptedException

Description copied from interface: ILoader

Loads the database schema.

Specified by:

load in interface ILoader

Specified by:

load in class AbstractLoader<ChDatabase>

Returns:

loaded database

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)