SQLite快速上手

Full-Stack-python / 2023-08-28 / 原文

安装sqlite3

使用 npm 安装 sqlite3，执行如下命令：

$ npm i sqlite3 --save

连接数据库

引入依赖

const sqlite3 = require('sqlite3').verbose()

引入 sqlite3 模块后，执行了 verbose 函数。 verbose 函数用于将执行模式设置为输出调用堆栈，也就是说，如果代码出错，将会定位到具体的代码执行函数，而不仅仅只是提示错误信息，方便我们调试代码。

初始化数据库

var db = new sqlite3.Database(
    './user.db', 
    sqlite3.OPEN_READWRITE, 
    function (err) {
        if (err) {
            return console.log(err.message)
        }
        console.log('connect database successfully')
    }
)

第 1 行，使用 Database 函数，初始化数据库对象 db；第 2 行，配置数据存储的文件路径为 user.db ；第 3 行，指定数据库操作模式为读写模式。得到一个数据库对象 db 后，接下来我们进行建表操作。

run方法

sqlite3 模块提供了一个执行 sql 语句的方法 run。有了这个方法，我们可以很简单地执行对应的 sql 语句，实现除了*查询*操作之外的*建表*、插入、更新及删除操作。那查询用什么方法呢？别急，接下来会介绍到。

在操作数据库之前，有必要先介绍 run 方法如何使用。 run 接收三个参数，分别是，sql、value 和 callback。语法糖如下：

run(sql, value, callback)

其中，sql 表示需要执行的语句，value 表示 sql 语句中需要替换的值，callback 则是执行后的回调函数。具体的例子，可以接着看下面的介绍。

建表

我们建立一张表，命名为user：

    db.run('CREATE TABLE user(name text)', function (err) {
        if (err) {
            return console.log(err)

        }
        console.log('create table user')
    })

建表没有存储数据的操作，因此不必传入 value。

数据操作

插入

sqlite 表示插入的 sql 语句为： INSERT INTO table_name(column_name) VALUES(value) 。对应的，可以写出以下代码：

    db.run('INSERT INTO user(name) VALUES(?)', ['Alice'], function (err) {
        if (err) {
            return console.log('insert data error: ', err.message)
        }
        console.log('insert data: ', this)
    })

第 1 行，run 方法的第二参数 value，主要用于替换 sql 语句的 ? 符号; 第 5 行，callback 中的 this 关键字，存储了插入数据的信息。结构为： Statement {sql: ‘sql语句’, lastID: id, changes: changesNum }

查询

查询数据，我们使用另一个方法：all。all 方法表示查询所有数据，除此之外，sqlite3 还提供了`其他查询方式`。

    db.all('SELECT name FROM user WHERE name = ?', ['Alice'], function (err, rows) {
        if (err) {
            return console.log('find Alice error: ', err.message)
        }

        console.log('find Alice: ', rows)
    })

第 1 行，all 同 run 方法一样，接收三个参数：sql、value、callback，用法也同 run 方法一样，不再详述；第 6 行，callback 除了 err 参数，还有 rows 参数，表示插入后的数据。

更新

将 name 的值，由 Alice 改为 Alin：

    db.run(
        'UPDATE user SET name = ? WHERE name = ?', 
        ['Alin', 'Alice'], 
        function (err) {
            if (err) {
                return console.log('update data error: ', err.message)
            }
            console.log('update data: ', this)
        }
    )

第 2 行，更新的 sql 语句中，出现了两个 ? 符号，因此对应的，可以看到 value 数组也传入了两个数据。

验证下是否成功将 Alice 改为 Alin：

    db.all('SELECT * FROM user', [], function (err, rows) {
        if (err) {
            return console.log('find error: ', err)
        }
        console.log('find updated data', rows)
    })

删除

将 name 值改为 Alin 后，删除 Alin 的数据：

    db.run('DELETE FROM user WHERE name = ?', ['Alin'], function (err) {
        if (err) {
            return console.log(err.message)
        }
        console.log('deleted Alin: ', this)
    })
})

关闭数据库

在做完所有操作后，使用 close 方法关闭数据库：

db.close(function (err) {
    if (err) {
        return console.log(err.message)
    }
    console.log('close database connection')
})

运行demo

ok，至此我们知道了数据库从连接、建表、操作数据到关闭的过程，先来运行下 demo：

$ node demo.js

终端输出如下：

connect database successfully
find error:  { [Error: SQLITE_ERROR: no such table: user] errno: 1, code: 'SQLITE_ERROR' }
SQLITE_ERROR: no such table: user
update data error:  SQLITE_ERROR: no such table: user
insert data error:  SQLITE_ERROR: no such table: user
create table user
find Alice:  undefined
close database connection

咦？这结果不对，报错了。仔细看下结果，发现，插入、更新、建表等操作都乱了顺序执行。建表前进行查询、更新等操作，当然会报 no such table 错误。现在知道问题了，是因为操作没有顺序执行，怎么解决呢？ sqlite3 提供了 serialize 方法，顾名思义，指定操作串行执行。使用如下：

// 引入依赖
const sqlite3 = require('sqlite3').verbose()
// 初始化数据库
var db = new sqlite.Database(...)
db.serialize(function() {
// 建表
db.run('CREATE ...')
// 插入数据
db.run('INSERT ...')
// 查询数据
db.all('SELECT ...')
// 更新数据
db.run('UPDATE ...')
// 删除数据
db.run('DELETE ...')
})

// 关闭数据库
db.close(...)

以上有关数据库的操作均为伪代码，具体的可看上面几小节。

加上 serialize 方法后，我们再运行 demo，输出如下结果：

connect database successfully
create table user
insert data:  Statement {
sql: 'INSERT INTO user(name) VALUES(?)',
lastID: 1,
changes: 1 }
find Alice:  [ { name: 'Alice' } ]
update data:  Statement {
sql: 'UPDATE user SET name = ? WHERE name = ?',
lastID: 1,
changes: 1 }
find updated data [ { name: 'Alin' } ]
deleted Alin:  Statement { sql: 'DELETE FROM user WHERE name = ?', lastID: 1, changes: 1 }
close database connection

成功了！