org.springframework.session.jdbc

Class JdbcOperationsSessionRepository

java.lang.Object

org.springframework.session.jdbc.JdbcOperationsSessionRepository

All Implemented Interfaces:

FindByIndexNameSessionRepository<org.springframework.session.jdbc.JdbcOperationsSessionRepository.JdbcSession>, SessionRepository<org.springframework.session.jdbc.JdbcOperationsSessionRepository.JdbcSession>

public class JdbcOperationsSessionRepository
extends java.lang.Object
implements FindByIndexNameSessionRepository<org.springframework.session.jdbc.JdbcOperationsSessionRepository.JdbcSession>

A SessionRepository implementation that uses Spring's JdbcOperations to store sessions in a relational database. This implementation does not support publishing of session events.

An example of how to create a new instance can be seen below:

 JdbcTemplate jdbcTemplate = new JdbcTemplate();

 // ... configure jdbcTemplate ...

 PlatformTransactionManager transactionManager = new DataSourceTransactionManager();

 // ... configure transactionManager ...

 JdbcOperationsSessionRepository sessionRepository =
         new JdbcOperationsSessionRepository(jdbcTemplate, transactionManager);
 

For additional information on how to create and configure JdbcTemplate and PlatformTransactionManager, refer to the Spring Framework Reference Documentation.

By default, this implementation uses SPRING_SESSION and SPRING_SESSION_ATTRIBUTES tables to store sessions. Note that the table name can be customized using the setTableName(String) method. In that case the table used to store attributes will be named using the provided table name, suffixed with _ATTRIBUTES. Depending on your database, the table definition can be described as below:

 CREATE TABLE SPRING_SESSION (
   SESSION_ID CHAR(36),
   CREATION_TIME BIGINT NOT NULL,
   LAST_ACCESS_TIME BIGINT NOT NULL,
   MAX_INACTIVE_INTERVAL INT NOT NULL,
   PRINCIPAL_NAME VARCHAR(100),
   CONSTRAINT SPRING_SESSION_PK PRIMARY KEY (SESSION_ID)
 );

 CREATE INDEX SPRING_SESSION_IX1 ON SPRING_SESSION (LAST_ACCESS_TIME);
 CREATE INDEX SPRING_SESSION_IX2 ON SPRING_SESSION (PRINCIPAL_NAME);

 CREATE TABLE SPRING_SESSION_ATTRIBUTES (
  SESSION_ID CHAR(36),
  ATTRIBUTE_NAME VARCHAR(200),
  ATTRIBUTE_BYTES BYTEA,
  CONSTRAINT SPRING_SESSION_ATTRIBUTES_PK PRIMARY KEY (SESSION_ID, ATTRIBUTE_NAME),
  CONSTRAINT SPRING_SESSION_ATTRIBUTES_FK FOREIGN KEY (SESSION_ID) REFERENCES SPRING_SESSION(SESSION_ID) ON DELETE CASCADE
 );

 CREATE INDEX SPRING_SESSION_ATTRIBUTES_IX1 ON SPRING_SESSION_ATTRIBUTES (SESSION_ID);
 

Due to the differences between the various database vendors, especially when it comes to storing binary data, make sure to use SQL script specific to your database. Scripts for most major database vendors are packaged as org/springframework/session/jdbc/schema-*.sql, where * is the target database type.

Since:

1.2.0

Author:

Vedran Pavic

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DEFAULT_TABLE_NAME The default name of database table used by Spring Session to store sessions.

Fields inherited from interface org.springframework.session.FindByIndexNameSessionRepository

PRINCIPAL_NAME_INDEX_NAME

Constructor Summary

Constructors

Constructor and Description
JdbcOperationsSessionRepository(javax.sql.DataSource dataSource, org.springframework.transaction.PlatformTransactionManager transactionManager) Create a new JdbcOperationsSessionRepository instance which uses the default JdbcOperations to manage sessions.
JdbcOperationsSessionRepository(org.springframework.jdbc.core.JdbcOperations jdbcOperations, org.springframework.transaction.PlatformTransactionManager transactionManager) Create a new JdbcOperationsSessionRepository instance which uses the provided JdbcOperations to manage sessions.

Method Summary

