Spring中使用MongoDB进行CRUD

2020-07-30

× 文章目录

1. 1.增加（Create）
2. 2.查询（Read）
3. 3.修改（Update）
4. 4.删除（Delete）
5. 5.条件查询（Query）

1.增加（Create）

调用mongoTemplate.insert()方法即可。

例：

   import org.springframework.data.mongodb.core.MongoTemplate;

   @Autowired
//使用@Autowried自动注入MongoTemplate实例
   private MongoTemplate mongoTemplate;

   	public void test() {
   		Song song = new Song();//新建一个Song类型的对象，用于储存专辑，歌手等信息
   		song.setSubjectId("s001");
   		song.setLyrics("Kalafina");
   		song.setName("満天");

   	mongoTemplate.insert(song);//将该Song对象添加至MongoTemplates数据库实例中
   }

2.查询（Read）

调用findById()方法即可。

findById()方法的第一个参数是主键id，第二个参数是具体的类

例：

   private static final Logger LOG = LoggerFactory.getLogger(SongService);

  @Autowired
  public Song get(String songId) {
  // 输入的主键 id 必须有文本，不能为空或全空格
  	if (!StringUtils.hasText(songId)) {
   		LOG.error("input songId is blank.");
   		return null;
}

  	Song song = mongoTemplate.findById(songId, Song.class);
	
  	return song;
  }

3.修改（Update）

修改的操作分为两个部分:

修改哪条数据?
改数据的哪个字段修改成什么值?

所以,修改操作也分为两部分:修改条件和修改的字段。

具体实现：

先使用条件对象 Criteria 构建条件对象 Query 实例，然后再调用修改对象 Update 的方法 .set() 设置需要修改的字段。最后调用 mongoTemplate.updateFirst(query, updateData, Song.class) 方法完成修改;第 3 个参数是具体的类

例：

  private static final Logger LOG = LoggerFactory.getLogger(SongService);
	
  @Override
  public boolean modify(Song song) {
// 作为服务，要对入参进行判断，不能假设被调用时，入参一定正确
if (song == null || !StringUtils.hasText(song.getId())) {
  LOG.error("input song data is not correct.");
  return false;
}

// 主键不能修改
Query query = new Query(Criteria.where("id").is(song.getId()));

Update updateData = new Update();
// 值为 null 表示不修改。值为长度为 0 的字符串 "" 表示清空此字段
if (song.getName() != null) {
	updateData.set("name", song.getName());  
}

if (song.getLyrics() != null) {
  updateData.set("lyrics", song.getLyrics());
}

if (song.getSubjectId() != null) {
  updateData.set("subjectId", song.getSubjectId());
}

UpdateResult result = mongoTemplate.updateFirst(query, updateData, Song.class);
return result != null && result.getModifiedCount() > 0;
//若result不为0且修改记录数大于0则返回true，否则返回false
  }

总结：mongoTemplate.updateFirst(query, updateData, Song.class)方法中，Song.class用于确定需要修改的数据类名，query用于通过唯一的id锁定要修改的具体数据是哪一个，updateData用于储存修改后的新数据。

4.删除（Delete）

调用mongoTemplate.remove()方法即可。

例：

  private static final Logger LOG = LoggerFactory.getLogger(SongService);
	
   @Override
  public boolean delete(String songId) {
// 输入的主键 id 必须有文本，不能为空或全空格
if (!StringUtils.hasText(songId)) {
  LOG.error("input songId is blank.");
  return false;
}

Song song = new Song();
song.setId(songId);
//创建一个对象并设置好属性值,作为删除的条件,符合条件的数据都将被删除 可以设置更多的属性值来提高
//精确性,但通过主键来删除数据,是保证不误删的一个比较好的办法

DeleteResult result = mongoTemplate.remove(song);
return result != null && result.getDeletedCount() > 0;
//若result不为0且修改记录数大于0则返回true，否则返回false
}

5.条件查询（Query）

需要引入的类：

1 2	import org.springframework.data.mongodb.core.query.Query; import org.springframework.data.mongodb.core.query.Criteria;

调用List<Song> songs = mongoTemplate.find(query, Song.class);方法

因为可能查询到多条数据,所以返回结果是对象的集合第一个参数是查询对象 Query 实例;第二个参数就表示查询什么样的对象,写法是类名.class 。

其中的query是Query类别，需要用Criteria类进行修饰确定。

1 2	Query query = new Query(criteria); //criteria是Criteria类别

Criteria类有两种定义方法：
1.单一条件：

1	Criteria criteria1 = Criteria.where("条件字段名").is("条件值");

2.组合条件

//第一种：or关系，调用orOperator()方法
Criteria criteria = new Criteria();
criteria.orOperator(criteria1, criteria2);

//第二种：and关系，调用andOperator()方法
Criteria criteria = new Criteria();
criteria.andOperator(criteria1, criteria2);

//两者可以组合使用

例：

//Service层代码：
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.data.mongodb.core.query.Criteria;

public List<Song> list(Song songParam) {
	// 总条件
	Criteria criteria = new Criteria();
	// 可能有多个子条件
	List<Criteria> subCris = new ArrayList();
	if (StringUtils.hasText(songParam.getName())) {
	  subCris.add(Criteria.where("name").is(songParam.getName()));
	}

	if (StringUtils.hasText(songParam.getLyrics())) {
	  subCris.add(Criteria.where("lyrics").is(songParam.getLyrics()));
	}

	if (StringUtils.hasText(songParam.getSubjectId())) {
	  subCris.add(Criteria.where("subjectId").is(songParam.getSubjectId()));
	}

	// 必须至少有一个查询条件
	if (subCris.isEmpty()) {
	  LOG.error("input song query param is not correct.");
	  return null;
	}

	// 三个子条件以 and 关键词连接成总条件对象，相当于 name='' and lyrics='' and subjectId=''
	criteria.andOperator(subCris.toArray(new Criteria[]{}));

	// 条件对象构建查询对象
	Query query = new Query(criteria);

	List<Song> songs = mongoTemplate.find(query, Song.class);

	return songs;
}


//Control层代码
@RequestMapping("/songlist")
public Map list(String subjectId, String name, String lyrics) {
Map returnData = new HashMap();
Song queryParam = new Song();
queryParam.setLyrics(lyrics);
queryParam.setName(name);
queryParam.setSubjectId(subjectId);
List<Song> songResult= songService.list(queryParam);

returnData.put("songResult", songResult);
return returnData;
}