Thinkphp使用mongodb數(shù)據(jù)庫實現(xiàn)多條件查詢方法

更新時間：2014年06月26日 10:28:35 投稿：junjie

這篇文章主要介紹了Thinkphp使用mongodb數(shù)據(jù)庫實現(xiàn)多條件查詢方法,修改了mongodb驅(qū)動文件來實現(xiàn)復(fù)合查詢、多條件查詢,需要的朋友可以參考下

有個項目用了mongodb數(shù)據(jù)庫,查詢條件有and也有or,按Thinkphp官方手冊,使用復(fù)合查詢（_complex）,getLastSql輸出查詢語句,發(fā)現(xiàn)查詢條件是空的.用字符串模式查詢（_string）,請求字符串查詢（_query）無法滿足需求.估計用mongodb的用戶不多,thinkphp官方對這方面支持也不夠.打開thinkphp的mongodb驅(qū)動,Thinkphp/Extend/Driver/Db/DbMongo.class.php,找到protected function parseThinkWhere($key,$val)方法,可以發(fā)現(xiàn),switch里沒有_complex,也就是說,Thinkphp使用mongodb時,根本不支持復(fù)合查詢.加上:

復(fù)制代碼代碼如下:

case '_complex'://復(fù)合查詢

             $arr   = array();

             foreach ($val as $nkey=>$nval){

              if( strpos($nkey,'_')!=0)

              {

               $parseArr=$this->parseWhereItem($nkey,$nval);

               //轉(zhuǎn)換成對象

               $obj=new stdClass();

               foreach ($parseArr as $pkey=>$pval)

               {

                $obj->$pkey=$pval;

               }

               array_push($arr, $obj);

              }

             }

             if(isset($val['_logic']) && strtolower($val['_logic']) == 'or' ) {

              unset($val['_logic']);

              $query['$or']   =  $arr;

             }

             break;

這里之所以要轉(zhuǎn)換成對象,是因為使用thinkphp使用json_encode函數(shù)生成查詢語句,但是如果數(shù)組元素帶key,json_encode函數(shù)會把數(shù)組轉(zhuǎn)換成對象的形式,mongodb不能識別.因為目前只用到or,所以,代碼只對or作了處理.
另外,發(fā)現(xiàn)個BUG(不知道算不算),在parseWhere方法中:

復(fù)制代碼代碼如下:

foreach ($where as $key=>$val){

            if('_id' != $key && 0===strpos($key,'_')) {

                // 解析特殊條件表達式

                //原 $query=$this->parseThinkWhere($key,$val);

                $query   = array_merge($query,$this->parseThinkWhere($key,$val));

            }else{

                // 查詢字段的安全過濾

                if(!preg_match('/^[A-Z_\|\&\-.a-z0-9]+$/',trim($key))){

                    throw_exception(L('_ERROR_QUERY_').':'.$key);

                }

                $key = trim($key);

                if(strpos($key,'|')) {

                    $array   =  explode('|',$key);

                    $str   = array();

                    foreach ($array as $k){

                        $str[]   = $this->parseWhereItem($k,$val);

                    }

                    $query['$or'] =    $str;

                }elseif(strpos($key,'&')){

                    $array   =  explode('&',$key);

                    $str   = array();

                    foreach ($array as $k){

                        $str[]   = $this->parseWhereItem($k,$val);

                    }

                    $query   = array_merge($query,$str);

                }else{

                    $str   = $this->parseWhereItem($key,$val);

                    $query   = array_merge($query,$str);

                }

            }

        }