PHP基于PDO扩展操作mysql数据库示例

本文实例讲述了PHP基于PDO扩展操作mysql数据库。分享给大家供大家参考，具体如下：

SELECT

//查单条function get_sub_product(){  $res_zz = $pdo->query("SELECT id FROM content WHERE is_publish = 0 LIMIT 1;");  $rep = $res_zz->fetch();}//查多条function get_sub_product(){  $dsn = "mysql:host=localhost;dbname=bwdb";  $pdo = new PDO($dsn, "root", "root");  $pdo->query("set names utf8");  $res_zz = $pdo->query("SELECT product_id FROM sub_product WHERE 1= 1;");  $rep = $res_zz->fetchAll();  $product_id_arr = array();  foreach ($rep as $v) {    $product_id_arr[] = $v["product_id"];  }  return $product_id_arr;}

INSERT

function add(){  try {    $pdo->beginTransaction();    $reb = $pdo->prepare("INSERT INTO `content` (`id`,`content`) VALUES(:version_id,:content);");    $reb->bindParam(":version_id", $version_id, PDO::PARAM_INT);    $reb->bindParam(":content", $content, PDO::PARAM_STR);    $type_id = 1;    $reb->bindParam(":type_id", $type_id, PDO::PARAM_INT);    $reb->bindParam(":cdate", $time, PDO::PARAM_STR);    $reb->bindParam(":mdate", $time, PDO::PARAM_STR);    if ($reb->execute() > 0) {      $pdo->commit();      die("成功!");    }    $pdo->rollback();    die("失败!");  } catch (PDOException $ex) {    echo($ex->getMessage());  }}function add($res_arr){  $dsn = "mysql:host=localhost;dbname=db";  $pdo = new PDO($dsn, "root", "root");  $pdo->query("set names utf8");  $value = "";  date_default_timezone_set("Asia/Shanghai"); //时区  $time = date("Y-m-d h:i:s");  foreach ($res_arr as $k => $v) {    $hash = md5($v["ProductID"] . "-" . $v["CategoryID"] . "-" . $v["CategoryName"]);    $value .= "("" . $v["ProductID"] . "","" . $v["CategoryID"] . "","" . $v["CategoryName"] . "","" . $v["ProductName"] . "","" . $v["Abbreviation"] . "","" . $v["SubscribeStatus"] . "","" . $v["ProductStatus"] . "","" .      $v["BrandID"] . "","" . $v["BrandName"] . "","" . $v["TradeType"] . "","" . $v["ProductModel"] . "","" . $v["UPCCode"] . "","" . $v["Weight"] . "","" . $v["Summary"] . "","" .      $v["LongDescription"] . "","" . $v["BuyNotice"] . "","" . $v["PackingList"] . "","" . $v["DefaultImage"] . "","" . $v["Keywords"] . "","" . $v["VendorID"] . "","" . $v["StoreID"] . "","" .      $v["CurrentPrice"] . "","" . $v["AvailableQty"] . "","" . $hash . "","" . $time . "","" . $time . ""),";  }  $vv = substr($value, 0, strlen($value) - 1);  try {    $pdo->beginTransaction();    if (!empty($vv)) {      $reb = $pdo->prepare("REPLACE INTO `product_list` (`product_id`, `category_id`, `category_name`, `product_name`, `abbreviation`, `subscribe_status`, `product_status`, `brand_id`, `brand_name`, `trade_type`, "        . "`product_model`, `upc_code`, `weight`, `summary`, `long_description`, `buy_notice`, `packing_list`, `default_image`, `keywords`, `vendor_id`, `store_id`, `current_price`, "        . "`available_qty`, `hash`, `cdate`, `mdate`) VALUES $vv;");      if ($reb->execute() > 0) {        $pdo->commit();        return 1;      }    }  } catch (PDOException $ex) {    $pdo->rollback();  }  return -1;}

UPDATE

function update(){  try {    $pdo->beginTransaction();    $is_publish = 1;    $req = $pdo->prepare("UPDATE `content` SET is_pub=:is_pub,mdate=:mdate WHERE id = :id;");    $req->bindParam(":is_publish", $is_publish, PDO::PARAM_INT);    $req->bindParam(":id", $version_id, PDO::PARAM_INT);    $req->bindParam(":mdate", $time, PDO::PARAM_STR);    if ($req->execute()) {      $pdo->commit();      die("成功!");    }    $pdo->rollback();    die("失败!");  } catch (PDOException $ex) {    echo($ex->getMessage());  }}

更多关于PHP相关内容感兴趣的读者可查看本站专题：《PHP基于pdo操作数据库技巧总结》、《php+Oracle数据库程序设计技巧总结》、《PHP+MongoDB数据库操作技巧大全》、《php面向对象程序设计入门教程》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》

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