electron中使用本地数据库的方法详解

sql/index.js // 这是连接数据库文件
sql/db.js // 这是创建db表格文件
sql/sql-api // 这是接口文件

const sqlite3 = require('sqlite3').verbose()
let db;
// 连接数据库
export default function conDb() {
  const os = require('os');
  const homedir = os.homedir(); // 用于获取当前用户的主目录路径
  const users = homedir.replace(/\\/g,'\\\\'); // 替换绝对和相对路径
  if (!db || !db.open) {
    db = new sqlite3.Database(users+'\\sql.db'); // 保存地址文件
  };
  return db;
}

import conDb from './index';
let db;
export function init () {
    db = conDb();
    return new Promise((resolve,reject) => {
        db.serialize(() => {
            // 测试数据库
            db.run(`create table if not exists test (
                id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL,
                buyerType varchar(64) DEFAULT '1',
                tel int,
                cookie varchar(2000),
                uin varchar(1000) DEFAULT null,
                uid varchar(1000) DEFAULT null,
                createdTimer int
            )`);
            resolve();
        })
    })
}

import { init } from '@/sql/db';
init();

import conDb from "../index";
export default {
    /**
     * 增加数据
     * @param {*} param0 
     * @returns 
     */
    addTest({type = 1, tel, cookie, uin}) {
        let db = conDb();
        let createdTimer = new Date().getTime();
        return new Promise((resolve, reject) => {
            let sql = `INSERT INTO test (type, tel, cookie, createdTimer, uin) `;
            sql += `values ("${type}", "${tel}", "${cookie}", "${createdTimer}", "${uin}")`;
            let inquire = `select * from test where tel = "${tel}"`;
            db.all(inquire,(err,list) => { // 查询用户
                if (err) {
                    reject({code:400,msg:err,data:[]});
                }else {
                    if (list.length) { // 有用户
                        resolve({code:201,msg:'已有该用户',data:list})
                    }else { // 没有用户
                        db.all(sql,(error,data) => {
                            if (error) {
                              reject({code:400,msg:error});
                            } else {
                              resolve({code:200,msg:'成功',data});
                            }
                        });
                    }
                }
            })
        })
    }
}

testApi.addTest({
    type:1,
    tel:'177****1111',
    cookie:'dsjadljsakldjsakldjkaslfklaj',
})
.then(res=>{
console.log(res);
})

    getTest({page = 1,pageSize = 10,tel = ''}) {
        let db = conDb();
        // 获取total语法
        let totalSql = `select count(*) total from test`;
        let total = 0;
        return new Promise((resolve, reject) => {
            // 统计总数
            db.all(totalSql,(err,totalData)=>{
                if(err) {reject({code:200,msg:err,data:'总计条数错误'})};
                total = totalData[0].total;
            });
            // 实现分页语法
            let sql = `select * from test`;
            if (tel) {
                sql += ` where tel = "${tel}"`;
            };
            sql += ` limit ${(page - 1) * pageSize},${pageSize}`;
            db.all(sql,(error,data) => {
                if (error) {
                  reject({code:400,msg:error});
                } else {
                  resolve({code:200,msg:'成功',data});
                }
            });
        })
    }

testApi.getTest({page:1})
      .then(res=>{
        console.log(res);
      })

delTest({id = 1}) {
        let sql = `DELETE FROM test WHERE id = ${id}`;
        let weightSql = `select * from test where id = ${id}`;
        return new Promise((resolve, reject) => {
            let db = conDb();
            db.all(weightSql,(err,list)=>{
                    if (err) {
                        reject({code:400,msg:err,data:[]});
                    } else {
                    if (list.length) {
                        db.all(sql,(error,data) => {
                        if (error) {
                            reject({code:400,msg:error});
                        } else {
                            resolve({code:200,msg:'删除成功',data:list});
                        }
                        });
                    }else {
                        resolve({code:400,msg:`买家号不存在`});
                    }
                }
            });
        })
    }

testApi.delTest({id:1})
      .then(res=>{
        console.log(res);
      })