模型操作

通过模型操作数据库，在swoole下自动切换为连接池。在fpm下自动为单列。

插入一条数据

  2. $id  = User::insert([
  3.     'name'  => $key,
  4.     'email' => 'name@aa.com',
  5. ]);

迭代用户所有的数据

  1. $rs = User::chunk();
  2. foreach($rs as $user){
  4. }

迭代和关系组合使用

  1. User::where('id', '>', 100)
  2. ->where('status', '>', 1)
  3. ->with('category')
  4. ->with('article', [
  5.     function ($q) {
  6.         $q->with('tags.tag')->with('commmit.user');
  7.     }
  8. ])
  9. ->chunk();

插入多条数据

  2. $ar = [];
  3. for ($i = 0; $i < 100; $i++) {
  4.     $ar[] = [
  5.         'name'  => 'name' . $i,
  6.         'email' => 'name' . $i . '@aa.com',
  7.         'age'   => rand(10, 70)
  8.     ];
  9. }
  10. User::insert($ar, true);

更新数据

  2. // 先查询后更新 累加
  3. $one = User::find(10);
  4. $row = $one->update(['name' => 'name3s', 'age' => ['age+1']]); // 条件是主键
  5. echo $row . PHP_EOL; // 影响行数
  6. //update users set name='name3s',age=age+1 where id='10'
  8. // 批量更新
  9. $row = User::whereIn('id', [6, 7, 8])->update(['email' => 1423]);
  10. echo $row . PHP_EOL;
  11. // update users set email='123' where id in ('6','7','8')
  13. // 查询出来的对象可以直接调用update
  14. $arr = User::where('id', '>', '20')->orderBy('id asc')->limit(3)->findAll();
  15. foreach ($arr as $v) {
  16.     $v->update(['age' => 19]); // 条件是主键
  17. }

删除

  2. $row = User::whereIn('id', [61, 71, 81])->delete();
  3. echo $row . PHP_EOL;// 影响行数
  4. $one = User::find(66);
  5. $row = $one->delete();  // 条件是主键
  6. echo $row . PHP_EOL;

查询

  2. // with 可无限级数关联下去
  4. $arr = User::with('articles.article_tags.tag')->limit(10)->findAll()->toArray();

关联查询

  1. // select * from users left join articles on users.id=articles.user_id where users.id>1
  2. $arr = User::where('users.id', '>', '1')->leftJoin('articles', 'users.id', 'articles.user_id')->findAll()->toArray();
  4. // select * from users left join articles on users.id=articles.user_id and articles.read_count>2 where users.id>1
  5. $arr = User::where('users.id', '>', '1')->leftJoin('articles', function (Join $q) {
  6.     $q->on('users.id', 'articles.user_id')->where('articles.read_count', '>', 2);
  7. })->findAll()->toArray();