| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474247524762477247824792480248124822483248424852486248724882489249024912492249324942495249624972498249925002501250225032504250525062507250825092510251125122513251425152516251725182519252025212522252325242525252625272528252925302531253225332534253525362537253825392540254125422543254425452546254725482549255025512552255325542555255625572558255925602561256225632564256525662567256825692570257125722573257425752576257725782579258025812582258325842585258625872588258925902591259225932594259525962597259825992600260126022603 |
- <?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\Datasource\ConnectionManager;
- use Cake\TestSuite\TestCase;
- /**
- * Tests Query class
- *
- */
- class QueryTest extends TestCase {
- public $fixtures = ['core.article', 'core.author', 'core.comment'];
- 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(array('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(array('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(array('body', 'author_id'))->from('articles')->execute();
- $this->assertEquals(array('body' => 'First Article Body', 'author_id' => 1), $result->fetch('assoc'));
- $this->assertEquals(array('body' => 'Second Article Body', 'author_id' => 3), $result->fetch('assoc'));
- //Append more tables to next execution
- $result = $query->select('name')->from(array('authors'))->order(['name' => 'desc', 'articles.id' => 'asc'])->execute();
- $this->assertEquals(array('body' => 'First Article Body', 'author_id' => 1, 'name' => 'nate'), $result->fetch('assoc'));
- $this->assertEquals(array('body' => 'Second Article Body', 'author_id' => 3, 'name' => 'nate'), $result->fetch('assoc'));
- $this->assertEquals(array('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(array('nate'), $result->fetch());
- $this->assertEquals(array('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' => 'body', 'author_id'])->from('articles')->execute();
- $this->assertEquals(array('text' => 'First Article Body', 'author_id' => 1), $result->fetch('assoc'));
- $this->assertEquals(array('text' => 'Second Article Body', 'author_id' => 3), $result->fetch('assoc'));
- $query = new Query($this->connection);
- $result = $query->select(['text' => 'body', 'author' => 'author_id'])->from('articles')->execute();
- $this->assertEquals(array('text' => 'First Article Body', 'author' => 1), $result->fetch('assoc'));
- $this->assertEquals(array('text' => 'Second Article Body', 'author' => 3), $result->fetch('assoc'));
- $query = new Query($this->connection);
- $query->select(['text' => 'body'])->select(['author_id', 'foo' => 'body']);
- $result = $query->from('articles')->execute();
- $this->assertEquals(array('foo' => 'First Article Body', 'text' => 'First Article Body', 'author_id' => 1), $result->fetch('assoc'));
- $this->assertEquals(array('foo' => 'Second Article Body', 'text' => 'Second Article Body', 'author_id' => 3), $result->fetch('assoc'));
- $query = new Query($this->connection);
- $exp = $query->newExpr()->add('1 + 1');
- $comp = $query->newExpr()->add(['author_id +' => 2]);
- $result = $query->select(['text' => 'body', 'two' => $exp, 'three' => $comp])
- ->from('articles')->execute();
- $this->assertEquals(array('text' => 'First Article Body', 'two' => 2, 'three' => 3), $result->fetch('assoc'));
- $this->assertEquals(array('text' => 'Second Article Body', 'two' => 2, 'three' => 5), $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' => 'author_id = a.id'])
- ->order(['title' => 'asc'])
- ->execute();
- $this->assertCount(3, $result);
- $this->assertEquals(array('title' => 'First Article', 'name' => 'mariano'), $result->fetch('assoc'));
- $this->assertEquals(array('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' => 'author_id = authors.id']
- ], [], true)->execute();
- $this->assertCount(3, $result);
- $this->assertEquals(array('title' => 'First Article', 'name' => 'mariano'), $result->fetch('assoc'));
- $this->assertEquals(array('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' => ['author_id = a.id']])
- ->order(['title' => 'asc'])
- ->execute();
- $this->assertEquals(array('title' => 'First Article', 'name' => 'mariano'), $result->fetch('assoc'));
- $this->assertEquals(array('title' => 'Second Article', 'name' => 'larry'), $result->fetch('assoc'));
- $query = new Query($this->connection);
- $conditions = $query->newExpr()->add('author_id = a.id');
- $result = $query
- ->select(['title', 'name'])
- ->from('articles')
- ->join(['table' => 'authors', 'alias' => 'a', 'conditions' => $conditions])
- ->order(['title' => 'asc'])
- ->execute();
- $this->assertEquals(array('title' => 'First Article', 'name' => 'mariano'), $result->fetch('assoc'));
- $this->assertEquals(array('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(array('title' => 'First Article', 'name' => 'nate'), $result->fetch('assoc'));
- $this->assertEquals(array('title' => 'Second Article', 'name' => 'nate'), $result->fetch('assoc'));
- $query = new Query($this->connection);
- $conditions = $query->newExpr()->add('author_id = a.id');
- $result = $query
- ->select(['title', 'name'])
- ->from('articles')
- ->join(['a' => ['table' => 'authors', 'conditions' => $conditions]])
- ->order(['title' => 'asc'])
- ->execute();
- $this->assertEquals(array('title' => 'First Article', 'name' => 'mariano'), $result->fetch('assoc'));
- $this->assertEquals(array('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(array('title' => 'First Article', 'name' => 'First 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);
- $query = new Query($this->connection);
- $result = $query
- ->select(['title'])
- ->from('articles')
- ->where(['id' => 100], ['id' => 'integer'])
- ->execute();
- $this->assertCount(0, $result);
- }
- /**
- * Tests using where conditions with operators and scalar values works
- *
- * @return void
- */
- public function testSelectWhereOperators() {
- $query = new Query($this->connection);
- $result = $query
- ->select(['title'])
- ->from('articles')
- ->where(['id >' => 1])
- ->execute();
- $this->assertCount(2, $result);
- $this->assertEquals(array('title' => 'Second Article'), $result->fetch('assoc'));
- $query = new Query($this->connection);
- $result = $query
- ->select(['title'])
- ->from('articles')
- ->where(['id <' => 2])
- ->execute();
- $this->assertCount(1, $result);
- $this->assertEquals(array('title' => 'First Article'), $result->fetch('assoc'));
- $query = new Query($this->connection);
- $result = $query
- ->select(['title'])
- ->from('articles')
- ->where(['id <=' => 2])
- ->execute();
- $this->assertCount(2, $result);
- $query = new Query($this->connection);
- $result = $query
- ->select(['title'])
- ->from('articles')
- ->where(['id >=' => 1])
- ->execute();
- $this->assertCount(3, $result);
- $query = new Query($this->connection);
- $result = $query
- ->select(['title'])
- ->from('articles')
- ->where(['id <=' => 1])
- ->execute();
- $this->assertCount(1, $result);
- $query = new Query($this->connection);
- $result = $query
- ->select(['title'])
- ->from('articles')
- ->where(['id !=' => 2])
- ->execute();
- $this->assertCount(2, $result);
- $this->assertEquals(array('title' => 'First Article'), $result->fetch('assoc'));
- $query = new Query($this->connection);
- $result = $query
- ->select(['title'])
- ->from('articles')
- ->where(['title LIKE' => 'First Article'])
- ->execute();
- $this->assertCount(1, $result);
- $this->assertEquals(array('title' => 'First Article'), $result->fetch('assoc'));
- $query = new Query($this->connection);
- $result = $query
- ->select(['title'])
- ->from('articles')
- ->where(['title like' => '%Article%'])
- ->execute();
- $this->assertCount(3, $result);
- $query = new Query($this->connection);
- $result = $query
- ->select(['title'])
- ->from('articles')
- ->where(['title not like' => '%Article%'])
- ->execute();
- $this->assertCount(0, $result);
- }
- /**
- * 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(array('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 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,
- true
- );
- }
- /**
- * 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 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(array('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(array('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(array('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(array('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'));
- $query = new Query($this->connection);
- $result = $query
- ->select(['id'])
- ->from('comments')
- ->where(function($exp, $q) {
- return $exp->in(
- 'created',
- $q->newExpr()->add("'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, $q) {
- return $exp->notIn(
- 'created',
- $q->newExpr()->add("'2007-03-18 10:45:23'"),
- 'datetime'
- );
- })
- ->execute();
- $this->assertCount(5, $result);
- }
- /**
- * 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'));
- $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);
- }
- /**
- * 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()
- ->add(['(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'));
- }
- /**
- * 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 an specific implementation for DISTINCT ON
- *
- * @return void
- */
- public function testSelectDistinctON() {
- $this->skipIf(
- $this->connection->driver() instanceof \Cake\Database\Driver\Sqlserver,
- 'Not implemented yet in SqlServer'
- );
- $query = new Query($this->connection);
- $result = $query
- ->select(['id', 'author_id'])
- ->distinct(['author_id'])
- ->from(['a' => 'articles'])
- ->execute();
- $this->assertCount(2, $result);
- }
- /**
- * 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(),
- true
- );
- $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(),
- true
- );
- $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(),
- true
- );
- }
- /**
- * 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' => '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' => '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' => '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' => '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' => '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' => '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' => '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'));
- }
- /**
- * 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)
- ->execute();
- $this->assertCount(1, $result);
- $this->assertEquals(['id' => 2], $result->fetch('assoc'));
- $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(['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'));
- $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'));
- }
- /**
- * Tests that it is possible to use a subquery in a join clause
- *
- * @return void
- */
- public function testSubqueyInJoin() {
- $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');
- $subquery->where(['id' => 1]);
- $result = $query->execute();
- $this->assertCount(3, $result);
- $query->join(['b' => ['table' => $subquery, 'conditions' => ['b.id = articles.id']]], [], true);
- $result = $query->execute();
- $this->assertCount(1, $result);
- }
- /**
- * 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();
- $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());
- $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());
- }
- /**
- * 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();
- $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());
- }
- /**
- * 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 = $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);
- }
- }
- /**
- * 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, true);
- $result = $query->execute();
- $this->assertInstanceOf('Cake\Database\StatementInterface', $result);
- $this->assertCount(self::AUTHOR_COUNT, $result);
- }
- /**
- * 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, true);
- $result = $query->execute();
- $this->assertInstanceOf('Cake\Database\StatementInterface', $result);
- $this->assertCount(self::AUTHOR_COUNT, $result);
- }
- /**
- * 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, true);
- $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, true);
- $result = $query->execute();
- $this->assertCount(1, $result);
- }
- /**
- * 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,
- true
- );
- $this->assertQuotedQuery(' WHERE <id> = :c2$', $result, true);
- $result = $query->execute();
- $this->assertCount(1, $result);
- }
- /**
- * 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,
- true
- );
- $this->assertQuotedQuery('WHERE <id> = :', $result, true);
- $result = $query->execute();
- $this->assertCount(1, $result);
- }
- /**
- * Test updates with an expression.
- *
- * @return void
- */
- public function testUpdateWithExpression() {
- $query = new Query($this->connection);
- $expr = $query->newExpr();
- $expr->add('title = author_id');
- $query->update('articles')
- ->set($expr)
- ->where(['id' => 1]);
- $result = $query->sql();
- $this->assertQuotedQuery(
- 'UPDATE <articles> SET title = author_id WHERE <id> = :',
- $result,
- true
- );
- $result = $query->execute();
- $this->assertCount(1, $result);
- }
- /**
- * 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,
- true
- );
- $this->assertQuotedQuery(' WHERE <id> = :c2$', $result, true);
- $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);
- }
- /**
- * You cannot call values() before insert() it causes all sorts of pain.
- *
- * @expectedException \Cake\Error\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>\) ' .
- 'VALUES \(\?, \?\)',
- $result,
- true
- );
- $result = $query->execute();
- $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>\) ' .
- 'VALUES \(\?, \?\)',
- $result,
- true
- );
- $result = $query->execute();
- $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();
- $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>\) SELECT',
- $result,
- true
- );
- $this->assertQuotedQuery(
- 'SELECT <name>, \'some text\', 99 FROM <authors>', $result, true);
- $result = $query->execute();
- $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\Error\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\Error\Exception
- */
- public function testInsertFailureMixingTypesQueryFirst() {
- $query = new Query($this->connection);
- $query->insert(['name'])
- ->into('articles')
- ->values(new Query($this->connection))
- ->values(['name' => 'mark']);
- }
- /**
- * 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('articles')
- ->execute();
- $expected = [['total' => 3]];
- $this->assertEquals($expected, $result->fetchAll('assoc'));
- $query = new Query($this->connection);
- $result = $query->select([
- 'c' => $query->func()->concat(['title' => 'literal', ' is appended'])
- ])
- ->from('articles')
- ->order(['c' => 'ASC'])
- ->execute();
- $expected = [
- ['c' => 'First Article is appended'],
- ['c' => 'Second Article is appended'],
- ['c' => 'Third 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->assertWithinMargin(
- 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->assertWithinMargin(
- date('U'),
- (new \DateTime($result->fetchAll('assoc')[0]['d']))->format('U'),
- 1
- );
- }
- /**
- * 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()->add('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> AS <foo>$', $sql);
- $query = new Query($this->connection);
- $sql = $query->select('*')->from(['foo' => $query->newExpr()->add('bar')])->sql();
- $this->assertQuotedQuery('FROM \(bar\) AS <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()->add('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()->add('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()->add('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, true);
- }
- /**
- * Tests __debugInfo
- *
- * @return void
- */
- public function testDebugInfo() {
- $query = (new Query($this->connection))->select('*')
- ->from('articles')
- ->defaultTypes(['id' => 'integer'])
- ->where(['id' => '1']);
- $expected = [
- '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 = [
- 'sql' => $query->sql(),
- 'params' => [
- ':c0' => ['value' => '1', 'type' => 'integer', 'placeholder' => 'c0']
- ],
- 'defaultTypes' => ['id' => 'integer'],
- 'decorators' => 0,
- 'executed' => true
- ];
- $result = $query->__debugInfo();
- }
- /**
- * 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());
- }
- /**
- * 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'));
- }
- /**
- * Assertion for comparing a regex pattern against a query having its indentifiers
- * 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);
- }
- }
|