2

私が使用しているのは：node-mysql

arrtickersは約200の値を取得しました。

arrtickersクロージャーは、値をsymに渡します。

symは各関数に値を渡します（非同期モードで実行すると、各fnは、前のfnが完了するのを待たずに独自に実行を開始します）

ここでの問題は、mysqlが複数の呼び出しを処理できないように見えることです。

events.js:48
        throw arguments[1]; // Unhandled 'error' event
                       ^
Error: reconnection attempt failed before connection was fully set up
    at Socket.<anonymous> (/home/ubuntu/node/node_modules/mysql/lib/client.js:67:28)
    at Socket.emit (events.js:64:17)
    at TCP.onread (net.js:398:51)


        arrtickers.forEach(function(value) {

            var sym= value;


            (function(sym) {

                    url2= "http://test2.com/quote.ashx?t="+sym+"&ty=c&ta=1&p=d&b=1";

                    request({ uri:url2 }, function (error, response, body) {

                      jsdom.env({
                        html: body,
                        scripts: [
                          jqlib
                        ]
                      }, function (err, window) {

                        var $ = window.jQuery;
                        var data= $('body').html();
                        //some scrapping

                        var client2 = mysql.createClient({
                          user: 'root',
                          password: '123',
                            host: '127.0.0.1',
                            port: '3306'
                        });

                        client2.query('USE testtable');

                        sql= "update tbla SET a='"+a+"', b='"+b+"', c='"+c+"', d='"+d+"' where ticker='"+sym+"'";

                        client2.query(  
                             sql, function(err, info){

                                if (err) {  
                                  throw err;  
                                }  
                            }
                        );

                        client2.end();


                      });
                    });

            })(sym);



            (function(sym) {

                    url= "http://test3.com/quote.ashx?t="+sym+"&ty=c&ta=1&p=d&b=1";

                    request({ uri:url3 }, function (error, response, body) {

                      jsdom.env({
                        html: body,
                        scripts: [
                          jqlib
                        ]
                      }, function (err, window) {

                        var $ = window.jQuery;
                        var data= $('body').html();
                        //some scrapping

                        var client3 = mysql.createClient({
                          user: 'root',
                          password: '123',
                            host: '127.0.0.1',
                            port: '3306'
                        });

                        client3.query('USE testtable');

                        sql= "update tbla SET a='"+a+"', b='"+b+"', c='"+c+"', d='"+d+"' where ticker='"+sym+"'";

                        client3.query(  
                             sql, function(err, info){

                                if (err) {  
                                  throw err;  
                                }  
                            }
                        );

                        client3.end();


                      });
                    });

            })(sym);






            (function(sym) {

                    url= "http://test4.com/quote.ashx?t="+sym+"&ty=c&ta=1&p=d&b=1";

                    request({ uri:url4 }, function (error, response, body) {

                      jsdom.env({
                        html: body,
                        scripts: [
                          jqlib
                        ]
                      }, function (err, window) {

                        var $ = window.jQuery;
                        var data= $('body').html();
                        //some scrapping

                        var client4 = mysql.createClient({
                          user: 'root',
                          password: '123',
                            host: '127.0.0.1',
                            port: '3306'
                        });

                        client4.query('USE testtable');

                        sql= "update tbla SET a='"+a+"', b='"+b+"', c='"+c+"', d='"+d+"' where ticker='"+sym+"'";

                        client4.query(  
                             sql, function(err, info){

                                if (err) {  
                                  throw err;  
                                }  
                            }
                        );

                        client4.end();


                      });
                    });

            })(sym);



            //same function repeat for test5.com, test6.com, test7.com, test8.com, test9.com



        });

以下はclient.js（node-mysqlの一部）のコードの一部です。プロセス全体がどのようにリンクされているのかよくわかりません。

Client.prototype._connect = function() {
  this.destroy();

  var socket = this._socket = new Socket();
  var parser = this._parser = new Parser();
  var self = this;

  socket
    .on('error', this._connectionErrorHandler())
    .on('data', parser.write.bind(parser))
    .on('end', function() {
      if (self.ending) {
        // @todo destroy()?
        self.connected = false;
        self.ending = false;

        if (self._queue.length) {
          self._connect();
        }

        return;
      }

      if (!self.connected) {
        this.emit('error', new Error('reconnection attempt failed before connection was fully set up'));
        return;
      }

      self._connect();
    })
    .connect(this.port, this.host);

  parser.on('packet', this._handlePacket.bind(this));
};
4

1 に答える 1

1

現在使用しているモジュールのラッパーであるnode-mysql-queuesモジュールを使用できます。情報は次のとおりです：https ：//github.com/bminer/node-mysql-queues

彼らのページからのサンプルマルチクエリ：

var q = client.createQueue();
q.query(...); 
q.query(...);
q.execute();

client.query(...); //Will not execute until all queued queries (and their callbacks) completed.
于 2012-03-23T22:47:03.623 に答える