[PHP] PHP PDO和消息队列的个人理解与应用实例分析

[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

-- 消息队列测试
-- 商品表
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);

<?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();
  }
  }
}

<?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);