MongoDB Java

Umwelt-Konfiguration

Wenn Sie in Java mit MongoDB programmieren wollen, müssen Sie sicherstellen, dass Sie die Java-Umgebung und MongoDB JDBC-Treiber installiert haben.

Beispiele in diesem Abschnitt, wenn Mongo 3.x oder höher.

Sie können auf dieser Website finden Sie Java Tutorial das Java - Programm zu installieren. Lassen Sie uns jetzt testen Sie Ihr MongoDB JDBC-Treiber installiert ist.

Zuerst müssen Sie Mongo jar - Paket herunterladen Adresse herunterladen: http://mongodb.github.io/mongo-java-driver/ , sollten Sie die neueste Version herunterzuladen.
Sie müssen Mongo-java-Treiber-3.2.2.jar (eine passende Version finden) in Ihrem Classpath enthalten. .
Domestic mongodb-driver jar Download: http://central.maven.org/maven2/org/mongodb/mongo-java-driver/

Mit der Datenbank verbinden

Mit der Datenbank verbinden, müssen Sie den Namen der Datenbank angeben, wenn die angegebene Datenbank nicht vorhanden ist, Mongo Datenbank wird automatisch erstellt.

Mit der Datenbank Java-Code ist wie folgt:

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() );
     }
   }
}

Nun lassen Sie uns zusammenzustellen und um das Programm und die Verbindung zur Datenbank Test ausführen.

Sie können die MongoDB-JDBC-Treiber Pfad ändern entsprechend Ihrer tatsächlichen Umgebung.

Dieses Beispiel wird MongoDB JDBC-Paket Mongo-java-Treiber-3.2.2.jar im lokalen Verzeichnis zu starten:

$ javac -cp .:mongo-java-driver-3.2.2.jar MongoDBJDBC.java
$ java -cp .:mongo-java-driver-3.2.2.jar MongoDBJDBC
Connect to database successfully
Authentication: true

Dieses Beispiel Mongo Datenbank ohne Benutzername und Passwort-Authentifizierung erfordern. Wenn Ihr Mongo müssen den Benutzernamen und das Kennwort ein, um zu überprüfen, können Sie den folgenden Code verwenden:

import java.util.ArrayList;  
import java.util.List;  
import com.mongodb.MongoClient;  
import com.mongodb.MongoCredential;  
import com.mongodb.ServerAddress;  
import com.mongodb.client.MongoDatabase;  
  
public class MongoDBJDBC {  
    public static void main(String[] args){  
        try {  
            //连接到MongoDB服务 如果是远程连接可以替换“localhost”为服务器所在IP地址  
            //ServerAddress()两个参数分别为 服务器地址 和 端口  
            ServerAddress serverAddress = new ServerAddress("localhost",27017);  
            List<ServerAddress> addrs = new ArrayList<ServerAddress>();  
            addrs.add(serverAddress);  
              
            //MongoCredential.createScramSha1Credential()三个参数分别为 用户名 数据库名称 密码  
            MongoCredential credential = MongoCredential.createScramSha1Credential("username", "databaseName", "password".toCharArray());  
            List<MongoCredential> credentials = new ArrayList<MongoCredential>();  
            credentials.add(credential);  
              
            //通过连接认证获取MongoDB连接  
            MongoClient mongoClient = new MongoClient(addrs,credentials);  
              
            //连接到数据库  
            MongoDatabase mongoDatabase = mongoClient.getDatabase("databaseName");  
            System.out.println("Connect to database successfully");  
        } catch (Exception e) {  
            System.err.println( e.getClass().getName() + ": " + e.getMessage() );  
        }  
    }  
}

Erstellen Sie eine Sammlung

Wir können com.mongodb.client.MongoDatabase Klasse createCollection () verwenden, um eine Sammlung zu erstellen

Das folgende Codefragment:

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() );
     }
   }
}

Kompilieren und das obige Programm ausführen, werden die Ausgabeergebnisse wie folgt:

Connect to database successfully
集合创建成功

Ruft die Auflistung

