let sqlite3 = require('sqlite3').verbose();
let { open } = require('sqlite');
let db = null;

async function openDB() {
    if (dataSet == {}) {
        console.log(dataSet);
    }
    else {
        console.log(dataSet[0]);
    };
};

exports.increaseCount = async function increaseCount(keys) {
    if (keys === {}) {
        return;
    };
    if (!db) {
        db = await open({filename: './data/codecounter.db', driver: sqlite3.Database});
    }
    let product = keys.product;
    let version = keys.version;
    let countdate = keys.countdate;
    let codekey = keys.codekey;
    let dataSet = await db.all(`SELECT * FROM counters WHERE product = '${product}' AND version = '${version}' AND countdate = '${countdate}' AND codekey = '${codekey}'`);
    let icount;
    if (dataSet.length > 0) {
        icount = dataSet[0].counter + 1;
        await db.run(`UPDATE counters SET counter = '${icount}' WHERE product = '${product}' AND version = '${version}' AND countdate = '${countdate}' AND codekey = '${codekey}'`);
    }
    else {
        icount = 1;
        await db.run(`INSERT INTO counters VALUES('${product}', '${version}', '${countdate}', '${codekey}', ${icount})`);
    }
    //db.close();
}

exports.queryData = async function queryData() {
    if (!db) {
        db = await open({filename: './data/codecounter.db', driver: sqlite3.Database});
    }
    let dataSet = await db.all(`SELECT * FROM counters`);
    return dataSet;
}

exports.closeDB = async function closeDB() {
    if (db) {
        await db.closeDB();
    }
}