Modifier and Type	Method and Description
void	cleanUpExpiredSessions()
org.springframework.session.jdbc.JdbcOperationsSessionRepository.JdbcSession	createSession() Creates a new Session that is capable of being persisted by this SessionRepository.
void	delete(java.lang.String id) Deletes the Session with the given Session.getId() or does nothing if the Session is not found.
java.util.Map<java.lang.String,org.springframework.session.jdbc.JdbcOperationsSessionRepository.JdbcSession>	findByIndexNameAndIndexValue(java.lang.String indexName, java.lang.String indexValue) Find a Map of the session id to the Session of all sessions that contain the session attribute with the name FindByIndexNameSessionRepository.PRINCIPAL_NAME_INDEX_NAME and the value of the specified principal name.
org.springframework.session.jdbc.JdbcOperationsSessionRepository.JdbcSession	getSession(java.lang.String id) Gets the Session by the Session.getId() or null if no Session is found.
void	save(org.springframework.session.jdbc.JdbcOperationsSessionRepository.JdbcSession session) Ensures the Session created by SessionRepository.createSession() is saved.
void	setConversionService(org.springframework.core.convert.ConversionService conversionService) Sets the ConversionService to use.
void	setCreateSessionAttributeQuery(java.lang.String createSessionAttributeQuery) Set the custom SQL query used to create the session attribute.
void	setCreateSessionQuery(java.lang.String createSessionQuery) Set the custom SQL query used to create the session.
void	setDefaultMaxInactiveInterval(java.lang.Integer defaultMaxInactiveInterval) Set the maximum inactive interval in seconds between requests before newly created sessions will be invalidated.
void	setDeleteSessionAttributeQuery(java.lang.String deleteSessionAttributeQuery) Set the custom SQL query used to delete the session attribute.
void	setDeleteSessionQuery(java.lang.String deleteSessionQuery) Set the custom SQL query used to delete the session.
void	setDeleteSessionsByLastAccessTimeQuery(java.lang.String deleteSessionsByLastAccessTimeQuery) Set the custom SQL query used to delete the sessions by last access time.
void	setGetSessionQuery(java.lang.String getSessionQuery) Set the custom SQL query used to retrieve the session.
void	setListSessionsByPrincipalNameQuery(java.lang.String listSessionsByPrincipalNameQuery) Set the custom SQL query used to retrieve the sessions by principal name.
void	setLobHandler(org.springframework.jdbc.support.lob.LobHandler lobHandler)
void	setTableName(java.lang.String tableName) Set the name of database table used to store sessions.
void	setUpdateSessionAttributeQuery(java.lang.String updateSessionAttributeQuery) Set the custom SQL query used to update the session attribute.
void	setUpdateSessionQuery(java.lang.String updateSessionQuery) Set the custom SQL query used to update the session.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

DEFAULT_TABLE_NAME

public static final java.lang.String DEFAULT_TABLE_NAME

The default name of database table used by Spring Session to store sessions.

See Also:

Constant Field Values

Constructor Detail

JdbcOperationsSessionRepository

public JdbcOperationsSessionRepository(javax.sql.DataSource dataSource,
                                       org.springframework.transaction.PlatformTransactionManager transactionManager)

Create a new JdbcOperationsSessionRepository instance which uses the default JdbcOperations to manage sessions.

Parameters:

dataSource - the DataSource to use

transactionManager - the PlatformTransactionManager to use

JdbcOperationsSessionRepository

public JdbcOperationsSessionRepository(org.springframework.jdbc.core.JdbcOperations jdbcOperations,
                                       org.springframework.transaction.PlatformTransactionManager transactionManager)

Create a new JdbcOperationsSessionRepository instance which uses the provided JdbcOperations to manage sessions.

Parameters:

jdbcOperations - the JdbcOperations to use

transactionManager - the PlatformTransactionManager to use

Method Detail

setTableName

public void setTableName(java.lang.String tableName)

Set the name of database table used to store sessions.

Parameters:

tableName - the database table name

setCreateSessionQuery

public void setCreateSessionQuery(java.lang.String createSessionQuery)

Set the custom SQL query used to create the session.

Parameters:

createSessionQuery - the SQL query string

setCreateSessionAttributeQuery

public void setCreateSessionAttributeQuery(java.lang.String createSessionAttributeQuery)

Set the custom SQL query used to create the session attribute.

Parameters:

createSessionAttributeQuery - the SQL query string

setGetSessionQuery

public void setGetSessionQuery(java.lang.String getSessionQuery)

Set the custom SQL query used to retrieve the session.

Parameters:

getSessionQuery - the SQL query string

setUpdateSessionQuery

public void setUpdateSessionQuery(java.lang.String updateSessionQuery)

Set the custom SQL query used to update the session.

Parameters:

updateSessionQuery - the SQL query string

setUpdateSessionAttributeQuery

public void setUpdateSessionAttributeQuery(java.lang.String updateSessionAttributeQuery)

Set the custom SQL query used to update the session attribute.

Parameters:

updateSessionAttributeQuery - the SQL query string

setDeleteSessionAttributeQuery

public void setDeleteSessionAttributeQuery(java.lang.String deleteSessionAttributeQuery)

