MongoDBJava
Configuration de l'environnement
Si vous souhaitez utiliser MongoDB dans un programme Java, vous devez vous assurer que l'environnement Java et le pilote MongoDB JDBC ont été installés.
Les exemples de ce chapitre sont basés sur Mongo 3.x ou supérieur.
Vous pouvez vous référer au tutoriel Java sur ce site pour installer des programmes Java. Vérifions maintenant si le pilote MongoDB JDBC est installé.
Vous devez d'abord télécharger le package mongo jar, adresse de téléchargement : http://mongodb.github.io/mongo-java-driver/, Veuillez vous assurer de télécharger la dernière version.
Vous devez mongo-java-driver-3.2.2.jar (trouver la version appropriée) inclus dans votre chemin de classe. .
Adresse de téléchargement du fichier jar du pilote mongodb national : http://central.maven.org/maven2/org/mongodb/mongo-java-driver/
Connectez-vous à la base de données
Pour vous connecter à la base de données, vous devez spécifier le nom de la base de données. Si la base de données spécifiée n'existe pas, mongo créera automatiquement la base de données. base de données.
Le code Java pour se connecter à la base de données est le 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");
}catch(Exception e){
System.err.println( e.getClass().getName() + ": " + e.getMessage() );
}
}
}Maintenant, compilons et exécutons le programme et connectons-nous au test de la base de données.
Vous pouvez modifier le chemin du pilote MongoDB JDBC en fonction de votre environnement réel.
Dans cet exemple, le package de démarrage MongoDB JDBC mongo-java-driver-3.2.2.jar est placé 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
Dans cet exemple, la base de données Mongo ne nécessite pas authentification par nom d'utilisateur et mot de passe. Si votre Mongo a besoin de vérifier le nom d'utilisateur et le 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() dans le com.mongodb.client Classe .MongoDatabase Pour créer une collection
l'extrait de code est le 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() );
}
}
}Compilez et exécutez le programme ci-dessus, le résultat est le suivant :
Connect to database successfully 集合创建成功
Récupérer la collection
On peut utiliser La méthode getCollection() de la classe com.mongodb.client.MongoDatabase est utilisée pour obtenir une collection
L'extrait de code est le 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() );
}
}
} Compilez et exécutez le programme ci-dessus, le résultat de sortie est le suivant :
Connect to database successfully 集合 test 选择成功
Insérer un document
Nous pouvons utiliser la méthode insertMany() de com.mongodb.client Classe .MongoCollection pour insérer un document
L'extrait de code est le 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 résultat du programme ci-dessus est le suivant :
Connect to database successfully 集合 test 选择成功 文档插入成功
Récupérer tous les documents
Nous pouvons utiliser la méthode find() dans la classe com.mongodb.client.MongoCollection pour obtenir tous les documents de la collection .
Cette méthode renvoie un curseur, vous devez donc parcourir ce curseur.
L'extrait de code est le 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() );
}
}
}Compilez et exécutez le programme ci-dessus, le résultat de sortie est le suivant :
Connect to database successfully
集合 test 选择成功
Document{{_id=56e65fb1fd57a86304fe2692, title=MongoDB, description=database, likes=100, by=Fly}}Mettre à jour le document
Vous pouvez utiliser com.mongodb La méthode updateMany() dans la classe .client.MongoCollection pour mettre à jour les documents de la collection.
L'extrait de code est le 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() );
}
}
}Compilez et exécutez le programme ci-dessus, le résultat de sortie est le suivant :
Connect to database successfully
集合 test 选择成功
Document{{_id=56e65fb1fd57a86304fe2692, title=MongoDB, description=database, likes=200, by=Fly}}Supprimer le premier document
Pour supprimer le premier document de la collection, vous devez d'abord utiliser la classe com.mongodb.DBCollection findOne() pour obtenir le premier document, puis utilisez la méthode Remove pour le supprimer.
L'extrait de code est le 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() );
}
}
}Compilez et exécutez le programme ci-dessus, le résultat de sortie est le suivant :
Connect to database successfully 集合 test 选择成功
Pour plus d'opérations, veuillez vous référer à : 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
