// 引入SQLite模块
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 messages (
id INTEGER PRIMARY KEY AUTOINCREMENT,
title TEXT NOT NULL,
content TEXT,
created_at DATE DEFAULT (datetime('now', 'localtime'))
)
`, (err) => {
if (err) {
console.error(err.message);
} else {
console.log('Messages table created or already exists.');
}
});
// 插入数据
const insertStatement = `
INSERT INTO messages (title, content)
VALUES (?, ?)
`;
db.run(insertStatement, ['Hello World', 'This is a message.'], (err) => {
if (err) {
console.error(err.message);
} else {
console.log('A row has been inserted.');
}
});
// 查询数据
db.all('SELECT id, title, content, created_at FROM messages', (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环境中管理数据库非常有帮助。