Java连接MongoDB进行增删改查的操作

java连接mongodb进行增删改查的操作

1.创建数据库的连接，进行增删改查

（分别为接口和实现类）

package com.dao;

import java.util.list;

import org.springframework.beans.factory.annotation.autowired;
import org.springframework.data.mongodb.core.mongotemplate;
import org.springframework.data.mongodb.core.query.criteria;
import org.springframework.data.mongodb.core.query.query;
import org.springframework.stereotype.repository;

import com.bean.company;

@repository
public class repositoryimpl implements abstractrepository {
  @autowired
  private mongotemplate mongotemplate;

  // 查询所有数据
  public list<?> findall(class<?> entity) {
    return mongotemplate.findall(entity);
  }

  // 更新数据
  public company findone(string id, class<?> entity) {
    return (company) mongotemplate.findone(new query(criteria.where("id")
        .is(id)), entity);

  }

  // 添加到数据库
  public void updateentity(company company) {
    mongotemplate.save(company);
  }

  // 删除选中的数据
  public void delete(string id, class<company> class1) {
    criteria criteria = criteria.where("id").in(id);
    if (criteria != null) {
      query query = new query(criteria);
      if (query != null && mongotemplate.findone(query, class1) != null)
        mongotemplate.remove(mongotemplate.findone(query, class1));
    }

  }
  //增加到数据库
  public void insert(company company) {
    mongotemplate.insert(company);
    
  }

}

package com.dao;

import java.util.list;

import com.bean.company;

public interface abstractrepository {
  public list<?> findall(class<?> entity);
  
  public company findone(string id,class<?> entity);

  public void updateentity(company company);

  public void delete(string id, class<company> class1);

  public void insert(company company);
}

总结：与关系型数据库的连接一样，没有什么区别。

感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！