关键词搜索

源码搜索 ×
×

TP6模型原理与基本操作教程

发布2021-11-20浏览1582次

详情内容

模型简介

  1. /*
  2. Navicat MySQL Data Transfer
  3.  
  4. Source Server         : 127.0.0.1
  5. Source Server Version : 50726
  6. Source Host           : localhost:3306
  7. Source Database       : tp6
  8.  
  9. Target Server Type    : MYSQL
  10. Target Server Version : 50726
  11. File Encoding         : 65001
  12.  
  13. Date: 2020-05-28 11:45:22
  14. */
  15.  
  16. SET FOREIGN_KEY_CHECKS=0;
  17.  
  18. -- ----------------------------
  19. -- Table structure for user
  20. -- ----------------------------
  21. DROP TABLE IF EXISTS `user`;
  22. CREATE TABLE `user` (
  23.   `user_id` int(10) unsigned NOT NULL AUTO_INCREMENT,
  24.   `name` varchar(30) COLLATE utf8mb4_unicode_ci NOT NULL,
  25.   `age` tinyint(3) unsigned NOT NULL,
  26.   `email` varchar(100) COLLATE utf8mb4_unicode_ci NOT NULL,
  27.   `password` varchar(32) COLLATE utf8mb4_unicode_ci NOT NULL,
  28.   PRIMARY KEY (`user_id`)
  29. ) ENGINE=InnoDB AUTO_INCREMENT=7 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;
  30.  
  31. -- ----------------------------
  32. -- Records of user
  33. -- ----------------------------
  34. INSERT INTO `user` VALUES ('1', '韦小宝', '35', 'wexiaobao@php.cn', 'e10adc3949ba59abbe56e057f20f883e');
  35. INSERT INTO `user` VALUES ('2', '小龙女', '50', 'xln@php.cn', 'e10adc3949ba59abbe56e057f20f883e');
  36. INSERT INTO `user` VALUES ('3', '过儿', '25', 'ge@php.cn', 'e10adc3949ba59abbe56e057f20f883e');
  37. INSERT INTO `user` VALUES ('4', '郭大侠', '45', 'gj@php.cn', 'e10adc3949ba59abbe56e057f20f883e');

第1步：（ app\index\model\User.php ）新建model文件目录，并在其下方新建一个类文件User.php内容如下

  1. <?php
  2. namespace app\index\model;
  3.  
  4. use think\Model;
  5.  
  6. class User extends Model{
  7.  
  8.     protected $table = 'user';
  9.     protected $pk = 'user_id';
  10.  
  11. }

