Mongodb的核心数据操作MongodbBaseDao,
public abstract class MongodbBaseDao {
Logger log = Logger.getLogger(this.getClass()); // spring mongodb 集成操作类
// protected MongoTemplate
// mongoTemplate; //
// 链接本地数据库并创建数据表
public void CreateCollection(String collectionName) {
try {
log.info("Collection created successfully");
} catch (Exception e) {
System.err.println(e.getClass().getName() + ": " + e.getMessage());
}
} // 获取数据表 public DBCollection GetCollection(String collectionName) {
// DBCollection coll = null; try { coll =
// mongoTemplate.getCollection(collectionName); return coll; } catch
// (Exception e) { System.err.println(e.getClass().getName() + ": " +
// e.getMessage()); } return coll; } // 通过条件查询实体(集合) public List<T>
// Listfind(Query query) { return mongoTemplate.find(query,
// this.getEntityClass()); } // 通过一定的条件查询一个实体 public T findOne(Query
// query) { return (T) mongoTemplate.findOne(query,
// this.getEntityClass()); } // 通过条件查询更新数据 public void update(Query
// query, Update update) { mongoTemplate.upsert(query, update,
// this.getEntityClass()); } // 保存一个对象到mongodb public T save(T bean) {
// mongoTemplate.save(bean); return bean; } // 通过ID获取记录 public T
// get(String id) { return (T) mongoTemplate.findById(id,
// this.getEntityClass()); } // 通过ID获取记录,并且指定了集合名 public T get(String
// id, String collectionName) { return (T) mongoTemplate.findById(id,
// this.getEntityClass(), collectionName); } // 获取需要操作的实体类class
// protected abstract Class getEntityClass(); //
// spring容器注入mongodbTemplate protected abstract void
// setMongoTemplate(MongoTemplate mongoTemplate);
}
本站文章为和通数据库网友分享或者投稿,欢迎任何形式的转载,但请务必注明出处.
同时文章内容如有侵犯了您的权益,请联系QQ:970679559,我们会在尽快处理。