欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

Yii框架自定义数据库操作组件示例

程序员文章站 2023-01-04 08:33:00
本文实例讲述了yii框架自定义数据库操作组件。分享给大家供大家参考,具体如下: yii 的数据库操作对象提供的方法确实很方便。 但是有的时候我们已经习惯了我们以前编写php的数据库操...

本文实例讲述了yii框架自定义数据库操作组件。分享给大家供大家参考,具体如下:

yii 的数据库操作对象提供的方法确实很方便。 但是有的时候我们已经习惯了我们以前编写php的数据库操作语法,没有那么多时间去仔细看每个yii提供的数据库操作语法,怎么办呢? 那就是一边学习,一边二次封装自己习惯的数据库操作类。 以后我们使用数据库操作对象,就用我们自己定义的组件去操作。

将我的数据库操作组件注册进配置文件web.php 中

array(
  'components' => array(
    //自定义数据库操作组件
    'dboper'  => array(
      'class'   => 'app\components\dboper\realization\dbrealization1'
    ),
    //yii 框架数据库连接组件
    'db'      =>  array(
        'class'     => 'yii\db\connection',
        'dsn'      => 'mysql:host=localhost;dbname=yii',
        'username'   => 'root',
        'password'   => '123456',
        'charset'    => 'utf8'
      );
  )
)

然后我们就可以在components 目录下定义我们的数据库操作类了。 因为,不知道怎么去获得php pdo 的原生操作对象,所以这里是对yii数据库操作类的一个二次封装。

接口文件 dboper.php 自定义的数据库操作类都得实现该接口

<?php
namespace app\components\dboper;
/**
 * 自定义数据库操作组件 依赖系统定义组件db
 */
interface dboper
{
  /**
   * 查询多条数据
   * @param
   * string $sql 需要查询的sql语句
   * array $keyval 字段映射
   * @return
   * array 查询结果
   */
  public function fetchall($sql='',$keyval=array());
  /**
   * 查询一条数据 原生sql
   * @param
   * string $sql 需要查询的sql语句
   * array $keyval 字段映射
   * @return
   * array 查询结果
   */
  public function fetch($sql='',$keyval=array());
  /**
   * 添加数据
   * @param
   * string $tablename 表名
   * array $values 要插入的数据
   * @return
   * int 受影响的行数
   */
  public function insert($tablename='',$values=array());
  /**
   * 更新数据
   * @param
   * string $tablename 表名
   * array | string $where 修改条件 为 1 时更改该表所有的行
   * array $update 要更新的数据 
   * @return
   * int 受影响的行数
   */
  public function update($tablename='',$where='',$update=array());
  /**
   * 删除数据
   * @param
   * string $tablename 表名
   * array | string $where 删除条件
   * @return
   * int 受影响的行数
   */
  public function delete($tablename='',$where='');
  /**
   * 事务处理
   * @param
   * array $sqls 要执行的sql集合
   * return
   * boolean 是否执行成功
   */
  public function transcation($sqls = array());
  /**
   * 获得数据库链接
   */
  public function getyiidbconnection();
}

针对dboper 接口的实现类 dbrealization1.php

<?php
namespace app\components\dboper\realization;
use yii;
use app\components\dboper\dboper;
/**
 * 自定义数据库操作组件实现类
 */
class dbrealization1 implements dboper
{
  private $db = null;
  /**
   * interface @override
   */
  public function fetchall($sql='',$keyval=array())
  {
    if($sql === '')
      return array();
    $result = $this->getqueryobj($sql,$keyval)->queryall();
    if($result)
      return $result;
    else
      return array();
  }
  /**
   * interface @override
   */
  public function fetch($sql='',$keyval=array())
  {
    if($sql === '')
      return array();
    $result = $this->getqueryobj($sql,$keyval)->queryone();
    if($result)
      return $result;
    else
      return array();
  }
  /**
   * interface @override
   */
  public function insert($tablename='',$values=array())
  {
    if($tablename === '')
      return 0;
    $insert = $this->getyiidbconnection()->createcommand();
    if(is_array($values[0]))
    {
      $keys = array_keys($values[0]);
      return $insert->batchinsert($tablename,$keys,$values)->execute();
    }
    return $insert->insert($tablename,$values)->execute();
  }
  /**
   * interface @override
   */
  public function update($tablename='',$where = '',$update=array())
  {
    if($tablename === '')
      return 0;
    if($where === '')
      return 0;
    return $this->getyiidbconnection()
        ->createcommand()
        ->update($tablename,$update,$where)
        ->execute();
  }
  /**
   * interface @override
   */
  public function delete($tablename='',$where='')
  {
    if($tablename === '')
      return 0;
    return $this->getyiidbconnection()
        ->createcommand()
        ->delete($tablename,$where)
        ->execute();
  }
  /**
   * 获得查询操作对象
   * @return 
   * object 
   */
  private function getqueryobj($sql='',$keyval=array())
  {
    $query = $this->getyiidbconnection()->createcommand($sql);
    if(!empty($keyval))
      $query->bindvalues($keyval);
    return $query;
  }
  /**
   * interface @override
   */
  public function transcation($sqls = array())
  {
    if(empty($sqls))
      return false;
    $db = $this->getyiidbconnection();
    $outertransaction = $db->begintransaction();
    $runclient = true;
    try
    {
      foreach($sqls as $sql)
      {
        $db->createcommand($sql)->execute();
      }
      $outertransaction->commit();
    }catch(\exception $e){
      $runclient = false;
      $outertransaction->rollback();
    }
    return $runclient;
  }
  /**
   * interface @override
   */
  public function getyiidbconnection()
  {
    if($this->db === null)
    {
      $this->db = yii::$app->db;
    }
    return $this->db;
  }
}

注意:我的自定义数据库操作类 依赖 yii::$app->db 这个组件, 也就是框架自带的数据库连接组件

然后我们就可以通过 yii::$app->dboper 去操作数据库了。