//read all data
//$mng = new MongoDB\Driver\Manager("mongodb://localhost:27017");
$mng = new MongoDB\Driver\Manager("mongodb://root:testtest@localhost:27017");
$query = new MongoDB\Driver\Query([]);
$rows = $mng->executeQuery("q_alert_db.qa_sys_user", $query);
foreach ($rows as $man) {
echo "$man->fname $man->lname<br>";
}
//read with sort and limit 5
//$mng = new MongoDB\Driver\Manager("mongodb://localhost:27017");
$mng = new MongoDB\Driver\Manager("mongodb://root:testtest@localhost:27017");
$query = new MongoDB\Driver\Query([], ['sort' => [ 'fname' => 1], 'limit' => 5]);
/* 'sort' => [ 'fname' => -1] */
$rows = $mng->executeQuery("q_alert_db.qa_sys_user", $query);
foreach ($rows as $man) {
echo "$man->fname $man->lname<br>";
}
//filter and wilde card
//$mng = new MongoDB\Driver\Manager("mongodb://localhost:27017");
$mng = new MongoDB\Driver\Manager("mongodb://root:testtest@localhost:27017");
$filter = [ 'office_id' => array('$regex' => '12')];
$options = ['projection' => ['_id' => 0],'sort' => ['office_id' => -1]];
$query = new MongoDB\Driver\Query($filter, $options);
$res = $mng->executeQuery('q_alert_db.qa_sys_user', $query);
$c=1;
foreach ($res as $man) {
if(substr($man->office_id,0,2)=='12'){ //แก้ปัญหา ที่จะแสดงทุกค่าที่มี 12
echo "$c $man->fname $man->lname $man->office_id<br>";
$c++;
}
}
//insert or write data
//$mng = new MongoDB\Driver\Manager("mongodb://localhost:27017");
$mng = new MongoDB\Driver\Manager("mongodb://root:testtest@localhost:27017");
$bulk = new MongoDB\Driver\BulkWrite;
$doc = ['_id' => new MongoDB\BSON\ObjectID,
'username' => 'Toyota',
'password' => 'aaa',
'login_type' =>'1',
'login_status' =>'1'
];
$bulk->insert($doc);
/*
$bulk->update(['name' => 'Audi'], ['$set' => ['price' => 52000]]);
$bulk->delete(['name' => 'Hummer']);
*/
$mng->executeBulkWrite('q_alert_db.qa_sys_user', $bulk);
echo "Insert Data Already\n";