org.keycloak.connections.jpa.updater.liquibase.custom.ExtractRealmKeysFromRealmTable クラス

org.keycloak.connections.jpa.updater.liquibase.custom.ExtractRealmKeysFromRealmTable の継承関係図

org.keycloak.connections.jpa.updater.liquibase.custom.ExtractRealmKeysFromRealmTable 連携図

公開メンバ関数
ValidationErrors	validate (Database database)
void	setFileOpener (ResourceAccessor resourceAccessor)
String	getConfirmationMessage ()
void	setUp () throws SetupException
SqlStatement []	generateStatements (Database database) throws CustomChangeException

限定公開メンバ関数
void	generateStatementsImpl () throws CustomChangeException
String	getTaskId ()
boolean	isApplicable () throws CustomChangeException
String	getTableName (String tableName)

限定公開変数類
KeycloakSession	kcSession
Database	database
JdbcConnection	jdbcConnection
Connection	connection
StringBuilder	confirmationMessage = new StringBuilder()
List< SqlStatement >	statements = new ArrayList<SqlStatement>()

非公開メンバ関数
InsertStatement	componentConfigStatement (String componentId, String name, String value)

詳解

著者

Marek Posolda

関数詳解

componentConfigStatement()

InsertStatement org.keycloak.connections.jpa.updater.liquibase.custom.ExtractRealmKeysFromRealmTable.componentConfigStatement ( String  componentId, String  name, String  value  )

inlineprivate

                                                                                                    {
        return new InsertStatement(null, null, database.correctObjectName("COMPONENT_CONFIG", Table.class))
                .addColumnValue("ID", KeycloakModelUtils.generateId())
                .addColumnValue("COMPONENT_ID", componentId)
                .addColumnValue("NAME", name)
                .addColumnValue("VALUE", value);
    }

generateStatements()

SqlStatement [] org.keycloak.connections.jpa.updater.liquibase.custom.CustomKeycloakTask.generateStatements ( Database  database ) throws CustomChangeException

inlineinherited

                                                                                             {
        this.database = database;
        jdbcConnection = (JdbcConnection) database.getConnection();
        connection = jdbcConnection.getWrappedConnection();

        if (isApplicable()) {
            confirmationMessage.append(getTaskId() + ": ");
            generateStatementsImpl();
        } else {
            confirmationMessage.append(getTaskId() + ": no update applicable for this task");
        }

        return statements.toArray(new SqlStatement[statements.size()]);
    }

generateStatementsImpl()

void org.keycloak.connections.jpa.updater.liquibase.custom.ExtractRealmKeysFromRealmTable.generateStatementsImpl ( ) throws CustomChangeException

inlineprotected

                                                                         {
        try {
            PreparedStatement statement = jdbcConnection.prepareStatement("select ID, PRIVATE_KEY, CERTIFICATE from " + getTableName("REALM"));

            try {
                ResultSet resultSet = statement.executeQuery();
                try {
                    while (resultSet.next()) {
                        String realmId = resultSet.getString(1);
                        String privateKeyPem = resultSet.getString(2);
                        String certificatePem = resultSet.getString(3);

                        String componentId = KeycloakModelUtils.generateId();

                        InsertStatement insertComponent = new InsertStatement(null, null, database.correctObjectName("COMPONENT", Table.class))
                                .addColumnValue("ID", componentId)
                                .addColumnValue("REALM_ID", realmId)
                                .addColumnValue("PARENT_ID", realmId)
                                .addColumnValue("NAME", "rsa")
                                .addColumnValue("PROVIDER_ID", "rsa")
                                .addColumnValue("PROVIDER_TYPE", KeyProvider.class.getName());

                        statements.add(insertComponent);

                        statements.add(componentConfigStatement(componentId, "priority", "100"));
                        statements.add(componentConfigStatement(componentId, "privateKey", privateKeyPem));
                        statements.add(componentConfigStatement(componentId, "certificate", certificatePem));
                    }
                } finally {
                    resultSet.close();
                }
            } finally {
                statement.close();
            }

            confirmationMessage.append("Updated " + statements.size() + " records in USER_FEDERATION_PROVIDER table");
        } catch (Exception e) {
            throw new CustomChangeException(getTaskId() + ": Exception when updating data from previous version", e);
        }
    }

