gitee
/
spring-oauth-server
mirror of https://gitee.com/shengzhao/spring-oauth-server
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

(151) - 数据添加Ehcache缓存支持

0.6
LSZ 2016-07-23 00:21:48 +08:00
parent ec46267f66
commit b6cf1fcd91
2 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/main/java/com/monkeyk/sos/infrastructure/jdbc/OauthRepositoryJdbc.java
View File

@ -13,7 +13,9 @@ package com.monkeyk.sos.infrastructure.jdbc;
import com.monkeyk.sos.domain.oauth.OauthClientDetails; import com.monkeyk.sos.domain.oauth.OauthClientDetails;
import com.monkeyk.sos.domain.oauth.OauthRepository; import com.monkeyk.sos.domain.oauth.OauthRepository;
import com.monkeyk.sos.infrastructure.CacheConstants;
import static com.monkeyk.sos.infrastructure.CacheConstants.*;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cache.annotation.CacheEvict; import org.springframework.cache.annotation.CacheEvict;
import org.springframework.cache.annotation.Cacheable; import org.springframework.cache.annotation.Cacheable;
@ -39,7 +41,7 @@ public class OauthRepositoryJdbc implements OauthRepository {
@Override @Override
@Cacheable(value = CacheConstants.CLIENT_DETAILS_CACHE, key = "#clientId") @Cacheable(value = CLIENT_DETAILS_CACHE, key = "#clientId")
public OauthClientDetails findOauthClientDetails(String clientId) { public OauthClientDetails findOauthClientDetails(String clientId) {
final String sql = " select * from oauth_client_details where client_id = ? "; final String sql = " select * from oauth_client_details where client_id = ? ";
final List<OauthClientDetails> list = this.jdbcTemplate.query(sql, new Object[]{clientId}, oauthClientDetailsRowMapper); final List<OauthClientDetails> list = this.jdbcTemplate.query(sql, new Object[]{clientId}, oauthClientDetailsRowMapper);
@ -53,7 +55,7 @@ public class OauthRepositoryJdbc implements OauthRepository {
} }
@Override @Override
@CacheEvict(value = CacheConstants.CLIENT_DETAILS_CACHE, key = "#clientId") @CacheEvict(value = CLIENT_DETAILS_CACHE, key = "#clientId")
public void updateOauthClientDetailsArchive(String clientId, boolean archive) { public void updateOauthClientDetailsArchive(String clientId, boolean archive) {
final String sql = " update oauth_client_details set archived = ? where client_id = ? "; final String sql = " update oauth_client_details set archived = ? where client_id = ? ";
this.jdbcTemplate.update(sql, archive, clientId); this.jdbcTemplate.update(sql, archive, clientId);

8
src/main/java/com/monkeyk/sos/infrastructure/jdbc/UserRepositoryJdbc.java
View File

@ -14,7 +14,9 @@ package com.monkeyk.sos.infrastructure.jdbc;
import com.monkeyk.sos.domain.user.Privilege; import com.monkeyk.sos.domain.user.Privilege;
import com.monkeyk.sos.domain.user.User; import com.monkeyk.sos.domain.user.User;
import com.monkeyk.sos.domain.user.UserRepository; import com.monkeyk.sos.domain.user.UserRepository;
import com.monkeyk.sos.infrastructure.CacheConstants;
import static com.monkeyk.sos.infrastructure.CacheConstants.*;
import org.apache.commons.lang.StringUtils; import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cache.annotation.CacheEvict; import org.springframework.cache.annotation.CacheEvict;
@ -96,7 +98,7 @@ public class UserRepositoryJdbc implements UserRepository {
} }
@Override @Override
@CacheEvict(value = CacheConstants.USER_CACHE, key = "#user.username()") @CacheEvict(value = USER_CACHE, key = "#user.username()")
public void updateUser(final User user) { public void updateUser(final User user) {
final String sql = " update user_ set username = ?, password = ?, phone = ?,email = ? where guid = ? "; final String sql = " update user_ set username = ?, password = ?, phone = ?,email = ? where guid = ? ";
this.jdbcTemplate.update(sql, ps -> { this.jdbcTemplate.update(sql, ps -> {
@ -111,7 +113,7 @@ public class UserRepositoryJdbc implements UserRepository {
} }
@Override @Override
@Cacheable(value = CacheConstants.USER_CACHE, key = "#username") @Cacheable(value = USER_CACHE, key = "#username")
public User findByUsername(String username) { public User findByUsername(String username) {
final String sql = " select * from user_ where username = ? and archived = 0 "; final String sql = " select * from user_ where username = ? and archived = 0 ";
final List<User> list = this.jdbcTemplate.query(sql, new Object[]{username}, userRowMapper); final List<User> list = this.jdbcTemplate.query(sql, new Object[]{username}, userRowMapper);