Set the custom SQL query used to delete the session attribute.

Parameters:

deleteSessionAttributeQuery - the SQL query string

setDeleteSessionQuery

public void setDeleteSessionQuery(java.lang.String deleteSessionQuery)

Set the custom SQL query used to delete the session.

Parameters:

deleteSessionQuery - the SQL query string

setListSessionsByPrincipalNameQuery

public void setListSessionsByPrincipalNameQuery(java.lang.String listSessionsByPrincipalNameQuery)

Set the custom SQL query used to retrieve the sessions by principal name.

Parameters:

listSessionsByPrincipalNameQuery - the SQL query string

setDeleteSessionsByLastAccessTimeQuery

public void setDeleteSessionsByLastAccessTimeQuery(java.lang.String deleteSessionsByLastAccessTimeQuery)

Set the custom SQL query used to delete the sessions by last access time.

Parameters:

deleteSessionsByLastAccessTimeQuery - the SQL query string

setDefaultMaxInactiveInterval

public void setDefaultMaxInactiveInterval(java.lang.Integer defaultMaxInactiveInterval)

Set the maximum inactive interval in seconds between requests before newly created sessions will be invalidated. A negative time indicates that the session will never timeout. The default is 1800 (30 minutes).

Parameters:

defaultMaxInactiveInterval - the maximum inactive interval in seconds

setLobHandler

public void setLobHandler(org.springframework.jdbc.support.lob.LobHandler lobHandler)

setConversionService

public void setConversionService(org.springframework.core.convert.ConversionService conversionService)

Sets the ConversionService to use.

Parameters:

conversionService - the converter to set

createSession

public org.springframework.session.jdbc.JdbcOperationsSessionRepository.JdbcSession createSession()

Description copied from interface: SessionRepository

Creates a new Session that is capable of being persisted by this SessionRepository.

This allows optimizations and customizations in how the Session is persisted. For example, the implementation returned might keep track of the changes ensuring that only the delta needs to be persisted on a save.

Specified by:

createSession in interface SessionRepository<org.springframework.session.jdbc.JdbcOperationsSessionRepository.JdbcSession>

Returns:

a new Session that is capable of being persisted by this SessionRepository

save

public void save(org.springframework.session.jdbc.JdbcOperationsSessionRepository.JdbcSession session)

Description copied from interface: SessionRepository

Ensures the Session created by SessionRepository.createSession() is saved.

Some implementations may choose to save as the Session is updated by returning a Session that immediately persists any changes. In this case, this method may not actually do anything.

Specified by:

save in interface SessionRepository<org.springframework.session.jdbc.JdbcOperationsSessionRepository.JdbcSession>

Parameters:

session - the Session to save

getSession

public org.springframework.session.jdbc.JdbcOperationsSessionRepository.JdbcSession getSession(java.lang.String id)

Description copied from interface: SessionRepository

Gets the Session by the Session.getId() or null if no Session is found.

Specified by:

getSession in interface SessionRepository<org.springframework.session.jdbc.JdbcOperationsSessionRepository.JdbcSession>

Parameters:

id - the Session.getId() to lookup

Returns:

the Session by the Session.getId() or null if no Session is found.

delete

public void delete(java.lang.String id)

Description copied from interface: SessionRepository

Deletes the Session with the given Session.getId() or does nothing if the Session is not found.

Specified by:

delete in interface SessionRepository<org.springframework.session.jdbc.JdbcOperationsSessionRepository.JdbcSession>

Parameters:

id - the Session.getId() to delete

findByIndexNameAndIndexValue

public java.util.Map<java.lang.String,org.springframework.session.jdbc.JdbcOperationsSessionRepository.JdbcSession> findByIndexNameAndIndexValue(java.lang.String indexName,
                                                                                                                                                 java.lang.String indexValue)

Description copied from interface: FindByIndexNameSessionRepository

Find a Map of the session id to the Session of all sessions that contain the session attribute with the name FindByIndexNameSessionRepository.PRINCIPAL_NAME_INDEX_NAME and the value of the specified principal name.

Specified by:

findByIndexNameAndIndexValue in interface FindByIndexNameSessionRepository<org.springframework.session.jdbc.JdbcOperationsSessionRepository.JdbcSession>

Parameters:

indexName - the name of the index (i.e. FindByIndexNameSessionRepository.PRINCIPAL_NAME_INDEX_NAME)

indexValue - the value of the index to search for.

Returns:

a Map (never null) of the session id to the Session of all sessions that contain the session specified index name and the value of the specified index name. If no results are found, an empty Map is returned.

cleanUpExpiredSessions

@Scheduled(cron="${spring.session.cleanup.cron.expression:0 * * * * *}")
public void cleanUpExpiredSessions()