| @@ 112-122 (lines=11) @@ | ||
| 109 | return; |
|
| 110 | } |
|
| 111 | ||
| 112 | foreach (array_chunk($zsets, self::BULK_SIZE, true) as $zset) { |
|
| 113 | $part = []; |
|
| 114 | $part[] = 'ZADD'; |
|
| 115 | $part[] = $this->escape($key); |
|
| 116 | ||
| 117 | foreach ($zset as $value => $score) { |
|
| 118 | $part[] = $this->escape($score); |
|
| 119 | $part[] = $this->escape($value); |
|
| 120 | } |
|
| 121 | $parts[] = implode(' ', $part); |
|
| 122 | } |
|
| 123 | } |
|
| 124 | ||
| 125 | /** |
|
| @@ 168-177 (lines=10) @@ | ||
| 165 | return; |
|
| 166 | } |
|
| 167 | ||
| 168 | foreach (array_chunk($hashes, self::BULK_SIZE, true) as $hash) { |
|
| 169 | $part = []; |
|
| 170 | $part[] = 'HMSET'; |
|
| 171 | $part[] = $this->escape($key); |
|
| 172 | foreach ($hash as $k => $val) { |
|
| 173 | $part[] = $this->escape($k); |
|
| 174 | $part[] = $this->escape($val); |
|
| 175 | } |
|
| 176 | $parts[] = implode(' ', $part); |
|
| 177 | } |
|
| 178 | } |
|
| 179 | ||
| 180 | /** |
|