dbobjectsearch.class.php 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918
  1. <?php
  2. // Copyright (C) 2010 Combodo SARL
  3. //
  4. // This program is free software; you can redistribute it and/or modify
  5. // it under the terms of the GNU General Public License as published by
  6. // the Free Software Foundation; version 3 of the License.
  7. //
  8. // This program is distributed in the hope that it will be useful,
  9. // but WITHOUT ANY WARRANTY; without even the implied warranty of
  10. // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  11. // GNU General Public License for more details.
  12. //
  13. // You should have received a copy of the GNU General Public License
  14. // along with this program; if not, write to the Free Software
  15. // Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
  16. /**
  17. * Define filters for a given class of objects (formerly named "filter")
  18. *
  19. * @author Erwan Taloc <erwan.taloc@combodo.com>
  20. * @author Romain Quetiez <romain.quetiez@combodo.com>
  21. * @author Denis Flaven <denis.flaven@combodo.com>
  22. * @license http://www.opensource.org/licenses/gpl-3.0.html LGPL
  23. */
  24. class DBObjectSearch
  25. {
  26. private $m_aClasses; // queried classes (alias => class name), the first item is the class corresponding to this filter (the rest is coming from subfilters)
  27. private $m_aSelectedClasses; // selected for the output (alias => class name)
  28. private $m_oSearchCondition;
  29. private $m_aParams;
  30. private $m_aFullText;
  31. private $m_aPointingTo;
  32. private $m_aReferencedBy;
  33. private $m_aRelatedTo;
  34. // By default, some information may be hidden to the current user
  35. // But it may happen that we need to disable that feature
  36. private $m_bAllowAllData = false;
  37. public function __construct($sClass, $sClassAlias = null)
  38. {
  39. if (is_null($sClassAlias)) $sClassAlias = $sClass;
  40. assert('is_string($sClass)');
  41. assert('MetaModel::IsValidClass($sClass)'); // #@# could do better than an assert, or at least give the caller's reference
  42. // => idee d'un assert avec call stack (autre utilisation = echec sur query SQL)
  43. $this->m_aSelectedClasses = array($sClassAlias => $sClass);
  44. $this->m_aClasses = array($sClassAlias => $sClass);
  45. $this->m_oSearchCondition = new TrueExpression;
  46. $this->m_aParams = array();
  47. $this->m_aFullText = array();
  48. $this->m_aPointingTo = array();
  49. $this->m_aReferencedBy = array();
  50. $this->m_aRelatedTo = array();
  51. }
  52. public function AllowAllData() {$this->m_bAllowAllData = true;}
  53. public function IsAllDataAllowed() {return $this->m_bAllowAllData;}
  54. public function GetClassName($sAlias) {return $this->m_aClasses[$sAlias];}
  55. public function GetJoinedClasses() {return $this->m_aClasses;}
  56. public function GetClass()
  57. {
  58. return reset($this->m_aSelectedClasses);
  59. }
  60. public function GetClassAlias()
  61. {
  62. reset($this->m_aSelectedClasses);
  63. return key($this->m_aSelectedClasses);
  64. }
  65. public function GetFirstJoinedClass()
  66. {
  67. return reset($this->m_aClasses);
  68. }
  69. public function GetFirstJoinedClassAlias()
  70. {
  71. reset($this->m_aClasses);
  72. return key($this->m_aClasses);
  73. }
  74. public function SetSelectedClasses($aNewSet)
  75. {
  76. $this->m_aSelectedClasses = array();
  77. foreach ($aNewSet as $sAlias => $sClass)
  78. {
  79. if (!array_key_exists($sAlias, $this->m_aClasses))
  80. {
  81. throw new CoreException('Unexpected class alias', array('alias'=>$sAlias, 'expected'=>$this->m_aClasses));
  82. }
  83. $this->m_aSelectedClasses[$sAlias] = $sClass;
  84. }
  85. }
  86. public function GetSelectedClasses()
  87. {
  88. return $this->m_aSelectedClasses;
  89. }
  90. public function IsAny()
  91. {
  92. // #@# todo - if (!$this->m_oSearchCondition->IsTrue()) return false;
  93. if (count($this->m_aFullText) > 0) return false;
  94. if (count($this->m_aPointingTo) > 0) return false;
  95. if (count($this->m_aReferencedBy) > 0) return false;
  96. if (count($this->m_aRelatedTo) > 0) return false;
  97. return true;
  98. }
  99. public function Describe()
  100. {
  101. // To replace __Describe
  102. }
  103. public function DescribeConditionPointTo($sExtKeyAttCode)
  104. {
  105. if (!isset($this->m_aPointingTo[$sExtKeyAttCode])) return "";
  106. $oFilter = $this->m_aPointingTo[$sExtKeyAttCode];
  107. if ($oFilter->IsAny()) return "";
  108. $oAtt = MetaModel::GetAttributeDef($this->GetClass(), $sExtKeyAttCode);
  109. return $oAtt->GetLabel()." having ({$oFilter->DescribeConditions()})";
  110. }
  111. public function DescribeConditionRefBy($sForeignClass, $sForeignExtKeyAttCode)
  112. {
  113. if (!isset($this->m_aReferencedBy[$sForeignClass][$sForeignExtKeyAttCode])) return "";
  114. $oFilter = $this->m_aReferencedBy[$sForeignClass][$sForeignExtKeyAttCode];
  115. if ($oFilter->IsAny()) return "";
  116. $oAtt = MetaModel::GetAttributeDef($sForeignClass, $sForeignExtKeyAttCode);
  117. return "being ".$oAtt->GetLabel()." for ".$sForeignClass."s in ({$oFilter->DescribeConditions()})";
  118. }
  119. public function DescribeConditionRelTo($aRelInfo)
  120. {
  121. $oFilter = $aRelInfo['flt'];
  122. $sRelCode = $aRelInfo['relcode'];
  123. $iMaxDepth = $aRelInfo['maxdepth'];
  124. return "related ($sRelCode... peut mieux faire !, $iMaxDepth dig depth) to a {$oFilter->GetClass()} ({$oFilter->DescribeConditions()})";
  125. }
  126. public function DescribeConditions()
  127. {
  128. $aConditions = array();
  129. $aCondFT = array();
  130. foreach($this->m_aFullText as $sFullText)
  131. {
  132. $aCondFT[] = " contain word(s) '$sFullText'";
  133. }
  134. if (count($aCondFT) > 0)
  135. {
  136. $aConditions[] = "which ".implode(" and ", $aCondFT);
  137. }
  138. // #@# todo - review textual description of the JOIN and search condition (is that still feasible?)
  139. $aConditions[] = $this->RenderCondition();
  140. $aCondPoint = array();
  141. foreach($this->m_aPointingTo as $sExtKeyAttCode=>$oFilter)
  142. {
  143. if ($oFilter->IsAny()) continue;
  144. $aCondPoint[] = $this->DescribeConditionPointTo($sExtKeyAttCode);
  145. }
  146. if (count($aCondPoint) > 0)
  147. {
  148. $aConditions[] = implode(" and ", $aCondPoint);
  149. }
  150. $aCondReferred= array();
  151. foreach($this->m_aReferencedBy as $sForeignClass=>$aReferences)
  152. {
  153. foreach($aReferences as $sForeignExtKeyAttCode=>$oForeignFilter)
  154. {
  155. if ($oForeignFilter->IsAny()) continue;
  156. $aCondReferred[] = $this->DescribeConditionRefBy($sForeignClass, $sForeignExtKeyAttCode);
  157. }
  158. }
  159. foreach ($this->m_aRelatedTo as $aRelInfo)
  160. {
  161. $aCondReferred[] = $this->DescribeConditionRelTo($aRelInfo);
  162. }
  163. if (count($aCondReferred) > 0)
  164. {
  165. $aConditions[] = implode(" and ", $aCondReferred);
  166. }
  167. return implode(" and ", $aConditions);
  168. }
  169. public function __DescribeHTML()
  170. {
  171. try
  172. {
  173. $sConditionDesc = $this->DescribeConditions();
  174. }
  175. catch (MissingQueryArgument $e)
  176. {
  177. $sConditionDesc = '?missing query argument?';
  178. }
  179. if (!empty($sConditionDesc))
  180. {
  181. return "Objects of class '".$this->GetClass()."', $sConditionDesc";
  182. }
  183. return "Any object of class '".$this->GetClass()."'";
  184. }
  185. protected function TransferConditionExpression($oFilter, $aTranslation)
  186. {
  187. $oTranslated = $oFilter->GetCriteria()->Translate($aTranslation, false, false /* leave unresolved fields */);
  188. $this->AddConditionExpression($oTranslated);
  189. // #@# what about collisions in parameter names ???
  190. $this->m_aParams = array_merge($this->m_aParams, $oFilter->m_aParams);
  191. }
  192. public function ResetCondition()
  193. {
  194. $this->m_oSearchCondition = new TrueExpression();
  195. // ? is that usefull/enough, do I need to rebuild the list after the subqueries ?
  196. }
  197. public function AddConditionExpression($oExpression)
  198. {
  199. $this->m_oSearchCondition = $this->m_oSearchCondition->LogAnd($oExpression);
  200. }
  201. public function AddNameCondition($sName)
  202. {
  203. $oValueExpr = new ScalarExpression($sName);
  204. $oNameExpr = new FieldExpression('friendlyname', $this->GetClassAlias());
  205. $oNewCondition = new BinaryExpression($oNameExpr, '=', $oValueExpr);
  206. $this->AddConditionExpression($oNewCondition);
  207. }
  208. public function AddCondition($sFilterCode, $value, $sOpCode = null)
  209. {
  210. MyHelpers::CheckKeyInArray('filter code', $sFilterCode, MetaModel::GetClassFilterDefs($this->GetClass()));
  211. $oFilterDef = MetaModel::GetClassFilterDef($this->GetClass(), $sFilterCode);
  212. $oField = new FieldExpression($sFilterCode, $this->GetClassAlias());
  213. if (empty($sOpCode))
  214. {
  215. if ($sFilterCode == 'id')
  216. {
  217. $sOpCode = '=';
  218. }
  219. else
  220. {
  221. $oAttDef = MetaModel::GetAttributeDef($this->GetClass(), $sFilterCode);
  222. $oNewCondition = $oAttDef->GetSmartConditionExpression($value, $oField, $this->m_aParams);
  223. $this->AddConditionExpression($oNewCondition);
  224. return;
  225. }
  226. }
  227. MyHelpers::CheckKeyInArray('operator', $sOpCode, $oFilterDef->GetOperators());
  228. // Preserve backward compatibility - quick n'dirty way to change that API semantic
  229. //
  230. switch($sOpCode)
  231. {
  232. case 'SameDay':
  233. case 'SameMonth':
  234. case 'SameYear':
  235. case 'Today':
  236. case '>|':
  237. case '<|':
  238. case '=|':
  239. throw new CoreException('Deprecated operator, please consider using OQL (SQL) expressions like "(TO_DAYS(NOW()) - TO_DAYS(x)) AS AgeDays"', array('operator' => $sOpCode));
  240. break;
  241. case "IN":
  242. if (!is_array($value)) $value = array($value);
  243. $sListExpr = '('.implode(', ', CMDBSource::Quote($value)).')';
  244. $sOQLCondition = $oField->Render()." IN $sListExpr";
  245. break;
  246. case "NOTIN":
  247. if (!is_array($value)) $value = array($value);
  248. $sListExpr = '('.implode(', ', CMDBSource::Quote($value)).')';
  249. $sOQLCondition = $oField->Render()." NOT IN $sListExpr";
  250. break;
  251. case 'Contains':
  252. $this->m_aParams[$sFilterCode] = "%$value%";
  253. $sOperator = 'LIKE';
  254. break;
  255. case 'Begins with':
  256. $this->m_aParams[$sFilterCode] = "$value%";
  257. $sOperator = 'LIKE';
  258. break;
  259. case 'Finishes with':
  260. $this->m_aParams[$sFilterCode] = "%$value";
  261. $sOperator = 'LIKE';
  262. break;
  263. default:
  264. $this->m_aParams[$sFilterCode] = $value;
  265. $sOperator = $sOpCode;
  266. }
  267. switch($sOpCode)
  268. {
  269. case "IN":
  270. case "NOTIN":
  271. $oNewCondition = Expression::FromOQL($sOQLCondition);
  272. break;
  273. case 'Contains':
  274. case 'Begins with':
  275. case 'Finishes with':
  276. default:
  277. $oRightExpr = new VariableExpression($sFilterCode);
  278. $oNewCondition = new BinaryExpression($oField, $sOperator, $oRightExpr);
  279. }
  280. $this->AddConditionExpression($oNewCondition);
  281. }
  282. public function AddCondition_FullText($sFullText)
  283. {
  284. $this->m_aFullText[] = $sFullText;
  285. }
  286. protected function AddToNameSpace(&$aClassAliases, &$aAliasTranslation)
  287. {
  288. $sOrigAlias = $this->GetClassAlias();
  289. if (array_key_exists($sOrigAlias, $aClassAliases))
  290. {
  291. $sNewAlias = MetaModel::GenerateUniqueAlias($aClassAliases, $sOrigAlias, $this->GetClass());
  292. $this->m_aSelectedClasses[$sNewAlias] = $this->GetClass();
  293. unset($this->m_aSelectedClasses[$sOrigAlias]);
  294. // Translate the condition expression with the new alias
  295. $aAliasTranslation[$sOrigAlias]['*'] = $sNewAlias;
  296. }
  297. // add the alias into the filter aliases list
  298. $aClassAliases[$this->GetClassAlias()] = $this->GetClass();
  299. foreach($this->m_aPointingTo as $sExtKeyAttCode=>$oFilter)
  300. {
  301. $oFilter->AddToNameSpace($aClassAliases, $aAliasTranslation);
  302. }
  303. foreach($this->m_aReferencedBy as $sForeignClass=>$aReferences)
  304. {
  305. foreach($aReferences as $sForeignExtKeyAttCode=>$oForeignFilter)
  306. {
  307. $oForeignFilter->AddToNameSpace($aClassAliases, $aAliasTranslation);
  308. }
  309. }
  310. }
  311. public function AddCondition_PointingTo(DBObjectSearch $oFilter, $sExtKeyAttCode)
  312. {
  313. $aAliasTranslation = array();
  314. $res = $this->AddCondition_PointingTo_InNameSpace($oFilter, $sExtKeyAttCode, $this->m_aClasses, $aAliasTranslation);
  315. $this->TransferConditionExpression($oFilter, $aAliasTranslation);
  316. return $res;
  317. }
  318. protected function AddCondition_PointingTo_InNameSpace(DBObjectSearch $oFilter, $sExtKeyAttCode, &$aClassAliases, &$aAliasTranslation)
  319. {
  320. if (!MetaModel::IsValidKeyAttCode($this->GetClass(), $sExtKeyAttCode))
  321. {
  322. throw new CoreWarning("The attribute code '$sExtKeyAttCode' is not an external key of the class '{$this->GetClass()}' - the condition will be ignored");
  323. }
  324. $oAttExtKey = MetaModel::GetAttributeDef($this->GetClass(), $sExtKeyAttCode);
  325. if(!MetaModel::IsSameFamilyBranch($oFilter->GetClass(), $oAttExtKey->GetTargetClass()))
  326. {
  327. throw new CoreException("The specified filter (pointing to {$oFilter->GetClass()}) is not compatible with the key '{$this->GetClass()}::$sExtKeyAttCode', which is pointing to {$oAttExtKey->GetTargetClass()}");
  328. }
  329. if (array_key_exists($sExtKeyAttCode, $this->m_aPointingTo))
  330. {
  331. $this->m_aPointingTo[$sExtKeyAttCode]->MergeWith_InNamespace($oFilter, $aClassAliases, $aAliasTranslation);
  332. }
  333. else
  334. {
  335. $oFilter->AddToNamespace($aClassAliases, $aAliasTranslation);
  336. // #@# The condition expression found in that filter should not be used - could be another kind of structure like a join spec tree !!!!
  337. // $oNewFilter = clone $oFilter;
  338. // $oNewFilter->ResetCondition();
  339. $this->m_aPointingTo[$sExtKeyAttCode] = $oFilter;
  340. }
  341. }
  342. public function AddCondition_ReferencedBy(DBObjectSearch $oFilter, $sForeignExtKeyAttCode)
  343. {
  344. $aAliasTranslation = array();
  345. $res = $this->AddCondition_ReferencedBy_InNameSpace($oFilter, $sForeignExtKeyAttCode, $this->m_aClasses, $aAliasTranslation);
  346. $this->TransferConditionExpression($oFilter, $aAliasTranslation);
  347. return $res;
  348. }
  349. protected function AddCondition_ReferencedBy_InNameSpace(DBObjectSearch $oFilter, $sForeignExtKeyAttCode, &$aClassAliases, &$aAliasTranslation)
  350. {
  351. $sForeignClass = $oFilter->GetClass();
  352. $sForeignClassAlias = $oFilter->GetClassAlias();
  353. if (!MetaModel::IsValidKeyAttCode($sForeignClass, $sForeignExtKeyAttCode))
  354. {
  355. throw new CoreException("The attribute code '$sForeignExtKeyAttCode' is not an external key of the class '{$sForeignClass}' - the condition will be ignored");
  356. }
  357. $oAttExtKey = MetaModel::GetAttributeDef($sForeignClass, $sForeignExtKeyAttCode);
  358. if(!MetaModel::IsSameFamilyBranch($this->GetClass(), $oAttExtKey->GetTargetClass()))
  359. {
  360. throw new CoreException("The specified filter (objects referencing an object of class {$this->GetClass()}) is not compatible with the key '{$sForeignClass}::$sForeignExtKeyAttCode', which is pointing to {$oAttExtKey->GetTargetClass()}");
  361. }
  362. if (array_key_exists($sForeignClass, $this->m_aReferencedBy) && array_key_exists($sForeignExtKeyAttCode, $this->m_aReferencedBy[$sForeignClass]))
  363. {
  364. $this->m_aReferencedBy[$sForeignClass][$sForeignExtKeyAttCode]->MergeWith_InNamespace($oFilter, $aClassAliases, $aAliasTranslation);
  365. }
  366. else
  367. {
  368. $oFilter->AddToNamespace($aClassAliases, $aAliasTranslation);
  369. // #@# The condition expression found in that filter should not be used - could be another kind of structure like a join spec tree !!!!
  370. //$oNewFilter = clone $oFilter;
  371. //$oNewFilter->ResetCondition();
  372. $this->m_aReferencedBy[$sForeignClass][$sForeignExtKeyAttCode]= $oFilter;
  373. }
  374. }
  375. public function AddCondition_LinkedTo(DBObjectSearch $oLinkFilter, $sExtKeyAttCodeToMe, $sExtKeyAttCodeTarget, DBObjectSearch $oFilterTarget)
  376. {
  377. $oLinkFilterFinal = clone $oLinkFilter;
  378. $oLinkFilterFinal->AddCondition_PointingTo($sExtKeyAttCodeToMe);
  379. $this->AddCondition_ReferencedBy($oLinkFilterFinal, $sExtKeyAttCodeToMe);
  380. }
  381. public function AddCondition_RelatedTo(DBObjectSearch $oFilter, $sRelCode, $iMaxDepth)
  382. {
  383. MyHelpers::CheckValueInArray('relation code', $sRelCode, MetaModel::EnumRelations());
  384. $this->m_aRelatedTo[] = array('flt'=>$oFilter, 'relcode'=>$sRelCode, 'maxdepth'=>$iMaxDepth);
  385. }
  386. public function MergeWith($oFilter)
  387. {
  388. $aAliasTranslation = array();
  389. $res = $this->MergeWith_InNamespace($oFilter, $this->m_aClasses, $aAliasTranslation);
  390. $this->TransferConditionExpression($oFilter, $aAliasTranslation);
  391. return $res;
  392. }
  393. protected function MergeWith_InNamespace($oFilter, &$aClassAliases, &$aAliasTranslation)
  394. {
  395. if ($this->GetClass() != $oFilter->GetClass())
  396. {
  397. throw new CoreException("Attempting to merge a filter of class '{$this->GetClass()}' with a filter of class '{$oFilter->GetClass()}'");
  398. }
  399. // Translate search condition into our aliasing scheme
  400. $aAliasTranslation[$oFilter->GetClassAlias()]['*'] = $this->GetClassAlias();
  401. $this->m_aFullText = array_merge($this->m_aFullText, $oFilter->m_aFullText);
  402. $this->m_aRelatedTo = array_merge($this->m_aRelatedTo, $oFilter->m_aRelatedTo);
  403. foreach($oFilter->m_aPointingTo as $sExtKeyAttCode=>$oExtFilter)
  404. {
  405. $this->AddCondition_PointingTo_InNamespace($oExtFilter, $sExtKeyAttCode, $aClassAliases, $aAliasTranslation);
  406. }
  407. foreach($oFilter->m_aReferencedBy as $sForeignClass => $aReferences)
  408. {
  409. foreach($aReferences as $sForeignExtKeyAttCode => $oForeignFilter)
  410. {
  411. $this->AddCondition_ReferencedBy_InNamespace($oForeignFilter, $sForeignExtKeyAttCode, $aClassAliases, $aAliasTranslation);
  412. }
  413. }
  414. }
  415. public function GetCriteria() {return $this->m_oSearchCondition;}
  416. public function GetCriteria_FullText() {return $this->m_aFullText;}
  417. public function GetCriteria_PointingTo($sKeyAttCode = "")
  418. {
  419. if (empty($sKeyAttCode))
  420. {
  421. return $this->m_aPointingTo;
  422. }
  423. if (!array_key_exists($sKeyAttCode, $this->m_aPointingTo)) return null;
  424. return $this->m_aPointingTo[$sKeyAttCode];
  425. }
  426. public function GetCriteria_ReferencedBy($sRemoteClass = "", $sForeignExtKeyAttCode = "")
  427. {
  428. if (empty($sRemoteClass))
  429. {
  430. return $this->m_aReferencedBy;
  431. }
  432. if (!array_key_exists($sRemoteClass, $this->m_aReferencedBy)) return null;
  433. if (empty($sForeignExtKeyAttCode))
  434. {
  435. return $this->m_aReferencedBy[$sRemoteClass];
  436. }
  437. if (!array_key_exists($sForeignExtKeyAttCode, $this->m_aReferencedBy[$sRemoteClass])) return null;
  438. return $this->m_aReferencedBy[$sRemoteClass][$sForeignExtKeyAttCode];
  439. }
  440. public function GetCriteria_RelatedTo()
  441. {
  442. return $this->m_aRelatedTo;
  443. }
  444. public function GetInternalParams()
  445. {
  446. return $this->m_aParams;
  447. }
  448. public function RenderCondition()
  449. {
  450. return $this->m_oSearchCondition->Render($this->m_aParams, false);
  451. }
  452. public function serialize($bDevelopParams = false, $aContextParams = null)
  453. {
  454. $sOql = $this->ToOql($bDevelopParams, $aContextParams);
  455. return base64_encode(serialize(array($sOql, $this->m_aParams)));
  456. }
  457. static public function unserialize($sValue)
  458. {
  459. $aData = unserialize(base64_decode($sValue));
  460. $sOql = $aData[0];
  461. $aParams = $aData[1];
  462. // We've tried to use gzcompress/gzuncompress, but for some specific queries
  463. // it was not working at all (See Trac #193)
  464. // gzuncompress was issuing a warning "data error" and the return object was null
  465. return self::FromOQL($sOql, $aParams);
  466. }
  467. // SImple BUt Structured Query Languag - SubuSQL
  468. //
  469. static private function Value2Expression($value)
  470. {
  471. $sRet = $value;
  472. if (is_array($value))
  473. {
  474. $sRet = VS_START.implode(', ', $value).VS_END;
  475. }
  476. else if (!is_numeric($value))
  477. {
  478. $sRet = "'".addslashes($value)."'";
  479. }
  480. return $sRet;
  481. }
  482. static private function Expression2Value($sExpr)
  483. {
  484. $retValue = $sExpr;
  485. if ((substr($sExpr, 0, 1) == "'") && (substr($sExpr, -1, 1) == "'"))
  486. {
  487. $sNoQuotes = substr($sExpr, 1, -1);
  488. return stripslashes($sNoQuotes);
  489. }
  490. if ((substr($sExpr, 0, 1) == VS_START) && (substr($sExpr, -1, 1) == VS_END))
  491. {
  492. $sNoBracket = substr($sExpr, 1, -1);
  493. $aRetValue = array();
  494. foreach (explode(",", $sNoBracket) as $sItem)
  495. {
  496. $aRetValue[] = self::Expression2Value(trim($sItem));
  497. }
  498. return $aRetValue;
  499. }
  500. return $retValue;
  501. }
  502. // Alternative to object mapping: the data are transfered directly into an array
  503. // This is 10 times faster than creating a set of objects, and makes sense when optimization is required
  504. public function ToDataArray($aColumns = array(), $aOrderBy = array(), $aArgs = array())
  505. {
  506. $sSQL = MetaModel::MakeSelectQuery($this, $aOrderBy, $aArgs);
  507. $resQuery = CMDBSource::Query($sSQL);
  508. if (!$resQuery) return;
  509. if (count($aColumns) == 0)
  510. {
  511. $aColumns = array_keys(MetaModel::ListAttributeDefs($this->GetClass()));
  512. // Add the standard id (as first column)
  513. array_unshift($aColumns, 'id');
  514. }
  515. $aQueryCols = CMDBSource::GetColumns($resQuery);
  516. $sClassAlias = $this->GetClassAlias();
  517. $aColMap = array();
  518. foreach ($aColumns as $sAttCode)
  519. {
  520. $sColName = $sClassAlias.$sAttCode;
  521. if (in_array($sColName, $aQueryCols))
  522. {
  523. $aColMap[$sAttCode] = $sColName;
  524. }
  525. }
  526. $aRes = array();
  527. while ($aRow = CMDBSource::FetchArray($resQuery))
  528. {
  529. $aMappedRow = array();
  530. foreach ($aColMap as $sAttCode => $sColName)
  531. {
  532. $aMappedRow[$sAttCode] = $aRow[$sColName];
  533. }
  534. $aRes[] = $aMappedRow;
  535. }
  536. CMDBSource::FreeResult($resQuery);
  537. return $aRes;
  538. }
  539. public function ToOQL($bDevelopParams = false, $aContextParams = null)
  540. {
  541. // Currently unused, but could be useful later
  542. $bRetrofitParams = false;
  543. if ($bDevelopParams)
  544. {
  545. if (is_null($aContextParams))
  546. {
  547. $aParams = array_merge($this->m_aParams);
  548. }
  549. else
  550. {
  551. $aParams = array_merge($aContextParams, $this->m_aParams);
  552. }
  553. }
  554. else
  555. {
  556. // Leave it as is, the rendering will be made with parameters in clear
  557. $aParams = null;
  558. }
  559. $sSelectedClasses = implode(', ', array_keys($this->m_aSelectedClasses));
  560. $sRes = 'SELECT '.$sSelectedClasses.' FROM';
  561. $sRes .= ' '.$this->GetClass().' AS '.$this->GetClassAlias();
  562. $sRes .= $this->ToOQL_Joins();
  563. $sRes .= " WHERE ".$this->m_oSearchCondition->Render($aParams, $bRetrofitParams);
  564. // Temporary: add more info about other conditions, necessary to avoid strange behaviors with the cache
  565. foreach($this->m_aFullText as $sFullText)
  566. {
  567. $sRes .= " AND MATCHES '$sFullText'";
  568. }
  569. return $sRes;
  570. }
  571. protected function ToOQL_Joins()
  572. {
  573. $sRes = '';
  574. foreach($this->m_aPointingTo as $sExtKey=>$oFilter)
  575. {
  576. $sRes .= ' JOIN '.$oFilter->GetClass().' AS '.$oFilter->GetClassAlias().' ON '.$this->GetClassAlias().'.'.$sExtKey.' = '.$oFilter->GetClassAlias().'.id';
  577. $sRes .= $oFilter->ToOQL_Joins();
  578. }
  579. foreach($this->m_aReferencedBy as $sForeignClass=>$aReferences)
  580. {
  581. foreach($aReferences as $sForeignExtKeyAttCode=>$oForeignFilter)
  582. {
  583. $sRes .= ' JOIN '.$oForeignFilter->GetClass().' AS '.$oForeignFilter->GetClassAlias().' ON '.$oForeignFilter->GetClassAlias().'.'.$sForeignExtKeyAttCode.' = '.$this->GetClassAlias().'.id';
  584. $sRes .= $oForeignFilter->ToOQL_Joins();
  585. }
  586. }
  587. return $sRes;
  588. }
  589. protected function OQLExpressionToCondition($sQuery, $oExpression, $aClassAliases)
  590. {
  591. if ($oExpression instanceof BinaryOqlExpression)
  592. {
  593. $sOperator = $oExpression->GetOperator();
  594. $oLeft = $this->OQLExpressionToCondition($sQuery, $oExpression->GetLeftExpr(), $aClassAliases);
  595. $oRight = $this->OQLExpressionToCondition($sQuery, $oExpression->GetRightExpr(), $aClassAliases);
  596. return new BinaryExpression($oLeft, $sOperator, $oRight);
  597. }
  598. elseif ($oExpression instanceof FieldOqlExpression)
  599. {
  600. $sClassAlias = $oExpression->GetParent();
  601. $sFltCode = $oExpression->GetName();
  602. if (empty($sClassAlias))
  603. {
  604. // Try to find an alias
  605. // Build an array of field => array of aliases
  606. $aFieldClasses = array();
  607. foreach($aClassAliases as $sAlias => $sReal)
  608. {
  609. foreach(MetaModel::GetFiltersList($sReal) as $sAnFltCode)
  610. {
  611. $aFieldClasses[$sAnFltCode][] = $sAlias;
  612. }
  613. }
  614. if (!array_key_exists($sFltCode, $aFieldClasses))
  615. {
  616. throw new OqlNormalizeException('Unknown filter code', $sQuery, $oExpression->GetNameDetails(), array_keys($aFieldClasses));
  617. }
  618. if (count($aFieldClasses[$sFltCode]) > 1)
  619. {
  620. throw new OqlNormalizeException('Ambiguous filter code', $sQuery, $oExpression->GetNameDetails());
  621. }
  622. $sClassAlias = $aFieldClasses[$sFltCode][0];
  623. }
  624. else
  625. {
  626. if (!array_key_exists($sClassAlias, $aClassAliases))
  627. {
  628. throw new OqlNormalizeException('Unknown class [alias]', $sQuery, $oExpression->GetParentDetails(), array_keys($aClassAliases));
  629. }
  630. $sClass = $aClassAliases[$sClassAlias];
  631. if (!MetaModel::IsValidFilterCode($sClass, $sFltCode))
  632. {
  633. throw new OqlNormalizeException('Unknown filter code', $sQuery, $oExpression->GetNameDetails(), MetaModel::GetFiltersList($sClass));
  634. }
  635. }
  636. return new FieldExpression($sFltCode, $sClassAlias);
  637. }
  638. elseif ($oExpression instanceof VariableOqlExpression)
  639. {
  640. return new VariableExpression($oExpression->GetName());
  641. }
  642. elseif ($oExpression instanceof TrueOqlExpression)
  643. {
  644. return new TrueExpression;
  645. }
  646. elseif ($oExpression instanceof ScalarOqlExpression)
  647. {
  648. return new ScalarExpression($oExpression->GetValue());
  649. }
  650. elseif ($oExpression instanceof ListOqlExpression)
  651. {
  652. $aItems = array();
  653. foreach ($oExpression->GetItems() as $oItemExpression)
  654. {
  655. $aItems[] = $this->OQLExpressionToCondition($sQuery, $oItemExpression, $aClassAliases);
  656. }
  657. return new ListExpression($aItems);
  658. }
  659. elseif ($oExpression instanceof FunctionOqlExpression)
  660. {
  661. $aArgs = array();
  662. foreach ($oExpression->GetArgs() as $oArgExpression)
  663. {
  664. $aArgs[] = $this->OQLExpressionToCondition($sQuery, $oArgExpression, $aClassAliases);
  665. }
  666. return new FunctionExpression($oExpression->GetVerb(), $aArgs);
  667. }
  668. elseif ($oExpression instanceof IntervalOqlExpression)
  669. {
  670. return new IntervalExpression($oExpression->GetValue(), $oExpression->GetUnit());
  671. }
  672. else
  673. {
  674. throw new CoreException('Unknown expression type', array('class'=>get_class($oExpression), 'query'=>$sQuery));
  675. }
  676. }
  677. // Create a search definition that leads to 0 result, still a valid search object
  678. static public function FromEmptySet($sClass)
  679. {
  680. $oResultFilter = new DBObjectSearch($sClass);
  681. $oResultFilter->m_oSearchCondition = new FalseExpression;
  682. return $oResultFilter;
  683. }
  684. static protected $m_aOQLQueries = array();
  685. // Do not filter out depending on user rights
  686. // In particular when we are currently in the process of evaluating the user rights...
  687. static public function FromOQL_AllData($sQuery, $aParams = null)
  688. {
  689. $oRes = self::FromOQL($sQuery, $aParams);
  690. $oRes->AllowAllData();
  691. return $oRes;
  692. }
  693. static public function FromOQL($sQuery, $aParams = null)
  694. {
  695. if (empty($sQuery)) return null;
  696. // Query caching
  697. $bOQLCacheEnabled = true;
  698. if ($bOQLCacheEnabled && array_key_exists($sQuery, self::$m_aOQLQueries))
  699. {
  700. // hit!
  701. return clone self::$m_aOQLQueries[$sQuery];
  702. }
  703. $oOql = new OqlInterpreter($sQuery);
  704. $oOqlQuery = $oOql->ParseObjectQuery();
  705. $sClass = $oOqlQuery->GetClass();
  706. $sClassAlias = $oOqlQuery->GetClassAlias();
  707. if (!MetaModel::IsValidClass($sClass))
  708. {
  709. throw new OqlNormalizeException('Unknown class', $sQuery, $oOqlQuery->GetClassDetails(), MetaModel::GetClasses());
  710. }
  711. $oResultFilter = new DBObjectSearch($sClass, $sClassAlias);
  712. $aAliases = array($sClassAlias => $sClass);
  713. // Maintain an array of filters, because the flat list is in fact referring to a tree
  714. // And this will be an easy way to dispatch the conditions
  715. // $oResultFilter will be referenced by the other filters, or the other way around...
  716. $aJoinItems = array($sClassAlias => $oResultFilter);
  717. $aJoinSpecs = $oOqlQuery->GetJoins();
  718. if (is_array($aJoinSpecs))
  719. {
  720. foreach ($aJoinSpecs as $oJoinSpec)
  721. {
  722. $sJoinClass = $oJoinSpec->GetClass();
  723. $sJoinClassAlias = $oJoinSpec->GetClassAlias();
  724. if (!MetaModel::IsValidClass($sJoinClass))
  725. {
  726. throw new OqlNormalizeException('Unknown class', $sQuery, $oJoinSpec->GetClassDetails(), MetaModel::GetClasses());
  727. }
  728. if (array_key_exists($sJoinClassAlias, $aAliases))
  729. {
  730. if ($sJoinClassAlias != $sJoinClass)
  731. {
  732. throw new OqlNormalizeException('Duplicate class alias', $sQuery, $oJoinSpec->GetClassAliasDetails());
  733. }
  734. else
  735. {
  736. throw new OqlNormalizeException('Duplicate class name', $sQuery, $oJoinSpec->GetClassDetails());
  737. }
  738. }
  739. // Assumption: ext key on the left only !!!
  740. // normalization should take care of this
  741. $oLeftField = $oJoinSpec->GetLeftField();
  742. $sFromClass = $oLeftField->GetParent();
  743. $sExtKeyAttCode = $oLeftField->GetName();
  744. $oRightField = $oJoinSpec->GetRightField();
  745. $sToClass = $oRightField->GetParent();
  746. $sPKeyDescriptor = $oRightField->GetName();
  747. if ($sPKeyDescriptor != 'id')
  748. {
  749. throw new OqlNormalizeException('Wrong format for Join clause (right hand), expecting an id', $sQuery, $oRightField->GetNameDetails(), array('id'));
  750. }
  751. $aAliases[$sJoinClassAlias] = $sJoinClass;
  752. $aJoinItems[$sJoinClassAlias] = new DBObjectSearch($sJoinClass, $sJoinClassAlias);
  753. if (!array_key_exists($sFromClass, $aJoinItems))
  754. {
  755. throw new OqlNormalizeException('Unknown class in join condition (left expression)', $sQuery, $oLeftField->GetParentDetails(), array_keys($aJoinItems));
  756. }
  757. if (!array_key_exists($sToClass, $aJoinItems))
  758. {
  759. throw new OqlNormalizeException('Unknown class in join condition (right expression)', $sQuery, $oRightField->GetParentDetails(), array_keys($aJoinItems));
  760. }
  761. $aExtKeys = array_keys(MetaModel::GetExternalKeys($aAliases[$sFromClass]));
  762. if (!in_array($sExtKeyAttCode, $aExtKeys))
  763. {
  764. throw new OqlNormalizeException('Unknown external key in join condition (left expression)', $sQuery, $oLeftField->GetNameDetails(), $aExtKeys);
  765. }
  766. if ($sFromClass == $sJoinClassAlias)
  767. {
  768. $aJoinItems[$sToClass]->AddCondition_ReferencedBy($aJoinItems[$sFromClass], $sExtKeyAttCode);
  769. }
  770. else
  771. {
  772. $aJoinItems[$sFromClass]->AddCondition_PointingTo($aJoinItems[$sToClass], $sExtKeyAttCode);
  773. }
  774. }
  775. }
  776. // Check and prepare the select information
  777. $aSelected = array();
  778. foreach ($oOqlQuery->GetSelectedClasses() as $oClassDetails)
  779. {
  780. $sClassToSelect = $oClassDetails->GetValue();
  781. if (!array_key_exists($sClassToSelect, $aAliases))
  782. {
  783. throw new OqlNormalizeException('Unknown class [alias]', $sQuery, $oClassDetails, array_keys($aAliases));
  784. }
  785. $aSelected[$sClassToSelect] = $aAliases[$sClassToSelect];
  786. }
  787. $oResultFilter->m_aClasses = $aAliases;
  788. $oResultFilter->SetSelectedClasses($aSelected);
  789. $oConditionTree = $oOqlQuery->GetCondition();
  790. if ($oConditionTree instanceof Expression)
  791. {
  792. $oResultFilter->m_oSearchCondition = $oResultFilter->OQLExpressionToCondition($sQuery, $oConditionTree, $aAliases);
  793. }
  794. if (!is_null($aParams))
  795. {
  796. $oResultFilter->m_aParams = $aParams;
  797. }
  798. if ($bOQLCacheEnabled)
  799. {
  800. self::$m_aOQLQueries[$sQuery] = clone $oResultFilter;
  801. }
  802. return $oResultFilter;
  803. }
  804. public function toxpath()
  805. {
  806. // #@# a voir...
  807. }
  808. static public function fromxpath()
  809. {
  810. // #@# a voir...
  811. }
  812. }
  813. ?>