La premi\u00e8re \u00e9tape essentielle est de t\u00e9l\u00e9charger MongoDB Java Drivers<\/a> pour commencer \u00e0 utiliser MongoDB. <\/p>\n\n\n\n Les librairies cit\u00e9es ci-dessous seront ajout\u00e9es comme d\u00e9pendances \u00e0 votre routine Talend. <\/p>\n\n\n\n Assurez-vous de choisir les versions compatibles avec votre version de MongoDB (Dans cet exemple, nous utilisons le pilote Java v4.5.1 pour se connecter \u00e0 MongoDB v5.0<\/em>).<\/p>\n\n\n\n Maintenant que nous avons t\u00e9l\u00e9charg\u00e9 les librairies Java, nous allons cr\u00e9er une routine Talend nomm\u00e9e MongoDBConnection<\/strong> pour encapsuler notre logique de connexion \u00e0 la base de donn\u00e9es.<\/p>\n\n\n\n Cr\u00e9ez un nouveau job Talend pour tester la routine MongoDBConnection, que vous pouvez nommer job_Read_Mongo_Collection<\/strong>. Ajoutez deux composants, tJavaFlex<\/strong> et tLogRow<\/strong>, puis reliez-les en renommant le lien comme NEXT_DOCUMENT<\/strong>.<\/p>\n\n\n\n Adaptez le code suivant et modifiez la connexion et le nom de la base pass\u00e9s en param\u00e8tres du constructeur de MongoDBConnection<\/strong>.<\/p>\n\n\n\n Modifiez \u00e9galement le nom de la collection et le filtre (optionnel) \u00e0 appliquer sur la collection.<\/p>\n\n\n\n En conclusion, l’int\u00e9gration de MongoDB dans Talend peut s’av\u00e9rer \u00e0 la fois puissante et flexible. En adoptant une approche bas\u00e9e sur des routines Java personnalis\u00e9es, nous avons d\u00e9montr\u00e9 comment \u00e9tablir une connexion \u00e0 une base de donn\u00e9es MongoDB sans n\u00e9cessiter la licence BigData, offrant ainsi une solution \u00e9volutive et performante.<\/p>\n\n\n\n La simplicit\u00e9 de l’exemple pr\u00e9sent\u00e9 ici, se limitant \u00e0 la lecture d’une collection MongoDB, ne refl\u00e8te qu’une fraction des capacit\u00e9s offertes. J’ai \u00e9tendu cette approche pour g\u00e9rer l’insertion, la mise \u00e0 jour de donn\u00e9es, ainsi que l’extraction du journal des modifications (OpLog) de MongoDB pour un mode delta.<\/p>\n\n\n\n Cette approche procure une ma\u00eetrise totale de votre code, une \u00e9volutivit\u00e9 garantie et des par exp\u00e9rience des performances optimales. L’int\u00e9gration de MongoDB avec Talend s’\u00e9rige comme une solution robuste.<\/p>\n\n\n\n J’esp\u00e8re que cet article vous a fourni des insights utiles pour tirer parti de la synergie entre MongoDB et Talend, et je vous encourage \u00e0 explorer davantage cette approche pour r\u00e9pondre \u00e0 vos besoins sp\u00e9cifiques. N’h\u00e9sitez pas \u00e0 partager vos exp\u00e9riences et \u00e0 poser des questions dans les commentaires. <\/p>\n\n\n\n Bonne int\u00e9gration !<\/strong><\/p>\n","protected":false},"excerpt":{"rendered":" Lors d’un r\u00e9cent projet de mise en place d’un PIM (Product Information Management) visant \u00e0 centraliser une grande quantit\u00e9 de donn\u00e9es, l’utilisation de MongoDB s’est av\u00e9r\u00e9e n\u00e9cessaire. Pour r\u00e9pondre \u00e0 ce besoin, j’ai adopt\u00e9 une approche particuli\u00e8re ax\u00e9e sur l’\u00e9volutivit\u00e9, et les performances. Dans cette d\u00e9marche, j’ai exploit\u00e9 les routines Java de Talend Integration Suite […]<\/p>\n","protected":false},"author":1,"featured_media":2563,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[13],"tags":[],"class_list":["post-2537","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-talend"],"_links":{"self":[{"href":"https:\/\/devportfolio.net\/wp-dev-blog\/wp-json\/wp\/v2\/posts\/2537","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/devportfolio.net\/wp-dev-blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/devportfolio.net\/wp-dev-blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/devportfolio.net\/wp-dev-blog\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/devportfolio.net\/wp-dev-blog\/wp-json\/wp\/v2\/comments?post=2537"}],"version-history":[{"count":12,"href":"https:\/\/devportfolio.net\/wp-dev-blog\/wp-json\/wp\/v2\/posts\/2537\/revisions"}],"predecessor-version":[{"id":2562,"href":"https:\/\/devportfolio.net\/wp-dev-blog\/wp-json\/wp\/v2\/posts\/2537\/revisions\/2562"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/devportfolio.net\/wp-dev-blog\/wp-json\/wp\/v2\/media\/2563"}],"wp:attachment":[{"href":"https:\/\/devportfolio.net\/wp-dev-blog\/wp-json\/wp\/v2\/media?parent=2537"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/devportfolio.net\/wp-dev-blog\/wp-json\/wp\/v2\/categories?post=2537"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/devportfolio.net\/wp-dev-blog\/wp-json\/wp\/v2\/tags?post=2537"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}\n
Cr\u00e9er une nouvelle routine <\/strong><\/h2>\n\n\n\n
package routines;\n\nimport java.util.Arrays;\nimport java.util.List;\n\nimport org.bson.Document;\nimport org.bson.conversions.Bson;\n\nimport com.mongodb.ConnectionString;\nimport com.mongodb.client.MongoClients;\nimport com.mongodb.client.MongoCursor;\nimport com.mongodb.client.MongoDatabase;\nimport com.mongodb.client.model.Aggregates;\n\n\/**\n * Classe permettant la connexion \u00e0 une base de donn\u00e9es MongoDB et l'ex\u00e9cution\n * d'op\u00e9rations.\n * \n * @author Votre Nom\n *\/\npublic class MongoDBConnection {\n\n private final String databaseName;\n private final String connectionString;\n private boolean isProcessFinished = false;\n\n private MongoCursor<Document> mongoCursor;\n\n \/**\n * Constructeur de la classe MongoDBConnection.\n * \n * @param connectionString L'URL de connexion \u00e0 MongoDB.\n * @param databaseName Le nom de la base de donn\u00e9es MongoDB.\n *\/\n public MongoDBConnection(String connectionString, String databaseName) {\n this.connectionString = isEmpty(connectionString) ? \"mongodb:\/\/127.0.0.1:27017\" : connectionString;\n this.databaseName = requireNonEmpty(databaseName, \"Database name cannot be null or empty.\");\n }\n\n \/**\n * \u00c9tablit une connexion \u00e0 la base de donn\u00e9es MongoDB.\n * \n * @return La base de donn\u00e9es MongoDB connect\u00e9e.\n * @throws IllegalArgumentException Si la connexion \u00e9choue.\n *\/\n public MongoDatabase connect() {\n try {\n return MongoClients.create(new ConnectionString(connectionString)).getDatabase(databaseName);\n } catch (Exception ex) {\n throw new IllegalArgumentException(ex.getMessage());\n }\n }\n\n \/**\n * Ex\u00e9cute une requ\u00eate sur une collection MongoDB avec des options de\n * filtrage et de tri facultatives.\n * \n * @param collectionName Le nom de la collection \u00e0 interroger.\n * @param queryString La cha\u00eene de filtrage de la requ\u00eate.\n * @param sortString La cha\u00eene de tri de la requ\u00eate.\n * @throws IllegalArgumentException Si le nom de la collection est nul ou vide.\n *\/\n public void queryCollection(String collectionName, String queryString, String sortString) {\n if (isEmpty(collectionName)) {\n throw new IllegalArgumentException(\"Collection name cannot be null or empty.\");\n }\n\n Bson filter = getAggregationOperatorFromString(queryString);\n\n List<Bson> operators = (isEmpty(sortString))\n ? Arrays.asList(Aggregates.match(filter))\n : Arrays.asList(Aggregates.match(filter), Aggregates.sort(getAggregationOperatorFromString(sortString)));\n\n mongoCursor = connect().getCollection(collectionName).aggregate(operators).iterator();\n }\n\n \/**\n * Convertit une cha\u00eene en op\u00e9rateur d'agr\u00e9gation MongoDB (Bson Document).\n * \n * @param operator La cha\u00eene repr\u00e9sentant l'op\u00e9rateur.\n * @return L'op\u00e9rateur d'agr\u00e9gation MongoDB sous forme de Document Bson.\n *\/\n public Document getAggregationOperatorFromString(String operator) {\n if (isEmpty(operator)) {\n return Document.parse(\"{}\");\n }\n\n return Document.parse(operator);\n }\n\n \/**\n * R\u00e9cup\u00e8re le document suivant du curseur.\n * \n * @return Le document suivant ou null si le curseur est vide.\n *\/\n public Document getNextDocument() {\n if (mongoCursor != null) {\n Document next = mongoCursor.tryNext();\n if (next != null) {\n return next;\n } else {\n mongoCursor.close();\n this.isProcessFinished = true;\n }\n } else {\n this.isProcessFinished = true;\n }\n return null;\n }\n\n \/**\n * R\u00e9cup\u00e8re le document suivant sous forme de cha\u00eene JSON.\n * \n * @return Le document suivant au format JSON ou null si le curseur est vide.\n *\/\n public String getNextDocumentToJSON() {\n Document doc = getNextDocument();\n return (doc != null) ? doc.toJson() : null;\n }\n\n \/**\n * V\u00e9rifie si le processus est termin\u00e9.\n * \n * @return true si le processus est termin\u00e9, false sinon.\n *\/\n public boolean isProcessFinished() {\n return this.isProcessFinished;\n }\n\n \/**\n * V\u00e9rifie si la cha\u00eene est vide ou contient \"null\".\n * \n * @param s La cha\u00eene \u00e0 v\u00e9rifier.\n * @return true si la cha\u00eene est vide ou contient \"null\", false sinon.\n *\/\n public static boolean isEmpty(String s) {\n if (s == null) {\n return true;\n }\n if (s.trim().isEmpty()) {\n return true;\n }\n if (s.trim().equals(\"null\")) {\n return true;\n }\n return false;\n }\n\n \/**\n * Exige une valeur non vide, sinon l\u00e8ve une exception avec le message\n * sp\u00e9cifi\u00e9.\n * \n * @param value La valeur \u00e0 v\u00e9rifier.\n * @param message Le message \u00e0 inclure dans l'exception.\n * @return La valeur si elle n'est pas vide.\n * @throws IllegalArgumentException Si la valeur est vide.\n *\/\n private static String requireNonEmpty(String value, String message) {\n if (isEmpty(value)) {\n throw new IllegalArgumentException(message);\n }\n return value;\n }\n}<\/code><\/pre>\n\n\n\nAjouter les d\u00e9pendances \u00e0 la routine<\/strong><\/h2>\n\n\n\n
![\"\"](\"https:\/\/devportfolio.net\/wp-dev-blog\/wp-content\/uploads\/2023\/12\/Talend_MongoDB_1.png\")
<\/figure>\n\n\n\nCr\u00e9er un nouveau job <\/strong><\/h2>\n\n\n\n
![\"\"](\"https:\/\/devportfolio.net\/wp-dev-blog\/wp-content\/uploads\/2023\/12\/Talend_MongoDB_2.png\")
<\/figure>\n\n\n\nMongoDBConnection mongoConnection = new MongoDBConnection(\"mongodb:\/\/127.0.0.1:27017\", \"PIMSOG\");\nmongoConnection.queryCollection(\"H308\", \"{ EAN13: '3324976120027' }\", null);\n\nwhile (true) {\n String sRecord = mongoConnection.getNextDocumentToJSON();\n\n if (mongoConnection.isProcessFinished() == Boolean.TRUE) {\n\n break;\n } else {\n\n \/\/ Flux de sortie\n if (sRecord != null) {\n NEXT_DOCUMENT.Record = sRecord.trim();\n }\n }\n}<\/code><\/pre>\n\n\n\n![\"\"](\"https:\/\/devportfolio.net\/wp-dev-blog\/wp-content\/uploads\/2023\/12\/Talend_MongoDB_3-1024x649.png\")
<\/figure>\n\n\n\n