Phalcon入门教程之模型CURD(1)

上一篇《Phalcon入门教程之模型》中介绍了数据库模型操作的一些基础功能,本篇将介绍模型的 selectinsert 用法。由于数据库模型操作的内容比较多和细,所以本篇只是粗略的介绍基础用法,以及补充文档中没有提及的一些用法和注意点。因此,强烈建议大家在熟读文档的前提下,再阅读此篇教程。

数据表

假设数据表名为 test_articles,数据结构及记录下:

mysql> select * from test_articles;
+-----+--------------+--------------+--------+-------------+--------------+--------+-----------+---------------------+-----------+---------------------+
| aid | title        | introduce    | status | view_number | is_recommend | is_top | create_by | create_time         | modify_by | modify_time         |
+-----+--------------+--------------+--------+-------------+--------------+--------+-----------+---------------------+-----------+---------------------+
|   1 | 英语演讲     | 纯口语式       |      1 |           0 | 0            | 0      |         1 | 2017-05-21 05:13:46 |         1 | 2017-05-21 05:13:46 |
|   2 | 限购政策     | 快买房         |      1 |           0 | 0            | 0      |         1 | 2017-05-21 05:13:46 |         1 | 2017-05-21 05:13:46 |
+-----+--------------+--------------+--------+-------------+--------------+--------+-----------+---------------------+-----------+---------------------+

其中 aid 是主键,其他每个字段的意思就不做介绍了。

查找记录

Phalcon\Mvc\Model 为数据查询提供了多种函数,下面将直接用demo来介绍其用法。

查找多条记录

使用 find() 函数可以查找多条记录:

$articleModel = new ArticlesModel();
//查询所有记录,返回一个对象
$result = $articleModel->find();
//循环输出结果
foreach($result as $record){
  var_dump($record->aid); 
  var_dump($record->title);
}

find() 函数返回的是 Phalcon\Mvc\Model\Resultset\Simple 对象,我们可以通过 foreach 循环输出结果。也可以将结果集对象转成一个二维数组:

$records = $result->toArray();

还可以统计结果集对象的记录总数:

$count = count($result);

查找单条记录

查找单条记录,可以通过使用 findFirst() 函数来实现:

$result1 = $articleModel->findFirst(1);
print_r($result1->toArray());

findFirst() 返回的就是当前模型对象(如果不明白,可以打印 $result1 即会明白),toArray() 会将其转成一维数组。

细心的朋友可能会有疑问,findFirst(1) 是按什么字段做查询条件的? 通过监听打印SQL语句,可以看到在 Phalcon 中会默认使用主键作为查询条件:

SELECT * FROM `test_articles` WHERE `test_articles`.`aid` = 1 LIMIT :APL0

当然,我们也可以使用完整的查询条件:

$result2 = $articleModel->findFirst("aid = 1");

返回的结果,和上面的 findFirst(1) 是一样的。

参数绑定

仔细观察上面的SQL语句,会发现查询条件并没有进行预处理。如果 aid 的值是通过外部数据(比如用户输入)或者变量传输进来,则有可能出现SQL注入的危险。我们必须要用参数绑定的方式来防止SQL注入:

$result2 = $articleModel->find([
  'conditions' => 'aid = :aid: AND status = :status:',
  'bind' => [
    'aid' => 2,
    'status' => 1,
  ],
]);

生成的SQL语句如下:

SELECT * FROM `test_articles` WHERE `test_articles`.`aid` = :aid AND `test_articles`.`status` = :status

经过参数替换后的SQL语句如下:

SELECT * FROM `test_articles` WHERE `test_articles`.`aid` = 2 AND `test_articles`.`status` = 1

参数绑定支持字符串和整数占位符,本篇只介绍字符串占位符,整数占位符的用法可查阅文档。

查询选项

Phalcon 提供了很多查询选项,常用的查询选项demo如下:

$articleModel->find([
  'columns' => 'aid, title', //查询字段
  'conditions' => 'aid = :aid:',  //查询条件
  'bind' => [ //参数绑定
    'aid' => 2
  ],
  'order' => 'aid DESC', //排序
  'limit' => 10, //限制查询结果的数量
  'offset' => 10, //偏移量
 ]);

全部的查询选项,请查阅文档。 很多朋友在群里问 inlike 在参数绑定下的用法,下面跟大家分享一下。

