<?php

$pdo = new PDO("mysql:host=127.0.0.1;dbname=testdb","root","1234567");

$pdo->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);

$stmt = $pdo->query("select id,myval from dict_ifdomestic");

$wuwa = $stmt->fetchall(PDO::FETCH_ASSOC);

var_dump($wuwa);

$manager = new \MongoDB\Driver\Manager('mongodb://localhost:27017');

$writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);

for ($i=0;$i<count($wuwa);$i++)

{

    $document=['_id'=>$wuwa[$i]['id'],'myval'=>$wuwa[$i]['myval']];
    //注意：这里$bulk要不断的被实例化，否则会报错

    $bulk = new \MongoDB\Driver\BulkWrite();

    $bulk->insert($document);

    $val1 = $manager->executeBulkWrite('olddream.dict_ifdomestic',$bulk,$writeConcern);

    echo "插入的记录数:".$val1->getInsertedCount();

}

?>