0

Mongo DB でいくつかの基本的なフィクスチャをセットアップしようとしています。そのために、一連の JSON ファイルを読み取り、それらをローカル データベースに挿入しようとします (管理者権限で接続しています)。ここが奇妙な部分です。いくつかの理由で、基本的に同じように動作するコードのバージョンを書いたので、1つ持っています。

$client = new \MongoClient($connectionURI);
$db = $client->selectDB($database);
$collections = $db->listCollections();

foreach ($collections as $collection) {
    //echo "Removing all documents from '$collection'" . PHP_EOL;
    $collection->remove();

    $tmp = explode('.', (string)$collection);
    $collectionName = $tmp[1];
    $tmp = explode('_', $tmp[0]);
    $dbName = $tmp[1];
    $country = $tmp[2];

    if(file_exists(__DIR__."/fixtures/{$country}/{$dbName}/{$collectionName}.json")) {
        echo "Inserting fixture data into '{$collection}'".PHP_EOL;
        $data = json_decode(file_get_contents(__DIR__."/fixtures/{$country}/{$dbName}/{$collectionName}.json"));
        $doc = $collection->insert($data, ["w" => "majority"]);
    }
}

もう 1 つは、既存のコレクションを一覧表示する代わりに、読み取るファイルの繰り返しに基づいています。

$client = new \MongoClient($connectionURI);
foreach(glob(__DIR__.'/fixtures/*', GLOB_ONLYDIR) as $dir) {
    $country = basename($dir);
    foreach(glob(__DIR__.'/fixtures/'.$country.'/*', GLOB_ONLYDIR) as $dbDir) {
    $collections = array_diff(
        scandir(__DIR__."/fixtures/{$country}/".basename($dbDir)), ['.', '..']
        );

        $dbName = 'test_'.basename($dbDir).'_'.$country;

        foreach($collections as $collectionFile) {
            $collectionName = pathinfo($collectionFile)['filename'];

            $data = [];//json_decode(file_get_contents(__DIR__."/fixtures/{$country}/".basenam    e($dbDir)."/{$collectionName}.json"));
//            $client->$dbName->$collectionName->insert($data);
            $db = $client->selectDB($dbName);
            $collection = $db->selectCollection($collectionName);
            $collection->insert($data, ["w" => "majority"]);
            echo $country.'->'.$dbName.'->'.$collectionName.PHP_EOL;
        }
    }
}

秘訣は、最初の実装はうまく機能し、2 番目の実装MongoCursorExceptionでは認証の問題が発生することです。私が抱えている問題は、実際には両方のバージョンがまったく同じデータベースとコレクションに接続しようとすることです。したがって、次の出力が得られます。

Inserting fixture data into 'test_customers_poland.accounts'
PHP Fatal error:  Uncaught exception 'MongoCursorException' with message 'Couldn't get connection: Failed to connect to: 127.0.0.1:27017: SASL Authentication failed on database 'test_customers_poland': Authentication failed.' in /srv/dev-api/src/tests/init_databases.php:96
Stack trace:
#0 /srv/dev-api/src/tests/init_databases.php(96): MongoCollection->insert(Array, Array)
#1 {main}
  thrown in /s

96 行目の rv/dev-api/src/tests/init_databases.php

もちろん、これらのスニペットを個別に実行しても同じ結果が得られることも確認したので、問題は次のとおりです。2番目のアプローチで何が間違っているのですか?

4

0 に答える 0