SQLite，是一款轻型的数据库，是遵守ACID的关系型数据库管理系统，SQLite第一个Alpha版本诞生于2000年5月。 至2021年已经接近有21个年头，SQLite也迎来了一个版本 SQLite 3已经发布。

我们通过一个简单的例子，来了解nodejs如何创建sqlite3数据库，以及创建表、插入、修改、查询等操作。

我感觉我在头条写开源项目，不足之处欢迎交流。[捂脸]

安装

npm i sqlite3 --save

DB类

DB类包含了基本操作，可以根据实际情况做出修改。

// db.sqlite3.ts
import { Config } from './../ini/config';
import sqlite3, { Database } from 'sqlite3'
let db: Database = null as any;
export class DBSqlite3 {

    constructor(callBack: (error: Error | null) => void) {
        if (db) {
            setTimeout(() => { callBack(null) });
            return this;
        }
        db = new sqlite3.Database(Config.dbName, (err) => {
            callBack(this.error(err, '数据库链接失败！'));
        });
        return this;
    }

    /** 查询 */
    select(selectSql: string, callBack: (err: Error | null, rows: any[]) => void) {
        db.all(selectSql, (err, rows) => {
            callBack(this.error(err, '查询失败！'), rows);
        });
    }

    /**
     * 执行SQL
     * @param sql sql语句 create table | insert into
     * @param data 参数
     * @param callback 回调函数
     */
    excuteSql(sql: string, data: any, callback: (error: Error | null) => void) {
        const resOperate = (err: Error) => {
            callback(this.error(err, 'Sql执行错误！'));
        }
        data ? db.run(sql, data, resOperate) : db.run(sql, resOperate);;
    }

    /**
     * 错误处理
     * @param err 数据库错误消息
     * @param message 返回消息
     * @returns 
     */
    error(err: Error | null, message: string) {
        const error: any = err ? { message } : null;
        if (err) {
            // ... 记录日志
        }
        return error;
    }

    /**关闭链接 */
    close(callBack: (error: Error | null) => void) {
        db || callBack(null);
        db && db.close(callBack);
    }
}

应用

// app.ts
import { DBSqlite3 } from "./db/db.sqlite3";

const db = new DBSqlite3(err => {
    err || console.log('数据库链接成功！');
    err && console.log(err);
    createTables(() => {
        insertData(() => {
            selectData(() => {
                updateData(() => {
                    selectData();
                });
            });
        });
    })
});

/** 创建表 */
const createTables = (callback: () => void) => {
    db.excuteSql('create table if not exists user (name text, pass text) ', null, err => {
        err || console.log('创建user表成功！');
        if (err) return;
        callback();
    });
}

/** 创建视图 */
const createView = () => {
    db.excuteSql('create view if not exists v_user AS select * from user ', null, (err) => { })
}

/** 插入数据 */
const insertData = (callback: () => void) => {
    db.excuteSql("insert into user (name, pass) values (?, ?)", ['admin', btoa('0123456')], err => {
        err || console.log('插入数据成功！');
        if (err) return;
        callback();
    });
}

/** 修改数据 */
const updateData = (callback: () => void) => {
    db.excuteSql("update user set name=?, pass=? where name=?", ['007', btoa('007.'), 'admin'], err => {
        err || console.log('修改数据成功！');
        if (err) return;
        callback();
    });
}

// 查询数据
const selectData = (callback?: () => void) => {
    db.select('select * from user', (err, datas: IUser[]) => {
        const len = datas?.length || 0;
        len || console.log('暂无数据！');
        let { name, pass } = datas[0];
        len && console.log('user：', name, pass);
        callback && callback();
    })
}

人人为我，我为人人，欢迎您的浏览，我们一起加油吧。