org.keycloak.connections.jpa.updater.liquibase.conn.DefaultLiquibaseConnectionProvider クラス

org.keycloak.connections.jpa.updater.liquibase.conn.DefaultLiquibaseConnectionProvider の継承関係図

org.keycloak.connections.jpa.updater.liquibase.conn.DefaultLiquibaseConnectionProvider 連携図

クラス
class	LogWrapper

公開メンバ関数
LiquibaseConnectionProvider	create (KeycloakSession session)
void	init (Config.Scope config)
void	postInit (KeycloakSessionFactory factory)
void	close ()
String	getId ()
Liquibase	getLiquibase (Connection connection, String defaultSchema) throws LiquibaseException
Liquibase	getLiquibaseForCustomUpdate (Connection connection, String defaultSchema, String changelogLocation, ClassLoader classloader, String changelogTableName) throws LiquibaseException
default int	order ()

限定公開メンバ関数
void	baseLiquibaseInitialization ()

非公開変数類
volatile boolean	initialized = false

静的非公開変数類
static final Logger	logger = Logger.getLogger(DefaultLiquibaseConnectionProvider.class)

詳解

著者

Marek Posolda

関数詳解

baseLiquibaseInitialization()

void org.keycloak.connections.jpa.updater.liquibase.conn.DefaultLiquibaseConnectionProvider.baseLiquibaseInitialization ( )

inlineprotected

                                                 {
        ServiceLocator sl = ServiceLocator.getInstance();
        sl.setResourceAccessor(new ClassLoaderResourceAccessor(getClass().getClassLoader()));

        if (!System.getProperties().containsKey("liquibase.scan.packages")) {
            if (sl.getPackages().remove("liquibase.core")) {
                sl.addPackageToScan("liquibase.core.xml");
            }

            if (sl.getPackages().remove("liquibase.parser")) {
                sl.addPackageToScan("liquibase.parser.core.xml");
            }

            if (sl.getPackages().remove("liquibase.serializer")) {
                sl.addPackageToScan("liquibase.serializer.core.xml");
            }

            sl.getPackages().remove("liquibase.ext");
            sl.getPackages().remove("liquibase.sdk");

            String lockPackageName = DummyLockService.class.getPackage().getName();
            logger.debugf("Added package %s to liquibase", lockPackageName);
            sl.addPackageToScan(lockPackageName);
        }

        LogFactory.setInstance(new LogWrapper());

        // Adding PostgresPlus support to liquibase
        DatabaseFactory.getInstance().register(new PostgresPlusDatabase());
        // Adding newer version of MySQL/MariaDB support to liquibase
        DatabaseFactory.getInstance().register(new UpdatedMySqlDatabase());

        // Change command for creating lock and drop DELETE lock record from it
        SqlGeneratorFactory.getInstance().register(new CustomInsertLockRecordGenerator());

        // Use "SELECT FOR UPDATE" for locking database
        SqlGeneratorFactory.getInstance().register(new CustomLockDatabaseChangeLogGenerator());
    }

close()

void org.keycloak.connections.jpa.updater.liquibase.conn.DefaultLiquibaseConnectionProvider.close ( )

inline

org.keycloak.provider.Providerを実装しています。

                        {
    }

create()

LiquibaseConnectionProvider org.keycloak.connections.jpa.updater.liquibase.conn.DefaultLiquibaseConnectionProvider.create ( KeycloakSession  session )

inline

org.keycloak.provider.ProviderFactory< T extends Provider >を実装しています。

                                                                       {
        if (!initialized) {
            synchronized (this) {
                if (!initialized) {
                    baseLiquibaseInitialization();
                    initialized = true;
                }
            }
        }
        return this;
    }

getId()

String org.keycloak.connections.jpa.updater.liquibase.conn.DefaultLiquibaseConnectionProvider.getId ( )

inline

org.keycloak.provider.ProviderFactory< T extends Provider >を実装しています。

                          {
        return "default";
    }

getLiquibase()

Liquibase org.keycloak.connections.jpa.updater.liquibase.conn.DefaultLiquibaseConnectionProvider.getLiquibase ( Connection  connection, String  defaultSchema  ) throws LiquibaseException

inline

org.keycloak.connections.jpa.updater.liquibase.conn.LiquibaseConnectionProviderを実装しています。

                                                                                                         {
        Database database = DatabaseFactory.getInstance().findCorrectDatabaseImplementation(new JdbcConnection(connection));
        if (defaultSchema != null) {
            database.setDefaultSchemaName(defaultSchema);
        }

        String changelog = LiquibaseJpaUpdaterProvider.CHANGELOG;
        ResourceAccessor resourceAccessor = new ClassLoaderResourceAccessor(getClass().getClassLoader());

        logger.debugf("Using changelog file %s and changelogTableName %s", changelog, database.getDatabaseChangeLogTableName());
        
        return new Liquibase(changelog, resourceAccessor, database);
    }

getLiquibaseForCustomUpdate()

Liquibase org.keycloak.connections.jpa.updater.liquibase.conn.DefaultLiquibaseConnectionProvider.getLiquibaseForCustomUpdate ( Connection  connection, String  defaultSchema, String  changelogLocation, ClassLoader  classloader, String  changelogTableName  ) throws LiquibaseException

inline

org.keycloak.connections.jpa.updater.liquibase.conn.LiquibaseConnectionProviderを実装しています。

                                                                                                                                                                                                      {
        Database database = DatabaseFactory.getInstance().findCorrectDatabaseImplementation(new JdbcConnection(connection));
        if (defaultSchema != null) {
            database.setDefaultSchemaName(defaultSchema);
        }

        ResourceAccessor resourceAccessor = new ClassLoaderResourceAccessor(classloader);
        database.setDatabaseChangeLogTableName(changelogTableName);

        logger.debugf("Using changelog file %s and changelogTableName %s", changelogLocation, database.getDatabaseChangeLogTableName());

        return new Liquibase(changelogLocation, resourceAccessor, database);
    }

init()

void org.keycloak.connections.jpa.updater.liquibase.conn.DefaultLiquibaseConnectionProvider.init ( Config.Scope  config )

inline

org.keycloak.provider.ProviderFactory< T extends Provider >を実装しています。

                                          {

    }

order()

default int org.keycloak.provider.ProviderFactory< T extends Provider >.order ( )

inlineinherited

org.keycloak.protocol.docker.DockerAuthV2ProtocolFactory, org.keycloak.urls.HostnameProviderFactory, org.keycloak.protocol.oidc.ext.OIDCExtProviderFactoryで実装されています。

                        {
        return 0;
    }

postInit()

void org.keycloak.connections.jpa.updater.liquibase.conn.DefaultLiquibaseConnectionProvider.postInit ( KeycloakSessionFactory  factory )

inline

org.keycloak.provider.ProviderFactory< T extends Provider >を実装しています。

                                                         {

    }

メンバ詳解

initialized

volatile boolean org.keycloak.connections.jpa.updater.liquibase.conn.DefaultLiquibaseConnectionProvider.initialized = false

private

logger

final Logger org.keycloak.connections.jpa.updater.liquibase.conn.DefaultLiquibaseConnectionProvider.logger = Logger.getLogger(DefaultLiquibaseConnectionProvider.class)

staticprivate

---

このクラス詳解は次のファイルから抽出されました:

• D:/AppData/doxygen/keycloak/src/keycloak/src/main/java/org/keycloak/connections/jpa/updater/liquibase/conn/DefaultLiquibaseConnectionProvider.java