PHP中怎么使用PDO和消息队列

这期内容当中小编将会给大家带来有关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=setnamesutf8

数据表文件queue.sql的内容：

--消息队列测试
--商品表
createtablegoods(
idintunsignedprimarykeyauto_increment,
goodsnamevarchar(40)notnullcomment'商品名',
pricedecimal(9,2)notnullcomment'价格',
category_idtinyintunsignednotnullcomment'商品类别id',
sorttinyintcomment'商品排序',
descriptionvarchar(255)comment'商品描述',
remarkvarchar(255)comment'备注'
)engineInnoDBdefaultcharset=utf8;
insertintogoodsvalues(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
namespaceHome;
header('content-type:text/html;charset=utf-8;');
//引入PDO类
use\PDO;
use\PDOStatement;
use\PDOException;
/*简单消息队列*/
classQueue{
//容器可以是私有，最好是公有
staticpublic$container=array();
//把PDO对象存放到属性中是为了跨方法使用
staticprivate$pdo;
//构造函数实现初始化PDO连接数据库
publicfunction__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=newPDO($dsn,$username,$password,$options);
//设置PDO属性。抛出错误报告
self::$pdo->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
try{
//选择商品数据表所在的数据库
self::$pdo->exec('usequeue');
}catch(PDOException$e){
echo$e->getMessage();
}
}catch(PDOException$e){
echo$e->getMessage();
}
}
/*
*入列
*$data数组
*成功返回1，失败返回false，或者null
*/
publicfunction_unshift($data=array()){
if(!is_array($data)||empty($data)){returnfalse;}
$sql='default';
foreach($dataas$k=>$v){
$sql.=',"'.$v.'"';
}
//把$data转为sql语句，添加到队列容器contain中
$sql='insertintogoodsvalues('.$sql.')';
return@array_unshift(self::$container,$sql);
}
/*
*出列
*成功返回最后插入的数据id
*失败返回失败信息
*/
privatestaticfunction_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
returnself::$pdo->lastInsertId();
}catch(PDOException$e){
return$e->getMessage();
}
}
//析构函数，对象回收时调用，通过它实现自动让容器数据入库
publicfunction__destruct(){
//当对象被回收时，判断容器是否存在消息，假如存在，则调用_pop方法，把消息出列
if(self::$container){
self::_pop();
}
}
}

下面是同一级目录下调用这个类的文件的内容，当然，你也可以在上面那个queue类的下面调用_unshift方法实现消息队列的操作

<?php
include'./queue.php';
useHome\Queue;//引入命名空间的Queue类
$ob=newQueue;
//消息入列
$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和消息队列了，如果刚好有类似的疑惑，不妨参照上述分析进行理解。如果想知道更多相关知识，欢迎关注恰卡编程网行业资讯频道。