Java中使用mongodb實現增刪改查

阿新 • • 發佈：2018-12-24

Java

安裝

要想在 Java 程式中使用 MongoDB，需要先確定是否安裝了 MongoDB JDBC 驅動，並且要在機器上安裝了 Java。檢視 Java 教程來確保在機器上安裝好 Java。下面來介紹如何安裝 MongoDB JDBC 驅動。

從路徑 Download mongo.jar 處下載 jar 檔案，注意下載最新版本。
在類路徑中包括 mongo.jar 檔案。

連線資料庫

為了連線資料庫，需要指定資料庫名稱，如果資料庫不存在，mongodb 就會自動建立它。

連線資料庫的程式碼段如下所示：

import com.mongodb.MongoClient;
import com.mongodb.MongoException;
import com.mongodb.WriteConcern;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.BasicDBObject;
import com.mongodb.DBObject;
import com.mongodb.DBCursor;
import com.mongodb.ServerAddress;
import java.util.Arrays;

public class MongoDBJDBC{
   public static void main( String args[] ){
      try{   
         // To connect to mongodb server
         MongoClient mongoClient = new MongoClient( "localhost" , 27017 );
         // Now connect to your databases
         DB db = mongoClient.getDB( "test" );
         System.out.println("Connect to database successfully");
         boolean auth = db.authenticate(myUserName, myPassword);
         System.out.println("Authentication: "+auth);
      }catch(Exception e){
         System.err.println( e.getClass().getName() + ": " + e.getMessage() );
      }
   }
}

下面編譯並執行上面的程式，以便測試資料庫。可以針對每個需求改變路徑。假設當前 JDBC 驅動版本 mongo-2.10.1.jar 可用於當前路徑。

$javac MongoDBJDBC.java
$java -classpath ".:mongo-2.10.1.jar" MongoDBJDBC
Connect to database successfully
Authentication: true

如果想使用 Windows 系統的機器，則編譯並執行程式碼如下：

$javac MongoDBJDBC.java
$java -classpath ".;mongo-2.10.1.jar" MongoDBJDBC
Connect to database successfully
Authentication: true

如果選定資料庫的使用者名稱及密碼有效，則 auth 值為 true。

建立集合

建立集合需要使用 com.mongodb.DB 類的 createCollection() 方法。

建立集合的程式碼段如下所示：

import com.mongodb.MongoClient;
import com.mongodb.MongoException;
import com.mongodb.WriteConcern;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.BasicDBObject;
import com.mongodb.DBObject;
import com.mongodb.DBCursor;
import com.mongodb.ServerAddress;
import java.util.Arrays;

public class MongoDBJDBC{
   public static void main( String args[] ){
      try{   
     // To connect to mongodb server
         MongoClient mongoClient = new MongoClient( "localhost" , 27017 );
         // Now connect to your databases
         DB db = mongoClient.getDB( "test" );
     System.out.println("Connect to database successfully");
         boolean auth = db.authenticate(myUserName, myPassword);
     System.out.println("Authentication: "+auth);
         DBCollection coll = db.createCollection("mycol");
         System.out.println("Collection created successfully");
      }catch(Exception e){
         System.err.println( e.getClass().getName() + ": " + e.getMessage() );
      }
   }
}

編譯並執行該程式，結果如下所示：

Connect to database successfully
Authentication: true
Collection created successfully

獲取/選擇一個集合

從資料庫中獲取/選擇一個集合，使用 com.mongodb.DBCollection 類的 getCollection() 方法。程式碼段如下：

import com.mongodb.MongoClient;
import com.mongodb.MongoException;
import com.mongodb.WriteConcern;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.BasicDBObject;
import com.mongodb.DBObject;
import com.mongodb.DBCursor;
import com.mongodb.ServerAddress;
import java.util.Arrays;

public class MongoDBJDBC{
   public static void main( String args[] ){
      try{   
     // To connect to mongodb server
         MongoClient mongoClient = new MongoClient( "localhost" , 27017 );
         // Now connect to your databases
         DB db = mongoClient.getDB( "test" );
     System.out.println("Connect to database successfully");
         boolean auth = db.authenticate(myUserName, myPassword);
     System.out.println("Authentication: "+auth);
         DBCollection coll = db.createCollection("mycol");
         System.out.println("Collection created successfully");
         DBCollection coll = db.getCollection("mycol");
         System.out.println("Collection mycol selected successfully");
      }catch(Exception e){
         System.err.println( e.getClass().getName() + ": " + e.getMessage() );
      }
   }
}