第2步：（ app\index\controller\ModelTest.php ）在controller文件目录下，新建一个类文件 ModelTest .php内容如下

  1. <?php
  2. namespace app\index\controller;
  3.  
  4. use app\index\model\User;
  5.  
  6.  
  7. class ModelTest{
  8.  
  9.  
  10.     //模型对象  
  11.     public function demo1()
  12.     {
  13.  
  14.         //创建模型对象
  15.         $user = new User();
  16.         
  17.         //查询一条数据
  18.         $res = $user->db()->find(1);
  19.         dump($res);
  20.  
  21.         //查询所有数据
  22.         //$res = $user->db()->select();
  23.  
  24.         //测试打印输出对象方式 dump()/var_dump() 
  25.         // var_dump 打印输出对象：var_dump($user);
  26.         // dump($res);
  27.         // dump(gettype($user));   
  28.     }
  29.  
  30.     //依赖注入
  31.     public function demo2(User $user)
  32.     {
  33.  
  34.           $res = $user->db()->find(3);          
  35.           //dump($res);
  36.           var_dump($res);
  37.  
  38.           echo '<hr>';
  39.           echo  $res['name'];
  40.  
  41.           echo '<br/>';
  42.           echo  $res->name;
  43.  
  44.     }
  45.  
  46.  
  47.  
  48.  
  49.     //1.新增操作：create():参数就是要新增的数据，返回当前模型对象
  50.  
  51.     public function insert()
  52.     {
  53.         $data = ['name'=> '乔峰','age'=>40,'email'=>'qiaofeng@php.cn','password'=>Md5('123')];  // 根据数据库字段设置，也可以用 sha1('123')
  54.  
  55.         $user = User::create($data);
  56.  
  57.         $insertId = $user['user_id'];
  58.  
  59.         return '新增成功，新增记录的主键ID是：'.$insertId;
  60.  
  61.     }
  62.  
  63.  
  64.  
  65.     //2.查询操作
  66.     //在tp6中，删除了传统的get/all，直接用db()来调用Query类中的方法完成
  67.  
  68.     public function select(User $user)
  69.     {
  70.         //单条  查看对象：var_dump($user->db()); 
  71.         echo '打印单条数据：';       
  72.         $res1 = $user->db()->find(3);
  73.         dump($res1);
  74.  
  75.         echo '<hr>';
  76.         echo '打印全部数据：';   
  77.  
  78.         //all()  根据条件 where() 打印出年龄大于30的所有数据
  79.         $res2 = $user->db()->where('age','>',30)->select();
  80.         dump($res2);
  81.     }
  82.  
  83.  
  84.  
  85.     //3.更新操作：update
  86.     public function update()
  87.     {
  88.         $user = User::update(['age'=>50],['user_id'=>2]);       
  89.         return '年龄已经被更新成：'.$user['age'];
  90.  
  91.     }
  92.  
  93.  
  94.     // 4.删除操作：destroy():返回布尔值
  95.  
  96.     public function delete()
  97.     {
  98.  
  99.       //删除user_id 等于 5的数据记录
  100.  
  101.       //删除方式1：静态方法方式
  102.       //   $res = User::destroy(['user_id'=>5]);
  103.  
  104.       //删除方式2：闭包方式，根据条件,删除user_id 等于5的记录
  105.       $res = User::destroy( function($query){
  106.           $query->where('user_id',5);  //凡是使用静态方法的，都可以用闭包方式传递参数，例如：User::destroy和User::update
  107.       });
  108.       return $res ? '删除成功':'删除失败';
  109.  
  110.     }
  111. }

运行结果截图

总结

模型基本操作一

创建模型类: 类名与数据库同名
实例化方式： 类方法中实例化，依赖注入(外部实例化)
常用操作: CURD(增删改查)
调用方式：
实例方法: 必须通过模型对象调用
静态方法: 直接用模型类调用(推荐)

模型基本操作二

查询：db()
新增：create()
更新: update()
删除: destory()

使用：

  1. //引用
  2. use app\services\table\model\Guestbook;
  3.  
  4. //实例化
  5. $Guestbook = new GuestbookModel();
  6.  
  7. //写入默认数据库(protected $connection = 'enterprise_cold')的表
  8. $rs=$Guestbook->save([
  9.   'username'  =>  'thinkphp',
  10.   'phone' =>  '1364002250'
  11. ]);
  12.  
  13. //写入其它数据库(enterprise)中，不使用默认值
  14. $rs=$Guestbook->connect('enterprise')->save([
  15.   'username'  =>  'thinkphp',
  16.   'phone' =>  '1364002250'
  17. ]);

实际例子：

1.分布式数据库插入多表数据，有事务需要回滚

调用：

  1. //引用
  2. use app\services\table\model\Guestbook;
  3.  
  4. //静态调用
  5. $returnData = Guestbook::saveGuestbook($postdata);
  6.

