ThinkPHP 数据的增删改查

之前接触的都是sql原生语句，thinkPHP做了封装，不过适应起来还是挺快的。

记录了几个常用的例子，还有其他形式的，本文没有记录。

目录

　　1. 增

　　2. 删

　　3. 改

　　4. 查

　　　　4.1 select

　　　　4.2 find

　　　　4.3 getBy

　　　　4.4 getField

　　　　4.5 区间查询

　　　　4.6 原生SQL查询

　　　　4.7 统计查询

　　　　　　4.7.1 count

　　　　　　4.7.2 max

　　　　　　4.7.3 min

　　　　　　4.7.4 avg

　　　　　　4.7.5 sum

1、增

ThinkPHP 内置的 add 方法用于向数据表添加数据，相当于 SQL 中的 INSERT INTO 行为。

public function insert(){
    header("Content-Type:text/html; charset=utf-8");
    $Dao = M("User");    // 实例化模型类

    // 构建写入的数据数组
    $data["username"] = "小王";
    $data["password"] = md5("123456");
    $data["email"] = "12345@163.com";    
    $data["regdate"] = time();

    // 写入数据
    $insertM = $Dao->add($data)；
}

等同于SQL语句：

INSERT INTO user(username,password,email,regdate) VALUES ('小王','e10adc3949ba59abbe56e057f20f883e','12345@163.com',1486974334);

2、删

delete() 方法执行成功返回操作影响（删除）的记录数。

public function del(){
    header("Content-Type:text/html; charset=utf-8");
    $Dao = M("User");
    // 删除 uid=5 的数据记录
    $result = $Dao->where('uid = 5')->delete();
}

等同于SQL语句：

DELETE FROM user WHERE uid = 5;

3、改

ThinkPHP 内置的 save() 方法用于向数据表更新数据，相当于 SQL 中的 UPDATE 行为。

public function update(){
    header("Content-Type:text/html; charset=utf-8");
    $Dao = M("User");

    // 需要更新的数据
    $data['email'] = 'Jack@163.com';
    // 更新的条件
    $condition['username'] = 'Jack';
    $result = $Dao->where($condition)->save($data);
    //或者：$resul t= $Dao->where($condition)->data($data)->save();
}

等同于SQL语句：

UPDATE user SET email='Jack@163.com' WHERE username='Jack';

提示

为了保证数据库的安全，避免出错更新整个数据表，如果没有任何更新条件，数据对象本身也不包含主键字段的话，save方法不会更新任何数据库的记录。

因此要使用 save() 方法更新数据，必须指定更新条件或者更新的数据中包含主键字段。

4、查

　ThinkPHP 查询数据主要提供以下几类查询：　

1）select

是 ThinkPHP 中最常用的普通查询方法，得到的是一个二维数组。

//方法php
public function read(){
    $Dao = M("User");
    
    // 查询数据
    $list = $Dao->select();
    //dump($list);    // 用 dump() 可以在调试阶段查看数据是否已读取

    // 模板变量赋值
    $this->assign("list", $list);
    // 输出模板
    $this->display();
}

