本文实例讲述了PHP基于PDO扩展操作mysql数据库。分享给大家供大家参考，具体如下：
SELECT
//查单条
function get_sub_product()
{
$res_zz...
本文实例讲述了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程序设计有所帮助。
版权声明
本文仅代表作者观点，不代表百度立场。
本文系作者授权百度百家发表，未经许可，不得转载。
