Mysql-nodejs 嵌套查询

Question

它说无法读取 socket.broadcast 行中的属性authorid undefined。

setInterval(function(){
    db.query("select * from `notifications`", function(err, rows){
        if (rows.length>temp){

            for (var i=temp; i<rows.length; i++){
                console.log('sending room post', rows[i].authorid);
                db.query("select `name` from `users` where `id`=?", [rows[i].authorid ], function(err, name){
                    name=name[0].name;
                    socket.broadcast.to(rows[i].authorid).emit('new notification', {
                        authorname:name,
                        dpid:rows[i].followid,
                        read:rows[i].read,
                        type:rows[i].type,
                        followstatus:1
                    }); 
                });


            }
            temp=rows.length;
        }
    })
}, 3000);

Answer 1

问题是i的值在使用socket的时候是rows.length。

您可以通过创建将当前行发送到的函数或发送index 并使用rows[index] 来解决此问题：

setInterval(function() {
    db.query("select * from `notifications`", function(err, rows) {

        // You access the values of the current row
        // row.authorid
        // ...
        var broadcast = function(row) {
            console.log('sending room post', row.authorid);
            db.query("select `name` from `users` where `id`=?", [row.authorid], function(err, name) {
                name=name[0].name;
                socket.broadcast.to(row.authorid).emit('new notification', {
                    authorname:   name,
                    dpid:         row.followid,
                    read:         row.read,
                    type:         row.type,
                    followstatus: 1
                }); 
            });
        };

        if (rows.length>temp) {
            for (var i=temp; i<rows.length; i++) {
                broadcast(rows[i]);
            }
            temp=rows.length;
        }
    })
}, 3000);