Uses of Interface
org.linuxforhealth.fhir.database.utils.api.ISchemaAdapter

Packages that use ISchemaAdapter

Package	Description
org.linuxforhealth.fhir.bucket.persistence
org.linuxforhealth.fhir.database.utils.common
org.linuxforhealth.fhir.database.utils.derby
org.linuxforhealth.fhir.database.utils.model
org.linuxforhealth.fhir.database.utils.version
org.linuxforhealth.fhir.schema.app
org.linuxforhealth.fhir.schema.app.util
org.linuxforhealth.fhir.schema.build
org.linuxforhealth.fhir.schema.control

Uses of ISchemaAdapter in org.linuxforhealth.fhir.bucket.persistence

Methods in org.linuxforhealth.fhir.bucket.persistence with parameters of type ISchemaAdapter

Modifier and Type	Method	Description
protected void	FhirBucketSchema.applyModel(ISchemaAdapter adapter, SchemaApplyContext context, PhysicalDataModel pdm)	Apply the model to the database.

Uses of ISchemaAdapter in org.linuxforhealth.fhir.database.utils.common

Classes in org.linuxforhealth.fhir.database.utils.common that implement ISchemaAdapter

Modifier and Type	Class	Description
class	PlainSchemaAdapter	Adapter to build the plain version of the FHIR schema.

Uses of ISchemaAdapter in org.linuxforhealth.fhir.database.utils.derby

Methods in org.linuxforhealth.fhir.database.utils.derby that return ISchemaAdapter

Modifier and Type	Method	Description
static ISchemaAdapter	DerbyMaster.wrap(IDatabaseAdapter databaseAdapter)	Utility method to wrap the database adapter in a plain schema adapter which acts as a pass-through to the underlying databaseAdapter

Method parameters in org.linuxforhealth.fhir.database.utils.derby with type arguments of type ISchemaAdapter

Modifier and Type	Method	Description
void	DerbyMaster.runWithAdapter(java.util.function.Consumer<ISchemaAdapter> fn)	Run the function with an adapter configured for this database
void	DerbyMaster.runWithAdapter(IConnectionProvider pool, java.util.function.Consumer<ISchemaAdapter> fn)	Run the IDatabaseAdapter command fn using a DerbyAdapter for the given connection pool

Uses of ISchemaAdapter in org.linuxforhealth.fhir.database.utils.model

Methods in org.linuxforhealth.fhir.database.utils.model with parameters of type ISchemaAdapter

