这篇文章主要介绍了PHP基于PDO扩展操作mysql数据库,结合实例形式分析了php使用pdo扩展针对mysql数据库的查询、插入、修改等操作实现技巧,需要的朋友可以参考下。

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

SELECT

1. //查单条 
2. function get_sub_product() 
3. { 
4.   $res_zz = $pdo->query("SELECT id FROM content WHERE is_publish = 0 LIMIT 1;"); 
5.   $rep = $res_zz->fetch(); 
6. } 
7. //查多条 
8. function get_sub_product() 
9. { 
10.   $dsn = 'mysql:host=localhost;dbname=bwdb'; 
11.   $pdo = new PDO($dsn, 'root', 'root'); 
12.   $pdo->query('set names utf8'); 
13.   $res_zz = $pdo->query("SELECT product_id FROM sub_product WHERE 1= 1;"); 
14.   $rep = $res_zz->fetchAll(); 
15.   $product_id_arr = array(); 
16.   foreach ($rep as $v) { 
17.     $product_id_arr[] = $v['product_id']; 
18.   } 
19.   return $product_id_arr; 
20. } 

INSERT

1. function add() 
2. { 
3.   try { 
4.     $pdo->beginTransaction(); 
5.     $reb = $pdo->prepare("INSERT INTO `content` (`id`,`content`) VALUES(:version_id,:content);"); 
6.     $reb->bindParam(':version_id', $version_id, PDO::PARAM_INT); 
7.     $reb->bindParam(':content', $content, PDO::PARAM_STR); 
8.     $type_id = 1; 
9.     $reb->bindParam(':type_id', $type_id, PDO::PARAM_INT); 
10.     $reb->bindParam(':cdate', $time, PDO::PARAM_STR); 
11.     $reb->bindParam(':mdate', $time, PDO::PARAM_STR); 
12.     if ($reb->execute() > 0) { 
13.       $pdo->commit(); 
14.       die("成功!"); 
15.     } 
16.     $pdo->rollback(); 
17.     die("失败!"); 
18.   } catch (PDOException $ex) { 
19.     echo($ex->getMessage()); 
20.   } 
21. } 
22. function add($res_arr) 
23. { 
24.   $dsn = 'mysql:host=localhost;dbname=db'; 
25.   $pdo = new PDO($dsn, 'root', 'root'); 
26.   $pdo->query('set names utf8'); 
27.   $value = ''; 
28.   date_default_timezone_set("Asia/Shanghai"); //时区 
29.   $time = date('Y-m-d h:i:s'); 
30.   foreach ($res_arr as $k => $v) { 
31.     $hash = md5($v['ProductID'] . "-" . $v['CategoryID'] . "-" . $v['CategoryName']); 
32.     $value .= "('" . $v['ProductID'] . "','" . $v['CategoryID'] . "','" . $v['CategoryName'] . "','" . $v['ProductName'] . "','" . $v['Abbreviation'] . "','" . $v['SubscribeStatus'] . "','" . $v['ProductStatus'] . "','" . 
33.       $v['BrandID'] . "','" . $v['BrandName'] . "','" . $v['TradeType'] . "','" . $v['ProductModel'] . "','" . $v['UPCCode'] . "','" . $v['Weight'] . "','" . $v['Summary'] . "','" . 
34.       $v['LongDescription'] . "','" . $v['BuyNotice'] . "','" . $v['PackingList'] . "','" . $v['DefaultImage'] . "','" . $v['Keywords'] . "','" . $v['VendorID'] . "','" . $v['StoreID'] . "','" . 
35.       $v['CurrentPrice'] . "','" . $v['AvailableQty'] . "','" . $hash . "','" . $time . "','" . $time . "'),"; 
36.   } 
37.   $vv = substr($value, 0, strlen($value) - 1); 
38.   try { 
39.     $pdo->beginTransaction(); 
40.     if (!emptyempty($vv)) { 
41.       $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`, " 
42.         . "`product_model`, `upc_code`, `weight`, `summary`, `long_description`, `buy_notice`, `packing_list`, `default_image`, `keywords`, `vendor_id`, `store_id`, `current_price`, " 
43.         . "`available_qty`, `hash`, `cdate`, `mdate`) VALUES $vv;"); 
44.       if ($reb->execute() > 0) { 
45.         $pdo->commit(); 
46.         return 1; 
47.       } 
48.     } 
49.   } catch (PDOException $ex) { 
50.     $pdo->rollback(); 
51.   } 
52.   return -1; 
53. } 

UPDATE

1. function update() 
2. { 
3.   try { 
4.     $pdo->beginTransaction(); 
5.     $is_publish = 1; 
6.     $req = $pdo->prepare("UPDATE `content` SET is_pub=:is_pub,mdate=:mdate WHERE id = :id;"); 
7.     $req->bindParam(':is_publish', $is_publish, PDO::PARAM_INT); 
8.     $req->bindParam(':id', $version_id, PDO::PARAM_INT); 
9.     $req->bindParam(':mdate', $time, PDO::PARAM_STR); 
10.     if ($req->execute()) { 
11.       $pdo->commit(); 
12.       die("成功!"); 
13.     } 
14.     $pdo->rollback(); 
15.     die("失败!"); 
16.   } catch (PDOException $ex) { 
17.     echo($ex->getMessage()); 
18.   } 
19. }

Tags: PDO扩展 PHP扩展

分享到：