RedisCommandsTest.php 49 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352
  1. <?php
  2. define('I_AM_AWARE_OF_THE_DESTRUCTIVE_POWER_OF_THIS_TEST_SUITE', false);
  3. require_once 'PHPUnit/Framework.php';
  4. require_once 'PredisShared.php';
  5. class RedisCommandTestSuite extends PHPUnit_Framework_TestCase {
  6. public $redis;
  7. // TODO: instead of an boolean assertion against the return value
  8. // of RC::sameValuesInArrays, we should extend PHPUnit with
  9. // a new assertion, e.g. $this->assertSameValues();
  10. // TODO: an option to skip certain tests such as testFlushDatabases
  11. // should be provided.
  12. // TODO: missing test with float values for a few commands
  13. protected function setUp() {
  14. $this->redis = RC::getConnection();
  15. $this->redis->flushDatabase();
  16. }
  17. protected function tearDown() {
  18. }
  19. protected function onNotSuccessfulTest($exception) {
  20. // drops and reconnect to a redis server on uncaught exceptions
  21. RC::resetConnection();
  22. parent::onNotSuccessfulTest($exception);
  23. }
  24. /* miscellaneous commands */
  25. function testPing() {
  26. $this->assertTrue($this->redis->ping());
  27. }
  28. function testEcho() {
  29. $string = 'This is an echo test!';
  30. $this->assertEquals($string, $this->redis->echo($string));
  31. }
  32. function testQuit() {
  33. $this->redis->quit();
  34. $this->assertFalse($this->redis->isConnected());
  35. }
  36. function testMultiExec() {
  37. // NOTE: due to a limitation in the current implementation of Predis_Client,
  38. // the replies returned by Predis_Command_Exec are not parsed by their
  39. // respective Predis_Command::parseResponse methods. If you need that
  40. // kind of behaviour, you should use an instance of Predis_MultiExecBlock.
  41. $this->assertTrue($this->redis->multi());
  42. $this->assertType('Predis_ResponseQueued', $this->redis->ping());
  43. $this->assertType('Predis_ResponseQueued', $this->redis->echo('hello'));
  44. $this->assertType('Predis_ResponseQueued', $this->redis->echo('redis'));
  45. $this->assertEquals(array('PONG', 'hello', 'redis'), $this->redis->exec());
  46. $this->assertTrue($this->redis->multi());
  47. $this->assertEquals(array(), $this->redis->exec());
  48. // should throw an exception when trying to EXEC without having previously issued MULTI
  49. RC::testForServerException($this, RC::EXCEPTION_EXEC_NO_MULTI, p_anon("\$test", "
  50. \$test->redis->exec();
  51. "));
  52. }
  53. /* commands operating on string values */
  54. function testSet() {
  55. $this->assertTrue($this->redis->set('foo', 'bar'));
  56. $this->assertEquals('bar', $this->redis->get('foo'));
  57. }
  58. function testGet() {
  59. $this->redis->set('foo', 'bar');
  60. $this->assertEquals('bar', $this->redis->get('foo'));
  61. $this->assertNull($this->redis->get('fooDoesNotExist'));
  62. // should throw an exception when trying to do a GET on non-string types
  63. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  64. \$test->redis->pushTail('metavars', 'foo');
  65. \$test->redis->get('metavars');
  66. "));
  67. }
  68. function testExists() {
  69. $this->redis->set('foo', 'bar');
  70. $this->assertTrue($this->redis->exists('foo'));
  71. $this->assertFalse($this->redis->exists('key_does_not_exist'));
  72. }
  73. function testSetPreserve() {
  74. $multi = RC::getKeyValueArray();
  75. $this->assertTrue($this->redis->setPreserve('foo', 'bar'));
  76. $this->assertFalse($this->redis->setPreserve('foo', 'rab'));
  77. $this->assertEquals('bar', $this->redis->get('foo'));
  78. }
  79. function testMultipleSetAndGet() {
  80. $multi = RC::getKeyValueArray();
  81. // key=>value pairs via array instance
  82. $this->assertTrue($this->redis->setMultiple($multi));
  83. $multiRet = $this->redis->getMultiple(array_keys($multi));
  84. $this->assertEquals($multi, array_combine(array_keys($multi), array_values($multiRet)));
  85. // key=>value pairs via function arguments
  86. $this->assertTrue($this->redis->setMultiple('a', 1, 'b', 2, 'c', 3));
  87. $this->assertEquals(array(1, 2, 3), $this->redis->getMultiple('a', 'b', 'c'));
  88. }
  89. function testSetMultiplePreserve() {
  90. $multi = RC::getKeyValueArray();
  91. $newpair = array('hogehoge' => 'piyopiyo');
  92. $hijacked = array('foo' => 'baz', 'hoge' => 'fuga');
  93. // successful set
  94. $expectedResult = array_merge($multi, $newpair);
  95. $this->redis->setMultiple($multi);
  96. $this->assertTrue($this->redis->setMultiplePreserve($newpair));
  97. $this->assertEquals(
  98. array_values($expectedResult),
  99. $this->redis->getMultiple(array_keys($expectedResult))
  100. );
  101. $this->redis->flushDatabase();
  102. // unsuccessful set
  103. $expectedResult = array_merge($multi, array('hogehoge' => null));
  104. $this->redis->setMultiple($multi);
  105. $this->assertFalse($this->redis->setMultiplePreserve(array_merge($newpair, $hijacked)));
  106. $this->assertEquals(
  107. array_values($expectedResult),
  108. $this->redis->getMultiple(array_keys($expectedResult))
  109. );
  110. }
  111. function testGetSet() {
  112. $this->assertNull($this->redis->getSet('foo', 'bar'));
  113. $this->assertEquals('bar', $this->redis->getSet('foo', 'barbar'));
  114. $this->assertEquals('barbar', $this->redis->getSet('foo', 'baz'));
  115. }
  116. function testIncrementAndIncrementBy() {
  117. // test subsequent increment commands
  118. $this->assertEquals(1, $this->redis->increment('foo'));
  119. $this->assertEquals(2, $this->redis->increment('foo'));
  120. // test subsequent incrementBy commands
  121. $this->assertEquals(22, $this->redis->incrementBy('foo', 20));
  122. $this->assertEquals(10, $this->redis->incrementBy('foo', -12));
  123. $this->assertEquals(-100, $this->redis->incrementBy('foo', -110));
  124. }
  125. function testDecrementAndDecrementBy() {
  126. // test subsequent decrement commands
  127. $this->assertEquals(-1, $this->redis->decrement('foo'));
  128. $this->assertEquals(-2, $this->redis->decrement('foo'));
  129. // test subsequent decrementBy commands
  130. $this->assertEquals(-22, $this->redis->decrementBy('foo', 20));
  131. $this->assertEquals(-10, $this->redis->decrementBy('foo', -12));
  132. $this->assertEquals(100, $this->redis->decrementBy('foo', -110));
  133. }
  134. function testDelete() {
  135. $this->redis->set('foo', 'bar');
  136. $this->assertTrue($this->redis->delete('foo'));
  137. $this->assertFalse($this->redis->exists('foo'));
  138. $this->assertFalse($this->redis->delete('foo'));
  139. }
  140. function testType() {
  141. $this->assertEquals('none', $this->redis->type('fooDoesNotExist'));
  142. $this->redis->set('fooString', 'bar');
  143. $this->assertEquals('string', $this->redis->type('fooString'));
  144. $this->redis->pushTail('fooList', 'bar');
  145. $this->assertEquals('list', $this->redis->type('fooList'));
  146. $this->redis->setAdd('fooSet', 'bar');
  147. $this->assertEquals('set', $this->redis->type('fooSet'));
  148. $this->redis->zsetAdd('fooZSet', 'bar', 0);
  149. $this->assertEquals('zset', $this->redis->type('fooZSet'));
  150. }
  151. /* commands operating on the key space */
  152. function testKeys() {
  153. $keyValsNs = RC::getNamespacedKeyValueArray();
  154. $keyValsOthers = array('aaa' => 1, 'aba' => 2, 'aca' => 3);
  155. $allKeyVals = array_merge($keyValsNs, $keyValsOthers);
  156. $this->redis->setMultiple($allKeyVals);
  157. $this->assertEquals(array(), $this->redis->keys('nokeys:*'));
  158. $keysFromRedis = $this->redis->keys('metavar:*');
  159. $this->assertEquals(array(), array_diff(array_keys($keyValsNs), $keysFromRedis));
  160. $keysFromRedis = $this->redis->keys('*');
  161. $this->assertEquals(array(), array_diff(array_keys($allKeyVals), $keysFromRedis));
  162. $keysFromRedis = $this->redis->keys('a?a');
  163. $this->assertEquals(array(), array_diff(array_keys($keyValsOthers), $keysFromRedis));
  164. }
  165. function testRandomKey() {
  166. $keyvals = RC::getKeyValueArray();
  167. $this->assertNull($this->redis->randomKey());
  168. $this->redis->setMultiple($keyvals);
  169. $this->assertTrue(in_array($this->redis->randomKey(), array_keys($keyvals)));
  170. }
  171. function testRename() {
  172. $this->redis->setMultiple(array('foo' => 'bar', 'foofoo' => 'barbar'));
  173. // rename existing keys
  174. $this->assertTrue($this->redis->rename('foo', 'foofoo'));
  175. $this->assertFalse($this->redis->exists('foo'));
  176. $this->assertEquals('bar', $this->redis->get('foofoo'));
  177. // should throw an excepion then trying to rename non-existing keys
  178. RC::testForServerException($this, RC::EXCEPTION_NO_SUCH_KEY, p_anon("\$test", "
  179. \$test->redis->rename('hoge', 'hogehoge');
  180. "));
  181. }
  182. function testRenamePreserve() {
  183. $this->redis->setMultiple(array('foo' => 'bar', 'hoge' => 'piyo', 'hogehoge' => 'piyopiyo'));
  184. $this->assertTrue($this->redis->renamePreserve('foo', 'foofoo'));
  185. $this->assertFalse($this->redis->exists('foo'));
  186. $this->assertEquals('bar', $this->redis->get('foofoo'));
  187. $this->assertFalse($this->redis->renamePreserve('hoge', 'hogehoge'));
  188. $this->assertTrue($this->redis->exists('hoge'));
  189. // should throw an excepion then trying to rename non-existing keys
  190. RC::testForServerException($this, RC::EXCEPTION_NO_SUCH_KEY, p_anon("\$test", "
  191. \$test->redis->renamePreserve('fuga', 'baz');
  192. "));
  193. }
  194. function testExpirationAndTTL() {
  195. $this->redis->set('foo', 'bar');
  196. // check for key expiration
  197. $this->assertTrue($this->redis->expire('foo', 1));
  198. $this->assertEquals(1, $this->redis->ttl('foo'));
  199. $this->assertTrue($this->redis->exists('foo'));
  200. sleep(2);
  201. $this->assertFalse($this->redis->exists('foo'));
  202. $this->assertEquals(-1, $this->redis->ttl('foo'));
  203. // check for consistent TTL values
  204. $this->redis->set('foo', 'bar');
  205. $this->assertTrue($this->redis->expire('foo', 100));
  206. sleep(3);
  207. $this->assertEquals(97, $this->redis->ttl('foo'));
  208. // delete key on negative TTL
  209. $this->redis->set('foo', 'bar');
  210. $this->assertTrue($this->redis->expire('foo', -100));
  211. $this->assertFalse($this->redis->exists('foo'));
  212. $this->assertEquals(-1, $this->redis->ttl('foo'));
  213. }
  214. function testDatabaseSize() {
  215. // TODO: is this really OK?
  216. $this->assertEquals(0, $this->redis->databaseSize());
  217. $this->redis->setMultiple(RC::getKeyValueArray());
  218. $this->assertGreaterThan(0, $this->redis->databaseSize());
  219. }
  220. /* commands operating on lists */
  221. function testPushTail() {
  222. $this->assertTrue($this->redis->pushTail('metavars', 'foo'));
  223. $this->assertTrue($this->redis->exists('metavars'));
  224. $this->assertTrue($this->redis->pushTail('metavars', 'hoge'));
  225. // should throw an exception when trying to do a RPUSH on non-list types
  226. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  227. \$test->redis->set('foo', 'bar');
  228. \$test->redis->pushTail('foo', 'bar');
  229. "));
  230. }
  231. function testPushHead() {
  232. $this->assertTrue($this->redis->pushHead('metavars', 'foo'));
  233. $this->assertTrue($this->redis->exists('metavars'));
  234. $this->assertTrue($this->redis->pushHead('metavars', 'hoge'));
  235. // should throw an exception when trying to do a LPUSH on non-list types
  236. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  237. \$test->redis->set('foo', 'bar');
  238. \$test->redis->pushHead('foo', 'bar');
  239. "));
  240. }
  241. function testListLength() {
  242. $this->assertTrue($this->redis->pushTail('metavars', 'foo'));
  243. $this->assertTrue($this->redis->pushTail('metavars', 'hoge'));
  244. $this->assertEquals(2, $this->redis->listLength('metavars'));
  245. $this->assertEquals(0, $this->redis->listLength('doesnotexist'));
  246. // should throw an exception when trying to do a LLEN on non-list types
  247. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  248. \$test->redis->set('foo', 'bar');
  249. \$test->redis->listLength('foo');
  250. "));
  251. }
  252. function testListRange() {
  253. $numbers = RC::pushTailAndReturn($this->redis, 'numbers', RC::getArrayOfNumbers());
  254. $this->assertEquals(
  255. array_slice($numbers, 0, 4),
  256. $this->redis->listRange('numbers', 0, 3)
  257. );
  258. $this->assertEquals(
  259. array_slice($numbers, 4, 5),
  260. $this->redis->listRange('numbers', 4, 8)
  261. );
  262. $this->assertEquals(
  263. array_slice($numbers, 0, 1),
  264. $this->redis->listRange('numbers', 0, 0)
  265. );
  266. $this->assertEquals(
  267. array(),
  268. $this->redis->listRange('numbers', 1, 0)
  269. );
  270. $this->assertEquals(
  271. $numbers,
  272. $this->redis->listRange('numbers', 0, -1)
  273. );
  274. $this->assertEquals(
  275. array(5),
  276. $this->redis->listRange('numbers', 5, -5)
  277. );
  278. $this->assertEquals(
  279. array(),
  280. $this->redis->listRange('numbers', 7, -5)
  281. );
  282. $this->assertEquals(
  283. array_slice($numbers, -5, -1),
  284. $this->redis->listRange('numbers', -5, -2)
  285. );
  286. $this->assertEquals(
  287. $numbers,
  288. $this->redis->listRange('numbers', -100, 100)
  289. );
  290. $this->assertNull($this->redis->listRange('keyDoesNotExist', 0, 1));
  291. // should throw an exception when trying to do a LRANGE on non-list types
  292. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  293. \$test->redis->set('foo', 'bar');
  294. \$test->redis->listRange('foo', 0, -1);
  295. "));
  296. }
  297. function testListTrim() {
  298. $numbers = RC::pushTailAndReturn($this->redis, 'numbers', RC::getArrayOfNumbers());
  299. $this->assertTrue($this->redis->listTrim('numbers', 0, 2));
  300. $this->assertEquals(
  301. array_slice($numbers, 0, 3),
  302. $this->redis->listRange('numbers', 0, -1)
  303. );
  304. $numbers = RC::pushTailAndReturn($this->redis, 'numbers', RC::getArrayOfNumbers(), RC::WIPE_OUT);
  305. $this->assertTrue($this->redis->listTrim('numbers', 5, 9));
  306. $this->assertEquals(
  307. array_slice($numbers, 5, 5),
  308. $this->redis->listRange('numbers', 0, -1)
  309. );
  310. $numbers = RC::pushTailAndReturn($this->redis, 'numbers', RC::getArrayOfNumbers(), RC::WIPE_OUT);
  311. $this->assertTrue($this->redis->listTrim('numbers', 0, -6));
  312. $this->assertEquals(
  313. array_slice($numbers, 0, -5),
  314. $this->redis->listRange('numbers', 0, -1)
  315. );
  316. $numbers = RC::pushTailAndReturn($this->redis, 'numbers', RC::getArrayOfNumbers(), RC::WIPE_OUT);
  317. $this->assertTrue($this->redis->listTrim('numbers', -5, -3));
  318. $this->assertEquals(
  319. array_slice($numbers, 5, 3),
  320. $this->redis->listRange('numbers', 0, -1)
  321. );
  322. $numbers = RC::pushTailAndReturn($this->redis, 'numbers', RC::getArrayOfNumbers(), RC::WIPE_OUT);
  323. $this->assertTrue($this->redis->listTrim('numbers', -100, 100));
  324. $this->assertEquals(
  325. $numbers,
  326. $this->redis->listRange('numbers', 0, -1)
  327. );
  328. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  329. \$test->redis->set('foo', 'bar');
  330. \$test->redis->listTrim('foo', 0, 1);
  331. "));
  332. }
  333. function testListIndex() {
  334. $numbers = RC::pushTailAndReturn($this->redis, 'numbers', RC::getArrayOfNumbers());
  335. $this->assertEquals(0, $this->redis->listIndex('numbers', 0));
  336. $this->assertEquals(5, $this->redis->listIndex('numbers', 5));
  337. $this->assertEquals(9, $this->redis->listIndex('numbers', 9));
  338. $this->assertNull($this->redis->listIndex('numbers', 100));
  339. $this->assertEquals(0, $this->redis->listIndex('numbers', -0));
  340. $this->assertEquals(9, $this->redis->listIndex('numbers', -1));
  341. $this->assertEquals(7, $this->redis->listIndex('numbers', -3));
  342. $this->assertNull($this->redis->listIndex('numbers', -100));
  343. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  344. \$test->redis->set('foo', 'bar');
  345. \$test->redis->listIndex('foo', 0);
  346. "));
  347. }
  348. function testListSet() {
  349. $numbers = RC::pushTailAndReturn($this->redis, 'numbers', RC::getArrayOfNumbers());
  350. $this->assertTrue($this->redis->listSet('numbers', 5, -5));
  351. $this->assertEquals(-5, $this->redis->listIndex('numbers', 5));
  352. RC::testForServerException($this, RC::EXCEPTION_OUT_OF_RANGE, p_anon("\$test", "
  353. \$test->redis->listSet('numbers', 99, 99);
  354. "));
  355. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  356. \$test->redis->set('foo', 'bar');
  357. \$test->redis->listSet('foo', 0, 0);
  358. "));
  359. }
  360. function testListRemove() {
  361. $mixed = array(0, '_', 2, '_', 4, '_', 6, '_');
  362. RC::pushTailAndReturn($this->redis, 'mixed', $mixed);
  363. $this->assertEquals(2, $this->redis->listRemove('mixed', 2, '_'));
  364. $this->assertEquals(array(0, 2, 4, '_', 6, '_'), $this->redis->listRange('mixed', 0, -1));
  365. RC::pushTailAndReturn($this->redis, 'mixed', $mixed, RC::WIPE_OUT);
  366. $this->assertEquals(4, $this->redis->listRemove('mixed', 0, '_'));
  367. $this->assertEquals(array(0, 2, 4, 6), $this->redis->listRange('mixed', 0, -1));
  368. RC::pushTailAndReturn($this->redis, 'mixed', $mixed, RC::WIPE_OUT);
  369. $this->assertEquals(2, $this->redis->listRemove('mixed', -2, '_'));
  370. $this->assertEquals(array(0, '_', 2, '_', 4, 6), $this->redis->listRange('mixed', 0, -1));
  371. RC::pushTailAndReturn($this->redis, 'mixed', $mixed, RC::WIPE_OUT);
  372. $this->assertEquals(0, $this->redis->listRemove('mixed', 2, '|'));
  373. $this->assertEquals($mixed, $this->redis->listRange('mixed', 0, -1));
  374. $this->assertEquals(0, $this->redis->listRemove('listDoesNotExist', 2, '_'));
  375. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  376. \$test->redis->set('foo', 'bar');
  377. \$test->redis->listRemove('foo', 0, 0);
  378. "));
  379. }
  380. function testListPopFirst() {
  381. $numbers = RC::pushTailAndReturn($this->redis, 'numbers', array(0, 1, 2, 3, 4));
  382. $this->assertEquals(0, $this->redis->popFirst('numbers'));
  383. $this->assertEquals(1, $this->redis->popFirst('numbers'));
  384. $this->assertEquals(2, $this->redis->popFirst('numbers'));
  385. $this->assertEquals(array(3, 4), $this->redis->listRange('numbers', 0, -1));
  386. $this->redis->popFirst('numbers');
  387. $this->redis->popFirst('numbers');
  388. $this->assertNull($this->redis->popFirst('numbers'));
  389. $this->assertNull($this->redis->popFirst('numbers'));
  390. $this->assertNull($this->redis->popFirst('listDoesNotExist'));
  391. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  392. \$test->redis->set('foo', 'bar');
  393. \$test->redis->popFirst('foo');
  394. "));
  395. }
  396. function testListPopLast() {
  397. $numbers = RC::pushTailAndReturn($this->redis, 'numbers', array(0, 1, 2, 3, 4));
  398. $this->assertEquals(4, $this->redis->popLast('numbers'));
  399. $this->assertEquals(3, $this->redis->popLast('numbers'));
  400. $this->assertEquals(2, $this->redis->popLast('numbers'));
  401. $this->assertEquals(array(0, 1), $this->redis->listRange('numbers', 0, -1));
  402. $this->redis->popLast('numbers');
  403. $this->redis->popLast('numbers');
  404. $this->assertNull($this->redis->popLast('numbers'));
  405. $this->assertNull($this->redis->popLast('numbers'));
  406. $this->assertNull($this->redis->popLast('listDoesNotExist'));
  407. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  408. \$test->redis->set('foo', 'bar');
  409. \$test->redis->popLast('foo');
  410. "));
  411. }
  412. function testListPopLastPushHead() {
  413. $numbers = RC::pushTailAndReturn($this->redis, 'numbers', array(0, 1, 2));
  414. $this->assertEquals(0, $this->redis->listLength('temporary'));
  415. $this->assertEquals(2, $this->redis->listPopLastPushHead('numbers', 'temporary'));
  416. $this->assertEquals(1, $this->redis->listPopLastPushHead('numbers', 'temporary'));
  417. $this->assertEquals(0, $this->redis->listPopLastPushHead('numbers', 'temporary'));
  418. $this->assertEquals(0, $this->redis->listLength('numbers'));
  419. $this->assertEquals(3, $this->redis->listLength('temporary'));
  420. $this->assertEquals(array(), $this->redis->listRange('numbers', 0, -1));
  421. $this->assertEquals($numbers, $this->redis->listRange('temporary', 0, -1));
  422. $numbers = RC::pushTailAndReturn($this->redis, 'numbers', array(0, 1, 2));
  423. $this->redis->listPopLastPushHead('numbers', 'numbers');
  424. $this->redis->listPopLastPushHead('numbers', 'numbers');
  425. $this->redis->listPopLastPushHead('numbers', 'numbers');
  426. $this->assertEquals($numbers, $this->redis->listRange('numbers', 0, -1));
  427. $this->assertEquals(null, $this->redis->listPopLastPushHead('listDoesNotExist1', 'listDoesNotExist2'));
  428. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  429. \$test->redis->set('foo', 'bar');
  430. \$test->redis->listPopLastPushHead('foo', 'hoge');
  431. "));
  432. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  433. \$test->redis->set('foo', 'bar');
  434. \$test->redis->listPopLastPushHead('temporary', 'foo');
  435. "));
  436. }
  437. function testListBlockingPopFirst() {
  438. // TODO: this test does not cover all the aspects of BLPOP/BRPOP as it
  439. // does not run with a concurrent client pushing items on lists.
  440. RC::helperForBlockingPops('blpop');
  441. // BLPOP on one key
  442. $start = time();
  443. $item = $this->redis->blpop('blpop3', 5);
  444. $this->assertEquals((float)(time() - $start), 0, '', 1);
  445. $this->assertEquals($item, array('blpop3', 'c'));
  446. // BLPOP on more than one key
  447. $poppedItems = array();
  448. while ($item = $this->redis->blpop('blpop1', 'blpop2', 1)) {
  449. $poppedItems[] = $item;
  450. }
  451. $this->assertEquals(
  452. array(array('blpop1', 'a'), array('blpop1', 'd'), array('blpop2', 'b')),
  453. $poppedItems
  454. );
  455. // check if BLPOP timeouts as expected on empty lists
  456. $start = time();
  457. $this->redis->blpop('blpop4', 2);
  458. $this->assertEquals((float)(time() - $start), 2, '', 1);
  459. }
  460. function testListBlockingPopLast() {
  461. // TODO: this test does not cover all the aspects of BLPOP/BRPOP as it
  462. // does not run with a concurrent client pushing items on lists.
  463. RC::helperForBlockingPops('brpop');
  464. // BRPOP on one key
  465. $start = time();
  466. $item = $this->redis->brpop('brpop3', 5);
  467. $this->assertEquals((float)(time() - $start), 0, '', 1);
  468. $this->assertEquals($item, array('brpop3', 'c'));
  469. // BRPOP on more than one key
  470. $poppedItems = array();
  471. while ($item = $this->redis->brpop('brpop1', 'brpop2', 1)) {
  472. $poppedItems[] = $item;
  473. }
  474. $this->assertEquals(
  475. array(array('brpop1', 'd'), array('brpop1', 'a'), array('brpop2', 'b')),
  476. $poppedItems
  477. );
  478. // check if BRPOP timeouts as expected on empty lists
  479. $start = time();
  480. $this->redis->brpop('brpop4', 2);
  481. $this->assertEquals((float)(time() - $start), 2, '', 1);
  482. }
  483. /* commands operating on sets */
  484. function testSetAdd() {
  485. $this->assertTrue($this->redis->setAdd('set', 0));
  486. $this->assertTrue($this->redis->setAdd('set', 1));
  487. $this->assertFalse($this->redis->setAdd('set', 0));
  488. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  489. \$test->redis->set('foo', 'bar');
  490. \$test->redis->setAdd('foo', 0);
  491. "));
  492. }
  493. function testSetRemove() {
  494. $set = RC::setAddAndReturn($this->redis, 'set', array(0, 1, 2, 3, 4));
  495. $this->assertTrue($this->redis->setRemove('set', 0));
  496. $this->assertTrue($this->redis->setRemove('set', 4));
  497. $this->assertFalse($this->redis->setRemove('set', 10));
  498. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  499. \$test->redis->set('foo', 'bar');
  500. \$test->redis->setRemove('foo', 0);
  501. "));
  502. }
  503. function testSetPop() {
  504. $set = RC::setAddAndReturn($this->redis, 'set', array(0, 1, 2, 3, 4));
  505. $this->assertTrue(in_array($this->redis->setPop('set'), $set));
  506. $this->assertNull($this->redis->setPop('setDoesNotExist'));
  507. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  508. \$test->redis->set('foo', 'bar');
  509. \$test->redis->setPop('foo');
  510. "));
  511. }
  512. function testSetMove() {
  513. $setA = RC::setAddAndReturn($this->redis, 'setA', array(0, 1, 2, 3, 4, 5));
  514. $setB = RC::setAddAndReturn($this->redis, 'setB', array(5, 6, 7, 8, 9, 10));
  515. $this->assertTrue($this->redis->setMove('setA', 'setB', 0));
  516. $this->assertFalse($this->redis->setRemove('setA', 0));
  517. $this->assertTrue($this->redis->setRemove('setB', 0));
  518. $this->assertTrue($this->redis->setMove('setA', 'setB', 5));
  519. $this->assertFalse($this->redis->setMove('setA', 'setB', 100));
  520. // wrong type
  521. $this->redis->set('foo', 'bar');
  522. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  523. \$test->redis->setMove('foo', 'setB', 5);
  524. "));
  525. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  526. \$test->redis->setMove('setA', 'foo', 5);
  527. "));
  528. }
  529. function testSetCardinality() {
  530. RC::setAddAndReturn($this->redis, 'setA', array(0, 1, 2, 3, 4, 5));
  531. $this->assertEquals(6, $this->redis->setCardinality('setA'));
  532. // empty set
  533. $this->redis->setAdd('setB', 0);
  534. $this->redis->setPop('setB');
  535. $this->assertEquals(0, $this->redis->setCardinality('setB'));
  536. // non-existing set
  537. $this->assertEquals(0, $this->redis->setCardinality('setDoesNotExist'));
  538. // wrong type
  539. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  540. \$test->redis->set('foo', 'bar');
  541. \$test->redis->setCardinality('foo');
  542. "));
  543. }
  544. function testSetIsMember() {
  545. RC::setAddAndReturn($this->redis, 'set', array(0, 1, 2, 3, 4, 5));
  546. $this->assertTrue($this->redis->setIsMember('set', 3));
  547. $this->assertFalse($this->redis->setIsMember('set', 100));
  548. $this->assertFalse($this->redis->setIsMember('setDoesNotExist', 0));
  549. // wrong type
  550. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  551. \$test->redis->set('foo', 'bar');
  552. \$test->redis->setIsMember('foo', 0);
  553. "));
  554. }
  555. function testSetMembers() {
  556. $set = RC::setAddAndReturn($this->redis, 'set', array(0, 1, 2, 3, 4, 5, 6));
  557. $this->assertTrue(RC::sameValuesInArrays($set, $this->redis->setMembers('set')));
  558. $this->assertNull($this->redis->setMembers('setDoesNotExist'));
  559. // wrong type
  560. $this->redis->set('foo', 'bar');
  561. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  562. \$test->redis->setMembers('foo');
  563. "));
  564. }
  565. function testSetIntersection() {
  566. $setA = RC::setAddAndReturn($this->redis, 'setA', array(0, 1, 2, 3, 4, 5, 6));
  567. $setB = RC::setAddAndReturn($this->redis, 'setB', array(1, 3, 4, 6, 9, 10));
  568. $this->assertTrue(RC::sameValuesInArrays(
  569. $setA,
  570. $this->redis->setIntersection('setA')
  571. ));
  572. $this->assertTrue(RC::sameValuesInArrays(
  573. array_intersect($setA, $setB),
  574. $this->redis->setIntersection('setA', 'setB')
  575. ));
  576. // TODO: should nil really be considered an empty set?
  577. $this->assertNull($this->redis->setIntersection('setA', 'setDoesNotExist'));
  578. // wrong type
  579. $this->redis->set('foo', 'bar');
  580. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  581. \$test->redis->setIntersection('foo');
  582. "));
  583. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  584. \$test->redis->setIntersection('setA', 'foo');
  585. "));
  586. }
  587. function testSetIntersectionStore() {
  588. $setA = RC::setAddAndReturn($this->redis, 'setA', array(0, 1, 2, 3, 4, 5, 6));
  589. $setB = RC::setAddAndReturn($this->redis, 'setB', array(1, 3, 4, 6, 9, 10));
  590. $this->assertEquals(count($setA), $this->redis->setIntersectionStore('setC', 'setA'));
  591. $this->assertTrue(RC::sameValuesInArrays(
  592. $setA,
  593. $this->redis->setMembers('setC')
  594. ));
  595. $this->redis->delete('setC');
  596. $this->assertEquals(4, $this->redis->setIntersectionStore('setC', 'setA', 'setB'));
  597. $this->assertTrue(RC::sameValuesInArrays(
  598. array(1, 3, 4, 6),
  599. $this->redis->setMembers('setC')
  600. ));
  601. $this->redis->delete('setC');
  602. $this->assertNull($this->redis->setIntersection('setC', 'setDoesNotExist'));
  603. $this->assertFalse($this->redis->exists('setC'));
  604. // existing keys are replaced by SINTERSTORE
  605. $this->redis->set('foo', 'bar');
  606. $this->assertEquals(count($setA), $this->redis->setIntersectionStore('foo', 'setA'));
  607. // wrong type
  608. $this->redis->set('foo', 'bar');
  609. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  610. \$test->redis->setIntersectionStore('setA', 'foo');
  611. "));
  612. }
  613. function testSetUnion() {
  614. $setA = RC::setAddAndReturn($this->redis, 'setA', array(0, 1, 2, 3, 4, 5, 6));
  615. $setB = RC::setAddAndReturn($this->redis, 'setB', array(1, 3, 4, 6, 9, 10));
  616. $this->assertTrue(RC::sameValuesInArrays(
  617. $setA,
  618. $this->redis->setUnion('setA')
  619. ));
  620. $this->assertTrue(RC::sameValuesInArrays(
  621. array_union($setA, $setB),
  622. $this->redis->setUnion('setA', 'setB')
  623. ));
  624. $this->assertTrue(RC::sameValuesInArrays(
  625. $setA,
  626. $this->redis->setUnion('setA', 'setDoesNotExist')
  627. ));
  628. // wrong type
  629. $this->redis->set('foo', 'bar');
  630. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  631. \$test->redis->setUnion('foo');
  632. "));
  633. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  634. \$test->redis->setUnion('setA', 'foo');
  635. "));
  636. }
  637. function testSetUnionStore() {
  638. $setA = RC::setAddAndReturn($this->redis, 'setA', array(0, 1, 2, 3, 4, 5, 6));
  639. $setB = RC::setAddAndReturn($this->redis, 'setB', array(1, 3, 4, 6, 9, 10));
  640. $this->assertEquals(count($setA), $this->redis->setUnionStore('setC', 'setA'));
  641. $this->assertTrue(RC::sameValuesInArrays(
  642. $setA,
  643. $this->redis->setMembers('setC')
  644. ));
  645. $this->redis->delete('setC');
  646. $this->assertEquals(9, $this->redis->setUnionStore('setC', 'setA', 'setB'));
  647. $this->assertTrue(RC::sameValuesInArrays(
  648. array_union($setA, $setB),
  649. $this->redis->setMembers('setC')
  650. ));
  651. // non-existing keys are considered empty sets
  652. $this->redis->delete('setC');
  653. $this->assertEquals(0, $this->redis->setUnionStore('setC', 'setDoesNotExist'));
  654. $this->assertTrue($this->redis->exists('setC'));
  655. $this->assertEquals(0, $this->redis->setCardinality('setC'));
  656. // existing keys are replaced by SUNIONSTORE
  657. $this->redis->set('foo', 'bar');
  658. $this->assertEquals(count($setA), $this->redis->setUnionStore('foo', 'setA'));
  659. // wrong type
  660. $this->redis->set('foo', 'bar');
  661. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  662. \$test->redis->setUnionStore('setA', 'foo');
  663. "));
  664. }
  665. function testSetDifference() {
  666. $setA = RC::setAddAndReturn($this->redis, 'setA', array(0, 1, 2, 3, 4, 5, 6));
  667. $setB = RC::setAddAndReturn($this->redis, 'setB', array(1, 3, 4, 6, 9, 10));
  668. $this->assertTrue(RC::sameValuesInArrays(
  669. $setA,
  670. $this->redis->setDifference('setA')
  671. ));
  672. $this->assertTrue(RC::sameValuesInArrays(
  673. array_diff($setA, $setB),
  674. $this->redis->setDifference('setA', 'setB')
  675. ));
  676. $this->assertTrue(RC::sameValuesInArrays(
  677. $setA,
  678. $this->redis->setDifference('setA', 'setDoesNotExist')
  679. ));
  680. // wrong type
  681. $this->redis->set('foo', 'bar');
  682. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  683. \$test->redis->setDifference('foo');
  684. "));
  685. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  686. \$test->redis->setDifference('setA', 'foo');
  687. "));
  688. }
  689. function testSetDifferenceStore() {
  690. $setA = RC::setAddAndReturn($this->redis, 'setA', array(0, 1, 2, 3, 4, 5, 6));
  691. $setB = RC::setAddAndReturn($this->redis, 'setB', array(1, 3, 4, 6, 9, 10));
  692. $this->assertEquals(count($setA), $this->redis->setDifferenceStore('setC', 'setA'));
  693. $this->assertTrue(RC::sameValuesInArrays(
  694. $setA,
  695. $this->redis->setMembers('setC')
  696. ));
  697. $this->redis->delete('setC');
  698. $this->assertEquals(3, $this->redis->setDifferenceStore('setC', 'setA', 'setB'));
  699. $this->assertTrue(RC::sameValuesInArrays(
  700. array_diff($setA, $setB),
  701. $this->redis->setMembers('setC')
  702. ));
  703. // non-existing keys are considered empty sets
  704. $this->redis->delete('setC');
  705. $this->assertEquals(0, $this->redis->setDifferenceStore('setC', 'setDoesNotExist'));
  706. $this->assertTrue($this->redis->exists('setC'));
  707. $this->assertEquals(0, $this->redis->setCardinality('setC'));
  708. // existing keys are replaced by SDIFFSTORE
  709. $this->redis->set('foo', 'bar');
  710. $this->assertEquals(count($setA), $this->redis->setDifferenceStore('foo', 'setA'));
  711. // wrong type
  712. $this->redis->set('foo', 'bar');
  713. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  714. \$test->redis->setDifferenceStore('setA', 'foo');
  715. "));
  716. }
  717. function testRandomMember() {
  718. $set = RC::setAddAndReturn($this->redis, 'set', array(0, 1, 2, 3, 4, 5, 6));
  719. $this->assertTrue(in_array($this->redis->setRandomMember('set'), $set));
  720. $this->assertNull($this->redis->setRandomMember('setDoesNotExist'));
  721. // wrong type
  722. $this->redis->set('foo', 'bar');
  723. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  724. \$test->redis->setRandomMember('foo');
  725. "));
  726. }
  727. /* commands operating on sorted sets */
  728. function testZsetAdd() {
  729. $this->assertTrue($this->redis->zsetAdd('zset', 0, 'a'));
  730. $this->assertTrue($this->redis->zsetAdd('zset', 1, 'b'));
  731. $this->assertTrue($this->redis->zsetAdd('zset', -1, 'c'));
  732. // TODO: floats?
  733. //$this->assertTrue($this->redis->zsetAdd('zset', -1.0, 'c'));
  734. //$this->assertTrue($this->redis->zsetAdd('zset', -1.0, 'c'));
  735. $this->assertFalse($this->redis->zsetAdd('zset', 2, 'b'));
  736. $this->assertFalse($this->redis->zsetAdd('zset', -2, 'b'));
  737. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  738. \$test->redis->set('foo', 'bar');
  739. \$test->redis->zsetAdd('foo', 0, 'a');
  740. "));
  741. }
  742. function testZsetIncrementBy() {
  743. $this->assertEquals(1, $this->redis->zsetIncrementBy('zsetDoesNotExist', 1, 'foo'));
  744. $this->assertEquals('zset', $this->redis->type('zsetDoesNotExist'));
  745. RC::zsetAddAndReturn($this->redis, 'zset', RC::getZSetArray());
  746. $this->assertEquals(-5, $this->redis->zsetIncrementBy('zset', 5, 'a'));
  747. $this->assertEquals(1, $this->redis->zsetIncrementBy('zset', 1, 'b'));
  748. $this->assertEquals(10, $this->redis->zsetIncrementBy('zset', 0, 'c'));
  749. $this->assertEquals(0, $this->redis->zsetIncrementBy('zset', -20, 'd'));
  750. $this->assertEquals(2, $this->redis->zsetIncrementBy('zset', 2, 'd'));
  751. $this->assertEquals(-10, $this->redis->zsetIncrementBy('zset', -30, 'e'));
  752. $this->assertEquals(1, $this->redis->zsetIncrementBy('zset', 1, 'x'));
  753. // wrong type
  754. $this->redis->set('foo', 'bar');
  755. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  756. \$test->redis->zsetIncrementBy('foo', 1, 'a');
  757. "));
  758. }
  759. function testZsetRemove() {
  760. RC::zsetAddAndReturn($this->redis, 'zset', RC::getZSetArray());
  761. $this->assertTrue($this->redis->zsetRemove('zset', 'a'));
  762. $this->assertFalse($this->redis->zsetRemove('zset', 'x'));
  763. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  764. \$test->redis->set('foo', 'bar');
  765. \$test->redis->zsetRemove('foo', 'bar');
  766. "));
  767. }
  768. function testZsetRange() {
  769. $zset = RC::zsetAddAndReturn($this->redis, 'zset', RC::getZSetArray());
  770. $this->assertEquals(
  771. array_slice(array_keys($zset), 0, 4),
  772. $this->redis->zsetRange('zset', 0, 3)
  773. );
  774. $this->assertEquals(
  775. array_slice(array_keys($zset), 0, 1),
  776. $this->redis->zsetRange('zset', 0, 0)
  777. );
  778. $this->assertEquals(
  779. array(),
  780. $this->redis->zsetRange('zset', 1, 0)
  781. );
  782. $this->assertEquals(
  783. array_values(array_keys($zset)),
  784. $this->redis->zsetRange('zset', 0, -1)
  785. );
  786. $this->assertEquals(
  787. array_slice(array_keys($zset), 3, 1),
  788. $this->redis->zsetRange('zset', 3, -3)
  789. );
  790. $this->assertEquals(
  791. array(),
  792. $this->redis->zsetRange('zset', 5, -3)
  793. );
  794. $this->assertEquals(
  795. array_slice(array_keys($zset), -5, -1),
  796. $this->redis->zsetRange('zset', -5, -2)
  797. );
  798. $this->assertEquals(
  799. array_values(array_keys($zset)),
  800. $this->redis->zsetRange('zset', -100, 100)
  801. );
  802. $this->assertEquals(
  803. array_values(array_keys($zset)),
  804. $this->redis->zsetRange('zset', -100, 100)
  805. );
  806. $this->assertEquals(
  807. array(array('a', -10), array('b', 0), array('c', 10)),
  808. $this->redis->zsetRange('zset', 0, 2, 'withscores')
  809. );
  810. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  811. \$test->redis->set('foo', 'bar');
  812. \$test->redis->zsetRange('foo', 0, -1);
  813. "));
  814. }
  815. function testZsetReverseRange() {
  816. $zset = RC::zsetAddAndReturn($this->redis, 'zset', RC::getZSetArray());
  817. $this->assertEquals(
  818. array_slice(array_reverse(array_keys($zset)), 0, 4),
  819. $this->redis->zsetReverseRange('zset', 0, 3)
  820. );
  821. $this->assertEquals(
  822. array_slice(array_reverse(array_keys($zset)), 0, 1),
  823. $this->redis->zsetReverseRange('zset', 0, 0)
  824. );
  825. $this->assertEquals(
  826. array(),
  827. $this->redis->zsetReverseRange('zset', 1, 0)
  828. );
  829. $this->assertEquals(
  830. array_values(array_reverse(array_keys($zset))),
  831. $this->redis->zsetReverseRange('zset', 0, -1)
  832. );
  833. $this->assertEquals(
  834. array_slice(array_reverse(array_keys($zset)), 3, 1),
  835. $this->redis->zsetReverseRange('zset', 3, -3)
  836. );
  837. $this->assertEquals(
  838. array(),
  839. $this->redis->zsetReverseRange('zset', 5, -3)
  840. );
  841. $this->assertEquals(
  842. array_slice(array_reverse(array_keys($zset)), -5, -1),
  843. $this->redis->zsetReverseRange('zset', -5, -2)
  844. );
  845. $this->assertEquals(
  846. array_values(array_reverse(array_keys($zset))),
  847. $this->redis->zsetReverseRange('zset', -100, 100)
  848. );
  849. $this->assertEquals(
  850. array(array('f', 30), array('e', 20), array('d', 20)),
  851. $this->redis->zsetReverseRange('zset', 0, 2, 'withscores')
  852. );
  853. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  854. \$test->redis->set('foo', 'bar');
  855. \$test->redis->zsetReverseRange('foo', 0, -1);
  856. "));
  857. }
  858. function testZsetRangeByScore() {
  859. $zset = RC::zsetAddAndReturn($this->redis, 'zset', RC::getZSetArray());
  860. $this->assertEquals(
  861. array('a'),
  862. $this->redis->zsetRangeByScore('zset', -10, -10)
  863. );
  864. $this->assertEquals(
  865. array('c', 'd', 'e', 'f'),
  866. $this->redis->zsetRangeByScore('zset', 10, 30)
  867. );
  868. $this->assertEquals(
  869. array('d', 'e'),
  870. $this->redis->zsetRangeByScore('zset', 20, 20)
  871. );
  872. $this->assertEquals(
  873. array(),
  874. $this->redis->zsetRangeByScore('zset', 30, 0)
  875. );
  876. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  877. \$test->redis->set('foo', 'bar');
  878. \$test->redis->zsetRangeByScore('foo', 0, 0);
  879. "));
  880. }
  881. function testZsetCardinality() {
  882. $zset = RC::zsetAddAndReturn($this->redis, 'zset', RC::getZSetArray());
  883. $this->assertEquals(count($zset), $this->redis->zsetCardinality('zset'));
  884. $this->redis->zsetRemove('zset', 'a');
  885. $this->assertEquals(count($zset) - 1, $this->redis->zsetCardinality('zset'));
  886. // empty zset
  887. $this->redis->zsetAdd('zsetB', 0, 'a');
  888. $this->redis->zsetRemove('zsetB', 'a');
  889. $this->assertEquals(0, $this->redis->zsetCardinality('setB'));
  890. // non-existing zset
  891. $this->assertEquals(0, $this->redis->zsetCardinality('zsetDoesNotExist'));
  892. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  893. \$test->redis->set('foo', 'bar');
  894. \$test->redis->zsetCardinality('foo');
  895. "));
  896. }
  897. function testZsetScore() {
  898. $zset = RC::zsetAddAndReturn($this->redis, 'zset', RC::getZSetArray());
  899. $this->assertEquals(-10, $this->redis->zsetScore('zset', 'a'));
  900. $this->assertEquals(10, $this->redis->zsetScore('zset', 'c'));
  901. $this->assertEquals(20, $this->redis->zsetScore('zset', 'e'));
  902. $this->assertNull($this->redis->zsetScore('zset', 'x'));
  903. $this->assertNull($this->redis->zsetScore('zsetDoesNotExist', 'a'));
  904. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  905. \$test->redis->set('foo', 'bar');
  906. \$test->redis->zsetScore('foo', 'bar');
  907. "));
  908. }
  909. function testZsetRemoveRangeByScore() {
  910. $zset = RC::zsetAddAndReturn($this->redis, 'zset', RC::getZSetArray());
  911. $this->assertEquals(2, $this->redis->zsetRemoveRangeByScore('zset', -10, 0));
  912. $this->assertEquals(
  913. array('c', 'd', 'e', 'f'),
  914. $this->redis->zsetRange('zset', 0, -1)
  915. );
  916. $this->assertEquals(1, $this->redis->zsetRemoveRangeByScore('zset', 10, 10));
  917. $this->assertEquals(
  918. array('d', 'e', 'f'),
  919. $this->redis->zsetRange('zset', 0, -1)
  920. );
  921. $this->assertEquals(0, $this->redis->zsetRemoveRangeByScore('zset', 100, 100));
  922. $this->assertEquals(3, $this->redis->zsetRemoveRangeByScore('zset', 0, 100));
  923. $this->assertEquals(0, $this->redis->zsetRemoveRangeByScore('zset', 0, 100));
  924. $this->assertEquals(0, $this->redis->zsetRemoveRangeByScore('zsetDoesNotExist', 0, 100));
  925. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  926. \$test->redis->set('foo', 'bar');
  927. \$test->redis->zsetRemoveRangeByScore('foo', 0, 0);
  928. "));
  929. }
  930. /* multiple databases handling commands */
  931. function testSelectDatabase() {
  932. $this->assertTrue($this->redis->selectDatabase(0));
  933. $this->assertTrue($this->redis->selectDatabase(RC::DEFAULT_DATABASE));
  934. RC::testForServerException($this, RC::EXCEPTION_INVALID_DB_IDX, p_anon("\$test", "
  935. \$test->redis->selectDatabase(32);
  936. "));
  937. RC::testForServerException($this, RC::EXCEPTION_INVALID_DB_IDX, p_anon("\$test", "
  938. \$test->redis->selectDatabase(-1);
  939. "));
  940. }
  941. function testMove() {
  942. // TODO: This test sucks big time. Period.
  943. $otherDb = 5;
  944. $this->redis->set('foo', 'bar');
  945. $this->redis->selectDatabase($otherDb);
  946. $this->redis->flushDatabase();
  947. $this->redis->selectDatabase(RC::DEFAULT_DATABASE);
  948. $this->assertTrue($this->redis->move('foo', $otherDb));
  949. $this->assertFalse($this->redis->move('foo', $otherDb));
  950. $this->assertFalse($this->redis->move('keyDoesNotExist', $otherDb));
  951. $this->redis->set('hoge', 'piyo');
  952. // TODO: shouldn't Redis send an EXCEPTION_INVALID_DB_IDX instead of EXCEPTION_OUT_OF_RANGE?
  953. RC::testForServerException($this, RC::EXCEPTION_OUT_OF_RANGE, p_anon("\$test", "
  954. \$test->redis->move('hoge', 32);
  955. "));
  956. }
  957. function testFlushDatabase() {
  958. $this->assertTrue($this->redis->flushDatabase());
  959. }
  960. function testFlushDatabases() {
  961. $this->assertTrue($this->redis->flushDatabases());
  962. }
  963. /* sorting */
  964. function testSort() {
  965. $unorderedList = RC::pushTailAndReturn($this->redis, 'unordered', array(2, 100, 3, 1, 30, 10));
  966. // without parameters
  967. $this->assertEquals(array(1, 2, 3, 10, 30, 100), $this->redis->sort('unordered'));
  968. // with parameter ASC/DESC
  969. $this->assertEquals(
  970. array(100, 30, 10, 3, 2, 1),
  971. $this->redis->sort('unordered', array(
  972. 'sort' => 'desc'
  973. ))
  974. );
  975. // with parameter LIMIT
  976. $this->assertEquals(
  977. array(1, 2, 3),
  978. $this->redis->sort('unordered', array(
  979. 'limit' => array(0, 3)
  980. ))
  981. );
  982. $this->assertEquals(
  983. array(10, 30),
  984. $this->redis->sort('unordered', array(
  985. 'limit' => array(3, 2)
  986. ))
  987. );
  988. // with parameter ALPHA
  989. $this->assertEquals(
  990. array(1, 10, 100, 2, 3, 30),
  991. $this->redis->sort('unordered', array(
  992. 'alpha' => true
  993. ))
  994. );
  995. // with combined parameters
  996. $this->assertEquals(
  997. array(30, 10, 3, 2),
  998. $this->redis->sort('unordered', array(
  999. 'alpha' => false,
  1000. 'sort' => 'desc',
  1001. 'limit' => array(1, 4)
  1002. ))
  1003. );
  1004. // with parameter ALPHA
  1005. $this->assertEquals(
  1006. array(1, 10, 100, 2, 3, 30),
  1007. $this->redis->sort('unordered', array(
  1008. 'alpha' => true
  1009. ))
  1010. );
  1011. // with parameter STORE
  1012. $this->assertEquals(
  1013. count($unorderedList),
  1014. $this->redis->sort('unordered', array(
  1015. 'store' => 'ordered'
  1016. ))
  1017. );
  1018. $this->assertEquals(array(1, 2, 3, 10, 30, 100), $this->redis->listRange('ordered', 0, -1));
  1019. // wront type
  1020. RC::testForServerException($this, RC::EXCEPTION_WRONG_TYPE, p_anon("\$test", "
  1021. \$test->redis->set('foo', 'bar');
  1022. \$test->redis->sort('foo');
  1023. "));
  1024. }
  1025. /* remote server control commands */
  1026. function testInfo() {
  1027. $serverInfo = $this->redis->info();
  1028. $this->assertType('array', $serverInfo);
  1029. $this->assertNotNull($serverInfo['redis_version']);
  1030. $this->assertGreaterThan(0, $serverInfo['uptime_in_seconds']);
  1031. $this->assertGreaterThan(0, $serverInfo['total_connections_received']);
  1032. }
  1033. function testSlaveOf() {
  1034. $masterHost = 'www.google.com';
  1035. $masterPort = 80;
  1036. $this->assertTrue($this->redis->slaveOf($masterHost, $masterPort));
  1037. $serverInfo = $this->redis->info();
  1038. $this->assertEquals('slave', $serverInfo['role']);
  1039. $this->assertEquals($masterHost, $serverInfo['master_host']);
  1040. $this->assertEquals($masterPort, $serverInfo['master_port']);
  1041. // slave of NO ONE, the implicit way
  1042. $this->assertTrue($this->redis->slaveOf());
  1043. $serverInfo = $this->redis->info();
  1044. $this->assertEquals('master', $serverInfo['role']);
  1045. // slave of NO ONE, the explicit way
  1046. $this->assertTrue($this->redis->slaveOf('NO ONE'));
  1047. }
  1048. /* persistence control commands */
  1049. function testSave() {
  1050. $this->assertTrue($this->redis->save());
  1051. }
  1052. function testBackgroundSave() {
  1053. $this->assertTrue($this->redis->backgroundSave());
  1054. }
  1055. function testLastSave() {
  1056. $this->assertGreaterThan(0, $this->redis->lastSave());
  1057. }
  1058. function testShutdown() {
  1059. // TODO: seriously, we even test shutdown?
  1060. /*
  1061. $this->assertNull($this->redis->shutdown());
  1062. sleep(1);
  1063. $this->assertFalse($this->redis->isConnected());
  1064. */
  1065. }
  1066. }
  1067. ?>