diff --git a/DocService/sources/mySqlBaseConnector.js b/DocService/sources/mySqlBaseConnector.js index aa34171c..2f873ced 100644 --- a/DocService/sources/mySqlBaseConnector.js +++ b/DocService/sources/mySqlBaseConnector.js @@ -105,6 +105,10 @@ exports.upsert = function(task, opt_updateUserIndex) { let p10 = addSqlParam(JSON.stringify(task.callback), values); sqlCommand += `, callback = CONCAT(callback , '${sqlBase.UserCallback.prototype.delimiter}{"userIndex":' , (user_index + 1) , ',"callback":', ${p10}, '}')`; } + if (task.baseurl) { + let p11 = addSqlParam(task.baseurl, values); + sqlCommand += `, baseurl = ${p11}`; + } if (opt_updateUserIndex) { sqlCommand += ', user_index = LAST_INSERT_ID(user_index + 1)'; } diff --git a/DocService/sources/postgreSqlBaseConnector.js b/DocService/sources/postgreSqlBaseConnector.js index 824b6526..8c361665 100644 --- a/DocService/sources/postgreSqlBaseConnector.js +++ b/DocService/sources/postgreSqlBaseConnector.js @@ -125,6 +125,10 @@ function getUpsertString(task, values) { sqlCommand += `, callback = task_result.callback || '${sqlBase.UserCallback.prototype.delimiter}{"userIndex":' `; sqlCommand += ` || (task_result.user_index + 1)::text || ',"callback":' || ${p10}::text || '}'`; } + if (task.baseurl) { + let p11 = addSqlParam(task.baseurl, values); + sqlCommand += `, baseurl = ${p11}`; + } sqlCommand += ", user_index = task_result.user_index + 1 RETURNING user_index as userindex;"; return sqlCommand; } else {