node-sqlite3/index.js at master · a-was/node-sqlite3 · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
const sqlite3 = require('sqlite3').verbose()

class SQLite3 {
    constructor(path) {
        this.db = null
        this.path = path
    }

    async open() {
        return new Promise((resolve, reject) => {
            this.db = new sqlite3.Database(this.path, function (err) {
                if (err) reject(err)
                else resolve(this.path + " opened")
            })
        })
    }

    async run(query) {
        return new Promise((resolve, reject) => {
            this.db.run(query, function (err) {
                if (err) reject(err)
                else resolve(true)
            })
        })
    }

    async get(query, params) {
        return new Promise((resolve, reject) => {
            this.db.get(query, params, function (err, row) {
                if (err) reject(err)
                else resolve(row)
            })
        })
    }

    async all(query, params) {
        return new Promise((resolve, reject) => {
            if (params == undefined) params = []

            this.db.all(query, params, function (err, rows) {
                if (err) reject(err)
                else resolve(rows)
            })
        })
    }

    async each(query, params, action) {
        return new Promise((resolve, reject) => {
            var db = this.db
            db.serialize(function () {
                db.each(query, params, function (err, row) {
                    if (err) reject(err)
                    else {
                        if (row) {
                            action(row)
                        }
                    }
                })
                resolve(true)
            })
        })
    }

    async close() {
        return new Promise((resolve, reject) => {
            this.db.close(function (err) {
                if (err) reject(err)
                else resolve(true)
            })
        })
    }
}

module.exports = SQLite3