Browse Source

dev 2020-11

Max F 5 years ago
parent
commit
5c14cecd64
1 changed files with 13 additions and 2 deletions
  1. 13 2
      src/Database/Redis/Redis.php

+ 13 - 2
src/Database/Redis/Redis.php

@@ -9,9 +9,10 @@ class Redis
 {
 	protected $dsn = null;
 	protected $client = null;
+	protected $connection_name = null;
 	
 
-	public function __construct($redis_dsn=null)
+	public function __construct($redis_dsn=null, $connection_name='')
 	{
 		if (empty($redis_dsn) && defined('REDIS_DSN')) {
 			$redis_dsn = REDIS_DSN;
@@ -24,28 +25,38 @@ class Redis
 		if (class_exists('\\Predis\\Client')) {
 			$this->setClient(new Predis\Client($redis_dsn));
 			$this->dsn = $redis_dsn;
-		}
+			$this->connection_name = $connection_name;
+
+			if ($connection_name) {
+				$this->getClient()->client('SETNAME', $connection_name);
+			}
 
+		}
 	}
 
+
 	public function getClient()
 	{
 		return $this->client;
 	}
 
+
 	public function setClient($client)
 	{
 		$this->client = $client;
 	}
 
+
 	public function get($key)
 	{
 		return $this->client->get($key);
 	}
 
+
 	public function set($key, $value)
 	{
 		return $this->client->set($key, $value);
 	}
+	
 }