Pentaho MongoDB Delete Plugin

A Pentaho Data Integration Plugin to delete MongoDB document


Delete with json query and execute each row

MongoDB Delete Plugin has ability to get value of incoming data and use it as parameter in your query.

Let's say you have row:

and have data structure like :

use mongodbdelete
db.customer.insert({first_name:"OLVERA", last_name:"DWAYNE", phone: "62127829280", email:"olvera.dwayne@yahoo.com", gender: "F"})
db.customer.insert({first_name:"JASON", last_name:"DWAYNE", phone: "62127829280", email:"jason.dwayne@yahoo.com", gender: "M"})
db.customer.insert({first_name:"HUEY", last_name:"BRANDON", phone: "99883471275", email:"huey.brandon@yahoo.com", gender: "M"})
db.customer.insert({first_name:"BROWN", last_name:"ELIZABETH", phone: "10655648674", email:"elizabeth.brown@gmail.com", gender: "M"})
db.customer.insert({first_name:"OWENS", last_name:"CARMEN", phone: "272234298332", email:"owens.carmen@gmail.com", gender: "F"})
db.customer.insert({first_name:"HANNON", last_name:"SETH", phone: "864392582257", email:"hannon.seth@gmail.com", gender: "F"})
                      

and you want to use it's value as parameter. Example: Delete row where first_name equals with value of firstname and last_name equals with value of lastname

To do that, you can write query:

The ?{firstname} and ?{lastname} will replace by value of respective column during execution.

Resources

Sample Transformation : delete-by-json-query-exec-each-row.ktr