Skip to content

Commit 5b561fe

Browse files
author
niulingyun
committed
mget过滤为值为NULL的元素
1 parent 9984f7f commit 5b561fe

2 files changed

Lines changed: 10 additions & 6 deletions

File tree

src/Coroutine/Redis.php

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -150,9 +150,11 @@ protected function unSerializeHandler($data, $keys = [], $len = 0)
150150
if (!empty($keys) && is_array($data)) {
151151
$ret = [];
152152
array_walk($data, function ($val, $k) use ($keys, $len, &$ret) {
153-
$key = substr($keys[$k], $len);
154-
$val = $this->realUnserialize($val);
155-
$ret[$key] = $val;
153+
if (!is_null($val)) {
154+
$key = substr($keys[$k], $len);
155+
$val = $this->realUnserialize($val);
156+
$ret[$key] = $val;
157+
}
156158
});
157159

158160
$data = $ret;

src/Pools/CoroutineRedisProxy.php

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -351,9 +351,11 @@ protected function unSerializeHandler($data, $keys = [], $len = 0)
351351
if (!empty($keys) && is_array($data)) {
352352
$ret = [];
353353
array_walk($data, function ($val, $k) use ($keys, $len, &$ret) {
354-
$key = substr($keys[$k], $len);
355-
$val = $this->realUnserialize($val);
356-
$ret[$key] = $val;
354+
if (!is_null($val)) {
355+
$key = substr($keys[$k], $len);
356+
$val = $this->realUnserialize($val);
357+
$ret[$key] = $val;
358+
}
357359
});
358360

359361
$data = $ret;

0 commit comments

Comments
 (0)