完整示例php+pdo实现的购物车类

<?php
session_start();
class Cart
{
  public $pdo = null;
  public function __construct($config)
  {
    $host = $config[&#39;host&#39;];
    $user = $config[&#39;user&#39;];
    $db = $config[&#39;db&#39;];
    $pwd = $config[&#39;pwd&#39;];
    if (empty($_SESSION[&#39;user_id&#39;])) {
      return show(0, &#39;请先登录&#39;);
    }
    try {
      $this->pdo = new PDO("mysql:host=$host;dbname=$db", "$user", "$pwd", array(PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION));
      $this->pdo->query("set names utf8");
    } catch (PDOException $e) {
      echo $e->getMessage();
    }
  }
  //添加商品到购物车
  public function add_cart($productid, $num)
  {
    $sql = "select price from shop_product where id=?";
    $stmt = $this->pdo->prepare($sql);
    $stmt->execute(array($productid));
    $data = $stmt->fetch(PDO::FETCH_ASSOC);
    $price = $data[&#39;price&#39;];
    $createtime = time();
    $sql = "select * from shop_cart where productid=? and userid=?";
    $stmt = $this->pdo->prepare($sql);
    $stmt->execute(array($productid, $_SESSION[&#39;user_id&#39;]));
    $data = $stmt->fetch(PDO::FETCH_ASSOC);
    if ($data) {
      $sql = "update shop_cart set num=num+? where userid=? and productid=?";
      $params = array($num, $_SESSION[&#39;user_id&#39;], $productid);
    } else {
      $sql = "insert into shop_cart(productid,num,userid,price,createtime) values(?,?,?,?,?)";
      $params = array($productid, $num, $_SESSION[&#39;user_id&#39;], $price, $createtime);
    }
    $stmt = $this->pdo->prepare($sql);
    $stmt->execute($params);
    $rows = $stmt->rowCount();
    return $rows ?
      show(1, &#39;ok&#39;, $rows) :
      show(0, &#39;fail&#39;);
  }
  //修改购买数量
  public function change_num($productid, $num)
  {
    $sql = "update shop_cart set num=? where userid=? and productid=?";
    $stmt = $this->pdo->prepare($sql);
    $stmt->execute(array($num, $_SESSION[&#39;user_id&#39;], $productid));
    $rows = $stmt->rowCount();
    return $rows ?
      show(1, &#39;ok&#39;, $rows) :
      show(0, &#39;fail&#39;);
  }
  //清空购物车
  public function clear_cart()
  {
    $sql = "delete from shop_cart where userid=?";
    $stmt = $this->pdo->prepare($sql);
    $this->pdo->execute(array($this->user_id));
    $rows = $stmt->rowCount();
    return $rows ?
      show(1, &#39;ok&#39;, $rows) :
      show(0, &#39;fail&#39;);
  }
  //从购物车中删除商品
  public function remove_cart($productid)
  {
    $sql = "delete from shop_cart where productid=? and userid=?";
    $stmt = $this->pdo->prepare($sql);
    $stmt->execute(array($productid, $_SESSION[&#39;user_id&#39;]));
    $rows = $stmt->rowCount();
    return $rows ?
      show(1, &#39;ok&#39;, $rows) :
      show(0, &#39;fail&#39;);
  }
}
//处理数据
function show($status, $message, $data = array())
{
  $result = array(
    &#39;status&#39; => $status,
    &#39;message&#39; => $message,
    &#39;data&#39; => $data
  );
  exit(json_encode($result));
}
//简单使用
$user = [
  &#39;host&#39; => &#39;&#39;,
  &#39;user&#39; => &#39;root&#39;,
  &#39;pwd&#39; => &#39;root&#39;,
  &#39;db&#39; => &#39;shop&#39;,
];
$productid = intval($_POST[&#39;productid&#39;]);
$num = intval($_POST[&#39;num&#39;]);
$cart = new Cart($user);
//添加到购物车
$cart->add_cart($productid, $num);
//删除指定的商品
$cart->remove_cart($productid);
//清空
$cart->clear_cart();
?>