如何使用 node.js 在 sqlite3 数据库中插入和选择数据?
在本文中,我们将了解如何使用 node.js 在 sqlite3 数据库中插入和选择数据。因此,为此,我们将使用 sqlite3 中可用的 run 和 all函数。
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 Occurred - " + err.message);
}
else {
console.log("DataBase Connected");
}
})
app.get('/' , (req , res)=>{
res.send("GeeksforGeeks");
});
// 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 selectQuery = 'SELECT * FROM GFG ;'
// Running Query
db.run(createQuery , (err) => {
if(err) return;
// Success
console.log("Table Created");
db.run(insertQuery , (err) => {
if(err) return;
// Success
console.log("Insertion Done");
db.all(selectQuery , (err , data) => {
if(err) return;
// Success
console.log(data);
});
});
});
})
第 4 步:使用以下语法将“sqlite3”导入我们的项目。 sqlite3 模块中有很多功能。
const sqlite3 = require('sqlite3');
第 5 步:现在编写一个查询,用于在 sqlite3 中插入和选择数据。
/* Here GFG is table name */
var insertQuery = ‘INSERT INTO GFG (ID , NAME) VALUES (1 , “GeeksforGeeks”);’
var selectQuery = ‘SELECT * FROM GFG ;’ /* Here GFG is table name */
第 6 步:这里我们将使用 sqlite3 中可用的 Run and All 方法。
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 Occurred - " + err.message);
}
else {
console.log("DataBase Connected");
}
})
app.get('/' , (req , res)=>{
res.send("GeeksforGeeks");
});
// 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 selectQuery = 'SELECT * FROM GFG ;'
// Running Query
db.run(createQuery , (err) => {
if(err) return;
// Success
console.log("Table Created");
db.run(insertQuery , (err) => {
if(err) return;
// Success
console.log("Insertion Done");
db.all(selectQuery , (err , data) => {
if(err) return;
// Success
console.log(data);
});
});
});
})
运行服务器的步骤:从项目的根目录使用以下命令运行服务器:
node index.js
输出:
参考: https://www.npmjs.com/package/sqlite3