使用 Koa2 和 SQLite 构建 Blog 系统

在现代 Web 应用程序开发中，建立一个 Blog 系统是一个很好的练手项目，也是一个很好地学习机会。在本文中，我们将介绍如何使用 Koa2 和 SQLite 构建一个 Blog 系统。

Koa2 简介

Koa2 是一个基于 Node.js 平台的 Web 应用程序框架。它提供了一种更简单、更直接的方式来编写 Web 应用程序，同时保持了与 Express.js 等框架相同的灵活性和功能。和 Express.js 不同的是，Koa2 使用了 ES6 的 async/await 特性，使得编写异步代码更加简单和直观。

SQLite 简介

SQLite 是一个嵌入式的关系型数据库引擎，它在一个本地文件中存储数据，并提供了 SQL 查询和事务支持。SQLite 是一个轻量级的数据库引擎，非常适合小规模应用程序，它不需要一个专门的服务器进程，而是直接在应用程序中被使用。

Blog 系统架构

我们将使用 Koa2 和 SQLite 构建一个简单的 Blog 系统，这个系统将包括以下几个部分：

• 前端页面：展示文章列表、文章详情、用户登录等页面。
• 后端 API：提供文章列表、文章详情、用户登录等 API。
• 数据库：存储文章和用户信息。

我们将使用以下技术来实现这个系统：

• Koa2：Web 应用程序框架。
• SQLite3：SQLite 的 Node.js 绑定库。
• Pug：一种模板引擎，用于渲染 HTML 页面。
• Bcrypt：一个密码哈希库，用于加密用户密码。

数据库设计

我们将使用 SQLite3 作为我们的数据库引擎。在这个 Blog 系统中，我们需要两个表格：文章表格和用户表格。

文章表格

文章表格将包含以下字段：

• id：文章的唯一标识符。
• title：文章的标题。
• content：文章的内容。
• created_at：文章的创建时间。

我们可以使用以下 SQL 语句来创建文章表格：

CREATE TABLE IF NOT EXISTS articles (
  id INTEGER PRIMARY KEY AUTOINCREMENT,
  title TEXT NOT NULL,
  content TEXT NOT NULL,
  created_at DATETIME DEFAULT CURRENT_TIMESTAMP
);

用户表格

用户表格将包含以下字段：

• id：用户的唯一标识符。
• username：用户的用户名。
• password：用户的密码的哈希值。

我们可以使用以下 SQL 语句来创建用户表格：

CREATE TABLE IF NOT EXISTS users (
  id INTEGER PRIMARY KEY AUTOINCREMENT,
  username TEXT NOT NULL UNIQUE,
  password TEXT NOT NULL
);

后端实现

安装依赖

首先，我们需要创建一个新的 Node.js 项目，并安装以下依赖：

npm install koa koa-router koa-bodyparser koa-session sqlite3 pug bcrypt

• koa：Koa2 框架。
• koa-router：路由中间件。
• koa-bodyparser：解析请求主体的中间件。
• koa-session：提供会话支持的中间件。
• sqlite3：SQLite3 的 Node.js 绑定库。
• pug：一种模板引擎，用于渲染 HTML 页面。
• bcrypt：一个密码哈希库，用于加密用户密码。

连接数据库

我们需要连接到我们的 SQLite 数据库，并创建一个数据库连接对象。在我们的项目中，我们将使用 sqlite3 模块来连接数据库。

// javascriptcn.com 代码示例
const sqlite3 = require('sqlite3').verbose();

const db = new sqlite3.Database('./blog.db', (err) => {
  if (err) {
    console.error(err.message);
    throw err;
  }
  console.log('Connected to the SQLite database.');
});

在这个例子中，我们连接到一个名为 blog.db 的 SQLite 数据库。

创建路由

我们需要创建一个路由来处理我们的 API 请求。在这个例子中，我们将使用 koa-router 模块来创建路由。

// javascriptcn.com 代码示例
const Router = require('koa-router');
const router = new Router();

router.get('/api/articles', async (ctx, next) => {
  // 处理获取文章列表的请求
});

router.get('/api/articles/:id', async (ctx, next) => {
  // 处理获取文章详情的请求
});

router.post('/api/articles', async (ctx, next) => {
  // 处理创建新文章的请求
});

router.put('/api/articles/:id', async (ctx, next) => {
  // 处理更新文章的请求
});

router.delete('/api/articles/:id', async (ctx, next) => {
  // 处理删除文章的请求
});

router.post('/api/login', async (ctx, next) => {
  // 处理用户登录请求
});

module.exports = router;

实现 API

现在我们已经设置好了路由，我们需要实现这些 API 请求。在这个例子中，我们将使用 async/await 语法来处理异步请求。

获取文章列表

router.get('/api/articles', async (ctx, next) => {
  const sql = 'SELECT id, title, created_at FROM articles ORDER BY created_at DESC;';
  const rows = await db.allAsync(sql);
  ctx.body = rows;
});

在这个例子中，我们使用 SQL 查询来获取文章列表，并将结果返回给客户端。

获取文章详情

// javascriptcn.com 代码示例
router.get('/api/articles/:id', async (ctx, next) => {
  const sql = 'SELECT * FROM articles WHERE id = ?;';
  const row = await db.getAsync(sql, [ctx.params.id]);
  if (row) {
    ctx.body = row;
  } else {
    ctx.status = 404;
    ctx.body = { message: 'Article not found.' };
  }
});

在这个例子中，我们使用 SQL 查询来获取文章详情，并将结果返回给客户端。如果文章不存在，我们将返回一个 404 错误。

创建新文章

router.post('/api/articles', async (ctx, next) => {
  const { title, content } = ctx.request.body;
  const sql = 'INSERT INTO articles (title, content) VALUES (?, ?);';
  const result = await db.runAsync(sql, [title, content]);
  ctx.body = { id: result.lastID };
});

