Principes de base de MongoDB: traitement des transactions

introduction

Le support des transactions est disponible depuis MongoDB 4.0. Il y a plus de cas d'utilisation car les transactions peuvent désormais être traitées.

Source: https://docs.mongodb.com/manual/core/transactions-in-applications/

Un nœud unique n'est pas pris en charge, n'est-ce pas? Si vous l'exécutez, une erreur se produira.

Exception in thread "main" com.mongodb.MongoClientException: Sessions are not supported by the MongoDB cluster to which this client is connected
	at com.mongodb.client.internal.MongoClientImpl.startSession(MongoClientImpl.java:127)
	at com.mongodb.client.internal.MongoClientImpl.startSession(MongoClientImpl.java:113)
	at mongodb.MongoDBTest.main(MongoDBTest.java:24)

Préparation de l'environnement du jeu de réplicas

Si vous ne disposez pas d'un environnement de jeu de réplicas, préparez-le d'abord localement. Source: https://docs.mongodb.com/manual/replication/

Créer un dossier pour chaque nœud

Node1: /data/mongo-replicaset/node1 Node2: /data/mongo-replicaset/node2 Node3: /data/mongo-replicaset/node3

Démarrez chaque nœud

mongod --replSet my-set --dbpath /data/mongo-replicaset/node1 --logpath /data/mongo-replicaset/node1/node1.log --port 27001
mongod --replSet my-set --dbpath /data/mongo-replicaset/node2 --logpath /data/mongo-replicaset/node2/node2.log --port 27002
mongod --replSet my-set --dbpath /data/mongo-replicaset/node3 --logpath /data/mongo-replicaset/node3/node3.log --port 27003

Initialisation de l'ensemble de relica

Connectez-vous à Node1 et initialisez.

rs.initiate(
{
        "_id" : "my-set",
        "members" : [
                {
                        "_id" : 0,
                        "host" : "localhost:27001"
                },
                {
                        "_id" : 1,
                        "host" : "localhost:27002"
                },
                {
                        "_id" : 2,
                        "host" : "localhost:27003"
                }
        ]
});

Résultat de l'exécution:

Vérifiez l'état avec rs.status ()

D'ACCORD. Vous êtes maintenant prêt.

Essayez le traitement des transactions avec JAVA

Ajouter plusieurs enregistrements à différents DB

MongoDBTest.java

package mongodb;

import com.mongodb.ReadConcern;
import com.mongodb.ReadPreference;
import com.mongodb.TransactionOptions;
import com.mongodb.WriteConcern;
import com.mongodb.client.ClientSession;
import com.mongodb.client.MongoClient;
import com.mongodb.client.MongoClients;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.TransactionBody;

import java.util.Date;

import org.bson.Document;

public class MongoDBTest {

	public static void main(String[] args) {
		//Générer le client MongoDB
		MongoClient client = MongoClients.create("mongodb://localhost:27001,localhost:27002,localhost:27003");

		//Si la collection n'existe pas, la transaction ne sera pas traitée, donc le code créera la collection.
        //(Une seule fois. Vous pouvez ajouter la collection manuellement)
		client.getDatabase("front").getCollection("access_log").withWriteConcern(WriteConcern.MAJORITY)
				.insertOne(new Document("dummy", 0));
		client.getDatabase("server").getCollection("users").withWriteConcern(WriteConcern.MAJORITY)
				.insertOne(new Document("dummy", 0));

		//Créer une session
		ClientSession session = client.startSession();

		//Définition des options
		TransactionOptions txnOptions = TransactionOptions.builder().readPreference(ReadPreference.primary())
				.readConcern(ReadConcern.LOCAL).writeConcern(WriteConcern.MAJORITY).build();

		TransactionBody txnBody = new TransactionBody<String>() {
			public String execute() {
				MongoCollection<Document> frontAccessLog = client.getDatabase("front").getCollection("access_log");
				MongoCollection<Document> serverUsers = client.getDatabase("server").getCollection("users");

				//journal d'accès
				Document accessLog = new Document();
				accessLog.append("log", "xxxx");
				accessLog.append("acccessDate", new Date());

				frontAccessLog.insertOne(session, accessLog);

				//Données d'utilisateur
				Document user = new Document();
				user.append("lastName", "tanaka");
				user.append("firstName", "tarou");
				user.append("createDate", new Date());

				serverUsers.insertOne(session, user);

				return "OK";
			}
		};

		try {
			//Traité dans la même transaction
			session.withTransaction(txnBody, txnOptions);

		} catch (RuntimeException e) {
			//Traitement anormal

		} finally {
			session.close();
		}

		//Fermer le client
		client.close();
	}
}

J'ai pu insérer les données sans aucun problème.

Traitement de plusieurs enregistrements dans le même DB

MongoDBTest.java

package mongodb;

import com.mongodb.ReadConcern;
import com.mongodb.ReadPreference;
import com.mongodb.TransactionOptions;
import com.mongodb.WriteConcern;
import com.mongodb.client.ClientSession;
import com.mongodb.client.MongoClient;
import com.mongodb.client.MongoClients;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.TransactionBody;
import com.mongodb.client.model.Filters;

import java.util.Date;

import org.bson.Document;

public class MongoDBTest {

	public static void main(String[] args) {
		//Générer le client MongoDB
		MongoClient client = MongoClients.create("mongodb://localhost:27001,localhost:27002,localhost:27003");

		//Créer une session
		ClientSession session = client.startSession();

		//Définition des options
		TransactionOptions txnOptions = TransactionOptions.builder().readPreference(ReadPreference.primary())
				.readConcern(ReadConcern.LOCAL).writeConcern(WriteConcern.MAJORITY).build();

		TransactionBody txnBody = new TransactionBody<String>() {
			public String execute() {
				MongoCollection<Document> frontAccessLog = client.getDatabase("front").getCollection("access_log");

				//Supprimer les données factices
				frontAccessLog.deleteOne(Filters.eq("dummy", 0));
				
				//journal d'accès
				Document accessLog = new Document();
				accessLog.append("log", "yyyyy");
				accessLog.append("acccessDate", new Date());

				frontAccessLog.insertOne(session, accessLog);
				
				//Rendez-le anormal
				throw new RuntimeException("Le traitement a échoué.");
                // return "OK";
			}
		};

		try {
			//Traité dans la même transaction
			session.withTransaction(txnBody, txnOptions);

		} catch (RuntimeException e) {
			//Traitement anormal
			e.printStackTrace();
		} finally {
			session.close();
		}

		//Fermer le client
		client.close();
	}
}

Puisqu'il a été lancé de façon anormale, vous pouvez confirmer que les données de la base de données n'ont pas changé. Quand j'ai supprimé le throw new RuntimeException (" processing failed. ");, J'ai pu supprimer et insérer les données comme prévu.

URL de transaction: https://docs.mongodb.com/manual/core/transactions/ Replication: https://docs.mongodb.com/manual/replication/ Construction de RelicaSet: https://docs.mongodb.com/manual/tutorial/deploy-replica-set/ Paramètres d'authentification ReplicaSet: https://docs.mongodb.com/manual/tutorial/deploy-replica-set-with-keyfile-access-control/

c'est tout