1.首先引入依赖
2.然后进行整合
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns="http://www.springframework.org/schema/beans"
xmlns:context="http://www.springframework.org/schema/context"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-4.0.xsd
">
<bean id="mongoClientUri" class="com.mongodb.MongoClientURI">
//用户名:密码@url:端口/数据库名
<constructor-arg name="uri" value="mongodb://yonhuming:mima@localhost:27017/dataName" />
</bean>
<bean id="mongoClient" class="com.mongodb.MongoClient">
<constructor-arg ref="mongoClientUri"/>
</bean>
<bean id="mongoDbFactory" class="org.springframework.data.mongodb.core.SimpleMongoDbFactory">
<constructor-arg ref="mongoClient"/>
//数据库名
<constructor-arg name="databaseName" value="dataName"/>
</bean>
<bean id="mongoTemplate" class="org.springframework.data.mongodb.core.MongoTemplate">
<constructor-arg ref="mongoDbFactory"/>
</bean>
</beans>
3.测试
@Controller
public class MongoDBTest {
@Autowired
private MongoTemplate mongoTemplate;
public void demo() {
//创建实体类
MarketKline marketKline = new MarketKline();
marketKline.setExchangeName("123");
//插入数据,需要指定数据库表名
mongoTemplate.insert(marketKline,"表名");
/**查询*/
//添加查询条件
criteria.andOperator(Criteria.where("name").is("张三"),Criteria.where("age").is("18");
//创建Query实例
Query query = new Query();
//根据年龄进行升序排序
query.with(new Sort(new Order(Direction.ASC,"age")));
query.addCriteria(criteria);
//进行查询
List list = mongoTemplate.find(query, 返回的实体类.getClass(),"数据库表名");
}
}