public class SqlflowShardedSQLEnv extends TSQLEnv
Parses catalog.json files from the sharded export format, loading metadata including tables, views, columns, and synonyms. Supports different database topologies based on the manifest configuration.
The sharded format structure:
manifest.json catalog/<shardId>.catalog.json source/<shardId>.source.jsonl index/<shardId>.source.idx
catalogCollationCaseSensitive, columnCollationCaseSensitive, DEFAULT_DB_NAME, DEFAULT_SCHEMA_NAME, DEFAULT_SERVER_NAME, defaultCollationCaseSensitive, functionCollationCaseSensitive, isAliasReferenceForbidden, tableCollationCaseSensitive| Constructor and Description |
|---|
SqlflowShardedSQLEnv(String defaultServer,
String defaultDatabase,
String defaultSchema,
EDbVendor dbVendor,
Map server,
String baseDir)
Constructor with explicit base directory for catalog files.
|
| Modifier and Type | Method and Description |
|---|---|
void |
initSQLEnv()
This method must be override in the subclass to build a SQL environment with real metadata.
|
addFunction, addFunction, addOraclePackage, addProcedure, addSQLRoutine, addTable, addTrigger, addView, columnInTable, compareColumn, compareColumn, compareIdentifier, compareIdentifier, compareIdentifier, compareQualifiedColumn, compareQualifiedTable, compareTable, compareTable, createSQLCatalog, createSQLSchema, delimitedChar, doAddCatalog, doAddSchemaObject, doAddSchemaObject, doSearchSchemaObject, endsWithDelimitedIdentifier, getAFullQualifiedSchemaObjectName, getCatalogList, getCatalogProvider, getCatalogStore, getColumnInTable, getColumnsInTable, getDatabaseName, getDatabaseName, getDBVendor, getDefaultCatalogName, getDefaultSchemaName, getDefaultServerName, getIdentifierProfile, getIdentifierService, getNumberOfTables, getObjectName, getObjectName, getProcedureParameterValue, getSchemaName, getSchemaName, getSQLCatalog, getSQLSchema, getStmtSeparatorChar, getVariableValue, isDelimitedIdentifier, isDelimitedIdentifier, isEnableGetMetadataFromDDL, isUsedBySqlflow, matchSubObjectNameToWhole, normalizeIdentifier, normalizeIdentifier, putSchemaObject, searchCatalog, searchFunction, searchFunction, searchSchemaObject, searchSchemaObject, searchTable, searchTable, setCatalogProviderForCompatibility, setDefaultCatalogName, setDefaultSchemaName, setDefaultServerName, setEnableGetMetadataFromDDL, supportCatalog, supportSchema, toStringpublic SqlflowShardedSQLEnv(String defaultServer, String defaultDatabase, String defaultSchema, EDbVendor dbVendor, Map server, String baseDir)
defaultServer - default server namedefaultDatabase - default database namedefaultSchema - default schema namedbVendor - database vendorserver - server configuration from manifestbaseDir - base directory containing catalog/, source/, index/ subdirectoriespublic void initSQLEnv()
TSQLEnvinitSQLEnv in class TSQLEnv