.forEach()를 사용하여 여러 모음을 삽입하는 방법 및 존재 여부 확인

Question

.forEach()을 사용하여 여러 사용자 세부 정보를 내 Mongodb 데이터베이스에 삽입하고 싶습니다. 레코드를 삽입하기 전에 사용자 레코드가 존재하는지 확인하고 싶습니다. 사용자가 존재하지 않으면 새로운 사용자 레코드를 삽입하십시오. 그렇지 않으면 기존 사용자 레코드를 업데이트하십시오.

다음은 배열에서, 자사의 확인에만 첫 번째 개체를이 코드를 실행하고 내 DB에 삽입 할 때

var dataArray=[ 
     {"id":"1","name":"abc","email":"abc@gmail.com"}, 
     {"id":"2","name":"xyz","email":"xyz@gmail.com"}, 
     {"id":"1","name":"abc","email":"abc@gmail.com"}, 
     ]; 

dataArray.forEach(function(dataVar){ 

//check record exist or not 

User.findOne({id:dataVar.id},function(err,user){ 
    if(!user){// Insert If user not exist 
     var userSchema=new User({ 
      id:dataVar.id, 
      name:dataVar.name, 
      email:dataVar.email 
     }); 
     userSchema.save(function(err,result){ 
     console.log('New Record Inserted');  
     }) 
    }else{ // Update records if user exist 
     User.update({id:dateVar.id},{email:dataVar.email},function(err,result){ 
     console.log('Record Updated');;  
     }); 
    } 
}) 
}); 

입니다. 그러나 다음 번에 세 번째 객체가 실행될 때 새 레코드와 같은 검사 및 삽입이 수행되지 않습니다.

나는 무슨 일이 일어나지 않을거야.

해결 방법을 알려주십시오.

감사합니다.

Answer 1

당신은

참조 비동기 루프를 수행해야합니다 https://caolan.github.io/async/docs.html#eachOfSeries

예제 코드

var dataArray = [{ 
    "id": "1", 
    "name": "abc", 
    "email": "abc@gmail.com" 
}, { 
    "id": "2", 
    "name": "xyz", 
    "email": "xyz@gmail.com" 
}, { 
    "id": "1", 
    "name": "abc", 
    "email": "abc@gmail.com" 
}, ]; 

async.eachOfSeries(dataArray, function(dataVar, key, callback) { 
    User.findOne({ 
     id: dataVar.id 
    }, function(err, user) { 
     if (!user) { // Insert If user not exist 
      var userSchema = new User({ 
       id: dataVar.id, 
       name: dataVar.name, 
       email: dataVar.email 
      }); 
      userSchema.save(function(err, result) { 
       console.log('New Record Inserted'); 
       callback(); 
      }) 
     } else { // Update records if user exist 
      User.update({ 
       id: dateVar.id 
      }, { 
       email: dataVar.email 
      }, function(err, result) { 
       console.log('Record Updated');; 
       callback(); 
      }); 
     } 
    }) 
}, function(err) { 
    if (err) console.error(err.message); 
    // configs is now a map of JSON data 
    console.log("All done") 
});