<?php

class MysqlController extends ControllerBase
{
    public $config = array();
    public $mysql = NULL;
    
    public function initialize(){
        $this->config = array(
            ‘host‘=>‘localhost:3306‘,
            ‘username‘=>‘daokrdb‘,
            ‘password‘=>‘123456‘,
            ‘dbname‘=>‘daokrdb‘,
        );
    }
    
 
public function indexAction()
    {
        // 創建連接
        $mysql = new mysqli($this->config[‘host‘], $this->config[‘username‘], $this->config[‘password‘], $this->config[‘dbname‘]);
        /* change db to world db */
        //$mysqli->select_db("world"); //可以利用select_db 改變數據庫
        // Check connection
 

        if ($mysql->connect_error) {
            die("連接失敗: " . $mysql->connect_error);
        }else{
            $thread_id = $mysql->thread_id;
            echo "mysql 的主機信息：".$mysql->host_info."<br/>";
            echo "mysql 查看服務器信息：".$mysql->server_info."<br/>";
            
 
echo "mysql 獲取最近一次數據庫查詢的信息：".$mysql->info."<br/>";
            echo "mysql 獲取當前系統狀態：".$mysql->stat()."<br/>";
            echo "mysql 是否線程安全：".$mysql->thread_safe()."<br>";
            echo "mysql 返回當前連接的線程ID：".$thread_id."<br>";
            $this->mysql = $mysql;
        }
        /* 設置客戶端字符集 */
        if (!$mysql->set_charset("utf8")) {
            echo("設置utf8錯誤: ".$mysql->error."<br>");
        } else {
            echo("當前已設置的字符集:".$mysql->character_set_name()."<br>");
        }
        
        /* kill 當前連接線程 */
        //$mysql->kill($thread_id);
        $this->insert();
        $this->select();
        $this->find();
        $this->delete();
        $this->update();
        
        
        $mysql->close();
    }
    function select(){
        $sql = "SELECT t.* FROM t_users t";
        $result = $this->mysql->query($sql);
        if($result->num_rows>0){
            while ($row = $result->fetch_assoc())
            {
                echo "編號:".$row[‘id‘]." 標題:".$row[‘title‘]."<br>";
            }
            $result->close();
        }
    }
    //增
    function insert(){
        $sql = "INSERT INTO t_users (title, author,submission_date) VALUES (‘John‘, ‘Doe‘, NOW())";
        
        if ($this->mysql->query($sql) === TRUE) {
            echo "新記錄插入成功<br/>";
        } else {
            echo "Error: " . $sql . "<br>" . $this->mysql->error;
        }
        $name = "學習 PHP";
        $query = "SELECT title FROM t_users WHERE title=?";
        $binduser = $this->mysql->prepare($query); 
        if($binduser){
            $binduser->bind_param(‘s‘, $name);//i - integer（整型）d - double（雙精度浮點型）s - string（字符串）b - BLOB（binary large object:二進制大對象）
            $binduser->execute();
            $binduser->bind_result($title); 
            $binduser->fetch();
            echo "bind_result 查詢成功：".$title."<br/>";
            $binduser->close();
        }
    }
    //刪
    function delete(){
        $sql = ‘delete from t_users where title="d" ‘;
        $result = $this->mysql->query($sql);
        if($result){
            echo "刪除成功<br>";
        }else{
            echo "Error: " . $sql . "<br>" . $this->mysql->error;
        }
    }
    //改
    function update(){
        $sql = ‘update t_users set title="PHP webs" where id=31‘;
        $result = $this->mysql->query($sql);
        if($result){
            echo "更新成功<br>";
        }else{
            echo "Error: " . $sql . "<br>" . $this->mysql->error;
        }
    }

    
}

mysqli的方法測試小結