const db = require("./db");

async function update(tblName, whereList, fieldList) {
  const params = [];
  let sql = 'UPDATE `' + tblName + '` SET ';

  fieldList.forEach((item, index) => {
    const suffix = (index + 1 < fieldList.length ? ',': '');
    sql += ' `' + item[0] + '`=?' + suffix;
    params.push(item[1]);
  });

  sql += ' WHERE 1=1';
  whereList.forEach((item, index) => {
    sql += ' AND ' + item[0] + '=?';
    params.push(item[1]);
  });

  db.execScript(sql, params);
}

async function insert(tblName, fieldList) {
  const params = [];
  let sql = 'INSERT INTO `' + tblName + '` (';

  fieldList.forEach((item, index) => {
    const suffix = (index + 1 < fieldList.length ? ',': '');
    sql += '`' + item[0] + '`' + suffix;
  });

  sql += ') VALUES (';
  fieldList.forEach((item, index) => {
    const suffix = (index + 1 < fieldList.length ? ',': '');
    sql += '?' + suffix;
    params.push(item[1]);
  });
  sql += ')';

  db.execScript(sql, params);
}

async function _delete(tblName, whereList) {
  const params = [];
  let sql = 'DELETE FROM `' + tblName + '` ';

  sql += ' WHERE 1=1';
  whereList.forEach((item, index) => {
    sql += ' AND ' + item[0] + '=?';
    params.push(item[1]);
  });

  db.execScript(sql, params);
}

exports.update = update;
exports.insert = insert;
exports._delete = _delete;