package com.gxx.record.service.impl; import org.apache.log4j.Logger; 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.Service; import com.gxx.record.base.vo.Friend; import com.gxx.record.base.vo.Student; import com.gxx.record.dto.MongodbDto; import com.gxx.record.service.MongodbService; /** *
*
Title:
*
* mongodb服务实现类 *
*
Description:
*
*

none *

*
* * @author Administrator * @version 1.0, 2015年7月23日 * @since record * */ @Service("mongodbService") public class MongodbServiceImpl implements MongodbService { /** * 日志处理器 */ private final Logger logger = Logger.getLogger(MongodbServiceImpl.class); @Autowired private MongoTemplate mongoTemplate; @Override public boolean save(MongodbDto mongodbDto) { Student student = get(mongodbDto.getName()); if(null == student){ student = new Student(); } student.setName(mongodbDto.getName()); Friend friend = new Friend(); friend.setName(mongodbDto.getFriendName()); friend.setSex(mongodbDto.isFriendSex()); student.setFriend(friend); mongoTemplate.save(student); logger.info("插入mongodb完成!"); return false; } @Override public Student get(String name) { Query query = new Query(); query.addCriteria(new Criteria("name").is(name)); Student student = mongoTemplate.findOne(query, Student.class); logger.info("查询到mongodb实体:" + student); return student; } }