文档章节

YII 数据库相关操作(转)

drewin
 drewin
发布于 2015/06/26 17:49
字数 3106
阅读 684
收藏 5

CDbConnection: 一个抽象数据库连接
CDbCommand: SQL statement
CDbDataReader: 匹配结果集的一行记录
CDbTransaction:数据库事务


访问数据库前需要建立数据库连接;使用DAO建立一个抽象数据库链接:


$connection = new CDbConnection($dsn, $username, $password);   $connection->active = true;     // 只有激活了连接才可以使用   $connection->active = false;  // 关闭连接
CDbConnection继承自CApplicationComponent,所以他可以像组件一样在任何地方使用。因此可以这样访问:
Yii::app()->db

 执行SQL语句需要CDbCommand对象,而该对象由CdbConnection::createCommand()返回,因此:

$connection=Yii::app()->db;  
$command=$connection->createCommand($sql); 
 如果SQL语句想要完全有自己写,可以这样:
$newSQL = 'SQL语句';  
$command->text=$newSQL; 
CDbCommand对象有两个方法execute()用于非查询SQL执行,而query(),通俗的讲就是用于SELECT查询
execute()返回的是INSERT, UPDATE and DELETE操作受影响的记录行数
query()返回一个CDbDataReader对象,使用CDbDataReader对象可以遍历匹配结果集中的所有记录。
$rowCount=$command->execute();  // execute the non-query SQL  
$dataReader=$command->query();  // execute a query SQL // 返回CDbDataReader对像  
$rows=$command->queryAll();     // query and return all rows of result  
$row=$command->queryRow();      // query and return the first row of result  
$column=$command->queryColumn();    // query and return the first column of result  
$value=$command->queryScalar();     // query and return the first field in the first row

 query()返回的是代表结果集的对象而非直接的结果,因此要获取结果集的记录可以这样:

$dataReader=$command->query();


CDbDataReader::read()可以一次获取一行数据,到末尾时返回false

while(($row=$dataReader->read())!==false)


CDbDataReader实现了迭代器接口因此可以使用foreach遍历

foreach($dataReader as $row)

一次性返回所有的记录(数组)

$rows=$dataReader->readAll(); 
queryXXX() 形式的方法会直接返回匹配的记录集合,当query()不是,他返回一个代表结果集的对象

YII中的CDbTransaction类用于事务

 首先,建立一个连接  
$connection = Yii::app()->db;  
// 第二,开始事务  
$transaction=$connection->beginTransaction();  
// 第三,执行SQL,如果错误就抛出异常,在异常处理中回滚。  
try  
{  
$connection->createCommand($sql1)->execute();  
$connection->createCommand($sql2)->execute();  
//.... other SQL executions  
// 如果SQL执行都没有抛出异常,那就提交。  
$transaction->commit();   
} catch(Exception $e) {  
    $transaction->rollBack();   // 在异常处理中回滚  
}

执行SQL中,一般都需要绑定一些用户参数,对于用户参数,需要防止SQL注入攻击
PDO对象的绑定参数的方法可以防止SQL注入攻击,同样扩展自PDO的DAO也有这样的功能
举例说明:

// 第一,建立一个连接:  
$connection = Yii::app()->db;  
// 第二,写下无敌的SQL语句,比如:  
$sql="INSERT INTO tbl_user (username, email) VALUES(:username,:email)";  
// 第三,创建CDbCommand对象用于执行SQL  
$command=$connection->createCommand($sql);  
// 接下来,将SQL语句中的形式参数,替换为实际参数  
$command->bindParam(":username",$username,PDO::PARAM STR);   // 这与PDO有点不同,PDO中不带冒号  
$command->bindParam(":email",$email,PDO::PARAM STR);    // 同样  
// 最后,执行  
$command->execute(); 
如果还有其他的数据需要插入,可以再次绑定实参。


使用CDbDataReader对象的bindColumn()方法将结果集中的列绑定到PHP变量。
因此,读取一行记录,列值将自动填充到对应的PHP对象中
比如这样:

