1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788278927902791279227932794279527962797279827992800280128022803280428052806280728082809281028112812281328142815281628172818281928202821282228232824282528262827282828292830283128322833283428352836283728382839284028412842284328442845284628472848284928502851285228532854285528562857285828592860286128622863286428652866286728682869287028712872287328742875287628772878287928802881288228832884288528862887288828892890289128922893289428952896289728982899290029012902290329042905290629072908290929102911291229132914291529162917291829192920292129222923292429252926292729282929293029312932293329342935293629372938293929402941294229432944294529462947294829492950295129522953295429552956295729582959296029612962296329642965296629672968296929702971297229732974297529762977297829792980298129822983298429852986298729882989299029912992299329942995299629972998299930003001300230033004300530063007300830093010301130123013301430153016301730183019302030213022302330243025302630273028302930303031303230333034303530363037303830393040304130423043304430453046304730483049305030513052305330543055305630573058305930603061306230633064306530663067306830693070307130723073307430753076307730783079308030813082308330843085308630873088308930903091309230933094309530963097309830993100310131023103310431053106310731083109311031113112311331143115311631173118311931203121312231233124312531263127312831293130313131323133313431353136313731383139314031413142314331443145314631473148314931503151315231533154315531563157315831593160316131623163316431653166316731683169317031713172317331743175317631773178317931803181318231833184318531863187318831893190319131923193319431953196319731983199320032013202320332043205320632073208320932103211321232133214321532163217321832193220322132223223322432253226322732283229323032313232323332343235323632373238323932403241324232433244324532463247324832493250325132523253325432553256325732583259326032613262326332643265326632673268326932703271327232733274327532763277327832793280328132823283328432853286328732883289329032913292329332943295329632973298329933003301330233033304330533063307330833093310331133123313331433153316331733183319332033213322332333243325332633273328332933303331333233333334333533363337333833393340334133423343334433453346334733483349335033513352335333543355335633573358335933603361336233633364336533663367336833693370337133723373337433753376337733783379338033813382338333843385338633873388338933903391339233933394339533963397339833993400340134023403340434053406340734083409341034113412341334143415341634173418341934203421342234233424342534263427342834293430343134323433343434353436343734383439344034413442344334443445344634473448344934503451345234533454345534563457345834593460346134623463346434653466346734683469347034713472347334743475347634773478347934803481348234833484348534863487348834893490349134923493349434953496349734983499350035013502350335043505350635073508350935103511351235133514351535163517351835193520352135223523352435253526352735283529353035313532353335343535353635373538353935403541354235433544354535463547354835493550355135523553355435553556355735583559356035613562356335643565356635673568356935703571357235733574357535763577357835793580358135823583358435853586358735883589359035913592359335943595359635973598359936003601360236033604360536063607360836093610361136123613361436153616361736183619362036213622362336243625362636273628362936303631363236333634363536363637363836393640364136423643364436453646364736483649365036513652365336543655365636573658365936603661366236633664366536663667366836693670367136723673367436753676367736783679368036813682368336843685368636873688368936903691369236933694369536963697369836993700370137023703370437053706370737083709371037113712371337143715371637173718371937203721372237233724372537263727372837293730373137323733373437353736373737383739374037413742374337443745374637473748374937503751375237533754375537563757375837593760376137623763376437653766376737683769377037713772377337743775377637773778377937803781378237833784378537863787378837893790379137923793379437953796379737983799380038013802380338043805380638073808380938103811381238133814381538163817381838193820382138223823382438253826382738283829383038313832383338343835383638373838383938403841384238433844384538463847384838493850385138523853385438553856385738583859386038613862386338643865386638673868386938703871387238733874387538763877387838793880388138823883388438853886388738883889389038913892389338943895389638973898389939003901390239033904390539063907390839093910391139123913391439153916391739183919392039213922392339243925392639273928392939303931393239333934393539363937393839393940394139423943394439453946394739483949395039513952395339543955395639573958395939603961396239633964396539663967396839693970397139723973397439753976397739783979398039813982398339843985398639873988398939903991399239933994399539963997399839994000400140024003400440054006400740084009401040114012401340144015401640174018401940204021402240234024402540264027402840294030403140324033403440354036403740384039404040414042404340444045404640474048404940504051405240534054405540564057405840594060406140624063406440654066406740684069407040714072407340744075407640774078407940804081408240834084408540864087408840894090409140924093409440954096409740984099410041014102410341044105410641074108410941104111411241134114411541164117411841194120412141224123412441254126412741284129413041314132413341344135413641374138413941404141414241434144414541464147414841494150415141524153415441554156415741584159416041614162416341644165416641674168416941704171417241734174417541764177417841794180418141824183418441854186418741884189419041914192419341944195419641974198419942004201420242034204420542064207420842094210421142124213421442154216421742184219422042214222422342244225422642274228422942304231423242334234423542364237423842394240424142424243424442454246424742484249425042514252425342544255425642574258425942604261426242634264426542664267426842694270427142724273427442754276427742784279428042814282428342844285428642874288428942904291429242934294429542964297429842994300430143024303430443054306430743084309431043114312431343144315431643174318431943204321432243234324432543264327432843294330433143324333433443354336433743384339434043414342434343444345434643474348434943504351435243534354435543564357435843594360436143624363436443654366436743684369437043714372437343744375437643774378437943804381438243834384438543864387438843894390439143924393439443954396439743984399440044014402440344044405440644074408440944104411441244134414441544164417441844194420442144224423442444254426442744284429443044314432443344344435443644374438443944404441444244434444444544464447444844494450445144524453445444554456445744584459446044614462446344644465446644674468446944704471447244734474447544764477447844794480448144824483448444854486448744884489449044914492449344944495449644974498449945004501450245034504450545064507450845094510451145124513451445154516451745184519452045214522452345244525452645274528452945304531453245334534453545364537453845394540454145424543454445454546454745484549455045514552455345544555455645574558455945604561456245634564456545664567456845694570457145724573457445754576457745784579458045814582458345844585458645874588458945904591459245934594459545964597459845994600460146024603460446054606460746084609461046114612461346144615461646174618461946204621462246234624462546264627462846294630463146324633463446354636463746384639464046414642464346444645464646474648464946504651465246534654465546564657465846594660466146624663466446654666466746684669467046714672467346744675467646774678467946804681468246834684468546864687468846894690469146924693469446954696469746984699470047014702470347044705470647074708470947104711471247134714471547164717471847194720472147224723472447254726472747284729473047314732473347344735473647374738473947404741474247434744474547464747474847494750475147524753475447554756475747584759476047614762476347644765476647674768476947704771477247734774477547764777477847794780478147824783478447854786478747884789479047914792479347944795479647974798479948004801480248034804480548064807480848094810481148124813481448154816481748184819482048214822482348244825482648274828482948304831483248334834483548364837483848394840484148424843484448454846484748484849485048514852485348544855485648574858485948604861486248634864486548664867486848694870487148724873487448754876487748784879488048814882488348844885488648874888488948904891489248934894489548964897489848994900490149024903490449054906490749084909491049114912491349144915491649174918491949204921492249234924492549264927492849294930493149324933493449354936493749384939494049414942494349444945494649474948494949504951495249534954495549564957495849594960496149624963496449654966496749684969497049714972497349744975497649774978497949804981498249834984498549864987498849894990499149924993499449954996499749984999500050015002500350045005500650075008500950105011501250135014501550165017501850195020502150225023502450255026502750285029503050315032503350345035503650375038503950405041504250435044504550465047504850495050505150525053505450555056505750585059506050615062506350645065506650675068506950705071507250735074507550765077507850795080508150825083508450855086508750885089509050915092509350945095509650975098509951005101510251035104510551065107510851095110511151125113511451155116511751185119512051215122512351245125512651275128512951305131513251335134513551365137513851395140514151425143514451455146514751485149515051515152515351545155515651575158515951605161516251635164516551665167516851695170517151725173517451755176517751785179518051815182518351845185518651875188518951905191519251935194519551965197519851995200520152025203520452055206520752085209521052115212521352145215521652175218521952205221522252235224522552265227522852295230523152325233523452355236523752385239524052415242524352445245524652475248524952505251525252535254525552565257525852595260526152625263526452655266526752685269527052715272527352745275527652775278527952805281528252835284528552865287528852895290529152925293529452955296529752985299530053015302530353045305530653075308530953105311531253135314531553165317531853195320532153225323532453255326532753285329533053315332533353345335533653375338533953405341534253435344534553465347534853495350535153525353535453555356535753585359536053615362536353645365536653675368536953705371537253735374537553765377537853795380538153825383538453855386538753885389539053915392539353945395539653975398539954005401540254035404540554065407540854095410541154125413541454155416541754185419542054215422542354245425542654275428542954305431543254335434543554365437543854395440544154425443544454455446544754485449545054515452545354545455545654575458545954605461546254635464546554665467546854695470547154725473547454755476547754785479548054815482548354845485548654875488548954905491549254935494549554965497549854995500550155025503550455055506550755085509551055115512551355145515551655175518551955205521552255235524552555265527552855295530553155325533553455355536553755385539554055415542554355445545554655475548554955505551555255535554555555565557555855595560556155625563556455655566556755685569557055715572557355745575557655775578557955805581558255835584558555865587558855895590559155925593559455955596559755985599560056015602560356045605560656075608560956105611561256135614561556165617561856195620562156225623562456255626562756285629563056315632563356345635563656375638563956405641564256435644564556465647564856495650565156525653565456555656565756585659566056615662566356645665566656675668566956705671567256735674567556765677567856795680568156825683568456855686568756885689569056915692569356945695569656975698569957005701570257035704570557065707570857095710571157125713571457155716571757185719572057215722572357245725572657275728572957305731573257335734573557365737573857395740574157425743574457455746574757485749575057515752575357545755575657575758575957605761576257635764576557665767576857695770577157725773577457755776577757785779578057815782578357845785578657875788578957905791579257935794 |
- <?php
- // Copyright (C) 2010-2017 Combodo SARL
- //
- // This file is part of iTop.
- //
- // iTop is free software; you can redistribute it and/or modify
- // it under the terms of the GNU Affero General Public License as published by
- // the Free Software Foundation, either version 3 of the License, or
- // (at your option) any later version.
- //
- // iTop is distributed in the hope that it will be useful,
- // but WITHOUT ANY WARRANTY; without even the implied warranty of
- // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- // GNU Affero General Public License for more details.
- //
- // You should have received a copy of the GNU Affero General Public License
- // along with iTop. If not, see <http://www.gnu.org/licenses/>
- /**
- * 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 "<p>Am I happy?</p>";
- echo "<p>Yes, I am!</p>";
- }
- }
- 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 '<p>'.$oQuery->RenderSelect().'</p>';
- $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 "<p>More info on this unexpected failure:<br/>".$OqlException->getHtmlDesc()."</p>\n";
- throw $OqlException;
- return false;
- }
- else
- {
- // Everything is fine :-)
- echo "<p>More info on this expected failure:<br/>".$OqlException->getHtmlDesc()."</p>\n";
- return true;
- }
- }
- catch (Exception $e)
- {
- if ($bIsCorrectQuery)
- {
- echo "<p>More info on this <b>un</b>expected failure:<br/>".htmlentities($e->getMessage(), ENT_QUOTES, 'UTF-8')."</p>\n";
- throw $OqlException;
- return false;
- }
- else
- {
- // Everything is fine :-)
- echo "<p>More info on this expected failure:<br/>".htmlentities($e->getMessage(), ENT_QUOTES, 'UTF-8')."</p>\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 "<h4>Testing query: $sQuery ($sIsOk)</h4>\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 "<p>More info on this unexpected failure:<br/>".$OqlException->getHtmlDesc()."</p>\n";
- throw $OqlException;
- return false;
- }
- else
- {
- // Everything is fine :-)
- echo "<p>More info on this expected failure:<br/>".$OqlException->getHtmlDesc()."</p>\n";
- return true;
- }
- }
- catch (Exception $e)
- {
- if ($bIsCorrectQuery)
- {
- echo "<p>More info on this <b>un</b>expected failure:<br/>".htmlentities($e->getMessage(), ENT_QUOTES, 'UTF-8')."</p>\n";
- throw $e;
- return false;
- }
- else
- {
- // Everything is fine :-)
- echo "<p>More info on this expected failure:<br/>".htmlentities($e->getMessage(), ENT_QUOTES, 'UTF-8')."</p>\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 "<h4>Testing query: $sQuery ($sIsOk)</h4>\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 "<table border=\"1\">\n";
- foreach ($aData as $iRow => $aRow)
- {
- echo "<tr>\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 = "<span style =\"color: red; background-color: grey;\">$sCellValue</span>";
- }
- elseif ($aExpectedResult[$iRow][$iCol] != $sCell)
- {
- $iIssues++;
- $sCellValue = "<span style =\"color: red; background-color: lightgrey;\">$sCellValue</span>, expecting '<span style =\"color: green; background-color: lightgrey;\">".$aExpectedResult[$iRow][$iCol]."</span>'";
- }
- echo "<td><pre>$sCellValue</pre></td>";
- }
- echo "</tr>\n";
- }
- echo "</table>\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 "<p>Totor: ".(UserRights::CheckCredentials('Totor', 'toto') ? 'ok' : 'NO')."</p>\n";
- echo "<p>Romain: ".(UserRights::CheckCredentials('Romain', 'toto') ? 'ok' : 'NO')."</p>\n";
- echo "<p>User: ".UserRights::GetUser()."</p>\n";
- echo "<p>On behalf of...".UserRights::GetRealUser()."</p>\n";
- echo "<p>Denis (impersonate) : ".(UserRights::Impersonate('Denis', 'tutu') ? 'ok' : 'NO')."</p>\n";
- echo "<p>User: ".UserRights::GetUser()."</p>\n";
- echo "<p>On behalf of...".UserRights::GetRealUser()."</p>\n";
- $oSet = new DBObjectSet(DBObjectSearch::FromOQL("SELECT bizOrganization"));
- echo "<p>IsActionAllowed...".(UserRights::IsActionAllowed('bizOrganization', UR_ACTION_MODIFY, $oSet) == UR_ALLOWED_YES ? 'ok' : 'NO')."</p>\n";
- echo "<p>IsStimulusAllowed...".(UserRights::IsStimulusAllowed('bizOrganization', 'myStimulus', $oSet) == UR_ALLOWED_YES ? 'ok' : 'NO')."</p>\n";
- echo "<p>IsActionAllowedOnAttribute...".(UserRights::IsActionAllowedOnAttribute('bizOrganization', 'myattribute', UR_ACTION_MODIFY, $oSet) == UR_ALLOWED_YES ? 'ok' : 'NO')."</p>\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 "<h4>Enum links</h4>";
- 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 "<h4>List attributes</h4>";
- foreach(MetaModel::ListAttributeDefs("cmdbTeam") as $sAttCode=>$oAttDef)
- {
- echo $oAttDef->GetLabel()." / ".$oAttDef->GetDescription()." / ".$oAttDef->GetType()."</br>\n";
- }
- }
-
- function test_search()
- {
- echo "<h4>Two searches</h4>";
- $oFilterAllDevs = new DBObjectSearch("cmdbTeam");
- $oAllDevs = new DBObjectSet($oFilterAllDevs);
-
- echo "Found ".$oAllDevs->Count()." items.</br>\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)."</br>\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 "<h4>Reload</h4>";
- $team = MetaModel::GetObject("cmdbContact", "2");
- echo "Chargement de l'attribut headcount: {$team->Get("headcount")}</br>\n";
- self::DumpVariable($team);
- }
-
- function test_setattribute()
- {
- echo "<h4>Set attribute and update</h4>";
- $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")}</br>\n";
- echo "Computed name = {$team->Get("name")}</br>\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 "<h4>Check the modified team</h4>";
- $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 "<h4>Create a new object (team)</h4>";
- $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</br>";
- echo "<h4>Delete team #$iId</h4>";
- $oTeam = MetaModel::GetObject("cmdbTeam", $iId);
- $oTeam->DBDeleteTracked($oMyChange);
- echo "Deleted team: $iId</br>";
- 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 "<h4>Update a the email: set to '$sNewEmail'</h4>";
- $oMyFilter = new DBObjectSearch("cmdbContact");
- $oMyFilter->AddCondition("name", "o", "Contains");
-
- echo "Candidates before:</br>";
- $this->search_and_show_list($oMyFilter);
-
- MetaModel::BulkUpdateTracked($oMyChange, $oMyFilter, array("email" => $sNewEmail));
-
- echo "Candidates after:</br>";
- $this->search_and_show_list($oMyFilter);
- }
-
- function test_error()
- {
- trigger_error("Stop requested", E_USER_ERROR);
- }
-
- function test_changetracking()
- {
- echo "<h4>Create a change</h4>";
- $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</br>";
- self::DumpVariable($oMyChange);
-
- echo "<h4>Create a new object (team)</h4>";
- $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</br>";
- echo "<h4>Delete team #$iId</h4>";
- $oTeam = MetaModel::GetObject("cmdbTeam", $iId);
- $oTeam->DBDeleteTracked($oMyChange);
- echo "Deleted team: $iId</br>";
- self::DumpVariable($oTeam);
- }
-
- function test_zlist()
- {
- echo "<h4>Test ZLists</h4>";
- $aZLists = MetaModel::EnumZLists();
- foreach ($aZLists as $sListCode)
- {
- $aListInfos = MetaModel::GetZListInfo($sListCode);
- echo "<h4>List '".$sListCode."' (".$aListInfos["description"].") of type '".$aListInfos["type"]."'</h5>\n";
-
- foreach (MetaModel::GetSubclasses("cmdbObjectHomeMade") as $sKlass)
- {
- $aItems = MetaModel::FlattenZlist(MetaModel::GetZListItems($sKlass, $sListCode));
- if (count($aItems) == 0) continue;
-
- echo "$sKlass - $sListCode : {".implode(", ", $aItems)."}</br>\n";
- }
- }
-
- echo "<h4>IsAttributeInZList()... </h4>";
- echo "Liens_entre_contacts_et_workshop::ws_info in list1 ? ".(MetaModel::IsAttributeInZList("Liens_entre_contacts_et_workshop", "list1", "ws_info") ? "yes" : "no")."</br>\n";
- echo "Liens_entre_contacts_et_workshop::toworkshop in list1 ? ".(MetaModel::IsAttributeInZList("Liens_entre_contacts_et_workshop", "list1", "toworkshop") ? "yes" : "no")."</br>\n";
-
- }
-
- function test_pkey()
- {
- echo "<h4>Test search on pkey</h4>";
- $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....</br>\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.</br>\n";
- echo "Set2 - Found ".$oSet2->Count()." items.</br>\n";
- echo "Intersect - Found ".$oIntersect->Count()." items.</br>\n";
- echo "Delta - Found ".$oDelta->Count()." items.</br>\n";
- echo "Append - Found ".$oAppend->Count()." items.</br>\n";
- //$this->show_list($oObjSet);
- }
-
- function test_relations()
- {
- echo "<h4>Test relations</h4>";
-
- //self::DumpVariable(MetaModel::EnumRelationQueries("cmdbObjectHomeMade", "Potes"));
- self::DumpVariable(MetaModel::EnumRelationQueries("cmdbContact", "Potes"));
-
- $iMaxDepth = 9;
- echo "Max depth = $iMaxDepth</br>\n";
-
- $oObj = MetaModel::GetObject("cmdbContact", 18);
- $aRels = $oObj->GetRelatedObjects("Potes", $iMaxDepth);
- echo $oObj->Get('name')." has some 'Potes'...</br>\n";
- foreach ($aRels as $sClass => $aObjs)
- {
- echo "$sClass, count = ".count($aObjs)." => ".implode(', ', array_keys($aObjs))."</br>\n";
- $oObjectSet = CMDBObjectSet::FromArray($sClass, $aObjs);
- $this->show_list($oObjectSet);
- }
-
- echo "<h4>Test relations - same results, by the mean of a OQL</h4>";
- $this->search_and_show_list_from_oql("cmdbContact: RELATED (Potes, $iMaxDepth) TO (cmdbContact: pkey = 18)");
-
- }
-
- function test_linkedset()
- {
- echo "<h4>Linked set attributes</h4>\n";
- $oObj = MetaModel::GetObject("cmdbContact", 18);
-
- echo "<h5>Current workshops</h5>\n";
- $oSetWorkshopsCurr = $oObj->Get("myworkshops");
- $this->show_list($oSetWorkshopsCurr);
-
- echo "<h5>Setting workshops</h5>\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 "<h5>New workshops</h5>\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 "<h5>After the write</h5>\n";
- $oSetWorkshopsCurr = $oObj->Get("myworkshops");
- $this->show_list($oSetWorkshopsCurr);
- }
-
- function test_object_lifecycle()
- {
- echo "<h4>Test object lifecycle</h4>";
-
-
- self::DumpVariable(MetaModel::GetStateAttributeCode("cmdbContact"));
- self::DumpVariable(MetaModel::EnumStates("cmdbContact"));
- self::DumpVariable(MetaModel::EnumStimuli("cmdbContact"));
- foreach(MetaModel::EnumStates("cmdbContact") as $sStateCode => $aStateDef)
- {
- echo "<p>Transition from <strong>$sStateCode</strong></p>\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: <em>$sExpr1</em> != <em>$sExpr2</em>");
- // $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 "<h4 style=\"color:green;\">$sQuery</h4>\n";
- }
- else
- {
- echo "<h4 style=\"color:red;\">$sQuery</h3>\n";
- }
- try
- {
- //$oOql = new OqlInterpreter($sQuery);
- //$oTrash = $oOql->ParseQuery();
- //self::DumpVariable($oTrash, true);
- $oMyFilter = DBObjectSearch::FromOQL($sQuery);
- }
- catch (OQLException $oOqlException)
- {
- if ($bIsCorrectQuery)
- {
- echo "<p>More info on this unexpected failure:<br/>".$oOqlException->getHtmlDesc()."</p>\n";
- throw $oOqlException;
- return false;
- }
- else
- {
- // Everything is fine :-)
- echo "<p>More info on this expected failure:\n";
- echo "<ul>\n";
- echo "<li>".get_class($oOqlException)."</li>\n";
- echo "<li>".$oOqlException->getMessage()."</li>\n";
- echo "<li>".$oOqlException->getHtmlDesc()."</li>\n";
- echo "</ul>\n";
- echo "</p>\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 "<p>To OQL: ".$oMyFilter->ToOQL()."</p>";
- $this->search_and_show_list($oMyFilter);
-
- //echo "<p>first pass<p>\n";
- //self::DumpVariable($oMyFilter, true);
- $sQuery1 = $oMyFilter->MakeSelectQuery();
- //echo "<p>second pass<p>\n";
- //self::DumpVariable($oMyFilter, true);
- //$sQuery1 = $oMyFilter->MakeSelectQuery();
-
- $sSerialize = $oMyFilter->serialize();
- echo "<p>Serialized:$sSerialize</p>\n";
- $oFilter2 = DBObjectSearch::unserialize($sSerialize);
- try
- {
- $sQuery2 = $oMyFilter2->MakeSelectQuery();
- }
- catch (Exception $e)
- {
- echo "<p>Could not compute the query after unserialize</p>\n";
- echo "<p>Query 1: $sQuery1</p>\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 "<p>serialize/unserialize mismatch :-(</p>\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: <em>$sExpr1</em> != <em>$sExpr2</em>");
- // $this->ReportSuccess('Found '.$oSet->Count()." objects of class $sClassName");
- echo "<h3>Create protagonists...</h3>";
- $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 "<h3>Parsing a long query, ".COUNT_BENCHMARK." times</h3>";
- $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 "<p>Mean time by op: $fParsingDuration</p>";
- }
- echo "<h3>Test queries...</h3>";
- $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: <em>$sExpr1</em> != <em>$sExpr2</em>");
- // $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</br>";
- echo "<h3>Planned for loading...</h3>";
- $aRes = $oBulk->Process();
- self::DumpVariable($aRes);
- echo "<h3>Go for loading...</h3>";
- $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 "<h3>Create protagonists...</h3>";
- $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 "<h3>Search...</h3>";
- $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 "<h3>Testing query: $sOqlQuery</h3>";
- $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 "<ul>\n";
- echo "<li>Parsing: $fParsingDuration</li>\n";
- echo "<li>Build: $fBuildDuration</li>\n";
- echo "<li>Query: $fQueryDuration</li>\n";
- echo "<li>Fetch: $fFetchDuration</li>\n";
- echo "<li>ToOql: $fToOqlDuration</li>\n";
- echo "</ul>\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 "<p>The test will be repeated ".COUNT_BENCHMARK." times</p>";
- $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 "<h5>Testing query: $sOqlQuery</h5>";
- $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 "<h2>Query $sQueryDesc</h2>\n";
- echo "<p>Using code: ".highlight_string("<?php\n".trim($aQuerySpec['search'])."\n?".'>', true)."</p>\n";
- echo "<p>Expected OQL: ".$aQuerySpec['oql']."</p>\n";
- if (isset($oSearch))
- {
- unset($oSearch);
- }
- eval($aQuerySpec['search']);
- $sResOQL = $oSearch->ToOQL();
- echo "<p>Resulting OQL: ".$sResOQL."</p>\n";
- echo "<pre>";
- print_r($oSearch);
- echo "</pre>";
- $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</br>";
- }
- echo "<h3>Planned for loading...</h3>";
- $aRes = $oBulk->Process();
- self::DumpVariable($aRes);
- if (false)
- {
- echo "<h3>Go for loading...</h3>";
- $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 "<div style=\"padding: 10;\">\n";
- if (is_null($iTestId))
- {
- echo "<h3 style=\"background-color: #ddddff; padding: 10;\">{$aLoadSpec['desc']}</h3>\n";
- }
- else
- {
- echo "<h3 style=\"background-color: #ddddff; padding: 10;\"><a href=\"?todo=exec&testid=TestImportREST&subtests=$iTestId\">$iTestId</a> - {$aLoadSpec['desc']}</h3>\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('<br/>', $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 "<div style=\"\">\n";
- echo " <div style=\"float:left; width:20%; padding:5; background-color:#eeeeff;\">\n";
- echo " $sArguments\n";
- echo " </div>\n";
- echo " <div style=\"float:right; width:75%; padding:5; background-color:#eeeeff\">\n";
- echo " <pre class=\"vardump\">$sCsvDataViewable</pre>\n";
- echo " </div>\n";
- echo "</div>\n";
- echo "<pre class=\"vardump\" style=\"clear: both; padding: 15; background-color: black; color: green;\">$sRes</pre>\n";
- echo "</div>\n";
- }
-
- protected function DoExecute()
- {
- $aLoads = array(
- array(
- 'desc' => 'Missing class',
- 'login' => 'admin',
- 'password' => 'admin',
- 'args' => array(
- ),
- 'csvdata' => "xxx",
- ),
- array(
- 'desc' => 'Wrong class',
- 'login' => 'admin',
- 'password' => 'admin',
- 'args' => array(
- 'class' => 'toto',
- ),
- 'csvdata' => "xxx",
- ),
- array(
- 'desc' => 'Wrong output type',
- 'login' => 'admin',
- 'password' => 'admin',
- 'args' => array(
- 'class' => 'NetworkDevice',
- 'output' => 'onthefly',
- ),
- 'csvdata' => "xxx",
- ),
- array(
- 'desc' => 'Weird format, working anyhow...',
- 'login' => 'admin',
- 'password' => 'admin',
- 'args' => array(
- 'class' => 'Server',
- 'output' => 'details',
- 'separator' => '*',
- 'qualifier' => '@',
- 'reconciliationkeys' => 'org_id,name',
- ),
- 'csvdata' => 'name*org_id
- server01*2
- @server02@@combodo@* 2
- server45*99',
- ),
- array(
- 'desc' => 'Load an organization',
- 'login' => 'admin',
- 'password' => 'admin',
- 'args' => array(
- 'class' => 'Organization',
- 'output' => 'details',
- 'separator' => ';',
- 'reconciliationkeys' => '',
- ),
- 'csvdata' => "name;code\nWorldCompany;WCY",
- ),
- array(
- 'desc' => 'Load a location',
- 'login' => 'admin',
- 'password' => 'admin',
- 'args' => array(
- 'class' => 'Location',
- 'output' => 'details',
- 'separator' => ';',
- 'reconciliationkeys' => '',
- ),
- 'csvdata' => "name;org_id;address\nParis;1;Centre de la Franca",
- ),
- array(
- 'desc' => 'Load a person',
- 'login' => 'admin',
- 'password' => 'admin',
- 'args' => array(
- 'class' => 'Person',
- 'output' => 'details',
- 'separator' => ';',
- 'reconciliationkeys' => '',
- ),
- 'csvdata' => "email;name;first_name;org_id;phone\njohn.foo@starac.com;Foo;John;1;+33(1)23456789",
- ),
- array(
- 'desc' => 'Load a person - wrong email format',
- 'login' => 'admin',
- 'password' => 'admin',
- 'args' => array(
- 'class' => 'Person',
- 'output' => 'details',
- 'separator' => ';',
- 'reconciliationkeys' => '',
- ),
- 'csvdata' => "email;name;first_name;org_id\nemailPASbon;Foo;John;1",
- ),
- array(
- 'desc' => 'Load a team',
- 'login' => 'admin',
- 'password' => 'admin',
- 'args' => array(
- 'class' => 'Team',
- 'output' => 'details',
- 'separator' => ';',
- 'reconciliationkeys' => '',
- ),
- 'csvdata' => "name;org_id;location_name\nSquadra Azzura2;1;Paris",
- ),
- array(
- 'desc' => 'Load server',
- 'login' => 'admin',
- 'password' => 'admin',
- 'args' => array(
- 'class' => 'Server',
- 'output' => 'details',
- 'separator' => ';',
- 'reconciliationkeys' => '',
- ),
- 'csvdata' => "name;status;owner_name;location_name;location_id->org_name;os_family;os_version;management_ip;cpu;ram;brand;model;serial_number\nlocalhost.;production;Demo;Grenoble;Demo;Ubuntu 9.10;2.6.31-19-generic-#56-Ubuntu SMP Thu Jan 28 01:26:53 UTC 2010;16.16.230.232;Intel(R) Core(TM)2 Duo CPU T7100 @ 1.80GHz;2005;Hewlett-Packard;HP Compaq 6510b (GM108UC#ABF);CNU7370BNP",
- ),
- array(
- 'desc' => 'Load server (column header localized in english)',
- 'login' => 'admin',
- 'password' => 'admin',
- 'args' => array(
- 'class' => 'Server',
- 'output' => 'details',
- 'separator' => ';',
- 'reconciliationkeys' => '',
- ),
- 'csvdata' => "Name;Status;Owner Organization;Location;location_id->org_name;OS Family;OS Version;Management IP;CPU;RAM;Brand;Model;Serial Number\nlocalhost.;production;Demo;Grenoble;Demo;Ubuntu 9.10;2.6.31-19-generic-#56-Ubuntu SMP Thu Jan 28 01:26:53 UTC 2010;16.16.230.232;Intel(R) Core(TM)2 Duo CPU T7100 @ 1.80GHz;2005;Hewlett-Packard;HP Compaq 6510b (GM108UC#ABF);CNU7370BNP",
- ),
- array(
- 'desc' => 'Load server (directly from Export results)',
- 'login' => 'admin',
- 'password' => 'admin',
- 'args' => array(
- 'class' => 'Server',
- 'output' => 'details',
- 'reconciliationkeys' => '',
- ),
- 'csvdata' => 'id,Name,Status,Owner organization,Owner organization->Name,Business criticity,Brand,Model,Serial Number,Asset Reference,Description,Location,Location->Name,Location details,Management IP,Default Gateway,CPU,RAM,Hard Disk,OS Family,OS Version
- 1,"dbserver1.demo.com","production",2,"Demo","medium","HP","DL380","","","ouille
- [[Server:webserver.demo.com]]",1,"Grenoble","","10.1.1.10","255.255.255.0","2","16Gb","120Gb","Linux","Debian (Lenny)"',
- ),
- array(
- 'desc' => 'Load server - wrong value for status',
- 'login' => 'admin',
- 'password' => 'admin',
- 'args' => array(
- 'class' => 'Server',
- 'output' => 'details',
- 'separator' => ';',
- 'reconciliationkeys' => '',
- ),
- 'csvdata' => "name;status;owner_name;location_name;location_id->org_name;os_family;os_version;management_ip;cpu;ram;brand;model;serial_number\nlocalhost.;Production;Demo;Grenoble;Demo;Ubuntu 9.10;2.6.31-19-generic-#56-Ubuntu SMP Thu Jan 28 01:26:53 UTC 2010;16.16.230.232;Intel(R) Core(TM)2 Duo CPU T7100 @ 1.80GHz;2005;Hewlett-Packard;HP Compaq 6510b (GM108UC#ABF);CNU7370BNP",
- ),
- array(
- 'desc' => 'Load NW if',
- 'login' => 'admin',
- 'password' => 'admin',
- 'args' => array(
- 'class' => 'NetworkInterface',
- 'output' => 'details',
- 'separator' => ';',
- 'reconciliationkeys' => '',
- ),
- 'csvdata' => "name;status;org_id;device_name;physical_type;ip_address;ip_mask;mac_address;speed\neth0;implementation;2;localhost.;ethernet;16.16.230.232;255.255.240.0;00:1a:4b:68:e3:97;\nlo;implementation;2;localhost.;ethernet;127.0.0.1;255.0.0.0;;",
- ),
- // Data Bruno
- array(
- 'desc' => 'Load NW devices from real life',
- 'login' => 'admin',
- 'password' => 'admin',
- 'args' => array(
- 'class' => 'NetworkDevice',
- 'output' => 'details',
- 'separator' => ';',
- 'reconciliationkeys' => 'org_id,Name',
- ),
- 'csvdata' => 'name;management_ip;importance;Owner organization->Name;type
- truc-machin-bidule;172.15.255.150;high;My Company/Department;switch
- 10.15.255.222;10.15.255.222;high;My Company/Department;switch',
- ),
- array(
- 'desc' => 'Load NW ifs',
- 'login' => 'admin',
- 'password' => 'admin',
- 'args' => array(
- 'class' => 'NetworkInterface',
- 'output' => 'details',
- 'separator' => ';',
- 'reconciliationkeys' => 'device_id->name,name',
- ),
- 'csvdata' => 'device_id->name;org_id->name;name;ip_address;ip_mask;speed;link_type;mac_address;physical_type
- truc-machin-bidule;My Company/Department;"GigabitEthernet44";;;0;downlink;00 12 F2 CB C4 EB ;ethernet
- truc-machin-bidule;My Company/Department;"GigabitEthernet38";;;0;downlink;00 12 F2 CB C4 E5 ;ethernet
- un-autre;My Company/Department;"GigabitEthernet2/3";;;1000000000;uplink;00 12 F2 20 0F 1A ;ethernet',
- ),
- array(
- 'desc' => 'The simplest data load',
- 'login' => 'admin',
- 'password' => 'admin',
- 'args' => array(
- 'class' => 'Location',
- 'output' => 'details',
- ),
- 'csvdata' => "name\nParis",
- ),
- array(
- 'desc' => 'The simplest data load + org',
- 'login' => 'admin',
- 'password' => 'admin',
- 'args' => array(
- 'class' => 'Location',
- 'output' => 'details',
- 'separator' => ';',
- ),
- 'csvdata' => "name;org_id\nParis;2",
- ),
- array(
- 'desc' => 'The simplest data load + org (name)',
- 'login' => 'admin',
- 'password' => 'admin',
- 'args' => array(
- 'class' => 'Location',
- 'output' => 'details',
- 'separator' => ';',
- ),
- 'csvdata' => "name;org_name\nParis;Demo",
- ),
- array(
- 'desc' => 'The simplest data load + org (code)',
- 'login' => 'admin',
- 'password' => 'admin',
- 'args' => array(
- 'class' => 'Location',
- 'output' => 'details',
- 'separator' => ';',
- ),
- 'csvdata' => "name;org_id->code\nParis;DEMO",
- ),
- array(
- 'desc' => 'Ouput: summary',
- 'login' => 'admin',
- 'password' => 'admin',
- 'args' => array(
- 'class' => 'Location',
- 'output' => 'summary',
- 'separator' => ';',
- ),
- 'csvdata' => "name;org_id->code\nParis;DEMO",
- ),
- array(
- 'desc' => 'Ouput: retcode',
- 'login' => 'admin',
- 'password' => 'admin',
- 'args' => array(
- 'class' => 'Location',
- 'output' => 'retcode',
- 'separator' => ';',
- ),
- 'csvdata' => "name;org_id->code\nParis;DEMO",
- ),
- array(
- 'desc' => 'Error in reconciliation list',
- 'login' => 'admin',
- 'password' => 'admin',
- 'args' => array(
- 'class' => 'Location',
- 'output' => 'details',
- 'separator' => ';',
- 'reconciliationkeys' => 'org_id',
- ),
- 'csvdata' => "org_name;name\nDemo;Paris",
- ),
- array(
- 'desc' => 'Error in attribute list that does not allow to compute reconciliation scheme',
- 'login' => 'admin',
- 'password' => 'admin',
- 'args' => array(
- 'class' => 'Location',
- 'output' => 'details',
- 'separator' => ';',
- ),
- 'csvdata' => "org_name;country\nDemo;France",
- ),
- array(
- 'desc' => 'Error in attribute list - case A',
- 'login' => 'admin',
- 'password' => 'admin',
- 'args' => array(
- 'class' => 'Location',
- 'output' => 'details',
- 'separator' => ';',
- ),
- 'csvdata' => "name;org\nParis;2",
- ),
- array(
- 'desc' => 'Error in attribute list - case B1 (key->attcode)',
- 'login' => 'admin',
- 'password' => 'admin',
- 'args' => array(
- 'class' => 'Location',
- 'output' => 'details',
- 'separator' => ';',
- ),
- 'csvdata' => "name;org->code\nParis;DEMO",
- ),
- array(
- 'desc' => 'Error in attribute list - case B2 (key->attcode)',
- 'login' => 'admin',
- 'password' => 'admin',
- 'args' => array(
- 'class' => 'Location',
- 'output' => 'details',
- 'separator' => ';',
- ),
- 'csvdata' => "name;org_id->duns\nParis;DEMO",
- ),
- array(
- 'desc' => 'Always changing... special comment in change tracking',
- 'login' => 'admin',
- 'password' => 'admin',
- 'args' => array(
- 'class' => 'Location',
- 'output' => 'details',
- 'separator' => ';',
- 'comment' => 'automated testing'
- ),
- 'csvdata' => "org_name;name;address\nDemo;Le pantheon;Addresse bidon:".((string)microtime(true)),
- ),
- array(
- 'desc' => 'Always changing... but "simulate"',
- 'login' => 'admin',
- 'password' => 'admin',
- 'args' => array(
- 'class' => 'Location',
- 'output' => 'details',
- 'separator' => ';',
- 'simulate' => '1',
- 'comment' => 'SHOULD NEVER APPEAR IN THE HISTORY'
- ),
- 'csvdata' => "org_name;name;address\nDemo;Le pantheon;restore address?",
- ),
- array(
- 'desc' => 'Load a user account',
- 'login' => 'admin',
- 'password' => 'admin',
- 'args' => array(
- 'class' => 'UserLocal',
- 'output' => 'details',
- 'separator' => ',',
- 'simulate' => '0',
- 'comment' => 'automated testing'
- ),
- 'csvdata' => "login,password,profile_list\nby_import_csv,fakepwd,profileid->name:Configuration Manager|profileid:10;reason:direct id",
- ),
- );
- $sSubTests = utils::ReadParam('subtests', null, true, 'raw_data');
- if (is_null($sSubTests))
- {
- foreach ($aLoads as $iTestId => $aLoadSpec)
- {
- $this->DoExecSingleLoad($aLoadSpec, $iTestId);
- }
- }
- else
- {
- $aSubTests = explode(',', $sSubTests);
- foreach ($aSubTests as $iTestId)
- {
- $this->DoExecSingleLoad($aLoads[$iTestId], $iTestId);
- }
- }
- }
- }
- ///////////////////////////////////////////////////////////////////////////
- // Test massive data load
- ///////////////////////////////////////////////////////////////////////////
- define('IMPORT_COUNT', 4000);
- class TestImportRESTMassive extends TestImportREST
- {
- static public function GetName()
- {
- return 'CSV import (REST) - HUGE data set ('.IMPORT_COUNT.' PCs)';
- }
- static public function GetDescription()
- {
- return 'Stress import.php';
- }
- protected function DoExecute()
- {
- $aLoadSpec = array(
- 'desc' => 'Loading PCs: '.IMPORT_COUNT,
- 'args' => array(
- 'class' => 'PC',
- 'output' => 'summary',
- ),
- 'csvdata' => "name;org_id;brand\n",
- );
- for($i = 0 ; $i <= IMPORT_COUNT ; $i++)
- {
- $aLoadSpec['csvdata'] .= "pc.import.$i;2;Combodo\n";
- }
- $this->DoExecSingleLoad($aLoadSpec);
- }
- }
- ///////////////////////////////////////////////////////////////////////////
- // Test data exchange
- ///////////////////////////////////////////////////////////////////////////
- class TestDataExchange extends TestBizModel
- {
- static public function GetName()
- {
- return 'Data exchange';
- }
- static public function GetDescription()
- {
- return 'Test REST services: synchro_import and synchro_exec';
- }
- protected function DoExecScenario($aSingleScenario)
- {
- echo "<div style=\"padding: 10;\">\n";
- echo "<h3 style=\"background-color: #ddddff; padding: 10;\">{$aSingleScenario['desc']}</h3>\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 "<p>Status at step $iRow</p>\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[] = '<NULL>';
- }
- 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 "<div style=\"\">\n";
- echo " <pre class=\"vardump\">$sCsvDataViewable</pre>\n";
- echo "</div>\n";
-
- echo "<pre class=\"vardump\" style=\"clear: both; padding: 15; background-color: black; color: green;\">$sRes</pre>\n";
- if (stripos($sRes, 'exception') !== false)
- {
- throw new UnitTestException('Encountered an Exception during the last import/synchro');
- }
- }
- }
- return;
- echo "</div>\n";
- }
-
- protected function DoExecute()
- {
- /*
- $aScenarios = array(
- array(
- 'desc' => 'Load user logins',
- 'login' => 'admin',
- 'password' => 'admin',
- 'target_class' => 'UserLocal',
- 'full_load_periodicity' => 3600, // should be ignored in this case
- 'reconciliation_policy' => 'use_attributes',
- 'action_on_zero' => 'create',
- 'action_on_one' => 'update',
- 'action_on_multiple' => 'error',
- 'delete_policy' => 'delete',
- 'delete_policy_update' => '',
- 'delete_policy_retention' => 0,
- 'source_data' => array(
- array('primary_key', 'login', 'password', 'profile_list'),
- array(
- array('user_A', 'login_A', 'password_A', 'profileid:10;reason:he/she is managing services'),
- ),
- ),
- 'target_data' => array(
- array('login'),
- array(
- // Initial state
- ),
- array(
- array('login_A'),
- ),
- ),
- 'attributes' => array(
- 'login' => array(
- 'do_reconcile' => true,
- 'do_update' => true,
- 'automatic_prefix' => true, // unique id (for unit testing)
- ),
- 'password' => array(
- 'do_reconcile' => false,
- 'do_update' => true,
- ),
- 'profile_list' => array(
- 'do_reconcile' => false,
- 'do_update' => true,
- ),
- ),
- ),
- );
- */
- $aScenarios = array(
- array(
- 'desc' => 'Simple scenario with delete option (and extkey given as org/name)',
- 'login' => 'admin',
- 'password' => 'admin',
- 'target_class' => 'ApplicationSolution',
- 'full_load_periodicity' => 3600, // should be ignored in this case
- 'reconciliation_policy' => 'use_attributes',
- 'action_on_zero' => 'create',
- 'action_on_one' => 'update',
- 'action_on_multiple' => 'error',
- 'delete_policy' => 'delete',
- 'delete_policy_update' => '',
- 'delete_policy_retention' => 0,
- 'source_data' => array(
- array('primary_key', 'org_id', 'name', 'status'),
- array(
- array('obj_A', null, 'obj_A', 'production'), // org_id unchanged
- array('obj_B', '_DUMMY_', 'obj_B', 'production'), // error, '_DUMMY_' unknown
- array('obj_C', 'SOMECODE', 'obj_C', 'production'),
- array('obj_D', null, 'obj_D', 'production'),
- array('obj_E', '_DUMMY_', 'obj_E', 'production'),
- ),
- array(
- ),
- array(
- ),
- ),
- 'target_data' => array(
- array('org_id', 'name', 'status'),
- array(
- // Initial state
- array(2, 'obj_A', 'production'),
- array(2, 'obj_B', 'production'),
- ),
- array(
- array(2, 'obj_A', 'production'),
- array(2, 'obj_B', 'production'),
- array(1, 'obj_C', 'production'),
- ),
- array(
- array(2, 'obj_A', 'production'),
- array(2, 'obj_B', 'production'),
- // deleted !
- ),
- // The only diff here is into the log
- array(
- array(2, 'obj_A', 'production'),
- array(2, 'obj_B', 'production'),
- // deleted !
- ),
- ),
- 'attributes' => array(
- 'org_id' => array(
- 'do_reconcile' => false,
- 'do_update' => true,
- 'reconciliation_attcode' => 'code',
- ),
- 'name' => array(
- 'do_reconcile' => true,
- 'do_update' => true,
- 'automatic_prefix' => true, // unique id
- ),
- 'status' => array(
- 'do_reconcile' => false,
- 'do_update' => true,
- ),
- ),
- ),
- // );
- // $aXXXXScenarios = array(
- array(
- 'desc' => 'Update then delete with retention (to complete with manual testing) and reconciliation on org/name',
- 'login' => 'admin',
- 'password' => 'admin',
- 'target_class' => 'ApplicationSolution',
- 'full_load_periodicity' => 3600,
- 'reconciliation_policy' => 'use_attributes',
- 'action_on_zero' => 'create',
- 'action_on_one' => 'update',
- 'action_on_multiple' => 'error',
- 'delete_policy' => 'update_then_delete',
- 'delete_policy_update' => 'status:obsolete',
- 'delete_policy_retention' => 15,
- 'source_data' => array(
- array('primary_key', 'org_id', 'name', 'status'),
- array(
- array('obj_A', 'Demo', 'obj_A', 'production'),
- ),
- array(
- ),
- ),
- 'target_data' => array(
- array('org_id', 'name', 'status'),
- array(
- // Initial state
- ),
- array(
- array(2, 'obj_A', 'production'),
- ),
- array(
- array(2, 'obj_A', 'obsolete'),
- // deleted !
- ),
- ),
- 'attributes' => array(
- 'org_id' => array(
- 'do_reconcile' => true,
- 'do_update' => true,
- 'reconciliation_attcode' => 'name',
- ),
- 'name' => array(
- 'do_reconcile' => true,
- 'do_update' => true,
- 'automatic_prefix' => true, // unique id
- ),
- 'status' => array(
- 'do_reconcile' => false,
- 'do_update' => true,
- ),
- ),
- ),
- //);
- //$aXXScenarios = array(
- array(
- 'desc' => 'Simple scenario loading a few ApplicationSolution',
- 'login' => 'admin',
- 'password' => 'admin',
- 'target_class' => 'ApplicationSolution',
- 'full_load_periodicity' => 3600,
- 'reconciliation_policy' => 'use_attributes',
- 'action_on_zero' => 'create',
- 'action_on_one' => 'update',
- 'action_on_multiple' => 'error',
- 'delete_policy' => 'update',
- 'delete_policy_update' => 'status:obsolete',
- 'delete_policy_retention' => 0,
- 'source_data' => array(
- array('primary_key', 'org_id', 'name', 'status'),
- array(
- array('obj_A', 2, 'obj_A', 'production'),
- array('obj_B', 2, 'obj_B', 'implementation'),
- array('obj_C', 2, 'obj_C', 'implementation'),
- ),
- array(
- array('obj_A', 2, 'obj_A', 'production'),
- array('obj_B', 2, 'obj_B', 'implementation'),
- array('obj_C', 2, 'obj_C', 'implementation'),
- ),
- array(
- array('obj_A', 2, 'obj_A', 'production'),
- array('obj_C', 2, 'obj_C', 'implementation'),
- array('obj_D', 2, 'obj_D', 'implementation'),
- ),
- array(
- array('obj_C', 2, 'obj_C', 'production'),
- ),
- array(
- array('obj_C', 2, 'obj_C', 'production'),
- ),
- ),
- 'target_data' => array(
- array('org_id', 'name', 'status'),
- array(
- // Initial state
- array(2, 'obj_A', 'implementation'),
- array(2, 'obj_B', 'production'),
- array(2, 'obj_B', 'implementation'),
- ),
- array(
- array(2, 'obj_A', 'production'),
- array(2, 'obj_B', 'production'),
- array(2, 'obj_B', 'implementation'),
- array(2, 'obj_C', 'implementation'),
- ),
- array(
- array(2, 'obj_A', 'production'),
- array(2, 'obj_B', 'production'),
- array(2, 'obj_B', 'implementation'),
- array(2, 'obj_C', 'implementation'),
- ),
- array(
- array(2, 'obj_A', 'production'),
- array(2, 'obj_B', 'production'),
- array(2, 'obj_B', 'implementation'),
- array(2, 'obj_C', 'implementation'),
- array(2, 'obj_D', 'implementation'),
- ),
- array(
- array(2, 'obj_A', 'obsolete'),
- array(2, 'obj_B', 'production'),
- array(2, 'obj_B', 'implementation'),
- array(2, 'obj_C', 'production'),
- array(2, 'obj_D', 'obsolete'),
- ),
- array(
- array(2, 'obj_A', 'obsolete'),
- array(2, 'obj_B', 'production'),
- array(2, 'obj_B', 'implementation'),
- array(2, 'obj_C', 'production'),
- array(2, 'obj_D', 'obsolete'),
- ),
- ),
- 'attributes' => array(
- 'org_id' => array(
- 'do_reconcile' => false,
- 'do_update' => true,
- ),
- 'name' => array(
- 'do_reconcile' => true,
- 'do_update' => true,
- 'automatic_prefix' => true, // unique id
- ),
- 'status' => array(
- 'do_reconcile' => false,
- 'do_update' => true,
- ),
- ),
- ),
- );
- foreach ($aScenarios as $aSingleScenario)
- {
- $this->DoExecScenario($aSingleScenario);
- }
- }
- }
- ///////////////////////////////////////////////////////////////////////////
- // Test SOAP services
- ///////////////////////////////////////////////////////////////////////////
- $aCreateTicketSpecs = array(
- array(
- 'service_category' => 'BasicServices',
- 'verb' => 'GetVersion',
- // 'expected result' => '1.0.1',
- 'expected result' => '$ITOP_VERSION$ [dev]',
- 'explain result' => 'no comment!',
- 'args' => array(),
- ),
- array(
- 'service_category' => '',
- 'verb' => 'CreateIncidentTicket',
- 'expected result' => true,
- 'explain result' => 'link attribute unknown + a CI not found',
- 'args' => array(
- 'admin', /* sLogin */
- 'admin', /* sPassword */
- 'desc of ticket', /* sDescription */
- 'initial situation blah blah blah', /* sInitialSituation */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('id', 1))), /* aCallerDesc */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('name', 'Demo'))), /* aCustomerDesc */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('name', 'Telecom and connectivity'))), /* aServiceDesc */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('name', 'Network Troubleshooting'))), /* aServiceSubcategoryDesc */
- 'sub product of the service', /* sProduct */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('name', 'Hardware support'))), /* aWorkgroupDesc */
- array(
- new SOAPLinkCreationSpec(
- 'InfrastructureCI',
- array(new SOAPSearchCondition('name', 'dbserver1.demo.com')),
- array(new SOAPAttributeValue('impacting', 'very critical'))
- ),
- new SOAPLinkCreationSpec(
- 'NetworkDevice',
- array(new SOAPSearchCondition('name', 'switch01')),
- array(new SOAPAttributeValue('impact', 'who cares'))
- ),
- new SOAPLinkCreationSpec(
- 'Server',
- array(new SOAPSearchCondition('name', 'thisone')),
- array(new SOAPAttributeValue('impact', 'our lives'))
- ),
- ), /* aImpact */
- '1', /* sImpact */
- '1', /* sUrgency */
- ),
- ),
- array(
- 'service_category' => '',
- 'verb' => 'CreateIncidentTicket',
- 'expected result' => true,
- 'explain result' => 'caller not specified',
- 'args' => array(
- 'admin', /* sLogin */
- 'admin', /* sPassword */
- 'PC burning', /* sDescription */
- 'The power supply suddenly started to warm up', /* sInitialSituation */
- new SOAPExternalKeySearch(), /* aCallerDesc */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('name', 'Demo'))), /* aCustomerDesc */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('name', 'Computers and peripherals'))), /* aServiceDesc */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('id', 1))), /* aServiceSubcategoryDesc */
- 'sub product of the service', /* sProduct */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('name', 'Hardware support'))), /* aWorkgroupDesc */
- array(
- new SOAPLinkCreationSpec(
- 'InfrastructureCI',
- array(new SOAPSearchCondition('name', 'dbserver1.demo.com')),
- array()
- ), /* aImpact */
- ),
- '1', /* sImpact */
- '1', /* sUrgency */
- ),
- ),
- array(
- 'service_category' => '',
- 'verb' => 'CreateIncidentTicket',
- 'expected result' => false,
- 'explain result' => 'wrong class on CI to attach',
- 'args' => array(
- 'admin', /* sLogin */
- 'admin', /* sPassword */
- 'PC burning', /* sDescription */
- 'The power supply suddenly started to warm up', /* sInitialSituation */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('id', 1))), /* aCallerDesc */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('name', 'Demo'))), /* aCustomerDesc */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('name', 'Computers and peripherals'))), /* aServiceDesc */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('id', 1))), /* aServiceSubcategoryDesc */
- 'sub product of the service', /* sProduct */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('name', 'Hardware support'))), /* aWorkgroupDesc */
- array(
- new SOAPLinkCreationSpec(
- 'logInfra',
- array(new SOAPSearchCondition('dummyfiltercode', 2)),
- array(new SOAPAttributeValue('impact', 'very critical'))
- ),
- ), /* aImpact */
- '1', /* sImpact */
- '1', /* sUrgency */
- ),
- ),
- array(
- 'service_category' => '',
- 'verb' => 'CreateIncidentTicket',
- 'expected result' => false,
- 'explain result' => 'wrong search condition on CI to attach',
- 'args' => array(
- 'admin', /* sLogin */
- 'admin', /* sPassword */
- 'PC burning', /* sDescription */
- 'The power supply suddenly started to warm up', /* sInitialSituation */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('id', 1))), /* aCallerDesc */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('name', 'Demo'))), /* aCustomerDesc */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('name', 'Computers and peripherals'))), /* aServiceDesc */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('id', 1))), /* aServiceSubcategoryDesc */
- 'sub product of the service', /* sProduct */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('name', 'Hardware support'))), /* aWorkgroupDesc */
- array(
- new SOAPLinkCreationSpec(
- 'InfrastructureCI',
- array(new SOAPSearchCondition('dummyfiltercode', 2)),
- array(new SOAPAttributeValue('impact', 'very critical'))
- ),
- ), /* aImpact */
- '1', /* sImpact */
- '1', /* sUrgency */
- ),
- ),
- array(
- 'service_category' => '',
- 'verb' => 'CreateIncidentTicket',
- 'expected result' => true,
- 'explain result' => 'no CI to attach (empty array)',
- 'args' => array(
- 'admin', /* sLogin */
- 'admin', /* sPassword */
- 'Houston not reachable', /* sDescription */
- 'Tried to join the shuttle', /* sInitialSituation */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('id', 1))), /* aCallerDesc */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('name', 'Demo'))), /* aCustomerDesc */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('name', 'Computers and peripherals'))), /* aServiceDesc */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('id', 1))), /* aServiceSubcategoryDesc */
- 'sub product of the service', /* sProduct */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('name', 'Hardware support'))), /* aWorkgroupDesc */
- array(
- ), /* aImpact */
- '1', /* sImpact */
- '1', /* sUrgency */
- ),
- ),
- array(
- 'service_category' => '',
- 'verb' => 'CreateIncidentTicket',
- 'expected result' => true,
- 'explain result' => 'no CI to attach (null)',
- 'args' => array(
- 'admin', /* sLogin */
- 'admin', /* sPassword */
- 'Houston not reachable', /* sDescription */
- 'Tried to join the shuttle', /* sInitialSituation */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('id', 1))), /* aCallerDesc */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('name', 'Demo'))), /* aCustomerDesc */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('name', 'Computers and peripherals'))), /* aServiceDesc */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('id', 1))), /* aServiceSubcategoryDesc */
- 'sub product of the service', /* sProduct */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('name', 'Hardware support'))), /* aWorkgroupDesc */
- null, /* aImpact */
- '1', /* sImpact */
- '1', /* sUrgency */
- ),
- ),
- array(
- 'service_category' => '',
- 'verb' => 'CreateIncidentTicket',
- 'expected result' => true,
- 'explain result' => 'caller unknown',
- 'args' => array(
- 'admin', /* sLogin */
- 'admin', /* sPassword */
- 'Houston not reachable', /* sDescription */
- 'Tried to join the shuttle', /* sInitialSituation */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('id', 1000))), /* aCallerDesc */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('name', 'Demo'))), /* aCustomerDesc */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('name', 'Computers and peripherals'))), /* aServiceDesc */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('id', 1))), /* aServiceSubcategoryDesc */
- 'sub product of the service', /* sProduct */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('name', 'Hardware support'))), /* aWorkgroupDesc */
- array(
- ), /* aImpact */
- '1', /* sImpact */
- '1', /* sUrgency */
- ),
- ),
- array(
- 'service_category' => '',
- 'verb' => 'CreateIncidentTicket',
- 'expected result' => false,
- 'explain result' => 'wrong values for impact and urgency',
- 'args' => array(
- 'admin', /* sLogin */
- 'admin', /* sPassword */
- 'Houston not reachable', /* sDescription */
- 'Tried to join the shuttle', /* sInitialSituation */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('id', 1))), /* aCallerDesc */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('name', 'Demo'))), /* aCustomerDesc */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('name', 'Computers and peripherals'))), /* aServiceDesc */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('id', 1))), /* aServiceSubcategoryDesc */
- 'sub product of the service', /* sProduct */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('name', 'Hardware support'))), /* aWorkgroupDesc */
- array(
- ), /* aImpact */
- '6', /* sImpact */
- '7', /* sUrgency */
- ),
- ),
- array(
- 'service_category' => '',
- 'verb' => 'CreateIncidentTicket',
- 'expected result' => false,
- 'explain result' => 'wrong password',
- 'args' => array(
- 'admin', /* sLogin */
- 'xxxxx', /* sPassword */
- 'Houston not reachable', /* sDescription */
- 'Tried to join the shuttle', /* sInitialSituation */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('id', 1))), /* aCallerDesc */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('name', 'Demo'))), /* aCustomerDesc */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('name', 'Computers and peripherals'))), /* aServiceDesc */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('id', 1))), /* aServiceSubcategoryDesc */
- 'sub product of the service', /* sProduct */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('name', 'Hardware support'))), /* aWorkgroupDesc */
- array(
- ), /* aImpact */
- '1', /* sImpact */
- '1', /* sUrgency */
- ),
- ),
- array(
- 'service_category' => '',
- 'verb' => 'CreateIncidentTicket',
- 'expected result' => false,
- 'explain result' => 'wrong login',
- 'args' => array(
- 'xxxxx', /* sLogin */
- 'yyyyy', /* sPassword */
- 'Houston not reachable', /* sDescription */
- 'Tried to join the shuttle', /* sInitialSituation */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('id', 1))), /* aCallerDesc */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('name', 'Demo'))), /* aCustomerDesc */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('name', 'Computers and peripherals'))), /* aServiceDesc */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('id', 1))), /* aServiceSubcategoryDesc */
- 'sub product of the service', /* sProduct */
- new SOAPExternalKeySearch(array(new SOAPSearchCondition('name', 'Hardware support'))), /* aWorkgroupDesc */
- array(
- ), /* aImpact */
- '1', /* sImpact */
- '1', /* sUrgency */
- ),
- ),
- array(
- 'service_category' => '',
- 'verb' => 'SearchObjects',
- 'expected result' => true,
- 'explain result' => '',
- 'args' => array(
- 'admin', /* sLogin */
- 'admin', /* sPassword */
- 'SELECT Incident WHERE id > 20', /* sOQL */
- ),
- ),
- array(
- 'service_category' => '',
- 'verb' => 'SearchObjects',
- 'expected result' => false,
- 'explain result' => 'wrong OQL',
- 'args' => array(
- 'admin', /* sLogin */
- 'admin', /* sPassword */
- 'SELECT ThisClassDoesNotExist', /* sOQL */
- ),
- ),
- );
- $aManageCloudUsersSpecs = array(
- array(
- 'service_category' => '',
- 'verb' => 'SearchObjects',
- 'expected result' => false,
- 'explain result' => 'wrong OQL',
- 'args' => array(
- 'admin', /* sLogin */
- 'admin', /* sPassword */
- 'SELECT ThisClassDoesNotExist', /* sOQL */
- ),
- ),
- array(
- 'service_category' => '',
- 'verb' => 'SearchObjects',
- 'expected result' => true,
- 'explain result' => 'ok',
- 'args' => array(
- 'admin', /* sLogin */
- 'admin', /* sPassword */
- 'SELECT Organization', /* sOQL */
- ),
- ),
- array(
- 'service_category' => 'CloudUsersManagementService',
- 'verb' => 'CreateAccount',
- 'expected result' => true,
- 'explain result' => 'ok',
- 'args' => array(
- 'admin', /* sAdminLogin */
- 'admin', /* sAdminPassword */
- 'http://myserver.mydomain.fr:8080', /* sCloudMgrUrl */
- 'andros@combodo.com', /* sLogin */
- 'André', /* sFirstName */
- 'Dupont', /* sLastName */
- 1, /* iOrgId */
- 'FR FR', /* sLanguage */
- array(
- array(
- new SOAPKeyValue('profile_id', '2'),
- new SOAPKeyValue('reason', 'whynot'),
- ),
- array(
- new SOAPKeyValue('profile_id', '3'),
- new SOAPKeyValue('reason', 'because'),
- ),
- ), /* aProfiles (array of key/value pairs) */
- array(
- ), /* aAllowedOrgs (array of key/value pairs) */
- 'comment on the creation operation', /* sComment */
- ),
- ),
- array(
- 'service_category' => 'CloudUsersManagementService',
- 'verb' => 'ModifyAccount',
- 'expected result' => true,
- 'explain result' => 'ok',
- 'args' => array(
- 'admin', /* sAdminLogin */
- 'admin', /* sAdminPassword */
- 'andros@combodo.com', /* sLogin */
- 'nono', /* sFirstName */
- 'robot', /* sLastName */
- 2, /* iOrgId */
- 'EN US', /* sLanguage */
- array(
- array(
- new SOAPKeyValue('profile_id', '3'),
- new SOAPKeyValue('reason', 'because'),
- ),
- ), /* aProfiles (array of key/value pairs) */
- array(
- ), /* aAllowedOrgs (array of key/value pairs) */
- 'comment on the modify operation', /* sComment */
- ),
- ),
- array(
- 'service_category' => 'CloudUsersManagementService',
- 'verb' => 'DeleteAccount',
- 'expected result' => true,
- 'explain result' => '',
- 'args' => array(
- 'admin', /* sAdminLogin */
- 'admin', /* sAdminPassword */
- 'andros@combodo.com', /* sLogin */
- 'comment on the deletion operation', /* sComment */
- ),
- ),
- array(
- 'service_category' => 'CloudUsersManagementService',
- 'verb' => 'DeleteAccount',
- 'expected result' => false,
- 'explain result' => 'wrong login',
- 'args' => array(
- 'admin', /* sAdminLogin */
- 'admin', /* sAdminPassword */
- 'taratatata@sdf.com', /* sLogin */
- 'comment on the deletion operation', /* sComment */
- ),
- ),
- );
- abstract class TestSoap extends TestSoapWebService
- {
- static public function GetName() {return 'Test SOAP';}
- static public function GetDescription() {return 'Do basic stuff to test the SOAP capability';}
- protected $m_aTestSpecs;
- protected function DoExecute()
- {
- echo "<p>Note: You may also want to try the sample SOAP client <a href=\"../webservices/itopsoap.examples.php\">itopsoap.examples.php</a></p>\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 "<h2>SOAP call #$iPos - {$aWebService['verb']}</h2>\n";
- echo "<p>Using WSDL: $sWsdlUriForService</p>\n";
- echo "<p>{$aWebService['explain result']}</p>\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 "<pre>\n";
- print "Request: \n".htmlspecialchars($this->m_SoapClient->__getLastRequest()) ."\n";
- print "Response: \n".htmlspecialchars($this->m_SoapClient->__getLastResponse())."\n";
- print "</pre>";
- print "Response in HTML: <p>".$this->m_SoapClient->__getLastResponse()."</p>";
- throw $e;
- }
- self::DumpVariable($oRes);
-
- print "<pre>\n";
- print "Request: \n".htmlspecialchars($this->m_SoapClient->__getLastRequest()) ."\n";
- print "Response: \n".htmlspecialchars($this->m_SoapClient->__getLastResponse())."\n";
- print "</pre>";
- if ($oRes instanceof SOAPResult)
- {
- $res = $oRes->status;
- }
- elseif ($oRes instanceof SOAPSimpleResult)
- {
- $res = $oRes->status;
- }
- else
- {
- $res = $oRes;
- }
- if ($res != $aWebService['expected result'])
- {
- echo "Expecting:<br/>\n";
- var_dump($aWebService['expected result']);
- echo "Obtained:<br/>\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 "<h2>SOAP call #$iPos - {$aWebService['verb']}</h2>\n";
- echo "<p>{$aWebService['explain result']}</p>\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:<br/>\n";
- var_dump($aWebService['expected result']);
- echo "Obtained:<br/>\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", "<html><body><p>Dear customer,</p><p>We have created the server \$this->hyperlink()$ in the IT infrastructure database.</p><p>You will be further notified when it is in <strong>Production</strong>.</p><p>The IT infrastructure management team.</p><p>Here are some accentuated characters for french people: 'ééà'</p></body></html>");
- $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 "<p>Write... then read property <b>$sName</b>, found: '$sValue'</p>\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 "<p>Created: {$oMyObj->GetHyperLink()}</p>";
- $sTicketRef = "I-abcdef";
- echo "<p>Creating: $sTicketRef</p>";
- $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 "<p>Created: {$oMyObj->GetHyperLink()}</p>";
- }
- }
- 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 "<p>Created: {$oUser->GetHyperLink()}</p>";
- }
- }
- 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<br/>\n";
- break;
- case EMAIL_SEND_PENDING:
- echo "EMAIL_SEND_PENDING<br/>\n";
- break;
- case EMAIL_SEND_ERROR:
- echo "EMAIL_SEND_ERROR: <br/>\n";
- foreach($aIssues as $sIssue)
- {
- echo "Issue: $sIssue<br/>\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 "<h4>".$aScenario['description']."</h4>\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: <pre>".$sRes."</pre>\n";
-
- $sExpectedRes = var_export($aScenario['expected-res'], true);
- if ($sRes != $sExpectedRes)
- {
- $bFoundIssue = true;
- echo "NOT COMPLIANT!!! Expecting: <pre>".$sExpectedRes."</pre>\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()."<br/>\n";
- if ($aScenario['history_added'] != $oAdded->Count())
- {
- $bFoundIssue = true;
- echo "NOT COMPLIANT!!! Expecting: ".$aScenario['history_added']."<br/>\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()."<br/>\n";
- if ($aScenario['history_removed'] != $oRemoved->Count())
- {
- $bFoundIssue = true;
- echo "NOT COMPLIANT!!! Expecting: ".$aScenario['history_removed']."<br/>\n";
- }
-
- $oModified = new DBObjectSet(DBSearch::FromOQL("SELECT CMDBChangeOpSetAttributeLinksTune WHERE objclass = :objclass AND objkey = :objkey AND change = :change"), array(), $aQueryParams);
- echo "modified: ".$oModified->Count()."<br/>\n";
- if ($aScenario['history_modified'] != $oModified->Count())
- {
- $bFoundIssue = true;
- echo "NOT COMPLIANT!!! Expecting: ".$aScenario['history_modified']."<br/>\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 "<h4>".$aScenario['description']."</h4>\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: <pre>".$sRes."</pre>\n";
-
- $sExpectedRes = var_export($aScenario['expected-res'], true);
- if ($sRes != $sExpectedRes)
- {
- $bFoundIssue = true;
- echo "NOT COMPLIANT!!! Expecting: <pre>".$sExpectedRes."</pre>\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()."<br/>\n";
- if ($aScenario['history_added'] != $oAdded->Count())
- {
- $bFoundIssue = true;
- echo "NOT COMPLIANT!!! Expecting: ".$aScenario['history_added']."<br/>\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()."<br/>\n";
- if ($aScenario['history_removed'] != $oRemoved->Count())
- {
- $bFoundIssue = true;
- echo "NOT COMPLIANT!!! Expecting: ".$aScenario['history_removed']."<br/>\n";
- }
-
- $oModified = new DBObjectSet(DBSearch::FromOQL("SELECT CMDBChangeOpSetAttributeLinksTune WHERE objclass = :objclass AND objkey = :objkey AND change = :change"), array(), $aQueryParams);
- echo "modified: ".$oModified->Count()."<br/>\n";
- if ($aScenario['history_modified'] != $oModified->Count())
- {
- $bFoundIssue = true;
- echo "NOT COMPLIANT!!! Expecting: ".$aScenario['history_modified']."<br/>\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 "<h4>".$aScenario['description']."</h4>\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: <pre>".$sRes."</pre>\n";
- $sExpectedRes = var_export($aScenario['expected-res'], true);
- if ($sRes != $sExpectedRes)
- {
- $bFoundIssue = true;
- echo "NOT COMPLIANT!!! Expecting: <pre>".$sExpectedRes."</pre>\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()."<br/>\n";
- if ($aScenario['history_added'] != $oAdded->Count())
- {
- $bFoundIssue = true;
- echo "NOT COMPLIANT!!! Expecting: ".$aScenario['history_added']."<br/>\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()."<br/>\n";
- if ($aScenario['history_removed'] != $oRemoved->Count())
- {
- $bFoundIssue = true;
- echo "NOT COMPLIANT!!! Expecting: ".$aScenario['history_removed']."<br/>\n";
- }
- $oModified = new DBObjectSet(DBSearch::FromOQL("SELECT CMDBChangeOpSetAttributeLinksTune WHERE objclass = :objclass AND objkey = :objkey AND change = :change"), array(), $aQueryParams);
- echo "modified: ".$oModified->Count()."<br/>\n";
- if ($aScenario['history_modified'] != $oModified->Count())
- {
- $bFoundIssue = true;
- echo "NOT COMPLIANT!!! Expecting: ".$aScenario['history_modified']."<br/>\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 "<h4>".$aScenario['description']."</h4>\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: <pre>".$sRes."</pre>\n";
- $sExpectedRes = var_export($aScenario['expected-res'], true);
- if ($sRes != $sExpectedRes)
- {
- $bFoundIssue = true;
- echo "NOT COMPLIANT!!! Expecting: <pre>".$sExpectedRes."</pre>\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()."<br/>\n";
- if ($aScenario['history_added'] != $oAdded->Count())
- {
- $bFoundIssue = true;
- echo "NOT COMPLIANT!!! Expecting: ".$aScenario['history_added']."<br/>\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()."<br/>\n";
- if ($aScenario['history_removed'] != $oRemoved->Count())
- {
- $bFoundIssue = true;
- echo "NOT COMPLIANT!!! Expecting: ".$aScenario['history_removed']."<br/>\n";
- }
- $oModified = new DBObjectSet(DBSearch::FromOQL("SELECT CMDBChangeOpSetAttributeLinksTune WHERE objclass = :objclass AND objkey = :objkey AND change = :change"), array(), $aQueryParams);
- echo "modified: ".$oModified->Count()."<br/>\n";
- if ($aScenario['history_modified'] != $oModified->Count())
- {
- $bFoundIssue = true;
- echo "NOT COMPLIANT!!! Expecting: ".$aScenario['history_modified']."<br/>\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' : '<b>KO</b>')." - Validation: ".($bValidateOk ? 'Ok' : '<b>KO</b>'));
- }
- echo "</p>\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 ? '<b>KO</n>' : '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 "<h4>".htmlentities($aScenario['action'], ENT_QUOTES, 'UTF-8')."</h4>\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 "<h4>Base query: ".htmlentities($sBaseQuery, ENT_QUOTES, 'UTF-8')."</h4>\n";
- foreach ($aQueries as $sOQL)
- {
- echo "<h5>Checking: ".htmlentities($sOQL, ENT_QUOTES, 'UTF-8')."</h5>\n";
- $oSearchA = DBSearch::FromOQL($sBaseQuery);
- $oSearchB = DBSearch::FromOQL($sOQL);
- $oIntersect = $oSearchA->Intersect($oSearchB);
- echo "<p>Intersect: ".htmlentities($oIntersect->ToOQL(), ENT_QUOTES, 'UTF-8')."</p>\n";
- CMDBSource::TestQuery($oIntersect->MakeSelectQuery());
- echo "<p>Successfully tested the SQL query.</p>\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 "<h4>Base query: ".htmlentities($sBaseQuery, ENT_QUOTES, 'UTF-8')."</h4>\n";
- foreach ($aQueries as $sOQL)
- {
- echo "<h5>Checking: ".htmlentities($sOQL, ENT_QUOTES, 'UTF-8')."</h5>\n";
- $oSearchA = DBSearch::FromOQL($sBaseQuery);
- $oSearchB = DBSearch::FromOQL($sOQL);
- $oIntersect = $oSearchA->Intersect($oSearchB);
- echo "<p>Intersect: ".htmlentities($oIntersect->ToOQL(), ENT_QUOTES, 'UTF-8')."</p>\n";
- CMDBSource::TestQuery($oIntersect->MakeSelectQuery());
- echo "<p>Successfully tested the SQL query.</p>\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 "<h4>Mixing....</h4>\n";
- foreach ($aQueries as $aQ)
- {
- $sBaseQuery = $aQ[0];
- $sOQL = $aQ[1];
- echo "<h5>Left: ".htmlentities($sBaseQuery, ENT_QUOTES, 'UTF-8')."</h5>\n";
- echo "<h5>Right: ".htmlentities($sOQL, ENT_QUOTES, 'UTF-8')."</h5>\n";
- $oSearchA = DBSearch::FromOQL($sBaseQuery);
- $oSearchB = DBSearch::FromOQL($sOQL);
- $oIntersect = $oSearchA->Intersect($oSearchB);
- echo "<p>Intersect: ".htmlentities($oIntersect->ToOQL(), ENT_QUOTES, 'UTF-8')."</p>\n";
- CMDBSource::TestQuery($oIntersect->MakeSelectQuery());
- echo "<p>Successfully tested the SQL query.</p>\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 "<h4>Here we are (conluding a long series of tests)</h4>\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 "<h5>A: ".htmlentities($sQueryA, ENT_QUOTES, 'UTF-8')."</h5>\n";
- echo "<h5>B: ".htmlentities($sQueryB, ENT_QUOTES, 'UTF-8')."</h5>\n";
- $oSearchA = DBSearch::FromOQL($sQueryA);
- $oSearchB = DBSearch::FromOQL($sQueryB);
- $oSearchB->AddCondition_ReferencedBy($oSearchA, 'service_id');
- echo "<p>Referenced by...: ".htmlentities($oSearchB->ToOQL(), ENT_QUOTES, 'UTF-8')."</p>\n";
- CMDBSource::TestQuery($oSearchB->MakeSelectQuery());
- echo "<p>Successfully tested the SQL query.</p>\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 "<h4>Here we are (concluding a long series of tests)</h4>\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 "<h5>A: ".htmlentities($sQueryA, ENT_QUOTES, 'UTF-8')."</h5>\n";
- echo "<h5>B: ".htmlentities($sQueryB, ENT_QUOTES, 'UTF-8')."</h5>\n";
- $oSearchA = DBSearch::FromOQL($sQueryA);
- $oSearchB = DBSearch::FromOQL($sQueryB);
- $oSearchB->AddCondition_PointingTo($oSearchA, 'org_id');
- echo "<p>Pointing to...: ".htmlentities($oSearchB->ToOQL(), ENT_QUOTES, 'UTF-8')."</p>\n";
- CMDBSource::TestQuery($oSearchB->MakeSelectQuery());
- echo "<p>Successfully tested the SQL query.</p>\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 "<h5>To Parse: ".htmlentities($sQuery, ENT_QUOTES, 'UTF-8')."</h5>\n";
- $oSearch = DBSearch::FromOQL($sQuery);
- $sQueryOpt = $oSearch->ToOQL();
- echo "<h5>Optimized: ".htmlentities($sQueryOpt, ENT_QUOTES, 'UTF-8')."</h5>\n";
- CMDBSource::TestQuery($oSearch->MakeSelectQuery());
- echo "<p>Successfully tested the SQL query.</p>\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 "<h5>To Parse: ".htmlentities($sQuery, ENT_QUOTES, 'UTF-8')."</h5>\n";
- try
- {
- $oSearch = DBSearch::FromOQL($sQuery);
- if (!$bSuccess) throw new Exception('This query should not be parsable!');
- CMDBSource::TestQuery($oSearch->MakeSelectQuery());
- echo "<p>Successfully tested the SQL query.</p>\n";
- }
- catch (OQLException $e)
- {
- if ($bSuccess) throw $e;
- echo "<p>Failed as expected.</p>\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 "<h5>To Parse: ".htmlentities($sQuery, ENT_QUOTES, 'UTF-8')."</h5>\n";
- try
- {
- $oSearch = DBSearch::FromOQL($sQuery);
- if (!$bSuccess) throw new Exception('This query should not be parsable!');
- CMDBSource::TestQuery($oSearch->MakeSelectQuery());
- echo "<p>Successfully tested the SQL query.</p>\n";
- }
- catch (OQLException $e)
- {
- if ($bSuccess) throw $e;
- echo "<p>Failed as expected.</p>\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 "<h4>Intersect NOT optimized on 'pointing to'</h4>\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 "<h5>Left: ".htmlentities($sBaseQuery, ENT_QUOTES, 'UTF-8')."</h5>\n";
- echo "<h5>Right: ".htmlentities($sOQL, ENT_QUOTES, 'UTF-8')."</h5>\n";
- $oSearchA = DBSearch::FromOQL($sBaseQuery);
- $oSearchB = DBSearch::FromOQL($sOQL);
- $oIntersect = $oSearchA->Intersect($oSearchB);
- echo "<p>Intersect: ".htmlentities($oIntersect->ToOQL(), ENT_QUOTES, 'UTF-8')."</p>\n";
- CMDBSource::TestQuery($oIntersect->MakeSelectQuery());
- echo "<p>Successfully tested the SQL query.</p>\n";
- echo "<h4>Intersect NOT optimized on 'referenced by'</h4>\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 "<h5>Left: ".htmlentities($sBaseQuery, ENT_QUOTES, 'UTF-8')."</h5>\n";
- echo "<h5>Right: ".htmlentities($sOQL, ENT_QUOTES, 'UTF-8')."</h5>\n";
- $oSearchA = DBSearch::FromOQL($sBaseQuery);
- $oSearchB = DBSearch::FromOQL($sOQL);
- $oIntersect = $oSearchA->Intersect($oSearchB);
- echo "<p>Intersect: ".htmlentities($oIntersect->ToOQL(), ENT_QUOTES, 'UTF-8')."</p>\n";
- CMDBSource::TestQuery($oIntersect->MakeSelectQuery());
- echo "<p>Successfully tested the SQL query.</p>\n";
- echo "<h4>NOT Folding on AddCondition_PointingTo</h4>\n";
- $sQueryA = 'SELECT Organization AS o JOIN Contact AS c ON c.org_id = o.id';
- $sQueryB = 'SELECT Person';
- echo "<h5>A: ".htmlentities($sQueryA, ENT_QUOTES, 'UTF-8')."</h5>\n";
- echo "<h5>B: ".htmlentities($sQueryB, ENT_QUOTES, 'UTF-8')."</h5>\n";
- $oSearchA = DBSearch::FromOQL($sQueryA);
- $oSearchB = DBSearch::FromOQL($sQueryB);
- $oSearchB->AddCondition_PointingTo($oSearchA, 'org_id');
- echo "<p>Pointing to...: ".htmlentities($oSearchB->ToOQL(), ENT_QUOTES, 'UTF-8')."</p>\n";
- CMDBSource::TestQuery($oSearchB->MakeSelectQuery());
- echo "<p>Successfully tested the SQL query.</p>\n";
- echo "<h4>NOT Folding on AddCondition_ReferencedBy</h4>\n";
- $sQueryA = 'SELECT lnkContactToFunctionalCI AS l JOIN Contact AS c ON l.contact_id = c.id';
- $sQueryB = 'SELECT Person';
- echo "<h5>A: ".htmlentities($sQueryA, ENT_QUOTES, 'UTF-8')."</h5>\n";
- echo "<h5>B: ".htmlentities($sQueryB, ENT_QUOTES, 'UTF-8')."</h5>\n";
- $oSearchA = DBSearch::FromOQL($sQueryA);
- $oSearchB = DBSearch::FromOQL($sQueryB);
- $oSearchB->AddCondition_ReferencedBy($oSearchA, 'contact_id');
- echo "<p>Referenced by...: ".htmlentities($oSearchA->ToOQL(), ENT_QUOTES, 'UTF-8')."</p>\n";
- CMDBSource::TestQuery($oSearchA->MakeSelectQuery());
- echo "<p>Successfully tested the SQL query.</p>\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 <b>".$oObject->GetName()."</b><br>\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 "<h5>Graphe initial</h5>";
- echo $oGraph->DumpAsHtmlImage();
- echo $oGraph->DumpAsHTMLText();
- echo "<h5>Removing C</h5>";
- $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 "<h5>Removing B</h5>";
- $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 "<h5>TOP $iLimit offenders (+ those exceeding $iCountThreshold tables)</h5>";
- foreach ($aClassToCount_Full as $sClass => $iCountFull)
- {
- $i++;
- if (($iCountFull <= $iCountThreshold) && ($i >= $iLimit)) break;
- echo "$sClass: $iCountFull tables<br/>";
- }
- echo "<h5>Distribution of table counts</h5>";
- echo "<p>Over a total of $iTotalClasses instantiable classes.</p>";
- echo "<table>";
- echo "<tr><td>Table count</td><td>Classes</td></tr>";
- foreach ($aDistribution as $iTableCount => $iClassCount)
- {
- echo "<tr><td>$iTableCount</td><td>$iClassCount</td></tr>";
- }
- echo "</table>";
- }
- }
- 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 '<p>'.$sOql.'</p>';
- echo '<p>This query rendered with all columns give a MySQL query having <b>'.$oSql->CountTables().'</b> tables... let\'s try it with the DBObjectSet API:</p>';
- $oSet = new DBObjectSet($oSearch);
- $oObj = $oSet->Fetch();
- echo '<p>Well done, this is working fine! Some magic happened in the background!</p>';
- }
- }
- 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');
- }
- }
|