dt-pgsql

Changelog

 # Changelog
-## [1.2.6dev] - 2023-05-22
+## [1.2.6dev] - 2023-05-23
 ### Added
 - TRIGGER :: http trigger callback
 - PLUGIN :: do-http-callback
+- PLUGIN :: dt-pgsql
 ### Removed
 - PLUGIN :: di-gistda-air
 - PLUGIN :: di-tanpibut

plugins/dt/dt-pgsql/index.js

+var util = require('util');
+var DTPlugin = require('../dt-plugin');
+
+function DTTask(context,request){
+  DTPlugin.call(this,context,request);
+  this.name = "pgsql";
+  this.output_type = "";
+}
+util.inherits(DTTask,DTPlugin);
+
+DTTask.prototype.perform  =  require('./perform');
+
+module.exports = DTTask;

plugins/dt/dt-pgsql/package.json

+{
+  "name": "dt-pgsql",
+  "version": "1.0.0",
+  "description": "",
+  "main": "index.js",
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "author": "",
+  "license": "ISC",
+  "dependencies": {
+    "pg": "^8.5.1"
+  }
+}

plugins/dt/dt-pgsql/perform.js

+var pg = require('pg');
+
+var ctx = require('../../../context');
+var Utils = ctx.getLib('lib/util/plugin-utils');
+
+function perform_function(context,request,response){
+  var job_id = context.jobconfig.job_id;
+  var transaction_id = context.transaction.id;
+  var param = context.task.config.param || {};
+  var memstore = context.task.memstore
+
+  var output_type  = request.input_type;
+  var data = request.data;
+  var meta = request.meta || {};
+
+  var req_host = param.host || "localhost";
+  var req_port = param.port || "3306"
+  var req_user = param.user || "";
+  var req_pass = param.password || "";
+  var req_db = param.database || "";
+  var req_sql = param.sql || "";
+
+  var env = {
+    'type' : output_type,
+    'data' : data,
+    'meta' : meta
+  }
+ 
+  if(typeof data == 'string' && req_sql == ""){
+    req_sql = "${data}"
+  }
+  req_sql = Utils.vm_execute_text(env,req_sql);
+
+  //parsing param from meta
+  if(typeof meta._param == 'object')
+  {
+    var _prm = meta._param;
+    req_host = (_prm.host)?_prm.host:req_host;
+    req_port = (_prm.port)?_prm.host:req_port;
+    req_user = (_prm.user)?_prm.user:req_user;
+    req_pass = (_prm.password)?_prm.password:req_pass;
+    req_db = (_prm.database)?_prm.database:req_db;
+    req_sql = (_prm.sql)?_prm.sql:req_sql;
+  }
+
+  var conf = {
+    "host" : req_host,
+    "port" : Number(req_port),
+    "user" : req_user,
+    "password" : req_pass,
+    "database" : req_db
+  }
+
+  response.meta = meta;
+
+  pgexcute(conf,req_sql,function(err,result){
+    if(!err){
+      response.success(result,output_type);
+    }else{
+      response.error("pgsql error");
+    }
+  });
+}
+
+function pgexcute(conf,sql,callback){
+    var client = new pg.Client(conf);
+    client.connect(function(err) {
+        if(err) {
+            callback(err);
+            return console.error('could not connect to postgres', err);
+        }
+
+        client.query(sql, function(err, result) {
+            if(err) {
+                callback(err);
+		client.end();    
+                return console.error('error running query', err);
+            }
+            callback(null,result);
+            client.end();
+      	});
+    });
+}
+
+
+module.exports = perform_function;

version.json

 {
     "version":"1.2.6dev",
-    "build":"202305221600"
+    "build":"202305232200"
 }
\ No newline at end of file