美文网首页
[PDO]②0--获取一条记录

[PDO]②0--获取一条记录

作者: 子木同 | 来源:发表于2017-09-06 10:27 被阅读19次
     /**
     * 得到结果集的一条记录
     * @param null $sql
     * @return mixed
     */
    public function getRow($sql = null)
    {
        if ($sql != null) {
            self::query($sql);
        }
        $result = self::$PDOStatement->fetch(constant("PDO::FETCH_ASSOC"));
        return $result;
    }

    PdoMYSQL.class.php

    <?php

class PdoMYSQL
{
    public static $config = array();//设置配置参数，配置信息
    public static $link = null;//保存连接标识符
    public static $pconnect = false;//是否开启长连接
    public static $dbVersion = null;//保存数据库版本
    public static $connected = false;//判断是否连接成功
    public static $PDOStatement = null;//保存PDOStatement对象
    public static $queryStr = null;//保存最后执行的操作
    public static $error = null;//保存错误信息

    public function __construct($dbConfig = '')
    {
        if (!class_exists("PDO")) {
            self::throw_exception('不支持PDO，请先开启');
        }
        if (!is_array($dbConfig)) {
            $dbConfig = array(
                'hostname' => DB_HOST,
                'username' => DB_USER,
                'password' => DB_PWD,
                'database' => DB_NAME,
                'hostport' => DB_PORT,
                'dsn' => DB_TYPE . ":host=" . DB_HOST . ";dbname=" . DB_NAME);
        }
        if (empty($dbConfig['hostname']))
            self::throw_exception('没有定义数据库配置，请先定义');
        self::$config = $dbConfig;
        if (empty(self::$config['params']))
            self::$config['params'] = array();
        if (!isset(self::$link)) {
            $configs = self::$config;
            if (self::$pconnect) {
                //开启长连接，添加到配置数组中
                $configs['params'][constant("PDO::ATTR_PERSISTENT")] = true;
            }
            try {
                self::$link = new PDO($configs['dsn'], $configs['username'], $configs['password'], $configs['params']);
            } catch (PDOException $e) {
                self::throw_exception($e->getMessage());
            }
            if (!self::$link) {
                self::throw_exception('PDO连接错误');
                return false;
            }
            self::$link->exec('SET NAMES ' . DB_CHARSET);
            self::$dbVersion = self::$link->getAttribute(constant("PDO::ATTR_SERVER_VERSION"));
            self::$connected = true;
            unset($configs);
        }
    }

    /**得到所有记录
     * @param null $sql
     * @return mixed
     */
    public static function getAll($sql = null)
    {
        if ($sql != null) {
            self::query($sql);
        }
        $result = self::$PDOStatement->fetchAll(constant("PDO::FETCH_ASSOC"));
        return $result;
    }

    /**
     * 得到结果集的一条记录
     * @param null $sql
     * @return mixed
     */
    public function getRow($sql = null)
    {
        if ($sql != null) {
            self::query($sql);
        }
        $result = self::$PDOStatement->fetch(constant("PDO::FETCH_ASSOC"));
        return $result;
    }

    /**
     * 释放结果集
     */
    public static function free()
    {
        self::$PDOStatement = null;
    }

    public static function query($sql = '')
    {
        $link = self::$link;
        if (!$link) return false;
        //判断之前是否有结果集，如果有，释放结果集
        if (!empty(self::$PDOStatement)) self::free();
        self::$queryStr = $sql;
        self::$PDOStatement = $link->prepare(self::$queryStr);
        $res = self::$PDOStatement->execute();
        self::haveErrorThrowException();
        return $res;
    }

    public static function haveErrorThrowException()
    {
        $obj = empty(self::$PDOStatement) ? self::$link : self::$PDOStatement;
        $arrError = $obj->errorInfo();
        /**
         * Array
         * (
         * [0] => 42S02
         * [1] => 1146
         * [2] => Table 'test.user1' doesn't exist
         * )
         */
//        print_r($arrError);
        if ($arrError[0] != '00000') {
            self::$error = 'SQLSTATE ' . $arrError[0] . 'SQL Error: ' . $arrError[2] . '<br/>Error SQL: ' . self::$queryStr;
            self::throw_exception(self::$error);
            return false;
        }
        if (self::$queryStr == '') {
            self::throw_exception('没有执行SQL语句');
            return false;
        }
    }

