面向对象风格的 MySQLi

使用方法：

$database = new database_mysqli("localhost", "username", "password", "databasename");

//show full results - single query
$sql = "SHOW TABLES";
$tables = $database->query($sql);

//execute multiple queries
$sql = array ("SELECT * FROM blogs WHERE userId = 2", "SELECT * FROM comments WHERE userId = 2");
$results = $database->query($sql, "", true, true);

//execute query, dont care about results
$sql = "DELETE FROM blogs WHERE userID = 2";
$database->justquery($sql);

//show first row only
$sql = "SHOW TABLES";
$firstTable = $database->loadFirstRow($sql);

//show first element of first row only (useful for SELECT COUNT(*) statements)
$sql = "SELECT COUNT(*) FROM users AS U";
$total = $database->loadResult($sql);

$database->destroyConnection();

php代码：

<?php

/**
 * This is the MySQLi OOP database interface class
 * @package Skyward_Landing_Page
 * @subpackage Database Interface
 * @filesource
 * @author Matt Ford
 * @version 2.0
 */

class database_mysqli {

    /**
     * database server hostname/IP
     * @var string
     */
    private $host = NULL;

    /**
     * SQL Server login username, encrypted for privacy
     * @var string
     */
    private $username = NULL;

    /**
     * SQL Server login password, encrypted for privacy
     * @var string
     */
    private $password = NULL;

    /**
     * name of database
     * @var string
     */
    public $databaseName = NULL;

    /**
     * SQL Server connection resource
     * @var object
     */
    public $link = NULL;

    /**
     * array of queries run against this object
     * @var array
     */
    public $queries = NULL;

    /**
     * any errors resulting from queries
     * @var array
     */
    public $errors = NULL;

    public function __construct($host, $username, $password, $database) {

        $this->host = $host;
        $this->username = sha1($username);
        $this->password = sha1($password);
        $this->databaseName = $database;
        $this->link = "";
        $this->queries = array ();
        $this->errors = array ();

        $this->sqls = array ();

        $this->link = @new mysqli($this->host, $username, $password);
        if ($this->link->connect_error != null) {
            die("Connect Error: " . $this->link->connect_error);
        }
        else {
            if ($this->link->select_db($this->databaseName) === false) {
                die("Cannot Select Table: " . $this->link->error);
            } else {}
        }
    }

    /**
     * This method kills the MySQLi connection
     * @access public
     * @author Matt Ford
     */
    public function destroyConnection() {
        $this->link->kill($this->link->thread_id);
        $this->link->close();
    }

    /**
     * This method executes a query and returns the raw result resource
     * @access public
     * @author Matt Ford
     * @param string $sql string query
     * @return object raw SQL result resource
     */
    public function justquery($sql) {
        $this->queries[] = $sql;
        return $this->link->query($sql);
    }

    /**
     * This method loads the first value of the first column of the first row of results
     * @access public
     * @author Matt Ford
     * @param string $sql string query
     * @return string result from first column of first row of query results
     */
    public function loadResult($sql) {
        if (!($cur = $this->justquery($sql))) {
            return null;
        }
        $ret = null;
        if ($row = $cur->fetch_row()) {
            $ret = $row[0];
        }
        $cur->free();
        return $ret;
    }

    /**
     * This method returns the first row of results
     * @access public
     * @author Matt Ford
     * @param string $sql string query
     * @return object first row of results
     */
    public function loadFirstRow($sql) {
        if (!($cur = $this->justquery($sql))) {
            return null;
        }
        $ret = null;
        if ($row = $cur->fetch_object()) {
            $ret = $row;
        }
        $cur->free();
        return $ret;
    }

    /**
     * This method returns the auto-increment value from the last query run
     * @access public
     * @author Matt Ford
     * @return int auto-incremeted (primary key) value of last query
     */
    public function insertid() {
        return $this->link->insert_id;
    }

    /**
     * This method returns the number of affected rows in the last insert/update/replace/delete query
     * @access public
     * @author Matt Ford
     * @return int number of affected rows
     */
    public function numAffectedRows() {
        return $this->link->affected_rows;
    }

    /**
     * This method queries the database, logs data, and returns results
     * @access public
     * @author Matt Ford
     * @param string|array $sql depending on $batch flag, could be a single string query or an array of queries to run
     * @param string $key if supplied, each group of results will be indexed with its respective $key&#39;s column value as its object index/position
     * @param bool $returns determins if any results will be returned or not, merely for I/O
     * @param bool $batch flag denoting whether $sql is a string query or an array of queries to loop over
     * @return unset|object depending on $returns, could be nothing, or an object of query results
     */
    public function query($sql, $key = "", $returns = true, $batch = false) {
        $sqls = $result = array ();

        switch ($batch) {
            default:
            case true:
                foreach ($sql as $index => $query) {
                    $this->queries[] = $query;
                    $answer = $this->link->query($query);

                    if (!$answer) {
                        $this->errors[] = $this->link->error;
                    }
                    else {
                        if ($returns != false) {
                            if ($answer->num_rows > 0){
                                while ($row = $answer->fetch_object()) {
                                    if ($key != ""){
                                        $result[$index][$row->$key] = $row;
                                    }
                                    else {
                                        $result[$index][] = $row;
                                    }
                                }
                                $answer->free();
                            } else {}
                        } else {}
                    }
                }
                break;

            case false:
                $this->queries[] = $sql;
                $answer = $this->link->query($sql);

                if (!$answer) {
                    $this->errors[] = $this->link->error;
                    $result = false;
                }
                else {
                    if ($returns != false) {
                        if ($answer->num_rows > 0){
                            while ($row = $answer->fetch_object()) {
                                if ($key != ""){
                                    $result[$row->$key] = $row;
                                }
                                else {
                                    $result[] = $row;
                                }
                            }
                            $answer->free();
                        } else {}
                    }
                    else {
                        $result = true;
                    }
                }
                break;
        }

        return $result;
    }

