table name parameter issue

Author: Gunasekar-K

src/api/migrateifxpg.js

@@ -33,9 +33,9 @@ async function migrateifxinsertdata(payload, client) {
       usepkforcond = await dbcommonfunction.ivalidatetousepkcondition(columnNames, payload, datapk)
     }
     if (usepkforcond == 0) {
-      conditionstr = await dbcommonfunction.insertretrivalcondition_withoutpk(columnNames, payload, datatypeobj)
+      conditionstr = await dbcommonfunction.insertretrivalcondition_withoutpk(columnNames, payload, datatypeobj,tablename)
     } else {
-      conditionstr = await dbcommonfunction.insertretrivalcondition_withpk(columnNames, payload, datatypeobj, datapk)
+      conditionstr = await dbcommonfunction.insertretrivalcondition_withpk(columnNames, payload, datatypeobj, tablename, datapk)
     }
     infsql = `select * from ${tablename} where ${conditionstr};` // "insert into <schema>:<table> (col_1, col_2, ...) values (val_1, val_2, ...)"
     console.log(`informix query ${infsql}`);
@@ -93,9 +93,9 @@ async function migrateifxupdatedata(payload, client) {
     }
     //REtrival contion
     if (usepkforcond == 0) {
-      conditionstr = await dbcommonfunction.updateretrivalcondition_withoutpk(columnNames,payload,datatypeobj )
+      conditionstr = await dbcommonfunction.updateretrivalcondition_withoutpk(columnNames,payload,datatypeobj,tablename )
     } else {
-      conditionstr = await dbcommonfunction.updateretrivalcondition_withpk(columnNames,payload,datatypeobj,datapk )
+      conditionstr = await dbcommonfunction.updateretrivalcondition_withpk(columnNames,payload,datatypeobj,tablename,datapk )
     }
     //Exemption added it should always in sequence
     payload = await dbcommonfunction.uvalidateexemptiondatatype(dbname, tablename, payload);
@@ -160,9 +160,9 @@ async function migrateifxdeletedata(payload, client) {
     }
     var conditionstr = ""
     if (usepkforcond == 0) {
-      conditionstr = await dbcommonfunction.deletedatacondition_withoutpk(columnNames, payload, datatypeobj)
+      conditionstr = await dbcommonfunction.deletedatacondition_withoutpk(columnNames, payload, datatypeobj, tablename)
     } else {
-      conditionstr = await dbcommonfunction.deletedatacondition_withpk(columnNames, payload, datatypeobj, datapk)
+      conditionstr = await dbcommonfunction.deletedatacondition_withpk(columnNames, payload, datatypeobj, tablename, datapk)
     }
     sql = `SET search_path TO ${schemaname};`;
     console.log(sql);

src/api/migratepg.js

@@ -106,9 +106,9 @@ async function migratepgDelete(dbpool, payload) {
     payload = await dbcommonfunction.hextoutf_insertpayload(columnNames, datatypeobj, payload) 
     var conditionstr = ""
     if (datapk.length == 0) {
-      conditionstr = await dbcommonfunction.deletedatacondition_withoutpk(columnNames, payload, datatypeobj)
+      conditionstr = await dbcommonfunction.deletedatacondition_withoutpk(columnNames, payload, datatypeobj, tablename)
     } else {
-      conditionstr = await dbcommonfunction.deletedatacondition_withpk(columnNames, payload, datatypeobj, datapk)
+      conditionstr = await dbcommonfunction.deletedatacondition_withpk(columnNames, payload, datatypeobj, tablename, datapk)
     }
     sql = `SET search_path TO ${schemaname};`;
     console.log(sql);

src/common/dbmigratefunctions.js

@@ -98,7 +98,7 @@ async function converthextoutf(hexdata) {
         throw "converthextoutf : " + err
     }
 }
-async function updateretrivalcondition_withpk(columnNames, payload, datatypeobj, datapk) {
+async function updateretrivalcondition_withpk(columnNames, payload, datatypeobj, tablename, datapk) {
     try {
         var conditionstr = ""
         bufffernewcond = 0
@@ -126,7 +126,7 @@ async function updateretrivalcondition_withpk(columnNames, payload, datatypeobj,
     }
 
 }
-async function insertretrivalcondition_withpk(columnNames, payload, datatypeobj, datapk) {
+async function insertretrivalcondition_withpk(columnNames, payload, datatypeobj, tablename, datapk) {
     try {
 
         var conditionstr = ""
@@ -179,7 +179,7 @@ async function updatedatacondition_withpk(columnNames, payload, datatypeobj, dat
         throw "updatedatacondition_withpk : " + err
     }
 }
-async function updateretrivalcondition_withoutpk(columnNames, payload, datatypeobj) {
+async function updateretrivalcondition_withoutpk(columnNames, payload, datatypeobj, tablename) {
     try {
         var conditionstr = ""
         bufffernewcond = 0
@@ -204,7 +204,7 @@ async function updateretrivalcondition_withoutpk(columnNames, payload, datatypeo
         throw "updateretrivalcondition_withoutpk : " + err
     }
 }
-async function insertretrivalcondition_withoutpk(columnNames, payload, datatypeobj) {
+async function insertretrivalcondition_withoutpk(columnNames, payload, datatypeobj,tablename) {
     try {
         var conditionstr = ""
         bufffercond = 0
@@ -275,7 +275,7 @@ async function updatesetdatastr(columnNames, payload, datatypeobj) {
         throw "updatesetdatastr : " + err
     }
 }
-async function deletedatacondition_withoutpk(columnNames, payload, datatypeobj) {
+async function deletedatacondition_withoutpk(columnNames, payload, datatypeobj, tablename) {
     try {
         var conditionstr = ""
         bufffercond = 0
@@ -298,7 +298,7 @@ async function deletedatacondition_withoutpk(columnNames, payload, datatypeobj)
         throw "deletedatacondition_withoutpk : " + err
     }
 }
-async function deletedatacondition_withpk(columnNames, payload, datatypeobj, datapk) {
+async function deletedatacondition_withpk(columnNames, payload, datatypeobj, tablename, datapk) {
     try {
         var conditionstr = ""
         bufffercond = 0