db_mysqli

<?php

$root_dir_mysqli = dirname(__FILE__);

include_once $root_dir_mysqli.'/file.php';

class DbMysqliOperation{

    //数据库资源

    public $connection = null;

    //数据库资源

    public $fileOperation = null;

    function __construct($dbhost='10.3.255.21', $username='off_dbsrt', $password='65c16c8b6', $db_name='ganji_vehicle', $port=3310){

        $this->connection = mysqli_connect($dbhost, $username,  $password, $db_name, $port);

        mysqli_query($this->connection, "set names utf8");

        //$this->fileOperation = new FileOperation('chexi_and_chexing');

        $this->fileOperation = new FileOperation('yiche_chexing_map');

    }

    public function lastInsertId()

    {

        $id = $this->getOneRecord('SELECT LAST_INSERT_ID() AS insertID');

        if($id !== false && !empty($id) && isset($id['insertID']))

        {

            return $id['insertID'];

        }

        else

        {

            return null;

        }

    }

    function query($sql, $fun) {

        if (mysqli_query($this->connection, $sql)) {

            echo "MySQL query is ok! fun:".$fun." \n";

            return $this->lastInsertId();

        }else{

            $this->fileOperation->writeToTxt($sql." \n");

            $this->fileOperation->writeToTxt("MySQL query is error! fun:".$fun." \n");

            echo "==============================".$sql." \n";

            echo "==============================MySQL query is error! fun:".$fun." \n";

        }

    }

    function update_query($sql) {

        //用sql 增加新的数据

        $result = mysqli_query($this->connection, $sql);

        if(!$result){

            echo "MySQL update_query is error! \n";

        }

    }

    function getAllRecord($sql='') {

        if ($result = mysqli_query($this->connection, $sql))

        {

            $res = array();

            while($row = mysqli_fetch_assoc($result))

            {

                $res[] = $row;

            }

            mysqli_free_result($result);

            return $res;

        } else {

            echo "MySQL getAllRecord is error! \n";

        }

    }

    function getOneRecord($sql='') {

        if($result = mysqli_query($this->connection, $sql))

        {

            $res = mysqli_fetch_assoc($result);

            mysqli_free_result($result);

            return $res;

        } else {

            echo "MySQL getOneRecord is error! \n";

        }

    }

}//class end