国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 語言 > PHP > 正文

Yaf框架封裝的MySQL數據庫操作示例

2024-05-05 00:07:13
字體:
來源:轉載
供稿:網友

本文實例講述了Yaf框架封裝的MySQL數據庫操作。分享給大家供大家參考,具體如下:

Yaf封裝DB簡單操作

介紹

因為Yaf是一個純天然的MVC闊架,本人還在貝銳的時候就和主管一起用Yaf框架去重構了向日葵的網站端,到后面,Yaf也逐漸應用到了其他項目上,但是Yaf是沒有帶DB類庫的,所以本人也共享下最近封裝的代碼!

代碼

使用PDO封裝MySQL操作

class Db_Mysql{  private $_options = array();  private $db;  private $statement;  private $_fetchMode = 2;  /**   * 構造函數   *   * @param string $host   * @param string $username   * @param string $password   * @param string $dbname   * @param string $charset   */  private function __construct($host, $username, $password, $dbname, $charset)  {    //初始化數據連接    try {      $dns = 'mysql:dbname=' . $dbname . ';host=' . $host;      $this->db = new PDO($dns, $username, $password, array(PDO::ATTR_PERSISTENT => true, PDO::ATTR_AUTOCOMMIT => 1));      $this->db->query('SET NAMES ' . $charset);    } catch (PDOException $e) {      echo header("Content-type: text/html; charset=utf-8");      echo '<pre />';      echo '<b>Connection failed:</b>' . $e->getMessage();      die;    }  }  /**   * 調用初始化MYSQL連接   *   * @param string $config   * @return Aomp_Db_Mysql   */  static public function getInstance($config = '')  {    $host = $config->host;    $username = $config->username;    $password = $config->password;    $dbname = $config->dbname;    $charset = $config->charset;    $db = new self($host, $username, $password, $dbname, $charset);    return $db;  }  /**   * 獲取多條數據   *   * @param string $sql   * @param array $bind   * @param string $fetchMode   * @return multitype:   */  public function fetchAll($sql, $bind = array(), $fetchMode = null)  {    if($fetchMode === NULL){      $fetchMode = $this->_fetchMode;    }    $stmt = $this->query($sql, $bind);    $res = $stmt->fetchAll($fetchMode);    return $res;  }  /**   * 獲取單條數據   *   * @param string $sql   * @param array $bind   * @param string $fetchMode   * @return mixed   */  public function fetchRow($sql, array $bind = array(), $fetchMode = null)  {    if ($fetchMode === null) {      $fetchMode = $this->_fetchMode;    }    $stmt = $this->query($sql, $bind);    $result = $stmt->fetch($fetchMode);    return $result;  }  /**   * 獲取統計或者ID   *   * @param string $sql   * @param array $bind   * @return string   */  public function fetchOne($sql, array $bind = array())  {    $stmt = $this->query($sql, $bind);    $res = $stmt->fetchColumn(0);    return $res;  }  /**   * 增加   *   * @param string $table   * @param array $bind   * @return number   */  public function insert($table, array $bind)  {    $cols = array();    $vals = array();    foreach ($bind as $k => $v) {      $cols[] = '`' . $k . '`';      $vals[] = ':' . $k;      unset($bind[$k]);      $bind[':' . $k] = $v;    }    $sql = 'INSERT INTO '      . $table      . ' (' . implode(',', $cols) . ') '      . 'VALUES (' . implode(',', $vals) . ')';    $stmt = $this->query($sql, $bind);    $res = $stmt->rowCount();    return $res;  }  /**   * 刪除   *   * @param string $table   * @param string $where   * @return boolean   */  public function delete($table, $where = '')  {    $where = $this->_whereExpr($where);    $sql = 'DELETE FROM '      . $table      . ($where ? ' WHERE ' .$where : '');    $stmt = $this->query($sql);    $res = $stmt->rowCount();    return $res;  }  /**   * 修改   *   * @param string $table   * @param array $bind   * @param string $where   * @return boolean   */  public function update($table, array $bind, $where = '')  {    $set = array();    foreach ($bind as $k => $v) {      $bind[':' . $k] = $v;      $v = ':' . $k;      $set[] = $k . ' = ' . $v;      unset($bind[$k]);    }    $where = $this->_whereExpr($where);    $sql = 'UPDATE '      . $table      . ' SET ' . implode(',', $set)      . (($where) ? ' WHERE ' . $where : '');    $stmt = $this->query($sql, $bind);    $res = $stmt->rowCount();    return $res;  }  /**   * 獲取新增ID   *   * @param string $tableName   * @param string $primaryKey   * @return string   */  public function lastInsertId()  {    return (string) $this->db->lastInsertId();  }  public function query($sql, $bind = array())  {    if(!is_array($bind)){      $bind = array($bind);    }    $stmt = $this->prepare($sql);    $stmt->execute($bind);    $stmt->setFetchMode($this->_fetchMode);    return $stmt;  }  public function prepare($sql = '')  {    if(empty($sql)){      return false;    }    $this->statement = $this->db->prepare($sql);    return $this->statement;  }  public function execute($param = '')  {    if(is_array($param)){      try {        return $this->statement->execute($param);      } catch (Exception $e) {        return $e->getMessage();      }    }else {      try {        return $this->statement->execute();      } catch (Exception $e) {        return $e->getMessage();      }    }  }  /**   *   * @param string $where   * @return null|string   */  protected function _whereExpr($where)  {    if(empty($where)){      return $where;    }    if(!is_array($where)){      $where = array($where);    }    $where = implode(' AND ', $where);    return $where;  }  /**   * 關閉數據庫操作   */  public function close()  {    $this->_db = null;  }}

配置

db.type = 'mysql'db.host = '127.0.0.1'db.username = 'root'db.password = '123456'db.dbname = 'test'db.charset = 'UTF8'

調用方法

class TestController extends Yaf_Controller_Abstract{  public function indexAction()  {    $config = Yaf_Application::app()->getConfig()->db;    $db = Db_Mysql::getInstance($config);    $row = $db->fetchOne('select count(*) from `user`');    print_r($row);die;  }}

結果

Yaf框架,封裝,MySQL,數據庫

 

希望本文所述對大家PHP程序設計有所幫助。


注:相關教程知識閱讀請移步到PHP教程頻道。
發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表

圖片精選

主站蜘蛛池模板: 鹤峰县| 突泉县| 福建省| 凉城县| 呈贡县| 西宁市| 新密市| 德惠市| 达州市| 黄骅市| 栾城县| 全南县| 长葛市| 托克托县| 阿尔山市| 盘山县| 库尔勒市| 铁力市| 迁西县| 大新县| 哈尔滨市| 上虞市| 攀枝花市| 陈巴尔虎旗| 钟山县| 依安县| 陕西省| 奈曼旗| 来宾市| 商水县| 古蔺县| 临洮县| 崇左市| 赤水市| 通榆县| 江陵县| 湖口县| 札达县| 阜新| 平阳县| 蕲春县|