php Mongodb 从 JSON 导出插入时"$oid is not valid for storage"错误

Question

我有一个文件，下面的数据导出与mongodb mongoexport命令:

mongoexport --db mydb --collection Users --out Users.json --jsonArray --journal

用户。json:包含

[
    {
      "_id" : { "$oid" : "53c3e81ebb593fe827040ef7" },
      "email" : "[e-mail]",
      "password" : "$2y$10$OYN9qOPa8EAU202Nsee7s.jDyT8ntHq2mBkM4wWAMxDYvARRyKmr2"
    }
]

我想导入数据没有mongoimport命令，只使用php客户端，所以我做

$fixtures = file_get_contents($fixturesPath . '/' . $fixtureFile);
$rows = json_decode($fixtures, true);
foreach ($rows as $row) {
  $this->db->Users->insert($row);
}

$row插入前的var_dump是正确的:

(
  [_id] => Array
    (
        [$oid] => 53c3e81ebb593fe827040ef7
    )
  [email] => [e-mail]
  [password] => $2y$10$OYN9qOPa8EAU202Nsee7s.jDyT8ntHq2mBkM4wWAMxDYvARRyKmr2
)

我得到以下错误:

[MongoWriteConcernException]
localhost:27017: $oid is not valid for storage.

问题是，如何从php导入这些数据?
显然，通过删除_id行它的工作，但我认为我需要这个id，所以我可以测试始终与用户id。

Answer 1

默认情况下，MongoDB使用"扩展JSON语法"标准。这是因为JSON不是"类型化"的BSON，而某些数据预计是"类型化"的，在本例中是ObjectId .

如果你在处理JSON的"扩展语法"形式那么你需要转换它:

foreach ( $rows as $row ) {
    foreach ( array_keys($row) as $key) {
        if ( $key == "_id" ) {
            $row[$key] = new MongoId( $row[$key]['$oid'] );
        }
    }
    $this->db->Users->insert( $row );
}

或类似的东西，如果你"检测"这个和其他类型，这里的循环会更实用。但基本上，您需要将这些特殊类型从JSON中的扩展表示"转换"。

Answer 2

Neil Lunn和Sammaye是正确的。他们给我指出了解决方案，并标记neil是正确的。

但是我也想在这里留下我自己的解决方案，因为你也可以有子文档，我最后写了这个递归函数来替换所有的$oid

private function replaceMongoIds(&$document, $name = false)
{
    foreach (array_keys($document) as $key) {
        if ($key == "_id" && isset($document[$key]['$oid'])) {
            $document[$key] = new MongoId($document[$key]['$oid']);
        } else if ($name && is_array($document[$key]) && isset($document[$key]['$oid'])) {
            $document[$key] = new MongoId($document[$key]['$oid']);
        } else if (is_array($document[$key]) ) {
           $this->replaceMongoIds($document[$key], $key);
        }
    }
}

现在我的代码看起来像

$fixtures = file_get_contents($fixturesPath . '/' . $fixtureFile);
$rows = json_decode($fixtures, true);
foreach ($rows as $row) {
  $this->replaceMongoIds($row);
  $this->db->Users->insert($row);
}