gudusoft.gsqlparser.sqlenv.catalog

Class CatalogStoreProvider

Object

gudusoft.gsqlparser.sqlenv.catalog.CatalogStoreProvider

All Implemented Interfaces:

ICatalogProvider

public class CatalogStoreProvider
extends Object
implements ICatalogProvider

CatalogStore Provider（新实现）

此实现基于 CatalogStore，使用 IdentifierService 进行标识符处理。

Since:

3.2.0 (Phase 1)

Constructor Summary

Constructors

Constructor and Description
CatalogStoreProvider(CatalogStore catalogStore, IdentifierService identifierService) Creates a CatalogStoreProvider wrapping existing CatalogStore
CatalogStoreProvider(EDbVendor vendor) Creates a CatalogStoreProvider with default flags
CatalogStoreProvider(EDbVendor vendor, IdentifierProfile.VendorFlags flags) Creates a CatalogStoreProvider with custom vendor flags

Method Summary

Modifier and Type	Method and Description
void	addObject(TSQLSchemaObject object) 添加 schema 对象
void	clear() 清空所有对象
TSQLCatalog	createCatalog(String catalogName) 创建 catalog（已存在则返回现有）
TSQLSchemaObject	findObject(String catalog, String schema, String objectName, ESQLDataObjectType type) 查找 schema 对象（全限定名查找）
List<TSQLCatalog>	getAllCatalogs() 获取所有 catalog
TSQLCatalog	getCatalog(String catalogName) 获取 catalog（不存在返回 null）
CatalogStore	getCatalogStore() Get the underlying CatalogStore
String	getDefaultCatalogName() 获取默认 catalog 名称
IdentifierService	getIdentifierService() Get the IdentifierService
void	registerCatalog(TSQLCatalog catalog) Register a catalog in the cache (used by TSQLEnv during migration)
boolean	removeObject(TSQLSchemaObject object) 移除 schema 对象
void	setDefaultCatalogName(String name) 设置默认 catalog 名称
int	size() 获取对象总数

Methods inherited from class Object

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

Constructor Detail

CatalogStoreProvider

public CatalogStoreProvider(EDbVendor vendor)

Creates a CatalogStoreProvider with default flags

Parameters:

vendor - database vendor

CatalogStoreProvider

public CatalogStoreProvider(EDbVendor vendor,
                            IdentifierProfile.VendorFlags flags)

Creates a CatalogStoreProvider with custom vendor flags

Parameters:

vendor - database vendor

flags - vendor-specific flags

CatalogStoreProvider

public CatalogStoreProvider(CatalogStore catalogStore,
                            IdentifierService identifierService)

Creates a CatalogStoreProvider wrapping existing CatalogStore

Parameters:

catalogStore - existing catalog store

identifierService - identifier service

Method Detail

getCatalog

public TSQLCatalog getCatalog(String catalogName)

Description copied from interface: ICatalogProvider

获取 catalog（不存在返回 null）

Specified by:

getCatalog in interface ICatalogProvider

Parameters:

catalogName - catalog 名称

Returns:

catalog 实例，未找到返回 null

createCatalog

public TSQLCatalog createCatalog(String catalogName)

Description copied from interface: ICatalogProvider

创建 catalog（已存在则返回现有）

Specified by:

createCatalog in interface ICatalogProvider

Parameters:

catalogName - catalog 名称

Returns:

catalog 实例

getAllCatalogs

public List<TSQLCatalog> getAllCatalogs()

Description copied from interface: ICatalogProvider

获取所有 catalog

Specified by:

getAllCatalogs in interface ICatalogProvider

Returns:

catalog 列表

getDefaultCatalogName

public String getDefaultCatalogName()

Description copied from interface: ICatalogProvider

获取默认 catalog 名称

Specified by:

getDefaultCatalogName in interface ICatalogProvider

Returns:

默认 catalog 名称

setDefaultCatalogName

public void setDefaultCatalogName(String name)

Description copied from interface: ICatalogProvider

设置默认 catalog 名称

Specified by:

setDefaultCatalogName in interface ICatalogProvider

Parameters:

name - 默认 catalog 名称

findObject

public TSQLSchemaObject findObject(String catalog,
                                   String schema,
                                   String objectName,
                                   ESQLDataObjectType type)

Description copied from interface: ICatalogProvider

查找 schema 对象（全限定名查找）

Specified by:

findObject in interface ICatalogProvider

Parameters:

catalog - catalog 名称

schema - schema 名称

objectName - 对象名称

type - 对象类型

Returns:

schema 对象，未找到返回 null

addObject

public void addObject(TSQLSchemaObject object)

Description copied from interface: ICatalogProvider

添加 schema 对象

Specified by:

addObject in interface ICatalogProvider

Parameters:

object - schema 对象

removeObject

public boolean removeObject(TSQLSchemaObject object)

Description copied from interface: ICatalogProvider

移除 schema 对象

Specified by:

removeObject in interface ICatalogProvider

Parameters:

object - schema 对象

Returns:

true 如果移除成功

clear

public void clear()

Description copied from interface: ICatalogProvider

清空所有对象

Specified by:

clear in interface ICatalogProvider

size

public int size()

Description copied from interface: ICatalogProvider

获取对象总数

Specified by:

size in interface ICatalogProvider

Returns:

对象总数

getCatalogStore

public CatalogStore getCatalogStore()

Get the underlying CatalogStore

Returns:

catalog store

getIdentifierService

public IdentifierService getIdentifierService()

Get the IdentifierService

Returns:

identifier service

registerCatalog

public void registerCatalog(TSQLCatalog catalog)

Register a catalog in the cache (used by TSQLEnv during migration)

Parameters:

catalog - the catalog to register