Node.js数据库查询数据undefined问题深度解析与异步处理实践

function fetchDataAsync() {
    setTimeout(() => {
        const data = [1, 2, 3];
        console.log("异步操作完成，数据：", data);
        return data; // 这里的return只对setTimeout内部有效
    }, 1000);
}

const result = fetchDataAsync();
console.log("fetchDataAsync的返回值：", result); // 输出：fetchDataAsync的返回值： undefined
// 1秒后，输出：异步操作完成，数据： [1, 2, 3]

// themod.js
module.exports = {
   getData: () => {
      let dbc = require('./mods/db.js');
      dbc.query(`SELECT 1 rn, 'One' rt UNION SELECT 2 rn, 'Two' rt UNION SELECT 3 rn, 'Three' rt ;`,
         function (err, rows) {
            if (err) {
              console.log ( ' Error 1: ' , err );
            } else {
               arows =  module.exports.getSubData(); // 问题所在：getSubData() 同步返回 undefined
               console.log ( 'arows.length: ', arows.length ); // 尝试访问 undefined 的 length 属性
            }
          })
   },

   getSubData: () => {
         let dbc = require('./mods/db.js');
         dbc.query(`SELECT 10 rn, 'Ten' rt UNION SELECT 20 rn, 'Twenty' rt UNION SELECT 30 rn, 'Thirty' rt ;`,
         function (err, rows) {
            if (err) {
              console.log ( ' Error 3: ' , err );
            } else {
               console.log ( 'arows: ', rows.length );
               return( rows ); // 这里的 return 只返回给 dbc.query 的内部机制，不影响 getSubData 的返回值
            }
          })
   }
}

// mods/db.js
var mysql = require('mysql');

var dbConn = mysql.createConnection({
   host     : 'localhost',
   user     : 'unam',
   password : 'pwrd',
   database : 'dbname'
});

dbConn.connect ( function(err) {
   if (err) {
      console.error( "DB Connect failed ", err);
   } else {
      console.log("数据库连接成功！");
   }
});

module.exports = dbConn;

// themod.js (使用回调函数改进)
module.exports = {
   // getData现在也需要一个回调函数来处理最终结果
   getData: (callback) => {
      let dbc = require('./mods/db.js');
      dbc.query(`SELECT 1 rn, 'One' rt UNION SELECT 2 rn, 'Two' rt UNION SELECT 3 rn, 'Three' rt ;`,
         function (err, rows1) {
            if (err) {
              console.log ( ' Error 1: ' , err );
              return callback(err); // 传递错误
            } else {
               // 调用 getSubData，并传入一个回调函数来接收其结果
               module.exports.getSubData((err, rows2) => {
                   if (err) {
                       console.log ( ' Error 2: ' , err );
                       return callback(err); // 传递错误
                   }
                   console.log ( 'rows1.length: ', rows1.length );
                   console.log ( 'rows2.length: ', rows2.length );
                   // 可以在这里处理 rows1 和 rows2
                   // 最后通过 getData 的回调函数返回最终结果
                   callback(null, { mainData: rows1, subData: rows2 });
               });
            }
          })
   },

   // getSubData 接受一个回调函数作为参数
   getSubData: (callback) => {
         let dbc = require('./mods/db.js');
         dbc.query(`SELECT 10 rn, 'Ten' rt UNION SELECT 20 rn, 'Twenty' rt UNION SELECT 30 rn, 'Thirty' rt ;`,
         function (err, rows) {
            if (err) {
              console.log ( ' Error 3: ' , err );
              return callback(err); // 发生错误时调用回调并传递错误
            } else {
               console.log ( 'getSubData 内部 rows.length: ', rows.length );
               return callback(null, rows); // 成功时调用回调并传递数据
            }
          })
   }
};

// theapp.js (使用回调函数改进)
let tm = require('./themod.js');

tm.getData((err, data) => {
    if (err) {
        console.error("获取数据失败:", err);
    } else {
        console.log("成功获取所有数据:");
        console.log("主数据:", data.mainData.length);
        console.log("子数据:", data.subData.length);
    }
});

// themod.js (使用 Promise 改进)
const util = require('util');
const dbc = require('./mods/db.js');

// 将 dbc.query 方法 Promise 化
dbc.query = util.promisify(dbc.query);

module.exports = {
   getData: () => {
      // getData 返回一个 Promise
      return dbc.query(`SELECT 1 rn, 'One' rt UNION SELECT 2 rn, 'Two' rt UNION SELECT 3 rn, 'Three' rt ;`)
         .then(rows1 => {
             // 第一个查询成功后，链式调用 getSubData
             return module.exports.getSubData()
                 .then(rows2 => {
                     console.log ( 'rows1.length: ', rows1.length );
                     console.log ( 'rows2.length: ', rows2.length );
                     return { mainData: rows1, subData: rows2 }; // 返回合并结果
                 });
         })
         .catch(err => {
             console.log ( ' Error in getData: ' , err );
             throw err; // 抛出错误，以便外部捕获
         });
   },

   getSubData: () => {
         // getSubData 直接返回一个 Promise
         return dbc.query(`SELECT 10 rn, 'Ten' rt UNION SELECT 20 rn, 'Twenty' rt UNION SELECT 30 rn, 'Thirty' rt ;`)
            .then(rows => {
               console.log ( 'getSubData 内部 rows.length: ', rows.length );
               return rows; // 返回查询结果
            })
            .catch(err => {
               console.log ( ' Error in getSubData: ' , err );
               throw err; // 抛出错误
            });
   }
};

// theapp.js (使用 Promise 改进)
let tm = require('./themod.js');

tm.getData()
    .then(