    /**
     * This method simply uses the database library&#39;s string escape utility
     * @access public
     * @author Matt Ford
     * @param string $string string needing escaping
     * @return string escaped string
     */
    public function escapeString($string) {
        return $this->link->real_escape_string($string);
    }

    /**
     * This method builds INSERT/UPDATE queries to allow easy query generation/maintenance for long queries.
     * @access public
     * @author Matt Ford
     * @param array $params key/value pair array of parameters for query
     * @return string resulting Query string for MySQLi
     */
    public function buildSQL($params) {
        /*
        Usage

        #INSERT Statements

            $params = array (
                    "type"      => "insert",
                    "table"     => "eventCal_events",
                    "doNotQuote"    => array(),
                    "data"      => array (
                                "eventName"             => $data->request["eventName"],
                                "eventText"             => $data->request["eventText"],
                                "eventLocation"         => $data->request["eventLocation"],
                                "eventStartDate_month"      => $start["month"],
                                "eventStartDate_day"        => $start["day"],
                                "eventStartDate_year"       => $start["year"],
                                "eventStartDate_time"       => $start["time"],
                                "eventStartDate_timestamp"  => $timestampStart,
                                "eventEndDate_month"        => $end["month"],
                                "eventEndDate_day"      => $end["day"],
                                "eventEndDate_year"         => $end["year"],
                                "eventEndDate_time"         => $end["time"],
                                "eventEndDate_timestamp"    => $timestampEnd,
                                "occursMonthly"         => $occursMonthly,
                                "occursYearly"          => $occursYearly,
                                "dynamicEvent"          => $dynamicEvent,
                                "dynNthDay"             => $data->request["dynOccurrence_freq"],
                                "dynDayName"            => $data->request["dynOccurrence_day"],
                                "dynMonth"          => $data->request["dynOccurrence_month"]
                            )
                );
            $sql = $database->buildSQL($params);



        #UPDATE Statements

            $params = array (
                    "type"      => "update",
                    "table"     => "eventCal_events",
                    "doNotQuote"    => array(),
                    "data"      => array (
                                "eventName"             => $data->request["eventName"],
                                "eventText"             => $data->request["eventText"],
                                "eventLocation"         => $data->request["eventLocation"],
                                "eventStartDate_month"      => $start["month"],
                                "eventStartDate_day"        => $start["day"],
                                "eventStartDate_year"       => $start["year"],
                                "eventStartDate_time"       => $start["time"],
                                "eventStartDate_timestamp"  => $timestampStart,
                                "eventEndDate_month"        => $end["month"],
                                "eventEndDate_day"      => $end["day"],
                                "eventEndDate_year"         => $end["year"],
                                "eventEndDate_time"         => $end["time"],
                                "eventEndDate_timestamp"    => $timestampEnd,
                                "occursMonthly"         => $occursMonthly,
                                "occursYearly"          => $occursYearly,
                                "dynamicEvent"          => $dynamicEvent,
                                "dynNthDay"             => $data->request["dynOccurrence_freq"],
                                "dynDayName"            => $data->request["dynOccurrence_day"],
                                "dynMonth"          => $data->request["dynOccurrence_month"]
                            ),
                    "where"     => array (
                                "eventID"           => $data->request["eventID"],
                                "eventCreator"          => $my->userID
                            )
                );
            $sql = $database->buildSQL($params);
        */
        $sql = "";
        $fieldQuantifier = "`";
        $valueQuantifier = &#39;"&#39;;

        $params["type"] = strtolower($params["type"]);
        $params["doNotQuote"] = (is_array($params["doNotQuote"]) === true) ? $params["doNotQuote"] : array();

        foreach ($params["data"] as $k => $v) {
            $value = stripslashes($v);
            $params["data"][$k] = $this->escapeString($value);
        }

        switch ($params["type"]) {
            case "insert":
                $sql .= "INSERT INTO " . $fieldQuantifier . $params["table"] . $fieldQuantifier . " ";
                $sql .= "(" . $fieldQuantifier . implode($fieldQuantifier . ", " . $fieldQuantifier, array_keys($params["data"])) . $fieldQuantifier . ") ";
                $sql .= "VALUES(";

                $vars = array();
                foreach ($params["data"] as $k => $v) {
                    $v = (in_array($k, $params["doNotQuote"])) ? $v : $valueQuantifier . $v . $valueQuantifier;
                    $vars[] = $v;
                }

                $sql .= implode(", ", $vars);
                $sql .= ");";
                break;

            case "update":
                $sql .= "UPDATE " . $fieldQuantifier . $params["table"] . $fieldQuantifier . " SET ";

                $vars = array();
                foreach ($params["data"] as $k => $v) {
                    $v = (in_array($k, $params["doNotQuote"])) ? $v : $valueQuantifier . $v . $valueQuantifier;
                    $vars[] = $fieldQuantifier . $k . $fieldQuantifier . " = " . $v;
                }

                $sql .= implode(", ", $vars);
                $vars = array();
                if ($params["where"]) {
                    $sql .= " WHERE ";
                    foreach ($params["where"] as $k => $v) {
                        $vars[] = $fieldQuantifier . $k . $fieldQuantifier . " = " . $valueQuantifier . $v . $valueQuantifier;
                    }
                    $sql .= implode(" AND ", $vars);
                } else {}
                $sql .= ";";
                break;
        }

        return $sql;
    }
}
?>