node.js对于数据库MySQL基本操作实例总结【增删改查】

下面是 “node.js对于数据库MySQL基本操作实例总结【增删改查】” 的完整攻略。

一、前置知识

在学习本文之前，需要掌握以下知识点：

Node.js 基础知识
MySQL数据库基础知识
Node.js连接MySQL的方法

二、环境搭建

在 node.js 项目中使用 MySQL，需要使用到 node.js 驱动程序。本文中我们使用 mysql 驱动，可通过 npm 安装。

在命令行窗口中输入以下命令进行安装：

npm install mysql --save

三、实现增删改查

连接数据库

在使用 mysql 驱动之前，需要先连接到数据库。连接过程包括配置数据库连接信息和创建数据库连接。代码如下：

const mysql = require('mysql');
const connection = mysql.createConnection({
  host: 'localhost',     //主机名
  port: 3306,            //端口号
  user: 'root',          //用户名
  password: '123456',    //密码
  database: 'test'       //数据库名
});

//连接数据库
connection.connect((err) => {
  if (err) {
    console.error('error connecting: ' + err.stack);
    return;
  }
  console.log('connected as id ' + connection.threadId);
});

插入数据

使用 SQL 语句插入一条数据，使用 mysql 驱动的 query() 方法即可。代码如下：

connection.query('insert into user set ?', { name: 'Tom', age: 18 }, (error, results, fields) => {
  if (error) throw error;
  console.log('插入成功');
  console.log(results);
});

查询数据

使用 SQL 语句查询数据，查询结果作为回调函数的第二个参数返回。代码如下：

connection.query('select * from user', (error, results, fields) => {
  if (error) throw error;
  console.log('查询结果为：');
  console.log(results);
});

更新数据

使用 SQL 语句更新一条数据，使用 mysql 驱动的 query() 方法即可。代码如下：

connection.query('update user set age=? where name=?', [20, 'Tom'], (error, results, fields) => {
  if (error) throw error;
  console.log('更新成功');
  console.log(results);
});

删除数据

使用 SQL 语句删除一条数据，使用 mysql 驱动的 query() 方法即可。代码如下：

connection.query('delete from user where name=?', ['Tom'], (error, results, fields) => {
  if (error) throw error;
  console.log('删除成功');
  console.log(results);
});

四、示例说明

示例一

假设我们有一个名为 users 的表，包含以下字段：

id：主键，自增长
name：姓名，不唯一
age：年龄，整型

我们可以使用以下代码创建表：

CREATE TABLE `users` (
  `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
  `name` varchar(255) DEFAULT NULL,
  `age` int(11) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

然后我们可以使用以下代码插入一条数据并查询：

connection.query('insert into users set ?', { name: 'Tom', age: 18 }, (error, results, fields) => {
  if (error) throw error;
  console.log('插入成功');
  console.log(results);
});

connection.query('select * from users', (error, results, fields) => {
  if (error) throw error;
  console.log('查询结果为：');
  console.log(results);
});

示例二

假设我们现在要实现一个简单的博客系统，需要实现文章的增删改查。我们可以使用以下代码创建文章表：

CREATE TABLE `articles` (
  `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
  `title` varchar(255) NOT NULL,
  `content` text NOT NULL,
  `created_at` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
  `updated_at` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

然后我们可以使用以下代码实现文章的增删改查：

// 插入文章
connection.query('insert into articles set ?', { title: 'Hello World!', content: '这是我的第一篇博客' }, (error, results, fields) => {
  if (error) throw error;
  console.log('插入成功');
  console.log(results);
});

// 查询文章
connection.query('select * from articles', (error, results, fields) => {
  if (error) throw error;
  console.log('查询结果为：');
  console.log(results);
});

// 更新文章
connection.query('update articles set title=?, content=? where id=?', ['Hello Node.js!', '这是我的第一篇 Node.js 博客', 1], (error, results, fields) => {
  if (error) throw error;
  console.log('更新成功');
  console.log(results);
});

// 删除文章
connection.query('delete from articles where id=?', [1], (error, results, fields) => {
  if (error) throw error;
  console.log('删除成功');
  console.log(results);
});