Merge pull request #136 from dongnan/final

Added new driver : ssdb

phpfastcache/3.0.0/drivers/ssdb.php

@@ -0,0 +1,135 @@
+<?php
+
+/**
+ * @author: [email protected]
+ * Website: http://www.phpfastcache.com
+ * Example at our website, any bugs, problems, please visit http://faster.phpfastcache.com
+ * 
+ * ssdb official website:
+ * http://ssdb.io/
+ */
+
+class phpfastcache_ssdb extends BasePhpFastCache implements phpfastcache_driver {
+
+    private $checked_ssdb = false;
+
+    function checkdriver() {
+        // Check memcache
+        $this->required_extension("SSDB.php");
+        if (class_exists("SimpleSSDB")) {
+            return true;
+        }
+        $this->fallback = true;
+        return false;
+    }
+
+    function __construct($config = array()) {
+        $this->setup($config);
+        if (!$this->checkdriver() && !isset($config['skipError'])) {
+            $this->fallback = true;
+        }
+    }
+
+    function connectServer() {
+
+        $server = isset($this->config['ssdb']) ? $this->config['ssdb'] : array(
+                                                                                "host" => "127.0.0.1",
+                                                                                "port" => 8888,
+                                                                                "password" => "",
+                                                                                "timeout" => 2000,
+                                                                              );
+
+        if ($this->checked_ssdb === false) {
+            $host = $server['host'];
+            $port = isset($server['port']) ? (Int) $server['port'] : 8888;
+            $password = isset($server['password']) ? $server['password'] : "";
+            $timeout = isset($server['timeout']) ? (Int) $server['timeout'] : 2000;
+            $this->instant = new SimpleSSDB($host, $port, $timeout);
+            if (!empty($password)) {
+                $this->instant->auth($password);
+            }
+            $this->checked_ssdb = true;
+            if (!$this->instant) {
+                $this->fallback = true;
+                return false;
+            } else {
+                return true;
+            }
+        }
+
+        return true;
+    }
+
+    function driver_set($keyword, $value = "", $time = 300, $option = array()) {
+        if ($this->connectServer()) {
+	        if (isset($option['skipExisting']) && $option['skipExisting'] == true) {
+		        $x = $this->instant->get($keyword);
+                if($x === false) {
+                    return false;
+                }elseif(!is_null($x)) {
+                    return true;
+                }
+	        }
+            $value = $this->encode($value);
+		    return $this->instant->setx($keyword, $value, $time);
+        } else {
+            return $this->backup()->set($keyword, $value, $time, $option);
+        }
+    }
+
+    function driver_get($keyword, $option = array()) {
+        if ($this->connectServer()) {
+            // return null if no caching
+	        // return value if in caching'
+	        $x = $this->instant->get($keyword);
+	        if($x == false) {
+		        return null;
+	        } else {
+		        return $this->decode($x);
+	        }
+        } else {
+            $this->backup()->get($keyword, $option);
+        }
+    }
+
+    function driver_delete($keyword, $option = array()) {
+        if ($this->connectServer()) {
+            $this->instant->del($keyword);
+        }
+    }
+
+    function driver_stats($option = array()) {
+        if ($this->connectServer()) {
+            $res = array(
+                "info" => "",
+                "size" => $this->instant->dbsize(),
+                "data" => $this->instant->info(),
+            );
+
+            return $res;
+        }
+
+        return array();
+    }
+
+    function driver_clean($option = array())
+    {
+        //Is not supported, only support command line operations
+        return false;
+    }
+
+    function driver_isExisting($keyword)
+    {
+        if ($this->connectServer()) {
+            $x = $this->instant->exists($keyword);
+            if ($x == null) {
+                return false;
+            } else {
+                return true;
+            }
+        } else {
+            return $this->backup()->isExisting($keyword);
+        }
+    }
+
+}

phpfastcache/3.0.0/phpfastcache.php

@@ -73,6 +73,13 @@ class phpFastCache {
 			"timeout"   =>  ""
 		),
 
+        "ssdb"         =>  array(
+			"host"  => "127.0.0.1",
+			"port"  =>  8888,
+			"password"  =>  "",
+			"timeout"   =>  ""
+		),
+
 		"extensions"    =>  array(),
 	);