Mongo-query-php

for Query data from MongoDB, _(*1)

Usage

Initial setup

Install composer. curl -s http://getcomposer.org/installer | php, _(*2)

Create composer.json containing:, _(*3)

{
  "require" : {
      "salamtam/mongo-query-php" : "^1.0"
  }
}

Run ./composer.phar install, _(*4)
Keep up-to-date: ./composer.phar update, _(*5)

Example 1

Query with URL, _(*6)

require_once __DIR__ . '/vendor/autoload.php';

use MongoQueryPHP\MongoQueryPHP;

/* set config */
$config = [
  'url' => 'mongodb://localhost:27017',
  'database' => 'test',
  'collection' => 'member'
];

/* set query (filter) */
$filter = [
  'name' => 'salamtam'
];

/* connect database */
$db = new MongoQueryPHP($config);
$db->setDatabase($config['database'])->setCollection($config['collection']);

/* query database */
$cursor = $db->query($filter);

/* result */
foreach ($cursor as $doc) {
  echo json_encode($doc) . PHP_EOL;
  break;
}

Example 2

Query with basic authentication, _(*7)

require_once __DIR__ . '/vendor/autoload.php';

use MongoQueryPHP\MongoQueryPHP;

/* set config */
$config = [
  'host' => 'localhost',
  'port' => '27017',
  'user' => 'root',
  'pass' => '',
  'database' => 'test',
  'collection' => 'member'
];

/* set query (filter) */
$filter = [
  'name' => 'salamtam'
];

/* connect database */
$db = new MongoQueryPHP($config);
$db->setDatabase($config['database'])->setCollection($config['collection']);

/* query database */
$cursor = $db->query($filter);

/* result */
foreach ($cursor as $doc) {
  echo json_encode($doc) . PHP_EOL;
  break;
}

Example 3

Query with multi filter, _(*8)

require_once __DIR__ . '/vendor/autoload.php';

use MongoQueryPHP\MongoQueryPHP;

/* set config */
$config = [
  'url' => 'mongodb://localhost:27017',
  'database' => 'test',
  'collection' => 'member'
];

/* set query (filter) */
$filter = json_decode('{"name":"salamtam","created_at":{"$gte":1499533200000}}', true);

/* connect database */
$db = new MongoQueryPHP($config);
$db->setDatabase($config['database'])->setCollection($config['collection']);

/* query database */
$cursor = $db->query($filter);

/* result */
foreach ($cursor as $doc) {
  echo json_encode($doc) . PHP_EOL;
  break;
}

Example 4

Query with multi filter and sort, _(*9)

require_once __DIR__ . '/vendor/autoload.php';

use MongoQueryPHP\MongoQueryPHP;

/* set config */
$config = [
  'url' => 'mongodb://localhost:27017',
  'database' => 'test',
  'collection' => 'member'
];

/* set query (filter) */
$filter = [
    'name' => 'salamtam',
    'created_at' => [
        '$gte' => 1499533200000,
    ],
];

$sort = [
    'sort' => [
        'created_at' => -1
    ],
];


/* connect database */
$db = new MongoQueryPHP($config);
$db->setDatabase($config['database'])->setCollection($config['collection']);

/* query database */
$cursor = $db->query($filter, $sort);

/* result */
foreach ($cursor as $doc) {
  echo json_encode($doc) . PHP_EOL;
  break;
}

Example 5

Aggregate with URL, _(*10)

require_once __DIR__ . '/vendor/autoload.php';

use MongoQueryPHP\MongoQueryPHP;

/* set config */
$config = [
  'url' => 'mongodb://localhost:27017',
  'database' => 'test',
  'collection' => 'member'
];

/* set query (filter) */
$filter = [
  '$match' => [
    'name' => 'salamtam'
  ]
];

/* connect database */
$db = new MongoQueryPHP($config);
$db->setDatabase($config['database'])->setCollection($config['collection']);

/* aggregate database */
$cursor = $db->aggregate($filter);

/* result */
foreach ($cursor as $doc) {
  echo json_encode($doc) . PHP_EOL;
  break;
}

Example 6

Aggregate with filter, _(*11)

require_once __DIR__ . '/vendor/autoload.php';

use MongoQueryPHP\MongoQueryPHP;

/* set config */
$config = [
  'url' => 'mongodb://localhost:27017',
  'database' => 'test',
  'collection' => 'member'
];

/* set query (filter) */
$filter = json_decode('[{"$match":{"name":"salamtam","created_at":{"$gte":1499533200000}}}]', true);

/* connect database */
$db = new MongoQueryPHP($config);
$db->setDatabase($config['database'])->setCollection($config['collection']);

/* aggregate database */
$cursor = $db->aggregate($filter);

/* result */
foreach ($cursor as $doc) {
  echo json_encode($doc) . PHP_EOL;
  break;
}