/**
* Core test list
*
* @copyright Copyright (C) 2010-2017 Combodo SARL
* @license http://opensource.org/licenses/AGPL-3.0
*/
class TestBeHappy extends TestHandler // TestFunctionInOut, TestBizModel...
{
static public function GetName()
{
return 'Be happy!';
}
static public function GetDescription()
{
return 'Sample test with success';
}
protected function DoExecute()
{
echo "Am I happy?
";
echo "Yes, I am!
";
}
}
class TestBeSad extends TestHandler
{
static public function GetName()
{
return 'Be sad...';
}
static public function GetDescription()
{
return 'Sample test with failure';
}
protected function DoExecute()
{
echo "Am I happy?";
throw new Exception('jamais content');
}
}
class TestSQLQuery extends TestScenarioOnDB
{
static public function GetName() {return 'SQLQuery';}
static public function GetDescription() {return 'SQLQuery does not depend on the rest of the framework, therefore it makes sense to have a separate test framework for it';}
static public function GetDBHost() {return 'localhost';}
static public function GetDBUser() {return 'root';}
static public function GetDBPwd() {return '';}
static public function GetDBName() {return 'TestSQLQuery';}
static public function GetDBSubName() {return 'taratata';}
protected function DoPrepare()
{
parent::DoPrepare();
cmdbSource::CreateTable('CREATE TABLE `myTable` (myKey INT(11) NOT NULL auto_increment, column1 VARCHAR(255), column2 VARCHAR(255), PRIMARY KEY (`myKey`)) ENGINE = '.MYSQL_ENGINE);
cmdbSource::CreateTable('CREATE TABLE `myTable1` (myKey1 INT(11) NOT NULL auto_increment, column1_1 VARCHAR(255), column1_2 VARCHAR(255), PRIMARY KEY (`myKey1`)) ENGINE = '.MYSQL_ENGINE);
cmdbSource::CreateTable('CREATE TABLE `myTable2` (myKey2 INT(11) NOT NULL auto_increment, column2_1 VARCHAR(255), column2_2 VARCHAR(255), PRIMARY KEY (`myKey2`)) ENGINE = '.MYSQL_ENGINE);
}
protected function DoExecute()
{
$oQuery = new SQLObjectQuery(
$sTable = 'myTable',
$sTableAlias = 'myTableAlias',
$aFields = array('column1'=>new FieldExpression('column1', 'myTableAlias'), 'column2'=>new FieldExpression('column2', 'myTableAlias')),
// $aFullTextNeedles = array('column1'),
$bToDelete = false,
$aValues = array()
);
$oQuery->AddCondition(Expression::FromOQL('DATE(NOW() - 1200 * 2) > \'2008-07-31\''));
$oSubQuery1 = new SQLObjectQuery(
$sTable = 'myTable1',
$sTableAlias = 'myTable1Alias',
$aFields = array('column1_1'=>new FieldExpression('column1', 'myTableAlias'), 'column1_2'=>new FieldExpression('column1', 'myTableAlias')),
// $aFullTextNeedles = array(),
$bToDelete = false,
$aValues = array()
);
$oSubQuery2 = new SQLObjectQuery(
$sTable = 'myTable2',
$sTableAlias = 'myTable2Alias',
$aFields = array('column2_1'=>new FieldExpression('column2', 'myTableAlias'), 'column2_2'=>new FieldExpression('column2', 'myTableAlias')),
// $aFullTextNeedles = array(),
$bToDelete = false,
$aValues = array()
);
$oQuery->AddInnerJoin($oSubQuery1, 'column1', 'column1_1');
$oQuery->AddLeftJoin($oSubQuery2, 'column2', 'column2_2');
$oQuery->DisplayHtml();
$oQuery->RenderDelete();
$oQuery->RenderUpdate();
echo ''.$oQuery->RenderSelect().'
';
$oQuery->RenderSelect(array('column1'));
$oQuery->RenderSelect(array('column1', 'column2'));
}
}
class TestOQLParser extends TestFunction
{
static public function GetName() {return 'Check OQL parsing';}
static public function GetDescription() {return 'Attempts a series of queries, and in particular those with a bad syntax';}
protected function CheckQuery($sQuery, $bIsCorrectQuery)
{
$oOql = new OqlInterpreter($sQuery);
try
{
$oTrash = $oOql->Parse(); // Not expecting a given format, otherwise use ParseExpression/ParseObjectQuery/ParseValueSetQuery
self::DumpVariable($oTrash);
}
catch (OQLException $OqlException)
{
if ($bIsCorrectQuery)
{
echo "More info on this unexpected failure:
".$OqlException->getHtmlDesc()."
\n";
throw $OqlException;
return false;
}
else
{
// Everything is fine :-)
echo "More info on this expected failure:
".$OqlException->getHtmlDesc()."
\n";
return true;
}
}
catch (Exception $e)
{
if ($bIsCorrectQuery)
{
echo "More info on this unexpected failure:
".htmlentities($e->getMessage(), ENT_QUOTES, 'UTF-8')."
\n";
throw $OqlException;
return false;
}
else
{
// Everything is fine :-)
echo "More info on this expected failure:
".htmlentities($e->getMessage(), ENT_QUOTES, 'UTF-8')."
\n";
return true;
}
}
// The query was correctly parsed, was it expected to be correct ?
if ($bIsCorrectQuery)
{
return true;
}
else
{
throw new UnitTestException("The query '$sQuery' was parsed with success, while it shouldn't (?)");
return false;
}
}
protected function TestQuery($sQuery, $bIsCorrectQuery)
{
if (!$this->CheckQuery($sQuery, $bIsCorrectQuery))
{
return false;
}
return true;
}
public function DoExecute()
{
$aQueries = array(
'SELECT toto' => true,
'SELECT toto WHERE toto.a = 1' => true,
'SELECT toto WHERE toto.a = -1' => true,
'SELECT toto WHERE toto.a = (1-1)' => true,
'SELECT toto WHERE toto.a = (-1+3)' => true,
'SELECT toto WHERE toto.a = (3+-1)' => true,
'SELECT toto WHERE toto.a = (3--1)' => true,
'SELECT toto WHERE toto.a = (3++1)' => false,
'SELECT toto WHERE toto.a = 0xC' => true,
'SELECT toto WHERE toto.a = \'AXDVFS0xCZ32\'' => true,
'SELECT toto WHERE toto.a = :myparameter' => true,
'SELECT toto WHERE toto.a IN (:param1)' => true,
'SELECT toto WHERE toto.a IN (:param1, :param2)' => true,
'SELECT toto WHERE toto.a=1' => true,
'SELECT toto WHERE toto.a = "1"' => true,
'SELECT toto WHHHERE toto.a = "1"' => false,
'SELECT toto WHERE toto.a == "1"' => false,
'SELECT toto WHERE toto.a % 1' => false,
'SELECT toto WHERE toto.a & 1' => true, // bitwise and
'SELECT toto WHERE toto.a | 1' => true, // bitwise or
'SELECT toto WHERE toto.a ^ 1' => true, // bitwise xor
'SELECT toto WHERE toto.a << 1' => true, // bitwise left shift
'SELECT toto WHERE toto.a >> 1' => true, // bitwise right shift
//'SELECT toto WHERE toto.a LIKE 1' => false,
'SELECT toto WHERE toto.a like \'arg\'' => false,
'SELECT toto WHERE toto.a NOT LIKE "That\'s it"' => true,
'SELECT toto WHERE toto.a NOT LIKE "That\'s "it""' => false,
'SELECT toto WHERE toto.a NOT LIKE "That\'s \\"it\\""' => true,
'SELECT toto WHERE toto.a NOT LIKE \'That"s it\'' => true,
'SELECT toto WHERE toto.a NOT LIKE \'That\'s it\'' => false,
'SELECT toto WHERE toto.a NOT LIKE \'That\\\'s it\'' => true,
'SELECT toto WHERE toto.a NOT LIKE "blah \\ truc"' => false,
'SELECT toto WHERE toto.a NOT LIKE "blah \\\\ truc"' => true,
'SELECT toto WHERE toto.a NOT LIKE \'blah \\ truc\'' => false,
'SELECT toto WHERE toto.a NOT LIKE \'blah \\\\ truc\'' => true,
'SELECT toto WHERE toto.a NOT LIKE "\\\\"' => true,
'SELECT toto WHERE toto.a NOT LIKE "\\""' => true,
'SELECT toto WHERE toto.a NOT LIKE "\\"\\\\"' => true,
'SELECT toto WHERE toto.a NOT LIKE "\\\\\\""' => true,
'SELECT toto WHERE toto.a NOT LIKE ""' => true,
'SELECT toto WHERE toto.a NOT LIKE "\\\\"' => true,
"SELECT UserRightsMatrixClassGrant WHERE UserRightsMatrixClassGrant.class = 'lnkContactRealObject' AND UserRightsMatrixClassGrant.action = 'modify' AND UserRightsMatrixClassGrant.login = 'Denis'" => true,
"SELECT A WHERE A.col1 = 'lit1' AND A.col2 = 'lit2' AND A.col3 = 'lit3'" => true,
'SELECT toto WHERE toto.a NOT LIKE "blah" AND toto.b LIKE "foo"' => true,
//'SELECT toto WHERE toto.a > \'asd\'' => false,
'SELECT toto WHERE toto.a = 1 AND toto.b LIKE "x" AND toto.f >= 12345' => true,
'SELECT Device JOIN Site ON Device.site = Site.id' => true,
'SELECT Device JOIN Site ON Device.site = Site.id JOIN Country ON Site.location = Country.id' => true,
"SELECT A JOIN B ON A.myB = B.id WHERE (A.col1 = 123 AND B.col1 = 'aa') OR (A.col3 = 'zzz' AND B.col4 > 100)" => true,
"SELECT A JOIN B ON A.myB = B.id WHERE (A.col1 = B.col2 AND B.col1 = A.col2) OR (A.col3 = '' AND B.col4 > 100)" => true,
"SELECT A JOIN B ON A.myB = B.id WHERE A.col1 + B.col2 * B.col1 = A.col2" => true,
"SELECT A JOIN B ON A.myB = B.id WHERE A.col1 + (B.col2 * B.col1) = A.col2" => true,
"SELECT A JOIN B ON A.myB = B.id WHERE (A.col1 + B.col2) * B.col1 = A.col2" => true,
"SELECT A JOIN B ON A.myB = B.id WHERE (A.col1 & B.col2) = A.col2" => true,
'SELECT Device AS D_ JOIN Site AS S_ ON D_.site = S_.id WHERE S_.country = "Francia"' => true,
// Several objects in a row...
//
'SELECT A FROM A' => true,
'SELECT A JOIN B ON A.myB = B.id WHERE A.col1 = 2' => true,
'SELECT A FROM A JOIN B ON A.myB = B.id WHERE A.col1 = 2' => true,
'SELECT B FROM A JOIN B ON A.myB = B.id WHERE A.col1 = 2' => true,
'SELECT A,B FROM A JOIN B ON A.myB = B.id WHERE A.col1 = 2' => true,
'SELECT A, B FROM A JOIN B ON A.myB = B.id WHERE A.col1 = 2' => true,
'SELECT B,A FROM A JOIN B ON A.myB = B.id WHERE A.col1 = 2' => true,
'SELECT A, B,C FROM A JOIN B ON A.myB = B.id' => true,
'SELECT C FROM A JOIN B ON A.myB = B.id WHERE A.col1 = 2' => true,
'SELECT A JOIN B ON A.myB BELOW B.id WHERE A.col1 = 2' => true,
'SELECT A JOIN B ON B.myA BELOW A.id WHERE A.col1 = 2' => true,
'SELECT A JOIN B ON A.myB = B.id JOIN C ON C.parent_id BELOW B.id WHERE A.col1 = 2 AND B.id = 3' => true,
'SELECT A JOIN B ON A.myB = B.id JOIN C ON C.parent_id BELOW STRICT B.id WHERE A.col1 = 2 AND B.id = 3' => true,
'SELECT A JOIN B ON A.myB = B.id JOIN C ON C.parent_id NOT BELOW B.id WHERE A.col1 = 2 AND B.id = 3' => true,
'SELECT A JOIN B ON A.myB = B.id JOIN C ON C.parent_id NOT BELOW STRICT B.id WHERE A.col1 = 2 AND B.id = 3' => true,
'SELECT A JOIN B ON A.myB = B.id JOIN C ON C.parent_id = B.id WHERE A.col1 BELOW 2 AND B.id = 3' => false,
// Unions
//
'SELECT A UNION SELECT B' => true,
'SELECT A WHERE A.b = "sdf" UNION SELECT B WHERE B.a = "sfde"' => true,
'SELECT A UNION SELECT B UNION SELECT C' => true,
'SELECT A UNION SELECT B UNION SELECT C UNION SELECT D' => true,
'SELECT A JOIN B ON A.myB = B.id JOIN C ON C.parent_id NOT BELOW B.id WHERE A.col1 = 2 AND B.id = 3 UNION SELECT Device JOIN Site ON Device.site = Site.id JOIN Country ON Site.location = Country.id' => true,
);
$iErrors = 0;
foreach($aQueries as $sQuery => $bIsCorrectQuery)
{
$sIsOk = $bIsCorrectQuery ? 'good' : 'bad';
echo "Testing query: $sQuery ($sIsOk)
\n";
try
{
$bRet = $this->TestQuery($sQuery, $bIsCorrectQuery);
}
catch(Exception $e)
{
$this->m_aErrors[] = $e->getMessage();
$bRet = false;
}
if (!$bRet) $iErrors++;
}
return ($iErrors == 0);
}
}
class TestOQLNormalization extends TestBizModel
{
static public function GetName() {return 'Check OQL normalization';}
static public function GetDescription() {return 'Attempts a series of queries, and in particular those with unknown or inconsistent class/attributes. Assumes a very standard installation!';}
protected function CheckQuery($sQuery, $bIsCorrectQuery)
{
try
{
$oSearch = DBObjectSearch::FromOQL($sQuery);
self::DumpVariable($sQuery);
}
catch (OQLNormalizeException $OqlException)
{
if ($bIsCorrectQuery)
{
echo "More info on this unexpected failure:
".$OqlException->getHtmlDesc()."
\n";
throw $OqlException;
return false;
}
else
{
// Everything is fine :-)
echo "More info on this expected failure:
".$OqlException->getHtmlDesc()."
\n";
return true;
}
}
catch (Exception $e)
{
if ($bIsCorrectQuery)
{
echo "More info on this unexpected failure:
".htmlentities($e->getMessage(), ENT_QUOTES, 'UTF-8')."
\n";
throw $e;
return false;
}
else
{
// Everything is fine :-)
echo "More info on this expected failure:
".htmlentities($e->getMessage(), ENT_QUOTES, 'UTF-8')."
\n";
return true;
}
}
// The query was correctly parsed, was it expected to be correct ?
if ($bIsCorrectQuery)
{
return true;
}
else
{
throw new UnitTestException("The query '$sQuery' was parsed with success, while it shouldn't (?)");
return false;
}
}
protected function TestQuery($sQuery, $bIsCorrectQuery)
{
if (!$this->CheckQuery($sQuery, $bIsCorrectQuery))
{
return false;
}
return true;
}
public function DoExecute()
{
$aQueries = array(
'SELECT Contact' => true,
'SELECT Contact WHERE nom_de_famille = "foo"' => false,
'SELECT Contact AS c WHERE name = "foo"' => true,
'SELECT Contact AS c WHERE nom_de_famille = "foo"' => false,
'SELECT Contact AS c WHERE c.name = "foo"' => true,
'SELECT Contact AS c WHERE Contact.name = "foo"' => false,
'SELECT Contact AS c WHERE x.name = "foo"' => false,
'SELECT Organization AS child JOIN Organization AS root ON child.parent_id BELOW root.id' => true,
'SELECT Organization AS root JOIN Organization AS child ON child.parent_id BELOW root.id' => true,
'SELECT RelationProfessionnelle' => false,
'SELECT RelationProfessionnelle AS c WHERE name = "foo"' => false,
// The first query is the base query altered only in one place in the subsequent queries
'SELECT Person AS p JOIN lnkPersonToTeam AS lnk ON lnk.person_id = p.id WHERE p.name LIKE "foo"' => true,
'SELECT Person AS p JOIN lnkXXXXXXXXXXXX AS lnk ON lnk.person_id = p.id WHERE p.name LIKE "foo"' => false,
'SELECT Person AS p JOIN lnkPersonToTeam AS lnk ON p.person_id = p.id WHERE p.name LIKE "foo"' => false,
'SELECT Person AS p JOIN lnkPersonToTeam AS lnk ON person_id = p.id WHERE p.name LIKE "foo"' => false,
'SELECT Person AS p JOIN lnkPersonToTeam AS lnk ON lnk.person_id = id WHERE p.name LIKE "foo"' => false,
'SELECT Person AS p JOIN lnkPersonToTeam AS lnk ON lnk.role = p.id WHERE p.name LIKE "foo"' => false,
'SELECT Person AS p JOIN lnkPersonToTeam AS lnk ON lnk.team_id = p.id WHERE p.name LIKE "foo"' => false,
'SELECT Person AS p JOIN lnkPersonToTeam AS lnk ON lnk.person_id BELOW p.id WHERE p.name LIKE "foo"' => false,
'SELECT Person AS p JOIN lnkPersonToTeam AS lnk ON lnk.person_id = p.org_id WHERE p.name LIKE "foo"' => false,
'SELECT Person AS p JOIN lnkPersonToTeam AS lnk ON p.id = lnk.person_id WHERE p.name LIKE "foo"' => false, // inverted the JOIN spec
'SELECT Person AS p JOIN lnkPersonToTeam AS lnk ON lnk.person_id = p.id WHERE name LIKE "foo"' => true,
'SELECT Person AS p JOIN lnkPersonToTeam AS lnk ON lnk.person_id = p.id WHERE x.name LIKE "foo"' => false,
'SELECT Person AS p JOIN lnkPersonToTeam AS lnk ON lnk.person_id = p.id WHERE p.eman LIKE "foo"' => false,
'SELECT Person AS p JOIN lnkPersonToTeam AS lnk ON lnk.person_id = p.id WHERE eman LIKE "foo"' => false,
'SELECT Person AS p JOIN lnkPersonToTeam AS lnk ON lnk.person_id = p.id WHERE id = 1' => false,
'SELECT Person AS p JOIN lnkPersonToTeam AS lnk ON p.id = lnk.person_id WHERE p.name LIKE "foo"' => false,
'SELECT Person AS p JOIN Organization AS o ON p.org_id = o.id WHERE p.name LIKE "foo" AND o.name LIKE "land"' => true,
'SELECT Person AS p JOIN Organization AS o ON p.location_id = o.id WHERE p.name LIKE "foo" AND o.name LIKE "land"' => false,
'SELECT Person AS p JOIN Organization AS o ON p.name = o.id WHERE p.name LIKE "foo" AND o.name LIKE "land"' => false,
'SELECT Person AS p JOIN Organization AS o ON p.org_id = o.id JOIN Person AS p ON p.org_id = o.id' => false,
'SELECT Person JOIN Organization AS o ON Person.org_id = o.id JOIN Person ON Person.org_id = o.id' => false,
'SELECT Person AS p JOIN Location AS l ON p.location_id = l.id' => true,
'SELECT Person AS p JOIN Location AS l ON p.location_id BELOW l.id' => false,
'SELECT Person FROM Person JOIN Location ON Person.location_id = Location.id' => true,
'SELECT p FROM Person AS p JOIN Location AS l ON p.location_id = l.id' => true,
'SELECT l FROM Person AS p JOIN Location AS l ON p.location_id = l.id' => true,
'SELECT l, p FROM Person AS p JOIN Location AS l ON p.location_id = l.id' => true,
'SELECT p, l FROM Person AS p JOIN Location AS l ON p.location_id = l.id' => true,
'SELECT foo FROM Person AS p JOIN Location AS l ON p.location_id = l.id' => false,
'SELECT p, foo FROM Person AS p JOIN Location AS l ON p.location_id = l.id' => false,
// Joins based on AttributeObjectKey
//
'SELECT Attachment AS a JOIN UserRequest AS r ON a.item_id = r.id' => true,
'SELECT UserRequest AS r JOIN Attachment AS a ON a.item_id = r.id' => true,
);
$iErrors = 0;
foreach($aQueries as $sQuery => $bIsCorrectQuery)
{
$sIsOk = $bIsCorrectQuery ? 'good' : 'bad';
echo "Testing query: $sQuery ($sIsOk)
\n";
try
{
$bRet = $this->TestQuery($sQuery, $bIsCorrectQuery);
}
catch(Exception $e)
{
$this->m_aErrors[] = $e->getMessage();
$bRet = false;
}
if (!$bRet) $iErrors++;
}
return ($iErrors == 0);
}
}
class TestCSVParser extends TestFunction
{
static public function GetName() {return 'Check CSV parsing';}
static public function GetDescription() {return 'Loads a set of CSV data';}
public function DoExecute()
{
$sDataFile = '?field1?;?field2?;?field3?
?a?;?b?;?c?
a;b;c
? a ? ; ? b ? ; ? c ?
a ; b ; c
??;??;??
;;
?a"?;?b?;?c?
?a1
a2?;?b?;?c?
?a1,a2?;?b?;?c?
?a?;?b?;?c1,",c2
,c3?
?a?;?b?;?ouf !?
Espace sur la fin ; 1234; e@taloc.com ';
self::DumpVariable($sDataFile);
$aExpectedResult = array(
//array('field1', 'field2', 'field3'),
array('a', 'b', 'c'),
array('a', 'b', 'c'),
array(' a ', ' b ', ' c '),
array('a', 'b', 'c'),
array('', '', ''),
array('', '', ''),
array('a"', 'b', 'c'),
array("a1\na2", 'b', 'c'),
array('a1,a2', 'b', 'c'),
array('a', 'b', "c1,\",c2\n,c3"),
array('a', 'b', 'ouf !'),
array('Espace sur la fin', '1234', 'e@taloc.com'),
);
$oCSVParser = new CSVParser($sDataFile, ';', '?');
$aData = $oCSVParser->ToArray(1, null, 0);
$iIssues = 0;
echo "\n";
foreach ($aData as $iRow => $aRow)
{
echo "\n";
foreach ($aRow as $iCol => $sCell)
{
if (empty($sCell))
{
$sCellValue = ' ';
}
else
{
$sCellValue = htmlentities($sCell, ENT_QUOTES, 'UTF-8');
}
if (!isset($aExpectedResult[$iRow][$iCol]))
{
$iIssues++;
$sCellValue = "$sCellValue";
}
elseif ($aExpectedResult[$iRow][$iCol] != $sCell)
{
$iIssues++;
$sCellValue = "$sCellValue, expecting '".$aExpectedResult[$iRow][$iCol]."'";
}
echo "$sCellValue | ";
}
echo "
\n";
}
echo "
\n";
return ($iIssues > 0);
}
}
class TestGenericItoMyModel extends TestBizModelGeneric
{
static public function GetName()
{
return 'Generic RO test on '.self::GetConfigFile();
}
static public function GetConfigFile() {return '/config-test-mymodel.php';}
}
class TestGenericItopBigModel extends TestBizModelGeneric
{
static public function GetName()
{
return 'Generic RO test on '.self::GetConfigFile();
}
static public function GetConfigFile() {return '/config-test-itopv06.php';}
}
class TestUserRightsMatrixItop extends TestUserRights
{
static public function GetName()
{
return 'User rights test on user rights matrix';
}
static public function GetDescription()
{
return 'blah blah blah';
}
public function DoPrepare()
{
parent::DoPrepare();
MetaModel::Startup('../config-test-itopv06.php');
}
protected function DoExecute()
{
$sUser = 'Romain';
echo "Totor: ".(UserRights::CheckCredentials('Totor', 'toto') ? 'ok' : 'NO')."
\n";
echo "Romain: ".(UserRights::CheckCredentials('Romain', 'toto') ? 'ok' : 'NO')."
\n";
echo "User: ".UserRights::GetUser()."
\n";
echo "On behalf of...".UserRights::GetRealUser()."
\n";
echo "Denis (impersonate) : ".(UserRights::Impersonate('Denis', 'tutu') ? 'ok' : 'NO')."
\n";
echo "User: ".UserRights::GetUser()."
\n";
echo "On behalf of...".UserRights::GetRealUser()."
\n";
$oSet = new DBObjectSet(DBObjectSearch::FromOQL("SELECT bizOrganization"));
echo "IsActionAllowed...".(UserRights::IsActionAllowed('bizOrganization', UR_ACTION_MODIFY, $oSet) == UR_ALLOWED_YES ? 'ok' : 'NO')."
\n";
echo "IsStimulusAllowed...".(UserRights::IsStimulusAllowed('bizOrganization', 'myStimulus', $oSet) == UR_ALLOWED_YES ? 'ok' : 'NO')."
\n";
echo "IsActionAllowedOnAttribute...".(UserRights::IsActionAllowedOnAttribute('bizOrganization', 'myattribute', UR_ACTION_MODIFY, $oSet) == UR_ALLOWED_YES ? 'ok' : 'NO')."
\n";
return true;
}
}
///////////////////////////////////////////////////////////////////////////
// Test a complex biz model on the fly
///////////////////////////////////////////////////////////////////////////
class TestMyBizModel extends TestBizModel
{
static public function GetName()
{
return 'A series of tests on a weird business model';
}
static public function GetDescription()
{
return 'Attempts various operations and build complex queries';
}
static public function GetConfigFile() {return '/config-test-mymodel.php';}
function test_linksinfo()
{
echo "Enum links
";
self::DumpVariable(MetaModel::EnumReferencedClasses("cmdbTeam"));
self::DumpVariable(MetaModel::EnumReferencingClasses("Organization"));
self::DumpVariable(MetaModel::EnumLinkingClasses());
self::DumpVariable(MetaModel::EnumLinkingClasses("cmdbContact"));
self::DumpVariable(MetaModel::EnumLinkingClasses("cmdWorkshop"));
self::DumpVariable(MetaModel::GetLinkLabel("Liens_entre_contacts_et_workshop", "toworkshop"));
}
function test_list_attributes()
{
echo "List attributes
";
foreach(MetaModel::ListAttributeDefs("cmdbTeam") as $sAttCode=>$oAttDef)
{
echo $oAttDef->GetLabel()." / ".$oAttDef->GetDescription()." / ".$oAttDef->GetType()."\n";
}
}
function test_search()
{
echo "Two searches
";
$oFilterAllDevs = new DBObjectSearch("cmdbTeam");
$oAllDevs = new DBObjectSet($oFilterAllDevs);
echo "Found ".$oAllDevs->Count()." items.\n";
while ($oDev = $oAllDevs->Fetch())
{
$aValues = array();
foreach(MetaModel::GetAttributesList($oAllDevs->GetClass()) as $sAttCode)
{
$aValues[] = MetaModel::GetLabel(get_class($oDev), $sAttCode)." (".MetaModel::GetDescription(get_class($oDev), $sAttCode).") = ".$oDev->GetAsHTML($sAttCode);
}
echo $oDev->GetKey()." => ".implode(", ", $aValues)."\n";
}
// a second one
$oMyFilter = new DBObjectSearch("cmdbContact");
//$oMyFilter->AddCondition("name", "aii", "Finishes with");
$oMyFilter->AddCondition("name", "aii");
$this->search_and_show_list($oMyFilter);
}
function test_reload()
{
echo "Reload
";
$team = MetaModel::GetObject("cmdbContact", "2");
echo "Chargement de l'attribut headcount: {$team->Get("headcount")}\n";
self::DumpVariable($team);
}
function test_setattribute()
{
echo "Set attribute and update
";
$team = MetaModel::GetObject("cmdbTeam", "2");
$team->Set("headcount", rand(1,1000));
$team->Set("email", "Luis ".rand(9,250));
self::DumpVariable($team->ListChanges());
echo "New headcount = {$team->Get("headcount")}\n";
echo "Computed name = {$team->Get("name")}\n";
$oMyChange = MetaModel::NewObject("CMDBChange");
$oMyChange->Set("date", time());
$oMyChange->Set("userinfo", "test_setattribute / Made by robot #".rand(1,100));
$iChangeId = $oMyChange->DBInsert();
//DBSearch::StartDebugQuery();
$team->DBUpdateTracked($oMyChange);
//DBSearch::StopDebugQuery();
echo "Check the modified team
";
$oTeam = MetaModel::GetObject("cmdbTeam", "2");
self::DumpVariable($oTeam);
}
function test_newobject()
{
$oMyChange = MetaModel::NewObject("CMDBChange");
$oMyChange->Set("date", time());
$oMyChange->Set("userinfo", "test_newobject / Made by robot #".rand(1,100));
$iChangeId = $oMyChange->DBInsert();
echo "Create a new object (team)
";
$oNewTeam = MetaModel::NewObject("cmdbTeam");
$oNewTeam->Set("name", "ekip2choc #".rand(1000, 2000));
$oNewTeam->Set("email", "machin".rand(1,100)."@tnut.com");
$oNewTeam->Set("email", null);
$oNewTeam->Set("owner", "ITOP");
$oNewTeam->Set("headcount", "0".rand(38000, 38999)); // should be reset to an int value
$iId = $oNewTeam->DBInsertTracked($oMyChange);
echo "Created new team: $iId";
echo "Delete team #$iId
";
$oTeam = MetaModel::GetObject("cmdbTeam", $iId);
$oTeam->DBDeleteTracked($oMyChange);
echo "Deleted team: $iId";
self::DumpVariable($oTeam);
}
function test_updatecolumn()
{
$oMyChange = MetaModel::NewObject("CMDBChange");
$oMyChange->Set("date", time());
$oMyChange->Set("userinfo", "test_updatecolumn / Made by robot #".rand(1,100));
$iChangeId = $oMyChange->DBInsert();
$sNewEmail = "updatecol".rand(9,250)."@quedlaballe.com";
echo "Update a the email: set to '$sNewEmail'
";
$oMyFilter = new DBObjectSearch("cmdbContact");
$oMyFilter->AddCondition("name", "o", "Contains");
echo "Candidates before:";
$this->search_and_show_list($oMyFilter);
MetaModel::BulkUpdateTracked($oMyChange, $oMyFilter, array("email" => $sNewEmail));
echo "Candidates after:";
$this->search_and_show_list($oMyFilter);
}
function test_error()
{
trigger_error("Stop requested", E_USER_ERROR);
}
function test_changetracking()
{
echo "Create a change
";
$oMyChange = MetaModel::NewObject("CMDBChange");
$oMyChange->Set("date", time());
$oMyChange->Set("userinfo", "Made by robot #".rand(1,100));
$iChangeId = $oMyChange->DBInsert();
echo "Created new change: $iChangeId";
self::DumpVariable($oMyChange);
echo "Create a new object (team)
";
$oNewTeam = MetaModel::NewObject("cmdbTeam");
$oNewTeam->Set("name", "ekip2choc #".rand(1000, 2000));
$oNewTeam->Set("email", "machin".rand(1,100)."@tnut.com");
$oNewTeam->Set("email", null);
$oNewTeam->Set("owner", "ITOP");
$oNewTeam->Set("headcount", "0".rand(38000, 38999)); // should be reset to an int value
$iId = $oNewTeam->DBInsertTracked($oMyChange);
echo "Created new team: $iId";
echo "Delete team #$iId
";
$oTeam = MetaModel::GetObject("cmdbTeam", $iId);
$oTeam->DBDeleteTracked($oMyChange);
echo "Deleted team: $iId";
self::DumpVariable($oTeam);
}
function test_zlist()
{
echo "Test ZLists
";
$aZLists = MetaModel::EnumZLists();
foreach ($aZLists as $sListCode)
{
$aListInfos = MetaModel::GetZListInfo($sListCode);
echo "List '".$sListCode."' (".$aListInfos["description"].") of type '".$aListInfos["type"]."'\n";
foreach (MetaModel::GetSubclasses("cmdbObjectHomeMade") as $sKlass)
{
$aItems = MetaModel::FlattenZlist(MetaModel::GetZListItems($sKlass, $sListCode));
if (count($aItems) == 0) continue;
echo "$sKlass - $sListCode : {".implode(", ", $aItems)."}\n";
}
}
echo "IsAttributeInZList()...
";
echo "Liens_entre_contacts_et_workshop::ws_info in list1 ? ".(MetaModel::IsAttributeInZList("Liens_entre_contacts_et_workshop", "list1", "ws_info") ? "yes" : "no")."\n";
echo "Liens_entre_contacts_et_workshop::toworkshop in list1 ? ".(MetaModel::IsAttributeInZList("Liens_entre_contacts_et_workshop", "list1", "toworkshop") ? "yes" : "no")."\n";
}
function test_pkey()
{
echo "Test search on pkey
";
$sExpr1 = "SELECT cmdbContact WHERE id IN (40, 42)";
$sExpr2 = "SELECT cmdbContact WHERE IN NOT IN (40, 42)";
$this->search_and_show_list_from_oql($sExpr1);
$this->search_and_show_list_from_oql($sExpr2);
echo "Et maintenant, on fusionne....\n";
$oSet1 = new CMDBObjectSet(DBObjectSearch::FromOQL($sExpr1));
$oSet2 = new CMDBObjectSet(DBObjectSearch::FromOQL($sExpr2));
$oIntersect = $oSet1->CreateIntersect($oSet2);
$oDelta = $oSet1->CreateDelta($oSet2);
$oMerge = clone $oSet1;
$oAppend->Append($oSet2);
$oAppend->Append($oSet2);
echo "Set1 - Found ".$oSet1->Count()." items.\n";
echo "Set2 - Found ".$oSet2->Count()." items.\n";
echo "Intersect - Found ".$oIntersect->Count()." items.\n";
echo "Delta - Found ".$oDelta->Count()." items.\n";
echo "Append - Found ".$oAppend->Count()." items.\n";
//$this->show_list($oObjSet);
}
function test_relations()
{
echo "Test relations
";
//self::DumpVariable(MetaModel::EnumRelationQueries("cmdbObjectHomeMade", "Potes"));
self::DumpVariable(MetaModel::EnumRelationQueries("cmdbContact", "Potes"));
$iMaxDepth = 9;
echo "Max depth = $iMaxDepth\n";
$oObj = MetaModel::GetObject("cmdbContact", 18);
$aRels = $oObj->GetRelatedObjects("Potes", $iMaxDepth);
echo $oObj->Get('name')." has some 'Potes'...\n";
foreach ($aRels as $sClass => $aObjs)
{
echo "$sClass, count = ".count($aObjs)." => ".implode(', ', array_keys($aObjs))."\n";
$oObjectSet = CMDBObjectSet::FromArray($sClass, $aObjs);
$this->show_list($oObjectSet);
}
echo "Test relations - same results, by the mean of a OQL
";
$this->search_and_show_list_from_oql("cmdbContact: RELATED (Potes, $iMaxDepth) TO (cmdbContact: pkey = 18)");
}
function test_linkedset()
{
echo "Linked set attributes
\n";
$oObj = MetaModel::GetObject("cmdbContact", 18);
echo "Current workshops
\n";
$oSetWorkshopsCurr = $oObj->Get("myworkshops");
$this->show_list($oSetWorkshopsCurr);
echo "Setting workshops
\n";
$oNewLink = new cmdbLiens();
$oNewLink->Set('toworkshop', 2);
$oNewLink->Set('function', 'mafonctioooon');
$oNewLink->Set('a1', 'tralala1');
$oNewLink->Set('a2', 'F7M');
$oSetWorkshops = CMDBObjectSet::FromArray("cmdbLiens", array($oNewLink));
$oObj->Set("myworkshops", $oSetWorkshops);
$this->show_list($oSetWorkshops);
echo "New workshops
\n";
$oSetWorkshopsCurr = $oObj->Get("myworkshops");
$this->show_list($oSetWorkshopsCurr);
$oMyChange = MetaModel::NewObject("CMDBChange");
$oMyChange->Set("date", time());
$oMyChange->Set("userinfo", "test_linkedset / Made by robot #".rand(1,100));
$iChangeId = $oMyChange->DBInsert();
$oObj->DBUpdateTracked($oMyChange);
$oObj = MetaModel::GetObject("cmdbContact", 18);
echo "After the write
\n";
$oSetWorkshopsCurr = $oObj->Get("myworkshops");
$this->show_list($oSetWorkshopsCurr);
}
function test_object_lifecycle()
{
echo "Test object lifecycle
";
self::DumpVariable(MetaModel::GetStateAttributeCode("cmdbContact"));
self::DumpVariable(MetaModel::EnumStates("cmdbContact"));
self::DumpVariable(MetaModel::EnumStimuli("cmdbContact"));
foreach(MetaModel::EnumStates("cmdbContact") as $sStateCode => $aStateDef)
{
echo "
Transition from $sStateCode
\n";
self::DumpVariable(MetaModel::EnumTransitions("cmdbContact", $sStateCode));
}
$oObj = MetaModel::GetObject("cmdbContact", 18);
echo "Current state: ".$oObj->GetState()."... let's go to school...";
self::DumpVariable($oObj->EnumTransitions());
$oObj->ApplyStimulus("toschool");
echo "New state: ".$oObj->GetState()."... let's get older...";
self::DumpVariable($oObj->EnumTransitions());
$oObj->ApplyStimulus("raise");
echo "New state: ".$oObj->GetState()."... let's try to go further... (should give an error)";
self::DumpVariable($oObj->EnumTransitions());
$oObj->ApplyStimulus("raise"); // should give an error
}
protected function DoExecute()
{
// $this->ReportError("Found two different OQL expression out of the (same?) filter: $sExpr1 != $sExpr2");
// $this->ReportSuccess('Found '.$oSet->Count()." objects of class $sClassName");
//$this->test_linksinfo();
//$this->test_list_attributes();
//$this->test_search();
//$this->test_reload();
//$this->test_newobject();
$this->test_setattribute();
//$this->test_updatecolumn();
//$this->test_error();
//$this->test_changetracking();
$this->test_zlist();
$this->test_OQL();
//$this->test_pkey();
$this->test_relations();
$this->test_linkedset();
$this->test_object_lifecycle();
}
}
///////////////////////////////////////////////////////////////////////////
// Test a complex biz model on the fly
///////////////////////////////////////////////////////////////////////////
abstract class MyFarm extends TestBizModel
{
static public function GetConfigFile() {return '/config-test-farm.php';}
protected function DoPrepare()
{
parent::DoPrepare();
$this->ResetDB();
MetaModel::DBCheckIntegrity();
}
protected function InsertMammal($sSpecies, $sSex, $iSpeed, $iMotherid, $iFatherId, $sName, $iHeight, $sBirth)
{
$oNew = MetaModel::NewObject('Mammal');
$oNew->Set('species', $sSpecies);
$oNew->Set('sex', $sSex);
$oNew->Set('speed', $iSpeed);
$oNew->Set('mother', $iMotherid);
$oNew->Set('father', $iFatherId);
$oNew->Set('name', $sName);
$oNew->Set('height', $iHeight);
$oNew->Set('birth', $sBirth);
return $this->ObjectToDB($oNew);
}
protected function InsertBird($sSpecies, $sSex, $iSpeed, $iMotherid, $iFatherId)
{
$oNew = MetaModel::NewObject('Bird');
$oNew->Set('species', $sSpecies);
$oNew->Set('sex', $sSex);
$oNew->Set('speed', $iSpeed);
$oNew->Set('mother', $iMotherid);
$oNew->Set('father', $iFatherId);
return $this->ObjectToDB($oNew);
}
protected function InsertFlyingBird($sSpecies, $sSex, $iSpeed, $iMotherid, $iFatherId, $iFlyingSpeed)
{
$oNew = MetaModel::NewObject('FlyingBird');
$oNew->Set('species', $sSpecies);
$oNew->Set('sex', $sSex);
$oNew->Set('speed', $iSpeed);
$oNew->Set('mother', $iMotherid);
$oNew->Set('father', $iFatherId);
$oNew->Set('flyingspeed', $iFlyingSpeed);
return $this->ObjectToDB($oNew);
}
private function InsertGroup($sName, $iLeaderId)
{
$oNew = MetaModel::NewObject('Group');
$oNew->Set('name', $sName);
$oNew->Set('leader', $iLeaderId);
$iId = $oNew->DBInsertNoReload();
return $iId;
}
}
class TestQueriesOnFarm extends MyFarm
{
static public function GetName()
{
return 'Farm test';
}
static public function GetDescription()
{
return 'A series of tests on the farm business model (SQL generation)';
}
protected function CheckQuery($sQuery, $bIsCorrectQuery)
{
if ($bIsCorrectQuery)
{
echo "$sQuery
\n";
}
else
{
echo "$sQuery\n";
}
try
{
//$oOql = new OqlInterpreter($sQuery);
//$oTrash = $oOql->ParseQuery();
//self::DumpVariable($oTrash, true);
$oMyFilter = DBObjectSearch::FromOQL($sQuery);
}
catch (OQLException $oOqlException)
{
if ($bIsCorrectQuery)
{
echo "
More info on this unexpected failure:
".$oOqlException->getHtmlDesc()."
\n";
throw $oOqlException;
return false;
}
else
{
// Everything is fine :-)
echo "More info on this expected failure:\n";
echo "
\n";
echo "- ".get_class($oOqlException)."
\n";
echo "- ".$oOqlException->getMessage()."
\n";
echo "- ".$oOqlException->getHtmlDesc()."
\n";
echo "
\n";
echo "\n";
return true;
}
}
// The query was correctly parsed, was it expected to be correct ?
if (!$bIsCorrectQuery)
{
throw new UnitTestException("The query '$sQuery' was parsed with success, while it shouldn't (?)");
return false;
}
echo "To OQL: ".$oMyFilter->ToOQL()."
";
$this->search_and_show_list($oMyFilter);
//echo "first pass
\n";
//self::DumpVariable($oMyFilter, true);
$sQuery1 = $oMyFilter->MakeSelectQuery();
//echo "
second pass
\n";
//self::DumpVariable($oMyFilter, true);
//$sQuery1 = $oMyFilter->MakeSelectQuery();
$sSerialize = $oMyFilter->serialize();
echo "
Serialized:$sSerialize
\n";
$oFilter2 = DBObjectSearch::unserialize($sSerialize);
try
{
$sQuery2 = $oMyFilter2->MakeSelectQuery();
}
catch (Exception $e)
{
echo "Could not compute the query after unserialize
\n";
echo "Query 1: $sQuery1
\n";
MyHelpers::var_cmp_html($oMyFilter, $oFilter2);
throw $e;
}
//if ($oFilter2 != $oMyFilter) no, they may differ while the resulting query is the same!
if ($sQuery1 != $sQuery2)
{
echo "serialize/unserialize mismatch :-(
\n";
MyHelpers::var_cmp_html($sQuery1, $sQuery2);
MyHelpers::var_cmp_html($oMyFilter, $oFilter2);
return false;
}
return true;
}
protected function DoExecute()
{
// $this->ReportError("Found two different OQL expression out of the (same?) filter: $sExpr1 != $sExpr2");
// $this->ReportSuccess('Found '.$oSet->Count()." objects of class $sClassName");
echo "Create protagonists...
";
$iId1 = $this->InsertMammal('human', 'male', 10, 0, 0, 'romanoff', 192, '1971-07-19');
$iId2 = $this->InsertMammal('human', 'female', 9, 0, 0, 'rouanita', 165, '1983-01-23');
$this->InsertMammal('human', 'female', 3, $iId2, $iId1, 'pomme', 169, '2008-02-23');
$this->InsertMammal('pig', 'female', 3, 0, 0, 'grouinkette', 85, '2006-06-01');
$this->InsertMammal('donkey', 'female', 3, 0, 0, 'muleta', 124, '2003-11-11');
$this->InsertBird('rooster', 'male', 12, 0, 0);
$this->InsertFlyingBird('pie', 'female', 11, 0, 0, 35);
// Benchmarking
//
if (false)
{
define ('COUNT_BENCHMARK', 10);
echo "Parsing a long query, ".COUNT_BENCHMARK." times
";
$sQuery = "SELECT Animal AS Child JOIN Mammal AS Dad ON Child.father = Dad.id JOIN Animal AS Mum ON Child.mother = Mum.id WHERE Dad.birth < DATE_SUB(CURRENT_DATE(), INTERVAL 10 YEAR) AND Dad.height * 2 <= ROUND(TO_DAYS(Dad.birth) / (3 + 1) * 5 - 3)";
$fStart = MyHelpers::getmicrotime();
for($i=0 ; $i < COUNT_BENCHMARK ; $i++)
{
$oMyFilter = DBObjectSearch::FromOQL($sQuery);
}
$fDuration = MyHelpers::getmicrotime() - $fStart;
$fParsingDuration = $fDuration / COUNT_BENCHMARK;
echo "Mean time by op: $fParsingDuration
";
}
echo "Test queries...
";
$aQueries = array(
'SELECT Animal' => true,
'SELECT Animal WHERE Animal.pkey = 1' => false,
'SELECT Animal WHERE Animal.id = 1' => true,
'SELECT Aniiimal' => false,
'SELECTe Animal' => false,
'SELECT * FROM Animal' => false,
'SELECT Animal AS zoo WHERE zoo.species = \'human\'' => true,
'SELECT Animal AS zoo WHERE species = \'human\'' => true,
'SELECT Animal AS zoo WHERE espece = \'human\'' => false,
'SELECT Animal AS zoo WHERE zoo.species IN (\'human\', "pig")' => true,
'SELECT Animal AS zoo WHERE CONCATENATION(zoo.species, zoo.sex) LIKE "hum%male"' => false,
'SELECT Animal AS zoo WHERE CONCAT(zoo.species, zoo.sex) LIKE "hum%male"' => true,
'SELECT Animal AS zoo WHERE zoo.species NOT IN (\'human\', "pig")' => true,
'SELECT Animal AS zoo WHERE zoo.kind = \'human\'' => false,
'SELECT Animal WHERE Animal.species = \'human\' AND Animal.sex = \'female\'' => true,
'SELECT Mammal AS x WHERE (x.species = \'human\' AND x.name LIKE \'ro%\') OR (x.species = \'donkey\' AND x.name LIKE \'po%\')' => true,
'SELECT Mammal AS x WHERE x.species = \'human\' AND x.name LIKE \'ro%\' OR x.species = \'donkey\' AND x.name LIKE \'po%\'' => true,
'SELECT Mammal AS m WHERE MONTH(m.birth) = 7' => true,
'SELECT Mammal AS m WHERE DAY(m.birth) = 19' => true,
'SELECT Mammal AS m WHERE YEAR(m.birth) = 1971' => true,
'SELECT Mammal AS m WHERE m.birth < DATE_SUB(CURRENT_DATE(), INTERVAL 10 YEAR)' => true,
'SELECT Mammal AS m WHERE m.birth > DATE_SUB(NOW(), INTERVAL 2000 DAY)' => true,
'SELECT Mammal AS m WHERE (TO_DAYS(NOW()) - TO_DAYS(m.birth)) > 2000' => true,
'SELECT Mammal AS m WHERE m.name = IF(FLOOR(ROUND(m.height)) > 2, "pomme", "romain")' => true,
'SELECT Mammal AS m WHERE (1 + 2' => false,
'SELECT Mammal AS m WHERE (1 + 2 * 4 / 23) > 0' => true,
'SELECT Mammal AS m WHERE (4 / 23 * 2 + 1) > 0' => true,
'SELECT Mammal AS m WHERE 1/0' => true,
'SELECT Mammal AS m WHERE MONTH(m.birth) = 7' => true,
'SELECT Animal JOIN Group ON Group.leader = Animal.id' => true,
'SELECT Group JOIN Animal ON Group.leader = Animal.id' => true,
'SELECT Animal AS A JOIN Group AS G1 ON G1.leader = A.id' => true,
'SELECT Animal AS A JOIN Group AS G ON FooClass.leader = A.id' => false,
'SELECT Animal AS A JOIN Group AS G ON G.leader = FooClass.id' => false,
'SELECT Animal AS A JOIN Group AS G ON G.masterchief = A.id' => false,
'SELECT Animal AS A JOIN Group AS G ON A.id = G.leader' => false,
'SELECT Animal AS A JOIN Group AS G ON G.leader = A.id WHERE A.sex=\'male\' OR G.qwerty = 123' => false,
'SELECT Animal AS A JOIN Group AS G ON G.leader = A.id WHERE A.sex=\'male\' OR G.name LIKE "a%"' => true,
'SELECT Animal AS A JOIN Group AS G ON G.leader = A.id WHERE A.id = 1' => true,
'SELECT Animal AS A JOIN Group AS G ON G.leader = A.id WHERE id = 1' => false,
'SELECT Animal AS A JOIN Group AS G ON A.member = G.id' => false,
'SELECT Mammal AS M JOIN Group AS G ON M.member = G.id' => true,
'SELECT Mammal AS M JOIN Group AS G ON A.member = G.id' => false,
'SELECT Mammal AS myAlias JOIN Group AS myAlias ON myAlias.member = myAlias.id' => false,
'SELECT Mammal AS Mammal JOIN Group AS Mammal ON Mammal.member = Mammal.id' => false,
'SELECT Group AS G WHERE G.leader_name LIKE "%"' => true,
'SELECT Group AS G WHERE G.leader_speed < 100000' => true,
'SELECT Mammal AS M JOIN Group AS G ON M.member = G.id WHERE G.leader_name LIKE "%"' => true,
'SELECT Mammal AS M JOIN Group AS G ON M.member = G.id WHERE G.leader_speed < 100000' => true,
'SELECT Mammal AS Child JOIN Mammal AS Dad ON Child.father = Dad.id' => true,
'SELECT Mammal AS Child JOIN Animal AS Dad ON Child.father = Dad.id' => true,
'SELECT Animal AS Child JOIN Mammal AS Dad ON Child.father = Dad.id' => true,
'SELECT Animal AS Child JOIN Animal AS Dad ON Child.father = Dad.id' => true,
'SELECT Animal AS Dad JOIN Animal AS Child ON Child.father = Dad.id' => true,
'SELECT Animal AS Child JOIN Animal AS Dad ON Child.father = Dad.id JOIN Animal AS Mum ON Child.mother = Mum.id' => true,
'SELECT Animal AS Child JOIN Animal AS Dad ON Child.father = Dad.id JOIN Animal AS Mum ON Child.mother = Mum.id WHERE Dad.id = 1' => true,
'SELECT Animal AS Child JOIN Animal AS Dad ON Child.father = Dad.id JOIN Animal AS Mum ON Child.mother = Mum.id WHERE Dad.name = \'romanoff\'' => false,
'SELECT Animal AS Child JOIN Mammal AS Dad ON Child.father = Dad.id' => true,
'SELECT Animal AS Child JOIN Mammal AS Dad ON Child.father = Dad.id JOIN Animal AS Mum ON Child.mother = Mum.id WHERE Dad.name = \'romanoff\' OR Mum.speed = 0' => true,
'SELECT Animal AS Dad JOIN Animal AS Child ON Child.father = Dad.id JOIN Animal AS Mum ON Child.mother = Mum.id' => true,
'SELECT Mammal AS Dad JOIN Mammal AS Child ON Child.father = Dad.id' => true,
'SELECT Mammal AS Dad JOIN Mammal AS Child ON Child.father = Dad.id JOIN Mammal AS Mum ON Child.mother = Mum.id WHERE Dad.name = \'romanoff\' OR Mum.name=\'chloe\' OR Child.name=\'bizounours\'' => true,
// Specifying multiple objects
'SELECT Animal FROM Animal' => true,
'SELECT yelele FROM Animal' => false,
'SELECT Animal FROM Animal AS A' => false,
'SELECT A FROM Animal AS A' => true,
);
//$aQueries = array(
// 'SELECT Mammal AS M JOIN Group AS G ON M.member = G.id WHERE G.leader_name LIKE "%"' => true,
//);
foreach($aQueries as $sQuery => $bIsCorrect)
{
$this->CheckQuery($sQuery, $bIsCorrect);
}
return true;
}
}
///////////////////////////////////////////////////////////////////////////
// Test data load
///////////////////////////////////////////////////////////////////////////
class TestBulkChangeOnFarm extends TestBizModel
{
static public function GetName()
{
return 'Farm test - data load';
}
static public function GetDescription()
{
return 'Bulk load';
}
static public function GetConfigFile() {return '/config-test-farm.php';}
protected function DoPrepare()
{
parent::DoPrepare();
$this->ResetDB();
MetaModel::DBCheckIntegrity();
}
protected function DoExecute()
{
// $this->ReportError("Found two different OQL expression out of the (same?) filter: $sExpr1 != $sExpr2");
// $this->ReportSuccess('Found '.$oSet->Count()." objects of class $sClassName");
$oParser = new CSVParser("denomination,hauteur,age
suzy,123,2009-01-01
chita,456,
", ',', '"');
$aData = $oParser->ToArray(1, array('_name', '_height', '_birth'));
self::DumpVariable($aData);
$oBulk = new BulkChange(
'Mammal',
$aData,
// attributes
array('name' => '_name', 'height' => '_height', 'birth' => '_birth'),
// ext keys
array(),
// reconciliation
array('name')
);
$oMyChange = MetaModel::NewObject("CMDBChange");
$oMyChange->Set("date", time());
$oMyChange->Set("userinfo", "Testor");
$iChangeId = $oMyChange->DBInsert();
// echo "Created new change: $iChangeId";
echo "Planned for loading...
";
$aRes = $oBulk->Process();
self::DumpVariable($aRes);
echo "Go for loading...
";
$aRes = $oBulk->Process($oMyChange);
self::DumpVariable($aRes);
return;
$oRawData = array(
'Mammal',
array('species', 'sex', 'speed', 'mother', 'father', 'name', 'height', 'birth'),
"human,male,23,0,0,romulus,192,1971
human,male,23,0,0,remus,154,-50
human,male,23,0,0,julius,160,-49
human,female,23,0,0,cleopatra,142,-50
pig,female,23,0,0,confucius,50,2003"
);
}
}
///////////////////////////////////////////////////////////////////////////
// Test data load
///////////////////////////////////////////////////////////////////////////
class TestFullTextSearchOnFarm extends MyFarm
{
static public function GetName()
{
return 'Farm test - full text search';
}
static public function GetDescription()
{
return 'Focus on the full text search feature';
}
protected function DoExecute()
{
echo "Create protagonists...
";
$iId1 = $this->InsertMammal('human', 'male', 10, 0, 0, 'romanoff', 192, '1971-07-19');
$iId2 = $this->InsertMammal('human', 'female', 9, 0, 0, 'rouanita', 165, '1983-01-23');
$this->InsertMammal('human', 'female', 3, $iId2, $iId1, 'pomme', 169, '2008-02-23');
$this->InsertMammal('pig', 'female', 3, 0, 0, 'grouinkette', 85, '2006-06-01');
$this->InsertMammal('donkey', 'female', 3, 0, 0, 'muleta', 124, '2003-11-11');
$this->InsertBird('rooster', 'male', 12, 0, 0);
$this->InsertFlyingBird('pie', 'female', 11, 0, 0, 35);
echo "Search...
";
$oSearch = new DBObjectSearch('Mammal');
$oSearch->AddCondition_FullText('manof');
//$oResultSet = new DBObjectSet($oSearch);
$this->search_and_show_list($oSearch);
}
}
///////////////////////////////////////////////////////////////////////////
// Test queries
///////////////////////////////////////////////////////////////////////////
class TestItopEfficiency extends TestBizModel
{
static public function GetName()
{
return 'Itop - benchmark';
}
static public function GetDescription()
{
return 'Measure time to perform the queries';
}
protected function DoBenchmark($sOqlQuery)
{
echo "Testing query: $sOqlQuery
";
$fStart = MyHelpers::getmicrotime();
for($i=0 ; $i < COUNT_BENCHMARK ; $i++)
{
$oFilter = DBObjectSearch::FromOQL($sOqlQuery);
}
$fDuration = MyHelpers::getmicrotime() - $fStart;
$fParsingDuration = $fDuration / COUNT_BENCHMARK;
$fStart = MyHelpers::getmicrotime();
for($i=0 ; $i < COUNT_BENCHMARK ; $i++)
{
$sSQL = $oFilter->MakeSelectQuery();
}
$fDuration = MyHelpers::getmicrotime() - $fStart;
$fBuildDuration = $fDuration / COUNT_BENCHMARK;
$fStart = MyHelpers::getmicrotime();
for($i=0 ; $i < COUNT_BENCHMARK ; $i++)
{
$res = CMDBSource::Query($sSQL);
}
$fDuration = MyHelpers::getmicrotime() - $fStart;
$fQueryDuration = $fDuration / COUNT_BENCHMARK;
// The fetch could not be repeated with the same results
// But we've seen so far that is was very very quick to exec
// So it makes sense to benchmark it a single time
$fStart = MyHelpers::getmicrotime();
$aRow = CMDBSource::FetchArray($res);
$fDuration = MyHelpers::getmicrotime() - $fStart;
$fFetchDuration = $fDuration;
$fStart = MyHelpers::getmicrotime();
for($i=0 ; $i < COUNT_BENCHMARK ; $i++)
{
$sOql = $oFilter->ToOQL();
}
$fDuration = MyHelpers::getmicrotime() - $fStart;
$fToOqlDuration = $fDuration / COUNT_BENCHMARK;
echo "\n";
echo "- Parsing: $fParsingDuration
\n";
echo "- Build: $fBuildDuration
\n";
echo "- Query: $fQueryDuration
\n";
echo "- Fetch: $fFetchDuration
\n";
echo "- ToOql: $fToOqlDuration
\n";
echo "
\n";
// Everything but the ToOQL (wich is interesting, anyhow)
$fTotal = $fParsingDuration + $fBuildDuration + $fQueryDuration + $fFetchDuration;
if ($fTotal == 0)
{
$aRet = array(
'rows' => CMDBSource::NbRows($res),
'duration (s)' => '0 (negligeable)',
'parsing (%)' => '?',
'build SQL (%)' => '?',
'query exec (%)' => '?',
'fetch (%)' => '?',
'to OQL (%)' => '?',
'parsing+build (%)' => '?',
);
}
else
{
$aRet = array(
'rows' => CMDBSource::NbRows($res),
'duration (s)' => round($fTotal, 4),
'parsing (%)' => round(100 * $fParsingDuration / $fTotal, 1),
'build SQL (%)' => round(100 * $fBuildDuration / $fTotal, 1),
'query exec (%)' => round(100 * $fQueryDuration / $fTotal, 1),
'fetch (%)' => round(100 * $fFetchDuration / $fTotal, 1),
'to OQL (%)' => round(100 * $fToOqlDuration / $fTotal, 1),
'parsing+build (%)' => round(100 * ($fParsingDuration + $fBuildDuration) / $fTotal, 1),
);
}
return $aRet;
}
protected function DoExecute()
{
define ('COUNT_BENCHMARK', 3);
echo "The test will be repeated ".COUNT_BENCHMARK." times
";
$aQueries = array(
'SELECT CMDBChangeOpSetAttribute',
'SELECT CMDBChangeOpSetAttribute WHERE id=10',
'SELECT CMDBChangeOpSetAttribute WHERE id=123456789',
'SELECT CMDBChangeOpSetAttribute WHERE CMDBChangeOpSetAttribute.id=10',
'SELECT Ticket',
'SELECT Ticket WHERE id=1',
'SELECT Person',
'SELECT Person WHERE id=1',
'SELECT Server',
'SELECT Server WHERE id=1',
'SELECT UserRequest JOIN Person ON UserRequest.agent_id = Person.id WHERE Person.id = 5',
);
$aStats = array();
foreach ($aQueries as $sOQL)
{
$aStats[$sOQL] = $this->DoBenchmark($sOQL);
}
$aData = array();
foreach ($aStats as $sOQL => $aResults)
{
$aValues = array();
$aValues['OQL'] = htmlentities($sOQL, ENT_QUOTES, 'UTF-8');
foreach($aResults as $sDesc => $sInfo)
{
$aValues[$sDesc] = htmlentities($sInfo, ENT_QUOTES, 'UTF-8');
}
$aData[] = $aValues;
}
echo MyHelpers::make_table_from_assoc_array($aData);
}
}
///////////////////////////////////////////////////////////////////////////
// Benchmark queries
///////////////////////////////////////////////////////////////////////////
class TestQueries extends TestBizModel
{
static public function GetName()
{
return 'Itop - queries';
}
static public function GetDescription()
{
return 'Try as many queries as possible';
}
protected function DoBenchmark($sOqlQuery)
{
echo "Testing query: $sOqlQuery
";
$fStart = MyHelpers::getmicrotime();
$oFilter = DBObjectSearch::FromOQL($sOqlQuery);
$fParsingDuration = MyHelpers::getmicrotime() - $fStart;
$fStart = MyHelpers::getmicrotime();
$sSQL = $oFilter->MakeSelectQuery();
$fBuildDuration = MyHelpers::getmicrotime() - $fStart;
$iJoins = preg_match_all('/JOIN/', $sSQL) + 1;
$fStart = MyHelpers::getmicrotime();
$res = CMDBSource::Query($sSQL);
$fQueryDuration = MyHelpers::getmicrotime() - $fStart;
// The fetch could not be repeated with the same results
// But we've seen so far that is was very very quick to exec
// So it makes sense to benchmark it a single time
$fStart = MyHelpers::getmicrotime();
$aRow = CMDBSource::FetchArray($res);
$fDuration = MyHelpers::getmicrotime() - $fStart;
$fFetchDuration = $fDuration;
$fStart = MyHelpers::getmicrotime();
$sOql = $oFilter->ToOQL();
$fToOqlDuration = MyHelpers::getmicrotime() - $fStart;
// Everything but the ToOQL (which is interesting, anyhow)
$fTotal = $fParsingDuration + $fBuildDuration + $fQueryDuration + $fFetchDuration;
if ($fTotal == 0)
{
$aRet = array(
'rows' => CMDBSource::NbRows($res),
'duration (s)' => '0 (negligeable)',
'parsing (%)' => '?',
'build SQL (%)' => '?',
'query exec (%)' => '?',
'fetch (%)' => '?',
'to OQL (%)' => '?',
'parsing+build (%)' => '?',
'joins' => $iJoins,
);
}
else
{
$aRet = array(
'rows' => CMDBSource::NbRows($res),
'duration (s)' => round($fTotal, 4),
'parsing (%)' => round(100 * $fParsingDuration / $fTotal, 1),
'build SQL (%)' => round(100 * $fBuildDuration / $fTotal, 1),
'query exec (%)' => round(100 * $fQueryDuration / $fTotal, 1),
'fetch (%)' => round(100 * $fFetchDuration / $fTotal, 1),
'to OQL (%)' => round(100 * $fToOqlDuration / $fTotal, 1),
'parsing+build (%)' => round(100 * ($fParsingDuration + $fBuildDuration) / $fTotal, 1),
'joins' => $iJoins,
);
}
return $aRet;
}
protected function DoExecute()
{
$aQueries = array();
foreach (MetaModel::GetClasses() as $sClass)
{
$aQueries[] = 'SELECT '.$sClass;
$aQueries[] = 'SELECT '.$sClass.' WHERE id = 1';
}
$aStats = array();
foreach ($aQueries as $sOQL)
{
$aStats[$sOQL] = $this->DoBenchmark($sOQL);
}
$aData = array();
foreach ($aStats as $sOQL => $aResults)
{
$aValues = array();
$aValues['OQL'] = htmlentities($sOQL, ENT_QUOTES, 'UTF-8');
foreach($aResults as $sDesc => $sInfo)
{
$aValues[$sDesc] = htmlentities($sInfo, ENT_QUOTES, 'UTF-8');
}
$aData[] = $aValues;
}
echo MyHelpers::make_table_from_assoc_array($aData);
}
}
///////////////////////////////////////////////////////////////////////////
// Check programmaticaly built queries
///////////////////////////////////////////////////////////////////////////
class TestQueriesByAPI extends TestBizModel
{
static public function GetName()
{
return 'Itop - queries build programmaticaly';
}
static public function GetDescription()
{
return 'Validate the DBObjectSearch API, through a set of complex (though realistic cases)';
}
protected function DoExecute()
{
// Note: relying on eval() - after upgrading to PHP 5.3 we can move to closure (aka anonymous functions)
$aQueries = array(
'Basic (validate the test)' => array(
'search' => '
$oSearch = DBObjectSearch::FromOQL("SELECT P FROM Organization AS O JOIN Person AS P ON P.org_id = O.id WHERE org_id = 2");
',
'oql' => 'SELECT P FROM Organization AS O JOIN Person AS P ON P.org_id = O.id WHERE P.org_id = 2'
),
'Double constraint' => array(
'search' => '
$oSearch = DBObjectSearch::FromOQL("SELECT Contact AS c");
$sClass = $oSearch->GetClass();
$sFilterCode = "org_id";
$oAttDef = MetaModel::GetAttributeDef($sClass, $sFilterCode);
if ($oAttDef->IsExternalKey())
{
$sHierarchicalKeyCode = MetaModel::IsHierarchicalClass($oAttDef->GetTargetClass());
if ($sHierarchicalKeyCode !== false)
{
$oFilter = new DBObjectSearch($oAttDef->GetTargetClass(), "ORGA");
$oFilter->AddCondition("id", 2);
$oHKFilter = new DBObjectSearch($oAttDef->GetTargetClass(), "ORGA");
$oHKFilter->AddCondition_PointingTo(clone $oFilter, $sHierarchicalKeyCode, TREE_OPERATOR_BELOW);
$oSearch->AddCondition_PointingTo(clone $oHKFilter, $sFilterCode);
$oFilter = new DBObjectSearch($oAttDef->GetTargetClass(), "ORGA");
$oFilter->AddCondition("id", 2);
$oHKFilter = new DBObjectSearch($oAttDef->GetTargetClass(), "ORGA");
$oHKFilter->AddCondition_PointingTo(clone $oFilter, $sHierarchicalKeyCode, TREE_OPERATOR_BELOW);
$oSearch->AddCondition_PointingTo(clone $oHKFilter, $sFilterCode);
}
}
',
'oql' => 'SELECT Contact AS C JOIN Organization ???'
),
'Simplified issue' => array(
'search' => '
$oSearch = DBObjectSearch::FromOQL("SELECT P FROM Organization AS O JOIN Person AS P ON P.org_id = O.id WHERE O.id = 2");
$oOrgSearch = new DBObjectSearch("Organization", "O2");
$oOrgSearch->AddCondition("id", 2);
$oSearch->AddCondition_PointingTo($oOrgSearch, "org_id");
',
'oql' => 'SELECT P FROM Organization AS O JOIN Person AS P ON P.org_id = O.id JOIN Organization AS O2 ON P.org_id = O2.id WHERE O.id = 2 AND O2.id = 2'
),
);
foreach ($aQueries as $sQueryDesc => $aQuerySpec)
{
echo "Query $sQueryDesc
\n";
echo "Using code: ".highlight_string("', true)."
\n";
echo "Expected OQL: ".$aQuerySpec['oql']."
\n";
if (isset($oSearch))
{
unset($oSearch);
}
eval($aQuerySpec['search']);
$sResOQL = $oSearch->ToOQL();
echo "Resulting OQL: ".$sResOQL."
\n";
echo "";
print_r($oSearch);
echo "
";
$sSQL = $oSearch->MakeSelectQuery();
$res = CMDBSource::Query($sSQL);
foreach (CMDBSource::ExplainQuery($sSQL) as $aRow)
{
}
}
// throw new UnitTestException("Expecting result '{$aWebService['expected result']}', but got '$res'");
}
}
///////////////////////////////////////////////////////////////////////////
// Test bulk load API
///////////////////////////////////////////////////////////////////////////
class TestItopBulkLoad extends TestBizModel
{
static public function GetName()
{
return 'Itop - test BulkChange class';
}
static public function GetDescription()
{
return 'Execute a bulk change at the Core API level';
}
protected function DoExecute()
{
$sLogin = 'testbulkload_'.time();
$oParser = new CSVParser("login,contactid->name,password,profile_list
_1_$sLogin,Picasso,secret1,profileid:10;reason:service manager|profileid->name:Problem Manager;'reason:toto;problem manager'
_2_$sLogin,Picasso,secret2,
", ',', '"');
$aData = $oParser->ToArray(1, array('_login', '_contact_name', '_password', '_profiles'));
self::DumpVariable($aData);
$oUser = new UserLocal();
$oUser->Set('login', 'patator');
$oUser->Set('password', 'patator');
//$oUser->Set('contactid', 0);
//$oUser->Set('language', $sLanguage);
$aProfiles = array(
array(
'profileid' => 10, // Service Manager
'reason' => 'service manager',
),
array(
'profileid->name' => 'Problem Manager',
'reason' => 'problem manager',
),
);
$oBulk = new BulkChange(
'UserLocal',
$aData,
// attributes
array('login' => '_login', 'password' => '_password', 'profile_list' => '_profiles'),
// ext keys
array('contactid' => array('name' => '_contact_name')),
// reconciliation
array('login'),
// Synchro - scope
"SELECT UserLocal",
// Synchro - set attribute on missing objects
array ('password' => 'terminated', 'login' => 'terminated'.time())
);
if (false)
{
$oMyChange = MetaModel::NewObject("CMDBChange");
$oMyChange->Set("date", time());
$oMyChange->Set("userinfo", "Testor");
$iChangeId = $oMyChange->DBInsert();
// echo "Created new change: $iChangeId";
}
echo "Planned for loading...
";
$aRes = $oBulk->Process();
self::DumpVariable($aRes);
if (false)
{
echo "Go for loading...
";
$aRes = $oBulk->Process($oMyChange);
self::DumpVariable($aRes);
}
return;
}
}
///////////////////////////////////////////////////////////////////////////
// Test data load
///////////////////////////////////////////////////////////////////////////
class TestImportREST extends TestWebServices
{
static public function GetName()
{
return 'CSV import (REST)';
}
static public function GetDescription()
{
return 'Test various options and fonctionality of import.php';
}
protected function DoExecSingleLoad($aLoadSpec, $iTestId = null)
{
$sCsvData = $aLoadSpec['csvdata'];
echo "\n";
if (is_null($iTestId))
{
echo "
{$aLoadSpec['desc']}
\n";
}
else
{
echo "
$iTestId - {$aLoadSpec['desc']}
\n";
}
$aPostData = array('csvdata' => $sCsvData);
$aGetParams = array();
$aGetParamReport = array();
foreach($aLoadSpec['args'] as $sArg => $sValue)
{
$aGetParams[] = $sArg.'='.urlencode($sValue);
$aGetParamReport[] = $sArg.'='.$sValue;
}
$sGetParams = implode('&', $aGetParams);
$sLogin = isset($aLoadSpec['login']) ? $aLoadSpec['login'] : 'admin';
$sPassword = isset($aLoadSpec['password']) ? $aLoadSpec['password'] : 'admin';
$sRes = self::DoPostRequestAuth('../webservices/import.php?'.$sGetParams, $aPostData, $sLogin, $sPassword);
$sArguments = implode('
', $aGetParamReport);
if (strlen($sCsvData) > 5000)
{
$sCsvDataViewable = 'INPUT TOO LONG TO BE DISPLAYED ('.strlen($sCsvData).")\n".substr($sCsvData, 0, 500)."\n... TO BE CONTINUED";
}
else
{
$sCsvDataViewable = $sCsvData;
}
echo "
\n";
echo "
\n";
echo " $sArguments\n";
echo "
\n";
echo "
\n";
echo "
$sCsvDataViewable
\n";
echo "
\n";
echo "
\n";
echo "
$sRes
\n";
echo "
\n";
echo "
{$aSingleScenario['desc']}
\n";
$sClass = $aSingleScenario['target_class'];
$aTargetData = $aSingleScenario['target_data'];
$aSourceData = $aSingleScenario['source_data'];
$aTargetAttributes = array_shift($aTargetData);
$aSourceAttributes = array_shift($aSourceData);
if (count($aSourceData) + 1 != count($aTargetData))
{
throw new Exception("Target data must contain exactly ".(count($aSourceData) + 1)." items, found ".count($aTargetData));
}
// Create the data source
//
$oDataSource = new SynchroDataSource();
$oDataSource->Set('name', 'Test data sync '.time());
$oDataSource->Set('description', 'unit test - created automatically');
$oDataSource->Set('status', 'production');
$oDataSource->Set('user_id', 0);
$oDataSource->Set('scope_class', $sClass);
$oDataSource->Set('scope_restriction', '');
$oDataSource->Set('full_load_periodicity', $aSingleScenario['full_load_periodicity']);
$oDataSource->Set('reconciliation_policy', $aSingleScenario['reconciliation_policy']);
$oDataSource->Set('action_on_zero', $aSingleScenario['action_on_zero']);
$oDataSource->Set('action_on_one', $aSingleScenario['action_on_one']);
$oDataSource->Set('action_on_multiple', $aSingleScenario['action_on_multiple']);
$oDataSource->Set('delete_policy', $aSingleScenario['delete_policy']);
$oDataSource->Set('delete_policy_update', $aSingleScenario['delete_policy_update']);
$oDataSource->Set('delete_policy_retention', $aSingleScenario['delete_policy_retention']);
$iDataSourceId = $this->ObjectToDB($oDataSource, true /* reload */);
$oAttributeSet = $oDataSource->Get('attribute_list');
while ($oAttribute = $oAttributeSet->Fetch())
{
if (array_key_exists($oAttribute->Get('attcode'), $aSingleScenario['attributes']))
{
$aAttribInfo = $aSingleScenario['attributes'][$oAttribute->Get('attcode')];
if (array_key_exists('reconciliation_attcode', $aAttribInfo))
{
$oAttribute->Set('reconciliation_attcode', $aAttribInfo['reconciliation_attcode']);
}
$oAttribute->Set('update', $aAttribInfo['do_update']);
$oAttribute->Set('reconcile', $aAttribInfo['do_reconcile']);
}
else
{
$oAttribute->Set('update', false);
$oAttribute->Set('reconcile', false);
}
$this->UpdateObjectInDB($oAttribute);
}
// Prepare list of prefixes -> make sure objects are unique with regard to the reconciliation scheme
$aPrefixes = array(); // attcode => prefix
foreach($aSourceAttributes as $iDummy => $sAttCode)
{
$aPrefixes[$sAttCode] = ''; // init with something
}
foreach($aSingleScenario['attributes'] as $sAttCode => $aAttribInfo)
{
if (isset($aAttribInfo['automatic_prefix']) && $aAttribInfo['automatic_prefix'])
{
$aPrefixes[$sAttCode] = 'TEST_'.$iDataSourceId.'_';
}
}
// List existing objects (to be ignored in the analysis
//
$oAllObjects = new DBObjectSet(new DBObjectSearch($sClass));
$aExisting = $oAllObjects->ToArray(true);
$sExistingIds = implode(', ', array_keys($aExisting));
// Create the initial object list
//
$aInitialTarget = $aTargetData[0];
foreach($aInitialTarget as $aObjFields)
{
$oNewTarget = MetaModel::NewObject($sClass);
foreach($aTargetAttributes as $iAtt => $sAttCode)
{
$oNewTarget->Set($sAttCode, $aPrefixes[$sAttCode].$aObjFields[$iAtt]);
}
$this->ObjectToDB($oNewTarget);
}
foreach($aTargetData as $iRow => $aExpectedObjects)
{
sleep(2);
// Check the status (while ignoring existing objects)
//
if (empty($sExistingIds))
{
$oObjects = new DBObjectSet(DBObjectSearch::FromOQL("SELECT $sClass"));
}
else
{
$oObjects = new DBObjectSet(DBObjectSearch::FromOQL("SELECT $sClass WHERE id NOT IN($sExistingIds)"));
}
$aFound = $oObjects->ToArray();
$aErrors_Unexpected = array();
foreach($aFound as $iObj => $oObj)
{
// Is this object in the expected objects list
$bFoundMatch = false;
foreach($aExpectedObjects as $iExp => $aValues)
{
$bDoesMatch = true;
foreach($aTargetAttributes as $iCol => $sAttCode)
{
if ($oObj->Get($sAttCode) != $aPrefixes[$sAttCode].$aValues[$iCol])
{
$bDoesMatch = false;
break;
}
}
if ($bDoesMatch)
{
$bFoundMatch = true;
unset($aExpectedObjects[$iExp]);
break;
}
}
if (!$bFoundMatch)
{
$aErrors_Unexpected[] = $oObj->GetKey();
}
}
// Display the current status
//
echo "
Status at step $iRow
\n";
$aCurrentDataSet = array();
foreach($aFound as $iObj => $oObj)
{
$aObjDesc = array(
'Status' => (in_array($iObj, $aErrors_Unexpected) ? 'unexpected' : 'ok'),
'Object' => $oObj->GetHyperLink()
);
foreach($aTargetAttributes as $iCol => $sAttCode)
{
$aObjDesc[$sAttCode] = $oObj->Get($sAttCode);
}
$aCurrentDataSet[] = $aObjDesc;
}
if (count($aExpectedObjects) > 0)
{
foreach($aExpectedObjects as $iExp => $aValues)
{
$aObjDesc = array(
'Status' => 'missing',
'Object' => 'n/a'
);
foreach($aTargetAttributes as $iCol => $sAttCode)
{
$aObjDesc[$sAttCode] = $aPrefixes[$sAttCode].$aValues[$iCol];
}
$aCurrentDataSet[] = $aObjDesc;
}
}
echo MyHelpers::make_table_from_assoc_array($aCurrentDataSet);
if ((count($aErrors_Unexpected) > 0) || (count($aExpectedObjects) > 0))
{
throw new UnitTestException("The current status in iTop does not match the expectations");
}
// If not on the final row, run a data exchange sequence
//
if (array_key_exists($iRow, $aSourceData))
{
$aToBeLoaded = $aSourceData[$iRow];
$sCsvData = implode(';', $aSourceAttributes)."\n";
foreach($aToBeLoaded as $aDataRow)
{
$aFinalData = array();
foreach($aDataRow as $iCol => $value)
{
if (is_null($value))
{
$aFinalData[] = '
';
}
else
{
$sAttCode = $aSourceAttributes[$iCol];
$aFinalData[] = $aPrefixes[$sAttCode].$value;
}
}
$sCsvData .= implode(';', $aFinalData)."\n";
}
$aPostData = array('csvdata' => $sCsvData);
$aImportArgs = array(
'data_source_id' => $iDataSourceId,
'separator' => ';',
'simulate' => 0,
'output' => 'details',
);
$aGetParams = array();
$aGetParamReport = array();
foreach($aImportArgs as $sArg => $sValue)
{
$aGetParams[] = $sArg.'='.urlencode($sValue);
$aGetParamReport[] = $sArg.'='.$sValue;
}
$sGetParams = implode('&', $aGetParams);
$sLogin = isset($aSingleScenario['login']) ? $aSingleScenario['login'] : 'admin';
$sPassword = isset($aSingleScenario['password']) ? $aSingleScenario['password'] : 'admin';
$sRes = self::DoPostRequestAuth('../synchro/synchro_import.php?'.$sGetParams, $aPostData, $sLogin, $sPassword);
// Report the load results
//
if (strlen($sCsvData) > 5000)
{
$sCsvDataViewable = 'INPUT TOO LONG TO BE DISPLAYED ('.strlen($sCsvData).")\n".substr($sCsvData, 0, 500)."\n... TO BE CONTINUED";
}
else
{
$sCsvDataViewable = $sCsvData;
}
$sCsvDataViewable = htmlentities($sCsvDataViewable, ENT_QUOTES, 'UTF-8');
echo "\n";
echo "
$sCsvDataViewable
\n";
echo "
$sRes
\n";
if (stripos($sRes, 'exception') !== false)
{
throw new UnitTestException('Encountered an Exception during the last import/synchro');
}
}
}
return;
echo "Note: You may also want to try the sample SOAP client itopsoap.examples.php
\n";
$aSOAPMapping = SOAPMapping::GetMapping();
// this file is generated dynamically with location = here
$sWsdlUri = 'http'.(utils::IsConnectionSecure() ? 's' : '').'://'.$_SERVER['SERVER_NAME'].':'.$_SERVER['SERVER_PORT'].dirname($_SERVER['SCRIPT_NAME']).'/../webservices/itop.wsdl.php';
ini_set("soap.wsdl_cache_enabled","0");
foreach ($this->m_aTestSpecs as $iPos => $aWebService)
{
echo "SOAP call #$iPos - {$aWebService['verb']}
\n";
echo "Using WSDL: $sWsdlUriForService
\n";
echo "{$aWebService['explain result']}
\n";
$sWsdlUriForService = $sWsdlUri.'?service_category='.$aWebService['service_category'];
$this->m_SoapClient = new SoapClient
(
$sWsdlUriForService,
array(
'classmap' => $aSOAPMapping,
'trace' => 1,
)
);
if (false)
{
self::DumpVariable($this->m_SoapClient->__getTypes());
}
try
{
$oRes = call_user_func_array(array($this->m_SoapClient, $aWebService['verb']), $aWebService['args']);
}
catch(SoapFault $e)
{
print "\n";
print "Request: \n".htmlspecialchars($this->m_SoapClient->__getLastRequest()) ."\n";
print "Response: \n".htmlspecialchars($this->m_SoapClient->__getLastResponse())."\n";
print "
";
print "Response in HTML: ".$this->m_SoapClient->__getLastResponse()."
";
throw $e;
}
self::DumpVariable($oRes);
print "\n";
print "Request: \n".htmlspecialchars($this->m_SoapClient->__getLastRequest()) ."\n";
print "Response: \n".htmlspecialchars($this->m_SoapClient->__getLastResponse())."\n";
print "
";
if ($oRes instanceof SOAPResult)
{
$res = $oRes->status;
}
elseif ($oRes instanceof SOAPSimpleResult)
{
$res = $oRes->status;
}
else
{
$res = $oRes;
}
if ($res != $aWebService['expected result'])
{
echo "Expecting:
\n";
var_dump($aWebService['expected result']);
echo "Obtained:
\n";
var_dump($res);
throw new UnitTestException("Expecting result '{$aWebService['expected result']}', but got '$res'");
}
}
}
}
abstract class TestSoapDirect extends TestBizModel
{
static public function GetName() {return 'Test web services locally';}
static public function GetDescription() {return 'Invoke the service directly (troubleshooting)';}
protected $m_aTestSpecs;
protected function DoExecute()
{
foreach ($this->m_aTestSpecs as $iPos => $aWebService)
{
$sServiceClass = $aWebService['service_category'];
if (empty($sServiceClass)) $sServiceClass = 'BasicServices';
$oWebServices = new $sServiceClass();
echo "SOAP call #$iPos - {$aWebService['verb']}
\n";
echo "{$aWebService['explain result']}
\n";
$oRes = call_user_func_array(array($oWebServices, $aWebService['verb']), $aWebService['args']);
self::DumpVariable($oRes);
if ($oRes instanceof SOAPResult)
{
$res = $oRes->status;
}
elseif ($oRes instanceof SOAPSimpleResult)
{
$res = $oRes->status;
}
else
{
$res = $oRes;
}
if ($res != $aWebService['expected result'])
{
echo "Expecting:
\n";
var_dump($aWebService['expected result']);
echo "Obtained:
\n";
var_dump($res);
throw new UnitTestException("Expecting result '{$aWebService['expected result']}', but got '$res'");
}
}
return true;
}
}
class TestSoap_Tickets extends TestSoap
{
static public function GetName() {return 'Test SOAP - create ticket';}
protected function DoExecute()
{
global $aCreateTicketSpecs;
$this->m_aTestSpecs = $aCreateTicketSpecs;
return parent::DoExecute();
}
}
class TestSoapDirect_Tickets extends TestSoapDirect
{
static public function GetName() {return 'Test SOAP without SOAP - create ticket';}
protected function DoExecute()
{
global $aCreateTicketSpecs;
$this->m_aTestSpecs = $aCreateTicketSpecs;
return parent::DoExecute();
}
}
class TestSoap_ManageCloudUsers extends TestSoap
{
static public function GetName() {return 'Test SOAP - manage Cloud Users';}
protected function DoExecute()
{
global $aManageCloudUsersSpecs;
$this->m_aTestSpecs = $aManageCloudUsersSpecs;
return parent::DoExecute();
}
}
class TestSoapDirect_ManageCloudUsers extends TestSoapDirect
{
static public function GetName() {return 'Test SOAP without SOAP - manage Cloud Users';}
protected function DoExecute()
{
global $aManageCloudUsersSpecs;
$this->m_aTestSpecs = $aManageCloudUsersSpecs;
return parent::DoExecute();
}
}
////////////////////// End of SOAP TESTS
class TestTriggerAndEmail extends TestBizModel
{
static public function GetName() {return 'Test trigger and email';}
static public function GetDescription() {return 'Create a trigger and an email, then activates the trigger';}
protected function CreateEmailSpec($oTrigger, $sStatus, $sTo, $sCC, $sTesterEmail)
{
$oAction = MetaModel::NewObject("ActionEmail");
$oAction->Set("status", $sStatus);
$oAction->Set("name", "New server");
$oAction->Set("test_recipient", $sTesterEmail);
$oAction->Set("from", $sTesterEmail);
$oAction->Set("reply_to", $sTesterEmail);
$oAction->Set("to", $sTo);
$oAction->Set("cc", $sCC);
$oAction->Set("bcc", "");
$oAction->Set("subject", "New server: '\$this->name()$'");
$oAction->Set("body", "Dear customer,
We have created the server \$this->hyperlink()$ in the IT infrastructure database.
You will be further notified when it is in Production.
The IT infrastructure management team.
Here are some accentuated characters for french people: 'ééà '
");
$oAction->Set("importance", "low");
$iActionId = $this->ObjectToDB($oAction, true);
$oLink = MetaModel::NewObject("lnkTriggerAction");
$oLink->Set("trigger_id", $oTrigger->GetKey());
$oLink->Set("action_id", $iActionId);
$oLink->Set("order", "1");
$iLink = $this->ObjectToDB($oLink, true);
}
protected function DoExecute()
{
$oMyPerson = MetaModel::NewObject("Person");
$oMyPerson->Set("name", "testemail1");
$oMyPerson->Set("first_name", "theodore");
$oMyPerson->Set("org_id", "1");
$oMyPerson->Set("email", "romain.quetiez@combodo.com");
$iPersonId = $this->ObjectToDB($oMyPerson, true);
$oMyPerson = MetaModel::NewObject("Person");
$oMyPerson->Set("name", "testemail2");
$oMyPerson->Set("first_name", "theodore");
$oMyPerson->Set("org_id", "1");
$oMyPerson->Set("email", "denis.flaven@combodo.com");
$iPersonId = $this->ObjectToDB($oMyPerson, true);
$oMyPerson = MetaModel::NewObject("Person");
$oMyPerson->Set("name", "testemail3");
$oMyPerson->Set("first_name", "theodore");
$oMyPerson->Set("org_id", "1");
$oMyPerson->Set("email", "erwan.taloc@combodo.com");
$iPersonId = $this->ObjectToDB($oMyPerson, true);
$oMyServer = MetaModel::NewObject("Server");
$oMyServer->Set("name", "wfr.terminator.com");
$oMyServer->Set("status", "production");
$oMyServer->Set("org_id", 2);
$iServerId = $this->ObjectToDB($oMyServer, true);
$oMyTrigger = MetaModel::NewObject("TriggerOnStateEnter");
$oMyTrigger->Set("description", "Testor");
$oMyTrigger->Set("target_class", "Server");
$oMyTrigger->Set("state", "Shipped");
$iTriggerId = $this->ObjectToDB($oMyTrigger, true);
// Error in OQL field(s)
//
$this->CreateEmailSpec
(
$oMyTrigger,
'test',
"SELECT Person WHERE naime = 'Dali'",
"SELECT Server",
'romain.quetiez@combodo.com'
);
// Error: no recipient
//
$this->CreateEmailSpec
(
$oMyTrigger,
'test',
"",
"",
'romain.quetiez@combodo.com'
);
// Test
//
$this->CreateEmailSpec
(
$oMyTrigger,
'test',
"SELECT Person WHERE name LIKE 'testemail%'",
"SELECT Person",
'romain.quetiez@combodo.com'
);
// Test failing because of a wrong test recipient address
//
$this->CreateEmailSpec
(
$oMyTrigger,
'test',
"SELECT Person WHERE name LIKE 'testemail%'",
"",
'toto@walibi.bg'
);
// Normal behavior
//
$this->CreateEmailSpec
(
$oMyTrigger,
'enabled',
"SELECT Person WHERE name LIKE 'testemail%'",
"",
'romain.quetiez@combodo.com'
);
// Does nothing, because it is disabled
//
$this->CreateEmailSpec
(
$oMyTrigger,
'disabled',
"SELECT Person WHERE name = 'testemail%'",
"",
'romain.quetiez@combodo.com'
);
$oMyTrigger->DoActivate($oMyServer->ToArgs('this'));
return true;
}
}
class TestDBProperties extends TestBizModel
{
static public function GetName()
{
return 'Itop - DB Properties';
}
static public function GetDescription()
{
return 'Write and read a dummy property';
}
protected function DoExecute()
{
$sName = 'test';
DBProperty::SetProperty($sName, 'unix time:'.time(), 'means nothing', 'done with the automated test utility');
$sValue = DBProperty::GetProperty($sName, 'defaults to this because the table has not been created (1.0.1 install?)');
echo "Write... then read property $sName, found: '$sValue'
\n";
}
}
class TestCreateObjects extends TestBizModel
{
static public function GetName()
{
return 'Itop - create objects';
}
static public function GetDescription()
{
return 'Create weird objects (reproduce a bug?)';
}
protected function DoExecute()
{
$oMyObj = MetaModel::NewObject("Server");
$oMyObj->Set("name", "test".rand(1,1000));
$oMyObj->Set("org_id", 2);
$oMyObj->Set("status", 'production');
$this->ObjectToDB($oMyObj, $bReload = true);
echo "Created: {$oMyObj->GetHyperLink()}
";
$sTicketRef = "I-abcdef";
echo "Creating: $sTicketRef
";
$oMyObj = MetaModel::NewObject("Incident");
$oMyObj->Set("ref", $sTicketRef);
$oMyObj->Set("title", "my title");
$oMyObj->Set("description", "my description");
$oMyObj->Set("ticket_log", "my ticket log");
$oMyObj->Set("start_date", "2010-03-08 17:37:00");
$oMyObj->Set("status", "resolved");
$oMyObj->Set("caller_id", 1);
$oMyObj->Set("org_id", 1);
$oMyObj->Set("urgency", 3);
$oMyObj->Set("agent_id", 1);
$oMyObj->Set("close_date", "0000-00-00 00:00:00");
$oMyObj->Set("last_update", "2010-04-08 16:47:29");
$oMyObj->Set("solution", "branche ton pc!");
// External key given as a string -> should be casted to an integer
$oMyObj->Set("service_id", "1");
$oMyObj->Set("servicesubcategory_id", "1");
$oMyObj->Set("product", "");
$oMyObj->Set("impact", 2);
$oMyObj->Set("priority", 3);
$oMyObj->Set("related_problem_id", 0);
$oMyObj->Set("related_change_id", 0);
$oMyObj->Set("assignment_date", "");
$oMyObj->Set("resolution_date", "");
$oMyObj->Set("tto_escalation_deadline", "");
$oMyObj->Set("ttr_escalation_deadline", "");
$oMyObj->Set("closure_deadline", "");
$oMyObj->Set("resolution_code", "fixed");
$oMyObj->Set("user_satisfaction", "");
$oMyObj->Set("user_commment", "");
$oMyObj->Set("workgroup_id", 4);
$this->ObjectToDB($oMyObj, $bReload = true);
echo "Created: {$oMyObj->GetHyperLink()}
";
}
}
class TestSetLinkset extends TestBizModel
{
static public function GetName()
{
return 'Itop - Link set from a string';
}
static public function GetDescription()
{
return 'Create a user account, setting its profile by the mean of a string (prerequisite to CSV import of linksets)';
}
protected function DoExecute()
{
$oUser = new UserLocal();
$oUser->Set('login', 'patator'.time());
$oUser->Set('password', 'patator');
//$oUser->Set('contactid', 0);
//$oUser->Set('language', $sLanguage);
$sLinkSetSpec = "profileid:10;reason:service manager|profileid->name:Problem Manager;'reason:problem manager;glandeur";
$oAttDef = MetaModel::GetAttributeDef('UserLocal', 'profile_list');
$oSet = $oAttDef->MakeValueFromString($sLinkSetSpec, $bLocalizedValue = false);
$oUser->Set('profile_list', $oSet);
// Create a change to record the history of the User object
$this->ObjectToDB($oUser, $bReload = true);
echo "Created: {$oUser->GetHyperLink()}
";
}
}
class TestEmailAsynchronous extends TestBizModel
{
static public function GetName()
{
return 'Itop - Asynchronous email';
}
static public function GetDescription()
{
return 'Queues a request to send an email';
}
protected function DoExecute()
{
for ($i = 0 ; $i < 2 ; $i++)
{
$oMail = new Email();
$oMail->SetRecipientTO('romain.quetiez@combodo.com');
$oMail->SetRecipientFrom('romain.quetiez@combodo.com');
$oMail->SetRecipientCC('romainquetiez@yahoo.fr');
$oMail->SetSubject('automated test - '.$i);
$oMail->SetBody('this is one is entirely working fine '.time());
$iRes = $oMail->Send($aIssues, false);
switch ($iRes)
{
case EMAIL_SEND_OK:
echo "EMAIL_SEND_OK
\n";
break;
case EMAIL_SEND_PENDING:
echo "EMAIL_SEND_PENDING
\n";
break;
case EMAIL_SEND_ERROR:
echo "EMAIL_SEND_ERROR:
\n";
foreach($aIssues as $sIssue)
{
echo "Issue: $sIssue
\n";
}
break;
}
}
}
}
abstract class TestLinkSet extends TestBizModel
{
protected function StandardizedDump($oSet, $sAttPrefixToIgnore)
{
if (!$oSet->m_bLoaded) $oSet->Load();
$oSet->Rewind();
$aRet = array();
while($oObject = $oSet->Fetch())
{
$aValues = array();
foreach(MetaModel::ListAttributeDefs(get_class($oObject)) as $sAttCode => $oAttDef)
{
//if (!$oAttDef->IsPartOfFingerprint()) continue;
//if ($oAttDef->IsMagic()) continue;
if ($sAttCode == 'friendlyname') continue;
if (substr($sAttCode, -strlen('_archive_flag')) == '_archive_flag') continue;
if (substr($sAttCode, -strlen('_obsolescence_flag')) == '_obsolescence_flag') continue;
if (substr($sAttCode, 0, strlen($sAttPrefixToIgnore)) == $sAttPrefixToIgnore) continue;
if ($oAttDef->IsScalar())
{
$aValues[] = $oObject->Get($sAttCode);
}
}
$aRet[] = implode(', ', $aValues);
}
sort($aRet);
return $aRet;
}
}
class TestLinkSetRecording_NN_WithDuplicates extends TestLinkSet
{
static public function GetName()
{
return 'Linkset N-N having duplicated allowed (Connectable CI to Network Device)';
}
static public function GetDescription()
{
return 'Simulate CSV/data synchro type of recording. Check the values and the history. Lots of issues there: #1145, #1146 and #1147';
}
protected function DoExecute()
{
CMDBSource::Query('START TRANSACTION');
//CMDBSource::Query('ROLLBACK'); automatique !
////////////////////////////////////////////////////////////////////////////////
// Set the stage
//
$oServer = MetaModel::NewObject('Server');
$oServer->Set('name', 'unit test linkset');
$oServer->Set('org_id', 3);
$oServer->DBInsert();
$iServer = $oServer->GetKey();
$oTypes = new DBObjectSet(DBObjectSearch::FromOQL('SELECT NetworkDeviceType WHERE name = "Router"'));
$oType = $oTypes->fetch();
$oDevice = MetaModel::NewObject('NetworkDevice');
$oDevice->Set('name', 'test device A');
$oDevice->Set('org_id', 3);
$oDevice->Set('networkdevicetype_id', $oType->GetKey());
$oDevice->DBInsert();
$iDev1 = $oDevice->GetKey();
$oDevice = MetaModel::NewObject('NetworkDevice');
$oDevice->Set('name', 'test device B');
$oDevice->Set('org_id', 3);
$oDevice->Set('networkdevicetype_id', $oType->GetKey());
$oDevice->DBInsert();
$iDev2 = $oDevice->GetKey();
////////////////////////////////////////////////////////////////////////////////
// Scenarii
//
$aScenarii = array(
array(
'description' => 'Add the first item',
'links' => array(
array(
'networkdevice_id' => $iDev1,
'connectableci_id' => $iServer,
'network_port' => '',
'device_port' => '',
),
),
'expected-res' => array (
"$iDev1, test device A, unit test linkset, , , downlink, test device A",
),
'history_added' => 1,
'history_removed' => 0,
'history_modified' => 0,
),
array(
'description' => 'Modify the unique item',
'links' => array(
array(
'networkdevice_id' => $iDev1,
'connectableci_id' => $iServer,
'network_port' => 'devTagada',
'device_port' => '',
),
),
'expected-res' => array (
"$iDev1, test device A, unit test linkset, devTagada, , downlink, test device A",
),
'history_added' => 1,
'history_removed' => 1,
'history_modified' => 0,
),
array(
'description' => 'Modify again the original item and add a second item',
'links' => array(
array(
'networkdevice_id' => $iDev1,
'connectableci_id' => $iServer,
'network_port' => '',
'device_port' => '',
),
array(
'networkdevice_id' => $iDev2,
'connectableci_id' => $iServer,
'network_port' => '',
'device_port' => '',
),
),
'expected-res' => array (
"$iDev1, test device A, unit test linkset, , , downlink, test device A",
"$iDev2, test device B, unit test linkset, , , downlink, test device B",
),
'history_added' => 2,
'history_removed' => 1,
'history_modified' => 0,
),
array(
'description' => 'No change, the links are added in the reverse order',
'links' => array(
array(
'networkdevice_id' => $iDev2,
'connectableci_id' => $iServer,
'network_port' => '',
'device_port' => '',
),
array(
'networkdevice_id' => $iDev1,
'connectableci_id' => $iServer,
'network_port' => '',
'device_port' => '',
),
),
'expected-res' => array (
"$iDev1, test device A, unit test linkset, , , downlink, test device A",
"$iDev2, test device B, unit test linkset, , , downlink, test device B",
),
'history_added' => 0,
'history_removed' => 0,
'history_modified' => 0,
),
array(
'description' => 'Change on attribute on both links at the same time',
'links' => array(
array(
'networkdevice_id' => $iDev2,
'connectableci_id' => $iServer,
'network_port' => 'PortDev B',
'device_port' => '',
),
array(
'networkdevice_id' => $iDev1,
'connectableci_id' => $iServer,
'network_port' => 'PortDev A',
'device_port' => '',
),
),
'expected-res' => array (
"$iDev1, test device A, unit test linkset, PortDev A, , downlink, test device A",
"$iDev2, test device B, unit test linkset, PortDev B, , downlink, test device B",
),
'history_added' => 2,
'history_removed' => 2,
'history_modified' => 0,
),
array(
'description' => 'Removing A',
'links' => array(
array(
'networkdevice_id' => $iDev2,
'connectableci_id' => $iServer,
'network_port' => 'PortDev B',
'device_port' => '',
),
),
'expected-res' => array (
"$iDev2, test device B, unit test linkset, PortDev B, , downlink, test device B",
),
'history_added' => 0,
'history_removed' => 1,
'history_modified' => 0,
),
array(
'description' => 'Adding B again - with a different port (duplicate!)',
'links' => array(
array(
'networkdevice_id' => $iDev2,
'connectableci_id' => $iServer,
'network_port' => 'port_123',
'device_port' => '',
),
array(
'networkdevice_id' => $iDev2,
'connectableci_id' => $iServer,
'network_port' => 'port_456',
'device_port' => '',
),
),
'expected-res' => array (
"$iDev2, test device B, unit test linkset, port_123, , downlink, test device B",
"$iDev2, test device B, unit test linkset, port_456, , downlink, test device B",
),
'history_added' => 2,
'history_removed' => 1,
'history_modified' => 0,
),
array(
'description' => 'No change (creating a set with the reloaded links, like in the UI)',
'links' => array(
array(
'id' => "SELECT lnkConnectableCIToNetworkDevice WHERE networkdevice_id = $iDev2 AND connectableci_id = $iServer AND network_port = 'port_123'",
'networkdevice_id' => $iDev2,
'connectableci_id' => $iServer,
'network_port' => 'port_123',
'device_port' => '',
),
array(
'id' => "SELECT lnkConnectableCIToNetworkDevice WHERE networkdevice_id = $iDev2 AND connectableci_id = $iServer AND network_port = 'port_456'",
'networkdevice_id' => $iDev2,
'connectableci_id' => $iServer,
'network_port' => 'port_456',
'device_port' => '',
),
),
'expected-res' => array (
"$iDev2, test device B, unit test linkset, port_123, , downlink, test device B",
"$iDev2, test device B, unit test linkset, port_456, , downlink, test device B",
),
'history_added' => 0,
'history_removed' => 0,
'history_modified' => 0,
),
array(
'description' => 'Change an attribute on one link (based on reloaded links, like in the UI)',
'links' => array(
array(
'id' => "SELECT lnkConnectableCIToNetworkDevice WHERE networkdevice_id = $iDev2 AND connectableci_id = $iServer AND network_port = 'port_123'",
'networkdevice_id' => $iDev2,
'connectableci_id' => $iServer,
'network_port' => 'port_123_modified',
'device_port' => '',
),
array(
'id' => "SELECT lnkConnectableCIToNetworkDevice WHERE networkdevice_id = $iDev2 AND connectableci_id = $iServer AND network_port = 'port_456'",
'networkdevice_id' => $iDev2,
'connectableci_id' => $iServer,
'network_port' => 'port_456',
'device_port' => '',
),
),
'expected-res' => array (
"$iDev2, test device B, unit test linkset, port_123_modified, , downlink, test device B",
"$iDev2, test device B, unit test linkset, port_456, , downlink, test device B",
),
'history_added' => 0,
'history_removed' => 0,
'history_modified' => 1,
),
array(
'description' => 'Remove the second link (set based on reloaded links, like in the UI)',
'links' => array(
array(
'id' => "SELECT lnkConnectableCIToNetworkDevice WHERE networkdevice_id = $iDev2 AND connectableci_id = $iServer AND network_port = 'port_123_modified'",
'networkdevice_id' => $iDev2,
'connectableci_id' => $iServer,
'network_port' => 'port_123_modified',
'device_port' => '',
),
),
'expected-res' => array (
"$iDev2, test device B, unit test linkset, port_123_modified, , downlink, test device B",
),
'history_added' => 0,
'history_removed' => 1,
'history_modified' => 0,
),
array(
'description' => 'Remove all',
'links' => array(
),
'expected-res' => array (
),
'history_added' => 0,
'history_removed' => 1,
'history_modified' => 0,
),
array(
'description' => 'Create one link from scratch, no port, to prepare for the next test case',
'links' => array(
array(
'networkdevice_id' => $iDev2,
'connectableci_id' => $iServer,
'network_port' => 'portX',
'device_port' => '',
),
),
'expected-res' => array (
"$iDev2, test device B, unit test linkset, portX, , downlink, test device B",
),
'history_added' => 1,
'history_removed' => 0,
'history_modified' => 0,
),
array(
'description' => 'Device B twice (same characteristics) - known issue #1145 (test failing until we fix it)',
'links' => array(
array(
'networkdevice_id' => $iDev2,
'connectableci_id' => $iServer,
'network_port' => 'portX',
'device_port' => '',
),
array(
'networkdevice_id' => $iDev2,
'connectableci_id' => $iServer,
'network_port' => 'portX',
'device_port' => '',
),
),
'expected-res' => array (
"$iDev2, test device B, unit test linkset, portX, , downlink, test device B",
"$iDev2, test device B, unit test linkset, portX, , downlink, test device B",
),
'history_added' => 1,
'history_removed' => 0,
'history_modified' => 0,
),
);
foreach ($aScenarii as $aScenario)
{
echo "".$aScenario['description']."
\n";
$oChange = MetaModel::NewObject("CMDBChange");
$oChange->Set("date", time());
$oChange->Set("userinfo", CMDBChange::GetCurrentUserName());
$oChange->Set("origin", 'custom-extension');
$oChange->DBInsert();
CMDBObject::SetCurrentChange($oChange);
$iChange = $oChange->GetKey();
// Prepare set
$oLinkset = DBObjectSet::FromScratch('lnkConnectableCIToNetworkDevice');
foreach ($aScenario['links'] as $aLinkData)
{
if (array_key_exists('id', $aLinkData))
{
$sOQL = $aLinkData['id'];
$oSet = new DBObjectSet(DBObjectSearch::FromOQL($sOQL));
$oLink1 = $oSet->Fetch();
if (!is_object($oLink1)) throw new Exception('Failed to find the lnkConnectableCIToNetworkDevice: '.$sOQL);
}
else
{
$oLink1 = MetaModel::NewObject('lnkConnectableCIToNetworkDevice');
}
foreach ($aLinkData as $sAttCode => $value)
{
if ($sAttCode == 'id') continue;
$oLink1->Set($sAttCode, $value);
}
$oLinkset->AddObject($oLink1);
}
// Write
$oServer = MetaModel::GetObject('Server', $iServer);
$oServer->Set('networkdevice_list', $oLinkset);
$oServer->DBWrite();
// Check Results
$bFoundIssue = false;
$oServer = MetaModel::GetObject('Server', $iServer);
$oLinkset = $oServer->Get('networkdevice_list');
$aRes = $this->StandardizedDump($oLinkset, 'connectableci_id');
$sRes = var_export($aRes, true);
echo "Found: ".$sRes."
\n";
$sExpectedRes = var_export($aScenario['expected-res'], true);
if ($sRes != $sExpectedRes)
{
$bFoundIssue = true;
echo "NOT COMPLIANT!!! Expecting: ".$sExpectedRes."
\n";
}
// Check History
$aQueryParams = array('change' => $iChange, 'objclass' => get_class($oServer), 'objkey' => $oServer->GetKey());
$oAdded = new DBObjectSet(DBSearch::FromOQL("SELECT CMDBChangeOpSetAttributeLinksAddRemove WHERE objclass = :objclass AND objkey = :objkey AND change = :change AND type = 'added'"), array(), $aQueryParams);
echo "added: ".$oAdded->Count()."
\n";
if ($aScenario['history_added'] != $oAdded->Count())
{
$bFoundIssue = true;
echo "NOT COMPLIANT!!! Expecting: ".$aScenario['history_added']."
\n";
}
$oRemoved = new DBObjectSet(DBSearch::FromOQL("SELECT CMDBChangeOpSetAttributeLinksAddRemove WHERE objclass = :objclass AND objkey = :objkey AND change = :change AND type = 'removed'"), array(), $aQueryParams);
echo "removed: ".$oRemoved->Count()."
\n";
if ($aScenario['history_removed'] != $oRemoved->Count())
{
$bFoundIssue = true;
echo "NOT COMPLIANT!!! Expecting: ".$aScenario['history_removed']."
\n";
}
$oModified = new DBObjectSet(DBSearch::FromOQL("SELECT CMDBChangeOpSetAttributeLinksTune WHERE objclass = :objclass AND objkey = :objkey AND change = :change"), array(), $aQueryParams);
echo "modified: ".$oModified->Count()."
\n";
if ($aScenario['history_modified'] != $oModified->Count())
{
$bFoundIssue = true;
echo "NOT COMPLIANT!!! Expecting: ".$aScenario['history_modified']."
\n";
}
if ($bFoundIssue)
{
throw new Exception('Stopping on failed scenario');
}
}
}
}
class TestLinkSetRecording_NN_NoDuplicates extends TestLinkSet
{
static public function GetName()
{
return 'Linksets N-N in general (99% of them)';
}
static public function GetDescription()
{
return 'Simulate CSV/data synchro type of recording. Check the values and the history.';
}
protected function DoExecute()
{
CMDBSource::Query('START TRANSACTION');
//CMDBSource::Query('ROLLBACK'); automatique !
////////////////////////////////////////////////////////////////////////////////
// Set the stage
//
$oTeam = MetaModel::NewObject('Team');
$oTeam->Set('name', 'unit test linkset');
$oTeam->Set('org_id', 3);
$oTeam->DBInsert();
$iTeam = $oTeam->GetKey();
$oPerson = MetaModel::NewObject('Person');
$oPerson->Set('name', 'test person A');
$oPerson->Set('first_name', 'totoche');
$oPerson->Set('org_id', 3);
$oPerson->DBInsert();
$iPerson1 = $oPerson->GetKey();
$oPerson = MetaModel::NewObject('Person');
$oPerson->Set('name', 'test person B');
$oPerson->Set('first_name', 'totoche');
$oPerson->Set('org_id', 3);
$oPerson->DBInsert();
$iPerson2 = $oPerson->GetKey();
$oTypes = new DBObjectSet(DBSearch::FromOQL('SELECT ContactType WHERE name="Manager"'));
$iRole = $oTypes->Fetch()->GetKey();
////////////////////////////////////////////////////////////////////////////////
// Scenarii
//
$aScenarii = array(
array(
'description' => 'Add the first item',
'links' => array(
array(
'person_id' => $iPerson1,
'team_id' => $iTeam,
'role_id' => 0,
),
),
'expected-res' => array (
"unit test linkset, $iPerson1, test person A, 0, , totoche test person A, ",
),
'history_added' => 1,
'history_removed' => 0,
'history_modified' => 0,
),
array(
'description' => 'Modify the unique item',
'links' => array(
array(
'person_id' => $iPerson1,
'team_id' => $iTeam,
'role_id' => $iRole,
),
),
'expected-res' => array (
"unit test linkset, $iPerson1, test person A, $iRole, Manager, totoche test person A, Manager",
),
'history_added' => 0,
'history_removed' => 0,
'history_modified' => 1,
),
array(
'description' => 'Modify again the original item and add a second item',
'links' => array(
array(
'person_id' => $iPerson1,
'team_id' => $iTeam,
'role_id' => 0,
),
array(
'person_id' => $iPerson2,
'team_id' => $iTeam,
'role_id' => 0,
),
),
'expected-res' => array (
"unit test linkset, $iPerson1, test person A, 0, , totoche test person A, ",
"unit test linkset, $iPerson2, test person B, 0, , totoche test person B, ",
),
'history_added' => 1,
'history_removed' => 0,
'history_modified' => 1,
),
array(
'description' => 'No change, the links are added in the reverse order',
'links' => array(
array(
'person_id' => $iPerson2,
'team_id' => $iTeam,
'role_id' => 0,
),
array(
'person_id' => $iPerson1,
'team_id' => $iTeam,
'role_id' => 0,
),
),
'expected-res' => array (
"unit test linkset, $iPerson1, test person A, 0, , totoche test person A, ",
"unit test linkset, $iPerson2, test person B, 0, , totoche test person B, ",
),
'history_added' => 0,
'history_removed' => 0,
'history_modified' => 0,
),
array(
'description' => 'Removing A',
'links' => array(
array(
'person_id' => $iPerson2,
'team_id' => $iTeam,
'role_id' => 0,
),
),
'expected-res' => array (
"unit test linkset, $iPerson2, test person B, 0, , totoche test person B, ",
),
'history_added' => 0,
'history_removed' => 1,
'history_modified' => 0,
),
array(
'description' => 'Adding B again (duplicate!)',
'links' => array(
array(
'person_id' => $iPerson2,
'team_id' => $iTeam,
'role_id' => 0,
),
array(
'person_id' => $iPerson2,
'team_id' => $iTeam,
'role_id' => 0,
),
),
'expected-res' => array (
"unit test linkset, $iPerson2, test person B, 0, , totoche test person B, ",
),
'history_added' => 0,
'history_removed' => 0,
'history_modified' => 0,
),
array(
'description' => 'Remove all',
'links' => array(
),
'expected-res' => array (
),
'history_added' => 0,
'history_removed' => 1,
'history_modified' => 0,
),
array(
'description' => 'Add the first item (again)',
'links' => array(
array(
'person_id' => $iPerson1,
'team_id' => $iTeam,
'role_id' => 0,
),
),
'expected-res' => array (
"unit test linkset, $iPerson1, test person A, 0, , totoche test person A, ",
),
'history_added' => 1,
'history_removed' => 0,
'history_modified' => 0,
),
array(
'description' => 'Set the role (based on reloaded links, like in the UI)',
'links' => array(
array(
'id' => "SELECT lnkPersonToTeam WHERE person_id=$iPerson1 AND team_id=$iTeam",
'person_id' => $iPerson1,
'team_id' => $iTeam,
'role_id' => $iRole,
),
),
'expected-res' => array (
"unit test linkset, $iPerson1, test person A, 14, Manager, totoche test person A, Manager",
),
'history_added' => 0,
'history_removed' => 0,
'history_modified' => 1,
),
array(
'description' => 'Clear the role and add another person with a role (based on reloaded links, like in the UI)',
'links' => array(
array(
'id' => "SELECT lnkPersonToTeam WHERE person_id=$iPerson1 AND team_id=$iTeam",
'person_id' => $iPerson1,
'team_id' => $iTeam,
'role_id' => 0,
),
array(
'person_id' => $iPerson2,
'team_id' => $iTeam,
'role_id' => $iRole,
),
),
'expected-res' => array (
"unit test linkset, $iPerson1, test person A, 0, , totoche test person A, ",
"unit test linkset, $iPerson2, test person B, 14, Manager, totoche test person B, Manager",
),
'history_added' => 1,
'history_removed' => 0,
'history_modified' => 1,
),
);
foreach ($aScenarii as $aScenario)
{
echo "".$aScenario['description']."
\n";
$oChange = MetaModel::NewObject("CMDBChange");
$oChange->Set("date", time());
$oChange->Set("userinfo", CMDBChange::GetCurrentUserName());
$oChange->Set("origin", 'custom-extension');
$oChange->DBInsert();
CMDBObject::SetCurrentChange($oChange);
$iChange = $oChange->GetKey();
// Prepare set
$oLinkset = DBObjectSet::FromScratch('lnkPersonToTeam');
foreach ($aScenario['links'] as $aLinkData)
{
if (array_key_exists('id', $aLinkData))
{
$sOQL = $aLinkData['id'];
$oSet = new DBObjectSet(DBObjectSearch::FromOQL($sOQL));
$oLink1 = $oSet->Fetch();
if (!is_object($oLink1)) throw new Exception('Failed to find the lnkPersonToTeam: '.$sOQL);
}
else
{
$oLink1 = MetaModel::NewObject('lnkPersonToTeam');
}
foreach ($aLinkData as $sAttCode => $value)
{
if ($sAttCode == 'id') continue;
$oLink1->Set($sAttCode, $value);
}
$oLinkset->AddObject($oLink1);
}
// Write
$oTeam = MetaModel::GetObject('Team', $iTeam);
$oTeam->Set('persons_list', $oLinkset);
$oTeam->DBWrite();
// Check Results
$bFoundIssue = false;
$oTeam = MetaModel::GetObject('Team', $iTeam);
$oLinkset = $oTeam->Get('persons_list');
$aRes = $this->StandardizedDump($oLinkset, 'team_id');
$sRes = var_export($aRes, true);
echo "Found: ".$sRes."
\n";
$sExpectedRes = var_export($aScenario['expected-res'], true);
if ($sRes != $sExpectedRes)
{
$bFoundIssue = true;
echo "NOT COMPLIANT!!! Expecting: ".$sExpectedRes."
\n";
}
// Check History
$aQueryParams = array('change' => $iChange, 'objclass' => get_class($oTeam), 'objkey' => $oTeam->GetKey());
$oAdded = new DBObjectSet(DBSearch::FromOQL("SELECT CMDBChangeOpSetAttributeLinksAddRemove WHERE objclass = :objclass AND objkey = :objkey AND change = :change AND type = 'added'"), array(), $aQueryParams);
echo "added: ".$oAdded->Count()."
\n";
if ($aScenario['history_added'] != $oAdded->Count())
{
$bFoundIssue = true;
echo "NOT COMPLIANT!!! Expecting: ".$aScenario['history_added']."
\n";
}
$oRemoved = new DBObjectSet(DBSearch::FromOQL("SELECT CMDBChangeOpSetAttributeLinksAddRemove WHERE objclass = :objclass AND objkey = :objkey AND change = :change AND type = 'removed'"), array(), $aQueryParams);
echo "removed: ".$oRemoved->Count()."
\n";
if ($aScenario['history_removed'] != $oRemoved->Count())
{
$bFoundIssue = true;
echo "NOT COMPLIANT!!! Expecting: ".$aScenario['history_removed']."
\n";
}
$oModified = new DBObjectSet(DBSearch::FromOQL("SELECT CMDBChangeOpSetAttributeLinksTune WHERE objclass = :objclass AND objkey = :objkey AND change = :change"), array(), $aQueryParams);
echo "modified: ".$oModified->Count()."
\n";
if ($aScenario['history_modified'] != $oModified->Count())
{
$bFoundIssue = true;
echo "NOT COMPLIANT!!! Expecting: ".$aScenario['history_modified']."
\n";
}
if ($bFoundIssue)
{
throw new Exception('Stopping on failed scenario');
}
}
}
}
class TestLinkSetRecording_1N extends TestLinkSet
{
static public function GetName()
{
return 'Linkset 1-N (Network Interface vs Server: Edit in-place)';
}
static public function GetDescription()
{
return 'Simulate CSV/data synchro type of recording. Check the values and the history.';
}
protected function DoExecute()
{
CMDBSource::Query('START TRANSACTION');
//CMDBSource::Query('ROLLBACK'); automatique !
////////////////////////////////////////////////////////////////////////////////
// Set the stage
//
$oServer = MetaModel::NewObject('Server');
$oServer->Set('name', 'unit test linkset');
$oServer->Set('org_id', 3);
$oServer->DBInsert();
$iServer = $oServer->GetKey();
////////////////////////////////////////////////////////////////////////////////
// Scenarii
//
$aScenarii = array(
array(
'description' => 'Add the first interface',
'interfaces' => array(
array(
'connectableci_id' => $iServer,
'name' => 'eth0',
'speed' => '1000.00',
),
),
'expected-res' => array (
"eth0, , , , , , 1000.00, $iServer, unit test linkset, PhysicalInterface, unit test linkset, Server",
),
'history_added' => 1,
'history_removed' => 0,
'history_modified' => 0,
),
array(
'description' => 'Add a second interface',
'interfaces' => array(
array(
'connectableci_id' => $iServer,
'name' => 'eth0',
'speed' => '1000.00',
),
array(
'connectableci_id' => $iServer,
'name' => 'eth1',
'speed' => '1000.00',
),
),
'expected-res' => array (
"eth0, , , , , , 1000.00, $iServer, unit test linkset, PhysicalInterface, unit test linkset, Server",
"eth1, , , , , , 1000.00, $iServer, unit test linkset, PhysicalInterface, unit test linkset, Server",
),
'history_added' => 1,
'history_removed' => 0,
'history_modified' => 0,
),
array(
'description' => 'Change the speed of an interface',
'interfaces' => array(
array(
'connectableci_id' => $iServer,
'name' => 'eth0',
'speed' => '100.00',
),
array(
'connectableci_id' => $iServer,
'name' => 'eth1',
'speed' => '1000.00',
),
),
'expected-res' => array (
"eth0, , , , , , 100.00, $iServer, unit test linkset, PhysicalInterface, unit test linkset, Server",
"eth1, , , , , , 1000.00, $iServer, unit test linkset, PhysicalInterface, unit test linkset, Server",
),
'history_added' => 1,
'history_removed' => 1,
'history_modified' => 0,
),
array(
'description' => 'Change the name of an interface',
'interfaces' => array(
array(
'connectableci_id' => $iServer,
'name' => 'eth0-renamed',
'speed' => '1000.00',
),
array(
'connectableci_id' => $iServer,
'name' => 'eth1',
'speed' => '1000.00',
),
),
'expected-res' => array (
"eth0-renamed, , , , , , 1000.00, $iServer, unit test linkset, PhysicalInterface, unit test linkset, Server",
"eth1, , , , , , 1000.00, $iServer, unit test linkset, PhysicalInterface, unit test linkset, Server",
),
'history_added' => 1,
'history_removed' => 1,
'history_modified' => 0,
),
array(
'description' => 'Remove all interfaces',
'interfaces' => array(
),
'expected-res' => array (
),
'history_added' => 0,
'history_removed' => 2,
'history_modified' => 0,
),
);
foreach ($aScenarii as $aScenario)
{
echo "".$aScenario['description']."
\n";
$oChange = MetaModel::NewObject("CMDBChange");
$oChange->Set("date", time());
$oChange->Set("userinfo", CMDBChange::GetCurrentUserName());
$oChange->Set("origin", 'custom-extension');
$oChange->DBInsert();
CMDBObject::SetCurrentChange($oChange);
$iChange = $oChange->GetKey();
// Prepare set
$oLinkset = DBObjectSet::FromScratch('PhysicalInterface');
foreach ($aScenario['interfaces'] as $aIntfData)
{
$oInterface = MetaModel::NewObject('PhysicalInterface');
foreach ($aIntfData as $sAttCode => $value)
{
$oInterface->Set($sAttCode, $value);
}
$oLinkset->AddObject($oInterface);
}
// Write
$oServer = MetaModel::GetObject('Server', $iServer);
$oServer->Set('physicalinterface_list', $oLinkset);
$oServer->DBWrite();
// Check Results
$bFoundIssue = false;
$oServer = MetaModel::GetObject('Server', $iServer);
$oLinkset = $oServer->Get('physicalinterface_list');
$aRes = $this->StandardizedDump($oLinkset, 'zzz');
$sRes = var_export($aRes, true);
echo "Found: ".$sRes."
\n";
$sExpectedRes = var_export($aScenario['expected-res'], true);
if ($sRes != $sExpectedRes)
{
$bFoundIssue = true;
echo "NOT COMPLIANT!!! Expecting: ".$sExpectedRes."
\n";
}
// Check History
$aQueryParams = array('change' => $iChange, 'objclass' => get_class($oServer), 'objkey' => $oServer->GetKey());
$oAdded = new DBObjectSet(DBSearch::FromOQL("SELECT CMDBChangeOpSetAttributeLinksAddRemove WHERE objclass = :objclass AND objkey = :objkey AND change = :change AND type = 'added'"), array(), $aQueryParams);
echo "added: ".$oAdded->Count()."
\n";
if ($aScenario['history_added'] != $oAdded->Count())
{
$bFoundIssue = true;
echo "NOT COMPLIANT!!! Expecting: ".$aScenario['history_added']."
\n";
}
$oRemoved = new DBObjectSet(DBSearch::FromOQL("SELECT CMDBChangeOpSetAttributeLinksAddRemove WHERE objclass = :objclass AND objkey = :objkey AND change = :change AND type = 'removed'"), array(), $aQueryParams);
echo "removed: ".$oRemoved->Count()."
\n";
if ($aScenario['history_removed'] != $oRemoved->Count())
{
$bFoundIssue = true;
echo "NOT COMPLIANT!!! Expecting: ".$aScenario['history_removed']."
\n";
}
$oModified = new DBObjectSet(DBSearch::FromOQL("SELECT CMDBChangeOpSetAttributeLinksTune WHERE objclass = :objclass AND objkey = :objkey AND change = :change"), array(), $aQueryParams);
echo "modified: ".$oModified->Count()."
\n";
if ($aScenario['history_modified'] != $oModified->Count())
{
$bFoundIssue = true;
echo "NOT COMPLIANT!!! Expecting: ".$aScenario['history_modified']."
\n";
}
if ($bFoundIssue)
{
throw new Exception('Stopping on failed scenario');
}
}
}
}
class TestLinkSetRecording_1NAdd_Remove extends TestLinkSet
{
static public function GetName()
{
return 'Linkset 1-N (Delivery Model vs Organization: Edit Add/Remove)';
}
static public function GetDescription()
{
return 'Simulate CSV/data synchro type of recording. Check the values and the history.';
}
protected function DoExecute()
{
CMDBSource::Query('START TRANSACTION');
//CMDBSource::Query('ROLLBACK'); automatique !
////////////////////////////////////////////////////////////////////////////////
// Set the stage
//
$oProvider = new Organization();
$oProvider->Set('name', 'Test-Provider1');
$oProvider->DBInsert();
$iProvider = $oProvider->GetKey();
$oDM1 = new DeliveryModel();
$oDM1->Set('name', 'Test-DM-1');
$oDM1->Set('org_id', $iProvider);
$oDM1->DBInsert();
$iDM1 = $oDM1->GetKey();
$oDM2 = new DeliveryModel();
$oDM2->Set('name', 'Test-DM-2');
$oDM2->Set('org_id', $iProvider);
$oDM2->DBInsert();
$iDM2 = $oDM2->GetKey();
////////////////////////////////////////////////////////////////////////////////
// Scenarii
//
$aScenarii = array(
array(
'description' => 'Add the first customer',
'organizations' => array(
array(
'deliverymodel_id' => $iDM1,
'name' => 'Test-Customer-1',
),
),
'expected-res' => array (
"Test-Customer-1, , active, 0, , $iDM1, Test-DM-1, , Test-DM-1",
),
'history_added' => 0,
'history_removed' => 0,
'history_modified' => 0,
),
array(
'description' => 'Remove the customer by loading an empty set',
'organizations' => array(
),
'expected-res' => array (
),
'history_added' => 0,
'history_removed' => 0,
'history_modified' => 0,
),
array(
'description' => 'Create two customers at once',
'organizations' => array(
array(
'deliverymodel_id' => $iDM1,
'name' => 'Test-Customer-1',
),
array(
'deliverymodel_id' => $iDM1,
'name' => 'Test-Customer-2',
),
),
'expected-res' => array (
"Test-Customer-1, , active, 0, , $iDM1, Test-DM-1, , Test-DM-1",
"Test-Customer-2, , active, 0, , $iDM1, Test-DM-1, , Test-DM-1",
),
'history_added' => 0,
'history_removed' => 0,
'history_modified' => 0,
),
array(
'description' => 'Move Customer-1 to the second Delivery Model',
'organizations' => array(
array(
'id' => "SELECT Organization WHERE name='Test-Customer-1'",
'deliverymodel_id' => $iDM2,
'name' => 'Test-Customer-1',
),
array(
'deliverymodel_id' => $iDM1,
'name' => 'Test-Customer-2',
),
),
'expected-res' => array (
"Test-Customer-2, , active, 0, , $iDM1, Test-DM-1, , Test-DM-1",
),
'history_added' => 0,
'history_removed' => 0,
'history_modified' => 0,
),
array(
'description' => 'Move Customer-1 back to the first Delivery Model and reset Customer-2 (no Delivery Model)',
'organizations' => array(
array(
'id' => "SELECT Organization WHERE name='Test-Customer-1'",
'deliverymodel_id' => $iDM1,
'name' => 'Test-Customer-1',
),
array(
'id' => "SELECT Organization WHERE name='Test-Customer-2'",
'deliverymodel_id' => 0,
'name' => 'Test-Customer-2',
),
),
'expected-res' => array (
"Test-Customer-1, , active, 0, , $iDM1, Test-DM-1, , Test-DM-1",
),
'history_added' => 0,
'history_removed' => 0,
'history_modified' => 0,
),
);
foreach ($aScenarii as $aScenario)
{
echo "".$aScenario['description']."
\n";
$oChange = MetaModel::NewObject("CMDBChange");
$oChange->Set("date", time());
$oChange->Set("userinfo", CMDBChange::GetCurrentUserName());
$oChange->Set("origin", 'custom-extension');
$oChange->DBInsert();
CMDBObject::SetCurrentChange($oChange);
$iChange = $oChange->GetKey();
// Prepare set
$oLinkset = DBObjectSet::FromScratch('Organization');
foreach ($aScenario['organizations'] as $aOrgData)
{
if (array_key_exists('id', $aOrgData))
{
$sOQL = $aOrgData['id'];
$oSet = new DBObjectSet(DBObjectSearch::FromOQL($sOQL));
$oOrg = $oSet->Fetch();
if (!is_object($oOrg)) throw new Exception('Failed to find the Organization: '.$sOQL);
}
else
{
$oOrg = MetaModel::NewObject('Organization');
}
foreach ($aOrgData as $sAttCode => $value)
{
if ($sAttCode == 'id') continue;
$oOrg->Set($sAttCode, $value);
}
$oLinkset->AddObject($oOrg);
}
// Write
$oDM = MetaModel::GetObject('DeliveryModel', $iDM1);
$oDM->Set('customers_list', $oLinkset);
$oDM->DBWrite();
// Check Results
$bFoundIssue = false;
$oDM = MetaModel::GetObject('DeliveryModel', $iDM1);
$oLinkset = $oDM->Get('customers_list');
$aRes = $this->StandardizedDump($oLinkset, 'zzz');
$sRes = var_export($aRes, true);
echo "Found: ".$sRes."
\n";
$sExpectedRes = var_export($aScenario['expected-res'], true);
if ($sRes != $sExpectedRes)
{
$bFoundIssue = true;
echo "NOT COMPLIANT!!! Expecting: ".$sExpectedRes."
\n";
}
// Check History
$aQueryParams = array('change' => $iChange, 'objclass' => get_class($oDM), 'objkey' => $oDM->GetKey());
$oAdded = new DBObjectSet(DBSearch::FromOQL("SELECT CMDBChangeOpSetAttributeLinksAddRemove WHERE objclass = :objclass AND objkey = :objkey AND change = :change AND type = 'added'"), array(), $aQueryParams);
echo "added: ".$oAdded->Count()."
\n";
if ($aScenario['history_added'] != $oAdded->Count())
{
$bFoundIssue = true;
echo "NOT COMPLIANT!!! Expecting: ".$aScenario['history_added']."
\n";
}
$oRemoved = new DBObjectSet(DBSearch::FromOQL("SELECT CMDBChangeOpSetAttributeLinksAddRemove WHERE objclass = :objclass AND objkey = :objkey AND change = :change AND type = 'removed'"), array(), $aQueryParams);
echo "removed: ".$oRemoved->Count()."
\n";
if ($aScenario['history_removed'] != $oRemoved->Count())
{
$bFoundIssue = true;
echo "NOT COMPLIANT!!! Expecting: ".$aScenario['history_removed']."
\n";
}
$oModified = new DBObjectSet(DBSearch::FromOQL("SELECT CMDBChangeOpSetAttributeLinksTune WHERE objclass = :objclass AND objkey = :objkey AND change = :change"), array(), $aQueryParams);
echo "modified: ".$oModified->Count()."
\n";
if ($aScenario['history_modified'] != $oModified->Count())
{
$bFoundIssue = true;
echo "NOT COMPLIANT!!! Expecting: ".$aScenario['history_modified']."
\n";
}
if ($bFoundIssue)
{
throw new Exception('Stopping on failed scenario');
}
}
}
}
class TestDateTimeFormats extends TestBizModel
{
static public function GetName() {return 'Check Date & Time formating and parsing';}
static public function GetDescription() {return 'Check the formating and parsing of dates for various formats';}
public function DoExecute()
{
require_once(APPROOT.'core/datetimeformat.class.inc.php');
$bRet = true;
$aTestFormats = array(
'French (short)' => 'd/m/Y H:i:s',
'French (short - no seconds)' => 'd/m/Y H:i',
'French (long)' => 'd/m/Y H\\h i\\m\\i\\n s\\s',
'English US' => 'm/d/Y H:i:s',
'English US (12 hours)' => 'm/d/Y h:i:s a',
'English US (12 hours, short)' => 'n/j/Y g:i:s a',
'English UK' => 'd/m/Y H:i:s',
'German' => 'd.m.Y H:i:s',
'SQL' => 'Y-m-d H:i:s',
);
// Valid date and times, all tests should pass
$aTestDates = array('2015-01-01 00:00:00', '2015-12-31 23:59:00', '2016-01-01 08:21:00', '2016-02-28 12:30:00', '2016-02-29 16:47:00', /*'2016-02-29 14:30:17'*/);
foreach($aTestFormats as $sDesc => $sFormat)
{
$this->ReportSuccess("Test of the '$sDesc' format: '$sFormat':");
$oFormat = new DateTimeFormat($sFormat);
foreach($aTestDates as $sTestDate)
{
$oDate = new DateTime($sTestDate);
$sFormattedDate = $oFormat->Format($oDate);
$oParsedDate = $oFormat->Parse($sFormattedDate);
$sPattern = $oFormat->ToRegExpr('/');
$bParseOk = ($oParsedDate->format('Y-m-d H:i:s') == $sTestDate);
if (!$bParseOk)
{
$this->ReportError('Parsed ('.$sFormattedDate.') date different from initial date (difference of '.((int)$oParsedDate->format('U')- (int)$oDate->format('U')).'s)');
$bRet = false;
}
$bValidateOk = preg_match($sPattern, $sFormattedDate);
if (!$bValidateOk)
{
$this->ReportError('Formatted date ('.$sFormattedDate.') does not match the validation pattern ('.$sPattern.')');
$bRet = false;
}
$this->ReportSuccess("Formatted date: $sFormattedDate - Parsing: ".($bParseOk ? 'Ok' : 'KO')." - Validation: ".($bValidateOk ? 'Ok' : 'KO'));
}
echo "\n";
}
// Invalid date & time strings, all regexpr validation should fail
$aInvalidTestDates = array(
'SQL' => array('2015-13-01 00:00:00', '2015-12-51 23:59:00', '2016-01-01 +08:21:00', '2016-02-28 24:30:00', '2016-02-29 16:67:88'),
'French (short)' => array('01/01/20150 00:00:00', '01/01/20150 00:00:00', '01/13/2015 00:00:00', '01/01/2015 40:00:00', '01/01/2015 00:99:00'),
'English US (12 hours)' => array('13/01/2015 12:00:00 am', '12/33/2015 12:00:00 am', '12/23/215 12:00:00 am', '05/04/2016 16:00:00 am', '05/04/2016 10:00:00 ap'),
);
foreach($aInvalidTestDates as $sFormatName => $aDatesToParse)
{
$sFormat = $aTestFormats[$sFormatName];
$oFormat = new DateTimeFormat($sFormat);
$this->ReportSuccess("Test of the '$sFormatName' format: '$sFormat':");
foreach($aDatesToParse as $sDate)
{
$sPattern = $oFormat->ToRegExpr('/');
$bValidateOk = preg_match($sPattern, $sDate);
if ($bValidateOk)
{
$this->ReportError('Formatted date ('.$sFormattedDate.') matches the validation pattern ('.$sPattern.') whereas it should not!');
$bRet = false;
}
$this->ReportSuccess("Formatted date: $sDate - Validation: ".($bValidateOk ? 'KO' : 'rejected, Ok.'));
}
}
return $bRet;
}
}
class TestExecActions extends TestBizModel
{
static public function GetName()
{
return 'Scripted actions API DBObject::ExecAction - syntax errors';
}
static public function GetDescription()
{
return 'Check that wrong arguments are correclty reported';
}
protected function DoExecute()
{
$oSource = new UserRequest();
$oSource->Set('title', 'Houston!');
$oSource->Set('description', 'Looks like we have a problem');
$oTarget = new Server();
////////////////////////////////////////////////////////////////////////////////
// Scenarii
//
$aScenarii = array(
array(
'action' => 'set',
'error' => 'Action: set - Invalid syntax'
),
array(
'action' => 'smurf()',
'error' => 'Action: smurf() - Invalid verb'
),
array(
'action' => ' smurf () ',
'error' => 'Action: smurf () - Invalid syntax'
),
array(
'action' => 'clone(some_att_code, another_one)',
'error' => 'Action: clone(some_att_code, another_one) - Unknown attribute Server::some_att_code'
),
array(
'action' => 'copy(toto, titi)',
'error' => 'Action: copy(toto, titi) - Unknown attribute Server::titi'
),
array(
'action' => 'copy(toto, name)',
'error' => 'Action: copy(toto, name) - Unknown attribute UserRequest::toto'
),
array(
'action' => 'copy()',
'error' => 'Action: copy() - Missing argument #1: source attribute'
),
array(
'action' => 'copy(title)',
'error' => 'Action: copy(title) - Missing argument #2: target attribute'
),
array(
'action' => 'set(toto)',
'error' => 'Action: set(toto) - Unknown attribute Server::toto'
),
array(
'action' => 'set(toto, something)',
'error' => 'Action: set(toto, something) - Unknown attribute Server::toto'
),
array(
'action' => 'set()',
'error' => 'Action: set() - Missing argument #1: target attribute'
),
array(
'action' => 'reset(toto)',
'error' => 'Action: reset(toto) - Unknown attribute Server::toto'
),
array(
'action' => 'reset()',
'error' => 'Action: reset() - Missing argument #1: target attribute'
),
array(
'action' => 'nullify(toto)',
'error' => 'Action: nullify(toto) - Unknown attribute Server::toto'
),
array(
'action' => 'nullify()',
'error' => 'Action: nullify() - Missing argument #1: target attribute'
),
array(
'action' => 'append(toto, something)',
'error' => 'Action: append(toto, something) - Unknown attribute Server::toto'
),
array(
'action' => 'append(name)',
'error' => 'Action: append(name) - Missing argument #2: value to append'
),
array(
'action' => 'append()',
'error' => 'Action: append() - Missing argument #1: target attribute'
),
array(
'action' => 'add_to_list(toto, titi)',
'error' => 'Action: add_to_list(toto, titi) - Unknown attribute UserRequest::toto'
),
array(
'action' => 'add_to_list(caller_id, titi)',
'error' => 'Action: add_to_list(caller_id, titi) - Unknown attribute Server::titi'
),
array(
'action' => 'add_to_list(caller_id)',
'error' => 'Action: add_to_list(caller_id) - Missing argument #2: target attribute (link set)'
),
array(
'action' => 'add_to_list()',
'error' => 'Action: add_to_list() - Missing argument #1: source attribute'
),
array(
'action' => 'apply_stimulus(toto)',
'error' => 'Action: apply_stimulus(toto) - Unknown stimulus Server::toto'
),
array(
'action' => 'apply_stimulus()',
'error' => 'Action: apply_stimulus() - Missing argument #1: stimulus'
),
array(
'action' => 'call_method(toto)',
'error' => 'Action: call_method(toto) - Unknown method Server::toto()'
),
array(
'action' => 'call_method()',
'error' => 'Action: call_method() - Missing argument #1: method name'
),
);
foreach ($aScenarii as $aScenario)
{
echo "".htmlentities($aScenario['action'], ENT_QUOTES, 'UTF-8')."
\n";
$sMessage = '';
try
{
$oTarget->ExecActions(array($aScenario['action']), array('source' => $oSource));
$sMessage = 'Expecting an exception... none has been thrown!';
}
catch (Exception $e)
{
if ($e->getMessage() != $aScenario['error'])
{
$sMessage = 'Wrong message: expecting "'.$aScenario['error'].'" and got "'.$e->getMessage().'"';
}
}
if ($sMessage !='')
{
throw new Exception($sMessage);
}
}
}
}
class TestIntersectOptimization extends TestBizModel
{
static public function GetName()
{
return 'Internal query optimizations (pointing to)';
}
static public function GetDescription()
{
return 'Clever optimization required for the portal to work fine (expected improvement: query never finishing... to an almost instantaneous query!';
}
protected function DoExecute()
{
$sBaseQuery = 'SELECT Service AS s JOIN Organization AS o ON s.org_id = o.id WHERE o.name = "The World Company"';
$aQueries = array(
// Exact same query
'SELECT Service AS s JOIN Organization AS o ON s.org_id = o.id WHERE o.name = "The World Company"',
// Same query, other aliases
'SELECT Service AS s2 JOIN Organization AS o2 ON s2.org_id = o2.id WHERE o2.name = "The World Company"',
// Same aliases, different condition
'SELECT Service AS s JOIN Organization AS o ON s.org_id = o.id WHERE o.parent_id = 0',
// Other aliases, different condition
'SELECT Service AS s2 JOIN Organization AS o2 ON s2.org_id = o2.id WHERE o2.parent_id = 0',
// Same aliases, simpler query tree
'SELECT Service AS s WHERE name LIKE "Save the World"',
// Other aliases, simpler query tree
'SELECT Service AS s2 WHERE name LIKE "Save the World"',
// Same aliases, different query tree
'SELECT Service AS s JOIN ServiceFamily AS f ON s.servicefamily_id = f.id WHERE s.org_id = 123 AND f.name = "Care"',
// Other aliases, different query tree
'SELECT Service AS s2 JOIN ServiceFamily AS f ON s2.servicefamily_id = f.id WHERE s2.org_id = 123 AND f.name = "Care"',
);
echo "Base query: ".htmlentities($sBaseQuery, ENT_QUOTES, 'UTF-8')."
\n";
foreach ($aQueries as $sOQL)
{
echo "Checking: ".htmlentities($sOQL, ENT_QUOTES, 'UTF-8')."
\n";
$oSearchA = DBSearch::FromOQL($sBaseQuery);
$oSearchB = DBSearch::FromOQL($sOQL);
$oIntersect = $oSearchA->Intersect($oSearchB);
echo "Intersect: ".htmlentities($oIntersect->ToOQL(), ENT_QUOTES, 'UTF-8')."
\n";
CMDBSource::TestQuery($oIntersect->MakeSelectQuery());
echo "Successfully tested the SQL query.
\n";
}
}
}
class TestIntersectOptimization2 extends TestBizModel
{
static public function GetName()
{
return 'Internal query optimizations (referenced by)';
}
static public function GetDescription()
{
return 'Clever optimization required for the portal to work fine (expected improvement: query never finishing... to an almost instantaneous query!';
}
protected function DoExecute()
{
$sBaseQuery = 'SELECT Organization AS o JOIN Service AS s ON s.org_id = o.id WHERE s.name = "Help"';
$aQueries = array(
// Exact same query
'SELECT Organization AS o JOIN Service AS s ON s.org_id = o.id WHERE s.name = "Help"',
// Same query, other aliases
'SELECT Organization AS o2 JOIN Service AS s2 ON s2.org_id = o2.id WHERE s2.name = "Help"',
// Same aliases, different condition
'SELECT Organization AS o JOIN Service AS s ON s.org_id = o.id WHERE s.servicefamily_id = 321',
// Other aliases, different condition
'SELECT Organization AS o2 JOIN Service AS s2 ON s2.org_id = o2.id WHERE s2.servicefamily_id = 321',
// Same aliases, simpler query tree
'SELECT Organization AS o WHERE o.name = "Demo"',
// Other aliases, simpler query tree
'SELECT Organization AS o2 WHERE o2.name = "Demo"',
// Same aliases, different query tree
'SELECT Organization AS o JOIN Location AS l ON l.org_id = o.id WHERE l.name = "Paris"',
// Other aliases, different query tree
'SELECT Organization AS o2 JOIN Location AS l ON l.org_id = o2.id WHERE l.name = "Paris"',
);
echo "Base query: ".htmlentities($sBaseQuery, ENT_QUOTES, 'UTF-8')."
\n";
foreach ($aQueries as $sOQL)
{
echo "Checking: ".htmlentities($sOQL, ENT_QUOTES, 'UTF-8')."
\n";
$oSearchA = DBSearch::FromOQL($sBaseQuery);
$oSearchB = DBSearch::FromOQL($sOQL);
$oIntersect = $oSearchA->Intersect($oSearchB);
echo "Intersect: ".htmlentities($oIntersect->ToOQL(), ENT_QUOTES, 'UTF-8')."
\n";
CMDBSource::TestQuery($oIntersect->MakeSelectQuery());
echo "Successfully tested the SQL query.
\n";
}
}
}
class TestIntersectOptimization3 extends TestBizModel
{
static public function GetName()
{
return 'Internal query optimizations (mix)';
}
static public function GetDescription()
{
return 'Clever optimization required for the portal to work fine (expected improvement: query never finishing... to an almost instantaneous query!';
}
protected function DoExecute()
{
$aQueries = array(
array(
'SELECT Organization AS o',
'SELECT Organization AS o JOIN Location AS l ON l.org_id = o.id JOIN Organization AS p ON o.parent_id = p.id WHERE l.name = "Paris" AND p.code LIKE "toto"',
),
array(
'SELECT UserRequest AS r JOIN Service AS s ON r.service_id = s.id JOIN Organization AS o ON s.org_id = o.id WHERE o.name = "left_name"',
'SELECT UserRequest AS r JOIN Service AS s ON r.service_id = s.id JOIN Organization AS o ON s.org_id = o.id WHERE o.name = "right_name"',
),
);
echo "Mixing....
\n";
foreach ($aQueries as $aQ)
{
$sBaseQuery = $aQ[0];
$sOQL = $aQ[1];
echo "Left: ".htmlentities($sBaseQuery, ENT_QUOTES, 'UTF-8')."
\n";
echo "Right: ".htmlentities($sOQL, ENT_QUOTES, 'UTF-8')."
\n";
$oSearchA = DBSearch::FromOQL($sBaseQuery);
$oSearchB = DBSearch::FromOQL($sOQL);
$oIntersect = $oSearchA->Intersect($oSearchB);
echo "Intersect: ".htmlentities($oIntersect->ToOQL(), ENT_QUOTES, 'UTF-8')."
\n";
CMDBSource::TestQuery($oIntersect->MakeSelectQuery());
echo "Successfully tested the SQL query.
\n";
}
}
}
class TestIntersectOptimization4 extends TestBizModel
{
static public function GetName()
{
return 'Internal query optimizations (Folding on Join/ReferencedBy)';
}
static public function GetDescription()
{
return 'Clever optimization required for the portal to work fine (expected improvement: query never finishing... to an almost instantaneous query!';
}
protected function DoExecute()
{
echo "Here we are (conluding a long series of tests)
\n";
$sQueryA = 'SELECT UserRequest AS r JOIN Service AS s ON r.service_id = s.id JOIN Organization AS o ON s.org_id = o.id WHERE r.agent_id = 456 AND s.servicefamily_id = 789 AND o.name = "right_name"';
$sQueryB = 'SELECT Service AS s JOIN Organization AS o ON s.org_id = o.id WHERE o.name = "some name"';
echo "A: ".htmlentities($sQueryA, ENT_QUOTES, 'UTF-8')."
\n";
echo "B: ".htmlentities($sQueryB, ENT_QUOTES, 'UTF-8')."
\n";
$oSearchA = DBSearch::FromOQL($sQueryA);
$oSearchB = DBSearch::FromOQL($sQueryB);
$oSearchB->AddCondition_ReferencedBy($oSearchA, 'service_id');
echo "Referenced by...: ".htmlentities($oSearchB->ToOQL(), ENT_QUOTES, 'UTF-8')."
\n";
CMDBSource::TestQuery($oSearchB->MakeSelectQuery());
echo "Successfully tested the SQL query.
\n";
}
}
class TestIntersectOptimization5 extends TestBizModel
{
static public function GetName()
{
return 'Internal query optimizations (Folding on Join/PointingTo)';
}
static public function GetDescription()
{
return 'Clever optimization required for the portal to work fine (expected improvement: query never finishing... to an almost instantaneous query!';
}
protected function DoExecute()
{
echo "Here we are (concluding a long series of tests)
\n";
$sQueryA = 'SELECT Organization AS o JOIN UserRequest AS r ON r.org_id = o.id JOIN Person AS p ON r.caller_id = p.id WHERE o.name LIKE "Company" AND r.service_id = 123 AND p.employee_number LIKE "007"';
$sQueryB = 'SELECT UserRequest AS ur JOIN Person AS p ON ur.agent_id = p.id WHERE p.status != "terminated"';
echo "A: ".htmlentities($sQueryA, ENT_QUOTES, 'UTF-8')."
\n";
echo "B: ".htmlentities($sQueryB, ENT_QUOTES, 'UTF-8')."
\n";
$oSearchA = DBSearch::FromOQL($sQueryA);
$oSearchB = DBSearch::FromOQL($sQueryB);
$oSearchB->AddCondition_PointingTo($oSearchA, 'org_id');
echo "Pointing to...: ".htmlentities($oSearchB->ToOQL(), ENT_QUOTES, 'UTF-8')."
\n";
CMDBSource::TestQuery($oSearchB->MakeSelectQuery());
echo "Successfully tested the SQL query.
\n";
}
}
class TestParsingOptimization extends TestBizModel
{
static public function GetName()
{
return 'Query optimizations (Merging joins on OQL parsing)';
}
static public function GetDescription()
{
return 'Checking a few queries that do involve query optimizations (implemented for the sake of optimizing the portal)';
}
protected function DoExecute()
{
$aQueries = array(
"SELECT UserRequest AS u
JOIN Person AS p1 ON u.caller_id=p1.id
JOIN Organization AS o1 ON p1.org_id=o1.id
JOIN Person AS p2 ON u.caller_id=p2.id WHERE p2.status='active' AND p1.status='inactive'",
"SELECT UserRequest AS u
JOIN Person AS p1 ON u.caller_id=p1.id
JOIN Person AS p2 ON u.caller_id=p2.id WHERE p2.status='active' AND p1.status='inactive'",
"SELECT UserRequest AS u
JOIN Person AS p1 ON u.caller_id=p1.id
JOIN Organization AS o1 ON p1.org_id=o1.id
JOIN Person ON u.caller_id=Person.id
JOIN Location AS l ON Person.location_id = l.id WHERE Person.status='active' AND p1.status='inactive' AND l.country='France'",
);
foreach ($aQueries as $sQuery)
{
echo "To Parse: ".htmlentities($sQuery, ENT_QUOTES, 'UTF-8')."
\n";
$oSearch = DBSearch::FromOQL($sQuery);
$sQueryOpt = $oSearch->ToOQL();
echo "Optimized: ".htmlentities($sQueryOpt, ENT_QUOTES, 'UTF-8')."
\n";
CMDBSource::TestQuery($oSearch->MakeSelectQuery());
echo "Successfully tested the SQL query.
\n";
}
}
}
class TestUnions extends TestBizModel
{
static public function GetName()
{
return 'Unions';
}
static public function GetDescription()
{
return 'Checking a few UNION queries';
}
protected function DoExecute()
{
// The two first items did reveal an issue with the query cache,
//because SELECT Person on the second line must not give the same query as SELECT Person on the first line
$aQueries = array(
"SELECT Person UNION SELECT Person" => true,
"SELECT Person UNION SELECT Team" => true,
"SELECT Person UNION SELECT Contact" => true,
"SELECT Contact UNION SELECT Person" => true,
"SELECT Person UNION SELECT Organization" => false,
);
foreach ($aQueries as $sQuery => $bSuccess)
{
echo "To Parse: ".htmlentities($sQuery, ENT_QUOTES, 'UTF-8')."
\n";
try
{
$oSearch = DBSearch::FromOQL($sQuery);
if (!$bSuccess) throw new Exception('This query should not be parsable!');
CMDBSource::TestQuery($oSearch->MakeSelectQuery());
echo "Successfully tested the SQL query.
\n";
}
catch (OQLException $e)
{
if ($bSuccess) throw $e;
echo "Failed as expected.
\n";
}
}
}
}
class TestImplicitAlias extends TestBizModel
{
static public function GetName()
{
return 'OQLImplicitAliases';
}
static public function GetDescription()
{
return 'Checking implicit aliases resolution';
}
protected function DoExecute()
{
// The two first items did reveal an issue with the query cache,
//because SELECT Person on the second line must not give the same query as SELECT Person on the first line
$aQueries = array(
"SELECT Person WHERE org_id = 1" => true,
"SELECT Person WHERE s.org_id = 1" => false,
"SELECT Person AS p WHERE p.org_id = 1" => true,
"SELECT Person AS p WHERE Person.org_id = 1" => false,
"SELECT P FROM Organization AS O JOIN Person AS P ON P.org_id = O.id WHERE org_id = 2" => true, // Bug N.539
"SELECT Server JOIN Location ON Server.location_id = Location.id" => true,
"SELECT Server JOIN Location ON Server.location_id = id" => false,
"SELECT Server JOIN Location ON Server = Location.id" => false,
"SELECT Server JOIN Location ON Server.location_id = Location.id WHERE Server.org_id = 1" => true,
"SELECT Server JOIN Location ON Server.location_id = Location.id WHERE org_id = 1" => false,
);
foreach ($aQueries as $sQuery => $bSuccess)
{
echo "To Parse: ".htmlentities($sQuery, ENT_QUOTES, 'UTF-8')."
\n";
try
{
$oSearch = DBSearch::FromOQL($sQuery);
if (!$bSuccess) throw new Exception('This query should not be parsable!');
CMDBSource::TestQuery($oSearch->MakeSelectQuery());
echo "Successfully tested the SQL query.
\n";
}
catch (OQLException $e)
{
if ($bSuccess) throw $e;
echo "Failed as expected.
\n";
}
}
}
}
class TestIntersectNotOptimized extends TestBizModel
{
static public function GetName()
{
return 'Internal query NOT optimized';
}
static public function GetDescription()
{
return '(N.718) Sometimes, the optimization CANNOT be performed because merging two different classes (same branch) is not implemented';
}
protected function DoExecute()
{
echo "Intersect NOT optimized on 'pointing to'
\n";
$sBaseQuery = 'SELECT lnkContactToFunctionalCI AS l JOIN Contact AS c ON l.contact_id = c.id';
$sOQL = 'SELECT lnkContactToFunctionalCI AS l JOIN Person AS p ON l.contact_id = p.id';
echo "Left: ".htmlentities($sBaseQuery, ENT_QUOTES, 'UTF-8')."
\n";
echo "Right: ".htmlentities($sOQL, ENT_QUOTES, 'UTF-8')."
\n";
$oSearchA = DBSearch::FromOQL($sBaseQuery);
$oSearchB = DBSearch::FromOQL($sOQL);
$oIntersect = $oSearchA->Intersect($oSearchB);
echo "Intersect: ".htmlentities($oIntersect->ToOQL(), ENT_QUOTES, 'UTF-8')."
\n";
CMDBSource::TestQuery($oIntersect->MakeSelectQuery());
echo "Successfully tested the SQL query.
\n";
echo "Intersect NOT optimized on 'referenced by'
\n";
$sBaseQuery = 'SELECT Organization AS o JOIN Contact AS c ON c.org_id = o.id WHERE c.id = 1';
$sOQL = 'SELECT Organization AS o JOIN Person AS p ON p.org_id = o.id WHERE p.id = 2';
echo "Left: ".htmlentities($sBaseQuery, ENT_QUOTES, 'UTF-8')."
\n";
echo "Right: ".htmlentities($sOQL, ENT_QUOTES, 'UTF-8')."
\n";
$oSearchA = DBSearch::FromOQL($sBaseQuery);
$oSearchB = DBSearch::FromOQL($sOQL);
$oIntersect = $oSearchA->Intersect($oSearchB);
echo "Intersect: ".htmlentities($oIntersect->ToOQL(), ENT_QUOTES, 'UTF-8')."
\n";
CMDBSource::TestQuery($oIntersect->MakeSelectQuery());
echo "Successfully tested the SQL query.
\n";
echo "NOT Folding on AddCondition_PointingTo
\n";
$sQueryA = 'SELECT Organization AS o JOIN Contact AS c ON c.org_id = o.id';
$sQueryB = 'SELECT Person';
echo "A: ".htmlentities($sQueryA, ENT_QUOTES, 'UTF-8')."
\n";
echo "B: ".htmlentities($sQueryB, ENT_QUOTES, 'UTF-8')."
\n";
$oSearchA = DBSearch::FromOQL($sQueryA);
$oSearchB = DBSearch::FromOQL($sQueryB);
$oSearchB->AddCondition_PointingTo($oSearchA, 'org_id');
echo "Pointing to...: ".htmlentities($oSearchB->ToOQL(), ENT_QUOTES, 'UTF-8')."
\n";
CMDBSource::TestQuery($oSearchB->MakeSelectQuery());
echo "Successfully tested the SQL query.
\n";
echo "NOT Folding on AddCondition_ReferencedBy
\n";
$sQueryA = 'SELECT lnkContactToFunctionalCI AS l JOIN Contact AS c ON l.contact_id = c.id';
$sQueryB = 'SELECT Person';
echo "A: ".htmlentities($sQueryA, ENT_QUOTES, 'UTF-8')."
\n";
echo "B: ".htmlentities($sQueryB, ENT_QUOTES, 'UTF-8')."
\n";
$oSearchA = DBSearch::FromOQL($sQueryA);
$oSearchB = DBSearch::FromOQL($sQueryB);
$oSearchB->AddCondition_ReferencedBy($oSearchA, 'contact_id');
echo "Referenced by...: ".htmlentities($oSearchA->ToOQL(), ENT_QUOTES, 'UTF-8')."
\n";
CMDBSource::TestQuery($oSearchA->MakeSelectQuery());
echo "Successfully tested the SQL query.
\n";
}
}
class TestBug609 extends TestBizModel
{
static public function GetName()
{
return 'UNION with JOINS ordered differently';
}
static public function GetDescription()
{
return '(N.609) Inconsistent SQL query (various symptoms, must mostly in the form of "Class \'IT Department\' not found"';
}
protected function DoExecute()
{
$sQueryA = 'SELECT t,o FROM Team AS t JOIN Organization AS o ON t.org_id = o.id';
$sQueryB = 'SELECT t,o FROM Organization AS o JOIN Team AS t ON t.org_id = o.id';
$oSearch = DBSearch::FromOQL("$sQueryB UNION $sQueryA");
$oSet = new DBObjectSet($oSearch);
while($oObject = $oSet->Fetch())
{
echo "Successfull load for ".$oObject->GetName()."
\n";
}
}
}
class TestBug788 extends TestBizModel
{
static public function GetName()
{
return 'Graph - delete nodes';
}
static public function GetDescription()
{
return '(N.788) Graph not refreshed when unchecking some classes';
}
protected function DoExecute()
{
$oGraph = new SimpleGraph();
$a = new GraphNode($oGraph, 'A');
$b = new GraphNode($oGraph, 'B');
$c = new GraphNode($oGraph, 'C');
new GraphEdge($oGraph, 'A--B', $a, $b);
new GraphEdge($oGraph, 'B--C', $b, $c);
new GraphEdge($oGraph, 'C--B', $c, $b);
echo "Graphe initial
";
echo $oGraph->DumpAsHtmlImage();
echo $oGraph->DumpAsHTMLText();
echo "Removing C
";
$oGraph->FilterNode($c);
unset($c);
echo $oGraph->DumpAsHtmlImage();
echo $oGraph->DumpAsHTMLText();
if ((count($oGraph->_GetNodes()) != 2) || (count($oGraph->_GetEdges()) != 1))
{
throw new Exception('The graph should be made of 2 nodes and 1 edge');
}
echo "Removing B
";
$oGraph->FilterNode($b);
unset($b);
echo $oGraph->DumpAsHtmlImage();
echo $oGraph->DumpAsHTMLText();
if ((count($oGraph->_GetNodes()) != 1) || (count($oGraph->_GetEdges()) != 0))
{
throw new Exception('The graph should contain only the node A');
}
}
}
class WhereIsThe61TablesThreat extends TestBizModel
{
static public function GetName()
{
return '61 tables';
}
static public function GetDescription()
{
return 'Evaluate where is the 61 tables limit threat';
}
protected function DoExecute()
{
$aClassToCount_Full = array();
$aDistribution = array();
$iTotalClasses = 0;
foreach (MetaModel::GetClasses() as $sClass)
{
if (MetaModel::IsAbstract($sClass)) continue;
$iTotalClasses++;
$oSearch = DBSearch::FromOQL("SELECT $sClass WHERE id = 1");
$oSql = $oSearch->GetSQLQueryStructure(array(), false, null);
$iCount = $oSql->CountTables();
$aClassToCount_Full[$sClass] = $iCount;
if (array_key_exists($iCount, $aDistribution))
{
$aDistribution[$iCount]++;
}
else
{
$aDistribution[$iCount] = 1;
}
}
arsort($aClassToCount_Full);
$iHighestCount = max($aClassToCount_Full);
for($i = 1; $i < $iHighestCount ; $i++)
{
if (!array_key_exists($i, $aDistribution))
{
$aDistribution[$i] = 0;
}
}
ksort($aDistribution);
$i = 0;
$iLimit = 15;
$iCountThreshold = 10;
echo "TOP $iLimit offenders (+ those exceeding $iCountThreshold tables)
";
foreach ($aClassToCount_Full as $sClass => $iCountFull)
{
$i++;
if (($iCountFull <= $iCountThreshold) && ($i >= $iLimit)) break;
echo "$sClass: $iCountFull tables
";
}
echo "Distribution of table counts
";
echo "Over a total of $iTotalClasses instantiable classes.
";
echo "";
echo "| Table count | Classes |
";
foreach ($aDistribution as $iTableCount => $iClassCount)
{
echo "| $iTableCount | $iClassCount |
";
}
echo "
";
}
}
class TestBug689 extends TestBizModel
{
static public function GetName()
{
return 'An OQL failing to export in XML';
}
static public function GetDescription()
{
return '(N.689) Reaching the limit of 61 tables';
}
protected function DoExecute()
{
$sOql = 'SELECT child, parent, s1, p, o FROM UserRequest AS child JOIN UserRequest AS parent ON child.parent_request_id = parent.id JOIN lnkFunctionalCIToTicket AS l1 ON l1.ticket_id = child.id JOIN Server AS s1 ON l1.functionalci_id = s1.id JOIN Person AS p ON child.caller_id = p.id JOIN Organization AS o ON p.org_id = o.id';
$oSearch = DBSearch::FromOQL($sOql);
$oSql = $oSearch->GetSQLQueryStructure(array(), false, null);
//$sSql = $oSql->RenderSelect();
echo ''.$sOql.'
';
echo 'This query rendered with all columns give a MySQL query having '.$oSql->CountTables().' tables... let\'s try it with the DBObjectSet API:
';
$oSet = new DBObjectSet($oSearch);
$oObj = $oSet->Fetch();
echo 'Well done, this is working fine! Some magic happened in the background!
';
}
}
class TestDBObjectLinkedObjects extends TestBizModel
{
static public function GetName()
{
return 'DBObject Linked objects API';
}
static public function GetDescription()
{
return 'Add/Remove/Modify linked objects (recorded as a delta within DBObject, later recorded in DB)';
}
protected function DoExecute()
{
CMDBSource::Query('START TRANSACTION');
//CMDBSource::Query('ROLLBACK'); automatique !
////////////////////////////////////////////////////////////////////////////////
// Set the stage
//
$oTypes = new DBObjectSet(DBObjectSearch::FromOQL('SELECT NetworkDeviceType WHERE name = "Router"'));
$oType = $oTypes->fetch();
$oDevice1 = MetaModel::NewObject('NetworkDevice');
$oDevice1->Set('name', 'test device 1');
$oDevice1->Set('org_id', 3);
$oDevice1->Set('networkdevicetype_id', $oType->GetKey());
$oDevice1->DBInsert();
$iDev1 = $oDevice1->GetKey();
$oDevice2 = MetaModel::NewObject('NetworkDevice');
$oDevice2->Set('name', 'test device 2');
$oDevice2->Set('org_id', 3);
$oDevice2->Set('networkdevicetype_id', $oType->GetKey());
$oDevice2->DBInsert();
$iDev2 = $oDevice2->GetKey();
$oServer = MetaModel::NewObject('Server');
$oServer->Set('name', 'unit test linkset');
$oServer->Set('org_id', 3);
$oLinkSet = $oServer->Get('networkdevice_list');
$oLinkSet->AddItem(MetaModel::NewObject('lnkConnectableCIToNetworkDevice', array('networkdevice_id' => $iDev1)));
$oServer->Set('networkdevice_list', $oLinkSet);
assert($oServer->IsModified(), 'Server is modified');
$oServer->DBInsert();
$iServer = $oServer->GetKey();
$oServer = MetaModel::GetObject('Server', $iServer);
$oLinkSet = $oServer->Get('networkdevice_list');
assert($oLinkSet->Count() == 1, 'One NW Dev attached');
$oLink = $oLinkSet->Fetch();
assert($oLink->Get('networkdevice_id') == $iDev1, 'New device correctly attached');
$oLinkSet = $oServer->Get('networkdevice_list');
$oLinkSet->AddItem(MetaModel::NewObject('lnkConnectableCIToNetworkDevice', array('networkdevice_id' => $iDev2)));
$oServer->Set('networkdevice_list', $oLinkSet);
assert($oServer->IsModified(), 'Server is modified');
$oServer->DBUpdate();
$oServer = MetaModel::GetObject('Server', $iServer);
$oLinkSet = $oServer->Get('networkdevice_list');
assert($oLinkSet->Count() == 2, 'Two NW Dev attached');
$oNewLinkSet = clone $oLinkSet;
while ($oLink = $oLinkSet->Fetch())
{
$iLinkId = $oLink->Get('networkdevice_id');
if ($iLinkId == $iDev1)
{
$oNewLinkSet->RemoveItem($oLink->GetKey());
}
elseif ($iLinkId == $iDev2)
{
$oLink->Set('network_port', 'lePortSalut');
$oNewLinkSet->ModifyItem($oLink);
}
}
$oServer->Set('networkdevice_list', $oNewLinkSet);
assert($oServer->IsModified(), 'Server is modified');
$oServer->DBUpdate();
$oServer = MetaModel::GetObject('Server', $iServer);
$oLinkSet = $oServer->Get('networkdevice_list');
assert($oLinkSet->Count() == 1, 'One NW Dev attached');
$oLink = $oLinkSet->Fetch();
assert($oLink->Get('networkdevice_id') == $iDev2, 'Dev2 remained attached');
assert($oLink->Get('network_port') == 'lePortSalut', 'Port has been changed');
}
}
class TestDBObjectLinkedObjectsLegacy extends TestBizModel
{
static public function GetName()
{
return 'DBObject Linked objects API (legacy usage)';
}
static public function GetDescription()
{
return 'Alter a link set by redefining the whole list of links (not recommended!)';
}
protected function DoExecute()
{
CMDBSource::Query('START TRANSACTION');
//CMDBSource::Query('ROLLBACK'); automatique !
////////////////////////////////////////////////////////////////////////////////
// Set the stage
//
$oTypes = new DBObjectSet(DBObjectSearch::FromOQL('SELECT NetworkDeviceType WHERE name = "Router"'));
$oType = $oTypes->fetch();
$oDevice1 = MetaModel::NewObject('NetworkDevice');
$oDevice1->Set('name', 'test device 1');
$oDevice1->Set('org_id', 3);
$oDevice1->Set('networkdevicetype_id', $oType->GetKey());
$oDevice1->DBInsert();
$iDev1 = $oDevice1->GetKey();
$oDevice2 = MetaModel::NewObject('NetworkDevice');
$oDevice2->Set('name', 'test device 2');
$oDevice2->Set('org_id', 3);
$oDevice2->Set('networkdevicetype_id', $oType->GetKey());
$oDevice2->DBInsert();
$iDev2 = $oDevice2->GetKey();
$oServer = MetaModel::NewObject('Server');
$oServer->Set('name', 'unit test linkset');
$oServer->Set('org_id', 3);
$oLinkSet = $oServer->Get('networkdevice_list');
$oNewLinkSet = DBObjectSet::FromScratch('lnkConnectableCIToNetworkDevice');
while ($oLink = $oLinkSet->Fetch())
{
$oNewLinkSet->AddObject($oLink);
}
$oNewLinkSet->AddObject(MetaModel::NewObject('lnkConnectableCIToNetworkDevice', array('networkdevice_id' => $iDev1)));
$oServer->Set('networkdevice_list', $oNewLinkSet);
assert($oServer->IsModified(), 'Server is modified');
$oServer->DBInsert();
$iServer = $oServer->GetKey();
$oServer = MetaModel::GetObject('Server', $iServer);
$oLinkSet = $oServer->Get('networkdevice_list');
assert($oLinkSet->Count() == 1, 'One NW Dev attached');
$oLink = $oLinkSet->Fetch();
assert($oLink->Get('networkdevice_id') == $iDev1, 'New device correctly attached');
$oNewLinkSet = DBObjectSet::FromScratch('lnkConnectableCIToNetworkDevice');
$oLinkSet->Rewind();
while ($oLink = $oLinkSet->Fetch())
{
$oNewLinkSet->AddObject($oLink);
}
$oNewLinkSet->AddObject(MetaModel::NewObject('lnkConnectableCIToNetworkDevice', array('networkdevice_id' => $iDev2)));
$oServer->Set('networkdevice_list', $oNewLinkSet);
assert($oServer->IsModified(), 'Server is modified');
$oServer->DBUpdate();
$oServer = MetaModel::GetObject('Server', $iServer);
$oLinkSet = $oServer->Get('networkdevice_list');
assert($oLinkSet->Count() == 2, 'Two NW Dev attached');
$oNewLinkSet = DBObjectSet::FromScratch('lnkConnectableCIToNetworkDevice');
$oServer->Set('networkdevice_list', $oNewLinkSet);
while ($oLink = $oLinkSet->Fetch())
{
$iLinkId = $oLink->Get('networkdevice_id');
if ($iLinkId == $iDev1)
{
// Remove...ie do not add it!
}
elseif ($iLinkId == $iDev2)
{
$oLink->Set('network_port', 'lePortSalut');
$oNewLinkSet->AddObject($oLink);
}
else
{
$oNewLinkSet->AddObject($oLink);
}
}
$oServer->Set('networkdevice_list', $oNewLinkSet);
assert($oServer->IsModified(), 'Server is modified');
$oServer->DBUpdate();
$oServer = MetaModel::GetObject('Server', $iServer);
$oLinkSet = $oServer->Get('networkdevice_list');
assert($oLinkSet->Count() == 1, 'One NW Dev attached');
$oLink = $oLinkSet->Fetch();
assert($oLink->Get('networkdevice_id') == $iDev2, 'Dev2 remained attached');
assert($oLink->Get('network_port') == 'lePortSalut', 'Port has been changed');
}
}