better-sqlite3是一个高性能、易于使用的SQLite3库，它提供了一个同步的API，比异步API更快。它支持完整的事务，高效、安全的操作，并支持用户自定义的函数、聚合和扩展。下面提供一些实用例子。

如果您使用的是node-sqlite3，并且进行过简单的封装，理论上可以无缝切换。

node-sqlite3例子：nodejs中使用sqlite3数据库

安装

// 安装
cnpm install better-sqlite3 --save
// 安装ts提示
cnpm install @types/better-sqlite3 --save

better-sqlite3 DB类

以下代码例子中包含node-sqlite3的版本，代码已注释。

// db.better-sqlite3.ts
import { Config } from './../ini/config';

import database, { Database } from 'better-sqlite3';
// sqlite3 引入
// import sqlite3, { Database } from 'sqlite3'

let db: Database = null as any;
const databaseOptions = {
    // verbose: console.log
};
export class DBBetterSqlite3 {

    constructor(callBack: (error: Error | null) => void) {
        if (db) {
            setTimeout(() => { callBack(null) });
            return this;
        }

        db = new database(Config.dbName, databaseOptions);
        setTimeout(() => { callBack(null) });

        // 方式1：sqlite3例子
        // db = new sqlite3.Database(Config.dbName, (err) => {
        //     callBack(this.error(err, '数据库链接失败！'));
        // });
        return this;
    }

    /** 查询 */
    select(selectSql: string, callBack: (err: Error | null, rows: any[]) => void) {
        const select_stmt = db.prepare(selectSql);
        callBack(null, select_stmt.all());

        // 方式1：sqlite3例子
        // 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, datas: any[] | null, callback: (error: Error | null) => void) {
        db.transaction(() => {
            const stmt = db.prepare(sql);
            if (datas && datas.length) {
                stmt.run(...datas);
            }
            else {
                stmt.run();
            }
        })();
        callback && callback(null);


        // 方式1：sqlite3例子
        // const resOperate = (err: Error) => {
        //     callback(this.error(err, 'Sql执行错误！'));
        // }
        // datas ? db.run(sql, datas, resOperate) : db.run(sql, resOperate);
    }

    /**
     * 批量插入
     * @param sql sql语句 insert into
     * @param data 参数
     * @param callback 回调函数
     */
    insertDatas(sql: string, datas: any[] | null, callback: (error: Error | null) => void) {
        db.transaction(() => {
            const stmt = db.prepare(sql);
            if (datas && datas.length) {
                datas.map(data => stmt.run(...data));
            }
            else {
                stmt.run();
            }
        })();
        callback && callback(null);
    }

    /**
     * 错误处理
     * @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(null);

        // 方式1：sqlite3例子
        //db && db.close(callBack);
    }
}

应用

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

const db = new DBBetterSqlite3(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.insertDatas("insert into user (name, pass) values (?, ?)",[
        ['admin1', btoa('0123456')],
        ['admin2', 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.'), 'admin1'], 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('暂无数据！');
        console.log(JSON.stringify(datas));
        
        callback && callback();
    })
}

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