使用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("查询成功");
    }