in Ubuntu
~\.node-red\settings.jsinclude the ObjectId as global import
functionGlobalContext: {
require: require, // Not mandatory
ObjectId : require('mongodb').ObjectID,
},And inside the function node, I just passed the payload as follows.
var ObjectId = global.get('ObjectId');
msg.payload={
"_id":ObjectId("5c9156c7f8c3ec3259454571")
};
return msg;
This flow is an adaption of the great flow developed by Steve-Mcl
| [{"id": "0338c3befa10e3ef","type": "tab","label": "MongoDB","disabled": false,"info": "","env": []},{"id": "c93ad5d5e0bf09e5","type": "tab","label": "MySQL","disabled": false,"info": "","env": []},{"id": "bad1ea5a333cb4d4","type": "tab","label": "Memory","disabled": false,"info": "","env": []},{"id": "dc42e32dff073243","type": "group","z": "0338c3befa10e3ef","name": "","style": {"fill": "#bfbfbf","label": true},"nodes": ["98bb4419b579a05d","a44dccd094937dc7","0214f907c6dde6e5","6830fb5b2dbb3c58","11de8e1f4cb16d24","037dce8e31058aab"],"x": 28,"y": 33,"w": 1304,"h": 534},{"id": "b63843cb893f8f99","type": "group","z": "bad1ea5a333cb4d4","style": {"stroke": "#93a1a1","stroke-opacity": "1","fill": "#eee8d5","fill-opacity": "0.5","label": true,"label-position": "nw","color": "#657b83"},"nodes": ["33f215417669f302","2bb822373b452b47","ad333172fb04b7e2","4a491b95e245e7c2","9f33e072997368b6","577d77dde821fe0e","2a45b1abb1a49ad6","305b5d0d4c97d4dd","098469ab1a800fe3","04955bf65de9fe2f","6445eb497e758dcc","55b62a42ae2ad47c","849df9bee5b7e1c5","16d491dfbd02964e","70a0e93542650b1f","7aea695d8fc1488c","8cea908331c72a07"],"x": 34,"y": 39,"w": 904,"h": 350},{"id": "7b144e46f5b6ec43","type": "group","z": "c93ad5d5e0bf09e5","style": {"stroke": "#93a1a1","stroke-opacity": "1","fill": "#eee8d5","fill-opacity": "0.5","label": true,"label-position": "nw","color": "#657b83"},"nodes": ["d433feb1.6365e","98b6cece.37871","3c1830eb.33b9","ef285826.0e9738","e396f56a.dcda38","458b0528.a4d98c","d84f16f7.3d9698","2b952c3a.f63884","c91568f0.c3f2f8","e4b82091.b8e9a","81bb8cdf.93e5b","c224cbcf.e3e718","9929a22b.66471","4bfc0ef6.e8511","c70c0833.831ab8","f92b07.fa8e84f8","7b9f8d8b.c6d4e4","857ff60c.da9078","9a8b3fa.c0817c","5b19502.0bae0b","4520409.a2751c","b9aef47c.8f0938","ece93a93.ebc878","930f03c1.94bd5","e51fe384.1db73","9fe2ed80.2522c","6ce2248e.9c889c","50307401.f1297c","c1934c38.6647d","973e8aa6.834338"],"x": 34,"y": 19,"w": 1142,"h": 382},{"id": "98bb4419b579a05d","type": "group","z": "0338c3befa10e3ef","g": "dc42e32dff073243","name": "","style": {"stroke": "#61AFFE","label": true,"fill": "#EFF7FF","fill-opacity": "1"},"nodes": ["1cb547dae9f9416d","117569d4e15e635d","6793251b39be4255","032c5b5f76bb58ec","38ebb2b60b411e67"],"x": 54,"y": 159,"w": 1252,"h": 82},{"id": "a44dccd094937dc7","type": "group","z": "0338c3befa10e3ef","g": "dc42e32dff073243","name": "","style": {"fill": "#FFF5EA","label": true,"fill-opacity": "1","stroke": "#FCA130"},"nodes": ["e12ffb8302454083","f9e42c50a8fc1816","9f069642444c25a7","0f538eeddd4f4270","377e6144780b155c"],"x": 54,"y": 259,"w": 1252,"h": 82},{"id": "0214f907c6dde6e5","type": "group","z": "0338c3befa10e3ef","g": "dc42e32dff073243","name": "","style": {"fill": "#ECFAF4","fill-opacity": "1","label": true,"stroke": "#49CC90"},"nodes": ["25538d080ca6636d","6fa3df0a02c2e2d7","c266861c547ad94b","df1b7b5834c6cb38"],"x": 54,"y": 359,"w": 1252,"h": 82},{"id": "6830fb5b2dbb3c58","type": "group","z": "0338c3befa10e3ef","g": "dc42e32dff073243","name": "","style": {"fill": "#FFEBEB","fill-opacity": "1","label": true,"stroke": "#F93E3E"},"nodes": ["f60209089e073bc6","75d1256bb4f79751","8731432811f95b1a","3d4e6c7b4de7bac6"],"x": 54,"y": 459,"w": 1252,"h": 82},{"id": "11de8e1f4cb16d24","type": "group","z": "0338c3befa10e3ef","g": "dc42e32dff073243","name": "","style": {"fill": "#FDF6E3","fill-opacity": "1","label": true},"nodes": ["cc207b5b.33df88","1d1b40c4d0f7ee32","c2852efd.3d7ad","663e1cfb.99c1e4","5fd8010a154e7b55"],"x": 154,"y": 59,"w": 1152,"h": 82},{"id": "f6c122ad.621c98","type": "mongodb2","uri": "mongodb://localhost:27017/db","name": "db","options": "","parallelism": "-1"},{"id": "d48d08d1.d221d8","type": "MySQLdatabase","name": "","host": "localhost","port": "3306","db": "mysql","tz": "","charset": ""},{"id": "377e6144780b155c","type": "http in","z": "0338c3befa10e3ef","g": "a44dccd094937dc7","name": "","url": "/update","method": "put","swaggerDoc": "","x": 150,"y": 300,"wires": [["0f538eeddd4f4270"]]},{"id": "9f069642444c25a7","type": "http response","z": "0338c3befa10e3ef","g": "a44dccd094937dc7","name": "","x": 1230,"y": 300,"wires": []},{"id": "0f538eeddd4f4270","type": "function","z": "0338c3befa10e3ef","g": "a44dccd094937dc7","name": "update request","func": "/*\r\nmsg.result correspond à l'objet mis à jour,\r\nle delete permet de supprimer la propriété\r\n_id de l'objet, en effet l'_id est géré directement\r\npar le noued OjectId\r\npour la requète update \r\non doit fournir un tableau [<query>,<valeur mises à jour>]\r\nici ce sera de la forme:[ {_id:ObjectId(\"xxx\")}, {\"nom\": \"toto\", \"prenom\": \"tutu\", \"immatriculation\": \"AB123CD\", \"heure\": null, \"minute\": null }]*/\r\nvar ObjectId = global.get('ObjectId');\r\nmsg.payload = { \"_id\": ObjectId(msg.payload._id)};\r\nmsg.result=msg.req.body;\r\ndelete msg.req.body._id;\r\nmsg.payload=[ msg.payload, msg.req.body];\r\nreturn msg;","outputs": "1","noerr": 0,"initialize": "","finalize": "","libs": [],"x": 400,"y": 300,"wires": [["f9e42c50a8fc1816"]]},{"id": "032c5b5f76bb58ec","type": "http in","z": "0338c3befa10e3ef","g": "98bb4419b579a05d","name": "","url": "/index","method": "get","upload": false,"swaggerDoc": "","x": 140,"y": 200,"wires": [["6793251b39be4255"]]},{"id": "117569d4e15e635d","type": "http response","z": "0338c3befa10e3ef","g": "98bb4419b579a05d","name": "","x": 1230,"y": 200,"wires": []},{"id": "1cb547dae9f9416d","type": "json","z": "0338c3befa10e3ef","g": "98bb4419b579a05d","name": "","x": 750,"y": 200,"wires": [["38ebb2b60b411e67"]]},{"id": "e12ffb8302454083","type": "function","z": "0338c3befa10e3ef","g": "a44dccd094937dc7","name": "callback response","func": "/*\r\npour que la jsGrid soit rafraichie, \r\nil faut lui envoyer l'objet qui a été mis à jour*/\r\nmsg.payload=msg.result;\r\nreturn msg;","outputs": 1,"noerr": 0,"x": 1010,"y": 300,"wires": [["9f069642444c25a7"]]},{"id": "c266861c547ad94b","type": "http response","z": "0338c3befa10e3ef","g": "0214f907c6dde6e5","name": "","x": 1230,"y": 400,"wires": []},{"id": "df1b7b5834c6cb38","type": "http in","z": "0338c3befa10e3ef","g": "0214f907c6dde6e5","name": "","url": "/insert","method": "post","swaggerDoc": "","x": 150,"y": 400,"wires": [["6fa3df0a02c2e2d7"]]},{"id": "3d4e6c7b4de7bac6","type": "http in","z": "0338c3befa10e3ef","g": "6830fb5b2dbb3c58","name": "","url": "/delete","method": "delete","swaggerDoc": "","x": 160,"y": 500,"wires": [["75d1256bb4f79751"]]},{"id": "8731432811f95b1a","type": "http response","z": "0338c3befa10e3ef","g": "6830fb5b2dbb3c58","name": "","x": 1230,"y": 500,"wires": []},{"id": "25538d080ca6636d","type": "function","z": "0338c3befa10e3ef","g": "0214f907c6dde6e5","name": "callback response","func": "/*\r\npour que la jsGrid soit rafraichie, \r\nil faut lui envoyer l'objet qui a été mis à jour*/\r\nmsg.payload=msg.req.body;\r\nreturn msg;","outputs": 1,"noerr": 0,"initialize": "","finalize": "","libs": [],"x": 850,"y": 400,"wires": [["c266861c547ad94b"]]},{"id": "75d1256bb4f79751","type": "function","z": "0338c3befa10e3ef","g": "6830fb5b2dbb3c58","name": "extract _id","func": "var ObjectId = global.get('ObjectId');\r\nmsg.payload = { \"_id\": ObjectId(msg.payload._id)};\r\nreturn msg;","outputs": 1,"noerr": 0,"initialize": "","finalize": "","libs": [],"x": 390,"y": 500,"wires": [["f60209089e073bc6"]]},{"id": "663e1cfb.99c1e4","type": "function","z": "0338c3befa10e3ef","g": "11de8e1f4cb16d24","name": "split elements","func": "var mapResult = { countdown: msg.payload.length, result: msg.payload.map(function(){})};\r\nreturn [msg.payload.map(function(element, index) { return { payload: element, index: index, mapResult: function() { return mapResult; } };})];","outputs": 1,"noerr": 0,"initialize": "","finalize": "","libs": [],"x": 540,"y": 100,"wires": [["1d1b40c4d0f7ee32"]],"icon": "node-red/split.svg"},{"id": "cc207b5b.33df88","type": "function","z": "0338c3befa10e3ef","g": "11de8e1f4cb16d24","name": "reconstruct array","func": "var mapResult = msg.mapResult();\r\nmapResult.result[msg.index] = msg.payload;\r\nmapResult.countdown -= 1;\r\nif (0 === mapResult.countdown) { return { payload: mapResult.result };}","outputs": 1,"noerr": 0,"initialize": "","finalize": "","libs": [],"x": 1070,"y": 100,"wires": [["c2852efd.3d7ad"]],"icon": "node-red/join.svg"},{"id": "c2852efd.3d7ad","type": "debug","z": "0338c3befa10e3ef","g": "11de8e1f4cb16d24","name": "","active": true,"tosidebar": true,"console": false,"tostatus": false,"complete": "true","targetType": "full","statusVal": "","statusType": "auto","x": 1245,"y": 100,"wires": [],"l": false},{"id": "5fd8010a154e7b55","type": "function","z": "0338c3befa10e3ef","g": "11de8e1f4cb16d24","name": "Generate dummy data","func": "const firstNames = [\"Liam\",\"Noah\",\"Oliver\",\"William\",\"Elijah\",\"James\",\"Benjamin\",\"Lucas\",\"Mason\",\"Ethan\",\"Alexander\",\"Henry\",\"Jacob\",\"Michael\",\"Daniel\",\"Logan\",\"Jackson\",\"Sebastian\",\"Jack\",\"Aiden\"];\r\nconst sirNames = [\"Jones\",\"Taylor\",\"Williams\",\"Brown\",\"White\",\"Harris\",\"Martin\",\"Davies\",\"Wilson\",\"Cooper\",\"Evans\",\"King\",\"Thomas\",\"Baker\",\"Green\",\"Wright\",\"Johnson\",\"Edwards\",\"Clark\",\"Roberts\",\"Robinson\",\"Hall\",\"Lewis\",\"Young\",\"Davis\",\"Turner\",\"Hill\",\"Phillips\",\"Collins\",\"Allen\",\"Moore\",\"Thompson\",\"Carter\",\"James\",\"Knight\",\"Walker\",\"Wood\",\"Hughes\",\"Parker\",\"Ward\",\"Bennett\",\"Cook\",\"Webb\",\"Bailey\",\"Scott\",\"Jackson\",\"Lee\",\"Cox\"]; \r\nvar database = [];\r\nfor(let i = 1; i <= 30; i++) { var item = {\"id\":i, \"timestamp\":Date.now()}; item.foreName = randomFirstname(); item.sirName = randomSirname(); item.userID = \"U\" + randomInt(1000, 2999); item.age = randomInt(20, 65); database.push(item);}\r\nfunction randomFirstname() { return firstNames[randomInt(0, firstNames.length-1)];}\r\nfunction randomSirname() { return sirNames[randomInt(0, sirNames.length-1)];}\r\nfunction randomInt(min, max) { return Math.floor(Math.random() * (max - min + 1) + min);}\r\nflow.set(\"database\", database);\r\nmsg.payload = database;\r\nreturn msg;","outputs": 1,"noerr": 0,"initialize": "","finalize": "","libs": [],"x": 280,"y": 100,"wires": [["663e1cfb.99c1e4"]],"icon": "node-red/leveldb.png"},{"id": "38ebb2b60b411e67","type": "template","z": "0338c3befa10e3ef","g": "98bb4419b579a05d","name": "Web Template","field": "payload","fieldType": "msg","format": "handlebars","syntax": "mustache","template": "<!DOCTYPE html><html lang=\"en-GB\"><head> <title>Users</title> <meta charset=\"utf-8\"> <meta name=\"viewport\" content=\"width=device-width, initial-scale=1\"> <link rel=\"stylesheet\" href=\"https://maxcdn.bootstrapcdn.com/bootstrap/3.3.7/css/bootstrap.min.css\"> <link rel=\"stylesheet\" href=\"https://cdnjs.cloudflare.com/ajax/libs/bootstrap-timepicker/0.5.2/css/bootstrap-timepicker.min.css\" /> <script src=\"https://ajax.googleapis.com/ajax/libs/jquery/3.1.1/jquery.min.js\"></script> <script src=\"https://maxcdn.bootstrapcdn.com/bootstrap/3.3.7/js/bootstrap.min.js\"></script> <link type=\"text/css\" rel=\"stylesheet\" href=\"https://cdnjs.cloudflare.com/ajax/libs/jsgrid/1.5.3/jsgrid.min.css\" /> <link type=\"text/css\" rel=\"stylesheet\" href=\"https://cdnjs.cloudflare.com/ajax/libs/jsgrid/1.5.3/jsgrid-theme.min.css\" /> <script type=\"text/javascript\" src=\"https://cdnjs.cloudflare.com/ajax/libs/jsgrid/1.5.3/jsgrid.min.js\"></script> <script type=\"text/javascript\"> (function () { console.log(\"crud demo\"); var db = {{#payload}}{{{.}}}{{/payload}}; (\"#jsgrid\").jsGrid({ width: \"100%\", confirmDeleting: false, inserting: true, editing: true, sorting: true, paging: true, data: db, fields: [ { title:\"ID\", name: \"id\", type: \"number\", width: 20, readOnly: true }, { title:\"User ID\", name: \"userID\", type: \"text\", width: 50 }, { title:\"First Name\", name: \"foreName\", type: \"text\", width: 50 }, { title:\"Last Name\", name: \"sirName\", type: \"text\", width: 50 }, { title:\"Age\", name: \"age\", type:\"number\", width: 25}, { type: \"control\" } ], controller: { insertItem: function(item) { return .ajax({ type: \"POST\", url: \"/insert\", data: item }); }, updateItem: function(item) { return .ajax({ type: \"PUT\", url: \"/update\", data: item }); }, deleteItem: function(item) { return .ajax({ type: \"DELETE\", url: \"/delete\", data: item }); } } }); }); </script></head><body class=\"container\"> <section class=\"row\"> <div class=\"col-md-6\"></div> <div class=\"col-md-6\" id=\"jsgrid\"> </div> </section></body></html>","x": 1000,"y": 200,"wires": [["117569d4e15e635d"]]},{"id": "037dce8e31058aab","type": "inject","z": "0338c3befa10e3ef","g": "dc42e32dff073243","name": "","props": [{"p": "payload"},{"p": "topic","vt": "str"}],"repeat": "","crontab": "","once": false,"onceDelay": 0.1,"topic": "","payload": "","payloadType": "date","x": 105,"y": 100,"wires": [["5fd8010a154e7b55"]],"l": false},{"id": "f9e42c50a8fc1816","type": "mongodb2 in","z": "0338c3befa10e3ef","g": "a44dccd094937dc7","service": "_ext_","configNode": "f6c122ad.621c98","name": "","collection": "LicencePlate","operation": "update","x": 690,"y": 300,"wires": [["e12ffb8302454083"]]},{"id": "6793251b39be4255","type": "mongodb2 in","z": "0338c3befa10e3ef","g": "98bb4419b579a05d","service": "_ext_","configNode": "f6c122ad.621c98","name": "","collection": "LicencePlate","operation": "find.toArray","x": 440,"y": 200,"wires": [["1cb547dae9f9416d"]]},{"id": "6fa3df0a02c2e2d7","type": "mongodb2 in","z": "0338c3befa10e3ef","g": "0214f907c6dde6e5","service": "_ext_","configNode": "f6c122ad.621c98","name": "","collection": "LicencePlate","operation": "insert","x": 420,"y": 400,"wires": [["25538d080ca6636d"]]},{"id": "f60209089e073bc6","type": "mongodb2 in","z": "0338c3befa10e3ef","g": "6830fb5b2dbb3c58","service": "_ext_","configNode": "f6c122ad.621c98","name": "","collection": "LicencePlate","operation": "deleteOne","x": 880,"y": 500,"wires": [["8731432811f95b1a"]]},{"id": "1d1b40c4d0f7ee32","type": "mongodb2 in","z": "0338c3befa10e3ef","g": "11de8e1f4cb16d24","service": "_ext_","configNode": "f6c122ad.621c98","name": "","collection": "LicencePlate","operation": "insert","x": 800,"y": 100,"wires": [["cc207b5b.33df88"]]},{"id": "d433feb1.6365e","type": "http in","z": "c93ad5d5e0bf09e5","g": "7b144e46f5b6ec43","name": "","url": "/index","method": "get","upload": false,"swaggerDoc": "","x": 120,"y": 60,"wires": [["98b6cece.37871"]]},{"id": "98b6cece.37871","type": "template","z": "c93ad5d5e0bf09e5","g": "7b144e46f5b6ec43","name": "web-template","field": "payload","fieldType": "msg","format": "handlebars","syntax": "mustache","template": "<!DOCTYPE html><html lang=\"en\"> <head> <!-- The jQuery library is a prerequisite for all jqSuite products --> <script type=\"text/ecmascript\" src=\"http://www.guriddo.net/demo/js/jquery.min.js\"></script> <!-- We support more than 40 localizations --> <script type=\"text/ecmascript\" src=\"http://www.guriddo.net/demo/js/trirand/i18n/grid.locale-en.js\"></script> <!-- This is the Javascript file of jqGrid --> <script type=\"text/ecmascript\" src=\"http://www.guriddo.net/demo/js/trirand/jquery.jqGrid.min.js\"></script> <!-- This is the localization file of the grid controlling messages, labels, etc. <!-- A link to a jQuery UI ThemeRoller theme, more than 22 built-in and many more custom --> <link rel=\"stylesheet\" type=\"text/css\" media=\"screen\" href=\"http://struts.jgeppert.com/struts2-jquery-grid-showcase/themes/showcase/jquery-ui.css\" /> <!-- The link to the CSS that the grid needs --> <link rel=\"stylesheet\" type=\"text/css\" media=\"screen\" href=\"http://www.guriddo.net/demo/css/trirand/ui.jqgrid.css\" /> <meta charset=\"utf-8\" /> <title>Demo CRUD with jqGrid</title> <script type=\"text/javascript\"></script> <link rel=\"stylesheet\" type=\"text/css\" href=\"http://www.guriddo.net/B1D671CF-E532-4481-99AA-19F420D90332/netdefender/hui/ndhui.css\" /> </head> <body> <script type=\"text/javascript\" language=\"javascript\" src=\"http://www.guriddo.net/B1D671CF-E532-4481-99AA-19F420D90332/netdefender/hui/ndhui.js?0=0&0=0&0=0\"></script> <table id=\"jqGrid\"></table> <div id=\"jqGridPager\"></div> <script type=\"text/javascript\"> (document).ready(function () { (\"#jqGrid\").jqGrid({ url: '/search', mtype: \"GET\", datatype: \"json\", colModel: [ { label: 'ID', name: 'id', key: true, search: false, width: 75 }, { label: 'Name', name: 'name', width: 150, editable: true, formoptions: { colpos: 1, rowpos: 1 } }, { label: 'Last Name', name: 'lastname', width: 150, editable: true, edittype: \"select\", formoptions: { colpos: 1, rowpos: 2 }, editoptions: { dataUrl:'/search/lastname', type:\"GET\", buildSelect: function(data) { var response = jQuery.parseJSON(data); //JSON data var s = '<select>'; if (response && response.length) { s += '<option hidden=\"true\">--- Select Lastname ---</option>'; for (var i = 0, l=response.length; i<l ; i++) { var id = response[i].id; var val = response[i].value; // You can concatenate ID or any other string here //For example: var ri = response[i].id + response[i].value; s += '<option value=\"'+id+'\">'+val+'</option>'; } } return s + \"</select>\"; } } }, { label: 'Code', name: 'code', width: 150, editable: true, formoptions: { colpos: 2, rowpos: 1 } }, { label: 'Married', name: 'married', width: 150, align: \"center\", search: false, editable: true, edittype: \"checkbox\", formatter: \"checkbox\", editoptions: { value: \"1:0\" }, formoptions: { colpos: 2, rowpos: 2 } } ], width: 500, height: 260, rowNum: 10, loadonce: true, viewrecords: true, pager: \"#jqGridPager\" }); ('#jqGrid').navGrid('#jqGridPager', // The buttons to appear on the toolbar of the grid { edit: true, add: true, del: true, search: true, refresh: true, view: true, position: \"left\", cloneToTop: true }, // Options for the Edit Dialog { url: '/update', editCaption: \"The Edit Dialog\", recreateForm: true,\t\t\t\t\t //checkOnUpdate : true,\t\t\t\t\t //checkOnSubmit : true,\t\t\t\t\t beforeSubmit : function( postdata, form , oper) {\t\t\t\t\t\t if(confirm('Are you sure you want to update this information?') ) {\t\t\t\t\t\t\t // Do something\t\t\t\t\t\t \t return [true,'/update'];\t\t\t\t\t\t } else {\t\t\t\t\t\t\treturn [false, 'Update failed!'];\t\t\t\t\t\t }\t\t\t\t\t }, afterSubmit: function () { (this).jqGrid(\"setGridParam\", {datatype: 'json'}); return [true]; }, closeAfterEdit: true, errorTextFormat: function (data) { return 'Error: ' + data.responseText } }, // Options for the Add Dialog { url: '/insert', addCaption: \"Add Dialog\", afterSubmit: function () { (this).jqGrid(\"setGridParam\", {datatype: 'json'}); return [true]; }, closeAfterAdd: true, recreateForm: true, errorTextFormat: function (data) { return 'Error: ' + data.responseText } }, // Options for the Delete Dialog { url: '/delete', errorTextFormat: function (data) { return 'Error: ' + data.responseText } }); (\"#jqGrid\").jqGrid('filterToolbar', { stringResult: true, searchOnEnter: true }); }); </script> </body></html>","x": 380,"y": 60,"wires": [["3c1830eb.33b9"]]},{"id": "3c1830eb.33b9","type": "http response","z": "c93ad5d5e0bf09e5","g": "7b144e46f5b6ec43","name": "","statusCode": "","headers": {},"x": 1100,"y": 60,"wires": []},{"id": "ef285826.0e9738","type": "http in","z": "c93ad5d5e0bf09e5","g": "7b144e46f5b6ec43","name": "","url": "/search","method": "get","upload": false,"swaggerDoc": "","x": 130,"y": 120,"wires": [["e396f56a.dcda38"]]},{"id": "e396f56a.dcda38","type": "function","z": "c93ad5d5e0bf09e5","g": "7b144e46f5b6ec43","name": "search-query","func": "//msg.topic=\"SELECT CONCAT('M00','',test.id) AS id,test.name AS name,lastname.lastname AS lastname,test.code AS code,test.married AS married FROM test INNER JOIN lastname ON lastname.id = test.lastname ORDER BY test.id DESC\";\r\nmsg.topic=\"SELECT test.id AS id,test.name AS name,lastname.lastname AS lastname,test.code AS code,test.married AS married FROM test INNER JOIN lastname ON lastname.id = test.lastname ORDER BY test.id DESC\";\r\nreturn msg;","outputs": 1,"noerr": 0,"x": 370,"y": 120,"wires": [["9fe2ed80.2522c"]]},{"id": "458b0528.a4d98c","type": "http response","z": "c93ad5d5e0bf09e5","g": "7b144e46f5b6ec43","name": "","statusCode": "","headers": {},"x": 1100,"y": 120,"wires": []},{"id": "d84f16f7.3d9698","type": "function","z": "c93ad5d5e0bf09e5","g": "7b144e46f5b6ec43","name": "search-response","func": "return msg;","outputs": 1,"noerr": 0,"x": 765,"y": 120,"wires": [["2b952c3a.f63884"]]},{"id": "2b952c3a.f63884","type": "json","z": "c93ad5d5e0bf09e5","g": "7b144e46f5b6ec43","name": "","property": "payload","action": "","pretty": false,"x": 950,"y": 120,"wires": [["458b0528.a4d98c"]]},{"id": "c91568f0.c3f2f8","type": "http in","z": "c93ad5d5e0bf09e5","g": "7b144e46f5b6ec43","name": "","url": "/insert","method": "post","upload": false,"swaggerDoc": "","x": 130,"y": 240,"wires": [["81bb8cdf.93e5b"]]},{"id": "e4b82091.b8e9a","type": "function","z": "c93ad5d5e0bf09e5","g": "7b144e46f5b6ec43","name": "insert-response","func": "msg.payload=msg.result;\r\nreturn msg;","outputs": 1,"noerr": 0,"x": 755,"y": 240,"wires": [["c224cbcf.e3e718"]]},{"id": "81bb8cdf.93e5b","type": "function","z": "c93ad5d5e0bf09e5","g": "7b144e46f5b6ec43","name": "insert-query","func": "msg.topic=\"INSERT INTO test (name,lastname,code,married,timestamp) VALUES ('\" + msg.payload.name + \"','\" + msg.payload.lastname + \"','\" + msg.payload.code + \"','\" + msg.payload.married + \"',CURRENT_TIMESTAMP)\";\r\nreturn msg;","outputs": 1,"noerr": 0,"x": 370,"y": 240,"wires": [["50307401.f1297c"]]},{"id": "c224cbcf.e3e718","type": "http response","z": "c93ad5d5e0bf09e5","g": "7b144e46f5b6ec43","name": "","x": 1100,"y": 240,"wires": []},{"id": "9929a22b.66471","type": "function","z": "c93ad5d5e0bf09e5","g": "7b144e46f5b6ec43","name": "lastname-query","func": "msg.topic=\"SELECT id, lastname as value FROM lastname\";\r\nreturn msg;","outputs": 1,"noerr": 0,"x": 380,"y": 180,"wires": [["6ce2248e.9c889c"]]},{"id": "4bfc0ef6.e8511","type": "function","z": "c93ad5d5e0bf09e5","g": "7b144e46f5b6ec43","name": "lastname-response","func": "return msg;","outputs": 1,"noerr": 0,"x": 765,"y": 180,"wires": [["7b9f8d8b.c6d4e4"]]},{"id": "c70c0833.831ab8","type": "http in","z": "c93ad5d5e0bf09e5","g": "7b144e46f5b6ec43","name": "","url": "/search/lastname","method": "get","upload": false,"swaggerDoc": "","x": 160,"y": 180,"wires": [["9929a22b.66471"]]},{"id": "f92b07.fa8e84f8","type": "http response","z": "c93ad5d5e0bf09e5","g": "7b144e46f5b6ec43","name": "","statusCode": "","headers": {},"x": 1100,"y": 180,"wires": []},{"id": "7b9f8d8b.c6d4e4","type": "json","z": "c93ad5d5e0bf09e5","g": "7b144e46f5b6ec43","name": "","property": "payload","action": "","pretty": false,"x": 950,"y": 180,"wires": [["f92b07.fa8e84f8"]]},{"id": "857ff60c.da9078","type": "http in","z": "c93ad5d5e0bf09e5","g": "7b144e46f5b6ec43","name": "","url": "/delete","method": "post","upload": false,"swaggerDoc": "","x": 130,"y": 360,"wires": [["5b19502.0bae0b"]]},{"id": "9a8b3fa.c0817c","type": "function","z": "c93ad5d5e0bf09e5","g": "7b144e46f5b6ec43","name": "delete-response","func": "msg.payload=msg.result;\r\nreturn msg;","outputs": 1,"noerr": 0,"x": 755,"y": 360,"wires": [["4520409.a2751c"]]},{"id": "5b19502.0bae0b","type": "function","z": "c93ad5d5e0bf09e5","g": "7b144e46f5b6ec43","name": "delete-query","func": "msg.topic=\"DELETE FROM test WHERE id='\" + msg.payload.id + \"'\";\r\nreturn msg;","outputs": 1,"noerr": 0,"x": 370,"y": 360,"wires": [["973e8aa6.834338"]]},{"id": "4520409.a2751c","type": "http response","z": "c93ad5d5e0bf09e5","g": "7b144e46f5b6ec43","name": "","x": 1100,"y": 360,"wires": []},{"id": "b9aef47c.8f0938","type": "http in","z": "c93ad5d5e0bf09e5","g": "7b144e46f5b6ec43","name": "","url": "/update","method": "post","upload": false,"swaggerDoc": "","x": 130,"y": 300,"wires": [["930f03c1.94bd5"]]},{"id": "ece93a93.ebc878","type": "function","z": "c93ad5d5e0bf09e5","g": "7b144e46f5b6ec43","name": "update-response","func": "msg.payload=msg.result;\r\nreturn msg;","outputs": 1,"noerr": 0,"x": 765,"y": 300,"wires": [["e51fe384.1db73"]]},{"id": "930f03c1.94bd5","type": "function","z": "c93ad5d5e0bf09e5","g": "7b144e46f5b6ec43","name": "update-query","func": "msg.topic=\"UPDATE test SET name='\" + msg.payload.name + \"', lastname='\" + msg.payload.lastname + \"', code='\" + msg.payload.code + \"', married='\" + msg.payload.married + \"' WHERE id='\" + msg.payload.id + \"'\";\r\nreturn msg;","outputs": 1,"noerr": 0,"x": 370,"y": 300,"wires": [["c1934c38.6647d"]]},{"id": "e51fe384.1db73","type": "http response","z": "c93ad5d5e0bf09e5","g": "7b144e46f5b6ec43","name": "","x": 1100,"y": 300,"wires": []},{"id": "9fe2ed80.2522c","type": "mysql","z": "c93ad5d5e0bf09e5","g": "7b144e46f5b6ec43","mydb": "d48d08d1.d221d8","name": "database","x": 570,"y": 120,"wires": [["d84f16f7.3d9698"]]},{"id": "6ce2248e.9c889c","type": "mysql","z": "c93ad5d5e0bf09e5","g": "7b144e46f5b6ec43","mydb": "d48d08d1.d221d8","name": "database","x": 570,"y": 180,"wires": [["4bfc0ef6.e8511"]]},{"id": "50307401.f1297c","type": "mysql","z": "c93ad5d5e0bf09e5","g": "7b144e46f5b6ec43","mydb": "d48d08d1.d221d8","name": "database","x": 570,"y": 240,"wires": [["e4b82091.b8e9a"]]},{"id": "c1934c38.6647d","type": "mysql","z": "c93ad5d5e0bf09e5","g": "7b144e46f5b6ec43","mydb": "d48d08d1.d221d8","name": "database","x": 570,"y": 300,"wires": [["ece93a93.ebc878"]]},{"id": "973e8aa6.834338","type": "mysql","z": "c93ad5d5e0bf09e5","g": "7b144e46f5b6ec43","mydb": "d48d08d1.d221d8","name": "database","x": 570,"y": 360,"wires": [["9a8b3fa.c0817c"]]},{"id": "33f215417669f302","type": "http in","z": "bad1ea5a333cb4d4","d": true,"g": "b63843cb893f8f99","name": "","url": "/update","method": "put","upload": false,"swaggerDoc": "","x": 130,"y": 220,"wires": [["55b62a42ae2ad47c"]]},{"id": "2bb822373b452b47","type": "http response","z": "bad1ea5a333cb4d4","g": "b63843cb893f8f99","name": "","x": 862,"y": 220,"wires": []},{"id": "ad333172fb04b7e2","type": "template","z": "bad1ea5a333cb4d4","g": "b63843cb893f8f99","name": "Web Template","field": "payload","fieldType": "msg","format": "handlebars","syntax": "mustache","template": "<!DOCTYPE html><html lang=\"en-GB\"><head> <title>Users</title> <meta charset=\"utf-8\"> <meta name=\"viewport\" content=\"width=device-width, initial-scale=1\"> <link rel=\"stylesheet\" href=\"https://maxcdn.bootstrapcdn.com/bootstrap/3.3.7/css/bootstrap.min.css\"> <link rel=\"stylesheet\" href=\"https://cdnjs.cloudflare.com/ajax/libs/bootstrap-timepicker/0.5.2/css/bootstrap-timepicker.min.css\" /> <script src=\"https://ajax.googleapis.com/ajax/libs/jquery/3.1.1/jquery.min.js\"></script> <script src=\"https://maxcdn.bootstrapcdn.com/bootstrap/3.3.7/js/bootstrap.min.js\"></script> <link type=\"text/css\" rel=\"stylesheet\" href=\"https://cdnjs.cloudflare.com/ajax/libs/jsgrid/1.5.3/jsgrid.min.css\" /> <link type=\"text/css\" rel=\"stylesheet\" href=\"https://cdnjs.cloudflare.com/ajax/libs/jsgrid/1.5.3/jsgrid-theme.min.css\" /> <script type=\"text/javascript\" src=\"https://cdnjs.cloudflare.com/ajax/libs/jsgrid/1.5.3/jsgrid.min.js\"></script> <script type=\"text/javascript\"> (function () { console.log(\"crud demo\"); var db = {{#payload}}{{{.}}}{{/payload}}; (\"#jsgrid\").jsGrid({ width: \"100%\", confirmDeleting: false, inserting: true, editing: true, sorting: true, paging: true, data: db, fields: [ { title:\"ID\", name: \"id\", type: \"number\", width: 20, readOnly: true }, { title:\"User ID\", name: \"userID\", type: \"text\", width: 50 }, { title:\"First Name\", name: \"foreName\", type: \"text\", width: 50 }, { title:\"Last Name\", name: \"sirName\", type: \"text\", width: 50 }, { title:\"Age\", name: \"age\", type:\"number\", width: 25}, { type: \"control\" } ], controller: { insertItem: function(item) { return .ajax({ type: \"POST\", url: \"/insert\", data: item }); }, updateItem: function(item) { return .ajax({ type: \"PUT\", url: \"/update\", data: item }); }, deleteItem: function(item) { return .ajax({ type: \"DELETE\", url: \"/delete\", data: item }); } } }); }); </script></head><body class=\"container\"> <section class=\"row\"> <div class=\"col-md-6\"></div> <div class=\"col-md-6\" id=\"jsgrid\"> </div> </section></body></html>","x": 652,"y": 156,"wires": [["9f33e072997368b6"]]},{"id": "4a491b95e245e7c2","type": "http in","z": "bad1ea5a333cb4d4","d": true,"g": "b63843cb893f8f99","name": "","url": "/index","method": "get","upload": false,"swaggerDoc": "","x": 120,"y": 156,"wires": [["70a0e93542650b1f"]]},{"id": "9f33e072997368b6","type": "http response","z": "bad1ea5a333cb4d4","g": "b63843cb893f8f99","name": "","x": 862,"y": 156,"wires": []},{"id": "577d77dde821fe0e","type": "http response","z": "bad1ea5a333cb4d4","g": "b63843cb893f8f99","name": "","x": 862,"y": 284,"wires": []},{"id": "2a45b1abb1a49ad6","type": "http in","z": "bad1ea5a333cb4d4","d": true,"g": "b63843cb893f8f99","name": "","url": "/insert","method": "post","upload": false,"swaggerDoc": "","x": 130,"y": 284,"wires": [["849df9bee5b7e1c5"]]},{"id": "305b5d0d4c97d4dd","type": "http in","z": "bad1ea5a333cb4d4","d": true,"g": "b63843cb893f8f99","name": "","url": "/delete","method": "delete","upload": false,"swaggerDoc": "","x": 140,"y": 348,"wires": [["16d491dfbd02964e"]]},{"id": "098469ab1a800fe3","type": "http response","z": "bad1ea5a333cb4d4","g": "b63843cb893f8f99","name": "","x": 862,"y": 348,"wires": []},{"id": "04955bf65de9fe2f","type": "function","z": "bad1ea5a333cb4d4","g": "b63843cb893f8f99","name": "Generate dummy data","func": "const firstNames = [\"Liam\",\"Noah\",\"Oliver\",\"William\",\"Elijah\",\"James\",\"Benjamin\",\"Lucas\",\"Mason\",\"Ethan\",\"Alexander\",\"Henry\",\"Jacob\",\"Michael\",\"Daniel\",\"Logan\",\"Jackson\",\"Sebastian\",\"Jack\",\"Aiden\"];\r\nconst sirNames = [\"Jones\",\"Taylor\",\"Williams\",\"Brown\",\"White\",\"Harris\",\"Martin\",\"Davies\",\"Wilson\",\"Cooper\",\"Evans\",\"King\",\"Thomas\",\"Baker\",\"Green\",\"Wright\",\"Johnson\",\"Edwards\",\"Clark\",\"Roberts\",\"Robinson\",\"Hall\",\"Lewis\",\"Young\",\"Davis\",\"Turner\",\"Hill\",\"Phillips\",\"Collins\",\"Allen\",\"Moore\",\"Thompson\",\"Carter\",\"James\",\"Knight\",\"Walker\",\"Wood\",\"Hughes\",\"Parker\",\"Ward\",\"Bennett\",\"Cook\",\"Webb\",\"Bailey\",\"Scott\",\"Jackson\",\"Lee\",\"Cox\"]; \r\nvar database = [];\r\nfor(let i = 1; i <= 30; i++) { var item = {\"id\":i, \"timestamp\":Date.now()}; item.foreName = randomFirstname(); item.sirName = randomSirname(); item.userID = \"U\" + randomInt(1000, 2999); item.age = randomInt(20, 65); database.push(item);}\r\nfunction randomFirstname() { return firstNames[randomInt(0, firstNames.length-1)];}\r\nfunction randomSirname() { return sirNames[randomInt(0, sirNames.length-1)];}\r\nfunction randomInt(min, max) { return Math.floor(Math.random() * (max - min + 1) + min);}\r\nflow.set(\"database\", database);\r\nmsg.payload = database;\r\nreturn msg;","outputs": 1,"noerr": 0,"initialize": "","finalize": "","libs": [],"x": 360,"y": 80,"wires": [["8cea908331c72a07"]]},{"id": "6445eb497e758dcc","type": "inject","z": "bad1ea5a333cb4d4","d": true,"g": "b63843cb893f8f99","name": "","props": [{"p": "payload"},{"p": "topic","vt": "str"}],"repeat": "","crontab": "","once": false,"onceDelay": 0.1,"topic": "","payload": "","payloadType": "date","x": 95,"y": 80,"wires": [["04955bf65de9fe2f"]],"l": false},{"id": "55b62a42ae2ad47c","type": "function","z": "bad1ea5a333cb4d4","g": "b63843cb893f8f99","name": "update-query","func": "\r\nvar database = flow.get(\"database\") || [];\r\nvar item = database.find(e => e.id == msg.payload.id );\r\nif(msg.payload.foreName == \"\" || msg.payload.sirName == \"\" || msg.payload.userID == \"\") { msg.statusCode = 400; msg.payload = null; return msg;}\r\nif(item) { item.foreName = msg.payload.foreName; item.sirName = msg.payload.sirName; item.age = msg.payload.age; item.userID = msg.payload.userID; flow.set(\"database\", database);} else { msg.statusCode = 404;//not found msg.payload = null; return msg;}\r\nmsg.payload = item;\r\nreturn msg;","outputs": 1,"noerr": 0,"initialize": "","finalize": "","x": 322,"y": 220,"wires": [["2bb822373b452b47"]]},{"id": "849df9bee5b7e1c5","type": "function","z": "bad1ea5a333cb4d4","g": "b63843cb893f8f99","name": "insert-query","func": "var database = flow.get(\"database\") || [];\r\nvar nextID = Math.max.apply(Math, database.map(function(o) { return o.id; })) + 1;\r\nvar item = { id: nextID, timestamp: Date.now(), foreName : msg.payload.foreName, sirName : msg.payload.sirName, age : msg.payload.age, userID : msg.payload.userID,}\r\nif(item.foreName == \"\" || item.sirName == \"\" || item.userID == \"\") { msg.statusCode = 400; msg.payload = null; return msg;}\r\ndatabase.push(item);\r\nflow.set(\"database\", database);\r\nmsg.payload = item;\r\nreturn msg;","outputs": 1,"noerr": 0,"initialize": "","finalize": "","x": 322,"y": 284,"wires": [["577d77dde821fe0e"]]},{"id": "16d491dfbd02964e","type": "function","z": "bad1ea5a333cb4d4","g": "b63843cb893f8f99","name": "delete-query","func": "\r\nvar database = flow.get(\"database\") || [];\r\ndatabase = database.filter(function( obj ) { return obj.id != msg.payload.id;});\r\nflow.set(\"database\", database);\r\nmsg.payload = database;\r\nreturn msg;","outputs": 1,"noerr": 0,"initialize": "","finalize": "","x": 322,"y": 348,"wires": [["098469ab1a800fe3"]]},{"id": "70a0e93542650b1f","type": "function","z": "bad1ea5a333cb4d4","g": "b63843cb893f8f99","name": "get database","func": "\r\nvar database = flow.get(\"database\") || [];\r\nmsg.payload = database;\r\nreturn msg;","outputs": 1,"noerr": 0,"initialize": "","finalize": "","x": 322,"y": 156,"wires": [["7aea695d8fc1488c"]]},{"id": "7aea695d8fc1488c","type": "json","z": "bad1ea5a333cb4d4","g": "b63843cb893f8f99","name": "","x": 478,"y": 156,"wires": [["ad333172fb04b7e2"]]},{"id": "8cea908331c72a07","type": "mongodb2 in","z": "bad1ea5a333cb4d4","g": "b63843cb893f8f99","service": "_ext_","configNode": "f6c122ad.621c98","name": "","collection": "LicencePlate","operation": "insert","x": 640,"y": 80,"wires": [[]]}] |
