在Node.js中从创建数据库到使用sqlite各项API
const sqlite3 = require('sqlite3').verbose();
// 创建或打开数据库
let db = new sqlite3.Database('./database.sqlite3', (err) => {
if (err) {
console.error(err.message);
} else {
console.log('Connected to the SQLite database.');
}
});
// 创建表
db.run(`
CREATE TABLE IF NOT EXISTS users (
id INTEGER PRIMARY KEY AUTOINCREMENT,
username TEXT NOT NULL,
email TEXT NOT NULL,
created_at TEXT NOT NULL
)
`, (err) => {
if (err) {
console.error(err.message);
} else {
console.log('Users table created.');
}
});
// 插入数据
const insertUser = (username, email, created_at) => {
db.run(`
INSERT INTO users (username, email, created_at)
VALUES (?, ?, ?)
`, [username, email, created_at], (err) => {
if (err) {
console.error(err.message);
} else {
console.log(`A row has been inserted with rowid ${this.lastID}`);
}
});
};
// 查询数据
db.all(`SELECT id, username, email FROM users`, (err, rows) => {
if (err) {
console.error(err.message);
} else {
rows.forEach((row) => {
console.log(row);
});
}
});
// 关闭数据库
db.close((err) => {
if (err) {
console.error(err.message);
} else {
console.log('Close the database connection.');
}
});
这段代码展示了如何在Node.js中使用sqlite3模块来进行数据库的基本操作,包括创建或打开数据库、创建表、插入数据、查询数据以及关闭数据库。这是学习Node.js数据库操作的一个很好的起点。
评论已关闭