1. Johngo学长首页
  2. 技术点详细复盘专题
  3. 大数据

node操作本地数据库-SQLite方案

• 大数据 • 阅读 56

SQLite是一款轻量级的数据库， SQLite的第一个版本是2000年就发布了的，经过十多年的历练，显然 SQLite目前已经相当成熟。 SQLite最大的特点就是没有任何数据库服务器，无论是 C、 java、 node.js，只需要相应的驱动，就可以直接对数据库进行读写，速度是相当的快。这里我们通过 SQLite3实现对 SQLite的一些操作。 SQLite3非常小，轻量级，就几百K大小；不需要用户名，密码，直接就可以对数据库进行操作。

一、安装 SQLite3数据库

cnpm install sqlite3 --save

二、建立数据库链接

const sqlite3 = require('sqlite3').verbose(),
    DB = new sqlite3.Database('data.db', {});

// 关闭数据库链接
DB.close((err, res) => {
    if (err) {
        console.log('数据库链接关闭失败::');
        console.log(err)
        return;
    }
    console.log('数据库链接关闭成功::');
    console.log(res)
})

三、操作数据库

const CREATE_TABLE_SQL = CREATE TABLE  IF NOT EXISTS  user
    (
    id INTEGER PRIMARY KEY AUTOINCREMENT,
    name VARCHAR(64),
    age INTEGER
    );;
DB.run(CREATE_TABLE_SQL, (err, res) => {
    if (err) {
        console.log('创建表失败::');
        console.log(err)
        return;
    }
    console.log('创建表成功::');
    console.log(res)
});

3.2. 新增数据

const _user_info = {
    name: 'cuiht-' + Math.ceil(Math.random() * 100),
    age: Math.ceil(Math.random() * 100)
}, TEST_INSERT_SQL = INSERT INTO user (name, age)  VALUES('${_user_info.name}','${_user_info.age}');
DB.all(TEST_INSERT_SQL, (err, res) => {
    if (err) {
        console.log('新增数据失败::');
        console.log(err)
        return;
    }
    console.log('新增数据成功::');
    console.log(res)
});

3.3. 修改数据

const _user_info_u = {
    name: 'cuiht-' + Math.ceil(Math.random() * 100),
    age: Math.ceil(Math.random() * 100)
}, TEST_UPT_SQL = UPDATE user
    SET name = '${_user_info_u.name}', age = '${_user_info_u.age}'
    WHERE id = '2';
DB.all(TEST_UPT_SQL, (err, res) => {
    if (err) {
        console.log('修改数据失败::');
        console.log(err)
        return;
    }
    console.log('修改数据成功::');
    console.log(res)
});

3.4. 删除数据

const TEST_DEL_SQL = DELETE FROM user WHERE id = '3';
DB.all(TEST_DEL_SQL, (err, res) => {
    if (err) {
        console.log('删除数据失败::');
        console.log(err)
        return;
    }
    console.log('删除数据成功::');
    console.log(res)
});

3.5. 查询数据列表

const TEST_LIST_SQL = SELECT * FROM user ORDER BY id DESC;
DB.all(TEST_LIST_SQL, (err, res) => {
    if (err) {
        console.log('查询数据列表失败::');
        console.log(err)
        return;
    }
    console.log('查询数据列表成功::');
    console.log(res)
});

3.6. 查询数据

const TEST_GET_SQL = SELECT * FROM user WHERE id = '3';
DB.all(TEST_GET_SQL, (err, res) => {
    if (err) {
        console.log('查询数据失败::');
        console.log(err)
        return;
    }
    console.log('查询数据成功::');
    console.log(res)
});

四、 使用案例

/*
 * @Author: cuiht
 * @Date: 2022-04-22 18:31:27
 * @LastEditors: cuiht
 * @LastEditTime: 2022-04-25 17:28:13
 * @Description: 数据库链接 及 数据库操作方法封装
 */
const { ipcMain } = require('electron'),
    sqlite3 = require('sqlite3').verbose(),
    DB = new sqlite3.Database('data.db', {});

