CODEWITHSUNDEEP
node.js
Alex
Alex

Reputation: 4473

Passing arguments through predefined function in Node.js

I'm struggling with passing data concept in Node.js. Let's take SQL tedious as example. Here is code from examples:

//acquire a connection
pool.acquire(function poolAcquire(err, connection) {
    if (err) { console.error(err); return; }

    //use the connection as normal
    var request = new Request('select 1;select 2;select 3', function requestCallback (err, rowCount) {
        if (err) { console.error(err); return;}

        console.log('rowCount: ' + rowCount);

        //release the connection back to the pool when finished
        connection.release();
    });

    request.on('row', function onRequestRow(columns) {
        console.log('value: ' + columns[0].value);
    });

    connection.execSql(request);
});

pool.acguire takes function as the argument and this function has particular signature (err,connection)

My question is - how do I pass SQL statement inside this function? I cannot change signature because different function signature is not called.

Also I cannot use global scope because variable may be changed outside.

In other words I need to find way to bypass wrappers calls and still pass some data.

Something like 

var mySQLs = ['select 1;select 2;select 3','select 4;select 5;'];
async.forEach(mySQLs,WorkWithOneItem, AllIsDone);

function WorkWithOneItem(item, callback){
    pool.acquire(?????(item));
    callback(); // tell async that the iterator has completed
} 

function AllIsDone (err) {
    console.log('All done');
}

Upvotes: 0

Views: 29

Answers (2)

dvlsg
dvlsg

Reputation: 5538

Do you need the results out as well?

var mySQLs = ['select 1;select 2;select 3','select 4;select 5;'];
async.forEach(mySQLs, WorkWithOneItem, AllIsDone);

function WorkWithOneItem(sql, callback){
  pool.acquire(function poolAcquire(err, connection) {
      if (err) return callback(err);

      //use the connection as normal
      var request = new Request(sql, function requestCallback (err, rowCount) {
          if (err) return callback(err);

          console.log('rowCount: ' + rowCount);

          //release the connection back to the pool when finished
          connection.release();
      });

      var rows = [];
      var count = 0;
      request.on('row', function onRequestRow(columns) {
          console.log('value: ' + columns[0].value);
          rows.push(columns[0].value); // or whatever you actually want out of these.
      });

      request.on('done', function onRequestDone() {
        callback(null, rows);
      });

      connection.execSql(request);
  });
  callback(); // tell async that the iterator has completed
} 

function AllIsDone (err) {
  console.log('All done');
  // you probably want async.map, so you can get the result back
  // as the second argument for a function like this
}

Upvotes: 1

DrakaSAN
DrakaSAN

Reputation: 7853

By wrapping it in another function:

function aquire(sql, callback) {
    pool.acquire(function poolAcquire(err, connection) {
        if (err) { console.error(err); return callback(); }

        //use the connection as normal
        var request = new Request(sql, function requestCallback (err, rowCount) {
            if (err) { console.error(err); return;}

            console.log('rowCount: ' + rowCount);

            //release the connection back to the pool when finished
            connection.release();
            callback();
        });

        request.on('row', function onRequestRow(columns) {
            console.log('value: ' + columns[0].value);
        });

        connection.execSql(request);
    });
}

function WorkWithOneItem(item, callback){
    acquire(item, () => {
        callback(); // tell async that the iterator has completed
    });
}

Upvotes: 2

Related Questions