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程序设计有所帮助。