• 企业400电话
  • 微网小程序
  • AI电话机器人
  • 电商代运营
  • 全 部 栏 目

    企业400电话 网络优化推广 AI电话机器人 呼叫中心 网站建设 商标✡知产 微网小程序 电商运营 彩铃•短信 增值拓展业务
    Yii框架自定义数据库操作组件示例

    本文实例讲述了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 去操作数据库了。

    更多关于Yii相关内容感兴趣的读者可查看本站专题:《Yii框架入门及常用技巧总结》、《php优秀开发框架总结》、《smarty模板入门基础教程》、《php面向对象程序设计入门教程》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》

    希望本文所述对大家基于Yii框架的PHP程序设计有所帮助。

    您可能感兴趣的文章:
    • Yii框架学习笔记之应用组件操作示例
    • yii2高级应用之自定义组件实现全局使用图片上传功能的方法
    • Yii框架组件和事件行为管理详解
    • Yii扩展组件编写方法实例分析
    • yii2行为的方法如何注入到组件类中详解
    • Yii框架响应组件用法实例分析
    • Yii框架核心组件类实例详解
    • PHP的Yii框架中移除组件所绑定的行为的方法
    • Yii2中组件的注册与创建方法
    • Yii框架组件的事件机制原理与用法分析
    • Yii框架应用组件用法实例分析
    上一篇:php接口隔离原则实例分析
    下一篇:Yii框架学习笔记之应用组件操作示例
  • 相关文章
  • 

    © 2016-2020 巨人网络通讯 版权所有

    《增值电信业务经营许可证》 苏ICP备15040257号-8

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