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

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

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

クラス
class	Key

公開メンバ関数
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>()

詳解

著者

hmlnarik

関数詳解

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.RemoveDuplicateOfflineSessions.generateStatementsImpl ( ) throws CustomChangeException

inlineprotected

                                                                         {
        Set<String> clientSessionIdsToDelete = new HashSet<>();

        String tableName = getTableName("OFFLINE_CLIENT_SESSION");
        String colClientSessionId = database.correctObjectName("CLIENT_SESSION_ID", Column.class);

        try (PreparedStatement ps = connection.prepareStatement(String.format(
            "SELECT t.CLIENT_SESSION_ID, t.USER_SESSION_ID, t.CLIENT_ID, t.OFFLINE_FLAG" +
            "  FROM %1$s t," +
            "    (SELECT USER_SESSION_ID, CLIENT_ID, OFFLINE_FLAG" +
            "      FROM %1$s" +
            "    GROUP BY USER_SESSION_ID, CLIENT_ID, OFFLINE_FLAG" +
            "    HAVING COUNT(*) > 1) t1" +
            "  WHERE t.USER_SESSION_ID = t1.USER_SESSION_ID" +
            "    AND t.CLIENT_ID = t1.CLIENT_ID" +
            "    AND t.OFFLINE_FLAG = t1.OFFLINE_FLAG" +
            "  ORDER BY t.USER_SESSION_ID, t.CLIENT_ID, t.OFFLINE_FLAG", tableName));

            ResultSet resultSet = ps.executeQuery()
          ) {
            // Find out all offending duplicates, keep first row only
            Key origKey = new Key(null, null, null);
            while (resultSet.next()) {
                String clientSessionId = resultSet.getString(1);
                Key key = new Key(resultSet.getString(2), resultSet.getString(3), resultSet.getString(4));

                if (key.equals(origKey)) {
                    clientSessionIdsToDelete.add(clientSessionId);
                } else {
                    origKey = key;
                }
            }
        } catch (Exception e) {
            throw new CustomChangeException(getTaskId() + ": Exception when updating data from previous version", e);
        }

        AtomicInteger ai = new AtomicInteger();
        clientSessionIdsToDelete.stream()
          .collect(Collectors.groupingByConcurrent(id -> ai.getAndIncrement() / 20, Collectors.toList())) // Split into chunks of at most 20 items

          .values().stream()
          .map(ids -> new DeleteStatement(null, null, "OFFLINE_CLIENT_SESSION")
            .setWhere(":name IN (" + ids.stream().map(id -> "?").collect(Collectors.joining(",")) + ")")
            .addWhereColumnName(colClientSessionId)
            .addWhereParameters(ids.toArray())
          )
          .forEach(statements::add);
    }

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.RemoveDuplicateOfflineSessions.getTaskId ( )

inlineprotected

                                 {
        return "Leave only single offline session per user and client";
    }

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/RemoveDuplicateOfflineSessions.java