Modifier and Type	Method	Description
void	AlterSequenceStartWith.apply(java.lang.Integer priorVersion, ISchemaAdapter target, SchemaApplyContext context)
void	AlterSequenceStartWith.apply(ISchemaAdapter target, SchemaApplyContext context)
void	AlterTableAddColumn.apply(java.lang.Integer priorVersion, ISchemaAdapter target, SchemaApplyContext context)
void	AlterTableAddColumn.apply(ISchemaAdapter target, SchemaApplyContext context)
void	AlterTableIdentityCache.apply(java.lang.Integer priorVersion, ISchemaAdapter target, SchemaApplyContext context)
void	AlterTableIdentityCache.apply(ISchemaAdapter target, SchemaApplyContext context)
void	CreateIndex.apply(java.lang.Integer priorVersion, ISchemaAdapter target, SchemaApplyContext context)
void	CreateIndex.apply(ISchemaAdapter target, SchemaApplyContext context)
void	ForeignKeyConstraint.apply(java.lang.String schemaName, java.lang.String name, ISchemaAdapter target, DistributionType sourceDistributionType)	Apply the FK constraint to the given target
void	FunctionDef.apply(java.lang.Integer priorVersion, ISchemaAdapter target, SchemaApplyContext context)
void	FunctionDef.apply(ISchemaAdapter target, SchemaApplyContext context)
void	IDatabaseObject.apply(java.lang.Integer priorVersion, ISchemaAdapter target, SchemaApplyContext context)	Apply migration logic to bring the target database to the current level of this object
void	IDatabaseObject.apply(ISchemaAdapter target, SchemaApplyContext context)	Apply the DDL for this object to the target database
void	IndexDef.apply(java.lang.String schemaName, java.lang.String tableName, ISchemaAdapter target, DistributionType distributionType, java.lang.String distributionColumn)	Apply this object to the given database target
void	NopObject.apply(java.lang.Integer priorVersion, ISchemaAdapter target, SchemaApplyContext context)
void	NopObject.apply(ISchemaAdapter target, SchemaApplyContext context)
void	ObjectGroup.apply(java.lang.Integer priorVersion, ISchemaAdapter target, SchemaApplyContext context)
void	ObjectGroup.apply(ISchemaAdapter target, SchemaApplyContext context)
void	PhysicalDataModel.apply(ISchemaAdapter target, SchemaApplyContext context)	Apply the entire model to the target in order
void	ProcedureDef.apply(java.lang.Integer priorVersion, ISchemaAdapter target, SchemaApplyContext context)
void	ProcedureDef.apply(ISchemaAdapter target, SchemaApplyContext context)
void	Sequence.apply(java.lang.Integer priorVersion, ISchemaAdapter target, SchemaApplyContext context)
void	Sequence.apply(ISchemaAdapter target, SchemaApplyContext context)
void	Table.apply(java.lang.Integer priorVersion, ISchemaAdapter target, SchemaApplyContext context)
void	Table.apply(ISchemaAdapter target, SchemaApplyContext context)
void	Tablespace.apply(java.lang.Integer priorVersion, ISchemaAdapter target, SchemaApplyContext context)
void	Tablespace.apply(ISchemaAdapter target, SchemaApplyContext context)
void	View.apply(java.lang.Integer priorVersion, ISchemaAdapter target, SchemaApplyContext context)
void	View.apply(ISchemaAdapter target, SchemaApplyContext context)
void	BaseObject.applyDistributionRules(ISchemaAdapter target, int pass)
void	DatabaseObject.applyDistributionRules(ISchemaAdapter target, int pass)
void	IDatabaseObject.applyDistributionRules(ISchemaAdapter target, int pass)	Apply any distribution rules associated with the object (usually a table)
void	ObjectGroup.applyDistributionRules(ISchemaAdapter target, int pass)
void	PhysicalDataModel.applyDistributionRules(ISchemaAdapter target, java.util.function.Supplier<ITransaction> transactionSupplier)	Make a pass over all the objects and apply any distribution rules they may have (e.g.
void	Table.applyDistributionRules(ISchemaAdapter target, int pass)
void	PhysicalDataModel.applyFunctions(ISchemaAdapter adapter, SchemaApplyContext context)	Apply all the functions in the order in which they were added to the model
void	PhysicalDataModel.applyGrants(ISchemaAdapter target, java.lang.String groupName, java.lang.String username)	Apply the grants for the given group to the user
void	PhysicalDataModel.applyProcedureAndFunctionGrants(ISchemaAdapter target, java.lang.String groupName, java.lang.String username)	Grant the privileges for any registered procedures and functions to the given username
void	PhysicalDataModel.applyProcedures(ISchemaAdapter adapter, SchemaApplyContext context)	Apply all the procedures in the order in which they were added to the model
void	BaseObject.applyTx(ISchemaAdapter target, SchemaApplyContext context, ITransactionProvider tp, IVersionHistoryService vhs)
void	DatabaseObject.applyTx(ISchemaAdapter target, SchemaApplyContext context, ITransactionProvider tp, IVersionHistoryService vhs)
void	IDatabaseObject.applyTx(ISchemaAdapter target, SchemaApplyContext context, ITransactionProvider cp, IVersionHistoryService vhs)	Apply the DDL, but within its own transaction
void	NopObject.applyTx(ISchemaAdapter target, SchemaApplyContext context, ITransactionProvider tp, IVersionHistoryService vhs)
void	BaseObject.applyVersion(ISchemaAdapter target, SchemaApplyContext context, IVersionHistoryService vhs)
void	DatabaseObject.applyVersion(ISchemaAdapter target, SchemaApplyContext context, IVersionHistoryService vhs)	Apply the change, but only if it has a newer version than we already have recorded in the database
void	IDatabaseObject.applyVersion(ISchemaAdapter target, SchemaApplyContext context, IVersionHistoryService vhs)	Apply the change, but only if it has a newer version than we already have recorded in the database
void	ObjectGroup.applyVersion(ISchemaAdapter target, SchemaApplyContext context, IVersionHistoryService vhs)
void	PhysicalDataModel.applyWithHistory(ISchemaAdapter target, SchemaApplyContext context, IVersionHistoryService vhs)	Apply all the objects linearly, but using the version history service to determine what's new and what already exists
ITaskGroup	BaseObject.collect(ITaskCollector tc, ISchemaAdapter target, SchemaApplyContext context, ITransactionProvider tp, IVersionHistoryService vhs)
ITaskGroup	IDatabaseObject.collect(ITaskCollector tc, ISchemaAdapter target, SchemaApplyContext context, ITransactionProvider tp, IVersionHistoryService vhs)	Collect the tasks into a dependency tree so that they can be executed concurrently (but in the right order)
void	PhysicalDataModel.collect(ITaskCollector tc, ISchemaAdapter target, SchemaApplyContext context, ITransactionProvider tp, IVersionHistoryService vhs)	Collect all the database objects we know of, describing their interdependencies so that the task collector implementation can execute them in parallel.
ITaskGroup	Tablespace.collect(ITaskCollector tc, ISchemaAdapter target, SchemaApplyContext context, ITransactionProvider tp, IVersionHistoryService vhs)
void	AlterSequenceStartWith.drop(ISchemaAdapter target)
void	AlterTableAddColumn.drop(ISchemaAdapter target)
void	AlterTableIdentityCache.drop(ISchemaAdapter target)
void	CreateIndex.drop(ISchemaAdapter target)
void	FunctionDef.drop(ISchemaAdapter target)
void	IDatabaseObject.drop(ISchemaAdapter target)	DROP this object from the target database
void	IndexDef.drop(java.lang.String schemaName, ISchemaAdapter target)	Drop this index
void	NopObject.drop(ISchemaAdapter target)
void	ObjectGroup.drop(ISchemaAdapter target)
void	PhysicalDataModel.drop(ISchemaAdapter target)	Drop the lot
void	PhysicalDataModel.drop(ISchemaAdapter target, java.lang.String tagGroup, java.lang.String tag)	Drop the model from the target database.
void	ProcedureDef.drop(ISchemaAdapter target)
void	Sequence.drop(ISchemaAdapter target)
void	Table.drop(ISchemaAdapter target)
void	Tablespace.drop(ISchemaAdapter target)
void	View.drop(ISchemaAdapter target)
void	PhysicalDataModel.dropForeignKeyConstraints(ISchemaAdapter target, java.lang.String tagGroup, java.lang.String tag)	Drop all foreign key constraints on tables in this model.
void	PhysicalDataModel.dropSplitTransaction(ISchemaAdapter target, ITransactionProvider transactionProvider, java.lang.String tagGroup, java.lang.String tag)	Split the drop in multiple (smaller) transactions, which can be helpful to reduce memory utilization in some scenarios
boolean	Table.exists(ISchemaAdapter target)	return true if the table already exists in the target
void	BaseObject.grant(ISchemaAdapter target, java.lang.String groupName, java.lang.String toUser)
void	IDatabaseObject.grant(ISchemaAdapter target, java.lang.String groupName, java.lang.String toUser)	Grant the given privileges to the user
void	ObjectGroup.grant(ISchemaAdapter target, java.lang.String groupName, java.lang.String toUser)
void	Tablespace.grant(ISchemaAdapter target, java.lang.String groupName, java.lang.String toUser)
protected void	AlterSequenceStartWith.grantGroupPrivileges(ISchemaAdapter target, java.util.Set<Privilege> group, java.lang.String toUser)
protected void	AlterTableAddColumn.grantGroupPrivileges(ISchemaAdapter target, java.util.Set<Privilege> group, java.lang.String toUser)
protected void	AlterTableIdentityCache.grantGroupPrivileges(ISchemaAdapter target, java.util.Set<Privilege> group, java.lang.String toUser)
protected void	BaseObject.grantGroupPrivileges(ISchemaAdapter target, java.util.Set<Privilege> group, java.lang.String toUser)	Internal method which can be override by different object types which may need to call a different grant method on the adapter
protected void	FunctionDef.grantGroupPrivileges(ISchemaAdapter target, java.util.Set<Privilege> group, java.lang.String toUser)
protected void	ProcedureDef.grantGroupPrivileges(ISchemaAdapter target, java.util.Set<Privilege> group, java.lang.String toUser)
protected void	Sequence.grantGroupPrivileges(ISchemaAdapter target, java.util.Set<Privilege> group, java.lang.String toUser)
protected void	Table.grantGroupPrivileges(ISchemaAdapter target, java.util.Set<Privilege> group, java.lang.String toUser)
protected void	View.grantGroupPrivileges(ISchemaAdapter target, java.util.Set<Privilege> group, java.lang.String toUser)

Uses of ISchemaAdapter in org.linuxforhealth.fhir.database.utils.version

Methods in org.linuxforhealth.fhir.database.utils.version with parameters of type ISchemaAdapter

Modifier and Type	Method	Description
static void	CreateControl.createTableIfNeeded(java.lang.String adminSchemaName, ISchemaAdapter target)	Create the CONTROL table in the admin schema.
static void	CreateVersionHistory.createTableIfNeeded(java.lang.String adminSchemaName, ISchemaAdapter target)	Create the version history table in the given (admin) schema.
static void	CreateWholeSchemaVersion.createTableIfNeeded(java.lang.String schemaName, ISchemaAdapter target)	Create the WHOLE_SCHEMA_VERSION table.
static void	CreateWholeSchemaVersion.dropTable(java.lang.String schemaName, ISchemaAdapter target)	Drop the WHOLE_SCHEMA_VERSION table if it exists in the given schema
static void	CreateWholeSchemaVersion.grantPrivilegesTo(ISchemaAdapter target, java.lang.String schemaName, java.lang.String groupName, java.lang.String toUser)	Grant the user privileges so that the row from this table can be read by the $healthcheck custom operation.

Uses of ISchemaAdapter in org.linuxforhealth.fhir.schema.app

Methods in org.linuxforhealth.fhir.schema.app with parameters of type ISchemaAdapter

Modifier and Type	Method	Description
protected void	Main.applyModel(PhysicalDataModel pdm, ISchemaAdapter adapter, ITaskCollector collector, VersionHistoryService vhs, SchemaType schemaType)	Start the schema object creation tasks and wait for everything to complete

Uses of ISchemaAdapter in org.linuxforhealth.fhir.schema.app.util

Methods in org.linuxforhealth.fhir.schema.app.util that return ISchemaAdapter

Modifier and Type	Method	Description
static ISchemaAdapter	CommonUtil.getSchemaAdapter(SchemaType schemaType, IDatabaseAdapter dbAdapter)	Wrap the given databaseAdapter in an ISchemaAdapter implementation selected by the given schemaType
static ISchemaAdapter	CommonUtil.getSchemaAdapter(SchemaType schemaType, DbType dbType, IConnectionProvider connectionProvider)	Get the schema adapter which will build the schema variant described by the given schemaType

Uses of ISchemaAdapter in org.linuxforhealth.fhir.schema.build

Classes in org.linuxforhealth.fhir.schema.build that implement ISchemaAdapter

Modifier and Type	Class	Description
class	DistributedSchemaAdapter	Represents an adapter used to build the FHIR schema when used with a distributed databse like Citus
class	FhirSchemaAdapter	Represents an adapter used to build the standard FHIR schema
class	ShardedSchemaAdapter	Adapter implementation used to build the distributed variant of the IBM FHIR Server RDBMS schema.

Uses of ISchemaAdapter in org.linuxforhealth.fhir.schema.control

Constructors in org.linuxforhealth.fhir.schema.control with parameters of type ISchemaAdapter

Constructor	Description
AddForeignKey(ISchemaAdapter adapter)	Public constructor