getConfirmationMessage()

String org.keycloak.connections.jpa.updater.liquibase.custom.CustomKeycloakTask.getConfirmationMessage ( )

inlineinherited

                                           {
        return confirmationMessage.toString();
    }

getTableName()

String org.keycloak.connections.jpa.updater.liquibase.custom.CustomKeycloakTask.getTableName ( String  tableName )

inlineprotectedinherited

                                                    {
        String correctedSchemaName = database.escapeObjectName(database.getDefaultSchemaName(), Schema.class);
        return LiquibaseJpaUpdaterProvider.getTable(tableName, correctedSchemaName);
    }

getTaskId()

String org.keycloak.connections.jpa.updater.liquibase.custom.ExtractRealmKeysFromRealmTable.getTaskId ( )

inlineprotected

                                 {
        return "Update 2.3.0.Final";
    }

isApplicable()

boolean org.keycloak.connections.jpa.updater.liquibase.custom.CustomKeycloakTask.isApplicable ( ) throws CustomChangeException

inlineprotectedinherited

                                                                  {
        try {
            String correctedTableName = database.correctObjectName("REALM", Table.class);
            if (SnapshotGeneratorFactory.getInstance().has(new Table().setName(correctedTableName), database)) {
                ResultSet resultSet = connection.createStatement().executeQuery("SELECT ID FROM " + getTableName(correctedTableName));
                try {
                    return (resultSet.next());
                } finally {
                    resultSet.close();
                }
            } else {
                return false;
            }
        } catch (Exception e) {
            throw new CustomChangeException("Failed to check database availability", e);
        }
    }

setFileOpener()

void org.keycloak.connections.jpa.updater.liquibase.custom.CustomKeycloakTask.setFileOpener ( ResourceAccessor  resourceAccessor )

inlineinherited

                                                                 {

    }

setUp()

void org.keycloak.connections.jpa.updater.liquibase.custom.CustomKeycloakTask.setUp ( ) throws SetupException

inlineinherited

                                              {
        this.kcSession = ThreadLocalSessionContext.getCurrentSession();

        if (this.kcSession == null) {
            // Probably running Liquibase from maven plugin. Try to create kcSession programmatically
            logger.info("No KeycloakSession provided in ThreadLocal. Initializing KeycloakSessionFactory");

            try {
                DefaultKeycloakSessionFactory factory = new DefaultKeycloakSessionFactory();
                factory.init();
                this.kcSession = factory.create();
            } catch (Exception e) {
                throw new SetupException("Exception when initializing factory", e);
            }
        }
    }

validate()

ValidationErrors org.keycloak.connections.jpa.updater.liquibase.custom.CustomKeycloakTask.validate ( Database  database )

inlineinherited

                                                        {
        return null;
    }

メンバ詳解

confirmationMessage

StringBuilder org.keycloak.connections.jpa.updater.liquibase.custom.CustomKeycloakTask.confirmationMessage = new StringBuilder()

protectedinherited

connection

Connection org.keycloak.connections.jpa.updater.liquibase.custom.CustomKeycloakTask.connection

protectedinherited

database

Database org.keycloak.connections.jpa.updater.liquibase.custom.CustomKeycloakTask.database

protectedinherited

jdbcConnection

JdbcConnection org.keycloak.connections.jpa.updater.liquibase.custom.CustomKeycloakTask.jdbcConnection

protectedinherited

kcSession

KeycloakSession org.keycloak.connections.jpa.updater.liquibase.custom.CustomKeycloakTask.kcSession

protectedinherited

statements

List<SqlStatement> org.keycloak.connections.jpa.updater.liquibase.custom.CustomKeycloakTask.statements = new ArrayList<SqlStatement>()

protectedinherited

---

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

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