Nodejs – 将 Mysql 与 Node 应用程序连接起来

简介

在 Node.js 应用程序中，连接 MySQL 数据库是一个非常普遍的操作。在本文中，我们将学习如何使用 Node.js 将 MySQL 数据库连接起来，并执行一些基本的操作。

准备工作

在开始之前，我们需要安装以下软件：

1. Node.js
2. MySQL

除此之外，我们还需要安装 mysql 模块。可以通过以下命令进行安装：

npm install mysql

连接 MySQL 数据库

在 Node.js 中，我们可以使用 mysql 模块来连接 MySQL 数据库。我们可以使用以下代码来连接数据库：

const mysql = require('mysql');

// 创建连接
const connection = mysql.createConnection({
  host: 'localhost',
  user: 'root',
  password: 'password',
  database: 'demo'
});

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

// 关闭连接
connection.end();

在上面的代码中，我们首先创建了一个连接对象，并且传入了连接数据库所需的参数。然后我们调用 connect 方法来连接数据库。如果连接成功，我们会打印出连接的线程 ID。最后，我们调用 end 方法来关闭连接。

执行基本操作

在连接 MySQL 数据库后，我们可以执行许多不同的操作，例如查询、插入、更新或删除。以下是一些基本操作的示例：

查询数据

// 查询数据
connection.query('SELECT * FROM users', (err, rows) => {
  if (err) throw err;

  console.log('Data received from Db:');
  console.log(rows);
});

在上面的代码中，我们使用 query 方法来执行一条 SQL 查询语句。在查询成功后，我们会打印出获取到的数据。

插入数据

// 插入数据
const user = { name: 'John', email: 'john@example.com' };
connection.query('INSERT INTO users SET ?', user, (err, res) => {
  if (err) throw err;

  console.log('Last insert ID:', res.insertId);
});

在上面的代码中，我们使用 query 方法来执行一条 SQL 插入语句。我们可以将数据对象作为第二个参数传递给方法。

更新数据

// 更新数据
connection.query(
  'UPDATE users SET email = ? WHERE name = ?',
  ['john2@example.com', 'John'],
  (err, res) => {
    if (err) throw err;

    console.log(`Changed ${res.changedRows} rows`);
  }
);

在上面的代码中，我们使用 query 方法来执行一条 SQL 更新语句。我们可以将需要更新的数据和更新条件作为参数传递给方法。

删除数据

// 删除数据
connection.query(
  'DELETE FROM users WHERE name = ?',
  ['John'],
  (err, res) => {
    if (err) throw err;

    console.log(`Deleted ${res.affectedRows} rows`);
  }
);

在上面的代码中，我们使用 query 方法来执行一条 SQL 删除语句。我们可以将需要删除的数据作为参数传递给方法。

结语

在本文中，我们学习了如何使用 Node.js 将 MySQL 数据库连接起来，并执行一些基本的操作。如果您想了解更多信息，请查看 MySQL 官方文档。