使用Node.js构建具有多个查询的JSON

Building JSON with Node.js with multiple queries

本文关键字：查询 JSON Node js 构建 使用      更新时间：2023-09-26

我刚刚开始使用node.js进行编码，我知道node.js是异步的，但不知道如何处理这个问题。

我正在查询mysql并构建一个JSON，如下所示，

var mysql = require('mysql');
var connection = mysql.createConnection({
    host : 'localhost',
    user : 'root',
    password : 'root',
    port : '3306',
    database : 'tango_prod'
});
connection.connect();
var postsJSON = { };
var arr = new Array();
connection.query('SELECT * FROM posts LIMIT 100', function(err, rows) {
    for(i=0; i < rows.length; i++){
        var post_obj = {};
        var post = rows[i];
        post_obj.id = post.id
        post_obj.actor = build_actor(post.author_id); 
        arr.push(post_obj);
    }
    console.log(JSON.stringify(arr));
});
function build_actor(actor_id){
    connection.query('SELECT * FROM people WHERE id ='+actor_id+';', function(err, actor) {
        connection.query('SELECT * FROM users WHERE id ='+actor.owner_id+';', function(err, user) {
          var actor_obj = {};
          actor_obj.id = user.id;
          actor_obj.name = user.name;
          actor_obj.email = user.email;
          return actor_obj
        });
    });
}
connection.end();

我得到JSON输出，稍后调用build_actor函数。我必须在构建actor对象之后才能获得JSON。

您必须使用回调异步执行：

connection.query('SELECT * FROM posts LIMIT 100', function(err, rows) {
    for(i=0; i < rows.length; i++){
        build_actor(post.author_id, function(actor){
            var post_obj = {};
            var post = rows[i];
            post_obj.id = post.id
            post_obj.actor = actor;
            arr.push(post_obj);
            if(arr.length === rows.length)
                 console.log(JSON.stringify(arr));
        });
    }
});
function build_actor(actor_id, callback){
    connection.query('SELECT * FROM people WHERE id ='+actor_id+';', function(err, actor) {
        connection.query('SELECT * FROM users WHERE id ='+actor.owner_id+';', function(err, user) {
          var actor_obj = {};
          actor_obj.id = user.id;
          actor_obj.name = user.name;
          actor_obj.email = user.email;
          callback(actor_obj);
        });
    });
}

 var mysql = require('mysql');
 var connection = mysql.createConnection({
 host : 'localhost',
 user : 'root',
 password : 'root',
 port : '3306',
 database : 'tango_prod'
});
connection.connect();
var postsJSON = { };
var arr = new Array();
connection.query('SELECT * FROM posts LIMIT 100', function(err, rows) {
  for(i=0; i < rows.length; i++){
     var post_obj = {};
     var post = rows[i];
     post_obj.id = post.id
     build_actor(post.author_id,function(err,res){
      if(!err){
             post_obj.actor=res;
             arr.push(post_obj);   
             console.log(JSON.stringify(arr));         
        }
     }); 
}
});
function build_actor(actor_id,cb){
    connection.query('SELECT * FROM people WHERE id ='+actor_id+';', function(err, actor) {
    connection.query('SELECT * FROM users WHERE id ='+actor.owner_id+';', function(err, user) {
       var actor_obj = {};
       actor_obj.id = user.id;
       actor_obj.name = user.name;
       actor_obj.email = user.email;
       connection.end();
       cb (null,actor_obj);
    });
});
}
相关文章：