技术新人，从搭建node.js(koa2)+MySQL开始！

2023-10-19 14:24:14

一、前期准备

1. 安装Node.js

首先，你需要安装Node.js。Node.js是一个运行时环境，它允许你在计算机上运行JavaScript代码。你可以从Node.js官网下载并安装Node.js。

2. 安装Koa2

Koa2是一个web框架，它可以帮助你快速构建web应用。你可以使用npm来安装Koa2：

npm install koa2

3. 安装MySQL

MySQL是一个关系型数据库，它可以帮助你存储和管理数据。你可以从MySQL官网下载并安装MySQL。

4. 安装MySQL驱动

MySQL驱动是一个Node.js模块，它可以帮助你连接和操作MySQL数据库。你可以使用npm来安装MySQL驱动：

npm install mysql

二、搭建node.js(koa2)+MySQL项目

1. 创建项目目录

首先，你需要创建一个项目目录，并在此目录下创建两个文件：app.js和db.js。app.js将作为项目的主文件，db.js将作为数据库操作的文件。

2. 编写app.js文件

在app.js文件中，你需要导入Koa2和MySQL驱动，并创建一个Koa2实例：

const Koa = require('koa2');
const mysql = require('mysql');

const app = new Koa();

接下来，你需要配置MySQL数据库的连接信息，并创建一个数据库连接池：

const pool = mysql.createPool({
  host: 'localhost',
  user: 'root',
  password: '123456',
  database: 'test'
});

然后，你需要定义一个中间件来处理数据库查询：

app.use(async (ctx, next) => {
  const connection = await pool.getConnection();
  ctx.state.connection = connection;
  await next();
  connection.release();
});

最后，你需要定义路由来处理HTTP请求：

app.get('/', async (ctx) => {
  const connection = ctx.state.connection;
  const results = await connection.query('SELECT * FROM users');
  ctx.body = results;
});

3. 编写db.js文件

在db.js文件中，你需要定义一些数据库操作函数，比如查询、插入、更新和删除数据。

const pool = mysql.createPool({
  host: 'localhost',
  user: 'root',
  password: '123456',
  database: 'test'
});

exports.query = async (sql, params) => {
  const connection = await pool.getConnection();
  const results = await connection.query(sql, params);
  connection.release();
  return results;
};

exports.insert = async (table, data) => {
  const connection = await pool.getConnection();
  const result = await connection.query(`INSERT INTO ${table} SET ?`, data);
  connection.release();
  return result;
};

exports.update = async (table, data, where) => {
  const connection = await pool.getConnection();
  const result = await connection.query(`UPDATE ${table} SET ? WHERE ?`, [data, where]);
  connection.release();
  return result;
};

exports.delete = async (table, where) => {
  const connection = await pool.getConnection();
  const result = await connection.query(`DELETE FROM ${table} WHERE ?`, where);
  connection.release();
  return result;
};