    /**
     * 自定义错误处理
     * @param $errMsg
     */
    public
    static function throw_exception($errMsg)
    {
        echo '<div style="width:80%;background-color:#ABCDEF;color: black;font-size: 20px;padding: 20px 0px">
        ' . $errMsg . '</div>';
    }

}

require_once 'config.php';
$PdoMySQL = new PdoMYSQL();
//var_dump($PdoMySQL);//object(PdoMYSQL)[1]
//$sql = 'select * from user';
//print_r($PdoMySQL::getAll($sql));
$sql = 'SELECT * FROM user WHERE id>4';
print_r($PdoMySQL->getRow($sql));//Array ( [id] => 13 [username] => king4 [password] => king1 [email] => imoooc1@qq.com )
    Paste_Image.png 
    /**执行增删改操作，返回受影响的记录的条数
     * @param null $sql
     * @return bool|int
     */
    public static function execute($sql = null)
    {
        $link = self::$link;
        if (!$link) return false;
        self::$queryStr = $sql;
        if (!empty(self::$PDOStatement)) self::free();
        $result = $link->exec(self::$queryStr);
        self::haveErrorThrowException();
        if ($result) {
            self::$lastInsertId = $link->lastInsertId();
            self::$numRows = $result;
            return self::$numRows;
        } else {
            return false;
        }
    }

    PdoMYSQL.class.php

    <?php

class PdoMYSQL
{
    public static $config = array();//设置配置参数，配置信息
    public static $link = null;//保存连接标识符
    public static $pconnect = false;//是否开启长连接
    public static $dbVersion = null;//保存数据库版本
    public static $connected = false;//判断是否连接成功
    public static $PDOStatement = null;//保存PDOStatement对象
    public static $queryStr = null;//保存最后执行的操作
    public static $error = null;//保存错误信息
    public static $lastInsertId = null;//保存上一步插入操作产生AUTO_INCREMENT
    public static $numRows = 0;//上一步操作产生受影响的记录的条数

    public function __construct($dbConfig = '')
    {
        if (!class_exists("PDO")) {
            self::throw_exception('不支持PDO，请先开启');
        }
        if (!is_array($dbConfig)) {
            $dbConfig = array(
                'hostname' => DB_HOST,
                'username' => DB_USER,
                'password' => DB_PWD,
                'database' => DB_NAME,
                'hostport' => DB_PORT,
                'dsn' => DB_TYPE . ":host=" . DB_HOST . ";dbname=" . DB_NAME);
        }
        if (empty($dbConfig['hostname']))
            self::throw_exception('没有定义数据库配置，请先定义');
        self::$config = $dbConfig;
        if (empty(self::$config['params']))
            self::$config['params'] = array();
        if (!isset(self::$link)) {
            $configs = self::$config;
            if (self::$pconnect) {
                //开启长连接，添加到配置数组中
                $configs['params'][constant("PDO::ATTR_PERSISTENT")] = true;
            }
            try {
                self::$link = new PDO($configs['dsn'], $configs['username'], $configs['password'], $configs['params']);
            } catch (PDOException $e) {
                self::throw_exception($e->getMessage());
            }
            if (!self::$link) {
                self::throw_exception('PDO连接错误');
                return false;
            }
            self::$link->exec('SET NAMES ' . DB_CHARSET);
            self::$dbVersion = self::$link->getAttribute(constant("PDO::ATTR_SERVER_VERSION"));
            self::$connected = true;
            unset($configs);
        }
    }

    /**得到所有记录
     * @param null $sql
     * @return mixed
     */
    public static function getAll($sql = null)
    {
        if ($sql != null) {
            self::query($sql);
        }
        $result = self::$PDOStatement->fetchAll(constant("PDO::FETCH_ASSOC"));
        return $result;
    }

