MongoDB Java基本操作
阿新 • • 發佈:2018-12-24
try{
// 連線到 mongodb 服務
MongoClient mongoClient = new MongoClient( "localhost" , 27017 );//(localhost:ip,27017 :埠號)
// 連線到資料庫
MongoDatabase mongoDatabase = mongoClient.getDatabase("test");
System.out.println("Java連線mongodb資料庫成功");
//建立集合
// mongoDatabase.createCollection("test");
//System.out.println("建立test集合成功");
MongoCollection<Document> collection = mongoDatabase.getCollection("col");
// MongoCollection<DBObject> collections=mongoDatabase.getWriteConcern();
System.out.println("集合 col選擇成功:");
//插入文件
/* Document document=new Document("title", "員工資訊").append("name", "蔡勇").append("sex", "男").append("age", 23).append("address", "北京市昌平區沙河高教園北街家園八區");
List<Document> list=new ArrayList<Document>();
list.add(document);
collection.insertMany(list);
System.out.println("插入文件成功");*/
//批量插入
List<Document> dblist=new LinkedList<Document>();
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
for(int a=1;a<10;a++){
for(int i=1;i<100;i++){
Document obj=new Document();
obj.put("title", "員工資訊");
obj.put("age", 23);
obj.put("sex", "男");
obj.put("tel", "18423560131");
obj.put("time", new Date());
dblist.add(obj);
}
}
collection.insertMany(dblist);
//查詢所有文件
FindIterable<Document> findIterable= collection.find();
MongoCursor<Document> mongoCursor = findIterable.iterator();
while(mongoCursor.hasNext()){
System.out.println(mongoCursor.next());
}
//更新文件
// collection.updateMany(Filters.eq("name", "張三"), new Document("$set",new Document("name","張三")));
//刪除第一個文件
//刪除符合條件的第一個文件
// collection.deleteOne(Filters.eq("name", "張三"));
//刪除所有符合條件的文件
collection.deleteMany (Filters.eq("age", 23));
}catch(Exception e){
System.err.println( e.getClass().getName() + ": " + e.getMessage() );
}
// 連線到 mongodb 服務
MongoClient mongoClient = new MongoClient( "localhost" , 27017 );//(localhost:ip,27017 :埠號)
// 連線到資料庫
MongoDatabase mongoDatabase = mongoClient.getDatabase("test");
System.out.println("Java連線mongodb資料庫成功");
//建立集合
// mongoDatabase.createCollection("test");
//System.out.println("建立test集合成功");
MongoCollection<Document> collection = mongoDatabase.getCollection("col");
// MongoCollection<DBObject> collections=mongoDatabase.getWriteConcern();
System.out.println("集合 col選擇成功:");
//插入文件
/* Document document=new Document("title", "員工資訊").append("name", "蔡勇").append("sex", "男").append("age", 23).append("address", "北京市昌平區沙河高教園北街家園八區");
List<Document> list=new ArrayList<Document>();
list.add(document);
collection.insertMany(list);
System.out.println("插入文件成功");*/
//批量插入
List<Document> dblist=new LinkedList<Document>();
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
for(int a=1;a<10;a++){
for(int i=1;i<100;i++){
Document obj=new Document();
obj.put("title", "員工資訊");
obj.put("age", 23);
obj.put("sex", "男");
obj.put("tel", "18423560131");
obj.put("time", new Date());
dblist.add(obj);
}
}
collection.insertMany(dblist);
//查詢所有文件
FindIterable<Document> findIterable= collection.find();
MongoCursor<Document> mongoCursor = findIterable.iterator();
while(mongoCursor.hasNext()){
System.out.println(mongoCursor.next());
}
//更新文件
// collection.updateMany(Filters.eq("name", "張三"), new Document("$set",new Document("name","張三")));
//刪除第一個文件
//刪除符合條件的第一個文件
// collection.deleteOne(Filters.eq("name", "張三"));
//刪除所有符合條件的文件
collection.deleteMany (Filters.eq("age", 23));
}catch(Exception e){
System.err.println( e.getClass().getName() + ": " + e.getMessage() );
}