MySQL 在Node.js中从回调函数中返回值的方法

阅读更多：MySQL 教程

什么是回调函数？

在Node.js中，回调函数是一种广泛使用的编程模式。它允许我们在执行某个操作完成后，将结果作为参数传递给另一个函数。在数据库操作中，回调函数用于处理数据库查询的结果。

使用MySQL模块进行数据库查询

在Node.js中，我们可以使用mysql模块来连接和操作MySQL数据库。首先，我们需要安装mysql模块：

npm install mysql

接下来，我们可以使用以下代码连接到数据库并执行查询：

const mysql = require('mysql');

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

connection.connect((error) => {
  if (error) {
    console.error('Error connecting to database:', error);
  } else {
    console.log('Connected to database');
    // 执行查询
    connection.query('SELECT * FROM users', (error, results) => {
      if (error) throw error;
      console.log(results);
      // 在这里返回结果
    });
  }
});

connection.end();

在上述代码中，我们使用mysql.createConnection方法创建了一个数据库连接，并在connection.connect方法的回调函数中执行查询。在查询的回调函数中，我们可以处理查询结果，并在需要时返回这些结果。

使用Promise解决回调地狱

回调地狱是指当我们有多个需要依赖的异步操作时，需要嵌套多个回调函数，导致代码可读性差、难以维护。为了解决这个问题，我们可以使用Promise来处理异步操作。

Promise是一个代表异步操作最终完成或失败的对象。我们可以使用Promise来封装MySQL的查询操作，并通过.then和.catch方法处理结果。以下是一个使用Promise的示例：

const mysql = require('mysql');

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

const queryPromise = (query) => {
  return new Promise((resolve, reject) => {
    connection.query(query, (error, results) => {
      if (error) reject(error);
      resolve(results);
    });
  });
};

connection.connect()
  .then(() => {
    console.log('Connected to database');
    return queryPromise('SELECT * FROM users');
  })
  .then((results) => {
    console.log(results);
    // 在这里返回结果
  })
  .catch((error) => {
    console.error('Error:', error);
  })
  .finally(() => {
    connection.end();
  });

在上述代码中，我们使用queryPromise函数封装了查询操作，并返回一个Promise对象。通过使用.then方法，我们可以依次处理每个异步操作的结果，并在最后使用.finally方法关闭数据库连接。

使用回调函数进行结果返回

虽然使用Promise可以解决回调地狱问题，但在某些情况下，我们可能仍然需要使用回调函数来处理查询结果的返回。

以下是一个使用回调函数返回查询结果的示例：

const mysql = require('mysql');

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

const queryWithCallback = (query, callback) => {
  connection.query(query, (error, results) => {
    if (error) callback(error);
    callback(null, results);
  });
};

connection.connect((error) => {
  if (error) {
    console.error('Error connecting to database:', error);
  } else {
    console.log('Connected to database');
    // 执行查询
    queryWithCallback('SELECT * FROM users', (error, results) => {
      if (error) throw error;
      console.log(results);
      // 在这里返回结果
    });
  }
});

connection.end();

在上述代码中，我们使用queryWithCallback函数