|
1、简单的配置
2、通用DAO
1)接口
package cn.luxh.app.repository;
import java.util.List;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.data.mongodb.core.query.Update;
public interface MongoDBDao {
void save(Object obj);
T findOne(Class clazz, Query query);
List findAll(Class clazz);
T findById(Class clazz,Object id);
List find(Class clazz, Query query);
List findList(Class clazz,Query query,int currentPage,int pageSize);
long findCount(Class clazz,Query query);
int update(Query query,Update update,Class clazz);
}
2)接口实现
package cn.luxh.app.repository;
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.Query;
import org.springframework.data.mongodb.core.query.Update;
import org.springframework.stereotype.Repository;
@Repository
public class MongoDBDaoImpl implements MongoDBDao{
@Autowired
private MongoTemplate mongoTemplate;
@Override
public T findOne(Class clazz, Query query) {
return mongoTemplate.findOne(query, clazz);
}
@Override
public void save(Object obj) {
mongoTemplate.save(obj);
}
@Override
public List findAll(Class clazz) {
return mongoTemplate.findAll(clazz);
}
@Override
public T findById(Class clazz, Object id) {
return mongoTemplate.findById(id, clazz);
}
@Override
public List find(Class clazz, Query query) {
return mongoTemplate.find(query, clazz);
}
@Override
public List findList(Class clazz, Query query, int currentPage,
int pageSize) {
//计算起始位置
int startIndex = ((currentPage - 1) |
|
|