首页 > 代码库 > 使用Java操作MongoDB
使用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
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。