    /**
     * 得到结果集的一条记录
     * @param null $sql
     * @return mixed
     */
    public static function getRow($sql = null)
    {
        if ($sql != null) {
            self::query($sql);
        }
        $result = self::$PDOStatement->fetch(constant("PDO::FETCH_ASSOC"));
        return $result;
    }

    /**执行增删改操作，返回受影响的记录的条数
     * @param null $sql
     * @return bool|int
     */
    public static function execute($sql = null)
    {
        $link = self::$link;
        if (!$link) return false;
        self::$queryStr = $sql;
        if (!empty(self::$PDOStatement)) self::free();
        $result = $link->exec(self::$queryStr);
        self::haveErrorThrowException();
        if ($result) {
            self::$lastInsertId = $link->lastInsertId();
            self::$numRows = $result;
            return self::$numRows;
        } else {
            return false;
        }
    }


    /**
     * 释放结果集
     */
    public static function free()
    {
        self::$PDOStatement = null;
    }

    public static function query($sql = '')
    {
        $link = self::$link;
        if (!$link) return false;
        //判断之前是否有结果集，如果有，释放结果集
        if (!empty(self::$PDOStatement)) self::free();
        self::$queryStr = $sql;
        self::$PDOStatement = $link->prepare(self::$queryStr);
        $res = self::$PDOStatement->execute();
        self::haveErrorThrowException();
        return $res;
    }

    public static function haveErrorThrowException()
    {
        $obj = empty(self::$PDOStatement) ? self::$link : self::$PDOStatement;
        $arrError = $obj->errorInfo();
        /**
         * Array
         * (
         * [0] => 42S02
         * [1] => 1146
         * [2] => Table 'test.user1' doesn't exist
         * )
         */
//        print_r($arrError);
        if ($arrError[0] != '00000') {
            self::$error = 'SQLSTATE ' . $arrError[0] . 'SQL Error: ' . $arrError[2] . '<br/>Error SQL: ' . self::$queryStr;
            self::throw_exception(self::$error);
            return false;
        }
        if (self::$queryStr == '') {
            self::throw_exception('没有执行SQL语句');
            return false;
        }
    }

    /**
     * 自定义错误处理
     * @param $errMsg
     */
    public
    static function throw_exception($errMsg)
    {
        echo '<div style="width:80%;background-color:#ABCDEF;color: black;font-size: 20px;padding: 20px 0px">
        ' . $errMsg . '</div>';
    }

}

require_once 'config.php';
$PdoMySQL = new PdoMYSQL();

//$sql = 'INSERT user(username,password,email) ';
//$sql .= "VALUES('imooc111','imooc122','imooc@imooc.com')";
//var_dump($PdoMySQL::execute($sql));//int 1
//echo $PdoMySQL::$lastInsertId;//65

//$sql = 'DELETE FROM user WHERE id>15';
//var_dump($PdoMySQL::execute($sql));//int 22

$sql = 'UPDATE user SET username="king1234" WHERE id=14';
var_dump($PdoMySQL::execute($sql));//int 1

    相关文章

      网友评论

          本文标题：[PDO]②0--获取一条记录

          本文链接：https://www.haomeiwen.com/subject/mkqpjxtx.html

          延伸阅读

          深度阅读

          • 您也可以注册成为美文阅读网的作者，发表您的原创作品、分享您的心情！

          栏目导航

          热点阅读

          关于我们|服务条款|联系我们|[PDO]②0--获取一条记录|投稿指南|网站地图|RSS订阅|排版工具|手机版

          提供经典美文摘抄,优美散文欣赏,现代诗歌精选,短篇小说,心情随笔,表白情书范文,故事会在线阅读欣赏

          Copyright © 2014-2023 Haomeiwen.com All Rights Reserved. 好美文阅读网 版权所有

          备案信息：桂公网安备 45052102000051号 · 桂ICP备13007215号-3

          本站所收录作品、热点评论等信息部分来源互联网，目的只是为了系统归纳学习和传递资讯

          所有作品版权归原创作者所有，与本站立场无关，如不慎侵犯了你的权益，请联系我们告知，我们将做删除处理！