Question

springboot怎么连接mongodb的

Answer 1

springboot连接mongodb方法：
pom.xml

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>

<groupId>com.example</groupId>
<artifactId>myproject</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>

<name>myproject</name>
<url>http://maven.apache.org</url>

<!-- 要继承的项目 -->
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>1.2.7.RELEASE</version>
</parent>

<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>

<dependencies>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<scope>test</scope>
</dependency>

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
<exclusions>
<exclusion>
<artifactId>log4j-over-slf4j</artifactId>
<groupId>org.slf4j</groupId>
</exclusion>
</exclusions>
</dependency>

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

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

</dependencies>

<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>

<repositories>
<repository>
<id>spring-snapshots</id>
<url>http://repo.spring.io/snapshot</url>
<snapshots>
<enabled>true</enabled>
</snapshots>
</repository>
<repository>
<id>spring-milestones</id>
<url>http://repo.spring.io/milestone</url>
</repository>
</repositories>
</project>

package com.example.myproject.dao;

import Java.util.List;

import com.mongodb.DBObject;

public interface UserDao {

long count();

List<DBObject> find();

}

package com.example.myproject.dao.impl;

import java.util.ArrayList;
import java.util.List;

import javax.annotation.PostConstruct;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;

import com.example.myproject.dao.UserDao;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.DBObject;
import com.mongodb.MongoClient;

@Repository
public class UserDaoImpl implements UserDao{

@Autowired
MongoClient client;

DBCollection dbCollection;

//初始化方法
@PostConstruct
public void init(){

DB db = client.getDB("test");

dbCollection = db.getCollection("users");

}

public long count() {

return dbCollection.count();
}

public List<DBObject> find(){

DBCursor it = dbCollection.find();

List<DBObject> result=new ArrayList<DBObject>();

while(it.hasNext()){

DBObject object = it.next();

result.add(object);

}

return result;
}

}

测试类：
@RestController
@EnableAutoConfiguration
@ComponentScan
public class Example {

@Autowired
ConnectionSettings connection;

@Autowired
UserDaoImpl userDao;

private Logger logger = Logger.getLogger(Example.class);

@RequestMapping("/")
String home() throws UnknownHostException {

long count = userDao.count();

System.out.println(count);

List<DBObject> find = userDao.find();

for(int i=0;i<find.size();i++){

DBObject DBObject = find.get(i);

System.out.println(DBObject);
}

logger.info(connection.getName() + "--" + connection.getAge());

return connection.getName() + connection.getAge() + connection.getSex();
}

public static void main(String[] args) throws Exception {
SpringApplication.run(Example.class, args);
}

}