📜  如何使用 Node.js 更新 sqlite3 中的数据?

📅  最后修改于: 2022-05-13 01:56:12.918000             🧑  作者: Mango

如何使用 Node.js 更新 sqlite3 中的数据?

在本文中,我们将了解如何使用 node.js 更新 sqlite3 数据库中的数据。因此,为此,我们将使用 sqlite3 中可用的 run函数。此函数将帮助我们运行查询以更新数据。

SQLite 是一个独立的、高可靠性的、嵌入式的、公共领域的 SQL 数据库引擎。它是世界上使用最多的数据库引擎。让我们了解如何使用 Node.js 更新 sqlite3 数据库中的数据。

下面是分步实现:

步骤 1:使用以下命令设置项目的 NPM 包:

npm init -y

第 2 步:使用以下命令安装依赖项:

npm install express sqlite3

项目结构:如下所示。

第 3 步:在这里,我们创建了一个基本的快速服务器,在浏览器屏幕上呈现 GeeksforGeeks。

index.js
const express = require('express');
const app = express();
       
app.get('/' , (req , res)=>{
    res.send("GeeksforGeeks");
});
      
app.listen(4000 , ()=>{
    console.log("server started");
});


index.js
const express = require("express");
const app = express();
const sqlite3 = require("sqlite3");
  
// Connecting Database
let db = new sqlite3.Database(":memory:", (err) => {
    if (err) {
        console.log("Error Occured - " + err.message);
    } else {
        console.log("DataBase Connected");
    }
});
  
// Promises
const createTable = (Query) => {
    return new Promise((resolve, reject) => {
        db.run(Query, (err) => {
            if (err) {
                reject("Some Error Occured");
            }
            resolve("Table Created");
        });
    });
};
const insertData = (Query) => {
    return new Promise((resolve, reject) => {
        db.run(Query, (err) => {
            if (err) {
                reject("Some Error Occured");
            }
            resolve("Data Inserted");
        });
    });
};
const updateData = (Query) => {
    return new Promise((resolve, reject) => {
        db.run(Query, (err) => {
            if (err) {
                reject("Some Error Occured");
            }
            resolve("Data Updated");
        });
    });
};
  
// Server Running
app.listen(4000, () => {
    console.log("Server started");
      
    // Query
    var createQuery = 
"CREATE TABLE GFG ( ID NUMBER , NAME VARCHAR(100 ));";
    var insertQuery = 
'INSERT INTO GFG (ID , NAME) VALUES (1 , "GeeksforGeeks");';
    var updateQuery = 'UPDATE GFG SET NAME = "GFG"';
      
    // Running Query
    createTable(createQuery)
        .then((data) => {
            console.log(data);
            return insertData(insertQuery);
        })
        .then((data) => {
            console.log(data);
            return updateData(updateQuery);
        })
        .then((data) => {
            console.log(data);
        })
        .catch((err) => {
            console.log(err);
        });
});


第 4 步:使用以下语法将“sqlite3”导入我们的项目。 sqlite3 模块中有很多功能。

const sqlite3 = require('sqlite3');

第 5 步:现在编写一个查询以更新 sqlite3 中的数据。

/* Here GFG is table name */
var updateQuery = 'UPDATE GFG SET NAME = "Updated_Name"';

第 6 步:这里我们将使用 sqlite3 中可用的 Run 方法。

index.js

const express = require("express");
const app = express();
const sqlite3 = require("sqlite3");
  
// Connecting Database
let db = new sqlite3.Database(":memory:", (err) => {
    if (err) {
        console.log("Error Occured - " + err.message);
    } else {
        console.log("DataBase Connected");
    }
});
  
// Promises
const createTable = (Query) => {
    return new Promise((resolve, reject) => {
        db.run(Query, (err) => {
            if (err) {
                reject("Some Error Occured");
            }
            resolve("Table Created");
        });
    });
};
const insertData = (Query) => {
    return new Promise((resolve, reject) => {
        db.run(Query, (err) => {
            if (err) {
                reject("Some Error Occured");
            }
            resolve("Data Inserted");
        });
    });
};
const updateData = (Query) => {
    return new Promise((resolve, reject) => {
        db.run(Query, (err) => {
            if (err) {
                reject("Some Error Occured");
            }
            resolve("Data Updated");
        });
    });
};
  
// Server Running
app.listen(4000, () => {
    console.log("Server started");
      
    // Query
    var createQuery = 
"CREATE TABLE GFG ( ID NUMBER , NAME VARCHAR(100 ));";
    var insertQuery = 
'INSERT INTO GFG (ID , NAME) VALUES (1 , "GeeksforGeeks");';
    var updateQuery = 'UPDATE GFG SET NAME = "GFG"';
      
    // Running Query
    createTable(createQuery)
        .then((data) => {
            console.log(data);
            return insertData(insertQuery);
        })
        .then((data) => {
            console.log(data);
            return updateData(updateQuery);
        })
        .then((data) => {
            console.log(data);
        })
        .catch((err) => {
            console.log(err);
        });
});

运行服务器的步骤:从项目的根目录使用以下命令运行服务器:

node index.js

输出:

参考: https://www.npmjs.com/package/sqlite3