Polish JdbcOneTimeTokenService

This commit is contained in:
Max Batischev 2024-10-25 16:51:29 +03:00 committed by Josh Cummings
parent 726ab52e1a
commit 9cb81f8ad5

View File

@ -82,7 +82,7 @@ public final class JdbcOneTimeTokenService implements OneTimeTokenService, Dispo
// @formatter:on
// @formatter:off
private static final String SAVE_AUTHORIZED_CLIENT_SQL = "INSERT INTO " + TABLE_NAME
private static final String SAVE_ONE_TIME_TOKEN_SQL = "INSERT INTO " + TABLE_NAME
+ " (" + COLUMN_NAMES + ") VALUES (?, ?, ?)";
// @formatter:on
@ -97,7 +97,7 @@ public final class JdbcOneTimeTokenService implements OneTimeTokenService, Dispo
// @formatter:on
// @formatter:off
private static final String DELETE_SESSIONS_BY_EXPIRY_TIME_QUERY = "DELETE FROM "
private static final String DELETE_ONE_TIME_TOKENS_BY_EXPIRY_TIME_QUERY = "DELETE FROM "
+ TABLE_NAME
+ " WHERE expires_at < ?";
// @formatter:on
@ -113,7 +113,7 @@ public final class JdbcOneTimeTokenService implements OneTimeTokenService, Dispo
}
/**
* Sets the chron expression used for cleaning up expired sessions. The default is to
* Sets the chron expression used for cleaning up expired tokens. The default is to
* run hourly.
*
* For more advanced use cases the cleanupCron may be set to null which will disable
@ -141,7 +141,7 @@ public final class JdbcOneTimeTokenService implements OneTimeTokenService, Dispo
private void insertOneTimeToken(OneTimeToken oneTimeToken) {
List<SqlParameterValue> parameters = this.oneTimeTokenParametersMapper.apply(oneTimeToken);
PreparedStatementSetter pss = new ArgumentPreparedStatementSetter(parameters.toArray());
this.jdbcOperations.update(SAVE_AUTHORIZED_CLIENT_SQL, pss);
this.jdbcOperations.update(SAVE_ONE_TIME_TOKEN_SQL, pss);
}
@Override
@ -192,7 +192,7 @@ public final class JdbcOneTimeTokenService implements OneTimeTokenService, Dispo
public void cleanupExpiredTokens() {
List<SqlParameterValue> parameters = List.of(new SqlParameterValue(Types.TIMESTAMP, Instant.now()));
PreparedStatementSetter pss = new ArgumentPreparedStatementSetter(parameters.toArray());
int deletedCount = this.jdbcOperations.update(DELETE_SESSIONS_BY_EXPIRY_TIME_QUERY, pss);
int deletedCount = this.jdbcOperations.update(DELETE_ONE_TIME_TOKENS_BY_EXPIRY_TIME_QUERY, pss);
if (this.logger.isDebugEnabled()) {
this.logger.debug("Cleaned up " + deletedCount + " expired tokens");
}