org.keycloak.connections.jpa.updater.liquibase.lock.CustomLockDatabaseChangeLogGenerator クラス

org.keycloak.connections.jpa.updater.liquibase.lock.CustomLockDatabaseChangeLogGenerator の継承関係図

org.keycloak.connections.jpa.updater.liquibase.lock.CustomLockDatabaseChangeLogGenerator 連携図

公開メンバ関数
int	getPriority ()
Sql []	generateSql (LockDatabaseChangeLogStatement statement, Database database, SqlGeneratorChain sqlGeneratorChain)

非公開メンバ関数
Sql	generateSelectForUpdate (Database database)

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

詳解

We use "SELECT FOR UPDATE" pessimistic locking (Same algorithm like Hibernate LockMode.PESSIMISTIC_WRITE )

著者

Marek Posolda

関数詳解

generateSelectForUpdate()

Sql org.keycloak.connections.jpa.updater.liquibase.lock.CustomLockDatabaseChangeLogGenerator.generateSelectForUpdate ( Database  database )

inlineprivate

                                                           {
        String catalog = database.getLiquibaseCatalogName();
        String schema = database.getLiquibaseSchemaName();
        String rawLockTableName = database.getDatabaseChangeLogLockTableName();

        String lockTableName = database.escapeTableName(catalog, schema, rawLockTableName);
        String idColumnName  = database.escapeColumnName(catalog, schema, rawLockTableName, "ID");

        String sqlBase = "SELECT " + idColumnName + " FROM " + lockTableName;
        String sqlWhere = " WHERE " + idColumnName + "=1";

        String sql;
        if (database instanceof MySQLDatabase || database instanceof PostgresDatabase || database instanceof H2Database ||
                database instanceof OracleDatabase) {
            sql = sqlBase + sqlWhere + " FOR UPDATE";
        } else if (database instanceof MSSQLDatabase) {
            sql = sqlBase + " WITH (UPDLOCK, ROWLOCK)" + sqlWhere;
        } else if (database instanceof DB2Database) {
            sql = sqlBase + sqlWhere +  " FOR READ ONLY WITH RS USE AND KEEP UPDATE LOCKS";
        } else {
            sql = sqlBase + sqlWhere;
            logger.warnf("No direct support for database %s . Database lock may not work correctly", database.getClass().getName());
        }

        logger.debugf("SQL command for pessimistic lock: %s", sql);
        
        return new UnparsedSql(sql);
    }

generateSql()

Sql [] org.keycloak.connections.jpa.updater.liquibase.lock.CustomLockDatabaseChangeLogGenerator.generateSql ( LockDatabaseChangeLogStatement  statement, Database  database, SqlGeneratorChain  sqlGeneratorChain  )

inline

                                                                                                                               {

        Sql selectForUpdateSql = generateSelectForUpdate(database);

        return new Sql[] { selectForUpdateSql };
    }

getPriority()

int org.keycloak.connections.jpa.updater.liquibase.lock.CustomLockDatabaseChangeLogGenerator.getPriority ( )

inline

                             {
        return super.getPriority() + 1; // Ensure bigger priority than LockDatabaseChangeLogGenerator
    }

メンバ詳解

logger

final Logger org.keycloak.connections.jpa.updater.liquibase.lock.CustomLockDatabaseChangeLogGenerator.logger = Logger.getLogger(CustomLockDatabaseChangeLogGenerator.class)

staticprivate

---

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

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