Skip to content

Commit

Permalink
added proper exception handling for mapReduce(), added tests
Browse files Browse the repository at this point in the history
  • Loading branch information
@avalanche123
avalanche123 committed May 18, 2010
1 parent 048c75c commit 9b27752
Show file tree
Hide file tree
Showing 2 changed files with 197 additions and 1 deletion.
5 changes: 4 additions & 1 deletion lib/Doctrine/ODM/MongoDB/DocumentManager.php
View file
Original file line number Diff line number Diff line change
Expand Up @@ -464,6 +464,9 @@ public function mapReduce($documentName, $map, $reduce, array $query = array(),
);
$command = array_merge($command, $options);
$result = $db->command($command);
if ( ! $result['ok']) {
throw new \RuntimeException($result['errmsg']);
}
return $db->selectCollection($result['result'])->find();
}

Expand Down Expand Up @@ -528,4 +531,4 @@ public function clear()
{
$this->_unitOfWork->clear();
}
}
}
193 changes: 193 additions & 0 deletions tests/MapReduceTest.php
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,193 @@
<?php

require_once 'TestInit.php';

use Doctrine\Common\Annotations\AnnotationReader,
Doctrine\ODM\MongoDB\DocumentManager,
Doctrine\ODM\MongoDB\Configuration,
Doctrine\ODM\MongoDB\Mapping\ClassMetadata,
Doctrine\ODM\MongoDB\Mongo,
Doctrine\ODM\MongoDB\Mapping\Driver\AnnotationDriver,
Documents\Ecommerce\ConfigurableProduct,
Documents\Ecommerce\StockItem,
Documents\Ecommerce\Currency,
Documents\Ecommerce\Money,
Documents\Ecommerce\Option;

