Yii自定义数据库操作组件的原理与实现方法是什么
Admin 2022-05-30 群英技术资讯 303 次浏览
本文实例讲述了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 去操作数据库了。
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:mmqy2019@163.com进行举报,并提供相关证据,查实之后,将立刻删除涉嫌侵权内容。
猜你喜欢
CakePhp作为主流的基于MVC架构的php框架,能够实现快速编写项目代码。使用方式如下:1、$uses来声明;2、转换成对象;3、cakephp 查询。
在本篇文章里小编给大家整理了一篇关于php缓存的类型总结及用法,对此有需要的朋友们可以跟着学习下。
重构代码是构建和维护软件的重要方面,重构涵盖了一系列不同的技术,包括移动,提取,复制,删除和重命名。PhpStorm的重构功能(包含在核心软件包中)支持所有这些功能。
这篇文章主要给大家介绍了关于如何破解PHP单继承魔咒的相关资料,Trait 是为类似 php 的单继承语言而准备的一种代码复用机制,文中通过图文以及实例代码介绍的非常详细,需要的朋友可以参考下
在PHP中,预定义的$_POST变量用于收集来自method="post"的表单中的值,$_POST也常用于传递变量。下文有实例供大家参考,对大家了解操作过程或相关知识有一定的帮助,而且实用性强,希望这篇文章能帮助大家,下面我们一起来了解看看吧。
成为群英会员,开启智能安全云计算之旅
立即注册Copyright © QY Network Company Ltd. All Rights Reserved. 2003-2020 群英 版权所有
增值电信经营许可证 : B1.B2-20140078 粤ICP备09006778号 域名注册商资质 粤 D3.1-20240008