Статьи

Интегрируйте MongoDB в свой проект Spring

В этой статье показано, как интегрировать MongoDB в ваш весенний проект с помощью конфигурации аннотаций.

Мы начнем с нашей конфигурации Gradle.

01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
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.8
 
dependencies {
 
 
    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'
}

Мы продолжим настройку MongoDB, используя весенние аннотации.

01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
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;
    }
 
}

Далее мы определим нашу модель. Мы создадим модель Location, которая будет содержать широту и долготу.

01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
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 {
 
    @Id
    private 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;
    }
}

Тогда мы создадим наш репозиторий

1
2
3
4
5
6
7
8
9
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> {
}

Тогда мы определим наш контроллер

01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
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 {
 
    @Autowired
    private LocationRepository locationRepository;
 
    private static final Logger LOGGER = LoggerFactory.getLogger(LocationRepository.class);
 
    @RequestMapping(value = "/",method = RequestMethod.POST)
    @ResponseBody
    public String post(@RequestBody Location location) {
 
        locationRepository.save(location);
 
        return "OK";
    }
 
    @RequestMapping(value = "/",method = RequestMethod.GET)
    @ResponseBody
    public List<Location> get() {
 
        List<Location> locations = new ArrayList<>();
        locationRepository.findAll().forEach(l->locations.add(l));
        return locations;
    }
 
}

Последний, но не менее важный наш класс Application

01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
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);
    }
 
}

Для того, чтобы бежать, просто беги

1
gradle bootRun