Added connection management functions for Unix sockets in

src/DB.php

@@ -59,6 +59,13 @@ class DB
      */
     protected static $telegram;
 
+    /**
+     * The encoding used
+     *
+     * @var string
+     */
+    protected static $encoding;
+
     /**
      * Initialize
      *
@@ -102,12 +109,68 @@ public static function initialize(
         self::$telegram          = $telegram;
         self::$mysql_credentials = $credentials;
         self::$table_prefix      = $table_prefix;
+        self::$encoding          = $encoding;
 
         self::defineTables();
 
         return self::$pdo;
     }
 
+    /**
+     * Disconnects from the database
+     *
+     * @return void
+     */
+    public static function disconnect()
+    {
+        self::$pdo = null;
+    }
+
+    /**
+     * Reconnects to the database
+     *
+     * @return void
+     * @throws TelegramException
+     */
+    public static function connect()
+    {
+        if (empty(self::$mysql_credentials))
+        {
+            throw new TelegramException('MySQL credentials not provided!');
+        }
+
+        if (isset(self::$mysql_credentials['unix_socket']))
+        {
+            $dsn = 'mysql:unix_socket=' . self::$mysql_credentials['unix_socket'];
+        }
+        else
+        {
+            $dsn = 'mysql:host=' . self::$mysql_credentials['host'];
+        }
+
+        $dsn .= ';dbname=' . self::$mysql_credentials['database'];
+
+        if (!empty(self::$mysql_credentials['port']))
+        {
+            $dsn .= ';port=' . self::$mysql_credentials['port'];
+        }
+
+        $options = [PDO::MYSQL_ATTR_INIT_COMMAND => 'SET NAMES ' . self::$encoding];
+
+        try
+        {
+            $pdo = new PDO($dsn, self::$mysql_credentials['user'], self::$mysql_credentials['password'], $options);
+            $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);
+        }
+        catch (PDOException $e)
+        {
+            throw new TelegramException($e->getMessage());
+        }
+
+        self::$pdo = $pdo;
+
+    }
+
     /**
      * External Initialize
      *
@@ -459,7 +522,7 @@ protected static function insertTelegramUpdate(
                 // Add the update ID to a set
                 $redis->lPush('telegram_update_ids', $update_id);
             }
-            
+
             // Sort the set now instead of later.
             $redis->sort('telegram_update_ids');
             // Actually add the update to redis

src/package.json

@@ -2,7 +2,7 @@
     "package": {
         "package_name": "net.intellivoid.tdlib",
         "name": "Telegram Database Library for Bots",
-        "version": "1.0.1.4",
+        "version": "1.0.1.5",
         "author": "Zi Xing Narrakas",
         "organization": "Intellivoid Technologies",
         "description": "Allows bot clients to communicate with the Telegram Bot API server",
@@ -671,4 +671,4 @@
     "files": [
         "package.json"
     ]
-}
+}