vybe/db.js

24 lines
628 B
JavaScript

const sqlite3 = require("sqlite3");
const fs = require('fs');
const db = new sqlite3.Database('vybe.db');
db.query = function (sql, params) {
var that = this;
return new Promise(function (resolve, reject) {
that.all(sql, params, function (error, rows) {
if (error) reject(error);
else resolve({ rows: rows });
});
});
};
(async () => {
if (!fs.existsSync('vybe.db')) {
console.log(fs.readFileSync('db/1-init.sql').toString().split(';'))
for(let sql of fs.readFileSync('db/1-init.sql').toString().split(';'))
await db.query(sql);
}
})();
module.exports = db;