sqllite.js

const sqlite3 = require('sqlite3').verbose();
let db = undefined;

function isDatabaseUndefined() {
    if (!db)
        return true;
    return false;
}
function getNowDate() {
    const d = new Date();
    return d.getFullYear() + "-" + d.getMonth() + "-" + d.getDay() + " " + d.getHours() + ":" + d.getMinutes() + ":" + d.getSeconds() + ":" + d.getMilliseconds()
}
function getDateFromString(str) {
    return new Date(str)
}
function updateString(table, sets, condition) {
    let set = []
    for (const [column, value] of Object.entries(sets)) {
        set.push(column + "=" + "'" + value + "'")
    }
    return "UPDATE " + table + " SET " + set.join(', ') + " " + condition
}
function insertString(table, insertOrder, values) {
    let order = insertOrder.map((f) => f).join(',');
    let val = values.map((v) => "'" + v + "'").join(',');
    return "INSERT INTO " + table + " (" + order + ")" + " VALUES(" + val + ");";
}
function selectString(table, fieldArray, condition) {
    const f = fieldArray.length == 0 ? "*" : fieldArray.map((f) => f).join(',');
    return "SELECT " + f + " FROM " + table + " " + condition;
}
function createTableString(name, field) {
    let t = []
    for (const [key, detail] of Object.entries(field)) {
        t.push(key + " " + detail)
    }
    return "CREATE TABLE IF NOT EXISTS " + name + "(" + t.map((f) => f).join(', ') + ");"
}
function deleteRowString(table, condition) {
    return "DELETE FROM "+table+" "+condition;
}

function _insert(table, orderArray, valueArray) {
    db.run(insertString(table, orderArray,
        valueArray));
}

module.exports.insert = (table, keyvalueArray) => {
    order = []
    vals = []
    for (const [key, value] of Object.entries(keyvalueArray)) {
        order.push(key)
        vals.push(value)
    }
    _insert(table, order, vals)
}
module.exports.select = (table, fieldArray, condition, handler) => {
    db.all(selectString(table, fieldArray, condition), [], (err, rows) => {
        handler(err, rows)
    })
}
module.exports.update = (table, sets, condition) => {
    db.run(updateString(table, sets, condition))
}
module.exports.updateOrInsert = (table, values, condition) => {
    order = []
    vals = []
    for (const [key, value] of Object.entries(values)) {
        order.push(key)
        vals.push(value)
    }
    this.select(table, ["id"], condition, (err, rows) => {
        if (err || rows == undefined || rows.length == 0) {
            _insert(table, order, vals)
        } else {
            this.update(table, values, condition)
        }
    })
}
module.exports.delete = (table, condition) => {
    if(condition == undefined || condition == "") return;
    db.run(deleteRowString(table, condition))
}
module.exports.serialize = (f) => {f()}
module.exports.initialize = () => {
    db = new sqlite3.Database(config.dbPath, (err) => {
        if (err) {
            console.log(err)
        }
        console.log("Well connected to sqlite");
    });
    db.serialize(() => {
        db.run(createTableString("Team", {
            "id": "INTEGER PRIMARY KEY AUTOINCREMENT",
            "name": "TEXT"
        }))
    })
}