您好,登录后才能下订单哦!
密码登录
登录注册
点击 登录注册 即表示同意《亿速云用户服务条款》
这期内容当中小编将会给大家带来有关PHP中怎么使用PDO和消息队列,文章内容丰富且以专业的角度为大家分析和叙述,阅读完这篇文章希望大家可以有所收获。
配置文件mysql.ini的内容:
[database] driver = mysql host = 127.0.0.1 port = 3306 dbname = mysql username = root password = 1234 [options] PDO::MYSQL_ATTR_INIT_COMMAND = set names utf8
数据表文件queue.sql的内容:
-- 消息队列测试 -- 商品表 create table goods( id int unsigned primary key auto_increment, goodsname varchar(40) not null comment '商品名', price decimal(9,2) not null comment '价格', category_id tinyint unsigned not null comment '商品类别id', sort tinyint comment '商品排序', description varchar(255) comment '商品描述', remark varchar(255) comment '备注' )engine InnoDB default charset=utf8; insert into goods values(default,'iPhone5s',5999,1,1,'美国入口贵重电子产品','请多多销售'),(default,'宏基手提电脑1',4888,3,1,'价格划算好电脑',null),(default,'f-30绒衣',200,2,1,'以纯白色厚皮羽绒服',null),(default,'n-100鞋子',300,4,1,'Nick品牌',null);
下面是简单的消息队列实现PDO商品入库的代码:
郑重提醒:请认真看我的注释,请认真看我的注释,请认真看我的注释。重要的信息要说三遍,呵呵!
<?php namespace Home; header('content-type:text/html;charset=utf-8;'); //引入PDO类 use \PDO; use \PDOStatement; use \PDOException; /*简单消息队列*/ class Queue{ //容器可以是私有,最好是公有 static public $container=array(); //把PDO对象存放到属性中是为了跨方法使用 static private $pdo; //构造函数实现初始化PDO连接数据库 public function __construct($file = './mysql.ini'){//mysql数据库的配置文件,./mysql.ini与这个类是同一个目录 //parse_ini_file函数作用,解析并获取ini文件的参数,加true是二维数组 $dbini = parse_ini_file($file,true); $driver = $dbini['database']['driver']; //这里的数据库是mysql的总数据库 $dbname = $dbini['database']['dbname']; $host = $dbini['database']['host']; $port = $dbini['database']['port']; //构造PDO连接数据库的第一个参数,这个参数这么设置纯属是PDO类的语法,不懂的可以百度一下,这里就不做详解了 $dsn = $driver.':'.'dbname='.$dbname.';host='.$host.';port='.$port; //其他连接数据库参数 $username = $dbini['database']['username']; $password = $dbini['database']['password']; $options = $dbini['options'];//初始化设置PDO选项 try{ self::$pdo = new PDO($dsn,$username,$password,$options); //设置PDO属性。抛出错误报告 self::$pdo->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION); try{ //选择商品数据表所在的数据库 self::$pdo->exec('use queue'); }catch(PDOException $e){ echo $e->getMessage(); } }catch(PDOException $e){ echo $e->getMessage(); } } /* *入列 *$data数组 *成功返回1,失败返回false,或者null */ public function _unshift($data =array()){ if(!is_array($data) || empty($data)){return false;} $sql = 'default'; foreach($data as $k=>$v){ $sql .= ',"'.$v.'"'; } //把$data转为sql语句,添加到队列容器contain中 $sql = 'insert into goods values('.$sql.')'; return @array_unshift(self::$container,$sql); } /* *出列 *成功返回最后插入的数据id *失败返回失败信息 */ private static function _pop(){ try{//获取尾部的sql语句,出列 $sql = array_pop(self::$container); self::$pdo->exec($sql); //把剩余的容器值赋给中间变量 $middle = self::$container; //判断中间变量是否为空,不为空则继续获取容器尾部的数据,继续出列 while($middle){ $sql = array_pop($middle); self::$pdo->exec($sql); //把数据再转给容器,也就是转给while循环外面的$middle,这样才能实现循环,让容器里面的数据全部出列,插入到数据库中 self::$container = $middle; } //返回的是,最后插入的id,失败是null return self::$pdo->lastInsertId(); }catch(PDOException $e){ return $e->getMessage(); } } //析构函数,对象回收时调用,通过它实现自动让容器数据入库 public function __destruct(){ //当对象被回收时,判断容器是否存在消息,假如存在,则调用_pop方法,把消息出列 if(self::$container){ self::_pop(); } } }
下面是同一级目录下调用这个类的文件的内容,当然,你也可以在上面那个queue类的下面调用_unshift方法实现消息队列的操作
<?php include './queue.php'; use Home\Queue;//引入命名空间的Queue类 $ob = new Queue; //消息入列 $ob->_unshift(array('goodsname'=>'vivo手机8888','price'=>1120,'category_id'=>1,'sort'=>1,'description'=>'vivo品牌','remark'=>'好用')); $ob->_unshift(array('goodsname'=>'小米手机888','price'=>1998,'category_id'=>1,'sort'=>1,'description'=>'小米品牌手机','remark'=>'国产好货')); //之所以打印出来,完成是为了看看效果,至于,有没有实现商品入库,你得去看看你的数据库了,呵呵 var_dump(Queue::$container);
上述就是小编为大家分享的PHP中怎么使用PDO和消息队列了,如果刚好有类似的疑惑,不妨参照上述分析进行理解。如果想知道更多相关知识,欢迎关注亿速云行业资讯频道。
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。