$connection = Yii::app()->db;  
$sql = "SELECT username, email FROM tbl_user";  
$dataReader = $connection->createCommand($sql)->query();    //很赞的方法链, 可惜不能接着.each()  
$dataReader->bindColumn(1, $username);  //第一列值绑定到$username  
$dataReader->bindColumn(2, $email);     //第二列值绑定到$email  
//接着循环读取并操作数据  
while( $dataReader->read() !== false ) {  
    ... // 与先前的 while(($row=$dataReader->read())!==false) 有所不同哦!  
}

设置表前缀,使用 CDbConnection::tablePrefix 属性在配置文件中设置
Yii实现了把一条完整的SQL语句完完全全肢解的能力,比如这样:

$user = Yii::app()->db->createCommand();      
        ->select('id, username, profile')  
        ->from('tbl_user u')  
        ->join('tbl_profile p', 'u.id=p.user_id')  
        ->where('id=:id', array(':id'=>$id)  
        ->queryRow();       // 返回匹配的结果集的第一行  
        // 其实这条语句是这样的: $newSQL ='SELECT id, username, profile from tbl_user u INNER JOIN tbl_profile p ON u.id = p.user_id WHERE u.id =:id'

yii提供了一种构建SQL的机制(也就是说不用自己写长长的SQL)

// 首先要实例化一个CDbCommand对象  
$command = Yii::app()->db->createCommand();     // 注意参数留空了。。  
// 可用的方法列表如下:  
->select(): SELECT子句  
->selectDistinct(): SELECT子句,并保持了记录的唯一性  
->from():         构建FROM子句  
->where():        构建WHERE子句  
->join():         在FROM子句中构建INNER JOIN 子句  
->leftJoin():     在FROM子句中构建左连接子句  
->rightJoin():    在FROM子句中构建右连接子句  
->crossJoin():    添加交叉查询片段(没用过)  
->naturalJoin():  添加一个自然连接子片段  
->group():        GROUP BY子句  
->having():       类似于WHERE的子句,但要与GROUP BY连用  
->order():        ORDER BY子句  
->limit():        LIMIT子句的第一部分  
->offset():       LIMIT子句的第二部分  
->union():        appends a UNION query fragment 
select()默认返回全部列


// 但你可以这样:  

select('username, email');

// 或使用表限定,或使用别名  

select('tbl_user.id, username name');


// 或使用数组作为参数  

select(array('id', 'count(*) as num'));

使用form() 如果制定了多个表需要使用逗号分隔的字符串,就像原生SQL语句那样:

from('tbl_user, tbl_post, tbl_profile');

// 当然,你也可以使用表别名, 还可以使用完整的数据库限定名  

from('tbl_user u, public.tbl_profile p');

WHERE子句

// 在where()中使用 AND  
where(array('and', 'id=:id', 'username=:username'), array(':id'=>$id, ':username'=>$username);  
// 在where()中使用 OR 与 AND用法相同,如下:  ##看起来比直接写更加繁琐##  
where( array('and', 'type=1', array('or', 'id=:id','username=:username') ),array(':id'=>$id, ':username'=>$username ));  
// IN 操作符用法  
where(array('in', 'id', array(1,2,3)))  
// LIKE 用法  
where( array('like', 'name', '%tester%') );  
where( array('like','name', array('%test%', '%sample%')) ) // 等于 name LIKE '%test%' AND name LIKE '%sample%  
    // 再这样复杂下去, 使用这种方法简直是自杀行为。  
  
$keyword=$ GET['q'];  
// escape % and characters  
$keyword=strtr($keyword, array('%'=>'n%', ' '=>'n '));  
$command->where(array('like', 'title', '%'.$keyword.'%'));

添加了这么多,你都不知道合成后的SQL长啥样了,可以使用->text查看(魔术方法)


如果觉得组合的SQL没有错误,那就执行他,添加->queryAll(); 这可以获得所有匹配的结果集。
当然,如果你确定执行的结果集中只有一行,可以添加->queryRow();来直接获取。
如果一个CDbCommand对象需要执行多次,那么在下一次执行之前记得调用reset();

$command = Yii::app()->db->createCommand();  
$users = $command->select('*')->from('tbl_users')->queryAll();  
$command->reset(); // clean up the previous query  
$posts = $command->select('*')->from('tbl_posts')->queryAll();

YII的SQL构建函数就是一鸡肋。
Active Record
使用AR以面向对象的方式访问数据库,AR实现了ORM技术
当Post类表示表tbl_post时,我们可以使用这样的方式插入一条数据

$post = new Post();  
$post->title = 'new title';  
$post->content = 'new content';  
$post->save();      // 保存即插入

AR最典型的功能就是执行CRUD操作
DAO定位于解决复杂的数据库查询,而AR定位于解决简单的数据库查询
一个AR类代表一张数据表,而一个AR对象代表表中的一行真实的记录,AR类继承CActiveRecord。
如果有一张POST表`tbl_post`,你可以这样定义一个AR类

class Post extends CACtiveRecord  
{  
    public static function model($className = __CLASS__)  
    {  
        return parent::model($className);  
    }  
  
    public function tablName()  
    {  
        return '{{post}}';  
    }  
}

表中的每一个字段都由AR类中的一个属性表示,如果试图通过属性访问表中没有字段,将会抛出一个异常。
一个AR一定需要一个主键,如果某张表没有主键,你就自己在类中伪造一个,像这样:

public function primaryKey()  
{  
    return 'id';        // 'id' 是关联表中的一个字段,但他不是主键,现在将它指定为主键  
}

实例化一个AR,填写信息(类似于填充用户提交的信息),然后保存

$post = new Post;  
$post->title = 'sample post';  
$post->content = 'content for the sample post';  
$post->create_time = time();  
$post->save();  // 保存/插入 
通过AR读取记录 fine() findByPk() findByAttributes() findBySql()
$post=Post::model()->find($condition,$params);                  // 返回Post对象(如果有匹配记录的话), 否则返回NULL  
$post=Post::model()->findByPk($postID,$condition,$params);  
$post=Post::model()->findByAttributes($attributes,$condition,$params);  
$post=Post::model()->findBySql($sql,$params);

// find()的一个例子:

$post=Post::model()->find('postID=:postID', array(':postID'=>10));

如果查询条件很是复杂,就要使用CDbCriteria类

$criteria = new CDbCriteria;  
$criteria->select='title';  
$creteria->condition='postID=:postID';  
$criteria->params=array(':postID'=>10);  
$post=Post::model()->find($criteria);   // 不需要第二个参数

另一种更好的写法

$post=Post::model()->find(array(  
        'select' => 'title',  
        'condition' => 'postID=:postID',  
        'params' => array(':postID' => 10)  
        ));

如果查找的是多行记录可以使用 findAll() findAllByPk() findAllByAttributes() findAllBySql()

// find all rows satisfying the specified condition  
$posts=Post::model()->findAll($condition,$params);  
// find all rows with the specified primary keys  
$posts=Post::model()->findAllByPk($postIDs,$condition,$params);  
// find all rows with the specified attribute values  
$posts=Post::model()->findAllByAttributes($attributes,$condition,$params);  
// find all rows using the specified SQL statement  
$posts=Post::model()->findAllBySql($sql,$params);

如果没有匹配的行,将返回一个空数组,这可以用empty()去检测
另外的一些可以使用的方法:

// get the number of rows satisfying the specified condition  
$n=Post::model()->count($condition,$params);  
// get the number of rows using the specified SQL statement  
$n=Post::model()->countBySql($sql,$params);  
// check if there is at least a row satisfying the specified condition  
$exists=Post::model()->exists($condition,$params);

使用AR更新记录
一个典型的实例:

$post=Post::model()->findByPk(10);  
$post->title='new post title';  
$post->save(); // save the change to database

怎么知道这是一条新纪录还是一条旧的记录呢?使用如下方法:

if( CActiveRecord::isNewRecord )  
// update the rows matching the specified condition  
Post::model()->updateAll($attributes,$condition,$params);  
// update the rows matching the specified condition and primary key(s)  
Post::model()->updateByPk($pk,$attributes,$condition,$params);  
// update counter columns in the rows satisfying the specified conditions  
Post::model()->updateCounters($counters,$condition,$params);

删除记录

$post=Post::model()->findByPk(10); // assuming there is a post whose ID is 10  
$post->delete(); // delete the row from the database table

注意,当删除记录之后,$post仍然可用, 且保留了原始数据。

// 类级别的方法  
// delete the rows matching the specified condition  
Post::model()->deleteAll($condition,$params);  
// delete the rows matching the specified condition and primary key(s)  
Post::model()->deleteByPk($pk,$condition,$params);

数据验证
将用户提交的数据保存到AR对象中

$post->title = $_POST['title'];  
$post->content = $_POST['content'];  
$post->save();  
  
// assume $ POST['Post'] is an array of column values indexed by column names  
$post->attributes=$ POST['Post'];  
$post->save(); 
RAR:Relatived Actie Record


RAR本质上就是执行关系数据查询
如何让一个AR关联另一个AR
4中关系类型

self::BELONGS_TO
self::HAS_MANY
self::HAS_ONE
self::MANY_MANY

关系名称(关系类型,要关联的类名,外键名,其他额外的选项);
定义表关系 类:Post

public function relations()  
{  
    return array(  
        'author'=>array(self::BELONGS_TO, 'User', 'author_id'),     // 返回User对象  
        'categories'=>array(self::MANY_MANY, 'Category', 'tbl_post_category(post_id, category_id)'),  
    );  
}

类:User

public function relations()  
{  
    return array(  
            'posts' => array(self::HAS_MANY, 'Post', 'author_id'),  
            'profile' => array(self::HAS_ONE, 'Profile', 'owner_id')  
    );  
}

定义了AR间的关系之后,当执行关系查询时,与AR关联的AR也会自动实例化, 比如这样:

$author = User::model()->findByPk(1);  
$author->posts;         // posts关系已经定义。

 
执行关系查询

1).lazy loading approach 懒惰关系执行
// retrieve the post whose ID is 10  
$post=Post::model()->findByPk(10);  
// retrieve the post's author: a relational query will be performed here  
$author=$post->author;  // 如果先前没有执行过,现在才执行这个关系查询(事情拖到这一步才做,真的是很懒啊!)

如果关系查询执行后没有匹配的结果,返回将会是NULL或空的数组。
2).eager loading approach   热心的关系查询 //这名字真的很萌!
// 也就是说一次性取回所有你想要的记录。管你要不要,这这这,太热心了吧!