/**
* @author Bulat Shakirzyanov <[email protected]>
*/
class MapReduceTest extends PHPUnit_Framework_TestCase
{
protected $dm;

public function setUp()
{
$config = new Configuration();

$config->setProxyDir(__DIR__ . '/Proxies');
$config->setProxyNamespace('Proxies');

$reader = new AnnotationReader();
$reader->setDefaultAnnotationNamespace('Doctrine\ODM\MongoDB\Mapping\\');
$config->setMetadataDriverImpl(new AnnotationDriver($reader, __DIR__ . '/Documents'));

$this->dm = DocumentManager::create(new Mongo(), $config);

$currencies = array('USD' => 1, 'EURO' => 1.7, 'JPN' => 0.0125);

foreach ($currencies as $name => &$multiplier) {
$multiplier = new Currency($name, $multiplier);
$this->dm->persist($multiplier);
}

$stockItems = array(
new StockItem('stock_item_0', new Money(9.99 * 0 + 5, $currencies['USD']), 5),
new StockItem('stock_item_1', new Money(9.99 * 1 + 5, $currencies['USD']), 15 * 1 - 4),
new StockItem('stock_item_2', new Money(9.99 * 2 + 5, $currencies['USD']), 15 * 2 - 4),
new StockItem('stock_item_3', new Money(9.99 * 3 + 5, $currencies['USD']), 15 * 3 - 4),
new StockItem('stock_item_4', new Money(9.99 * 4 + 5, $currencies['USD']), 15 * 4 - 4),
new StockItem('stock_item_5', new Money(9.99 * 5 + 5, $currencies['USD']), 15 * 5 - 4),
new StockItem('stock_item_6', new Money(9.99 * 6 + 5, $currencies['USD']), 15 * 6 - 4),
new StockItem('stock_item_7', new Money(9.99 * 7 + 5, $currencies['USD']), 15 * 7 - 4),
new StockItem('stock_item_8', new Money(9.99 * 8 + 5, $currencies['USD']), 15 * 8 - 4),
new StockItem('stock_item_9', new Money(9.99 * 9 + 5, $currencies['USD']), 15 * 9 - 4),
);

$options = array(
new Option('option_0', new Money(13.99, $currencies['USD']), $stockItems[0]),
new Option('option_1', new Money(14.99, $currencies['USD']), $stockItems[1]),
new Option('option_2', new Money(15.99, $currencies['USD']), $stockItems[2]),
new Option('option_3', new Money(16.99, $currencies['USD']), $stockItems[3]),
new Option('option_4', new Money(17.99, $currencies['USD']), $stockItems[4]),
new Option('option_5', new Money(18.99, $currencies['USD']), $stockItems[5]),
new Option('option_6', new Money(19.99, $currencies['USD']), $stockItems[6]),
new Option('option_7', new Money(20.99, $currencies['USD']), $stockItems[7]),
new Option('option_8', new Money(21.99, $currencies['USD']), $stockItems[8]),
new Option('option_9', new Money(22.99, $currencies['USD']), $stockItems[9]),
);

$products = array(
new ConfigurableProduct('product_0'),
new ConfigurableProduct('product_1'),
new ConfigurableProduct('product_2'),
new ConfigurableProduct('product_3'),
new ConfigurableProduct('product_4'),
new ConfigurableProduct('product_5'),
new ConfigurableProduct('product_6'),
new ConfigurableProduct('product_7'),
new ConfigurableProduct('product_8'),
new ConfigurableProduct('product_9'),
);

$products[0]->addOption($options[0]);
$products[0]->addOption($options[4]);
$products[0]->addOption($options[6]);

$products[1]->addOption($options[1]);
$products[1]->addOption($options[2]);
$products[1]->addOption($options[5]);
$products[1]->addOption($options[7]);
$products[1]->addOption($options[8]);

$products[2]->addOption($options[3]);
$products[2]->addOption($options[5]);
$products[2]->addOption($options[7]);
$products[2]->addOption($options[9]);

$products[3]->addOption($options[0]);
$products[3]->addOption($options[1]);
$products[3]->addOption($options[2]);
$products[3]->addOption($options[3]);
$products[3]->addOption($options[4]);
$products[3]->addOption($options[5]);

$products[4]->addOption($options[4]);
$products[4]->addOption($options[7]);
$products[4]->addOption($options[2]);
$products[4]->addOption($options[8]);

$products[5]->addOption($options[9]);

$products[6]->addOption($options[7]);
$products[6]->addOption($options[8]);
$products[6]->addOption($options[9]);

$products[7]->addOption($options[4]);
$products[7]->addOption($options[5]);

$products[8]->addOption($options[2]);

$products[9]->addOption($options[4]);
$products[9]->addOption($options[3]);
$products[9]->addOption($options[7]);

foreach ($products as $product) {
$this->dm->persist($product);
}
$this->dm->flush();
$this->dm->clear();
}

public function tearDown()
{
$documents = array(
'Documents\Ecommerce\ConfigurableProduct',
'Documents\Ecommerce\StockItem',
'Documents\Ecommerce\Currency',
);
foreach ($documents as $document) {
$this->dm->getDocumentCollection($document)->drop();
}
}

public function testMapReduce()
{
$map = 'function() {
for(i = 0; i <= this.options.length; i++) {
emit(this.name, { count: 1 });
}
}';

$reduce = 'function(product, values) {
var total = 0
values.forEach(function(value){
total+= value.count;
});
return {
product: product,
options: total,
test: values
};
}';

$results = $this->dm->mapReduce('Documents\Ecommerce\ConfigurableProduct', $map, $reduce);
$this->assertEquals(10, $results->count());
}

/**
* @expectedException RuntimeException
*/
public function testMapReduceError() {
$map = 'function() {
for(i = 0; i <= this.options.length; i++) {
emit(this.name.fetch(), { count: 1 });
}
}';

$reduce = 'function(product, values) {
var total = 0
values.forEach(function(value){
total+= value.count;
});
return {
product: product,
options: total,
test: values
};
}';

$results = $this->dm->mapReduce('Documents\Ecommerce\ConfigurableProduct', $map, $reduce);
}
}

0 comments on commit 9b27752

Please sign in to comment.