export const DBserve = (arg) => {
    return new Promise((resolve) => {
        const { tableName = '', order = '', option = {} } = arg;
        if (!tableName) {
            return resolve({
                code: 0,
                msg: '未获取数据表名！'
            })
        }
        if (!order) {
            return resolve({
                code: 0,
                msg: '未获取到指令！'
            })
        }
        switch (order) {
            case 'insert':
                const TEST_INSERT_SQL = INSERT INTO ${tableName} (name, age)  VALUES('${option.name}','${option.age}');
                DB.all(TEST_INSERT_SQL, (err, data) => {
                    if (err) {
                        return resolve({
                            code: 0,
                            msg: err
                        })
                    }
                    return resolve({
                        code: 200,
                        msg: "新增成功！",
                        data,
                    })
                });
                break;
            case 'find':
                const TEST_LIST_SQL = SELECT * FROM ${tableName} ORDER BY id DESC;
                DB.all(TEST_LIST_SQL, (err, data) => {
                    if (err) {
                        return resolve({
                            code: 0,
                            msg: err
                        })
                    }
                    return resolve({
                        code: 200,
                        msg: "查询列表成功！",
                        data,
                    })
                });
                break;
            case 'findOne':
                let findOne_str = '', findOne_i = 0;
                for (const key in option) {
                    if (findOne_i > 0) {
                        findOne_str +=  and ;
                    }
                    findOne_str += ${key} = ${option[key]};
                    findOne_i++;
                }
                const TEST_GET_SQL = SELECT * FROM ${tableName} WHERE ${findOne_str};
                DB.all(TEST_GET_SQL, (err, data) => {
                    if (err) {
                        return resolve({
                            code: 0,
                            msg: err
                        })
                    }
                    return resolve({
                        code: 200,
                        msg: "查询成功！",
                        data,
                    })
                });
                break;
            case 'update':
                if (!option.id) {
                    return resolve({
                        code: 0,
                        msg: '未获取到id'
                    })
                }
                let update_str = '', update_i = 0;
                for (const key in option) {
                    if (key!=='id') {
                        if (update_i > 0) {
                            update_str += ,;
                        }
                        update_str += ${key} = '${option[key]}';
                        update_i++;
                    }
                }
                const TEST_UPT_SQL = UPDATE ${tableName} SET ${update_str} WHERE id = ${option.id};
                DB.all(TEST_UPT_SQL, (err, data) => {
                    if (err) {
                        return resolve({
                            code: 0,
                            msg: err
                        })
                    }
                    return resolve({
                        code: 200,
                        msg: "更新成功！",
                        data,
                    })
                });
                break;
            case 'remove':
                if (!option.id) {
                    return resolve({
                        code: 0,
                        msg: '未获取到id'
                    })
                }
                const TEST_DEL_SQL = DELETE FROM ${tableName} WHERE id = ${option.id};
                DB.all(TEST_DEL_SQL, (err, data) => {
                    if (err) {
                        return resolve({
                            code: 0,
                            msg: err
                        })
                    }
                    return resolve({
                        code: 200,
                        msg: "删除成功！",
                        data,
                    })
                });
                break;
            default:
                break;
        }
    })
};

export const DBrunSql = (sql) => {
    return new Promise((resolve) => {
        if (!sql) {
            return resolve({
                code: 0,
                msg: '未获取到sql！'
            })
        }
        DB.run(sql, (err, data) => {
            if (err) {
                return resolve({
                    code: 0,
                    msg: err
                })
            }
            return resolve({
                code: 200,
                msg: 'sql执行成功!',
                data
            })
        })
    })
};

ipcMain.on('DBserve', (event, arg) => {
    DBserve(arg).then(res => {
        event.returnValue = res
    })
});
ipcMain.on('DBrunSql', (event, arg) => {
    DBrunSql(arg).then(res => {
        event.returnValue = res
    })
});

window.ipcRenderer = require("electron").ipcRenderer;

// 引入数据库入口文件
import './DB'
// ... 其他代码
async function createWindow() {
  const win = new BrowserWindow({
    // ...

    webPreferences: {
      // ...

      nodeIntegration: true,
      contextIsolation: false,
      preload: ${__static}/ipcRenderer.js
      // ...

    },
    // ...

  })
  // ...

}
// ... 其他代码

/*
 * @Author: cuiht
 * @Date: 2022-04-25 14:44:40
 * @LastEditors: cuiht
 * @LastEditTime: 2022-04-25 17:37:46
 * @Description: 调用数据库方法封装
 */

