Node连接MySQL并封装其增删改查的实现代码

下面是针对Node连接MySQL并封装其增删改查的实现代码的完整攻略：

一、安装和配置MySQL

首先，需要在本地安装MySQL服务器，并且创建一个数据库并且一个数据表。可以用如下命令来创建一个名为mydatabase的数据库：

CREATE DATABASE mydatabase;

然后，可以用如下命令来创建一个名为customers的数据表：

CREATE TABLE customers (id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(255), email VARCHAR(255));

二、连接MySQL

接下来，需要安装并使用Node.js中的mysql包来连接至MySQL数据库。可以用如下命令来安装mysql包：

npm install mysql

然后，在Node.js代码中，可以通过以下方式来连接数据库：

const mysql = require('mysql');
const connection = mysql.createConnection({
    host: 'localhost',
    user: 'yourusername',
    password: 'yourpassword',
    database: 'mydatabase'
});

connection.connect((err) => {
    if (err) throw err;
    console.log('Connected!');
});

确保替换yourusername和yourpassword为你在MySQL中用于连接的用户名和密码。

三、封装CRUD函数

为了执行常见的增删改查操作，可以封装一些函数。

1. 查询所有数据：

function getAllCustomers() {
    const sql = "SELECT * FROM customers";
    connection.query(sql, (err, result) => {
        if (err) throw err;
        console.log(result);
    });
}

2. 根据ID查询数据：

function getCustomerById(customerId) {
    const sql = `SELECT * FROM customers WHERE id = ${customerId}`;
    connection.query(sql, (err, result) => {
        if (err) throw err;
        console.log(result);
    });
}

3. 插入一条数据：

function addCustomer(name, email) {
    const sql = `INSERT INTO customers (name, email) VALUES ('${name}', '${email}')`;
    connection.query(sql, (err, result) => {
        if (err) throw err;
        console.log('Customer added successfully!');
    });
}

4. 根据ID更新数据：

function updateCustomer(customerId, name, email) {
    const sql = `UPDATE customers SET name='${name}', email='${email}' WHERE id=${customerId}`;
    connection.query(sql, (err, result) => {
        if (err) throw err;
        console.log('Customer updated successfully!');
    });
}

5. 根据ID删除数据：

function deleteCustomer(customerId) {
    const sql = `DELETE FROM customers WHERE id = ${customerId}`;
    connection.query(sql, (err, result) => {
        if (err) throw err;
        console.log('Customer deleted successfully!');
    });
}

注意：上面的这几个函数的代码中使用了ES6的字符串模板，以便插入变量。

四、示例说明

示例一：查询所有数据

下面是查询所有数据的示例代码和执行结果：

function getAllCustomers() {
    const sql = "SELECT * FROM customers";
    connection.query(sql, (err, result) => {
        if (err) throw err;
        console.log(result);
    });
}

getAllCustomers();

执行结果：

[
  { id: 1, name: 'John', email: 'john@example.com' },
  { id: 2, name: 'Peter', email: 'peter@example.com' },
  { id: 3, name: 'Amy', email: 'amy@example.com' },
  { id: 4, name: 'Hannah', email: 'hannah@example.com' },
  { id: 5, name: 'Michael', email: 'michael@example.com' }
]

示例二：插入一条数据

下面是插入一条数据的示例代码和执行结果：

function addCustomer(name, email) {
    const sql = `INSERT INTO customers (name, email) VALUES ('${name}', '${email}')`;
    connection.query(sql, (err, result) => {
        if (err) throw err;
        console.log('Customer added successfully!');
    });
}

addCustomer('David', 'david@example.com');