// 导入所需模块
const express = require('express');
const sqlite3 = require('sqlite3').verbose();
const bodyParser = require('body-parser');
// 创建SQLite数据库和相关表
const db = new sqlite3.Database('./print.db');
db.run(`CREATE TABLE IF NOT EXISTS prints (
id INTEGER PRIMARY KEY AUTOINCREMENT,
name TEXT,
file TEXT,
status TEXT
)`);
// 创建Express应用
const app = express();
app.use(bodyParser.json());
// 添加打印任务的API接口
app.post('/print', (req, res) => {
const { name, file } = req.body;
const status = 'waiting';
db.run(`INSERT INTO prints (name, file, status) VALUES (?, ?, ?)`, [name, file, status], function(err) {
if (err) {
return res.status(500).json({ error: err.message });
}
res.json({ message: 'Print job added successfully', id: this.lastID });
});
});
// 获取打印任务状态的API接口
app.get('/print/:id', (req, res) => {
const id = Number(req.params.id);
db.get(`SELECT * FROM prints WHERE id = ?`, [id], (err, print) => {
if (err) {
return res.status(500).json({ error: err.message });
}
if (!print) {
return res.status(404).json({ error: 'Print job not found' });
}
res.json(print);
});
});
// 启动服务器
const PORT = 3000;
app.listen(PORT, () => {
console.log(`Server running on port ${PORT}`);
});
这段代码创建了一个简单的Express服务器，用于处理添加打印任务和检索打印任务状态的HTTP请求。它使用了SQLite数据库和相应的node-sqlite3模块来存储打印任务信息。这个例子展示了如何使用Node.js和Express构建一个基本的Web服务，并且如何与SQLite数据库交互。