查询内的for循环

Question

我在 mongo 中有这个：

//fill QueryString
collection.find({"myID" : {$in:QueryString} },{}).toArray(function(err, Stuff) { 
... 
var flag = true;
for (var i=0; i<Stuff.length; i++) {

    //if statements .. alter flag
    // if Stuff[i].myField....
}

if (req.body.type == "myField") {

collection.update(
  { "my_id" : req.body.id },
  {$set : { "myField" : req.body.fileid }}, 
  function(err, result) {
  ....

 }

我在 postgresql 中做到了这一点：

pg.connect(conString, function(err, client, done) {

        if (err) return console.error('error fetching client from pool', err);

        client.query( "SELECT * FROM mytable WHERE my_id = ANY ($1::varchar[])  ",[QueryString], function(err,Stuff) {


            var flag = true;
            for (var i=0; i<Stuff.rows.length; i++) {
             ...
            //if statements .. alter flag
            if (typeof(Stuff.rows[i].myField) === 'undefined' || ( (typeof(Stuff.rows[i].myField) !== 'undefined' && Stuff.rows[i].myField.length < 16 ) )) {

              if (req.body.my_ids[i] === req.body.id && req.body.type === "myField") {

              }else{
                flag = false;
              }
          }
            debug('flag:'+flag);              

}//end of for loop



 if (req.body.type === "anotherField") {

        client.query("UPDATE mytable  SET anotherField ='req.body.fileid' WHERE my_id = 'req.body.id'",  function(err, result)  {
    ....

    });//endof update

done();
});//end of first query

但是，for 循环在 postgres 中没有按预期工作。 我不确定如何在查询中使用 for 循环。

问题是每个循环的标志都是假的，但它应该是真的。

=============== 使用 pg-promise ============================ =======

 dbPromise.tx(function (t) {
    return t.any("SELECT * FROM mytable WHERE my_id = ANY  ($1::varchar[]) ",[QueryString])
        .then(function (Stuff) {


        var flag = true;
        for (var i = 0; i < Stuff.length; i++) {

        ...//if statements
        if (typeof(Stuff[i].myField === ....) 
        ...
        } //end of for loop

           var queries = Stuff.map(function (d) {

        if (req.body.type === "myField") {

              return t.none("UPDATE mytable  SET myField ='req.body.fileid' WHERE my_id = 'req.body.id'")

              debug("success: "+req.body.id);
              res.send({ user : req.user, message : "SUCCESS", my_id : req.body.id});     


      } else if (req.body.type === "anotherField") {
        ....
        }

        });
      return t.batch(queries);

})
    }) 
.then(function (Stuff) {
      //this is executed for every single update ,right?
         console.log("Hurrah!");
})
.catch(function (error) {

            console.log("ERROR:", error.message || error);
});

使用这种方法，我仍然处于最初的问题中。 该标志是 false 而不是 true （关于 mongo ）。

最后，我不确定Stuff.map(function (d)，关于d。我应该改用myField吗？如果我有很多像我一样的字段？

Answer 1

为了完成您的示例，您应该使用一个事务进行多次更新，以保持数据完整性。

这就是使用pg-promise 完成整个事情的方式，使用事务：

db.tx(function (t) {
    return t.any("SELECT * FROM myTable WHERE my_id = ...", [params])
        .then(function (data) {
            var queries = data.map(function (d) {
                if (/*need to update*/) {
                    // do any checks or manipulations for 'd';
                    return t.none("UPDATE myTable SET ...", [params])
                }
            });
            return t.batch(queries);
        })
})
    .then(function (data) {
        // all updates were successful;
        console.log("Hurrah!");
    })
    .catch(function (error) {
        // something failed;
        console.log("ERROR:", error.message || error);
    });