Creating a new connector for yii2.

1 files changed, 69 insertions, 0 deletions

diff --git a/codebase/DataStorage/MySQLDBDataWrapper.php b/codebase/DataStorage/MySQLDBDataWrapper.php
new file mode 100644
index 0000000..3f13492
--- /dev/null
+++ b/codebase/DataStorage/MySQLDBDataWrapper.php
@@ -0,0 +1,69 @@
+<?php
+namespace DHTMLX\Connector\DataStorage;
+
+
+/*! Implementation of DataWrapper for MySQL
+**/
+class MySQLDBDataWrapper extends DBDataWrapper{
+    protected $last_result;
+    public function query($sql){
+        LogMaster::log($sql);
+        $res=mysql_query($sql,$this->connection);
+        if ($res===false) throw new Exception("MySQL operation failed\n".mysql_error($this->connection));
+        $this->last_result = $res;
+        return $res;
+    }
+
+    public function get_next($res){
+        if (!$res)
+            $res = $this->last_result;
+
+        return mysql_fetch_assoc($res);
+    }
+
+    public function get_new_id(){
+        return mysql_insert_id($this->connection);
+    }
+
+    public function escape($data){
+        return mysql_real_escape_string($data, $this->connection);
+    }
+
+    public function tables_list() {
+        $result = mysql_query("SHOW TABLES");
+        if ($result===false) throw new Exception("MySQL operation failed\n".mysql_error($this->connection));
+
+        $tables = array();
+        while ($table = mysql_fetch_array($result)) {
+            $tables[] = $table[0];
+        }
+        return $tables;
+    }
+
+    public function fields_list($table) {
+        $result = mysql_query("SHOW COLUMNS FROM `".$table."`");
+        if ($result===false) throw new Exception("MySQL operation failed\n".mysql_error($this->connection));
+
+        $fields = array();
+        $id = "";
+        while ($field = mysql_fetch_assoc($result)) {
+            if ($field['Key'] == "PRI")
+                $id = $field["Field"];
+            else
+                $fields[] = $field["Field"];
+        }
+        return array("fields" => $fields, "key" => $id );
+    }
+
+    /*! escape field name to prevent sql reserved words conflict
+        @param data
+            unescaped data
+        @return
+            escaped data
+    */
+    public function escape_name($data){
+        if ((strpos($data,"`")!==false || is_int($data)) || (strpos($data,".")!==false))
+            return $data;
+        return '`'.$data.'`';
+    }
+}
\ No newline at end of file