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

<"'.$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();
    }
  }
}

<"_blank" href="//www.jb51.net/Special/192.htm">PHP基于pdo操作数据库技巧总结》、《php+mysqli数据库程序设计技巧总结》、《php面向对象程序设计入门教程》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》

希望本文所述对大家PHP程序设计有所帮助。