編譯並執行該程式，結果如下所示：

Connect to database successfully
Authentication: true
Collection created successfully
Collection mycol selected successfully

插入文件

插入文件使用 com.mongodb.DBCollection 類的 insert() 方法。程式碼段如下所示：

import com.mongodb.MongoClient;
import com.mongodb.MongoException;
import com.mongodb.WriteConcern;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.BasicDBObject;
import com.mongodb.DBObject;
import com.mongodb.DBCursor;
import com.mongodb.ServerAddress;
import java.util.Arrays;

public class MongoDBJDBC{
   public static void main( String args[] ){
      try{   
     // To connect to mongodb server
         MongoClient mongoClient = new MongoClient( "localhost" , 27017 );
         // Now connect to your databases
         DB db = mongoClient.getDB( "test" );
     System.out.println("Connect to database successfully");
         boolean auth = db.authenticate(myUserName, myPassword);
     System.out.println("Authentication: "+auth);         
         DBCollection coll = db.getCollection("mycol");
         System.out.println("Collection mycol selected successfully");
         DBCursor cursor = coll.find();
         int i=1;
         while (cursor.hasNext()) { 
            System.out.println("Inserted Document: "+i); 
            System.out.println(cursor.next()); 
            i++;
         }
      }catch(Exception e){
         System.err.println( e.getClass().getName() + ": " + e.getMessage() );
      }
   }
}

編譯並執行該程式，結果如下所示

Connect to database successfully
Authentication: true
Collection mycol selected successfully
Document inserted successfully

檢索所有文件

選擇集合中的所有文件，使用 com.mongodb.DBCollection 類的 find() 方法。該方法返回一個遊標，所以需要迭代該遊標。

選擇所有文件的程式碼如下所示：

import com.mongodb.MongoClient;
import com.mongodb.MongoException;
import com.mongodb.WriteConcern;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.BasicDBObject;
import com.mongodb.DBObject;
import com.mongodb.DBCursor;
import com.mongodb.ServerAddress;
import java.util.Arrays;

public class MongoDBJDBC{
   public static void main( String args[] ){
      try{   
     // To connect to mongodb server
         MongoClient mongoClient = new MongoClient( "localhost" , 27017 );
         // Now connect to your databases
         DB db = mongoClient.getDB( "test" );
     System.out.println("Connect to database successfully");
         boolean auth = db.authenticate(myUserName, myPassword);
     System.out.println("Authentication: "+auth);         
         DBCollection coll = db.getCollection("mycol");
         System.out.println("Collection mycol selected successfully");
         DBCursor cursor = coll.find();
         while (cursor.hasNext()) { 
            DBObject updateDocument = cursor.next();
            updateDocument.put("likes","200")
            col1.update(updateDocument); 
         }
         System.out.println("Document updated successfully");
         cursor = coll.find();
         int i=1;
         while (cursor.hasNext()) { 
            System.out.println("Updated Document: "+i); 
            System.out.println(cursor.next()); 
            i++;
         }
      }catch(Exception e){
         System.err.println( e.getClass().getName() + ": " + e.getMessage() );
      }
   }
}

編譯並執行程式的結果如下：

Connect to database successfully
Authentication: true
Collection mycol selected successfully
Document updated successfully
Updated Document: 1
{
   "_id" : ObjectId(7df78ad8902c),
   "title": "MongoDB",
   "description": "database",
   "likes": 100,
   "url": "http://www.tutorialspoint.com/mongodb/",
   "by": "tutorials point"
}

更新文件

更新集合中的文件，使用 com.mongodb.DBCollection 類的 update() 方法。程式碼如下所示：

import com.mongodb.MongoClient;
import com.mongodb.MongoException;
import com.mongodb.WriteConcern;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.BasicDBObject;
import com.mongodb.DBObject;
import com.mongodb.DBCursor;
import com.mongodb.ServerAddress;
import java.util.Arrays;

