使用Java操作MongoDB详解数据库

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