Java操作Mongo
// 创建连接
MongoClient mongoClient = new MongoClient(Arrays.asList(new ServerAddress("localhost", 27017),
new ServerAddress("localhost", 27018),
new ServerAddress("localhost", 27019)));
//使用mydb数据库
DB db = mongoClient.getDB( "mydb" );
//获取所有Collection
Set<String> colls = db.getCollectionNames();
for (String s : colls) {
System.out.println(s);
}
//获取特定Collection
DBCollection coll = db.getCollection("testCollection");
//写入一个Document
BasicDBObject doc = new BasicDBObject("name", "MongoDB")
.append("type", "database")
.append("count", 1)
.append("info", new BasicDBObject("x", 203).append("y", 102));
coll.insert(doc);
//查询一个Collection中第一个Document
DBObject myDoc = coll.findOne();
System.out.println(myDoc);
//查询Collection中所有Documents
DBCursor cursor = coll.find();
try {
while(cursor.hasNext()) {
System.out.println(cursor.next());
}
} finally {
cursor.close();
}
Reference
时间: 2024-08-02 17:29:41