在这个例子中，我们使用 SQL 查询来创建新文章，并将结果返回给客户端。

更新文章

// javascriptcn.com 代码示例
router.put('/api/articles/:id', async (ctx, next) => {
  const { title, content } = ctx.request.body;
  const sql = 'UPDATE articles SET title = ?, content = ? WHERE id = ?;';
  const result = await db.runAsync(sql, [title, content, ctx.params.id]);
  if (result.changes === 1) {
    ctx.body = { message: 'Article updated successfully.' };
  } else {
    ctx.status = 404;
    ctx.body = { message: 'Article not found.' };
  }
});

在这个例子中，我们使用 SQL 查询来更新文章，并将结果返回给客户端。如果文章不存在，我们将返回一个 404 错误。

删除文章

// javascriptcn.com 代码示例
router.delete('/api/articles/:id', async (ctx, next) => {
  const sql = 'DELETE FROM articles WHERE id = ?;';
  const result = await db.runAsync(sql, [ctx.params.id]);
  if (result.changes === 1) {
    ctx.body = { message: 'Article deleted successfully.' };
  } else {
    ctx.status = 404;
    ctx.body = { message: 'Article not found.' };
  }
});

在这个例子中，我们使用 SQL 查询来删除文章，并将结果返回给客户端。如果文章不存在，我们将返回一个 404 错误。

用户登录

// javascriptcn.com 代码示例
router.post('/api/login', async (ctx, next) => {
  const { username, password } = ctx.request.body;
  const sql = 'SELECT * FROM users WHERE username = ?;';
  const row = await db.getAsync(sql, [username]);
  if (row && await bcrypt.compare(password, row.password)) {
    ctx.session.user = { id: row.id, username: row.username };
    ctx.body = { message: 'Login successful.' };
  } else {
    ctx.status = 401;
    ctx.body = { message: 'Invalid username or password.' };
  }
});

在这个例子中，我们使用 SQL 查询来查找用户，并使用 bcrypt 库来比较用户输入的密码和存储在数据库中的密码哈希值。如果登录成功，我们将在会话中存储用户信息。

渲染 HTML 页面

我们需要使用一个模板引擎来渲染我们的 HTML 页面。在这个例子中，我们将使用 pug 模板引擎。

// javascriptcn.com 代码示例
const Koa = require('koa');
const Router = require('koa-router');
const bodyParser = require('koa-bodyparser');
const session = require('koa-session');
const pug = require('pug');
const bcrypt = require('bcrypt');

const app = new Koa();
const router = new Router();

// 连接数据库
const sqlite3 = require('sqlite3').verbose();
const db = new sqlite3.Database('./blog.db', (err) => {
  if (err) {
    console.error(err.message);
    throw err;
  }
  console.log('Connected to the SQLite database.');
});

// 设置模板引擎
app.context.render = async function (template, data) {
  const html = pug.renderFile(`./views/${template}.pug`, data);
  this.body = html;
};

// 设置会话支持
app.keys = ['my secret key'];
app.use(session(app));

// 设置路由
router.get('/', async (ctx, next) => {
  const sql = 'SELECT id, title, created_at FROM articles ORDER BY created_at DESC;';
  const rows = await db.allAsync(sql);
  ctx.render('index', { articles: rows, user: ctx.session.user });
});

router.get('/articles/:id', async (ctx, next) => {
  const sql = 'SELECT * FROM articles WHERE id = ?;';
  const row = await db.getAsync(sql, [ctx.params.id]);
  if (row) {
    ctx.render('article', { article: row, user: ctx.session.user });
  } else {
    ctx.throw(404, 'Article not found.');
  }
});

router.get('/login', async (ctx, next) => {
  ctx.render('login', { user: ctx.session.user });
});

router.post('/login', async (ctx, next) => {
  const { username, password } = ctx.request.body;
  const sql = 'SELECT * FROM users WHERE username = ?;';
  const row = await db.getAsync(sql, [username]);
  if (row && await bcrypt.compare(password, row.password)) {
    ctx.session.user = { id: row.id, username: row.username };
    ctx.redirect('/');
  } else {
    ctx.render('login', { user: ctx.session.user, error: 'Invalid username or password.' });
  }
});

router.get('/logout', async (ctx, next) => {
  ctx.session.user = null;
  ctx.redirect('/');
});

router.get('/new', async (ctx, next) => {
  ctx.render('new', { user: ctx.session.user });
});

router.post('/new', async (ctx, next) => {
  const { title, content } = ctx.request.body;
  const sql = 'INSERT INTO articles (title, content) VALUES (?, ?);';
  const result = await db.runAsync(sql, [title, content]);
  ctx.redirect(`/articles/${result.lastID}`);
});

// 启动应用程序
app.use(bodyParser());
app.use(router.routes());
app.use(router.allowedMethods());
app.listen(3000, () => {
  console.log('Server is listening on port 3000.');
});

在这个例子中，我们使用 pug 模板引擎来渲染我们的 HTML 页面。我们还使用了 bcrypt 库来加密用户密码。在我们的应用程序中，我们设置了一个会话，用于存储用户信息。

总结

在本文中，我们介绍了如何使用 Koa2 和 SQLite 构建一个 Blog 系统。我们使用了 Koa2 来处理 API 请求，并使用 SQLite3 来存储数据。我们还使用了 pug 模板引擎来渲染我们的 HTML 页面，并使用了 bcrypt 库来加密用户密码。这个项目可以作为一个很好的练手项目，也是一个很好的学习机会。

来源：JavaScript中文网 ，转载请注明来源 本文地址：https://www.javascriptcn.com/post/655312dcd2f5e1655dcc3412