Wir können GetCollection () Methode verwenden, um eine Klasse com.mongodb.client.MongoDatabase Sammlung zu erhalten

Das folgende Codefragment:

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() );
     }
   }
}

Kompilieren und das obige Programm ausführen, werden die Ausgabeergebnisse wie folgt:

Connect to database successfully
集合 test 选择成功

Dokument einfügen

Wir können com.mongodb.client.MongoCollection Klasse insertMany () -Methode verwenden, um ein Dokument einfügen

Das folgende Codefragment:

import java.util.ArrayList;
import java.util.List;
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 选择成功");
         //插入文档  
         /** 
         * 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("文档插入成功");  
      }catch(Exception e){
         System.err.println( e.getClass().getName() + ": " + e.getMessage() );
      }
   }
}

Kompilieren und das obige Programm ausführen, werden die Ausgabeergebnisse wie folgt:

Connect to database successfully
集合 test 选择成功
文档插入成功

Rufen Sie alle Dokumente

Wir können com.mongodb.client.MongoCollection Klasse find () Methode verwenden, um eine Sammlung aller Dokumente zu erhalten.

Diese Methode gibt einen Cursor, so müssen Sie den Cursor zu durchqueren.

Das folgende Codefragment:

import org.bson.Document;
import com.mongodb.MongoClient;
import com.mongodb.client.FindIterable;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoCursor;
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 选择成功");
         
         //检索所有文档  
         /** 
         * 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());  
         }  
      
      }catch(Exception e){
         System.err.println( e.getClass().getName() + ": " + e.getMessage() );
      }
   }
}

Kompilieren und das obige Programm ausführen, werden die Ausgabeergebnisse wie folgt:

Connect to database successfully
集合 test 选择成功
Document{{_id=56e65fb1fd57a86304fe2692, title=MongoDB, description=database, likes=100, by=Fly}}

Update-Dokumentation

Sie können com.mongodb.client.MongoCollection Klasse updateMany () -Methode verwenden, um die Sammlung von Dokumenten zu aktualisieren.

Das folgende Codefragment:

import org.bson.Document;
import com.mongodb.MongoClient;
import com.mongodb.client.FindIterable;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoCursor;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.model.Filters;

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 选择成功");
         
         //更新文档   将文档中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());  
         }  
      
      }catch(Exception e){
         System.err.println( e.getClass().getName() + ": " + e.getMessage() );
      }
   }
}

Kompilieren und das obige Programm ausführen, werden die Ausgabeergebnisse wie folgt:

Connect to database successfully
集合 test 选择成功
Document{{_id=56e65fb1fd57a86304fe2692, title=MongoDB, description=database, likes=200, by=Fly}}

Entfernen Sie das erste Dokument

Um ein Dokument in der Sammlung des ersten zu löschen, müssen Sie zuerst com.mongodb.DBCollection Klasse FindOne () -Methode verwenden, um das erste Dokument zu erhalten, und verwenden Sie die Remove-Methode zu löschen.

Das folgende Codefragment:

import org.bson.Document;
import com.mongodb.MongoClient;
import com.mongodb.client.FindIterable;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoCursor;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.model.Filters;

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 选择成功");

         //删除符合条件的第一个文档  
         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());  
         }  
           
      }catch(Exception e){
        System.err.println( e.getClass().getName() + ": " + e.getMessage() );
     }
   }
}

Kompilieren und das obige Programm ausführen, werden die Ausgabeergebnisse wie folgt:

Connect to database successfully
集合 test 选择成功

Weitere Funktionen finden Sie in: http://mongodb.github.io/mongo-java-driver/3.0/driver/getting-started/quick-tour/

Referenzdokument: http: //blog.csdn.net/ererfei/article/details/50857103

Zurück: MongoDB - Monitoring

Next: MongoDB PHP

MongoDB Kurs

MongoDB Erweiterte Tutorial

MongoDB Java

Mit der Datenbank verbinden

Erstellen Sie eine Sammlung

Ruft die Auflistung

Dokument einfügen

Rufen Sie alle Dokumente

Update-Dokumentation

Entfernen Sie das erste Dokument