springboot 使用mongodb

springboot中使用mongodb第一步需要在pom.xml中配置mongodb依賴

<dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>

接着在application.properties中添加連接相關參數

spring.data.mongodb.host = 127.0.0.1
spring.data.mongodb.port = 27017
spring.data.mongodb.database = test

這些參數會被用於自動創建與mongodb的連接

緊接着，為了自動創建與mongodb的連接需要配置bean，這里我使用如下方式，當然也可以使用xml配置的方式

@Configuration
public class AppConfig {
    @Value("${spring.data.mongodb.host}")
    private String mongoHost;

    @Value("${spring.data.mongodb.database}")
    private String mongoDatabase;

    @Value("${spring.data.mongodb.port}")
    private int mongoPort;

    @Bean
    public MongoClient mongoClient() throws Exception {
        return new MongoClient(this.mongoHost, this.mongoPort);
    }

    @Bean(name="mongoTemplate")
    public MongoTemplate mongoTemplate() throws Exception {
        MongoTemplate mongoTemplate = new MongoTemplate(mongoClient(), this.mongoDatabase);
        return mongoTemplate;
    }
}

這樣做主要是因為, MongoClient和MongoTemplate並不受由spring容器管理, 也就無法自動注入到dao中(為了自定義dao各種接口的實現，需要用到MongoTemplate)

@Repository
public class JobInfoRepositoryImpl implements BaseRepository {

    @Resource
    private MongoTemplate mongoTemplate;

    private final String collectionName = "jobinfos";

    public List<JobInfo> findAll() {
        return mongoTemplate.findAll(JobInfo.class, this.collectionName);
    }

    public long count(String query) {
        return this.mongoTemplate.count(new BasicQuery(query), this.collectionName);
    }
}

上面代碼中的BaseRepository是我自定義的一個接口, 為了定義一些公共的方法