(1)pom添加相关依赖

     <dependency>
<groupId>org.springframework.data</groupId>
<artifactId>spring-data-mongodb</artifactId>
<version>1.10.18.RELEASE</version>
</dependency>

(2)注册相关bean

 package cn.coreqi.config;

 import com.mongodb.Mongo;
import com.mongodb.MongoClient;
import com.mongodb.MongoCredential;
import com.mongodb.ServerAddress;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.mongodb.config.AbstractMongoConfiguration;
import org.springframework.data.mongodb.repository.config.EnableMongoRepositories;
import java.util.Arrays; @Configuration
@EnableMongoRepositories(basePackages = "cn.coreqi.dao.mongodb")
public class MongodbConfig extends AbstractMongoConfiguration { @Override
protected String getDatabaseName() {
return "springmongo";
} @Override
public Mongo mongo() throws Exception {
MongoCredential credential = MongoCredential.createCredential("fanqi","springmongo","123456".toCharArray());
return new MongoClient(new ServerAddress("192.168.205.128",27017), Arrays.asList(credential));
}
}

(3)编写实体类

 package cn.coreqi.entities;

 import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.Document;
import org.springframework.data.mongodb.core.mapping.Field; import java.io.Serializable; @Document
public class User implements Serializable {
@Id
private Integer Id;
@Field("age")
private Integer Age;
private String UserName;
private String PassWord;
private Integer Enabled; public User(Integer id, Integer age, String userName, String passWord, Integer enabled) {
Id = id;
Age = age;
UserName = userName;
PassWord = passWord;
Enabled = enabled;
} public Integer getId() {
return Id;
} public void setId(Integer id) {
Id = id;
} public Integer getAge() {
return Age;
} public void setAge(Integer age) {
Age = age;
} public String getUserName() {
return UserName;
} public void setUserName(String userName) {
UserName = userName;
} public String getPassWord() {
return PassWord;
} public void setPassWord(String passWord) {
PassWord = passWord;
} public Integer getEnabled() {
return Enabled;
} public void setEnabled(Integer enabled) {
Enabled = enabled;
} @Override
public String toString() {
return "User{" +
"Id=" + Id +
", Age=" + Age +
", UserName='" + UserName + '\'' +
", PassWord='" + PassWord + '\'' +
", Enabled=" + Enabled +
'}';
}
}

(4)编写dao

 package cn.coreqi.dao.mongodb;

 import cn.coreqi.entities.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.MongoOperations;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.stereotype.Repository; @Repository
public class UserMongoDao {
@Autowired
private MongoOperations mongo; public long count(){
return mongo.getCollection("user").count();
}
public void addUser(User user){
mongo.save(user,"user");
}
public User getById(int id){
return mongo.findById(id,User.class);
}
public User getByUserName(String userName){
return mongo.findOne(Query.query(Criteria.where("UserName").is(userName)),User.class);
}
public void delById(int id){
mongo.remove(Query.query(Criteria.where("Id").is(id)),User.class);
}
}

最新文章

  1. unity3d 赛车游戏——复位点检测
  2. Linux-守护进程的实现
  3. jquery 设置select 默认值
  4. 熔断器设计模式&lt;转&gt;
  5. CoreAnimation3-专用图层
  6. Android学习4&mdash;短信发送器的实现
  7. 远程连接mysql数据库,1130问题
  8. zookeeper的安装及集群配置
  9. Vim命令快捷键(网摘)
  10. vue2.0 练习项目-外卖APP(1)
  11. 【Spring源码分析】配置文件读取流程
  12. linux expect 即exp脚本交互功能【原】
  13. Java面试题整理:这些Java程序员面试中经常遇见的题目,必须掌握才能有好结果
  14. React 学习过程中常见的错误
  15. 一个springboot注解不成功的小问题
  16. Django 系统日志logging
  17. Dockerfile 部署 nodejs
  18. MVC高级编程-目录
  19. Java基础(三):修饰符、运算符、循环结构和分支结构
  20. 安装 Android Studio 2.3 详细过程及错误解决

热门文章

  1. 自学Linux Shell2.2-GHOME Terminal仿真器
  2. [luogu4868]Preprefix sum
  3. C代码快速构建框架
  4. luogu1514 [NOIp2010]引水入城 (bfs+记忆化搜索)
  5. react缓存问题
  6. 警告: No data sources are configured to run this SQL and provide advanced code assistance. Disable this inspection via problem menu (Alt+Enter). more... (Ctrl+F1) SQL dialect is not configured. Postgr
  7. struts下载
  8. PLSQL Developer 连接Linux 下Oracle的安装与配置
  9. ajax跨域原理以及jsonp使用
  10. springboot下实现邮件发送功能