MongoDB Java

Configuration de l'environnement

Si vous souhaitez programmer en Java en utilisant MongoDB, vous devez vous assurer que vous avez installé l'environnement Java et le pilote JDBC MongoDB.

Les exemples dans cette section lorsque Mongo 3.x ou version ultérieure.

Vous pouvez consulter de ce site Java tutoriel pour installer le programme Java. Maintenant, nous allons tester votre pilote JDBC MongoDB est installé.

D' abord , vous devez télécharger le paquet jar mongo, téléchargez Adresse: http://mongodb.github.io/mongo-java-driver/ , assurez - vous de télécharger la dernière version.
Vous aurez besoin de mongo-java-driver-3.2.2.jar (trouver une version adaptée) inclus dans votre classpath. .
Domestic mongodb-pilote jar Téléchargement: http://central.maven.org/maven2/org/mongodb/mongo-java-driver/

Connectez-vous à la base de données

Connexion à la base de données, vous devez spécifier le nom de la base de données, si n'existe pas la base de données spécifiée, la base de données mongo sera automatiquement créé.

La connexion à l'aide du code Java de base de données est la suivante:

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

Maintenant, nous allons compiler et exécuter le programme et se connecter à la base de données test.

Vous pouvez modifier le chemin du pilote JDBC MongoDB en fonction de votre environnement réel.

Cet exemple va commencer MongoDB JDBC package mongo-java-driver-3.2.2.jar dans le répertoire local:

$ 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

Cet exemple base de données Mongo sans nécessiter nom d'utilisateur et l'authentification par mot de passe. Si votre besoin Mongo pour vérifier le nom d'utilisateur et mot de passe, vous pouvez utiliser le code suivant:

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

Créer une collection

Nous pouvons utiliser createCollection classe com.mongodb.client.MongoDatabase () pour créer une collection

Le fragment de code suivant:

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

Compiler et exécuter le programme ci-dessus, les résultats de sortie sont les suivantes:

Connect to database successfully
集合创建成功

Obtient la collection

Nous pouvons utiliser la méthode getCollection () pour obtenir une collection de com.mongodb.client.MongoDatabase de classe

Le fragment de code suivant:

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

Compiler et exécuter le programme ci-dessus, les résultats de sortie sont les suivantes:

Connect to database successfully
集合 test 选择成功

Insérer le document

Nous pouvons utiliser insertMany de classe com.mongodb.client.MongoCollection () pour insérer un document

Le fragment de code suivant:

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

Compiler et exécuter le programme ci-dessus, les résultats de sortie sont les suivantes:

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

Récupérer tous les documents

Nous pouvons utiliser la méthode com.mongodb.client.MongoCollection classe find () pour obtenir une collection de tous les documents.

Cette méthode renvoie un curseur, vous devez donc parcourir le curseur.

Le fragment de code suivant:

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

Compiler et exécuter le programme ci-dessus, les résultats de sortie sont les suivantes:

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

Mise à jour de la documentation

Vous pouvez utiliser la méthode com.mongodb.client.MongoCollection updateMany de classe () pour mettre à jour la collection de documents.

Le fragment de code suivant:

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

Compiler et exécuter le programme ci-dessus, les résultats de sortie sont les suivantes:

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

Retirer le premier document

Pour supprimer un document dans la collection de la première, vous devez d'abord utiliser la méthode de findOne de classe com.mongodb.DBCollection () pour obtenir le premier document, puis utiliser la méthode de suppression pour supprimer.

Le fragment de code suivant:

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

Compiler et exécuter le programme ci-dessus, les résultats de sortie sont les suivantes:

Connect to database successfully
集合 test 选择成功

Plus les opérations, reportez - vous à: http://mongodb.github.io/mongo-java-driver/3.0/driver/getting-started/quick-tour/

Document de référence: http: //blog.csdn.net/ererfei/article/details/50857103

Précédent: MongoDB Surveillance

Suivant: MongoDB PHP

MongoDB cours

MongoDB Tutorial avancée

MongoDB Java

Connectez-vous à la base de données

Créer une collection

Obtient la collection

Insérer le document

Récupérer tous les documents

Mise à jour de la documentation

Retirer le premier document