NodeJS与Mysql的交互示例代码

下面我就来详细讲解NodeJS与Mysql的交互示例代码的完整攻略。

前置知识

在学习NodeJS与Mysql的交互之前，需要先掌握以下知识：

• NodeJS基础知识：包括NodeJS的安装、常用API、事件循环等知识。
• Mysql基础知识：包括Mysql的安装、数据库创建、数据表创建等知识。
• Mysql NodeJS驱动模块：NodeJS可以使用第三方模块来与Mysql进行交互，常用的模块有mysql、mysql2、mysqljs/mysql等。

示例代码

下面是一个使用mysql模块进行Mysql交互的示例代码，该代码实现了一个简单的查询操作：

安装依赖

首先，需要安装mysql模块：

npm install mysql

建立连接

接着，需要使用mysql.createConnection()方法来建立与Mysql的连接，并指定连接的参数和回调函数。下面是一个建立连接的示例代码：

const mysql = require('mysql');

// 连接Mysql
const connection = mysql.createConnection({
  host     : 'localhost',  // 主机名
  user     : 'user',       // 用户名
  password : 'password',   // 密码
  database : 'database'    // 数据库名
});

// 连接错误回调函数
connection.connect(function(err) {
  if (err) {
    console.error('连接Mysql失败: ' + err.stack);
    return;
  }
  console.log('连接Mysql成功');
});

执行查询

连接成功后，就可以使用connection.query()方法来执行查询操作。下面是一个查询指定表中所有数据的示例代码：

const mysql = require('mysql');

// 连接Mysql
const connection = mysql.createConnection({
  host     : 'localhost',  // 主机名
  user     : 'user',       // 用户名
  password : 'password',   // 密码
  database : 'database'    // 数据库名
});

// 查询user表中所有数据
connection.query('SELECT * FROM user', function (error, results, fields) {
  if (error) throw error;
  console.log('查询结果: ', results);
});

断开连接

操作完成后，需要使用connection.end()方法来断开与Mysql的连接。下面是一个断开连接的示例代码：

const mysql = require('mysql');

// 连接Mysql
const connection = mysql.createConnection({
  host     : 'localhost',  // 主机名
  user     : 'user',       // 用户名
  password : 'password',   // 密码
  database : 'database'    // 数据库名
});

// 查询user表中所有数据
connection.query('SELECT * FROM user', function (error, results, fields) {
  if (error) throw error;
  console.log('查询结果: ', results);

  // 断开Mysql连接
  connection.end(function(err) {
    if (err) {
      console.error('断开Mysql连接失败: ' + err.stack);
      return;
    }
    console.log('断开Mysql连接成功');
  });
});

示例说明

示例1：插入数据

下面是一个使用mysql模块进行Mysql交互的示例代码，该代码实现了将数据插入到指定表中的操作：

const mysql = require('mysql');

// 连接Mysql
const connection = mysql.createConnection({
  host     : 'localhost',  // 主机名
  user     : 'user',       // 用户名
  password : 'password',   // 密码
  database : 'database'    // 数据库名
});

// 插入数据到user表中
const postData = {
  name: '张三',
  age: 18,
  gender: '男',
};
connection.query('INSERT INTO user SET ?', postData, function (error, results, fields) {
  if (error) throw error;
  console.log('插入数据成功');
});

// 断开Mysql连接
connection.end(function(err) {
  if (err) {
    console.error('断开Mysql连接失败: ' + err.stack);
    return;
  }
  console.log('断开Mysql连接成功');
});

示例2：更新数据

下面是一个使用mysql模块进行Mysql交互的示例代码，该代码实现了将指定表中的数据进行更新的操作：

const mysql = require('mysql');

// 连接Mysql
const connection = mysql.createConnection({
  host     : 'localhost',  // 主机名
  user     : 'user',       // 用户名
  password : 'password',   // 密码
  database : 'database'    // 数据库名
});

// 更新user表中的数据
const updateData = {
  name: '李四',
  age: 20,
  gender: '女',
};
connection.query('UPDATE user SET ? WHERE id = ?', [updateData, 1], function (error, results, fields) {
  if (error) throw error;
  console.log('更新数据成功');
});

// 断开Mysql连接
connection.end(function(err) {
  if (err) {
    console.error('断开Mysql连接失败: ' + err.stack);
    return;
  }
  console.log('断开Mysql连接成功');
});

在这个示例代码中，我们使用UPDATE语句更新了user表中id为1的数据。更新的数据为name='李四'，age=20，gender='女'。更新成功后，我们断开了与Mysql的连接。

以上两个示例仅用于演示操作，具体的场景中，需要根据实际需求来编写代码。