PHP基于PDO扩展操作mysql数据库示例
本文实例讲述了PHP基于PDO扩展操作mysql数据库。分享给大家供大家参考，具体如下：
SELECT
//查单条
functionget_sub_product()
{
$res_zz=$pdo->query("SELECTidFROMcontentWHEREis_publish=0LIMIT1;");
$rep=$res_zz->fetch();
}
//查多条
functionget_sub_product()
{
$dsn='mysql:host=localhost;dbname=bwdb';
$pdo=newPDO($dsn,'root','root');
$pdo->query('setnamesutf8');
$res_zz=$pdo->query("SELECTproduct_idFROMsub_productWHERE1=1;");
$rep=$res_zz->fetchAll();
$product_id_arr=array();
foreach($repas$v){
$product_id_arr[]=$v['product_id'];
}
return$product_id_arr;
}
INSERT
functionadd()
{
try{
$pdo->beginTransaction();
$reb=$pdo->prepare("INSERTINTO`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());
}
}
functionadd($res_arr)
{
$dsn='mysql:host=localhost;dbname=db';
$pdo=newPDO($dsn,'root','root');
$pdo->query('setnamesutf8');
$value='';
date_default_timezone_set("Asia/Shanghai");//时区
$time=date('Y-m-dh:i:s');
foreach($res_arras$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("REPLACEINTO`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();
return1;
}
}
}catch(PDOException$ex){
$pdo->rollback();
}
return-1;
}
UPDATE
functionupdate()
{
try{
$pdo->beginTransaction();
$is_publish=1;
$req=$pdo->prepare("UPDATE`content`SETis_pub=:is_pub,mdate=:mdateWHEREid=: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程序设计有所帮助。