表对应模型文件代码：

  1. <?php
  2. namespace app\services\table\model;
  3. use think\Model;
  4. use think\facade\Db;
  5. use app\services\table\validate\GuestbookValidate;
  6.  
  7. class Guestbook extends Model
  8. {
  9.     protected $name = 'guestbook'; //表名 
  10.     protected $connection = 'enterprise_cold';//数据库的连接
  11.  
  12.  
  13.     protected $autoWriteTimestamp = 'int';
  14.     protected $createTime = 'time';
  15.     // protected $updateTime = 'utime';
  16.  
  17.     // 设置字段信息
  18.     protected $schema = [
  19.         'id'          => 'int',
  20.         'uid'          => 'bigint',//(唯一:前端用户取得电脑MAC转为十制进数字)
  21.         'enterprise_id'        => 'int',
  22.         'phone'        => 'string',
  23.         'username'      => 'string',
  24.         'content'       => 'string',
  25.         'gid' => 'int',
  26.         'sid' => 'int',
  27.         'wx' => 'string',
  28.         'email' => 'string',
  29.         'qq' => 'int',
  30.         'url' => 'string',
  31.         'ip' => 'string',
  32.         'type' => 'int',
  33.         'hide' => 'int',
  34.         'deleted' => 'int',
  35.         'deleted_time' => 'int',
  36.         'deleted_userid' => 'int',
  37.         'time' => 'int',
  38.     ];
  39.  
  40. 	/**
  41. 	* @name 保存访客提交过来的留言
  42. 	* @method Model
  43. 	* @date 2021-11-19
  44.     * @param 1 $postdata arr/必填 提交数组
  45. 	* @ruturn array
  46. 	*/
  47. 	static public function saveGuestbook(array $postdata)
  48. 	{
  49. 		Db::connect('enterprise_cold')->startTrans();
  50. 		Db::connect('enterprise_heat')->startTrans();
  51. 		try {
  52.  
  53. 			$postdata['enterprise_id'] = !empty($postdata['eid'])?$postdata['eid']:0;
  54. 			
  55. 			validate(GuestbookValidate::class)->scene('onlineserviceApi_tel')->check($postdata);
  56.  
  57. 			// $eid = !empty($postdata['enterprise_id'])?$postdata['enterprise_id']:0;
  58. 			$enterpriseData = numberEncodeDecodeHashids('enterprise',$postdata['enterprise_id'],1);//解密
  59. 			if($enterpriseData['code']!=200){
  60. 				throw new \Exception("非法提交，互联网不是法外之地，请慎重！");
  61. 			}
  62.             //客服分组ID
  63.             if(!empty($postdata['gid'])){
  64.                 $enterpriseData = numberEncodeDecodeHashids('onlineservice_group',$postdata['gid'],1);//解密
  65.                 if($enterpriseData['code']!=200){
  66.                     throw new \Exception("非法提交，互联网不是法外之地，请慎重！");
  67.                 }
  68.             }
  69.             //客服ID
  70.             if(!empty($postdata['sid'])){
  71.                 $enterpriseData = numberEncodeDecodeHashids('enterprise_userid',$postdata['sid'],1);//解密
  72.                 if($enterpriseData['code']!=200){
  73.                     throw new \Exception("非法提交，互联网不是法外之地，请慎重！");
  74.                 }
  75.             }
  76.  
  77. 			$postdata['enterprise_id'] = $enterpriseData['data'][0];
  78.  
  79. 			//1.7天表、1个月表
  80. 			self::connect('enterprise_heat')->setSuffix('_7d')->save($postdata);//7天表
  81. 			self::connect('enterprise_heat')->setSuffix('_1m')->save($postdata);//1个月表
  82.  
  83. 			//2.今年表 以前表
  84. 			(new static())->setSuffix('_1y')->save($postdata);//今年表
  85. 			(new static())->save($postdata);//以前表(所有数据表)
  86.  
  87. 		    $code=200;$msg="成功";
  88. 			Db::connect('enterprise_cold')->commit();
  89. 			Db::connect('enterprise_heat')->commit();
  90. 		} catch (\Exception $e) {
  91. 			Db::connect('enterprise_cold')->rollback();
  92. 			Db::connect('enterprise_heat')->rollback();
  93. 			$code=-200;$msg=$e->getMessage();
  94. 		}
  95.         return ['code' => $code,'msg' =>$msg];
  96.  
  97. 	}
  98.  
  99. }

