| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788278927902791279227932794279527962797279827992800280128022803280428052806280728082809281028112812281328142815281628172818281928202821282228232824282528262827282828292830283128322833283428352836283728382839284028412842284328442845284628472848284928502851285228532854285528562857285828592860286128622863286428652866286728682869287028712872287328742875287628772878287928802881288228832884288528862887288828892890289128922893289428952896289728982899290029012902290329042905290629072908290929102911291229132914291529162917291829192920292129222923292429252926292729282929293029312932293329342935293629372938293929402941294229432944294529462947294829492950295129522953295429552956295729582959296029612962296329642965296629672968296929702971297229732974297529762977297829792980298129822983298429852986298729882989299029912992299329942995299629972998299930003001300230033004300530063007300830093010301130123013301430153016301730183019302030213022302330243025302630273028302930303031303230333034303530363037303830393040304130423043304430453046304730483049305030513052305330543055305630573058305930603061306230633064306530663067306830693070307130723073307430753076307730783079308030813082308330843085308630873088308930903091309230933094309530963097309830993100310131023103310431053106310731083109311031113112311331143115311631173118311931203121312231233124312531263127312831293130313131323133313431353136313731383139314031413142314331443145314631473148314931503151315231533154315531563157315831593160316131623163316431653166316731683169317031713172317331743175317631773178317931803181318231833184318531863187318831893190319131923193319431953196319731983199320032013202320332043205320632073208320932103211321232133214321532163217321832193220322132223223322432253226322732283229323032313232323332343235323632373238323932403241324232433244324532463247324832493250325132523253325432553256325732583259326032613262326332643265326632673268326932703271327232733274327532763277327832793280328132823283328432853286328732883289329032913292329332943295329632973298329933003301330233033304330533063307330833093310331133123313331433153316331733183319332033213322332333243325332633273328332933303331333233333334333533363337333833393340334133423343334433453346334733483349335033513352335333543355335633573358335933603361336233633364336533663367336833693370337133723373337433753376337733783379338033813382338333843385338633873388338933903391339233933394339533963397339833993400340134023403340434053406340734083409341034113412341334143415341634173418341934203421342234233424342534263427342834293430343134323433343434353436343734383439344034413442344334443445344634473448344934503451345234533454345534563457345834593460346134623463346434653466346734683469347034713472347334743475347634773478347934803481348234833484348534863487348834893490349134923493349434953496349734983499350035013502350335043505350635073508350935103511351235133514351535163517351835193520352135223523352435253526352735283529353035313532353335343535353635373538353935403541354235433544354535463547354835493550355135523553355435553556355735583559356035613562356335643565356635673568356935703571357235733574357535763577357835793580358135823583358435853586358735883589359035913592359335943595359635973598359936003601360236033604360536063607360836093610361136123613361436153616361736183619362036213622362336243625362636273628362936303631363236333634363536363637363836393640364136423643364436453646364736483649365036513652365336543655365636573658365936603661366236633664366536663667366836693670367136723673367436753676367736783679368036813682368336843685368636873688368936903691369236933694369536963697369836993700370137023703370437053706370737083709371037113712 |
- <?php
- /**
- * CakePHP(tm) : Rapid Development Framework (http://cakephp.org)
- * Copyright (c) Cake Software Foundation, Inc. (http://cakefoundation.org)
- *
- * Licensed under The MIT License
- * For full copyright and license information, please see the LICENSE.txt
- * Redistributions of files must retain the above copyright notice.
- *
- * @copyright Copyright (c) Cake Software Foundation, Inc. (http://cakefoundation.org)
- * @link http://cakephp.org CakePHP(tm) Project
- * @since 3.0.0
- * @license http://www.opensource.org/licenses/mit-license.php MIT License
- */
- namespace Cake\Test\TestCase\Database;
- use Cake\Core\Configure;
- use Cake\Database\Expression\IdentifierExpression;
- use Cake\Database\Query;
- use Cake\Database\TypeMap;
- use Cake\Datasource\ConnectionManager;
- use Cake\TestSuite\TestCase;
- /**
- * Tests Query class
- *
- */
- class QueryTest extends TestCase
- {
- public $fixtures = ['core.articles', 'core.authors', 'core.comments'];
- const ARTICLE_COUNT = 3;
- const AUTHOR_COUNT = 4;
- const COMMENT_COUNT = 6;
- public function setUp()
- {
- parent::setUp();
- $this->connection = ConnectionManager::get('test');
- $this->autoQuote = $this->connection->driver()->autoQuoting();
- }
- public function tearDown()
- {
- parent::tearDown();
- $this->connection->driver()->autoQuoting($this->autoQuote);
- unset($this->connection);
- }
- /**
- * Queries need a default type to prevent fatal errors
- * when an uninitialized query has its sql() method called.
- *
- * @return void
- */
- public function testDefaultType()
- {
- $query = new Query($this->connection);
- $this->assertEquals('', $query->sql());
- $this->assertEquals('select', $query->type());
- }
- /**
- * Tests that it is possible to obtain expression results from a query
- *
- * @return void
- */
- public function testSelectFieldsOnly()
- {
- $this->connection->driver()->autoQuoting(false);
- $query = new Query($this->connection);
- $result = $query->select('1 + 1')->execute();
- $this->assertInstanceOf('Cake\Database\StatementInterface', $result);
- $this->assertEquals([2], $result->fetch());
- //This new field should be appended
- $result = $query->select(['1 + 3'])->execute();
- $this->assertInstanceOf('Cake\Database\StatementInterface', $result);
- $this->assertEquals([2, 4], $result->fetch());
- //This should now overwrite all previous fields
- $result = $query->select(['1 + 2', '1 + 5'], true)->execute();
- $this->assertEquals([3, 6], $result->fetch());
- }
- /**
- * Tests that it is possible to pass a closure as fields in select()
- *
- * @return void
- */
- public function testSelectClosure()
- {
- $this->connection->driver()->autoQuoting(false);
- $query = new Query($this->connection);
- $result = $query->select(function ($q) use ($query) {
- $this->assertSame($query, $q);
- return ['1 + 2', '1 + 5'];
- })->execute();
- $this->assertEquals([3, 6], $result->fetch());
- }
- /**
- * Tests it is possible to select fields from tables with no conditions
- *
- * @return void
- */
- public function testSelectFieldsFromTable()
- {
- $query = new Query($this->connection);
- $result = $query->select(['body', 'author_id'])->from('articles')->execute();
- $this->assertEquals(['body' => 'First Article Body', 'author_id' => 1], $result->fetch('assoc'));
- $this->assertEquals(['body' => 'Second Article Body', 'author_id' => 3], $result->fetch('assoc'));
- //Append more tables to next execution
- $result = $query->select('name')->from(['authors'])->order(['name' => 'desc', 'articles.id' => 'asc'])->execute();
- $this->assertEquals(['body' => 'First Article Body', 'author_id' => 1, 'name' => 'nate'], $result->fetch('assoc'));
- $this->assertEquals(['body' => 'Second Article Body', 'author_id' => 3, 'name' => 'nate'], $result->fetch('assoc'));
- $this->assertEquals(['body' => 'Third Article Body', 'author_id' => 1, 'name' => 'nate'], $result->fetch('assoc'));
- // Overwrite tables and only fetch from authors
- $result = $query->select('name', true)->from('authors', true)->order(['name' => 'desc'], true)->execute();
- $this->assertEquals(['nate'], $result->fetch());
- $this->assertEquals(['mariano'], $result->fetch());
- $this->assertCount(4, $result);
- }
- /**
- * Tests it is possible to select aliased fields
- *
- * @return void
- */
- public function testSelectAliasedFieldsFromTable()
- {
- $query = new Query($this->connection);
- $result = $query->select(['text' => 'comment', 'article_id'])->from('comments')->execute();
- $this->assertEquals(['text' => 'First Comment for First Article', 'article_id' => 1], $result->fetch('assoc'));
- $this->assertEquals(['text' => 'Second Comment for First Article', 'article_id' => 1], $result->fetch('assoc'));
- $query = new Query($this->connection);
- $result = $query->select(['text' => 'comment', 'article' => 'article_id'])->from('comments')->execute();
- $this->assertEquals(['text' => 'First Comment for First Article', 'article' => 1], $result->fetch('assoc'));
- $this->assertEquals(['text' => 'Second Comment for First Article', 'article' => 1], $result->fetch('assoc'));
- $query = new Query($this->connection);
- $query->select(['text' => 'comment'])->select(['article_id', 'foo' => 'comment']);
- $result = $query->from('comments')->execute();
- $this->assertEquals(
- ['foo' => 'First Comment for First Article', 'text' => 'First Comment for First Article', 'article_id' => 1],
- $result->fetch('assoc')
- );
- $query = new Query($this->connection);
- $exp = $query->newExpr('1 + 1');
- $comp = $query->newExpr(['article_id +' => 2]);
- $result = $query->select(['text' => 'comment', 'two' => $exp, 'three' => $comp])
- ->from('comments')->execute();
- $this->assertEquals(['text' => 'First Comment for First Article', 'two' => 2, 'three' => 3], $result->fetch('assoc'));
- }
- /**
- * Tests that tables can also be aliased and referenced in the select clause using such alias
- *
- * @return void
- */
- public function testSelectAliasedTables()
- {
- $query = new Query($this->connection);
- $result = $query->select(['text' => 'a.body', 'a.author_id'])
- ->from(['a' => 'articles'])->execute();
- $this->assertEquals(['text' => 'First Article Body', 'author_id' => 1], $result->fetch('assoc'));
- $this->assertEquals(['text' => 'Second Article Body', 'author_id' => 3], $result->fetch('assoc'));
- $result = $query->select(['name' => 'b.name'])->from(['b' => 'authors'])
- ->order(['text' => 'desc', 'name' => 'desc'])
- ->execute();
- $this->assertEquals(
- ['text' => 'Third Article Body', 'author_id' => 1, 'name' => 'nate'],
- $result->fetch('assoc')
- );
- $this->assertEquals(
- ['text' => 'Third Article Body', 'author_id' => 1, 'name' => 'mariano'],
- $result->fetch('assoc')
- );
- }
- /**
- * Tests it is possible to add joins to a select query
- *
- * @return void
- */
- public function testSelectWithJoins()
- {
- $query = new Query($this->connection);
- $result = $query
- ->select(['title', 'name'])
- ->from('articles')
- ->join(['table' => 'authors', 'alias' => 'a', 'conditions' => $query->newExpr()->equalFields('author_id', 'a.id')])
- ->order(['title' => 'asc'])
- ->execute();
- $this->assertCount(3, $result);
- $this->assertEquals(['title' => 'First Article', 'name' => 'mariano'], $result->fetch('assoc'));
- $this->assertEquals(['title' => 'Second Article', 'name' => 'larry'], $result->fetch('assoc'));
- $result = $query->join('authors', [], true)->execute();
- $this->assertCount(12, $result, 'Cross join results in 12 records');
- $result = $query->join([
- ['table' => 'authors', 'type' => 'INNER', 'conditions' => $query->newExpr()->equalFields('author_id', 'authors.id')]
- ], [], true)->execute();
- $this->assertCount(3, $result);
- $this->assertEquals(['title' => 'First Article', 'name' => 'mariano'], $result->fetch('assoc'));
- $this->assertEquals(['title' => 'Second Article', 'name' => 'larry'], $result->fetch('assoc'));
- }
- /**
- * Tests it is possible to add joins to a select query using array or expression as conditions
- *
- * @return void
- */
- public function testSelectWithJoinsConditions()
- {
- $query = new Query($this->connection);
- $result = $query
- ->select(['title', 'name'])
- ->from('articles')
- ->join(['table' => 'authors', 'alias' => 'a', 'conditions' => [$query->newExpr()->equalFields('author_id ', 'a.id')]])
- ->order(['title' => 'asc'])
- ->execute();
- $this->assertEquals(['title' => 'First Article', 'name' => 'mariano'], $result->fetch('assoc'));
- $this->assertEquals(['title' => 'Second Article', 'name' => 'larry'], $result->fetch('assoc'));
- $query = new Query($this->connection);
- $conditions = $query->newExpr()->equalFields('author_id', 'a.id');
- $result = $query
- ->select(['title', 'name'])
- ->from('articles')
- ->join(['table' => 'authors', 'alias' => 'a', 'conditions' => $conditions])
- ->order(['title' => 'asc'])
- ->execute();
- $this->assertEquals(['title' => 'First Article', 'name' => 'mariano'], $result->fetch('assoc'));
- $this->assertEquals(['title' => 'Second Article', 'name' => 'larry'], $result->fetch('assoc'));
- $query = new Query($this->connection);
- $time = new \DateTime('2007-03-18 10:50:00');
- $types = ['created' => 'datetime'];
- $result = $query
- ->select(['title', 'comment' => 'c.comment'])
- ->from('articles')
- ->join(['table' => 'comments', 'alias' => 'c', 'conditions' => ['created <=' => $time]], $types)
- ->execute();
- $this->assertEquals(['title' => 'First Article', 'comment' => 'First Comment for First Article'], $result->fetch('assoc'));
- }
- /**
- * Tests that joins can be aliased using array keys
- *
- * @return void
- */
- public function testSelectAliasedJoins()
- {
- $query = new Query($this->connection);
- $result = $query
- ->select(['title', 'name'])
- ->from('articles')
- ->join(['a' => 'authors'])
- ->order(['name' => 'desc', 'articles.id' => 'asc'])
- ->execute();
- $this->assertEquals(['title' => 'First Article', 'name' => 'nate'], $result->fetch('assoc'));
- $this->assertEquals(['title' => 'Second Article', 'name' => 'nate'], $result->fetch('assoc'));
- $query = new Query($this->connection);
- $conditions = $query->newExpr('author_id = a.id');
- $result = $query
- ->select(['title', 'name'])
- ->from('articles')
- ->join(['a' => ['table' => 'authors', 'conditions' => $conditions]])
- ->order(['title' => 'asc'])
- ->execute();
- $this->assertEquals(['title' => 'First Article', 'name' => 'mariano'], $result->fetch('assoc'));
- $this->assertEquals(['title' => 'Second Article', 'name' => 'larry'], $result->fetch('assoc'));
- $query = new Query($this->connection);
- $time = new \DateTime('2007-03-18 10:45:23');
- $types = ['created' => 'datetime'];
- $result = $query
- ->select(['title', 'name' => 'c.comment'])
- ->from('articles')
- ->join(['c' => ['table' => 'comments', 'conditions' => ['created' => $time]]], $types)
- ->execute();
- $this->assertEquals(['title' => 'First Article', 'name' => 'First Comment for First Article'], $result->fetch('assoc'));
- }
- /**
- * Tests the leftJoin method
- *
- * @return void
- */
- public function testSelectLeftJoin()
- {
- $query = new Query($this->connection);
- $time = new \DateTime('2007-03-18 10:45:23');
- $types = ['created' => 'datetime'];
- $result = $query
- ->select(['title', 'name' => 'c.comment'])
- ->from('articles')
- ->leftJoin(['c' => 'comments'], ['created <' => $time], $types)
- ->execute();
- $this->assertEquals(['title' => 'First Article', 'name' => null], $result->fetch('assoc'));
- $query = new Query($this->connection);
- $result = $query
- ->select(['title', 'name' => 'c.comment'])
- ->from('articles')
- ->leftJoin(['c' => 'comments'], ['created >' => $time], $types)
- ->execute();
- $this->assertEquals(
- ['title' => 'First Article', 'name' => 'Second Comment for First Article'],
- $result->fetch('assoc')
- );
- }
- /**
- * Tests the innerJoin method
- *
- * @return void
- */
- public function testSelectInnerJoin()
- {
- $query = new Query($this->connection);
- $time = new \DateTime('2007-03-18 10:45:23');
- $types = ['created' => 'datetime'];
- $result = $query
- ->select(['title', 'name' => 'c.comment'])
- ->from('articles')
- ->innerJoin(['c' => 'comments'], ['created <' => $time], $types)
- ->execute();
- $this->assertCount(0, $result->fetchAll());
- }
- /**
- * Tests the rightJoin method
- *
- * @return void
- */
- public function testSelectRightJoin()
- {
- $this->skipIf(
- $this->connection->driver() instanceof \Cake\Database\Driver\Sqlite,
- 'SQLite does not support RIGHT joins'
- );
- $query = new Query($this->connection);
- $time = new \DateTime('2007-03-18 10:45:23');
- $types = ['created' => 'datetime'];
- $result = $query
- ->select(['title', 'name' => 'c.comment'])
- ->from('articles')
- ->rightJoin(['c' => 'comments'], ['created <' => $time], $types)
- ->execute();
- $this->assertCount(6, $result);
- $this->assertEquals(
- ['title' => null, 'name' => 'First Comment for First Article'],
- $result->fetch('assoc')
- );
- }
- /**
- * Tests that it is possible to pass a callable as conditions for a join
- *
- * @return void
- */
- public function testSelectJoinWithCallback()
- {
- $query = new Query($this->connection);
- $types = ['created' => 'datetime'];
- $result = $query
- ->select(['title', 'name' => 'c.comment'])
- ->from('articles')
- ->innerJoin(['c' => 'comments'], function ($exp, $q) use ($query, $types) {
- $this->assertSame($q, $query);
- $exp->add(['created <' => new \DateTime('2007-03-18 10:45:23')], $types);
- return $exp;
- })
- ->execute();
- $this->assertCount(0, $result->fetchAll());
- $query = new Query($this->connection);
- $types = ['created' => 'datetime'];
- $result = $query
- ->select(['title', 'name' => 'comments.comment'])
- ->from('articles')
- ->innerJoin('comments', function ($exp, $q) use ($query, $types) {
- $this->assertSame($q, $query);
- $exp->add(['created >' => new \DateTime('2007-03-18 10:45:23')], $types);
- return $exp;
- })
- ->execute();
- $this->assertEquals(
- ['title' => 'First Article', 'name' => 'Second Comment for First Article'],
- $result->fetch('assoc')
- );
- }
- /**
- * Tests it is possible to filter a query by using simple AND joined conditions
- *
- * @return void
- */
- public function testSelectSimpleWhere()
- {
- $query = new Query($this->connection);
- $result = $query
- ->select(['title'])
- ->from('articles')
- ->where(['id' => 1, 'title' => 'First Article'])
- ->execute();
- $this->assertCount(1, $result);
- $result->closeCursor();
- $query = new Query($this->connection);
- $result = $query
- ->select(['title'])
- ->from('articles')
- ->where(['id' => 100], ['id' => 'integer'])
- ->execute();
- $this->assertCount(0, $result);
- $result->closeCursor();
- }
- /**
- * Tests using where conditions with operators and scalar values works
- *
- * @return void
- */
- public function testSelectWhereOperators()
- {
- $query = new Query($this->connection);
- $result = $query
- ->select(['comment'])
- ->from('comments')
- ->where(['id >' => 4])
- ->execute();
- $this->assertCount(2, $result);
- $this->assertEquals(['comment' => 'First Comment for Second Article'], $result->fetch('assoc'));
- $result->closeCursor();
- $query = new Query($this->connection);
- $result = $query
- ->select(['title'])
- ->from('articles')
- ->where(['id <' => 2])
- ->execute();
- $this->assertCount(1, $result);
- $this->assertEquals(['title' => 'First Article'], $result->fetch('assoc'));
- $result->closeCursor();
- $query = new Query($this->connection);
- $result = $query
- ->select(['title'])
- ->from('articles')
- ->where(['id <=' => 2])
- ->execute();
- $this->assertCount(2, $result);
- $result->closeCursor();
- $query = new Query($this->connection);
- $result = $query
- ->select(['title'])
- ->from('articles')
- ->where(['id >=' => 1])
- ->execute();
- $this->assertCount(3, $result);
- $result->closeCursor();
- $query = new Query($this->connection);
- $result = $query
- ->select(['title'])
- ->from('articles')
- ->where(['id <=' => 1])
- ->execute();
- $this->assertCount(1, $result);
- $result->closeCursor();
- $query = new Query($this->connection);
- $result = $query
- ->select(['title'])
- ->from('articles')
- ->where(['id !=' => 2])
- ->execute();
- $this->assertCount(2, $result);
- $this->assertEquals(['title' => 'First Article'], $result->fetch('assoc'));
- $result->closeCursor();
- $query = new Query($this->connection);
- $result = $query
- ->select(['title'])
- ->from('articles')
- ->where(['title LIKE' => 'First Article'])
- ->execute();
- $this->assertCount(1, $result);
- $this->assertEquals(['title' => 'First Article'], $result->fetch('assoc'));
- $result->closeCursor();
- $query = new Query($this->connection);
- $result = $query
- ->select(['title'])
- ->from('articles')
- ->where(['title like' => '%Article%'])
- ->execute();
- $this->assertCount(3, $result);
- $result->closeCursor();
- $query = new Query($this->connection);
- $result = $query
- ->select(['title'])
- ->from('articles')
- ->where(['title not like' => '%Article%'])
- ->execute();
- $this->assertCount(0, $result);
- $result->closeCursor();
- }
- /**
- * Test that unary expressions in selects are built correctly.
- *
- * @return void
- */
- public function testSelectWhereUnary()
- {
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('articles')
- ->where([
- 'title is not' => null,
- 'user_id is' => null
- ])
- ->sql();
- $this->assertQuotedQuery(
- 'SELECT <id> FROM <articles> WHERE \(\(<title>\) IS NOT NULL AND \(<user_id>\) IS NULL\)',
- $result,
- !$this->autoQuote
- );
- }
- /**
- * Tests selecting with conditions and specifying types for those
- *
- * @return void
- */
- public function testSelectWhereTypes()
- {
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(['created' => new \DateTime('2007-03-18 10:45:23')], ['created' => 'datetime'])
- ->execute();
- $this->assertCount(1, $result);
- $this->assertEquals(['id' => 1], $result->fetch('assoc'));
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(['created >' => new \DateTime('2007-03-18 10:46:00')], ['created' => 'datetime'])
- ->execute();
- $this->assertCount(5, $result);
- $this->assertEquals(['id' => 2], $result->fetch('assoc'));
- $this->assertEquals(['id' => 3], $result->fetch('assoc'));
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(
- [
- 'created >' => new \DateTime('2007-03-18 10:40:00'),
- 'created <' => new \DateTime('2007-03-18 10:46:00')
- ],
- ['created' => 'datetime']
- )
- ->execute();
- $this->assertCount(1, $result);
- $this->assertEquals(['id' => 1], $result->fetch('assoc'));
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(
- [
- 'id' => '3something-crazy',
- 'created <' => new \DateTime('2013-01-01 12:00')
- ],
- ['created' => 'datetime', 'id' => 'integer']
- )
- ->execute();
- $this->assertCount(1, $result);
- $this->assertEquals(['id' => 3], $result->fetch('assoc'));
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(
- [
- 'id' => '1something-crazy',
- 'created <' => new \DateTime('2013-01-01 12:00')
- ],
- ['created' => 'datetime', 'id' => 'float']
- )
- ->execute();
- $this->assertCount(1, $result);
- $this->assertEquals(['id' => 1], $result->fetch('assoc'));
- }
- /**
- * Tests that passing an array type to any where condition will replace
- * the passed array accordingly as a proper IN condition
- *
- * @return void
- */
- public function testSelectWhereArrayType()
- {
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(['id' => ['1', '3']], ['id' => 'integer[]'])
- ->execute();
- $this->assertCount(2, $result);
- $this->assertEquals(['id' => 1], $result->fetch('assoc'));
- $this->assertEquals(['id' => 3], $result->fetch('assoc'));
- }
- /**
- * Tests that passing an empty array type to any where condition will not
- * result in a SQL error, but an internal exception
- *
- * @expectedException Cake\Database\Exception
- * @expectedExceptionMessage Impossible to generate condition with empty list of values for field
- * @return void
- */
- public function testSelectWhereArrayTypeEmpty()
- {
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(['id' => []], ['id' => 'integer[]'])
- ->execute();
- }
- /**
- * Tests exception message for impossible condition when using an expression
- * @expectedException Cake\Database\Exception
- * @expectedExceptionMessage with empty list of values for field (SELECT 1)
- * @return void
- */
- public function testSelectWhereArrayTypeEmptyWithExpression()
- {
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(function ($exp, $q) {
- return $exp->in($q->newExpr('SELECT 1'), []);
- })
- ->execute();
- }
- /**
- * Tests that Query::orWhere() can be used to concatenate conditions with OR
- *
- * @return void
- */
- public function testSelectOrWhere()
- {
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(['created' => new \DateTime('2007-03-18 10:45:23')], ['created' => 'datetime'])
- ->orWhere(['created' => new \DateTime('2007-03-18 10:47:23')], ['created' => 'datetime'])
- ->execute();
- $this->assertCount(2, $result);
- $this->assertEquals(['id' => 1], $result->fetch('assoc'));
- $this->assertEquals(['id' => 2], $result->fetch('assoc'));
- }
- /**
- * Tests that Query::andWhere() can be used to concatenate conditions with AND
- *
- * @return void
- */
- public function testSelectAndWhere()
- {
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(['created' => new \DateTime('2007-03-18 10:45:23')], ['created' => 'datetime'])
- ->andWhere(['id' => 1])
- ->execute();
- $this->assertCount(1, $result);
- $this->assertEquals(['id' => 1], $result->fetch('assoc'));
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(['created' => new \DateTime('2007-03-18 10:50:55')], ['created' => 'datetime'])
- ->andWhere(['id' => 2])
- ->execute();
- $this->assertCount(0, $result);
- }
- /**
- * Tests that combining Query::andWhere() and Query::orWhere() produces
- * correct conditions nesting
- *
- * @return void
- */
- public function testSelectExpressionNesting()
- {
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(['created' => new \DateTime('2007-03-18 10:45:23')], ['created' => 'datetime'])
- ->orWhere(['id' => 2])
- ->andWhere(['created >=' => new \DateTime('2007-03-18 10:40:00')], ['created' => 'datetime'])
- ->execute();
- $this->assertCount(2, $result);
- $this->assertEquals(['id' => 1], $result->fetch('assoc'));
- $this->assertEquals(['id' => 2], $result->fetch('assoc'));
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(['created' => new \DateTime('2007-03-18 10:45:23')], ['created' => 'datetime'])
- ->orWhere(['id' => 2])
- ->andWhere(['created >=' => new \DateTime('2007-03-18 10:40:00')], ['created' => 'datetime'])
- ->orWhere(['created' => new \DateTime('2007-03-18 10:49:23')], ['created' => 'datetime'])
- ->execute();
- $this->assertCount(3, $result);
- $this->assertEquals(['id' => 1], $result->fetch('assoc'));
- $this->assertEquals(['id' => 2], $result->fetch('assoc'));
- $this->assertEquals(['id' => 3], $result->fetch('assoc'));
- }
- /**
- * Tests that Query::orWhere() can be used without calling where() before
- *
- * @return void
- */
- public function testSelectOrWhereNoPreviousCondition()
- {
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->orWhere(['created' => new \DateTime('2007-03-18 10:45:23')], ['created' => 'datetime'])
- ->orWhere(['created' => new \DateTime('2007-03-18 10:47:23')], ['created' => 'datetime'])
- ->execute();
- $this->assertCount(2, $result);
- $this->assertEquals(['id' => 1], $result->fetch('assoc'));
- $this->assertEquals(['id' => 2], $result->fetch('assoc'));
- }
- /**
- * Tests that Query::andWhere() can be used without calling where() before
- *
- * @return void
- */
- public function testSelectAndWhereNoPreviousCondition()
- {
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->andWhere(['created' => new \DateTime('2007-03-18 10:45:23')], ['created' => 'datetime'])
- ->andWhere(['id' => 1])
- ->execute();
- $this->assertCount(1, $result);
- $this->assertEquals(['id' => 1], $result->fetch('assoc'));
- }
- /**
- * Tests that it is possible to pass a closure to where() to build a set of
- * conditions and return the expression to be used
- *
- * @return void
- */
- public function testSelectWhereUsingClosure()
- {
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(function ($exp) {
- return $exp->eq('id', 1);
- })
- ->execute();
- $this->assertCount(1, $result);
- $this->assertEquals(['id' => 1], $result->fetch('assoc'));
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(function ($exp) {
- return $exp
- ->eq('id', 1)
- ->eq('created', new \DateTime('2007-03-18 10:45:23'), 'datetime');
- })
- ->execute();
- $this->assertCount(1, $result);
- $this->assertEquals(['id' => 1], $result->fetch('assoc'));
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(function ($exp) {
- return $exp
- ->eq('id', 1)
- ->eq('created', new \DateTime('2021-12-30 15:00'), 'datetime');
- })
- ->execute();
- $this->assertCount(0, $result);
- }
- /**
- * Tests generating tuples in the values side containing closure expressions
- *
- * @return void
- */
- public function testTupleWithClosureExpression()
- {
- $query = new Query($this->connection);
- $query->select(['id'])
- ->from('comments')
- ->where([
- 'OR' => [
- 'id' => 1,
- function ($exp) {
- return $exp->eq('id', 2);
- }
- ]
- ]);
- $result = $query->sql();
- $this->assertQuotedQuery(
- 'SELECT <id> FROM <comments> WHERE \(<id> = :c0 OR <id> = :c1\)',
- $result,
- !$this->autoQuote
- );
- }
- /**
- * Tests that it is possible to pass a closure to andWhere() to build a set of
- * conditions and return the expression to be used
- *
- * @return void
- */
- public function testSelectAndWhereUsingClosure()
- {
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(['id' => '1'])
- ->andWhere(function ($exp) {
- return $exp->eq('created', new \DateTime('2007-03-18 10:45:23'), 'datetime');
- })
- ->execute();
- $this->assertCount(1, $result);
- $this->assertEquals(['id' => 1], $result->fetch('assoc'));
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(['id' => '1'])
- ->andWhere(function ($exp) {
- return $exp->eq('created', new \DateTime('2022-12-21 12:00'), 'datetime');
- })
- ->execute();
- $this->assertCount(0, $result);
- }
- /**
- * Tests that it is possible to pass a closure to orWhere() to build a set of
- * conditions and return the expression to be used
- *
- * @return void
- */
- public function testSelectOrWhereUsingClosure()
- {
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(['id' => '1'])
- ->orWhere(function ($exp) {
- return $exp->eq('created', new \DateTime('2007-03-18 10:47:23'), 'datetime');
- })
- ->execute();
- $this->assertCount(2, $result);
- $this->assertEquals(['id' => 1], $result->fetch('assoc'));
- $this->assertEquals(['id' => 2], $result->fetch('assoc'));
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(['id' => '1'])
- ->orWhere(function ($exp) {
- return $exp
- ->eq('created', new \DateTime('2012-12-22 12:00'), 'datetime')
- ->eq('id', 3);
- })
- ->execute();
- $this->assertCount(1, $result);
- $this->assertEquals(['id' => 1], $result->fetch('assoc'));
- }
- /**
- * Tests that expression objects can be used as the field in a comparison
- * and the values will be bound correctly to the query
- *
- * @return void
- */
- public function testSelectWhereUsingExpressionInField()
- {
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(function ($exp) {
- $field = clone $exp;
- $field->add('SELECT min(id) FROM comments');
- return $exp
- ->eq($field, 100, 'integer');
- })
- ->execute();
- $this->assertCount(0, $result);
- }
- /**
- * Tests using where conditions with operator methods
- *
- * @return void
- */
- public function testSelectWhereOperatorMethods()
- {
- $query = new Query($this->connection);
- $result = $query
- ->select(['title'])
- ->from('articles')
- ->where(function ($exp) {
- return $exp->gt('id', 1);
- })
- ->execute();
- $this->assertCount(2, $result);
- $this->assertEquals(['title' => 'Second Article'], $result->fetch('assoc'));
- $query = new Query($this->connection);
- $result = $query->select(['title'])
- ->from('articles')
- ->where(function ($exp) {
- return $exp->lt('id', 2);
- })
- ->execute();
- $this->assertCount(1, $result);
- $this->assertEquals(['title' => 'First Article'], $result->fetch('assoc'));
- $query = new Query($this->connection);
- $result = $query->select(['title'])
- ->from('articles')
- ->where(function ($exp) {
- return $exp->lte('id', 2);
- })
- ->execute();
- $this->assertCount(2, $result);
- $query = new Query($this->connection);
- $result = $query
- ->select(['title'])
- ->from('articles')
- ->where(function ($exp) {
- return $exp->gte('id', 1);
- })
- ->execute();
- $this->assertCount(3, $result);
- $query = new Query($this->connection);
- $result = $query
- ->select(['title'])
- ->from('articles')
- ->where(function ($exp) {
- return $exp->lte('id', 1);
- })
- ->execute();
- $this->assertCount(1, $result);
- $query = new Query($this->connection);
- $result = $query
- ->select(['title'])
- ->from('articles')
- ->where(function ($exp) {
- return $exp->notEq('id', 2);
- })
- ->execute();
- $this->assertCount(2, $result);
- $this->assertEquals(['title' => 'First Article'], $result->fetch('assoc'));
- $query = new Query($this->connection);
- $result = $query
- ->select(['title'])
- ->from('articles')
- ->where(function ($exp) {
- return $exp->like('title', 'First Article');
- })
- ->execute();
- $this->assertCount(1, $result);
- $this->assertEquals(['title' => 'First Article'], $result->fetch('assoc'));
- $query = new Query($this->connection);
- $result = $query
- ->select(['title'])
- ->from('articles')
- ->where(function ($exp) {
- return $exp->like('title', '%Article%');
- })
- ->execute();
- $this->assertCount(3, $result);
- $query = new Query($this->connection);
- $result = $query
- ->select(['title'])
- ->from('articles')
- ->where(function ($exp) {
- return $exp->notLike('title', '%Article%');
- })
- ->execute();
- $this->assertCount(0, $result);
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(function ($exp) {
- return $exp->isNull('published');
- })
- ->execute();
- $this->assertCount(0, $result);
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(function ($exp) {
- return $exp->isNotNull('published');
- })
- ->execute();
- $this->assertCount(6, $result);
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(function ($exp) {
- return $exp->in('published', ['Y', 'N']);
- })
- ->execute();
- $this->assertCount(6, $result);
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(function ($exp) {
- return $exp->in(
- 'created',
- [new \DateTime('2007-03-18 10:45:23'), new \DateTime('2007-03-18 10:47:23')],
- 'datetime'
- );
- })
- ->execute();
- $this->assertCount(2, $result);
- $this->assertEquals(['id' => 1], $result->fetch('assoc'));
- $this->assertEquals(['id' => 2], $result->fetch('assoc'));
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(function ($exp) {
- return $exp->notIn(
- 'created',
- [new \DateTime('2007-03-18 10:45:23'), new \DateTime('2007-03-18 10:47:23')],
- 'datetime'
- );
- })
- ->execute();
- $this->assertCount(4, $result);
- $this->assertEquals(['id' => 3], $result->fetch('assoc'));
- }
- /**
- * Tests that calling "in" and "notIn" will cast the passed values to an array
- *
- * @return void
- */
- public function testInValueCast()
- {
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(function ($exp) {
- return $exp->in('created', '2007-03-18 10:45:23', 'datetime');
- })
- ->execute();
- $this->assertCount(1, $result);
- $this->assertEquals(['id' => 1], $result->fetch('assoc'));
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(function ($exp) {
- return $exp->notIn('created', '2007-03-18 10:45:23', 'datetime');
- })
- ->execute();
- $this->assertCount(5, $result);
- $this->assertEquals(['id' => 2], $result->fetch('assoc'));
- $this->assertEquals(['id' => 3], $result->fetch('assoc'));
- $this->assertEquals(['id' => 4], $result->fetch('assoc'));
- $this->assertEquals(['id' => 5], $result->fetch('assoc'));
- $result->closeCursor();
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(function ($exp, $q) {
- return $exp->in(
- 'created',
- $q->newExpr("'2007-03-18 10:45:23'"),
- 'datetime'
- );
- })
- ->execute();
- $this->assertCount(1, $result);
- $this->assertEquals(['id' => 1], $result->fetch('assoc'));
- $result->closeCursor();
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(function ($exp, $q) {
- return $exp->notIn(
- 'created',
- $q->newExpr("'2007-03-18 10:45:23'"),
- 'datetime'
- );
- })
- ->execute();
- $this->assertCount(5, $result);
- $result->closeCursor();
- }
- /**
- * Tests that calling "in" and "notIn" will cast the passed values to an array
- *
- * @return void
- */
- public function testInValueCast2()
- {
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(['created IN' => '2007-03-18 10:45:23'])
- ->execute();
- $this->assertCount(1, $result);
- $this->assertEquals(['id' => 1], $result->fetch('assoc'));
- $result->closeCursor();
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(['created NOT IN' => '2007-03-18 10:45:23'])
- ->execute();
- $this->assertCount(5, $result);
- $result->closeCursor();
- }
- /**
- * Tests where() with callable types.
- *
- * @return void
- */
- public function testWhereCallables()
- {
- $query = new Query($this->connection);
- $query->select(['id'])
- ->from('articles')
- ->where([
- 'id' => '\Cake\Error\Debugger::dump',
- 'title' => ['\Cake\Error\Debugger', 'dump'],
- 'author_id' => function ($exp) {
- return 1;
- }
- ]);
- $this->assertQuotedQuery(
- 'SELECT <id> FROM <articles> WHERE \(<id> = :c0 AND <title> = :c1 AND <author_id> = :c2\)',
- $query->sql(),
- !$this->autoQuote
- );
- }
- /**
- * Tests that empty values don't set where clauses.
- *
- * @return void
- */
- public function testWhereEmptyValues()
- {
- $query = new Query($this->connection);
- $query->from('comments')
- ->where('');
- $this->assertCount(0, $query->clause('where'));
- $query->where([]);
- $this->assertCount(0, $query->clause('where'));
- }
- /**
- * Tests that it is possible to use a between expression
- * in a where condition
- *
- * @return void
- */
- public function testWhereWithBetween()
- {
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(function ($exp) {
- return $exp->between('id', 5, 6, 'integer');
- })
- ->execute();
- $this->assertCount(2, $result);
- $first = $result->fetch('assoc');
- $this->assertEquals(5, $first['id']);
- $second = $result->fetch('assoc');
- $this->assertEquals(6, $second['id']);
- $result->closeCursor();
- }
- /**
- * Tests that it is possible to use a between expression
- * in a where condition with a complex data type
- *
- * @return void
- */
- public function testWhereWithBetweenComplex()
- {
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(function ($exp) {
- $from = new \DateTime('2007-03-18 10:51:00');
- $to = new \DateTime('2007-03-18 10:54:00');
- return $exp->between('created', $from, $to, 'datetime');
- })
- ->execute();
- $this->assertCount(2, $result);
- $first = $result->fetch('assoc');
- $this->assertEquals(4, $first['id']);
- $second = $result->fetch('assoc');
- $this->assertEquals(5, $second['id']);
- $result->closeCursor();
- }
- /**
- * Tests that it is possible to use an expression object
- * as the field for a between expression
- *
- * @return void
- */
- public function testWhereWithBetweenWithExpressionField()
- {
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(function ($exp, $q) {
- $field = $q->func()->coalesce([new IdentifierExpression('id'), 1 => 'literal']);
- return $exp->between($field, 5, 6, 'integer');
- })
- ->execute();
- $this->assertCount(2, $result);
- $first = $result->fetch('assoc');
- $this->assertEquals(5, $first['id']);
- $second = $result->fetch('assoc');
- $this->assertEquals(6, $second['id']);
- $result->closeCursor();
- }
- /**
- * Tests that it is possible to use an expression object
- * as any of the parts of the between expression
- *
- * @return void
- */
- public function testWhereWithBetweenWithExpressionParts()
- {
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(function ($exp, $q) {
- $from = $q->newExpr("'2007-03-18 10:51:00'");
- $to = $q->newExpr("'2007-03-18 10:54:00'");
- return $exp->between('created', $from, $to);
- })
- ->execute();
- $this->assertCount(2, $result);
- $first = $result->fetch('assoc');
- $this->assertEquals(4, $first['id']);
- $second = $result->fetch('assoc');
- $this->assertEquals(5, $second['id']);
- }
- /**
- * Tests nesting query expressions both using arrays and closures
- *
- * @return void
- */
- public function testSelectExpressionComposition()
- {
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(function ($exp) {
- $and = $exp->and_(['id' => 2, 'id >' => 1]);
- return $exp->add($and);
- })
- ->execute();
- $this->assertCount(1, $result);
- $this->assertEquals(['id' => 2], $result->fetch('assoc'));
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(function ($exp) {
- $and = $exp->and_(['id' => 2, 'id <' => 2]);
- return $exp->add($and);
- })
- ->execute();
- $this->assertCount(0, $result);
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(function ($exp) {
- $and = $exp->and_(function ($and) {
- return $and->eq('id', 1)->gt('id', 0);
- });
- return $exp->add($and);
- })
- ->execute();
- $this->assertCount(1, $result);
- $this->assertEquals(['id' => 1], $result->fetch('assoc'));
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(function ($exp) {
- $or = $exp->or_(['id' => 1]);
- $and = $exp->and_(['id >' => 2, 'id <' => 4]);
- return $or->add($and);
- })
- ->execute();
- $this->assertCount(2, $result);
- $this->assertEquals(['id' => 1], $result->fetch('assoc'));
- $this->assertEquals(['id' => 3], $result->fetch('assoc'));
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(function ($exp) {
- $or = $exp->or_(function ($or) {
- return $or->eq('id', 1)->eq('id', 2);
- });
- return $or;
- })
- ->execute();
- $this->assertCount(2, $result);
- $this->assertEquals(['id' => 1], $result->fetch('assoc'));
- $this->assertEquals(['id' => 2], $result->fetch('assoc'));
- }
- /**
- * Tests that conditions can be nested with an unary operator using the array notation
- * and the not() method
- *
- * @return void
- */
- public function testSelectWhereNot()
- {
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(function ($exp) {
- return $exp->not(
- $exp->and_(['id' => 2, 'created' => new \DateTime('2007-03-18 10:47:23')], ['created' => 'datetime'])
- );
- })
- ->execute();
- $this->assertCount(5, $result);
- $this->assertEquals(['id' => 1], $result->fetch('assoc'));
- $this->assertEquals(['id' => 3], $result->fetch('assoc'));
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(function ($exp) {
- return $exp->not(
- $exp->and_(['id' => 2, 'created' => new \DateTime('2012-12-21 12:00')], ['created' => 'datetime'])
- );
- })
- ->execute();
- $this->assertCount(6, $result);
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('articles')
- ->where([
- 'not' => ['or' => ['id' => 1, 'id >' => 2], 'id' => 3]
- ])
- ->execute();
- $this->assertCount(2, $result);
- $this->assertEquals(['id' => 1], $result->fetch('assoc'));
- $this->assertEquals(['id' => 2], $result->fetch('assoc'));
- }
- /**
- * Tests order() method both with simple fields and expressions
- *
- * @return void
- */
- public function testSelectOrderBy()
- {
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('articles')
- ->order(['id' => 'desc'])
- ->execute();
- $this->assertEquals(['id' => 3], $result->fetch('assoc'));
- $this->assertEquals(['id' => 2], $result->fetch('assoc'));
- $this->assertEquals(['id' => 1], $result->fetch('assoc'));
- $result = $query->order(['id' => 'asc'])->execute();
- $this->assertEquals(['id' => 1], $result->fetch('assoc'));
- $this->assertEquals(['id' => 2], $result->fetch('assoc'));
- $this->assertEquals(['id' => 3], $result->fetch('assoc'));
- $result = $query->order(['title' => 'asc'])->execute();
- $this->assertEquals(['id' => 1], $result->fetch('assoc'));
- $this->assertEquals(['id' => 2], $result->fetch('assoc'));
- $this->assertEquals(['id' => 3], $result->fetch('assoc'));
- $result = $query->order(['title' => 'asc'], true)->execute();
- $this->assertEquals(['id' => 1], $result->fetch('assoc'));
- $this->assertEquals(['id' => 2], $result->fetch('assoc'));
- $this->assertEquals(['id' => 3], $result->fetch('assoc'));
- $result = $query->order(['title' => 'asc', 'published' => 'asc'], true)
- ->execute();
- $this->assertEquals(['id' => 1], $result->fetch('assoc'));
- $this->assertEquals(['id' => 2], $result->fetch('assoc'));
- $this->assertEquals(['id' => 3], $result->fetch('assoc'));
- $expression = $query->newExpr(['(id + :offset) % 2']);
- $result = $query
- ->order([$expression, 'id' => 'desc'], true)
- ->bind(':offset', 1, null)
- ->execute();
- $this->assertEquals(['id' => 3], $result->fetch('assoc'));
- $this->assertEquals(['id' => 1], $result->fetch('assoc'));
- $this->assertEquals(['id' => 2], $result->fetch('assoc'));
- $result = $query
- ->order($expression, true)
- ->order(['id' => 'asc'])
- ->bind(':offset', 1, null)
- ->execute();
- $this->assertEquals(['id' => 1], $result->fetch('assoc'));
- $this->assertEquals(['id' => 3], $result->fetch('assoc'));
- $this->assertEquals(['id' => 2], $result->fetch('assoc'));
- }
- /**
- * Test that order() being a string works.
- *
- * @return void
- */
- public function testSelectOrderByString()
- {
- $query = new Query($this->connection);
- $query->select(['id'])
- ->from('articles')
- ->order('id asc');
- $result = $query->execute();
- $this->assertEquals(['id' => 1], $result->fetch('assoc'));
- $this->assertEquals(['id' => 2], $result->fetch('assoc'));
- $this->assertEquals(['id' => 3], $result->fetch('assoc'));
- }
- /**
- * Test orderAsc() and its input types.
- *
- * @return void
- */
- public function testSelectOrderAsc()
- {
- $query = new Query($this->connection);
- $query->select(['id'])
- ->from('articles')
- ->orderAsc('id');
- $sql = $query->sql();
- $result = $query->execute()->fetchAll('assoc');
- $expected = [
- ['id' => 1],
- ['id' => 2],
- ['id' => 3],
- ];
- $this->assertEquals($expected, $result);
- $this->assertQuotedQuery(
- 'SELECT <id> FROM <articles> ORDER BY <id> ASC',
- $sql,
- !$this->autoQuote
- );
- $query = new Query($this->connection);
- $query->select(['id'])
- ->from('articles')
- ->orderAsc($query->func()->concat(['id' => 'identifier', '3']));
- $result = $query->execute()->fetchAll('assoc');
- $expected = [
- ['id' => 1],
- ['id' => 2],
- ['id' => 3],
- ];
- $this->assertEquals($expected, $result);
- }
- /**
- * Test orderDesc() and its input types.
- *
- * @return void
- */
- public function testSelectOrderDesc()
- {
- $query = new Query($this->connection);
- $query->select(['id'])
- ->from('articles')
- ->orderDesc('id');
- $sql = $query->sql();
- $result = $query->execute()->fetchAll('assoc');
- $expected = [
- ['id' => 3],
- ['id' => 2],
- ['id' => 1],
- ];
- $this->assertEquals($expected, $result);
- $this->assertQuotedQuery(
- 'SELECT <id> FROM <articles> ORDER BY <id> DESC',
- $sql,
- !$this->autoQuote
- );
- $query = new Query($this->connection);
- $query->select(['id'])
- ->from('articles')
- ->orderDesc($query->func()->concat(['id' => 'identifier', '3']));
- $result = $query->execute()->fetchAll('assoc');
- $expected = [
- ['id' => 3],
- ['id' => 2],
- ['id' => 1],
- ];
- $this->assertEquals($expected, $result);
- }
- /**
- * Tests that group by fields can be passed similar to select fields
- * and that it sends the correct query to the database
- *
- * @return void
- */
- public function testSelectGroup()
- {
- $query = new Query($this->connection);
- $result = $query
- ->select(['total' => 'count(author_id)', 'author_id'])
- ->from('articles')
- ->join(['table' => 'authors', 'alias' => 'a', 'conditions' => 'author_id = a.id'])
- ->group('author_id')
- ->execute();
- $expected = [['total' => 2, 'author_id' => 1], ['total' => '1', 'author_id' => 3]];
- $this->assertEquals($expected, $result->fetchAll('assoc'));
- $result = $query->select(['total' => 'count(title)', 'name'], true)
- ->group(['name'], true)
- ->order(['total' => 'asc'])
- ->execute();
- $expected = [['total' => 1, 'name' => 'larry'], ['total' => 2, 'name' => 'mariano']];
- $this->assertEquals($expected, $result->fetchAll('assoc'));
- $result = $query->select(['articles.id'])
- ->group(['articles.id'])
- ->execute();
- $this->assertCount(3, $result);
- }
- /**
- * Tests that it is possible to select distinct rows
- *
- * @return void
- */
- public function testSelectDistinct()
- {
- $query = new Query($this->connection);
- $result = $query
- ->select(['author_id'])
- ->from(['a' => 'articles'])
- ->execute();
- $this->assertCount(3, $result);
- $result = $query->distinct()->execute();
- $this->assertCount(2, $result);
- $result = $query->select(['id'])->distinct(false)->execute();
- $this->assertCount(3, $result);
- }
- /**
- * Tests that it is possible to select distinct rows, even filtering by one column
- * this is testing that there is a specific implementation for DISTINCT ON
- *
- * @return void
- */
- public function testSelectDistinctON()
- {
- $query = new Query($this->connection);
- $result = $query
- ->select(['id', 'author_id'])
- ->distinct(['author_id'])
- ->from(['a' => 'articles'])
- ->order(['author_id' => 'ASC'])
- ->execute();
- $this->assertCount(2, $result);
- $results = $result->fetchAll('assoc');
- $this->assertEquals(['id', 'author_id'], array_keys($results[0]));
- $this->assertEquals(
- [3, 1],
- collection($results)->sortBy('author_id')->extract('author_id')->toList()
- );
- $query = new Query($this->connection);
- $result = $query
- ->select(['id', 'author_id'])
- ->distinct('author_id')
- ->from(['a' => 'articles'])
- ->order(['author_id' => 'ASC'])
- ->execute();
- $this->assertCount(2, $result);
- $results = $result->fetchAll('assoc');
- $this->assertEquals(['id', 'author_id'], array_keys($results[0]));
- $this->assertEquals(
- [3, 1],
- collection($results)->sortBy('author_id')->extract('author_id')->toList()
- );
- }
- /**
- * Test use of modifiers in the query
- *
- * Testing the generated SQL since the modifiers are usually different per driver
- *
- * @return void
- */
- public function testSelectModifiers()
- {
- $query = new Query($this->connection);
- $result = $query
- ->select(['city', 'state', 'country'])
- ->from(['addresses'])
- ->modifier('DISTINCTROW');
- $this->assertQuotedQuery(
- 'SELECT DISTINCTROW <city>, <state>, <country> FROM <addresses>',
- $result->sql(),
- !$this->autoQuote
- );
- $query = new Query($this->connection);
- $result = $query
- ->select(['city', 'state', 'country'])
- ->from(['addresses'])
- ->modifier(['DISTINCTROW', 'SQL_NO_CACHE']);
- $this->assertQuotedQuery(
- 'SELECT DISTINCTROW SQL_NO_CACHE <city>, <state>, <country> FROM <addresses>',
- $result->sql(),
- !$this->autoQuote
- );
- $query = new Query($this->connection);
- $result = $query
- ->select(['city', 'state', 'country'])
- ->from(['addresses'])
- ->modifier('DISTINCTROW')
- ->modifier('SQL_NO_CACHE');
- $this->assertQuotedQuery(
- 'SELECT DISTINCTROW SQL_NO_CACHE <city>, <state>, <country> FROM <addresses>',
- $result->sql(),
- true
- );
- $query = new Query($this->connection);
- $result = $query
- ->select(['city', 'state', 'country'])
- ->from(['addresses'])
- ->modifier(['TOP 10']);
- $this->assertQuotedQuery(
- 'SELECT TOP 10 <city>, <state>, <country> FROM <addresses>',
- $result->sql(),
- !$this->autoQuote
- );
- }
- /**
- * Tests that having() behaves pretty much the same as the where() method
- *
- * @return void
- */
- public function testSelectHaving()
- {
- $query = new Query($this->connection);
- $result = $query
- ->select(['total' => 'count(author_id)', 'author_id'])
- ->from('articles')
- ->join(['table' => 'authors', 'alias' => 'a', 'conditions' => $query->newExpr()->equalFields('author_id', 'a.id')])
- ->group('author_id')
- ->having(['count(author_id) <' => 2], ['count(author_id)' => 'integer'])
- ->execute();
- $expected = [['total' => 1, 'author_id' => 3]];
- $this->assertEquals($expected, $result->fetchAll('assoc'));
- $result = $query->having(['count(author_id)' => 2], ['count(author_id)' => 'integer'], true)
- ->execute();
- $expected = [['total' => 2, 'author_id' => 1]];
- $this->assertEquals($expected, $result->fetchAll('assoc'));
- $result = $query->having(function ($e) {
- return $e->add('count(author_id) = 1 + 1');
- }, [], true)
- ->execute();
- $expected = [['total' => 2, 'author_id' => 1]];
- $this->assertEquals($expected, $result->fetchAll('assoc'));
- }
- /**
- * Tests that Query::orHaving() can be used to concatenate conditions with OR
- * in the having clause
- *
- * @return void
- */
- public function testSelectOrHaving()
- {
- $query = new Query($this->connection);
- $result = $query
- ->select(['total' => 'count(author_id)', 'author_id'])
- ->from('articles')
- ->join(['table' => 'authors', 'alias' => 'a', 'conditions' => $query->newExpr()->equalFields('author_id', 'a.id')])
- ->group('author_id')
- ->having(['count(author_id) >' => 2], ['count(author_id)' => 'integer'])
- ->orHaving(['count(author_id) <' => 2], ['count(author_id)' => 'integer'])
- ->execute();
- $expected = [['total' => 1, 'author_id' => 3]];
- $this->assertEquals($expected, $result->fetchAll('assoc'));
- $query = new Query($this->connection);
- $result = $query
- ->select(['total' => 'count(author_id)', 'author_id'])
- ->from('articles')
- ->join(['table' => 'authors', 'alias' => 'a', 'conditions' => $query->newExpr()->equalFields('author_id', 'a.id')])
- ->group('author_id')
- ->having(['count(author_id) >' => 2], ['count(author_id)' => 'integer'])
- ->orHaving(['count(author_id) <=' => 2], ['count(author_id)' => 'integer'])
- ->execute();
- $expected = [['total' => 2, 'author_id' => 1], ['total' => 1, 'author_id' => 3]];
- $this->assertEquals($expected, $result->fetchAll('assoc'));
- $query = new Query($this->connection);
- $result = $query
- ->select(['total' => 'count(author_id)', 'author_id'])
- ->from('articles')
- ->join(['table' => 'authors', 'alias' => 'a', 'conditions' => $query->newExpr()->equalFields('author_id', 'a.id')])
- ->group('author_id')
- ->having(['count(author_id) >' => 2], ['count(author_id)' => 'integer'])
- ->orHaving(function ($e) {
- return $e->add('count(author_id) = 1 + 1');
- })
- ->execute();
- $expected = [['total' => 2, 'author_id' => 1]];
- $this->assertEquals($expected, $result->fetchAll('assoc'));
- }
- /**
- * Tests that Query::andHaving() can be used to concatenate conditions with AND
- * in the having clause
- *
- * @return void
- */
- public function testSelectAndHaving()
- {
- $query = new Query($this->connection);
- $result = $query
- ->select(['total' => 'count(author_id)', 'author_id'])
- ->from('articles')
- ->join(['table' => 'authors', 'alias' => 'a', 'conditions' => $query->newExpr()->equalFields('author_id', 'a.id')])
- ->group('author_id')
- ->having(['count(author_id) >' => 2], ['count(author_id)' => 'integer'])
- ->andHaving(['count(author_id) <' => 2], ['count(author_id)' => 'integer'])
- ->execute();
- $this->assertCount(0, $result);
- $query = new Query($this->connection);
- $result = $query
- ->select(['total' => 'count(author_id)', 'author_id'])
- ->from('articles')
- ->join(['table' => 'authors', 'alias' => 'a', 'conditions' => $query->newExpr()->equalFields('author_id', 'a.id')])
- ->group('author_id')
- ->having(['count(author_id)' => 2], ['count(author_id)' => 'integer'])
- ->andHaving(['count(author_id) >' => 1], ['count(author_id)' => 'integer'])
- ->execute();
- $expected = [['total' => 2, 'author_id' => 1]];
- $this->assertEquals($expected, $result->fetchAll('assoc'));
- $query = new Query($this->connection);
- $result = $query
- ->select(['total' => 'count(author_id)', 'author_id'])
- ->from('articles')
- ->join(['table' => 'authors', 'alias' => 'a', 'conditions' => $query->newExpr()->equalFields('author_id', 'a.id')])
- ->group('author_id')
- ->andHaving(function ($e) {
- return $e->add('count(author_id) = 2 - 1');
- })
- ->execute();
- $expected = [['total' => 1, 'author_id' => 3]];
- $this->assertEquals($expected, $result->fetchAll('assoc'));
- }
- /**
- * Tests selecting rows using a limit clause
- *
- * @return void
- */
- public function testSelectLimit()
- {
- $query = new Query($this->connection);
- $result = $query->select('id')->from('articles')->limit(1)->execute();
- $this->assertCount(1, $result);
- $query = new Query($this->connection);
- $result = $query->select('id')->from('articles')->limit(2)->execute();
- $this->assertCount(2, $result);
- }
- /**
- * Tests selecting rows combining a limit and offset clause
- *
- * @return void
- */
- public function testSelectOffset()
- {
- $query = new Query($this->connection);
- $result = $query->select('id')->from('comments')
- ->limit(1)
- ->offset(0)
- ->order(['id' => 'ASC'])
- ->execute();
- $this->assertCount(1, $result);
- $this->assertEquals(['id' => 1], $result->fetch('assoc'));
- $query = new Query($this->connection);
- $result = $query->select('id')->from('comments')
- ->limit(1)
- ->offset(1)
- ->execute();
- $this->assertCount(1, $result);
- $this->assertEquals(['id' => 2], $result->fetch('assoc'));
- $query = new Query($this->connection);
- $result = $query->select('id')->from('comments')
- ->limit(1)
- ->offset(2)
- ->execute();
- $this->assertCount(1, $result);
- $this->assertEquals(['id' => 3], $result->fetch('assoc'));
- $query = new Query($this->connection);
- $result = $query->select('id')->from('articles')
- ->order(['id' => 'DESC'])
- ->limit(1)
- ->offset(0)
- ->execute();
- $this->assertCount(1, $result);
- $this->assertEquals(['id' => 3], $result->fetch('assoc'));
- $result = $query->limit(2)->offset(1)->execute();
- $this->assertCount(2, $result);
- $this->assertEquals(['id' => 2], $result->fetch('assoc'));
- $this->assertEquals(['id' => 1], $result->fetch('assoc'));
- $query = new Query($this->connection);
- $query->select('id')->from('comments')
- ->limit(1)
- ->offset(1)
- ->execute();
- $dirty = $this->readAttribute($query, '_dirty');
- $this->assertFalse($dirty);
- $query->offset(2);
- $dirty = $this->readAttribute($query, '_dirty');
- $this->assertTrue($dirty);
- }
- /**
- * Test selecting rows using the page() method.
- *
- * @return void
- */
- public function testSelectPage()
- {
- $query = new Query($this->connection);
- $result = $query->select('id')->from('comments')
- ->limit(1)
- ->page(1)
- ->execute();
- $this->assertCount(1, $result);
- $this->assertEquals(['id' => 1], $result->fetch('assoc'));
- $query = new Query($this->connection);
- $result = $query->select('id')->from('comments')
- ->limit(1)
- ->page(2)
- ->order(['id' => 'asc'])
- ->execute();
- $this->assertCount(1, $result);
- $this->assertEquals(['id' => 2], $result->fetch('assoc'));
- $query = new Query($this->connection);
- $query->select('id')->from('comments')->page(3, 10);
- $this->assertEquals(10, $query->clause('limit'));
- $this->assertEquals(20, $query->clause('offset'));
- $query = new Query($this->connection);
- $query->select('id')->from('comments')->page(1);
- $this->assertEquals(25, $query->clause('limit'));
- $this->assertEquals(0, $query->clause('offset'));
- $query->select('id')->from('comments')->page(2);
- $this->assertEquals(25, $query->clause('limit'));
- $this->assertEquals(25, $query->clause('offset'));
- }
- /**
- * Tests that Query objects can be included inside the select clause
- * and be used as a normal field, including binding any passed parameter
- *
- * @return void
- */
- public function testSubqueryInSelect()
- {
- $query = new Query($this->connection);
- $subquery = (new Query($this->connection))
- ->select('name')
- ->from(['b' => 'authors'])
- ->where([$query->newExpr()->equalFields('b.id', 'a.id')]);
- $result = $query
- ->select(['id', 'name' => $subquery])
- ->from(['a' => 'comments'])->execute();
- $expected = [
- ['id' => 1, 'name' => 'mariano'],
- ['id' => 2, 'name' => 'nate'],
- ['id' => 3, 'name' => 'larry'],
- ['id' => 4, 'name' => 'garrett'],
- ['id' => 5, 'name' => null],
- ['id' => 6, 'name' => null],
- ];
- $this->assertEquals($expected, $result->fetchAll('assoc'));
- $query = new Query($this->connection);
- $subquery = (new Query($this->connection))
- ->select('name')
- ->from(['b' => 'authors'])
- ->where(['name' => 'mariano'], ['name' => 'string']);
- $result = $query
- ->select(['id', 'name' => $subquery])
- ->from(['a' => 'articles'])->execute();
- $expected = [
- ['id' => 1, 'name' => 'mariano'],
- ['id' => 2, 'name' => 'mariano'],
- ['id' => 3, 'name' => 'mariano'],
- ];
- $this->assertEquals($expected, $result->fetchAll('assoc'));
- }
- /**
- * Tests that Query objects can be included inside the from clause
- * and be used as a normal table, including binding any passed parameter
- *
- * @return void
- */
- public function testSuqueryInFrom()
- {
- $query = new Query($this->connection);
- $subquery = (new Query($this->connection))
- ->select(['id', 'comment'])
- ->from('comments')
- ->where(['created >' => new \DateTime('2007-03-18 10:45:23')], ['created' => 'datetime']);
- $result = $query
- ->select(['say' => 'comment'])
- ->from(['b' => $subquery])
- ->where(['id !=' => 3])
- ->execute();
- $expected = [
- ['say' => 'Second Comment for First Article'],
- ['say' => 'Fourth Comment for First Article'],
- ['say' => 'First Comment for Second Article'],
- ['say' => 'Second Comment for Second Article'],
- ];
- $this->assertEquals($expected, $result->fetchAll('assoc'));
- }
- /**
- * Tests that Query objects can be included inside the where clause
- * and be used as a normal condition, including binding any passed parameter
- *
- * @return void
- */
- public function testSubqueryInWhere()
- {
- $query = new Query($this->connection);
- $subquery = (new Query($this->connection))
- ->select(['id'])
- ->from('authors')
- ->where(['id' => 1]);
- $result = $query
- ->select(['name'])
- ->from(['authors'])
- ->where(['id !=' => $subquery])
- ->execute();
- $expected = [
- ['name' => 'nate'],
- ['name' => 'larry'],
- ['name' => 'garrett'],
- ];
- $this->assertEquals($expected, $result->fetchAll('assoc'));
- $result->closeCursor();
- $query = new Query($this->connection);
- $subquery = (new Query($this->connection))
- ->select(['id'])
- ->from('comments')
- ->where(['created >' => new \DateTime('2007-03-18 10:45:23')], ['created' => 'datetime']);
- $result = $query
- ->select(['name'])
- ->from(['authors'])
- ->where(['id not in' => $subquery])
- ->execute();
- $expected = [
- ['name' => 'mariano'],
- ];
- $this->assertEquals($expected, $result->fetchAll('assoc'));
- $result->closeCursor();
- }
- /**
- * Tests that it is possible to use a subquery in a join clause
- *
- * @return void
- */
- public function testSubqueryInJoin()
- {
- $subquery = (new Query($this->connection))->select('*')->from('authors');
- $query = new Query($this->connection);
- $result = $query
- ->select(['title', 'name'])
- ->from('articles')
- ->join(['b' => $subquery])
- ->execute();
- $this->assertCount(self::ARTICLE_COUNT * self::AUTHOR_COUNT, $result, 'Cross join causes multiplication');
- $result->closeCursor();
- $subquery->where(['id' => 1]);
- $result = $query->execute();
- $this->assertCount(3, $result);
- $result->closeCursor();
- $query->join(['b' => ['table' => $subquery, 'conditions' => [$query->newExpr()->equalFields('b.id', 'articles.id')]]], [], true);
- $result = $query->execute();
- $this->assertCount(1, $result);
- $result->closeCursor();
- }
- /**
- * Tests that it is possible to one or multiple UNION statements in a query
- *
- * @return void
- */
- public function testUnion()
- {
- $union = (new Query($this->connection))->select(['id', 'title'])->from(['a' => 'articles']);
- $query = new Query($this->connection);
- $result = $query->select(['id', 'comment'])
- ->from(['c' => 'comments'])
- ->union($union)
- ->execute();
- $this->assertCount(self::COMMENT_COUNT + self::ARTICLE_COUNT, $result);
- $rows = $result->fetchAll();
- $result->closeCursor();
- $union->select(['foo' => 'id', 'bar' => 'title']);
- $union = (new Query($this->connection))
- ->select(['id', 'name', 'other' => 'id', 'nameish' => 'name'])
- ->from(['b' => 'authors'])
- ->where(['id ' => 1])
- ->order(['id' => 'desc']);
- $query->select(['foo' => 'id', 'bar' => 'comment'])->union($union);
- $result = $query->execute();
- $this->assertCount(self::COMMENT_COUNT + self::AUTHOR_COUNT, $result);
- $this->assertNotEquals($rows, $result->fetchAll());
- $result->closeCursor();
- $union = (new Query($this->connection))
- ->select(['id', 'title'])
- ->from(['c' => 'articles']);
- $query->select(['id', 'comment'], true)->union($union, true);
- $result = $query->execute();
- $this->assertCount(self::COMMENT_COUNT + self::ARTICLE_COUNT, $result);
- $this->assertEquals($rows, $result->fetchAll());
- $result->closeCursor();
- }
- /**
- * Tests that it is possible to run unions with order statements
- *
- * @return void
- */
- public function testUnionOrderBy()
- {
- $this->skipIf(
- ($this->connection->driver() instanceof \Cake\Database\Driver\Sqlite ||
- $this->connection->driver() instanceof \Cake\Database\Driver\Sqlserver),
- 'Driver does not support ORDER BY in UNIONed queries.'
- );
- $union = (new Query($this->connection))
- ->select(['id', 'title'])
- ->from(['a' => 'articles'])
- ->order(['a.id' => 'asc']);
- $query = new Query($this->connection);
- $result = $query->select(['id', 'comment'])
- ->from(['c' => 'comments'])
- ->order(['c.id' => 'asc'])
- ->union($union)
- ->execute();
- $this->assertCount(self::COMMENT_COUNT + self::ARTICLE_COUNT, $result);
- $rows = $result->fetchAll();
- $this->assertCount(self::COMMENT_COUNT + self::ARTICLE_COUNT, $result);
- }
- /**
- * Tests that UNION ALL can be built by setting the second param of union() to true
- *
- * @return void
- */
- public function testUnionAll()
- {
- $union = (new Query($this->connection))->select(['id', 'title'])->from(['a' => 'articles']);
- $query = new Query($this->connection);
- $result = $query->select(['id', 'comment'])
- ->from(['c' => 'comments'])
- ->union($union)
- ->execute();
- $this->assertCount(self::ARTICLE_COUNT + self::COMMENT_COUNT, $result);
- $rows = $result->fetchAll();
- $result->closeCursor();
- $union->select(['foo' => 'id', 'bar' => 'title']);
- $union = (new Query($this->connection))
- ->select(['id', 'name', 'other' => 'id', 'nameish' => 'name'])
- ->from(['b' => 'authors'])
- ->where(['id ' => 1])
- ->order(['id' => 'desc']);
- $query->select(['foo' => 'id', 'bar' => 'comment'])->unionAll($union);
- $result = $query->execute();
- $this->assertCount(1 + self::COMMENT_COUNT + self::ARTICLE_COUNT, $result);
- $this->assertNotEquals($rows, $result->fetchAll());
- $result->closeCursor();
- }
- /**
- * Tests stacking decorators for results and resetting the list of decorators
- *
- * @return void
- */
- public function testDecorateResults()
- {
- $query = new Query($this->connection);
- $result = $query
- ->select(['id', 'title'])
- ->from('articles')
- ->order(['id' => 'ASC'])
- ->decorateResults(function ($row) {
- $row['modified_id'] = $row['id'] + 1;
- return $row;
- })
- ->execute();
- while ($row = $result->fetch('assoc')) {
- $this->assertEquals($row['id'] + 1, $row['modified_id']);
- }
- $result = $query->decorateResults(function ($row) {
- $row['modified_id']--;
- return $row;
- })->execute();
- while ($row = $result->fetch('assoc')) {
- $this->assertEquals($row['id'], $row['modified_id']);
- }
- $result->closeCursor();
- $result = $query
- ->decorateResults(function ($row) {
- $row['foo'] = 'bar';
- return $row;
- }, true)
- ->execute();
- while ($row = $result->fetch('assoc')) {
- $this->assertEquals('bar', $row['foo']);
- $this->assertArrayNotHasKey('modified_id', $row);
- }
- $results = $query->decorateResults(null, true)->execute();
- while ($row = $result->fetch('assoc')) {
- $this->assertArrayNotHasKey('foo', $row);
- $this->assertArrayNotHasKey('modified_id', $row);
- }
- $results->closeCursor();
- }
- /**
- * Test a basic delete using from()
- *
- * @return void
- */
- public function testDeleteWithFrom()
- {
- $query = new Query($this->connection);
- $query->delete()
- ->from('authors')
- ->where('1 = 1');
- $result = $query->sql();
- $this->assertQuotedQuery('DELETE FROM <authors>', $result, !$this->autoQuote);
- $result = $query->execute();
- $this->assertInstanceOf('Cake\Database\StatementInterface', $result);
- $this->assertCount(self::AUTHOR_COUNT, $result);
- $result->closeCursor();
- }
- /**
- * Test delete with from and alias.
- *
- * @return void
- */
- public function testDeleteWithAliasedFrom()
- {
- $query = new Query($this->connection);
- $query->delete()
- ->from(['a ' => 'authors'])
- ->where(['a.id !=' => 99]);
- $result = $query->sql();
- $this->assertQuotedQuery('DELETE FROM <authors> WHERE <id> != :c0', $result, !$this->autoQuote);
- $result = $query->execute();
- $this->assertInstanceOf('Cake\Database\StatementInterface', $result);
- $this->assertCount(self::AUTHOR_COUNT, $result);
- $result->closeCursor();
- }
- /**
- * Test a basic delete with no from() call.
- *
- * @return void
- */
- public function testDeleteNoFrom()
- {
- $query = new Query($this->connection);
- $query->delete('authors')
- ->where('1 = 1');
- $result = $query->sql();
- $this->assertQuotedQuery('DELETE FROM <authors>', $result, !$this->autoQuote);
- $result = $query->execute();
- $this->assertInstanceOf('Cake\Database\StatementInterface', $result);
- $this->assertCount(self::AUTHOR_COUNT, $result);
- $result->closeCursor();
- }
- /**
- * Test setting select() & delete() modes.
- *
- * @return void
- */
- public function testSelectAndDeleteOnSameQuery()
- {
- $query = new Query($this->connection);
- $result = $query->select()
- ->delete('authors')
- ->where('1 = 1');
- $result = $query->sql();
- $this->assertQuotedQuery('DELETE FROM <authors>', $result, !$this->autoQuote);
- $this->assertContains(' WHERE 1 = 1', $result);
- }
- /**
- * Test a simple update.
- *
- * @return void
- */
- public function testUpdateSimple()
- {
- $query = new Query($this->connection);
- $query->update('authors')
- ->set('name', 'mark')
- ->where(['id' => 1]);
- $result = $query->sql();
- $this->assertQuotedQuery('UPDATE <authors> SET <name> = :', $result, !$this->autoQuote);
- $result = $query->execute();
- $this->assertCount(1, $result);
- $result->closeCursor();
- }
- /**
- * Test update with multiple fields.
- *
- * @return void
- */
- public function testUpdateMultipleFields()
- {
- $query = new Query($this->connection);
- $query->update('articles')
- ->set('title', 'mark', 'string')
- ->set('body', 'some text', 'string')
- ->where(['id' => 1]);
- $result = $query->sql();
- $this->assertQuotedQuery(
- 'UPDATE <articles> SET <title> = :c0 , <body> = :c1',
- $result,
- !$this->autoQuote
- );
- $this->assertQuotedQuery(' WHERE <id> = :c2$', $result, !$this->autoQuote);
- $result = $query->execute();
- $this->assertCount(1, $result);
- $result->closeCursor();
- }
- /**
- * Test updating multiple fields with an array.
- *
- * @return void
- */
- public function testUpdateMultipleFieldsArray()
- {
- $query = new Query($this->connection);
- $query->update('articles')
- ->set([
- 'title' => 'mark',
- 'body' => 'some text'
- ], ['title' => 'string', 'body' => 'string'])
- ->where(['id' => 1]);
- $result = $query->sql();
- $this->assertQuotedQuery(
- 'UPDATE <articles> SET <title> = :c0 , <body> = :c1',
- $result,
- !$this->autoQuote
- );
- $this->assertQuotedQuery('WHERE <id> = :', $result, !$this->autoQuote);
- $result = $query->execute();
- $this->assertCount(1, $result);
- $result->closeCursor();
- }
- /**
- * Test updates with an expression.
- *
- * @return void
- */
- public function testUpdateWithExpression()
- {
- $query = new Query($this->connection);
- $expr = $query->newExpr()->equalFields('article_id', 'user_id');
- $query->update('comments')
- ->set($expr)
- ->where(['id' => 1]);
- $result = $query->sql();
- $this->assertQuotedQuery(
- 'UPDATE <comments> SET <article_id> = \(<user_id>\) WHERE <id> = :',
- $result,
- !$this->autoQuote
- );
- $result = $query->execute();
- $this->assertCount(1, $result);
- $result->closeCursor();
- }
- /**
- * Test update with array fields and types.
- *
- * @return void
- */
- public function testUpdateArrayFields()
- {
- $query = new Query($this->connection);
- $date = new \DateTime;
- $query->update('comments')
- ->set(['comment' => 'mark', 'created' => $date], ['created' => 'date'])
- ->where(['id' => 1]);
- $result = $query->sql();
- $this->assertQuotedQuery(
- 'UPDATE <comments> SET <comment> = :c0 , <created> = :c1',
- $result,
- !$this->autoQuote
- );
- $this->assertQuotedQuery(' WHERE <id> = :c2$', $result, !$this->autoQuote);
- $result = $query->execute();
- $this->assertCount(1, $result);
- $query = new Query($this->connection);
- $result = $query->select('created')->from('comments')->where(['id' => 1])->execute();
- $result = $result->fetchAll('assoc')[0]['created'];
- $this->assertStringStartsWith($date->format('Y-m-d'), $result);
- }
- /**
- * Test update with callable in set
- *
- * @return void
- */
- public function testUpdateSetCallable()
- {
- $query = new Query($this->connection);
- $date = new \DateTime;
- $query->update('comments')
- ->set(function ($exp) use ($date) {
- return $exp
- ->eq('comment', 'mark')
- ->eq('created', $date, 'date');
- })
- ->where(['id' => 1]);
- $result = $query->sql();
- $this->assertQuotedQuery(
- 'UPDATE <comments> SET <comment> = :c0 , <created> = :c1',
- $result,
- !$this->autoQuote
- );
- $this->assertQuotedQuery(' WHERE <id> = :c2$', $result, !$this->autoQuote);
- $result = $query->execute();
- $this->assertCount(1, $result);
- }
- /**
- * You cannot call values() before insert() it causes all sorts of pain.
- *
- * @expectedException \Cake\Database\Exception
- * @return void
- */
- public function testInsertValuesBeforeInsertFailure()
- {
- $query = new Query($this->connection);
- $query->select('*')->values([
- 'id' => 1,
- 'title' => 'mark',
- 'body' => 'test insert'
- ]);
- }
- /**
- * Inserting nothing should not generate an error.
- *
- * @expectedException \RuntimeException
- * @expectedExceptionMessage At least 1 column is required to perform an insert.
- * @return void
- */
- public function testInsertNothing()
- {
- $query = new Query($this->connection);
- $query->insert([]);
- }
- /**
- * Test inserting a single row.
- *
- * @return void
- */
- public function testInsertSimple()
- {
- $query = new Query($this->connection);
- $query->insert(['title', 'body'])
- ->into('articles')
- ->values([
- 'title' => 'mark',
- 'body' => 'test insert'
- ]);
- $result = $query->sql();
- $this->assertQuotedQuery(
- 'INSERT INTO <articles> \(<title>, <body>\) (OUTPUT INSERTED\.\* )?' .
- 'VALUES \(:c0, :c1\)',
- $result,
- !$this->autoQuote
- );
- $result = $query->execute();
- $result->closeCursor();
- //PDO_SQLSRV returns -1 for successful inserts when using INSERT ... OUTPUT
- if (!$this->connection->driver() instanceof \Cake\Database\Driver\Sqlserver) {
- $this->assertCount(1, $result, '1 row should be inserted');
- }
- $expected = [
- [
- 'id' => 4,
- 'author_id' => null,
- 'title' => 'mark',
- 'body' => 'test insert',
- 'published' => 'N',
- ]
- ];
- $this->assertTable('articles', 1, $expected, ['id >=' => 4]);
- }
- /**
- * Test an insert when not all the listed fields are provided.
- * Columns should be matched up where possible.
- *
- * @return void
- */
- public function testInsertSparseRow()
- {
- $query = new Query($this->connection);
- $query->insert(['title', 'body'])
- ->into('articles')
- ->values([
- 'title' => 'mark',
- ]);
- $result = $query->sql();
- $this->assertQuotedQuery(
- 'INSERT INTO <articles> \(<title>, <body>\) (OUTPUT INSERTED\.\* )?' .
- 'VALUES \(:c0, :c1\)',
- $result,
- !$this->autoQuote
- );
- $result = $query->execute();
- $result->closeCursor();
- //PDO_SQLSRV returns -1 for successful inserts when using INSERT ... OUTPUT
- if (!$this->connection->driver() instanceof \Cake\Database\Driver\Sqlserver) {
- $this->assertCount(1, $result, '1 row should be inserted');
- }
- $expected = [
- [
- 'id' => 4,
- 'author_id' => null,
- 'title' => 'mark',
- 'body' => null,
- 'published' => 'N',
- ]
- ];
- $this->assertTable('articles', 1, $expected, ['id >=' => 4]);
- }
- /**
- * Test inserting multiple rows with sparse data.
- *
- * @return void
- */
- public function testInsertMultipleRowsSparse()
- {
- $query = new Query($this->connection);
- $query->insert(['title', 'body'])
- ->into('articles')
- ->values([
- 'body' => 'test insert'
- ])
- ->values([
- 'title' => 'jose',
- ]);
- $result = $query->execute();
- $result->closeCursor();
- //PDO_SQLSRV returns -1 for successful inserts when using INSERT ... OUTPUT
- if (!$this->connection->driver() instanceof \Cake\Database\Driver\Sqlserver) {
- $this->assertCount(2, $result, '2 rows should be inserted');
- }
- $expected = [
- [
- 'id' => 4,
- 'author_id' => null,
- 'title' => null,
- 'body' => 'test insert',
- 'published' => 'N',
- ],
- [
- 'id' => 5,
- 'author_id' => null,
- 'title' => 'jose',
- 'body' => null,
- 'published' => 'N',
- ],
- ];
- $this->assertTable('articles', 2, $expected, ['id >=' => 4]);
- }
- /**
- * Test that INSERT INTO ... SELECT works.
- *
- * @return void
- */
- public function testInsertFromSelect()
- {
- $select = (new Query($this->connection))->select(['name', "'some text'", 99])
- ->from('authors')
- ->where(['id' => 1]);
- $query = new Query($this->connection);
- $query->insert(
- ['title', 'body', 'author_id'],
- ['title' => 'string', 'body' => 'string', 'author_id' => 'integer']
- )
- ->into('articles')
- ->values($select);
- $result = $query->sql();
- $this->assertQuotedQuery(
- 'INSERT INTO <articles> \(<title>, <body>, <author_id>\) (OUTPUT INSERTED\.\* )?SELECT',
- $result,
- !$this->autoQuote
- );
- $this->assertQuotedQuery(
- 'SELECT <name>, \'some text\', 99 FROM <authors>',
- $result,
- !$this->autoQuote
- );
- $result = $query->execute();
- $result->closeCursor();
- //PDO_SQLSRV returns -1 for successful inserts when using INSERT ... OUTPUT
- if (!$this->connection->driver() instanceof \Cake\Database\Driver\Sqlserver) {
- $this->assertCount(1, $result);
- }
- $result = (new Query($this->connection))->select('*')
- ->from('articles')
- ->where(['author_id' => 99])
- ->execute();
- $this->assertCount(1, $result);
- $expected = [
- 'id' => 4,
- 'title' => 'mariano',
- 'body' => 'some text',
- 'author_id' => 99,
- 'published' => 'N',
- ];
- $this->assertEquals($expected, $result->fetch('assoc'));
- }
- /**
- * Test that an exception is raised when mixing query + array types.
- *
- * @expectedException \Cake\Database\Exception
- */
- public function testInsertFailureMixingTypesArrayFirst()
- {
- $query = new Query($this->connection);
- $query->insert(['name'])
- ->into('articles')
- ->values(['name' => 'mark'])
- ->values(new Query($this->connection));
- }
- /**
- * Test that an exception is raised when mixing query + array types.
- *
- * @expectedException \Cake\Database\Exception
- */
- public function testInsertFailureMixingTypesQueryFirst()
- {
- $query = new Query($this->connection);
- $query->insert(['name'])
- ->into('articles')
- ->values(new Query($this->connection))
- ->values(['name' => 'mark']);
- }
- /**
- * Test that insert can use expression objects as values.
- *
- * @return void
- */
- public function testInsertExpressionValues()
- {
- $query = new Query($this->connection);
- $query->insert(['title', 'author_id'])
- ->into('articles')
- ->values(['title' => $query->newExpr("SELECT 'jose'"), 'author_id' => 99]);
- $result = $query->execute();
- $result->closeCursor();
- //PDO_SQLSRV returns -1 for successful inserts when using INSERT ... OUTPUT
- if (!$this->connection->driver() instanceof \Cake\Database\Driver\Sqlserver) {
- $this->assertCount(1, $result);
- }
- $result = (new Query($this->connection))->select('*')
- ->from('articles')
- ->where(['author_id' => 99])
- ->execute();
- $this->assertCount(1, $result);
- $expected = [
- 'id' => 4,
- 'title' => 'jose',
- 'body' => null,
- 'author_id' => '99',
- 'published' => 'N',
- ];
- $this->assertEquals($expected, $result->fetch('assoc'));
- $subquery = new Query($this->connection);
- $subquery->select(['name'])
- ->from('authors')
- ->where(['id' => 1]);
- $query = new Query($this->connection);
- $query->insert(['title', 'author_id'])
- ->into('articles')
- ->values(['title' => $subquery, 'author_id' => 100]);
- $result = $query->execute();
- $result->closeCursor();
- //PDO_SQLSRV returns -1 for successful inserts when using INSERT ... OUTPUT
- if (!$this->connection->driver() instanceof \Cake\Database\Driver\Sqlserver) {
- $this->assertCount(1, $result);
- }
- $result = (new Query($this->connection))->select('*')
- ->from('articles')
- ->where(['author_id' => 100])
- ->execute();
- $this->assertCount(1, $result);
- $expected = [
- 'id' => 5,
- 'title' => 'mariano',
- 'body' => null,
- 'author_id' => '100',
- 'published' => 'N',
- ];
- $this->assertEquals($expected, $result->fetch('assoc'));
- }
- /**
- * Tests that functions are correctly transformed and their parameters are bound
- *
- * @group FunctionExpression
- * @return void
- */
- public function testSQLFunctions()
- {
- $query = new Query($this->connection);
- $result = $query->select(
- function ($q) {
- return ['total' => $q->func()->count('*')];
- }
- )
- ->from('comments')
- ->execute();
- $expected = [['total' => 6]];
- $this->assertEquals($expected, $result->fetchAll('assoc'));
- $query = new Query($this->connection);
- $result = $query->select([
- 'c' => $query->func()->concat(['comment' => 'literal', ' is appended'])
- ])
- ->from('comments')
- ->order(['c' => 'ASC'])
- ->limit(1)
- ->execute();
- $expected = [
- ['c' => 'First Comment for First Article is appended'],
- ];
- $this->assertEquals($expected, $result->fetchAll('assoc'));
- $query = new Query($this->connection);
- $result = $query
- ->select(['d' => $query->func()->dateDiff(['2012-01-05', '2012-01-02'])])
- ->execute()
- ->fetchAll('assoc');
- $this->assertEquals(3, abs($result[0]['d']));
- $query = new Query($this->connection);
- $result = $query
- ->select(['d' => $query->func()->now('date')])
- ->execute();
- $this->assertEquals([['d' => date('Y-m-d')]], $result->fetchAll('assoc'));
- $query = new Query($this->connection);
- $result = $query
- ->select(['d' => $query->func()->now('time')])
- ->execute();
- $this->assertWithinRange(
- date('U'),
- (new \DateTime($result->fetchAll('assoc')[0]['d']))->format('U'),
- 1
- );
- $query = new Query($this->connection);
- $result = $query
- ->select(['d' => $query->func()->now()])
- ->execute();
- $this->assertWithinRange(
- date('U'),
- (new \DateTime($result->fetchAll('assoc')[0]['d']))->format('U'),
- 1
- );
- $query = new Query($this->connection);
- $result = $query
- ->select([
- 'd' => $query->func()->datePart('day', 'created'),
- 'm' => $query->func()->datePart('month', 'created'),
- 'y' => $query->func()->datePart('year', 'created'),
- 'de' => $query->func()->extract('day', 'created'),
- 'me' => $query->func()->extract('month', 'created'),
- 'ye' => $query->func()->extract('year', 'created'),
- 'wd' => $query->func()->weekday('created'),
- 'dow' => $query->func()->dayOfWeek('created'),
- 'addDays' => $query->func()->dateAdd('created', 2, 'day'),
- 'substractYears' => $query->func()->dateAdd('created', -2, 'year')
- ])
- ->from('comments')
- ->where(['created' => '2007-03-18 10:45:23'])
- ->execute()
- ->fetchAll('assoc');
- $result[0]['m'] = ltrim($result[0]['m'], '0');
- $result[0]['me'] = ltrim($result[0]['me'], '0');
- $result[0]['addDays'] = substr($result[0]['addDays'], 0, 10);
- $result[0]['substractYears'] = substr($result[0]['substractYears'], 0, 10);
- $expected = [
- 'd' => '18',
- 'm' => '3',
- 'y' => '2007',
- 'de' => '18',
- 'me' => '3',
- 'ye' => '2007',
- 'wd' => '1', // Sunday
- 'dow' => '1',
- 'addDays' => '2007-03-20',
- 'substractYears' => '2005-03-18'
- ];
- $this->assertEquals($expected, $result[0]);
- }
- /**
- * Tests that default types are passed to functions accepting a $types param
- *
- * @return void
- */
- public function testDefaultTypes()
- {
- $query = new Query($this->connection);
- $this->assertEquals([], $query->defaultTypes());
- $types = ['id' => 'integer', 'created' => 'datetime'];
- $this->assertSame($query, $query->defaultTypes($types));
- $this->assertSame($types, $query->defaultTypes());
- $results = $query->select(['id', 'comment'])
- ->from('comments')
- ->where(['created >=' => new \DateTime('2007-03-18 10:55:00')])
- ->execute();
- $expected = [['id' => '6', 'comment' => 'Second Comment for Second Article']];
- $this->assertEquals($expected, $results->fetchAll('assoc'));
- // Now test default can be overridden
- $types = ['created' => 'date'];
- $results = $query
- ->where(['created >=' => new \DateTime('2007-03-18 10:50:00')], $types, true)
- ->execute();
- $this->assertCount(6, $results, 'All 6 rows should match.');
- }
- /**
- * Tests parameter binding
- *
- * @return void
- */
- public function testBind()
- {
- $query = new Query($this->connection);
- $results = $query->select(['id', 'comment'])
- ->from('comments')
- ->where(['created BETWEEN :foo AND :bar'])
- ->bind(':foo', new \DateTime('2007-03-18 10:50:00'), 'datetime')
- ->bind(':bar', new \DateTime('2007-03-18 10:52:00'), 'datetime')
- ->execute();
- $expected = [['id' => '4', 'comment' => 'Fourth Comment for First Article']];
- $this->assertEquals($expected, $results->fetchAll('assoc'));
- $query = new Query($this->connection);
- $results = $query->select(['id', 'comment'])
- ->from('comments')
- ->where(['created BETWEEN :foo AND :bar'])
- ->bind(':foo', '2007-03-18 10:50:00')
- ->bind(':bar', '2007-03-18 10:52:00')
- ->execute();
- $this->assertEquals($expected, $results->fetchAll('assoc'));
- }
- /**
- * Test that epilog() will actually append a string to a select query
- *
- * @return void
- */
- public function testAppendSelect()
- {
- $query = new Query($this->connection);
- $sql = $query
- ->select(['id', 'title'])
- ->from('articles')
- ->where(['id' => 1])
- ->epilog('FOR UPDATE')
- ->sql();
- $this->assertContains('SELECT', $sql);
- $this->assertContains('FROM', $sql);
- $this->assertContains('WHERE', $sql);
- $this->assertEquals(' FOR UPDATE', substr($sql, -11));
- }
- /**
- * Test that epilog() will actually append a string to an insert query
- *
- * @return void
- */
- public function testAppendInsert()
- {
- $query = new Query($this->connection);
- $sql = $query
- ->insert(['id', 'title'])
- ->into('articles')
- ->values([1, 'a title'])
- ->epilog('RETURNING id')
- ->sql();
- $this->assertContains('INSERT', $sql);
- $this->assertContains('INTO', $sql);
- $this->assertContains('VALUES', $sql);
- $this->assertEquals(' RETURNING id', substr($sql, -13));
- }
- /**
- * Test that epilog() will actually append a string to an update query
- *
- * @return void
- */
- public function testAppendUpdate()
- {
- $query = new Query($this->connection);
- $sql = $query
- ->update('articles')
- ->set(['title' => 'foo'])
- ->where(['id' => 1])
- ->epilog('RETURNING id')
- ->sql();
- $this->assertContains('UPDATE', $sql);
- $this->assertContains('SET', $sql);
- $this->assertContains('WHERE', $sql);
- $this->assertEquals(' RETURNING id', substr($sql, -13));
- }
- /**
- * Test that epilog() will actually append a string to a delete query
- *
- * @return void
- */
- public function testAppendDelete()
- {
- $query = new Query($this->connection);
- $sql = $query
- ->delete('articles')
- ->where(['id' => 1])
- ->epilog('RETURNING id')
- ->sql();
- $this->assertContains('DELETE FROM', $sql);
- $this->assertContains('WHERE', $sql);
- $this->assertEquals(' RETURNING id', substr($sql, -13));
- }
- /**
- * Tests automatic identifier quoting in the select clause
- *
- * @return void
- */
- public function testQuotingSelectFieldsAndAlias()
- {
- $this->connection->driver()->autoQuoting(true);
- $query = new Query($this->connection);
- $sql = $query->select(['something'])->sql();
- $this->assertQuotedQuery('SELECT <something>$', $sql);
- $query = new Query($this->connection);
- $sql = $query->select(['foo' => 'something'])->sql();
- $this->assertQuotedQuery('SELECT <something> AS <foo>$', $sql);
- $query = new Query($this->connection);
- $sql = $query->select(['foo' => 1])->sql();
- $this->assertQuotedQuery('SELECT 1 AS <foo>$', $sql);
- $query = new Query($this->connection);
- $sql = $query->select(['foo' => '1 + 1'])->sql();
- $this->assertQuotedQuery('SELECT <1 \+ 1> AS <foo>$', $sql);
- $query = new Query($this->connection);
- $sql = $query->select(['foo' => $query->newExpr('1 + 1')])->sql();
- $this->assertQuotedQuery('SELECT \(1 \+ 1\) AS <foo>$', $sql);
- $query = new Query($this->connection);
- $sql = $query->select(['foo' => new IdentifierExpression('bar')])->sql();
- $this->assertQuotedQuery('<bar>', $sql);
- }
- /**
- * Tests automatic identifier quoting in the from clause
- *
- * @return void
- */
- public function testQuotingFromAndAlias()
- {
- $this->connection->driver()->autoQuoting(true);
- $query = new Query($this->connection);
- $sql = $query->select('*')->from(['something'])->sql();
- $this->assertQuotedQuery('FROM <something>', $sql);
- $query = new Query($this->connection);
- $sql = $query->select('*')->from(['foo' => 'something'])->sql();
- $this->assertQuotedQuery('FROM <something> <foo>$', $sql);
- $query = new Query($this->connection);
- $sql = $query->select('*')->from(['foo' => $query->newExpr('bar')])->sql();
- $this->assertQuotedQuery('FROM \(bar\) <foo>$', $sql);
- }
- /**
- * Tests automatic identifier quoting for DISTINCT ON
- *
- * @return void
- */
- public function testQuotingDistinctOn()
- {
- $this->connection->driver()->autoQuoting(true);
- $query = new Query($this->connection);
- $sql = $query->select('*')->distinct(['something'])->sql();
- $this->assertQuotedQuery('<something>', $sql);
- }
- /**
- * Tests automatic identifier quoting in the join clause
- *
- * @return void
- */
- public function testQuotingJoinsAndAlias()
- {
- $this->connection->driver()->autoQuoting(true);
- $query = new Query($this->connection);
- $sql = $query->select('*')->join(['something'])->sql();
- $this->assertQuotedQuery('JOIN <something>', $sql);
- $query = new Query($this->connection);
- $sql = $query->select('*')->join(['foo' => 'something'])->sql();
- $this->assertQuotedQuery('JOIN <something> <foo>', $sql);
- $query = new Query($this->connection);
- $sql = $query->select('*')->join(['foo' => $query->newExpr('bar')])->sql();
- $this->assertQuotedQuery('JOIN \(bar\) <foo>', $sql);
- }
- /**
- * Tests automatic identifier quoting in the group by clause
- *
- * @return void
- */
- public function testQuotingGroupBy()
- {
- $this->connection->driver()->autoQuoting(true);
- $query = new Query($this->connection);
- $sql = $query->select('*')->group(['something'])->sql();
- $this->assertQuotedQuery('GROUP BY <something>', $sql);
- $query = new Query($this->connection);
- $sql = $query->select('*')->group([$query->newExpr('bar')])->sql();
- $this->assertQuotedQuery('GROUP BY \(bar\)', $sql);
- $query = new Query($this->connection);
- $sql = $query->select('*')->group([new IdentifierExpression('bar')])->sql();
- $this->assertQuotedQuery('GROUP BY \(<bar>\)', $sql);
- }
- /**
- * Tests automatic identifier quoting strings inside conditions expressions
- *
- * @return void
- */
- public function testQuotingExpressions()
- {
- $this->connection->driver()->autoQuoting(true);
- $query = new Query($this->connection);
- $sql = $query->select('*')
- ->where(['something' => 'value'])
- ->sql();
- $this->assertQuotedQuery('WHERE <something> = :c0', $sql);
- $query = new Query($this->connection);
- $sql = $query->select('*')
- ->where([
- 'something' => 'value',
- 'OR' => ['foo' => 'bar', 'baz' => 'cake']
- ])
- ->sql();
- $this->assertQuotedQuery('<something> = :c0 AND', $sql);
- $this->assertQuotedQuery('\(<foo> = :c1 OR <baz> = :c2\)', $sql);
- }
- /**
- * Tests that insert query parts get quoted automatically
- *
- * @return void
- */
- public function testQuotingInsert()
- {
- $this->connection->driver()->autoQuoting(true);
- $query = new Query($this->connection);
- $sql = $query->insert(['bar', 'baz'])
- ->into('foo')
- ->where(['something' => 'value'])
- ->sql();
- $this->assertQuotedQuery('INSERT INTO <foo> \(<bar>, <baz>\)', $sql);
- $query = new Query($this->connection);
- $sql = $query->insert([$query->newExpr('bar')])
- ->into('foo')
- ->where(['something' => 'value'])
- ->sql();
- $this->assertQuotedQuery('INSERT INTO <foo> \(\(bar\)\)', $sql);
- }
- /**
- * Tests converting a query to a string
- *
- * @return void
- */
- public function testToString()
- {
- $query = new Query($this->connection);
- $query
- ->select(['title'])
- ->from('articles');
- $result = (string)$query;
- $this->assertQuotedQuery('SELECT <title> FROM <articles>', $result, !$this->autoQuote);
- }
- /**
- * Tests __debugInfo
- *
- * @return void
- */
- public function testDebugInfo()
- {
- $query = (new Query($this->connection))->select('*')
- ->from('articles')
- ->defaultTypes(['id' => 'integer'])
- ->where(['id' => '1']);
- $expected = [
- '(help)' => 'This is a Query object, to get the results execute or iterate it.',
- 'sql' => $query->sql(),
- 'params' => [
- ':c0' => ['value' => '1', 'type' => 'integer', 'placeholder' => 'c0']
- ],
- 'defaultTypes' => ['id' => 'integer'],
- 'decorators' => 0,
- 'executed' => false
- ];
- $result = $query->__debugInfo();
- $this->assertEquals($expected, $result);
- $query->execute();
- $expected = [
- '(help)' => 'This is a Query object, to get the results execute or iterate it.',
- 'sql' => $query->sql(),
- 'params' => [
- ':c0' => ['value' => '1', 'type' => 'integer', 'placeholder' => 'c0']
- ],
- 'defaultTypes' => ['id' => 'integer'],
- 'decorators' => 0,
- 'executed' => true
- ];
- $result = $query->__debugInfo();
- $this->assertEquals($expected, $result);
- }
- /**
- * Tests that it is possible to pass ExpressionInterface to isNull and isNotNull
- *
- * @return void
- */
- public function testIsNullWithExpressions()
- {
- $query = new Query($this->connection);
- $subquery = (new Query($this->connection))
- ->select(['id'])
- ->from('authors')
- ->where(['id' => 1]);
- $result = $query
- ->select(['name'])
- ->from(['authors'])
- ->where(function ($exp) use ($subquery) {
- return $exp->isNotNull($subquery);
- })
- ->execute();
- $this->assertNotEmpty($result->fetchAll('assoc'));
- $result = (new Query($this->connection))
- ->select(['name'])
- ->from(['authors'])
- ->where(function ($exp) use ($subquery) {
- return $exp->isNull($subquery);
- })
- ->execute();
- $this->assertEmpty($result->fetchAll('assoc'));
- }
- /**
- * Tests that strings passed to isNull and isNotNull will be treated as identifiers
- * when using autoQuoting
- *
- * @return void
- */
- public function testIsNullAutoQuoting()
- {
- $this->connection->driver()->autoQuoting(true);
- $query = new Query($this->connection);
- $query->select('*')->from('things')->where(function ($exp) {
- return $exp->isNull('field');
- });
- $this->assertQuotedQuery('WHERE \(<field>\) IS NULL', $query->sql());
- $query = new Query($this->connection);
- $query->select('*')->from('things')->where(function ($exp) {
- return $exp->isNotNull('field');
- });
- $this->assertQuotedQuery('WHERE \(<field>\) IS NOT NULL', $query->sql());
- }
- /**
- * Tests that using the IS operator will automatically translate to the best
- * possible operator depending on the passed value
- *
- * @return void
- */
- public function testDirectIsNull()
- {
- $sql = (new Query($this->connection))
- ->select(['name'])
- ->from(['authors'])
- ->where(['name IS' => null])
- ->sql();
- $this->assertQuotedQuery('WHERE \(<name>\) IS NULL', $sql, !$this->autoQuote);
- $results = (new Query($this->connection))
- ->select(['name'])
- ->from(['authors'])
- ->where(['name IS' => 'larry'])
- ->execute();
- $this->assertCount(1, $results);
- $this->assertEquals(['name' => 'larry'], $results->fetch('assoc'));
- }
- /**
- * Tests that using the IS NOT operator will automatically translate to the best
- * possible operator depending on the passed value
- *
- * @return void
- */
- public function testDirectIsNotNull()
- {
- $sql = (new Query($this->connection))
- ->select(['name'])
- ->from(['authors'])
- ->where(['name IS NOT' => null])
- ->sql();
- $this->assertQuotedQuery('WHERE \(<name>\) IS NOT NULL', $sql, !$this->autoQuote);
- $results = (new Query($this->connection))
- ->select(['name'])
- ->from(['authors'])
- ->where(['name IS NOT' => 'larry'])
- ->execute();
- $this->assertCount(3, $results);
- $this->assertNotEquals(['name' => 'larry'], $results->fetch('assoc'));
- }
- /**
- * Tests that case statements work correctly for various use-cases.
- *
- * @return void
- */
- public function testSqlCaseStatement()
- {
- $query = new Query($this->connection);
- $publishedCase = $query
- ->newExpr()
- ->addCase(
- $query
- ->newExpr()
- ->add(['published' => 'Y']),
- 1,
- 'integer'
- );
- $notPublishedCase = $query
- ->newExpr()
- ->addCase(
- $query
- ->newExpr()
- ->add(['published' => 'N']),
- 1,
- 'integer'
- );
- //Postgres requires the case statement to be cast to a integer
- if ($this->connection->driver() instanceof \Cake\Database\Driver\Postgres) {
- $publishedCase = $query->func()->cast([$publishedCase, 'integer' => 'literal'])->type(' AS ');
- $notPublishedCase = $query->func()->cast([$notPublishedCase, 'integer' => 'literal'])->type(' AS ');
- }
- $results = $query
- ->select([
- 'published' => $query->func()->sum($publishedCase),
- 'not_published' => $query->func()->sum($notPublishedCase)
- ])
- ->from(['comments'])
- ->execute()
- ->fetchAll('assoc');
- $this->assertEquals(5, $results[0]['published']);
- $this->assertEquals(1, $results[0]['not_published']);
- $query = new Query($this->connection);
- $query
- ->insert(['article_id', 'user_id', 'comment', 'published'])
- ->into('comments')
- ->values([
- 'article_id' => 2,
- 'user_id' => 1,
- 'comment' => 'In limbo',
- 'published' => 'L'
- ])
- ->execute()
- ->closeCursor();
- $query = new Query($this->connection);
- $conditions = [
- $query
- ->newExpr()
- ->add(['published' => 'Y']),
- $query
- ->newExpr()
- ->add(['published' => 'N'])
- ];
- $values = [
- 'Published',
- 'Not published',
- 'None'
- ];
- $results = $query
- ->select([
- 'id',
- 'comment',
- 'status' => $query->newExpr()->addCase($conditions, $values)
- ])
- ->from(['comments'])
- ->execute()
- ->fetchAll('assoc');
- $this->assertEquals('Published', $results[2]['status']);
- $this->assertEquals('Not published', $results[3]['status']);
- $this->assertEquals('None', $results[6]['status']);
- }
- /**
- * Shows that bufferResults(false) will prevent client-side results buffering
- *
- * @return void
- */
- public function testUnbufferedQuery()
- {
- $query = new Query($this->connection);
- $result = $query->select(['body', 'author_id'])
- ->from('articles')
- ->bufferResults(false)
- ->execute();
- if (!method_exists($result, 'bufferResults')) {
- $result->closeCursor();
- $this->markTestSkipped('This driver does not support unbuffered queries');
- }
- $this->assertCount(0, $result, 'Unbuffered queries only have a count when results are fetched');
- $list = $result->fetchAll('assoc');
- $this->assertCount(3, $list);
- $result->closeCursor();
- $query = new Query($this->connection);
- $result = $query->select(['body', 'author_id'])
- ->from('articles')
- ->execute();
- $this->assertCount(3, $result, 'Buffered queries can be counted any time.');
- $list = $result->fetchAll('assoc');
- $this->assertCount(3, $list);
- $result->closeCursor();
- }
- /**
- * Test that cloning goes deep.
- *
- * @return void
- */
- public function testDeepClone()
- {
- $query = new Query($this->connection);
- $query->select(['id', 'title' => $query->func()->concat(['title' => 'literal', 'test'])])
- ->from('articles')
- ->where(['Articles.id' => 1])
- ->offset(10)
- ->limit(1)
- ->order(['Articles.id' => 'DESC']);
- $dupe = clone $query;
- $this->assertEquals($query->clause('where'), $dupe->clause('where'));
- $this->assertNotSame($query->clause('where'), $dupe->clause('where'));
- $dupe->where(['Articles.title' => 'thinger']);
- $this->assertNotEquals($query->clause('where'), $dupe->clause('where'));
- $this->assertNotSame(
- $query->clause('select')['title'],
- $dupe->clause('select')['title']
- );
- $this->assertEquals($query->clause('order'), $dupe->clause('order'));
- $this->assertNotSame($query->clause('order'), $dupe->clause('order'));
- $query->order(['Articles.title' => 'ASC']);
- $this->assertNotEquals($query->clause('order'), $dupe->clause('order'));
- $this->assertNotSame(
- $query->selectTypeMap(),
- $dupe->selectTypeMap()
- );
- }
- /**
- * Tests the selectTypeMap method
- *
- * @return void
- */
- public function testSelectTypeMap()
- {
- $query = new Query($this->connection);
- $typeMap = $query->selectTypeMap();
- $this->assertInstanceOf(TypeMap::class, $typeMap);
- $another = clone $typeMap;
- $query->selectTypeMap($another);
- $this->assertSame($another, $query->selectTypeMap());
- }
- /**
- * Tests the automatic type conversion for the fields in the result
- *
- * @return void
- */
- public function testSelectTypeConversion()
- {
- $query = new Query($this->connection);
- $query
- ->select(['id', 'comment', 'the_date' => 'created'])
- ->from('comments')
- ->limit(1)
- ->selectTypeMap()->types(['id' => 'integer', 'the_date' => 'datetime']);
- $result = $query->execute()->fetchAll('assoc');
- $this->assertInternalType('integer', $result[0]['id']);
- $this->assertInstanceOf('DateTime', $result[0]['the_date']);
- }
- /**
- * Test removeJoin().
- *
- * @return void
- */
- public function testRemoveJoin()
- {
- $query = new Query($this->connection);
- $query->select(['id', 'title'])
- ->from('articles')
- ->join(['authors' => [
- 'type' => 'INNER',
- 'conditions' => ['articles.author_id = authors.id']
- ]]);
- $this->assertArrayHasKey('authors', $query->join());
- $this->assertSame($query, $query->removeJoin('authors'));
- $this->assertArrayNotHasKey('authors', $query->join());
- }
- /**
- * Tests that types in the type map are used in the
- * specific comparison functions when using a callable
- *
- * @return void
- */
- public function testBetweenExpressionAndTypeMap()
- {
- $query = new Query($this->connection);
- $query->select('id')
- ->from('comments')
- ->defaultTypes(['created' => 'datetime'])
- ->where(function ($expr) {
- $from = new \DateTime('2007-03-18 10:45:00');
- $to = new \DateTime('2007-03-18 10:48:00');
- return $expr->between('created', $from, $to);
- });
- $this->assertCount(2, $query->execute()->fetchAll());
- }
- /**
- * Test use of modifiers in a INSERT query
- *
- * Testing the generated SQL since the modifiers are usually different per driver
- *
- * @return void
- */
- public function testInsertModifiers()
- {
- $query = new Query($this->connection);
- $result = $query
- ->insert(['title'])
- ->into('articles')
- ->values(['title' => 'foo'])
- ->modifier('IGNORE');
- $this->assertQuotedQuery(
- 'INSERT IGNORE INTO <articles> \(<title>\) VALUES \(:c0\)',
- $result->sql(),
- !$this->autoQuote
- );
- $query = new Query($this->connection);
- $result = $query
- ->insert(['title'])
- ->into('articles')
- ->values(['title' => 'foo'])
- ->modifier(['IGNORE', 'LOW_PRIORITY']);
- $this->assertQuotedQuery(
- 'INSERT IGNORE LOW_PRIORITY INTO <articles> \(<title>\) VALUES \(:c0\)',
- $result->sql(),
- !$this->autoQuote
- );
- }
- /**
- * Assertion for comparing a table's contents with what is in it.
- *
- * @param string $table
- * @param int $count
- * @param array $rows
- * @param array $conditions
- * @return void
- */
- public function assertTable($table, $count, $rows, $conditions = [])
- {
- $result = (new Query($this->connection))->select('*')
- ->from($table)
- ->where($conditions)
- ->execute();
- $this->assertCount($count, $result, 'Row count is incorrect');
- $this->assertEquals($rows, $result->fetchAll('assoc'));
- $result->closeCursor();
- }
- /**
- * Assertion for comparing a regex pattern against a query having its identifiers
- * quoted. It accepts queries quoted with the characters `<` and `>`. If the third
- * parameter is set to true, it will alter the pattern to both accept quoted and
- * unquoted queries
- *
- * @param string $pattern
- * @param string $query the result to compare against
- * @param bool $optional
- * @return void
- */
- public function assertQuotedQuery($pattern, $query, $optional = false)
- {
- if ($optional) {
- $optional = '?';
- }
- $pattern = str_replace('<', '[`"\[]' . $optional, $pattern);
- $pattern = str_replace('>', '[`"\]]' . $optional, $pattern);
- $this->assertRegExp('#' . $pattern . '#', $query);
- }
- }
|