PHP操作MongoDB的批量数据迁移

要在PHP中执行批量数据迁移，首先需要确保已经安装了PHP的MongoDB扩展。接下来，可以使用以下步骤进行批量数据迁移：

1. 建立源数据库和目标数据库的连接
2. 选择源数据库和目标数据库的集合（表）
3. 从源集合中查询文档
4. 将查询到的文档插入到目标集合中
5. 关闭数据库连接

以下是一个简单的示例，演示如何在PHP中使用MongoDB扩展进行批量数据迁移：

<?php
// 连接源数据库
$sourceClient = new MongoDB\Client("mongodb://source_host:source_port");
$sourceDatabase = $sourceClient->selectDatabase("source_database_name");
$sourceCollection = $sourceDatabase->selectCollection("source_collection_name");

// 连接目标数据库
$targetClient = new MongoDB\Client("mongodb://target_host:target_port");
$targetDatabase = $targetClient->selectDatabase("target_database_name");
$targetCollection = $targetDatabase->selectCollection("target_collection_name");

// 查询源集合中的所有文档
$cursor = $sourceCollection->find();

// 将查询到的文档插入到目标集合中
foreach ($cursor as $document) {
    $targetCollection->insertOne($document);
}

// 关闭数据库连接
$sourceClient->close();
$targetClient->close();
?>

请注意，这个示例仅适用于较小的数据集。对于大型数据集，建议使用批量插入操作以提高性能。以下是一个使用批量插入操作的示例：

<?php
// 连接源数据库
$sourceClient = new MongoDB\Client("mongodb://source_host:source_port");
$sourceDatabase = $sourceClient->selectDatabase("source_database_name");
$sourceCollection = $sourceDatabase->selectCollection("source_collection_name");

// 连接目标数据库
$targetClient = new MongoDB\Client("mongodb://target_host:target_port");
$targetDatabase = $targetClient->selectDatabase("target_database_name");
$targetCollection = $targetDatabase->selectCollection("target_collection_name");

// 查询源集合中的所有文档
$cursor = $sourceCollection->find();

// 使用批量插入操作将查询到的文档插入到目标集合中
$batchSize = 1000; // 自定义批量大小
$documents = [];
$count = 0;

foreach ($cursor as $document) {
    $documents[] = $document;
    $count++;

    if ($count % $batchSize === 0) {
        $targetCollection->insertMany($documents);
        $documents = [];
    }
}

// 插入剩余的文档
if (!empty($documents)) {
    $targetCollection->insertMany($documents);
}

// 关闭数据库连接
$sourceClient->close();
$targetClient->close();
?>

这个示例将源集合中的文档分成大小为1000的批次，并将这些批次插入到目标集合中。你可以根据实际需求调整批量大小。