java对mongoDB 的基本操作

MongoClient client = MongoDBConnection.getInstance("192.168.128.104", 27017);

MongoDatabase mongoDatabase = client.getDatabase(database);

mongoDatabase.createCollection(collection);

MongoCollection< Document> collection=database.getCollection("users");
//设置查找条件
Bson filterBson = Filters.gte("sul1", "sul1");
Bson filter2 = Filters.gte("xul2", "xul2");
//多个条件组合
Bson bson = Filters.and(filter2,filterBson);
FindIterable< Document> result = collection.find(bson);
for(Document doc : result){
System.out.println(doc.get("sul1"));
}

Document document = new Document();
document.append("sul1", "sul1").append("xul2", "xul2");
List<Document> list = new ArrayList<Document>();
list.add(document);
MongoDatabase database = this.getMongoDataBase("xul");
MongoCollection< Document> collection = database.getCollection("users");
collection.insertMany(list);

MongoCollection table = getCollection();
BasicDBObject dbObject = new BasicDBObject();
//mongodb中按age字段倒序查询（-1是倒序，1是正序）
dbObject.put("age",-1);
FindIterable iterate =table.find().sort(dbObject).limit(1);

int pageSize = 3;
MongoCollection table = getCollection();
//mongodb分页查询出游标
MongoCursor cursor = table.find().limit(pageSize).skip((pageIndex - 1) * pageSize).iterator();
System.out.println("当前页：" + pageIndex);
while (cursor.hasNext()) {
System.out.println(cursor.next());
}

public void displayDb()
{
MongoClient mongo = new MongoClient(host, port);
MongoIterable<String> dbs= mongo.listDatabaseNames();
for (String name:dbs)
{
System.out.println(name);
}
}

public void displayTable() {
MongoDatabase db = getDb();
MongoIterable<String> tables = db.listCollectionNames();
for (String name : tables) {
System.out.println(name);
}
}

public void delete() {
MongoCollection table = getCollection();
Document document = new Document();
document.put("name", "xul");
DeleteResult result = table.deleteMany(document);
}

public void updateDocument(){
MongoCollection<Document> collection = this.getCollection();
BasicDBObject upda = new BasicDBObject();
upda.append("xul2", "testupdatexul");
BasicDBObject object = new BasicDBObject();
object.append("$set", upda);
collection.updateOne(Filters.gte("sul1", "sul1"), object);
}