2.单库单表插入数据(有事就启用)

调用:

  1. //引用
  2. use app\services\table\model\Guestbook;
  3.  
  4. //动态调用 要实例化
  5. $TaskLog =new TaskLog();
  6. $returnData = $TaskLog ->saveGuestbook($postdata);

表对应模型文件代码：

  1. <?php
  2. namespace app\services\table\model;
  3. use think\Model;
  4. use think\facade\Db;
  5. use app\services\table\validate\TaskLogValidate;
  6.  
  7. /**
  8. * @name 任务日志
  9. * @method Model/POST/GET/
  10. * @date 2021-12-01
  11. */
  12. class TaskLog extends Model
  13. {
  14.     protected $name = 'task_log'; //表名 
  15.     protected $connection = 'log';//数据库的连接
  16.  
  17.  
  18.     protected $autoWriteTimestamp = 'int';
  19.     protected $createTime = 'time';
  20.     // protected $updateTime = 'utime';
  21.  
  22.     // 设置字段信息
  23.     protected $schema = [
  24.         'id'          => 'int',
  25.         'user_id'          => 'int',
  26.         'enterprise_id'        => 'int',
  27.         'title'        => 'string',
  28.         'data'      => 'string',
  29.         'content'       => 'string',
  30.         'starttime' => 'int',
  31.         'endtime' => 'int',
  32.         'url' => 'string',
  33.         'state' => 'int',
  34.         'url' => 'string',
  35.         'type' => 'int',
  36.         'mold' => 'int',
  37.         'delay' => 'int',
  38.         'time' => 'int',
  39.     ];
  40.  
  41.  
  42. 	/**
  43. 	* @name 保存访客提交过来的留言
  44. 	* @method Model
  45. 	* @date 2021-11-19
  46.     * @param 1 $postdata arr/必填 提交数组
  47. 	* @ruturn array
  48. 	*/
  49.     public function DataSave(array $postdata)
  50. 	{
  51. 		// Db::connect($this->connection)->startTrans();//有回滚就启用
  52. 		try {
  53.  
  54.             
  55. 			// if(empty($postdata)){
  56.             //     throw new \Exception("提交数据为空!");
  57.             // }
  58. 			$postdata['enterprise_id'] = !empty($postdata['eid'])?$postdata['eid']:0;
  59. 			
  60. 			validate(TaskLogValidate::class)->check($postdata);
  61.  
  62.             if(!empty($postdata['enterprise_id'])){
  63.                 $enterpriseData = numberEncodeDecodeHashids('enterprise',$postdata['enterprise_id'],1);//解密
  64.                 if($enterpriseData['code']!=200){
  65.                     throw new \Exception("非法提交，互联网不是法外之地，请慎重！");
  66.                 }
  67.                 $postdata['enterprise_id'] = $enterpriseData['data'][0];
  68.             }
  69.  
  70. 			$this->save($postdata);//以前表(所有数据表)
  71.  
  72. 		    $code=200;$msg="成功";
  73. 			// Db::connect($this->connection)->commit();
  74. 		} catch (\Exception $e) {
  75. 			// Db::connect($this->connection)->rollback();
  76. 			$code=-200;$msg=$e->getMessage();
  77. 		}
  78.         return ['code' => $code,'msg' =>$msg];
  79.  
  80. 	}
  81.  
  82. }

相关技术文章

最新源码

下载排行榜
点击QQ咨询
开通会员
返回顶部
×
微信扫码支付 元
微信扫码支付
确定支付下载
请使用微信描二维码支付
×

提示信息

×

选择支付方式

  • 微信支付
  • 支付宝付款
确定支付下载