$posts=Post::model()->with('author')->findAll();  
// SQL => 'SELECT tbl_post.*, author.* FROM tbl_post t INNER JOIN tbl_user author ON t.author = tbl_user.id'  
$posts=Post::model()->with('author','categories')->findAll();  
// SQL => 'SELECT * FROM tbl_post t INNER JOIN tbl_user u ON t.author = u.id INNER JOIN categories c ON t.id = c.post_id'  
$posts=Post::model()->with(  
    'author.profile',  
    'author.posts',  
    'categories')->findAll();  
$criteria=new CDbCriteria;  
$criteria->with=array(  
'author.profile',  
'author.posts',  
'categories',  
);  
$posts=Post::model()->findAll($criteria); 
或者
$posts=Post::model()->findAll(array(  
                                    'with'=>array(  
                                    'author.profile',  
                                    'author.posts',  
                                    'categories',  
                                    )  
                             );

如果我们想知道用户中谁发过帖子,并且帖子的状态是“公开”。我们并不关心用户发表过的帖子的内容。


$user = User::model()->with('posts')->findAll();  
                'VS'  
$user = User::model()->with(array(  
                                    'posts' => array(  
                                                        'select' => false,  
                                                        'joinType' => 'INNER JOIN',  
                                                        'condition' => 'posts.published = 1'  
                                                    ),  
                                 )  
                           )->findAll();

返回的将会是所有发过帖子(且帖子已经公开)的用户
在relatinos()中定义更加复杂的关系

class User extends CActiveRecord  
{  
    public function relations()  
    {  
            return array(  
                    'posts'=>array(self::HAS MANY, 'Post', 'author id',  
                    'order'=>'posts.create time DESC',  
                    'with'=>'categories'),  
                    'profile'=>array(self::HAS ONE, 'Profile', 'owner id'),  
                    );  
    }  
}

利用别名解决歧义

$posts=Post::model()->with('comments')->findAll(array(  
        'order'=>'t.create time, comments.create time'  
    ));

Dynamic Relational Query 动态关系SQL查询,更改默认插叙条件:

User::model()->with(array(  
        'posts'=>array('order'=>'posts.create time ASC'),  
        'profile',  
    ))->findAll();  
  
$user=User::model()->findByPk(1);  
$posts=$user->posts(array('condition'=>'status=1'));        // 返回的都是AR对象, 而不是数据

统计查询


class Post extends CActiveRecord  
{  
    public function relations()  
    {  
        return array(  
            'commentCount'=>array(self::STAT, 'Comment', 'post_id'),  
            'categoryCount'=>array(self::STAT, 'Category', 'post_category(post_id, category_id)'),  
        );  
    }  
  
}


本文转载自:http://blog.csdn.net/xinqingch/article/details/8186847

共有 人打赏支持
drewin
粉丝 28
博文 121
码字总数 43979
作品 0
海淀
程序员
私信 提问
加载中

评论(1)

Outshine
Outshine
居然还是yii1的
yii2实战教程之新手入门指南-简单博客管理系统

作者:白狼 出处:http://www.manks.top/document/easy_blog_manage_system.html 本文版权归作者,欢迎转载,但未经作者同意必须保留此段声明,且在文章页面明显位置给出原文连接,否则保留追...

白狼栈
2016/06/10
44
0
如何在hostease部署基于yii框架技术的web网站

从中午到腾到凌晨2点多,总算把网站部署好了。本以为会很轻松的,因为写好的blog网站,一直在我自己的LAMP环境主机上运行的很顺利,结果一放到网络服务器上,就遇到了问题。官方的教程是满足...

南国野兽
2013/01/07
0
0
Yii2的ActiveRecord与ActiveQuery简单介绍

活动记录 活动记录为与数据库中某张表中的某条记录相关联的对象,我们通过调用此对象的 CURD方法对记录进行操作,Yii2的活动记录其实很标准,AR 类为模型Model,对应数据表,AR 类的实例为活...

big_cat
2016/04/18
2.3K
0
Yii入门指导(四):强大的“小物件”

1,修改默认的控制器 Yii的默认应用: 所有的配置都可以在main.php中进行配置,那么修改默认的控制器就是在main.php中增加如下代码: 'defaultController' => '', //修改默认控制器 Yii模块:...

Koma
2014/10/24
0
1
reids之YII常见使用问题

首先YII的框架包中并不含redis部分,需要自己配置和安装。 第一部分:Mac下YII框架的redis安装与配置 1.安装redis 方法一: 在没有安装YII的时候,可以通过修改composer的json文件实现修改安...

0_0Loong
2017/10/19
0
0

没有更多内容

加载失败,请刷新页面

加载更多

数据库技术-Mysql主从复制与数据备份

数据库技术-Mysql 主从复制的原理: MySQL中数据复制的基础是二进制日志文件(binary log file)。一台MySQL数据库一旦启用二进制日志后,其作为master,它的数据库中所有操作都会以“事件”...

须臾之余
昨天
12
0
Git远程仓库——GitHub的使用(一)

Git远程仓库——GitHub的使用(一) 一 、 Git远程仓库 由于你的本地仓库和GitHub仓库之间的传输是通过SSH加密的,所以需要一下设置: 步骤一、 创建SSH key 在用户主目录下,看看有没有.ss...

lwenhao
昨天
2
0
SpringBoot 整合

springBoot 整合模板引擎 SpringBoot 整合Mybatis SpringBoot 整合redis SpringBoot 整合定时任务 SpringBoot 整合拦截器...

细节探索者
昨天
0
0
第二个JAVA应用

第二个JAVA应用 方法一:配置文件: # cd /usr/local/tomcat/conf/# vim server.xml</Host> <Host name="www.wangzb.cc" appBase="/data/wwwroot/www.wangzb.cc" //引用所......

wzb88
昨天
0
0
2019年阿里Java面试必问:JVM与性能优化+Redis+设计模式+分布式

前言 一年之计在于春 金三银四已经要到来,2019的新的开始,作为一个开发人员,你是否面上了自己理想的公司,薪资达到心中理想的高度? 面试:如果不准备充分的面试,完全是浪费时间,更是对...

火力全開
昨天
16
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部