public class MongoDBJDBC{
   public static void main( String args[] ){
      try{   
     // To connect to mongodb server
         MongoClient mongoClient = new MongoClient( "localhost" , 27017 );
         // Now connect to your databases
         DB db = mongoClient.getDB( "test" );
     System.out.println("Connect to database successfully");
         boolean auth = db.authenticate(myUserName, myPassword);
     System.out.println("Authentication: "+auth);         
         DBCollection coll = db.getCollection("mycol");
         System.out.println("Collection mycol selected successfully");
         DBCursor cursor = coll.find();
         while (cursor.hasNext()) { 
            DBObject updateDocument = cursor.next();
            updateDocument.put("likes","200")
            col1.update(updateDocument); 
         }
         System.out.println("Document updated successfully");
         cursor = coll.find();
         int i=1;
         while (cursor.hasNext()) { 
            System.out.println("Updated Document: "+i); 
            System.out.println(cursor.next()); 
            i++;
         }
      }catch(Exception e){
         System.err.println( e.getClass().getName() + ": " + e.getMessage() );
      }
   }
}

程式編譯及執行結果如下：

Connect to database successfully
Authentication: true
Collection mycol selected successfully
Document updated successfully
Updated Document: 1
{
   "_id" : ObjectId(7df78ad8902c),
   "title": "MongoDB",
   "description": "database",
   "likes": 100,
   "url": "http://www.tutorialspoint.com/mongodb/",
   "by": "tutorials point"
}

刪除第一個文件

刪除集合中的第一個文件，需要使用 findOne() 方法選中第一個文件，然後使用 com.mongodb.DBCollection 類的remove 方法將其刪除。程式碼範例如下：

import com.mongodb.MongoClient;
import com.mongodb.MongoException;
import com.mongodb.WriteConcern;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.BasicDBObject;
import com.mongodb.DBObject;
import com.mongodb.DBCursor;
import com.mongodb.ServerAddress;
import java.util.Arrays;

public class MongoDBJDBC{
   public static void main( String args[] ){
      try{   
     // To connect to mongodb server
         MongoClient mongoClient = new MongoClient( "localhost" , 27017 );
         // Now connect to your databases
         DB db = mongoClient.getDB( "test" );
     System.out.println("Connect to database successfully");
         boolean auth = db.authenticate(myUserName, myPassword);
     System.out.println("Authentication: "+auth);         
         DBCollection coll = db.getCollection("mycol");
         System.out.println("Collection mycol selected successfully");
         DBObject myDoc = coll.findOne();
         col1.remove(myDoc);
         DBCursor cursor = coll.find();
         int i=1;
         while (cursor.hasNext()) { 
            System.out.println("Inserted Document: "+i); 
            System.out.println(cursor.next()); 
            i++;
         }
         System.out.println("Document deleted successfully");
      }catch(Exception e){
         System.err.println( e.getClass().getName() + ": " + e.getMessage() );
      }
   }
}

Java中使用mongodb實現增刪改查

Java 安裝要想在 Java 程式中使用 MongoDB，需要先確定是否安裝了 MongoDB JDBC 驅動，並且要在機器上安裝了 Java。檢視 Java 教程來確保在機器上安裝好 Java。下面來介紹如何安裝 MongoDB JDBC 驅動。從路徑 Download mongo.jar 處下載

mongodb--java連線資料庫實現增刪改查

1.新建一個maven專案，匯入 <dependencies> <dependency> <groupId>junit</grou

spring連線mongodb實現增刪改查

applicationContext.xml： <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans"

python 連線mongodb實現增刪改查例項

# -*- coding:utf-8 -*- from pymongo import MongoClient settings = { "ip":'127.0.0.1', #ip

Spring Boot整合MongoDB實現增刪改查

MongoDB這兩年來是本人一直使用較多的，之前的使用大多通過封裝的工具類對資料庫進行操作，雖然也算穩定，但有了Spring Boot之前的工具類直接加到SpringBoot裡就沒那麼好使了，因此查閱資料後自己小試牛刀寫了個增刪改查，覺得也還不錯，所以分享給大家看看 1 p

java操作mongoDB之增刪改查

