摘要
看完本文你將掌握如下知識(shí)點(diǎn)：
- Spring Boot對(duì)MongoDB的支持
- Spring Boot對(duì)Redis的支持
SpringBoot系列：Spring Boot學(xué)習(xí)筆記
Spring Boot對(duì)MongoDB的支持
pom中加入依賴(lài)
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>
自定義Repository需要繼承于MongoRepository，與JPA類(lèi)似，同樣支持命名方法和@Query接口查詢。
按方法名進(jìn)行查詢，規(guī)則與JPA一致，@Query接口查詢就是mongo的原生查詢語(yǔ)句的語(yǔ)法類(lèi)似。
public interface PersonRepository extends MongoRepository<Person, String> {
//等于
List<Person> findByName(String name);
//And --- 等價(jià)于 SQL 中的 and 關(guān)鍵字；
List<Person> findByNameAndAge(String name, Integer age);
// Or --- 等價(jià)于 SQL 中的 or 關(guān)鍵字；
List<Person> findByNameOrAge(String name, Integer age);
//分頁(yè)
Page<Person> findByNameNot(String name, Pageable pageable);
//mongo原生查詢語(yǔ)句
//等于
@Query("{'age':?0}")
List<Person> withQueryFindByAge(Integer age);
//大于
@Query("{'age': {'$gt' : ?0}}")
List<Person> findByAgeGreaterThan(int age);
//正則匹配name，age范圍
@Query("{ 'name':{'$regex':?0,'$options':'i'}, 'age': {'$gte':?1,'$lte':?2}}")
public Page<Person> findByNameAndAgeRange(String name,int ageFrom,int ageTo,Pageable page);
//正則匹配name，age范圍，查詢結(jié)果只封裝name和age，當(dāng)然默認(rèn)ID是必須封裝的
@Query(value = "{ 'name':{'$regex':?0,'$options':'i'}, 'age': {'$gte':?1,'$lte':?2}}",fields = "{ 'name' : 1, 'age' : 1}")
public Page<Person> findByNameAndAgeRangeShow(String name,int ageFrom,int ageTo,Pageable page);
}
關(guān)于Mongo原生語(yǔ)句的說(shuō)明可以參考：http://www.cnblogs.com/egger/archive/2013/06/14/3135847.html
如果希望接管spring boot對(duì)mongo的自動(dòng)配置，可以創(chuàng)建如下配置類(lèi)，這樣我們也可以像前文介紹的JPA綁定多數(shù)據(jù)源那樣，綁定多個(gè)mongo數(shù)據(jù)源。
package com.example.mongo;
import com.mongodb.MongoClient;
import com.mongodb.MongoClientURI;
import com.mongodb.ServerAddress;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.mongodb.MongoDbFactory;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.SimpleMongoDbFactory;
import org.springframework.data.mongodb.repository.config.EnableMongoRepositories;
@Configuration
@EnableMongoRepositories(basePackages = {"com.example.mongo.dao"},mongoTemplateRef = "mongoTemplate")
public class MongoConfig {
@Value("${spring.data.mongodb.host}")
String mongoHost;
@Value("${spring.data.mongodb.uri}")
String mongoUrl;
@Bean
public MongoClient mongoClient() {
MongoClient mongoClient = new MongoClient(new ServerAddress(mongoHost));
return mongoClient;
}
@Bean
public MongoDbFactory mongoDbFactory(){
String database = new MongoClientURI(mongoUrl).getDatabase();
return new SimpleMongoDbFactory(mongoClient(),database);
}
@Bean(name = "mongoTemplate")
public MongoTemplate mongoTemplate(){
return new MongoTemplate(mongoDbFactory());
}
}
Spring Boot對(duì)Redis的支持
pom中加入依賴(lài)
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
然后就可以通過(guò)@Autowired注解注入RedisTemplate，比如：
package com.example.redis.dao;
import com.example.redis.domain.Student;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.core.ValueOperations;
import org.springframework.stereotype.Repository;
import javax.annotation.Resource;
@Repository
public class StudentDao {
@Autowired
StringRedisTemplate stringRedisTemplate;
@Autowired
RedisTemplate<Object,Object> redisTemplate;
@Resource(name = "stringRedisTemplate")
ValueOperations<String,String> valueOperationsStr;
@Resource(name = "redisTemplate")
ValueOperations<Object,Object> valueOperations;
public void setString(String key,String value){
valueOperationsStr.set(key,value);
}
public String getString(String key){
return valueOperationsStr.get(key);
}
public void saveStudent(Student student){
valueOperations.set(student.getId(),student);
}
public Student getStudent(String id){
return (Student)valueOperations.get(id);
}
}
同樣，如果希望接管spring boot對(duì)redis的自動(dòng)配置，可以創(chuàng)建如下自動(dòng)配置類(lèi)：
package com.example.redis;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;
@Configuration
public class RedisConfig {
@Value("${spring.redis.database}")
String redisDatabase;
@Value("${spring.redis.host}")
String redisHost;
@Bean
public JedisConnectionFactory connectionFactory(){
JedisConnectionFactory jedisConnectionFactory = new JedisConnectionFactory();
jedisConnectionFactory.setDatabase(Integer.valueOf(redisDatabase));
jedisConnectionFactory.setHostName(redisHost);
return jedisConnectionFactory;
}
@Bean
public Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer() {
ObjectMapper objectMapper = new ObjectMapper();
Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<Object>(
Object.class);
jackson2JsonRedisSerializer.setObjectMapper(objectMapper);
return jackson2JsonRedisSerializer;
}
//用于對(duì)存儲(chǔ)內(nèi)容轉(zhuǎn)換為json格式
@Bean(name = "redisTemplate")
public RedisTemplate<Object, Object> objRedisTemplate(JedisConnectionFactory connectionFactory,
Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer) {
RedisTemplate<Object, Object> redisTemplate = new RedisTemplate<Object, Object>();
redisTemplate.setConnectionFactory(connectionFactory);
redisTemplate.setDefaultSerializer(jackson2JsonRedisSerializer);
StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
redisTemplate.setKeySerializer(stringRedisSerializer);
redisTemplate.setHashKeySerializer(stringRedisSerializer);
return redisTemplate;
}
@Bean(name = "stringRedisTemplate")
public StringRedisTemplate stringRedisTemplate(JedisConnectionFactory connectionFactory) {
StringRedisTemplate stringRedisTemplate = new StringRedisTemplate(connectionFactory);
return stringRedisTemplate;
}
}
