PHP操作MongoDB時的整數(shù)問題及對策

三里屯搖滾

]

PHP操作MongoDB時的整數(shù)問題及對策

本文是一篇轉(zhuǎn)載文章，對MongoDB PHP驅(qū)動中的一個bug進行了描述，其間對MongoDB和Group操作和MapReduce操作都給出了典型的例子，值得一看。

原文鏈接：http://huoding.com/2011/03/13/55

本文所說的整數(shù)問題，其實并不是MongoDB的問題，而是PHP驅(qū)動的問題：MongoDB本身有兩種整數(shù)類型，分別是：32位整數(shù)和64位整數(shù)，但舊版的PHP驅(qū)動不管操作系統(tǒng)是32位還是64位，把所有整數(shù)都當做32位整數(shù)處理，結(jié)果導致64位整數(shù)被截斷。為了在盡可能保持兼容性的前提下解決這個問題，新版PHP驅(qū)動加入了mongo.native-long選項，以期在64位操作系統(tǒng)中把整數(shù)都當做64位來處理，有興趣的可參考：64-bit integers in MongoDB。

那么PHP驅(qū)動真的完全解決了整數(shù)問題么？NO！在處理group操作的時候還有BUG：

為了說明問題，我們先來生成一些測試數(shù)據(jù)：

1. selectCollection('test', 'test');
   
2. 
   
3. for ($i = 0; $i < 10; $i++) {
   
4.     $instance->insert(array(
   
5.         'group_id' => rand(1, 5),
   
6.         'count'    => rand(1, 5),
   
7.     ));
   
8. }
   
9. ?>下面讓我們使用group操作，根據(jù)group_id分組，匯總計算count：
   
10. 
    
11. selectCollection('test', 'test');
    
12. $keys = array('group_id' => 1);
    
13. $initial = array('count' => 0);
    
14. 
    
15. $reduce = '
    
16.     function(obj, prev) {
    
17.         prev.count += obj.count;
    
18.     }
    
19. ';
    
20. 
    
21. $result = $instance->group($keys, $initial, $reduce);
    
22. var_dump($result);

復制代碼

?>結(jié)果和預想的有出入，count沒有實現(xiàn)累加，而是變成了[object Object]，目前，如果必須使用group操作，那么有兩種方法可以緩解這個問題：

方法一：

ini_set('mongo.native_long', 0);方法二：

$initial = array('count' => (float)0);這兩種方法都是治標不治本的權(quán)宜之計，既然當前PHP驅(qū)動里group的實現(xiàn)有問題，那我們就繞開它，用其它的方式實現(xiàn)同樣的功能，這個方式就是MapReduce：

1. selectDB('test');
   
2. 
   
3. $map = '
   
4.     function() {
   
5.         emit(this.group_id, this.count);
   
6.     }
   
7. ';
   
8. 
   
9. $reduce = '
   
10.     function(key, values) {
    
11.         var sum = 0;
    
12. 
    
13.         for (var index in values) {
    
14.             sum += values[index];
    
15.         }
    
16. 
    
17.         return sum;
    
18.     }
    
19. ';
    
20. 
    
21. $result = $instance->command(array(
    
22.     'mapreduce' => 'test',
    
23.     'out'       => 'name',
    
24.     'map'       => $map,
    
25.     'reduce'    => $reduce
    
26. ));
    
27. 
    
28. $result = iterator_to_array($instance->{$result['result']}->find());
    
29. var_dump($result);
    
30. ?>

復制代碼

說明：雖然從表面上看MapReduce要生成一個新的Collection，顯得有些低效，但我們可以定期預生成它，相當于維護一個緩存表，只要對實時性要求不太高就沒問題。

把大象放冰箱里需要三步，而使用MapReduce僅僅需要Map和Reduce兩步即可，這里有一個PDF文檔生動的說明了MySQL中GROUP BY和MongoDB中MapReduce的對應關(guān)系：



此外，還有很多資料可供參考，如：MongoDB Aggregation III: Map-Reduce Basics。

說明：軟件版本為MongoDB（1.6.5），PECL Mongo（1.1.4）。不同版本結(jié)論可能不同。

冰釋一片天

希望與樓至多多交流