Fix database handling in Predis\MonitorContext.

2026-09-03 14:28:49 +00:00 · 2011-04-25 14:14:01 +02:00
parent b2575bd667
commit 88a9f509b4
1 changed files with 11 additions and 0 deletions
@@ -60,10 +60,21 @@ class MonitorContext implements \Iterator {
    }

    private function getValue() {
+        $database = 0;
        $event = $this->_client->getConnection()->read();
+
+        $callback = function($matches) use (&$database) {
+            if (isset($matches[1])) {
+                $database = (int) $matches[1];
+            }
+            return ' ';
+        };
+        $event = preg_replace_callback('/ \(db (\d+)\) /', $callback, $event, 1);
+
        @list($timestamp, $command, $arguments) = split(' ', $event, 3);
        return (object) array(
            'timestamp' => (float) $timestamp,
+            'database'  => $database,
            'command'   => substr($command, 1, -1),
            'arguments' => $arguments ?: '',
        );