将MongoDB集成到您的Spring项目

本文展示了如何通过注释配置将MongoDB集成到您的spring项目中。

我们将从Gradle配置开始。

group 'com.gkatzioura.spring'
version '1.0-SNAPSHOT'buildscript {repositories {mavenCentral()}dependencies {classpath("org.springframework.boot:spring-boot-gradle-plugin:1.2.7.RELEASE")}
}apply plugin: 'java'
apply plugin: 'eclipse'
apply plugin: 'idea'
apply plugin: 'spring-boot'jar {baseName = 'mdb-spring-boot'version =  '0.1.0'
}repositories {mavenCentral()
}sourceCompatibility = 1.8
targetCompatibility = 1.8dependencies {compile("org.springframework.boot:spring-boot-starter-web")compile('com.googlecode.json-simple:json-simple:1.1.1')compile("org.springframework.boot:spring-boot-starter-actuator")compile("org.springframework.data:spring-data-mongodb:1.8.0.RELEASE")compile("ch.qos.logback:logback-classic:1.1.3")compile("ch.qos.logback:logback-core:1.1.3")compile("org.json:json:20150729")compile("com.google.code.gson:gson:2.4")compile("org.slf4j:slf4j-api:1.7.12")testCompile("junit:junit")testCompile('org.springframework.boot:spring-boot-starter-test')
}task wrapper(type: Wrapper) {gradleVersion = '2.3'
}

我们将使用spring注释继续进行MongoDB配置。

package com.gkatzioura.spring.config;import com.mongodb.MongoClient;
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 java.net.UnknownHostException;/*** Created by oSeven3 on 21/10/2015.*/
@Configuration
public class MongoDbConfiguration {public @Bean MongoDbFactory getMongoDbFactory() throws UnknownHostException {return new SimpleMongoDbFactory(new MongoClient("localhost",27017),"mongotest");}public @Bean(name = "mongoTemplate") MongoTemplate getMongoTemplate() throws UnknownHostException {MongoTemplate mongoTemplate = new MongoTemplate(getMongoDbFactory());return mongoTemplate;}}

接下来，我们将定义模型。我们将创建位置模型，其中将包含纬度经度。

package com.gkatzioura.spring.persistence.entities;import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.Document;import java.math.BigDecimal;
import java.util.Date;
import java.util.UUID;@Document(collection = "location")
public class Location {@Idprivate String id;private BigDecimal latitude;private BigDecimal longitude;private Date timestamp;public String getId() {return id;}public void setId(String id) {this.id = id;}public BigDecimal getLatitude() {return latitude;}public void setLatitude(BigDecimal latitude) {this.latitude = latitude;}public BigDecimal getLongitude() {return longitude;}public void setLongitude(BigDecimal longitude) {this.longitude = longitude;}public Date getTimestamp() {return timestamp;}public void setTimestamp(Date timestamp) {this.timestamp = timestamp;}
}

然后我们将创建我们的存储库

package com.gkatzioura.spring.persistence.repositories;import com.gkatzioura.spring.persistence.entities.Location;
import org.springframework.data.repository.CrudRepository;import java.util.UUID;public interface LocationRepository extends CrudRepository<Location,String> {
}

然后我们将定义我们的控制器

package com.gkatzioura.spring.controller;import com.gkatzioura.spring.persistence.entities.Location;
import com.gkatzioura.spring.persistence.repositories.LocationRepository;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;import java.util.ArrayList;
import java.util.List;import java.io.IOException;/*** Created by oSeven3 on 21/10/2015.*/@RestController
@RequestMapping("/location")
public class LocationController {@Autowiredprivate LocationRepository locationRepository;private static final Logger LOGGER = LoggerFactory.getLogger(LocationRepository.class);@RequestMapping(value = "/",method = RequestMethod.POST)@ResponseBodypublic String post(@RequestBody Location location) {locationRepository.save(location);return "OK";}@RequestMapping(value = "/",method = RequestMethod.GET)@ResponseBodypublic List<Location> get() {List<Location> locations = new ArrayList<>();locationRepository.findAll().forEach(l->locations.add(l));return locations;}}

最后但并非最不重要的是我们的Application类

package com.gkatzioura.spring;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;/*** Created by gkatziourasemmanouil on 8/15/15.*/
@SpringBootApplication
public class Application {public static void main(String[] args) {SpringApplication.run(Application.class, args);}}

为了跑就跑