mongo find() ,IN の検証

join_2.js

//
// mongo finc() ,IN の検証
var ObjectID = require('mongodb').ObjectID;
const MongoClient = require('mongodb').MongoClient;

//
function join_test3(){
    var URL = "mongodb://localhost:27017";
    MongoClient.connect(URL, (err, client) => {
        var db = client.db("db1");
        db.collection("book_groups").find(
            {
                _id: {$in : [
                    ObjectID("5fd2bcca775662a47e0ba4f8"),
                    ObjectID("5fd2bcca775662a47e0ba4f9"),
                    ]
                }                
                /*
                _id: {$in : [
                    ObjectID("5fd1aa099618af7020ab6044"),
                    ObjectID("5fd1a5b4e746f86e8c8bb248"),
                    ]
                }                
                */
            }            
        ).toArray().then((docs) => {
                console.log(docs);
        })
        .catch((err) => {
            console.log(err);
        })
        .then(() => {
            client.close();
        });
    });
}
function convert_oid(items){
    var ret = []
    items.forEach(function(item){
        ret.push( ObjectID( item ) )
    });
    return ret;
}

//
async function join_test4(){
    var items = []
    items.push("5fd1aa099618af7020ab6044")
    items.push("5fd1a5b4e746f86e8c8bb248")
    var oid_items= convert_oid( items );
console.log(oid_items)
//return;
    let client = await MongoClient.connect( "mongodb://localhost:27017" );
    const db = client.db("db1");
    await db.collection("bread_orders").find(
        {
            _id: {$in : oid_items }                
        }            
    ).toArray().then((docs) => {
            console.log(docs);
    })
    .catch((err) => {
        console.log(err);
    })
    .then(() => {
        client.close();
    });    

}
// main
join_test3();