MongoDB學習(四) Java操作MongoDB
阿新 • • 發佈:2018-12-24
一、連線資料庫
連線資料庫,你需要指定資料庫名稱,如果指定的資料庫不存在,mongo會自動建立資料庫。
所需jar包: mongo-java-driver-3.2.2.jar
連線資料庫的Java程式碼如下:
import com.mongodb.MongoClient; import com.mongodb.client.MongoDatabase; public class MongoDBJDBC{ public static void main( String args[] ){ try{ // 連線到 mongodb 服務 MongoClient mongoClient = new MongoClient( "localhost" , 27017 ); // 連線到資料庫 MongoDatabase mongoDatabase = mongoClient.getDatabase("mycol"); System.out.println("Connect to database successfully"); }catch(Exception e){ System.err.println( e.getClass().getName() + ": " + e.getMessage() ); } } }
二、建立集合
我們可以使用 com.mongodb.client.MongoDatabase 類中的createCollection()來建立集合程式碼片段如下:
import com.mongodb.MongoClient; import com.mongodb.client.MongoDatabase; public class MongoDBJDBC{ public static void main( String args[] ){ try{ // 連線到 mongodb 服務 MongoClient mongoClient = new MongoClient( "localhost" , 27017 ); // 連線到資料庫 MongoDatabase mongoDatabase = mongoClient.getDatabase("mycol"); System.out.println("Connect to database successfully"); mongoDatabase.createCollection("test"); System.out.println("集合建立成功"); }catch(Exception e){ System.err.println( e.getClass().getName() + ": " + e.getMessage() ); } } }
三、獲取集合
import org.bson.Document; import com.mongodb.MongoClient; import com.mongodb.client.MongoCollection; import com.mongodb.client.MongoDatabase; public class MongoDBJDBC{ public static void main( String args[] ){ try{ // 連線到 mongodb 服務 MongoClient mongoClient = new MongoClient( "localhost" , 27017 ); // 連線到資料庫 MongoDatabase mongoDatabase = mongoClient.getDatabase("mycol"); System.out.println("Connect to database successfully"); MongoCollection<Document> collection = mongoDatabase.getCollection("test"); System.out.println("集合 test 選擇成功"); }catch(Exception e){ System.err.println( e.getClass().getName() + ": " + e.getMessage() ); } } }
四、插入文件
//插入文件
/**
* 1. 建立文件 org.bson.Document 引數為key-value的格式
* 2. 建立文件集合List<Document>
* 3. 將文件集合插入資料庫集合中 mongoCollection.insertMany(List<Document>) 插入單個文件可以用 mongoCollection.insertOne(Document)
* */
Document document = new Document("title", "MongoDB").
append("description", "database").
append("likes", 100).
append("by", "Fly");
List<Document> documents = new ArrayList<Document>();
documents.add(document);
collection.insertMany(documents);
System.out.println("文件插入成功");
四、查詢文件
//檢索所有文件
/**
* 1. 獲取迭代器FindIterable<Document>
* 2. 獲取遊標MongoCursor<Document>
* 3. 通過遊標遍歷檢索出的文件集合
* */
FindIterable<Document> findIterable = collection.find();
MongoCursor<Document> mongoCursor = findIterable.iterator();
while(mongoCursor.hasNext()){
System.out.println(mongoCursor.next());
}
五、修改文件
//更新文件 將文件中likes=100的文件修改為likes=200
collection.updateMany(Filters.eq("likes", 100), new Document("$set",new Document("likes",200)));
//檢索檢視結果
FindIterable<Document> findIterable = collection.find();
MongoCursor<Document> mongoCursor = findIterable.iterator();
while(mongoCursor.hasNext()){
System.out.println(mongoCursor.next());
}
六、刪除文件
//刪除符合條件的第一個文件
collection.deleteOne(Filters.eq("likes", 200));
//刪除所有符合條件的文件
collection.deleteMany (Filters.eq("likes", 200));
//檢索檢視結果
FindIterable<Document> findIterable = collection.find();
MongoCursor<Document> mongoCursor = findIterable.iterator();
while(mongoCursor.hasNext()){
System.out.println(mongoCursor.next());
}