PredisShared.php 3.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124
  1. <?php
  2. require_once '../lib/Predis.php';
  3. if (I_AM_AWARE_OF_THE_DESTRUCTIVE_POWER_OF_THIS_TEST_SUITE !== true) {
  4. exit('Please set the I_AM_AWARE_OF_THE_DESTRUCTIVE_POWER_OF_THIS_TEST_SUITE constant to TRUE if you want to proceed.');
  5. }
  6. if (!function_exists('array_union')) {
  7. function array_union(Array $a, Array $b) {
  8. return array_merge($a, array_diff($b, $a));
  9. }
  10. }
  11. class RC {
  12. const SERVER_HOST = '127.0.0.1';
  13. const SERVER_PORT = 6379;
  14. const DEFAULT_DATABASE = 15;
  15. const WIPE_OUT = 1;
  16. const EXCEPTION_WRONG_TYPE = 'Operation against a key holding the wrong kind of value';
  17. const EXCEPTION_NO_SUCH_KEY = 'no such key';
  18. const EXCEPTION_OUT_OF_RANGE = 'index out of range';
  19. const EXCEPTION_INVALID_DB_IDX = 'invalid DB index';
  20. private static $_connection;
  21. private static function createConnection() {
  22. $connection = new Predis\Client(RC::SERVER_HOST, RC::SERVER_PORT);
  23. $connection->connect();
  24. $connection->selectDatabase(RC::DEFAULT_DATABASE);
  25. return $connection;
  26. }
  27. public static function getConnection() {
  28. if (self::$_connection === null || !self::$_connection->isConnected()) {
  29. self::$_connection = self::createConnection();
  30. }
  31. return self::$_connection;
  32. }
  33. public static function resetConnection() {
  34. if (self::$_connection !== null && self::$_connection->isConnected()) {
  35. self::$_connection->disconnect();
  36. self::$_connection = self::createConnection();
  37. }
  38. }
  39. public static function getArrayOfNumbers() {
  40. return array(0, 1, 2, 3, 4, 5, 6, 7, 8, 9);
  41. }
  42. public static function getKeyValueArray() {
  43. return array(
  44. 'foo' => 'bar',
  45. 'hoge' => 'piyo',
  46. 'foofoo' => 'barbar',
  47. );
  48. }
  49. public static function getNamespacedKeyValueArray() {
  50. return array(
  51. 'metavar:foo' => 'bar',
  52. 'metavar:hoge' => 'piyo',
  53. 'metavar:foofoo' => 'barbar',
  54. );
  55. }
  56. public static function getZSetArray() {
  57. return array(
  58. 'a' => -10, 'b' => 0, 'c' => 10, 'd' => 20, 'e' => 20, 'f' => 30
  59. );
  60. }
  61. public static function sameValuesInArrays($arrayA, $arrayB) {
  62. if (count($arrayA) != count($arrayB)) {
  63. return false;
  64. }
  65. return count(array_diff($arrayA, $arrayB)) == 0;
  66. }
  67. public static function testForServerException($testcaseInstance, $expectedMessage, $wrapFunction) {
  68. $thrownException = null;
  69. try {
  70. $wrapFunction($testcaseInstance);
  71. }
  72. catch (Predis\ServerException $exception) {
  73. $thrownException = $exception;
  74. }
  75. $testcaseInstance->assertType('Predis\ServerException', $thrownException);
  76. $testcaseInstance->assertEquals($expectedMessage, $thrownException->getMessage());
  77. }
  78. public static function pushTailAndReturn(Predis\Client $client, $keyName, Array $values, $wipeOut = 0) {
  79. if ($wipeOut == true) {
  80. $client->delete($keyName);
  81. }
  82. foreach ($values as $value) {
  83. $client->pushTail($keyName, $value);
  84. }
  85. return $values;
  86. }
  87. public static function setAddAndReturn(Predis\Client $client, $keyName, Array $values, $wipeOut = 0) {
  88. if ($wipeOut == true) {
  89. $client->delete($keyName);
  90. }
  91. foreach ($values as $value) {
  92. $client->setAdd($keyName, $value);
  93. }
  94. return $values;
  95. }
  96. public static function zsetAddAndReturn(Predis\Client $client, $keyName, Array $values, $wipeOut = 0) {
  97. // $values: array(SCORE => VALUE, ...);
  98. if ($wipeOut == true) {
  99. $client->delete($keyName);
  100. }
  101. foreach ($values as $value => $score) {
  102. $client->zsetAdd($keyName, $score, $value);
  103. }
  104. return $values;
  105. }
  106. }
  107. ?>