frodovdr/node-red
1
0
Fork 0
mirror of https://github.com/node-red/node-red.git synced 2023-10-10 13:36:53 +02:00
Code Issues Releases Wiki Activity

Added delete to MongoDB node

Browse Source
This commit is contained in:
Dave C-J 2013-09-24 20:38:37 +01:00
parent c95fc633e3
commit 021b4cd610
2 changed files with 31 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
nodes/storage/66-mongodb.html
View File

@ -105,6 +105,13 @@
<label for="node-input-collection"><i class="icon-briefcase"></i> Collection</label> <label for="node-input-collection"><i class="icon-briefcase"></i> Collection</label>
<input type="text" id="node-input-collection" placeholder="collection"> <input type="text" id="node-input-collection" placeholder="collection">
</div> </div>
<div class="form-row">
<label for="node-input-operation"><i class="icon-wrench"></i> Operation</label>
<select type="text" id="node-input-operation" style="display: inline-block; width: auto; vertical-align: top;">
<option value=query>Query</option>
<option value=delete>Delete</option>
</select>
</div>
<div class="form-row"> <div class="form-row">
<label for="node-input-name"><i class="icon-tag"></i> Name</label> <label for="node-input-name"><i class="icon-tag"></i> Name</label>
<input type="text" id="node-input-name" placeholder="Name"> <input type="text" id="node-input-name" placeholder="Name">
@ -114,7 +121,9 @@
<script type="text/x-red" data-help-name="mongodb in"> <script type="text/x-red" data-help-name="mongodb in">
<p>Queries a MongoDB collection by using the <b>msg.payload</b> to be a MongoDB query statement as per the .find() function.</p> <p>Queries a MongoDB collection by using the <b>msg.payload</b> to be a MongoDB query statement as per the .find() function.</p>
<p>You may also (via a function) set a <b>msg.projection</b> object to constrain the returned fields, a <b>msg.sort</b> object and a <b>msg.limit</b> object.</p> <p>You may also (via a function) set a <b>msg.projection</b> object to constrain the returned fields, a <b>msg.sort</b> object and a <b>msg.limit</b> object.</p>
<p>All are optional - see the <a href="http://docs.mongodb.org/manual/reference/method/db.collection.find/" target="new"><i>MongoDB find docs</i></a> for examples. <p>All are optional - see the <a href="http://docs.mongodb.org/manual/reference/method/db.collection.find/" target="new"><i>MongoDB find docs</i></a> for examples.</p>
<p>You can also choose to <b>remove</b> items. To do so the <b>msg.payload</b> <i>MUST</i> contain an object that will select the items(s) to remove.
A blank object will delete <i>all of the objects</i> in the collection. You have been warned...</p>
</script> </script>
<script type="text/javascript"> <script type="text/javascript">
@ -125,6 +134,7 @@
mongodb: { type:"mongodb",required:true}, mongodb: { type:"mongodb",required:true},
name: {value:""}, name: {value:""},
collection: {value:"",required:true}, collection: {value:"",required:true},
operation: {value:"query"}
}, },
inputs:1, inputs:1,
outputs:1, outputs:1,

11
nodes/storage/66-mongodb.js
View File

@ -67,6 +67,7 @@ MongoOutNode.prototype.close = function() {
function MongoInNode(n) { function MongoInNode(n) {
RED.nodes.createNode(this,n); RED.nodes.createNode(this,n);
this.collection = n.collection; this.collection = n.collection;
this.operation = n.operation;
this.mongodb = n.mongodb; this.mongodb = n.mongodb;
this.mongoConfig = RED.nodes.getNode(this.mongodb); this.mongoConfig = RED.nodes.getNode(this.mongodb);
@ -80,6 +81,7 @@ function MongoInNode(n) {
if (err) { node.error(err); } if (err) { node.error(err); }
else { else {
node.on("input",function(msg) { node.on("input",function(msg) {
if (node.operation == "query") {
msg.projection = msg.projection || {}; msg.projection = msg.projection || {};
coll.find(msg.payload,msg.projection).sort(msg.sort).limit(msg.limit).toArray(function(err, items) { coll.find(msg.payload,msg.projection).sort(msg.sort).limit(msg.limit).toArray(function(err, items) {
if (err) { node.error(err); } if (err) { node.error(err); }
@ -89,6 +91,15 @@ function MongoInNode(n) {
delete msg.limit; delete msg.limit;
node.send(msg); node.send(msg);
}); });
}
if (node.operation == "delete") {
console.log(msg.payload);
coll.remove(msg.payload, {w:1}, function(err, items) {
if (err) node.error(err);
msg.payload = items;
node.send(msg);
});
}
}); });
} }
}); });