in的用法

直接上示例代码:

$result3 = $articleModel->find([
  'conditions' => 'aid IN ({aids:array})',
    'bind' => [
      'aids' => [1, 2]
    ],
]);

like的用法

示例代码如下:

$result4 = $articleModel->find([
  'conditions' => 'title like :title:',
  'bind' => [
    'title' => '%英语%',
  ],
]);

添加记录

添加单条记录

添加单条记录可用 create() 函数:

$articleModel = new ArticlesModel();
$result = $articleModel->create([
    'title' => 'phalcon测试',
    'introduce' => 'Phalcon入门教程',
    'status' => 1,
    'view_number' => 1,
    'is_recommend' => 1,
    'is_top' => 1,
    'create_by' => 1,
    'create_time' => date('Y-m-d H:i:s'),
    'modify_by' => 1,
    'modify_time' => date('Y-m-d H:i:s')
]);
if (!$result) { 
    //添加记录失败,获取错误信息
    $errorMessage = implode(',', $this->getMessages());
    echo $errorMessage;
}else {
    //添加记录成功,获取新增记录的主键aid
    $aid = $articleModel->aid;
    echo $aid;
}

create() 函数返回的是 boolean 值。如果返回值为 false ,我们可以通过模型的 getMessages() 函数来获取错误信息;若返回值为 true ,则可以直接获取最新的主键ID,即我们通常所说的 lastInsertId

批量添加记录

Phalcon 中并没有提供批量添加记录的函数,需要开发者自己动手实现,本篇跟大家分享两种实现批量添加记录的方法。

循环逐条添加

通过循环逐次添加一条记录,这种方法在性能上损耗较大,不推荐使用。但是这种方法牵涉到 Phalcon 模型的底层实现原理,所以这里拿出来跟大家分析一下。上代码:

$articleModel = new ArticlesModel();
//var_dump($articleModel->title);  //下面测试用
for ($i = 1; $i <= 10; $i++) {
    $data = [
        'title' => "phalcon测试{$i}",
        'introduce' => "Phalcon入门教程{$i}",
        'status' => $i,
        'view_number' => $i,
        'is_recommend' => 1,
        'is_top' => 1,
        'create_by' => $i,
        'create_time' => date('Y-m-d H:i:s'),
        'modify_by' => $i,
        'modify_time' => date('Y-m-d H:i:s')
    ];
    $result = $articleModel->create($data);
    if (!$result) {
        $errorMessage = implode(',', $articleModel->getMessages());
        exit($errorMessage);
    }else {
        $aid = $articleModel->aid;
        echo $aid;
        //var_dump($articleModel->title);  //下面测试用
    }
    echo '<br />';
}

这段代码的运行结果可能会出乎很多人的意料,只有循环中的第一条数据入库成功,并返回了主键ID,其他的数据入库时直接报错:

Record cannot be created because it already exists

意思是因为记录已经存在,所以无法再次入库。在前面 添加单条记录 的时候,我们有提到获取 lastInsertId 的方式,是直接通过模型的成员属性方式获取:

$aid = $articleModel->aid;

关键点就在这里,Phalcon 模型对象会把当前入库的数据,全部赋值给模型对象的成员属性,包括主键ID。我们做个测试,打开上面代码中的两处注释部分,再次运行后可以看到,第一次打印 title 成员属性的时候,会报一个 Notice 错误,提示信息是未定义的成员属性。当第二次打印 title 成员属性的时候,却有值了,而且是循环中第一条记录的 title 值。看到这里,相信大家应该已经差不多能明白其中的实现原理了。因为入库成功那条记录返回的主键ID也被赋值给模型对象的成员属性,create() 函数内部会判断当前对象的主键成员属性是否有值,在有值的情况下,就不再生成SQL语句发送到Mysql服务端,直接抛出错误信息。请记住这一点,Phalcon 模型的 update() 函数也是基于此原理实现的(下一篇教程会提到)。那么,通过循环逐条添加记录的方法要如何实现呢?请看代码:

