ZSCAN_Test.php 3.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139
  1. <?php
  2. /*
  3. * This file is part of the Predis package.
  4. *
  5. * (c) Daniele Alessandri <suppakilla@gmail.com>
  6. *
  7. * For the full copyright and license information, please view the LICENSE
  8. * file that was distributed with this source code.
  9. */
  10. namespace Predis\Command\Redis;
  11. /**
  12. * @group commands
  13. * @group realm-zset
  14. */
  15. class ZSCAN_Test extends PredisCommandTestCase
  16. {
  17. /**
  18. * {@inheritdoc}
  19. */
  20. protected function getExpectedCommand()
  21. {
  22. return 'Predis\Command\Redis\ZSCAN';
  23. }
  24. /**
  25. * {@inheritdoc}
  26. */
  27. protected function getExpectedId()
  28. {
  29. return 'ZSCAN';
  30. }
  31. /**
  32. * @group disconnected
  33. */
  34. public function testFilterArguments()
  35. {
  36. $arguments = array('key', 0, 'MATCH', 'member:*', 'COUNT', 10);
  37. $expected = array('key', 0, 'MATCH', 'member:*', 'COUNT', 10);
  38. $command = $this->getCommand();
  39. $command->setArguments($arguments);
  40. $this->assertSame($expected, $command->getArguments());
  41. }
  42. /**
  43. * @group disconnected
  44. */
  45. public function testFilterArgumentsBasicUsage()
  46. {
  47. $arguments = array('key', 0);
  48. $expected = array('key', 0);
  49. $command = $this->getCommand();
  50. $command->setArguments($arguments);
  51. $this->assertSame($expected, $command->getArguments());
  52. }
  53. /**
  54. * @group disconnected
  55. */
  56. public function testFilterArgumentsWithOptionsArray()
  57. {
  58. $arguments = array('key', 0, array('match' => 'member:*', 'count' => 10));
  59. $expected = array('key', 0, 'MATCH', 'member:*', 'COUNT', 10);
  60. $command = $this->getCommand();
  61. $command->setArguments($arguments);
  62. $this->assertSame($expected, $command->getArguments());
  63. }
  64. /**
  65. * @group disconnected
  66. */
  67. public function testParseResponse()
  68. {
  69. $raw = array('3', array('member:1', '1', 'member:2', '2', 'member:3', '3'));
  70. $expected = array('3', array('member:1' => 1.0, 'member:2' => 2.0, 'member:3' => 3.0));
  71. $command = $this->getCommand();
  72. $this->assertSame($expected, $command->parseResponse($raw));
  73. }
  74. /**
  75. * @group connected
  76. * @requiresRedisVersion >= 2.8.0
  77. */
  78. public function testScanWithoutMatch()
  79. {
  80. $expectedMembers = array('member:one', 'member:two', 'member:three', 'member:four');
  81. $expectedScores = array(1.0, 2.0, 3.0, 4.0);
  82. $redis = $this->getClient();
  83. $redis->zadd('key', array_combine($expectedMembers, $expectedScores));
  84. $response = $redis->zscan('key', 0);
  85. $this->assertSame('0', $response[0]);
  86. $this->assertSame($expectedMembers, array_keys($response[1]));
  87. $this->assertSame($expectedScores, array_values($response[1]));
  88. }
  89. /**
  90. * @group connected
  91. * @requiresRedisVersion >= 2.8.0
  92. */
  93. public function testScanWithMatchingMembers()
  94. {
  95. $redis = $this->getClient();
  96. $redis->zadd('key', array('member:one' => 1.0, 'member:two' => 2.0, 'member:three' => 3.0, 'member:four' => 4.0));
  97. $response = $redis->zscan('key', 0, 'MATCH', 'member:t*');
  98. $this->assertSame(array('member:two', 'member:three'), array_keys($response[1]));
  99. $this->assertSame(array(2.0, 3.0), array_values($response[1]));
  100. }
  101. /**
  102. * @group connected
  103. * @requiresRedisVersion >= 2.8.0
  104. */
  105. public function testScanWithNoMatchingMembers()
  106. {
  107. $redis = $this->getClient();
  108. $redis->zadd('key', $members = array('member:one' => 1.0, 'member:two' => 2.0, 'member:three' => 3.0, 'member:four' => 4.0));
  109. $response = $redis->zscan('key', 0, 'MATCH', 'nomember:*');
  110. $this->assertSame('0', $response[0]);
  111. $this->assertEmpty($response[1]);
  112. }
  113. }