マイクロフレームワーク Flight で MongoDB と csv を取り扱う

次のプログラムを改造して、MongoDB を取り扱うようにしました。

マイクロフレームワーク Flight で MariaDB と csv を取り扱う

次のルートを作成します。

http://localhost:9000/mongodb
http://localhost:9000/csv
http://localhost:9000/export
http://localhost:9000/import

1. index.php

index.php

<?php
// -----------------------------------------------------------------
require 'flight/Flight.php';

require 'app/views/greeting.php';


Flight::route('/',array('Greeting','hello'));
Flight::route('/mongodb',array('Greeting','mongodb'));
Flight::route('/csv',array('Greeting','csv'));
Flight::route('/export',array('Greeting','export'));
Flight::route('/import',array('Greeting','import'));


Flight::start();
// -----------------------------------------------------------------

1. app/views/greeting.php

app/views/greeting.php

<?php
require_once ("csv_manipulate.php");
require_once ("mongo_manipulate.php");

// -----------------------------------------------------------------
class Greeting {
// -----------------------------------------------------------------
    public static function hello() {
        echo '*** Greeting ***<p />';
	echo '<a href="/mongodb">mongodb</a><p />';
	echo '<a href="/csv">csv</a><p />';
	echo '<a href="/export">export</a><p />';
	echo '<a href="/import">import</a><p />';
        echo '*** Jul/31/2018 *** AM 10:37<p />';
    }

// -----------------------------------------------------------------
    public static function export() 
{
	$file_csv = "data/cities_out.csv";
	$user = 'scott';
	$password = 'tiger123';

	$dict_aa = Mongo_manipulate::mongo_to_dict_proc ($user,$password);

	Csv_manipulate::dict_display_proc ($dict_aa);

	Csv_manipulate::csv_write_proc ($file_csv,$dict_aa);

	echo '<p />';
        echo '*** Jul/31/2018 *** AM 10:40<p />';
    }
// -----------------------------------------------------------------
public static function import()
{
	$file_csv = "data/cities.csv";

	$dict_aa = Csv_manipulate::csv_read_proc ($file_csv);

	Csv_manipulate::dict_display_proc ($dict_aa);

	$user = 'scott';
	$password = 'tiger123';

	Mongo_manipulate::dict_to_mongo_proc ($dict_aa,$user,$password);

	$dbcon=null;

	echo '<p />';
        echo '*** Jul/31/2018 *** PM 15:26<p />';
}

// -----------------------------------------------------------------
public static function csv()
{
	$file_csv = "data/cities.csv";

	$dict_aa = Csv_manipulate::csv_read_proc ($file_csv);
	Csv_manipulate::dict_display_proc ($dict_aa);

	echo '<p />';
        echo '*** Jul/31/2018 *** AM 10:55<p />';
}

// -----------------------------------------------------------------
public static function mongodb()
{
	$user = 'scott';
	$password = 'tiger123';

	$dict_aa = Mongo_manipulate::mongo_to_dict_proc ($user,$password);
	Csv_manipulate::dict_display_proc ($dict_aa);

	echo '<p />';
        echo '*** Jul/31/2018 *** AM 10:55<p />';
}

// -----------------------------------------------------------------
}
// -----------------------------------------------------------------
?>

1. app/views/mongo_manipulate.php

app/views/mongo_manipulate.php

<?php
// --------------------------------------------------------------------
/*
	mongo_manipulate.php

					Aug/01/2018

*/
// --------------------------------------------------------------------
class Mongo_manipulate {
// --------------------------------------------------------------------
function dict_append_proc ($dict_aa,$id,$name,$population,$date_mod)
{
	$dict_unit = array ();
	$dict_unit['name'] = $name;
	$dict_unit['population'] = $population;
	$dict_unit['date_mod'] = $date_mod;
	$dict_aa[(string)$id]= $dict_unit;

	return	$dict_aa;
}

// --------------------------------------------------------------------
function mongo_to_dict_proc ($user,$password)
{
	$dict_aa = array ();

	$str_connect = "mongodb://" . $user . ":" . $password . "@localhost:27017";
	$manager = new MongoDB\Driver\Manager($str_connect);

	$filter = [];
	$options = [
		'projection' => ['_id' => 0],
		'sort' => ['_id' => -1],
	];

	$query = new MongoDB\Driver\Query($filter, $options);
	$cursor = $manager->executeQuery('city.saitama', $query);

	$dict_aa = array ();

	foreach ($cursor as $document) {
		$dict_aa = Mongo_manipulate::dict_append_proc ($dict_aa,$document->key,$document->name,$document->population,$document->date_mod);
	}

	return	$dict_aa;
}

// --------------------------------------------------------------------
function mongo_update_proc ($id_in,$population_in,$user,$password)
{
	$str_connect = "mongodb://" . $user . ":" . $password . "@localhost:27017";
	$manager = new MongoDB\Driver\Manager($str_connect);

	$bulk = new MongoDB\Driver\BulkWrite;

	date_default_timezone_set('Asia/Tokyo');
	$today = date ("Y-m-d");

	$newdata = array('$set' => array("population" => $population_in,"date_mod" => $today));

	$bulk->update(array("key" => $id_in), $newdata);

	$manager->executeBulkWrite('city.saitama', $bulk);
}

// --------------------------------------------------------------------
function mongo_delete_proc ($id_in,$user,$password)
{
	$str_connect = "mongodb://" . $user . ":" . $password . "@localhost:27017";
	$manager = new MongoDB\Driver\Manager($str_connect);

	$bulk = new MongoDB\Driver\BulkWrite;

	$bulk->delete(['key' => $id_in]);

	$result = $manager->executeBulkWrite('city.saitama', $bulk);
}

// --------------------------------------------------------------------
function dict_to_mongo_proc ($dict_aa,$user,$password)
{
	$str_connect = "mongodb://" . $user . ":" . $password . "@localhost:27017";

	$manager = new MongoDB\Driver\Manager($str_connect);

	$manager->executeCommand('city', new \MongoDB\Driver\Command(["drop" => "saitama"]));


	$bulk = new MongoDB\Driver\BulkWrite;
	foreach ($dict_aa as $key => $value)
		{
	$bulk->insert(['key' => $key, 'name' => $value["name"], 'population' => $value['population'], 'date_mod' => $value['date_mod']]);
		}

	$manager->executeBulkWrite('city.saitama', $bulk);
}

// --------------------------------------------------------------------
}
// --------------------------------------------------------------------
?>

1. app/views/csv_manipulate.php
   これは、
   次のものと同じです。
   マイクロフレームワーク Flight で MariaDB と csv を取り扱う