Nodejs连接mysql并实现增、删、改、查操作的方法详解

下面是“Nodejs连接mysql并实现增、删、改、查操作的方法详解”的完整攻略：

一、安装依赖

在使用 Nodejs 连接 Mysql 之前，你需要先安装 mysql 模块。在命令行中运行以下命令：

npm install mysql

二、连接数据库

首先，你需要用 mysql.createConnection 代替 mysql.createPool 来创建一个 MySQL 连接对象。代码示例如下：

const mysql = require('mysql');

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

connection.connect((error) => {
  if (error) throw error;
  console.log('Connected to MySQL server');
});

在将数据库的参数传递给 mysql.createConnection() 方法之后，你可以使用 connection.connect() 方法来尝试与数据库建立连接。

三、执行查询操作

你可以使用 connection.query() 方法来执行查询操作。以下是一个简单的示例：

connection.query('SELECT * FROM users', (error, results, fields) => {
  if (error) throw error;
  console.log('Fetched users from MySQL database: ', results);
});

在这个例子中，我们从 users 表中选择所有行并打印结果。

四、执行插入操作

你可以使用 connection.query() 方法来执行插入操作。以下是一个简单的示例：

const user = { name: 'John Doe', email: '[e-mail]' };

connection.query('INSERT INTO users SET ?', user, (error, results, fields) => {
  if (error) throw error;
  console.log('Inserted ' + results.affectedRows + ' row(s)');
});

在这个例子中，我们将一个对象插入到 users 表中，并打印插入的行数。

五、执行更新操作

你可以使用 connection.query() 方法来执行更新操作。以下是一个简单的示例：

const user = { id: 1, name: 'John Doe', email: '[e-mail]' };

connection.query('UPDATE users SET ? WHERE id=?', [user, user.id], (error, results, fields) => {
  if (error) throw error;
  console.log('Updated ' + results.changedRows + ' row(s)');
});

在这个例子中，我们更新了 users 表中 id 为 1 的用户，并打印更新的行数。

六、执行删除操作

你可以使用 connection.query() 方法来执行删除操作。以下是一个简单的示例：

connection.query('DELETE FROM users WHERE id=?', [1], (error, results, fields) => {
  if (error) throw error;
  console.log('Deleted ' + results.affectedRows + ' row(s)');
});

在这个例子中，我们删除了 users 表中 id 为 1 的用户，并打印删除的行数。

示例1：

const mysql = require('mysql');

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

connection.connect((error) => {
  if (error) throw error;
  console.log('Connected to MySQL server');

  connection.query('SELECT * FROM users', (error, results, fields) => {
    if (error) throw error;
    console.log('Fetched users from MySQL database: ', results);
  });
});

在这个示例中，我们首先建立了到 MySQL 数据库的连接，然后使用 connection.query() 方法执行查询操作。

示例2：

const mysql = require('mysql');

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

connection.connect((error) => {
  if (error) throw error;
  console.log('Connected to MySQL server');

  const user = { name: 'Jane Doe', email: '[e-mail]' };

  connection.query('INSERT INTO users SET ?', user, (error, results, fields) => {
    if (error) throw error;
    console.log('Inserted ' + results.affectedRows + ' row(s)');
  });
});

在这个示例中，我们首先建立了到 MySQL 数据库的连接，然后插入了一行数据到 users 表中，并打印插入的行数。

这就是 Nodejs 连接 mysql 并实现增、删、改、查操作的详细攻略。