怎么在Yii框架中自定义一个数据库操作组件？很多新手对此不是很清楚，为了帮助大家解决这个难题，下面小编将为大家详细讲解，有这方面需求的人可以来学习下，希望你能有所收获。
计算
安全
数据库
网络和加速
企业服务
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;
}
}看完上述内容是否对您有帮助呢？如果还想对相关知识有进一步的了解或阅读更多相关文章，请关注亿速云行业资讯频道，感谢您对亿速云的支持。
亿速云「云数据库 MySQL」免部署即开即用，比自行安装部署数据库高出1倍以上的性能，双节点冗余防止单节点故障，数据自动定期备份随时恢复。点击查看>>
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