$articleModel = new ArticlesModel();
for ($i = 1; $i <= 10; $i++) {
    $data = [
        'title' => "phalcon测试{$i}",
        'introduce' => "Phalcon入门教程{$i}",
        'status' => $i,
        'view_number' => $i,
        'is_recommend' => 1,
        'is_top' => 1,
        'create_by' => $i,
        'create_time' => date('Y-m-d H:i:s'),
        'modify_by' => $i,
        'modify_time' => date('Y-m-d H:i:s')
    ];
    $clone = clone $articleModel; //克隆一个新对象,使用新对象来调用create()函数
    $result = $clone->create($data);
    if (!$result) {
        $errorMessage = implode(',', $clone->getMessages());
        exit($errorMessage);
    }else {
        $aid = $clone->aid;
        echo $aid;
    }
    echo '<br />';
}

每循环一次,就克隆出一个新对象,通过新对象来调用 create() 函数添加数据记录。因为每个对象间的成员属性都是独立的,所以全部数据都会添加成功。

批量添加

我们常用的批量添加方式是生成一条 insert 语句把数据添加入库,下面跟大家分享我在项目中封装的函数:

//文件路径:Marser\app\frontend\models\ArticlesModel.php
class ArticlesModel extends \Marser\App\Frontend\Models\BaseModel {

    /*** 表名*/
    const TABLE_NAME = 'articles';

    public function initialize(){
        parent::initialize();
        $this->set_table_source(self::TABLE_NAME);
    }

    /**
     * 批量添加
     * @param array $data
     * @return boolean
     * @throws \Exception
     */
    public function batch_insert(array $data){
        if (count($data) == 0) {
            throw new \Exception('参数错误');
        }
        $keys = array_keys(reset($data));
        $keys = array_map(function ($key) {
            return "`{$key}`";
        }, $keys);
        $keys = implode(',', $keys);
        $sql = "INSERT INTO " . $this->getSource() . " ({$keys}) VALUES ";
        foreach ($data as $v) {
            $v = array_map(function ($value) {
                return "'{$value}'";
            }, $v);
            $values = implode(',', array_values($v));
            $sql .= " ({$values}), ";
        }
        $sql = rtrim(trim($sql), ',');
        //DI中注册的数据库服务名称为"db"
        $result = $this->getDI()->get('db')->execute($sql);
        if (!$result) {
            throw new \Exception('批量入库记录');
        }
        return $result;
    }
}

以上代码已托管在github:https://github.com/KevinJay/marser-phalcon-demo

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏行者悟空

Hadoop之MapReduce原理及运行机制

1514
来自专栏用户画像

JAVA单例模式

在整个应用中,保证一个类只有一个实例,它提供了一个可以访问到它自己的全局访问点(静态方法)。

722
来自专栏帘卷西风的专栏

关于mysql自增id的获取和重置

转载请注明出处:帘卷西风的专栏(http://blog.csdn.net/ljxfblog)

1012
来自专栏运维咖啡吧

Django model select的各种用法详解

Q对象可以对关键字参数进行封装,从而更好的应用多个查询,可以组合&(and)、|(or)、~(not)操作符。

903
来自专栏听雨堂

Python防止sql注入

看了网上文章,说的都挺好的,给cursor.execute传递格式串和参数,就能防止注入,但是我写了代码,却死活跑不通,怀疑自己用了一个假的python 最后,...

2697
来自专栏Hongten

spring开发_Spring+Struts2

http://www.cnblogs.com/hongten/gallery/image/112920.html

712
来自专栏灯塔大数据

每周学点大数据 | No.37字数统计

No.37期 字数统计 Mr. 王:我们来看几个 MapReduce 应用的实际例子,这样更有助于你对它的认识。 小可:我也迫不及待地想试试 MapRed...

28612
来自专栏chenssy

【死磕Java并发】-----Java内存模型之从JMM角度分析DCL

DCL,即Double Check Lock,即双重检查锁定。其实DCL很多人在单例模式中用过,LZ面试人的时候也要他们写过,但是有很多人都会写错。他们为什么会...

1143
来自专栏菩提树下的杨过

温故而知新:设计模式之单件模式(Singleton)

 1 using System;  2  3 namespace Singleton  4 {  5 class Program  6     {  7 ...

1707
来自专栏Seebug漏洞平台

从WordPress SQLi谈PHP格式化字符串问题

近日,WordPress爆出了一个SQLi漏洞,漏洞发生在WP的后台上传图片的位置,通过修改图片在数据库中的参数,以及利用php的sprintf函数的特性,在删...

39511

扫码关注云+社区