使用Java操作MongoDB
Posted 纪煜楷
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了使用Java操作MongoDB相关的知识,希望对你有一定的参考价值。
该篇比较简单,仅介绍Java操作MongoDB的简单CRUD案例,开搞前需要引入mongo-java-driver-3.2.2.jar,Java操作MongoDB的API众多,高级功能还需查询官方文档。
public void insert() { // 建立数据库连接 Mongo mongo = new Mongo("localhost", 27017); // 获取指定的数据库 DB db = mongo.getDB("kaiye"); // 获取指定的集合 DBCollection dbc = db.getCollection("c6"); // 获取操作增删改查的对象 DBObject dbo = new BasicDBObject(); dbo.put("name", "梓璇"); dbo.put("age", "22"); dbc.insert(dbo); // 关闭数据库链接 mongo.close(); System.out.println("插入成功"); }
@Override public void delete() { // 建立数据库连接 Mongo mongo = new Mongo("localhost", 27017); // 获取指定的数据库 DB db = mongo.getDB("kaiye"); // 获取指定的集合 DBCollection dbc = db.getCollection("c5"); // 获取操作增删改查的对象 DBObject dbo = new BasicDBObject(); dbo.put("name", "jumo"); dbc.remove(dbo); // 关闭数据库链接 mongo.close(); System.out.println("删除成功"); }
@Override public void update() { // 建立数据库连接 Mongo mongo = new Mongo("localhost", 27017); // 获取指定的数据库 DB db = mongo.getDB("kaiye"); // 获取指定的集合 DBCollection dbc = db.getCollection("c4"); // 获取操作增删改查的对象 DBObject query = new BasicDBObject("age",7); DBObject update = dbc.findOne(query); update.put("name", "xuxuanli"); dbc.update(query, update, true, true); // 关闭数据库链接 mongo.close(); System.out.println("更新成功"); }
@Override public void query() { // 建立数据库连接 Mongo mongo = new Mongo("localhost", 27017); // 获取指定的数据库 DB db = mongo.getDB("kaiye"); // 获取指定的集合 DBCollection dbc = db.getCollection("c6"); // 获取操作增删改查的对象 DBObject dbo = new BasicDBObject(); // 查询条件 dbo.put("age", "89"); // 游标查询 DBCursor dbCursor = dbc.find(dbo); // 遍历结果集,获取返回结果 while (dbCursor.hasNext()) { DBObject dbo1 = dbCursor.next(); System.out.println(dbo1); } System.out.println("查询成功"); }
以上是关于使用Java操作MongoDB的主要内容,如果未能解决你的问题,请参考以下文章