// 创建数据表
const CREATE_TABLE_SQL = CREATE TABLE  IF NOT EXISTS  users
    (
        id INTEGER PRIMARY KEY AUTOINCREMENT,
        name VARCHAR(64),
        age INTEGER
    );;
window.ipcRenderer.sendSync('DBrunSql', CREATE_TABLE_SQL)

const DBserve = ({ order = '', option = '' }) => {
    return new Promise((resolve) => {
        const res = window.ipcRenderer.sendSync('DBserve', {
            tableName: 'users',
            order,
            option
        })
        resolve(res)
    });
}

export const
    // 新增记录
    userAdd = data => DBserve({
        order: 'insert',
        option: {
            ...data,
            createTime: new Date().getTime()
        }
    }),
    // 查询记录列表
    userList = data => DBserve({
        order: 'find',
        option: data
    }),
    // 查询记录
    userGet = data => DBserve({
        order: 'findOne',
        option: data
    }),
    // 修改记录
    userUpt = data => DBserve({
        order: 'update',
        option: data
    }),
    // 删除记录
    userDel = data => DBserve({
        order: 'remove',
        option: data
    });

<!--
 * @Author: cuiht
 * @Date: 2022-04-22 18:41:07
 * @LastEditors: cuiht
 * @LastEditTime: 2022-04-25 17:39:03
 * @Description: 使用示例
-->
<template>
  <div id="text-page">
    <table class="list">
      <tr>
        <td><button @click="Add">&#x65B0;&#x589E;</button></td>
      </tr>
      <tr v-for="item in list" :key="item.id">
        <td>
          {{ item }}
        </td>
        <td style="width: 150px">
          <button @click="Upt(item)">&#x4FEE;&#x6539;</button>
          <button @click="Del(item)">&#x5220;&#x9664;</button>
          <button @click="Get(item)">&#x67E5;&#x770B;</button>
        </td>
      </tr>
    </table>
  </div>
</template>

<script>
import {
  userAdd,
  userList,
  userGet,
  userUpt,
  userDel,
} from "@/network/dataServes";
export default {
  name: "test",
  data() {
    return {
      list: [],
    };
  },
  mounted() {
    this.List();
  },
  methods: {
    Add() {
      const reqData = {
        age: this.list.length + 1,
        name: "cuiht-" + new Date().getTime(),
      };
      userAdd(reqData).then((res) => {
        console.log(res);
        if (res.code !== 200) {
          return;
        }
        this.List();
      });
    },
    List() {
      userList().then((res) => {
        console.log(res);
        if (res.code !== 200) {
          return;
        }
        this.list = res.data;
      });
    },
    Get(item) {
      userGet({
        id: item.id,
      }).then((res) => {
        console.log(res);
        if (res.code !== 200) {
          return;
        }
        alert(JSON.stringify(res.data));
      });
    },
    Upt(item) {
      const reqData = {
        id: item.id,
        age: this.list.length + 1,
        name: "undate-" + new Date().getTime(),
      };
      userUpt(reqData).then((res) => {
        console.log(res);
        if (res.code !== 200) {
          return;
        }
        this.List();
      });
    },
    Del(item) {
      userDel({
        id: item.id,
      }).then((res) => {
        console.log(res);
        if (res.code !== 200) {
          return;
        }
        this.List();
      });
    },
  },
};
</script>

<style lang="scss">
#text-page {
  width: 100vw;
  height: 100vh;
  position: fixed;
  top: 0;
  left: 0;
}
</style>

无论你将来想去哪里，想过怎样的生活，请现在就为自己蓄积能量。

Original: https://blog.csdn.net/hunter_97/article/details/124424486
Author: hunter_97
Title: node操作本地数据库-SQLite方案

原创文章受到原创版权保护。转载请注明出处：https://www.johngo689.com/815686/

转载文章受原作者版权保护。转载请注明原作者出处！

赞 (0)
0

【自取】最近整理的，有需要可以领取学习：



Linux核心资料大放送~

全栈面试题汇总（持续更新&可下载）

一个提高学习100%效率的工具！

【超详细】深度学习面试题目！

LeetCode Python刷题答案下载！

LeetCode Java版刷题答案下载！

LeetCode C++ 版本，抓紧保存！

LeetCode GO语言 刷题答案下载！

大家都在看

亲爱的 Coder【最近整理，可免费获取】👉 最新必读书单  | 👏 面试题下载  | 🌎 免费的AI知识星球