//模板html
<table border="1">
    <tr>
        <th width="10%">ID</th>
        <th width="30%">用户名</th>
        <th width="30%">电子邮件</th>
        <th>注册时间</th>
    </tr>
    <volist name="list" id="vo">//循环显示
    <tr>
        <td align="center">{$vo['uid']}</td>
        <td>{$vo['username']}</td>
        <td>{$vo['email']}</td>
        <td>{$vo['regdate']|date='Y-m-d H:i',###}</td>
    </tr>
    </volist>
</table>

2）find

该方法是和 select() 用法类似的一个方法，不同之处 find() 查询出来的始终只有一条数据，即系统自动加上了 LIMIT 1 限制。

//当确认查询的数据记录只能是一条记录时，建议使用 find() 方法查询，如用户登录账号检测：

public function chekUser(){
    header("Content-Type:text/html; charset=utf-8");
    $Dao = M("User");
    
    // 构造查询条件
    $condition['username'] = 'Admin';
    $condition['password'] = MD5('123456');
    // 查询数据
    $list = $Dao->where($condition)->find();
}

//与 select() 的另一个不同之处在于，find() 返回的是一个一维数组，可以在模板里直接输出数组单元的值而无需使用 volist 等标签循环输出：

<p>{$list['username']}</p>

 　　　　

3）getBy动态查询

是一个魔术方法，可以根据某个字段名称动态得到对应的一条数据记录。

public function chekUser(){
    header("Content-Type:text/html; charset=utf-8");
    $Dao = M("User");

    // 查询数据
    $user = $Dao->getByUsername('Admin');
}

等同于SQL语句：

SELECT * FROM user WHERE username = 'Admin' LIMIT 1

提示：

请注意，在getBy之后紧跟着的字段名称，首字母必须大写。对于如 user_name 这样的字段名称，以驼峰法自动识别下划线，即：

$user = $Dao->getByUserName('Admin');

实际使用中可以灵活根据查询的字段名来定义 getBy 放入，如：getByEmail、getByTitle、getById 等。

　　　　　　　　

4）getField

是专门用于获取某个字段的值或者多个字段的索引数组。该方法与 field方法 不同，是一个独立的方法而不需要再使用 find 或者 select 。

参数	说明
fields	必须，需要查询的字段名称，可以是一个或多个字段
condition	可选，查询条件，可以是字符或数组，参考 select 方法查询条件
spea	可选，多个字段数据生成关联数组时，数据间隔符号，默认为空格

public function select(){
    header("Content-Type:text/html; charset=utf-8");
    $Dao = M("User");
    $list = $Dao->getField('uid,username,email','uid < 4','|');
    dump($list);
}

 //dump 打印出的结果是：

array(3) {
  [1] => string(21) "admin|admin@5idev.com"
  [2] => string(23) "小明|xiaoming@163.com"
  [3] => string(19) "Jack|jack@gmail.com"
}

 　　　

5）区间查询

取得符合查询条件的区间记录

public function read(){
    $Dao = M('User');
    $condition['uid'] = array(array('gt',1),array('lt',5));//(uid > 1) AND (uid < 5)
3.1    $condition['uid'] = array(array('gt',3),array('lt',10), 'or');//(uid < 1) OR (uid > 10)
3.2    $condition['username'] = array(array('like','%a%'), array('like','%b%'), 'Admin','or');//(username LIKE '%a%') OR (username LIKE '%b%') OR (username = 'Admin')
    $list = $Dao->where($condition)->select();
    if($list){
        $this->assign('list', $list);
        $this->display();
    } else {
        $this->error($Dao->getError());
    }
} 

等同于SQL语句：

SELECT * FROM user WHERE ( (uid > 1) AND (uid < 5) );

6）原生SQL查询

尽管ThinkPHP内置了大量的数据操作方法，但ThinkPHP仍保留了对原生SQL查询的支持，以便满足复杂查询的需要和一些特殊的数据操作。SQL查询的返回值是直接返回DB类的查询结果，没有做任何的处理，而且可以支持查询缓存。

原生SQL查询有 query() 和 execute() 两个方法：

//query() 方法是用于 SQL 查询操作，和select()方法一样返回符合查询条件的数据集。
//对于 query() 方法返回的数据集，跟 select() 一样，可以在模板里直接循环输出。
public function read(){
    // 实例化一个空模型，没有对应任何数据表
    $Dao = M();
    //或者使用 $Dao = new Model();

    $list = $Dao->query("select * from user where uid<5");
    if($list){
        $this->assign('list', $list );
        $this->display();
    } else {
        $this->error($Dao->getError());
    }
}


//execute() 方法用于更新和写入数据的 SQL 操作（注：非查询操作，无返回数据集），返回影响的记录数。

public function read(){
    header("Content-Type:text/html; charset=utf-8");
    // 实例化一个空模型，没有对应任何数据表
    $Dao = M();
    //或者使用 $Dao = new Model();

    $num = $Dao->execute("update user set email = '12345@xxx.com' where uid=3");
    }

 　　　　 

7）统计查询

取得符合查询条件的统计数据 　　　　　　

count()

方法用于统计数据行数。

public function read(){
    $Dao = M('User');
    // 获取用户数：
    $userCount = $Dao->count();
    // 添加条件：
    $userCount2 = $Dao->where('uid > 10')->count();

    $this->assign('userCount', $userCount);
    $this->display();
}//可以在模板中直接输出得到的统计数据：共有用户 {$userCount} 人。

两个查询语句实际执行的 SQL 为：

SELECT COUNT(*) AS tp_count FROM user LIMIT 1 
SELECT COUNT(*) AS tp_count FROM user WHERE uid > 10 LIMIT 1

 　　　　

max()

方法用于统计某个字段最大数据。

1 //统计用户最大积分例子：

$maxScore = $Dao->max('score');

实际执行的 SQL 为：

SELECT MAX(score) AS tp_max FROM user LIMIT 1 ;

　　　

min()

统计某个字段最小数据。

//获取积分大于 0 的用户的最小积分例子：
$minScore = $Dao->where('score>0')->min('score');

实际执行的 SQL 为：

SELECT MIN(score) AS tp_min FROM user WHERE score>0 LIMIT 1;

 　　　　

avg()

统计某个字段平均数据。

//获取用户的平均积分例子：
$avgScore = $Dao->avg('score');

实际执行的 SQL 为：

SELECT AVG(score) AS tp_avg FROM user LIMIT 1;

 　　　

sum()

统计某个字段数据之和。

//统计积分排名前 10 名用户的积分之和：
$sumScore = $Dao->order('score DESC')->limit('10')->sum('score');

实际执行的 SQL 为：

SELECT SUM(score) AS tp_sum FROM user ORDER BY score DESC LIMIT 10;