Node.js数据存储新法宝：MySQL接入指南

2023-12-15 04:25:34

MySQL：Node.js 数据存储的利器

构建 Node.js 应用时，数据存储至关重要。然而，使用传统方法（如文件系统或内存）存储数据常常会遭遇效率低、安全性差等问题。此时，我们需要一款更强大、更可靠的数据存储解决方案。

MySQL，一款开源且功能强大的关系型数据库管理系统，以其高效、安全和可扩展性著称，成为 Node.js 数据存储的理想选择。

搭建 MySQL 环境

要使用 MySQL，首先需要搭建一个 MySQL 环境。有两种简单的方法：

1. 安装 MySQL 本地服务器：

brew install mysql@5.7  # MacOS
sudo apt-get install mysql-server  # Ubuntu

2. 使用云数据库服务：

直接在云平台（如阿里云、腾讯云等）上创建 MySQL 实例，更省时省力。

建库建表

安装好 MySQL 后，就可以创建数据库和数据表了。数据库就好比一个仓库，而数据表则是仓库中的货架。每个货架都有自己的名称和结构，用于存放特定类型的数据。

Express 接入 MySQL

Express 是一个流行的 Node.js 框架，可以帮助我们轻松实现各种 Web 应用。为了让 Express 与 MySQL 连接，我们需要安装一些必要的工具：

npm install mysql2

接下来，我们在 Express 中导入这些工具，并编写代码来完成与 MySQL 的连接：

const mysql = require('mysql2');
const connection = mysql.createConnection({
  host: 'localhost',
  user: 'root',
  password: 'password',
  database: 'my_database'
});

これで、ExpressとMySQLの接続が完了しました！

数据操作：CRUD 轻松玩转

CRUD 是数据存储的四大基本操作：Create（创建）、Retrieve（检索）、Update（更新）、Delete（删除）。掌握了这四项操作，我们就能对 MySQL 中的数据进行全面管理。

1. 创建数据：

connection.query('INSERT INTO users (name, email) VALUES (?, ?)', ['John Doe', 'john@doe.com'], (err, result) => {
  if (err) throw err;
  console.log('New user created with ID:', result.insertId);
});

2. 检索数据：

connection.query('SELECT * FROM users', (err, rows) => {
  if (err) throw err;
  console.log('All users:', rows);
});

3. 更新数据：

connection.query('UPDATE users SET name = ? WHERE id = ?', ['Jane Doe', 1], (err, result) => {
  if (err) throw err;
  console.log('User updated:', result.affectedRows);
});

4. 删除数据：

connection.query('DELETE FROM users WHERE id = ?', [1], (err, result) => {
  if (err) throw err;
  console.log('User deleted:', result.affectedRows);
});

小试牛刀：获取用户数据

为了巩固我们的学习成果，我们来实现一个小小的 DEMO：获取所有用户信息。

const express = require('express');
const app = express();
const mysql = require('mysql2');

const connection = mysql.createConnection({
  host: 'localhost',
  user: 'root',
  password: 'password',
  database: 'my_database'
});

app.get('/users', (req, res) => {
  connection.query('SELECT * FROM users', (err, rows) => {
    if (err) throw err;
    res.json(rows);
  });
});

app.listen(3000);