需要mongodb的驅動jar（mongo-java-driver-3.2.0.jar） package mongodb; import java.net.UnknownHostException; import java.util.Date; import co

java 順序表實現增刪改查，合併，排序功能

/** * @param args */ public int []data; public int yupeijie_length; final int Maxsize=1024; public yupeijie_Seq(){ data=new int[1024]; this

Java連線MySQL實現增刪改查

現在許多框架都對資料庫進行了封裝，但是我們剛開始學習時，更好的還是使用Java手寫sql語句，進行相關操作，以便於我們瞭解Mysql呼叫機制。本文中我們實現使用者註冊的基礎操作：從jsp得到使用者

java連接Oracle數據庫實現增刪改查並在Navicat中顯示

execute etag while args 自動 rest getc from lose 創建TEST表 eclipse中的java項目代碼數據庫方法類 DBUtil： package util; import java.sql.Connection;

基於MongoDB資料庫的Java程式實現增刪改查功能

今天我來說一下使用Java程式去實現MongoDB資料庫的增刪改查功能。首先需要匯入連線資料庫的jar包，需要的話這是連結：http://pan.baidu.com/s/1eSDytAM，把jar包

JDBC之java使用oracle中scott表實現增刪改查.1

Java與oracle資料庫連線—–JDBC Dao工具的建立 **寫部落格的目的及好處 1，為了把完成的知識點整理出來， 2，等同督促自己做學習總結 3，方便自己及同行者的閱覽 4，如有有心者，可以分享更精的知識

Java實現對MongoDB的增刪改查

ase cat 更新文檔 ret err har cursor filters 數據庫一、連接數據庫連接數據庫，你需要指定數據庫名稱，如果指定的數據庫不存在，mongo會自動創建數據庫。連接數據庫的Java代碼如下（無需密碼的連接）： public clas

python實現mongodb的增刪改查

pmd xxx rsn rpm vfat uwa paul dpf wdf python實現mongodb的增刪改查環境：192.168.122.1 pytho

Javaweb實現對mongodb的增刪改查（附帶源代碼）

bubuko 增刪 web .com image ODB htm ava read 運行截圖：刪除後的信息項目源代碼：https://www.cnblogs.com/post/readauth?url=/zyt-bg/p/9807396.html

webpack4+express+mongodb+vue 實現增刪改查

在講解之前，我們先來看看效果如下所示： 1）整個頁面的效果如下： 2) 新增資料效果如下： 3) 新增成功如下： 4) 編輯資料效果如下： 5) 編輯成功效果如下： 6) 刪除資料效果如下： 7) 刪除成功效果如下：

例項：建立一個表格，分頁顯示資料（MongoDB資料庫儲存），功能：實現增刪改查

需求：建立一個表格，分頁顯示資料，功能：實現增刪改查效果圖：自動建立一個專案命令列： express mongodb-demo --view=ejs cd mongodb-demo npm install npm install mongodb --save npm sta

詳解node + mongoDb(mongoDb安裝、執行，在node中連線、增刪改查)

一、序言好久沒寫部落格了，這次主要聊聊 node 和 mongoDb 。先說明一下技術棧 node + express + mongoose + mongoDb。這篇部落格，主要講述 mongoDb 的下載、安裝、配置、執行以及如何在 node

JAVA資料管理系統(用ArrayList實現增刪改查等操作)

通過查詢大量有關ArrayList操作的文章，終於將這個小東西寫完了。感覺心累。 //import java.util.ArrayList; //import java.util.List; //import java.util.Scanner;// I/O庫函式 /

Java操作Oracle並實現增刪改查

在這裡我選擇的是maven專案,但是找了良久沒有發現依賴,或者就是不能用,於是就去Oracle官網下載了ojdbc的jar包. 連線程式碼如下: package oracle; import java.sql.Connection; import java.sql.Dr

詳解node + mongoDb(mongoDb安裝、執行，在node中連線、增刪改查)

module.exports = { production: { uri: 'mongodb://localhost/db', option: { autoIndex: true, reconnectTries: Number.MAX_VALUE,

Java中使用mongodb實現增刪改查

Java

安裝

連線資料庫

建立集合

獲取/選擇一個集合

插入文件

檢索所有文件

更新文件

刪除第一個文件

相關推薦