Init commit

MySQLiConvertor.php

@@ -0,0 +1,208 @@
+<?php
+/**
+ *
+ * @author Daeus Tang 
+ * @version Alpha
+ *
+ */
+
+class SqliConvertor{
+
+    private $db;
+    private $query;
+
+	public function __construct($host, $username, $password, $db_name){
+
+		$this->db = new mysqli($host, $username, $password, $db_name);
+		if ($this->db->connect_errno) {
+			throw Exception("Failed to connect: {$this->db->connect_error}");
+		}   
+	}   
+
+    public function real_escape_string($q)
+    {
+        return $this->db->real_escape_string($q);
+    }
+
+    public function escape_string($q)
+    {
+        return $this->db->real_escape_string($q);
+    }
+
+	public function escape($q, $quote = false)
+	{
+        if($quote)
+        {
+            return "'" . $this->db->real_escape_string($q) . "'";
+        }
+        else
+        {
+            return $this->db->real_escape_string($q);
+        }
+    }
+
+    public function query($sql)
+    {
+        $this->query = $this->db->query($sql);
+        return $this->query;
+    }
+
+    public function error()
+    {
+        return $this->db->error;
+    }
+
+    public function numrows(&$query = NULL)
+    {
+        return $this->num_rows($query);
+    }
+
+    public function num_rows(&$query = NULL)
+    {
+        if($query !== NULL)
+        {
+            $this->query = $query;
+        }
+        return $this->query->num_rows;
+    }
+
+    public function fetch_array(&$query = NULL)
+    {
+        if($query !== NULL)
+        {
+            $this->query = $query;
+        }
+        return $this->query->fetch_array(); 
+    }
+
+    public function fetch_object(&$query, $className = 'stdClass', $params = NULL)
+    {
+        $this->query = $query;
+        if($params === NULL)
+        {
+            return $query->fetch_object($className);
+        } 
+        else 
+        {
+            return $query->fetch_object($className, $params);
+        }
+    }
+
+    public function result(&$query, $row, $field = 0)
+    {
+        $this->query = $query;
+
+        //seek to row
+        $query->data_seek($row);
+
+        //seek field
+        if(is_integer($field))
+        {
+            $row = $query->fetch_row();
+            $row->field_seek($field);
+            return $result->fetch_field();
+        } 
+        else
+        {
+            $row = $query->fetch_assoc();
+            return $row[$field];
+        }
+
+    }
+
+    public function insert_id(){
+        return $this->db->insert_id;    
+    }
+
+    /**
+     * Self-defined function
+     */
+    public function result_array($sql, $params = NULL, $field_name = NULL)
+    {
+        $sql = $this->build_sql($sql, $params);
+        $query = $this->db->query($sql);
+        if( !$query )
+        {
+            //throw new Exception("result_array error. Please check your SQL: " . $sql);
+        }
+        $result = ''; 
+        if($field_name === NULL){
+            while($row = $query->fetch_assoc())
+            {
+                $result[] = $row;
+            }
+        }else{
+            while($row = $query->fetch_assoc())
+            {
+                $result[] = $row[$field_name];
+            }
+        
+        }
+        return $result;
+    }   
+
+    public function run_query($sql, $params = NULL)
+    {
+        $sql = $this->build_sql($sql, $params);
+        $query = $this->query($sql);
+        if( !$query )
+        {
+            //throw new Exception("run_query error. Please check your SQL: " . $sql);
+        }
+        return $query;
+    }
+
+    public function insert($sql, $params = NULL)
+    {
+        $sql = $this->build_sql($sql, $params);
+        $this->query = $this->db->query($sql);
+        if( !$this->query )
+        {
+            //throw new Exception("insert error. Please check your SQL: " . $sql);
+        }
+        return $this->db->insert_id;
+    }   
+
+    public function row_array($sql, $params = NULL, $field_name = NULL)
+    {
+        $sql = $this->build_sql($sql, $params);
+        $this->query = $this->db->query($sql);
+        if( !$this->query )
+        {
+            //throw new Exception("result_row error. Please check your SQL: " . $sql);
+        }
+        $row = $this->query->fetch_assoc();
+        if( !$field_name == NULL)
+        {
+            return $row[$field_name];
+        }
+        else
+        {
+            return $row;
+        }
+    }   
+
+    public function build_sql($sql, $params = NULL)
+    {
+        if( !$params == NULL )
+        {
+            $sql = str_replace('?', '%s', $sql);
+            if( is_array($params) )
+            {
+                foreach($params as &$p)
+                {
+                    $p = "'" . $this->db->real_escape_string($p) . "'";
+                }
+				return vsprintf($sql, $params);
+
+            } else {
+                $params = "'" . $this->db->real_escape_string($params) . "'";
+				return sprintf($sql, $params);
+            }
+        }
+        return $sql;
+    }
+
+}
+
+?>

README.md

@@ -0,0 +1,27 @@
+MySQLi Convertor
+===========
+
+A simple trick to convert old depreciable mysql code to mysqli in PHP
+
+**IMPORTANT: Noted that converting mysql to mysqli doesn't enhance your system security. It is recommended to rewrite your system in a modern and security approach.**
+
+The project is unfinished. It currently doesn't include all of the function in mysql. 
+
+SETUP
+------
+
+
+1. Include the convertor in your code
+```
+include 'SqliConvertor.php'; 
+```
+
+2. Set up the connection
+```
+$sqliConvertor = new SqliConvertor($host, $username, $password, $db_name);
+```
+
+3. Replace all the string "mysql_" to "$sqliConvertor->" in your file. If you are using Vim, you may use the following command
+```
+:%s/mysql_/$sqliConvertor->/g
+```