PHP基于PDO扩展操作mysql数据库示例
更新时间:2019年2月26日 16:27 点击:311
本文实例讲述了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使用PDO操作数据库的乱码问题解决方法,实例分析了编码设置及属性设置解决乱码问题的实现技巧,需要的朋友可以参考下...2016-04-15
- 这篇文章主要介绍了php实现基于PDO的预处理,结合实例形式分析了php实现pdo预处理的相关操作技巧与注意事项,需要的朋友可以参考下...2017-04-03
- 本篇文章主要介绍了php pdo操作数据库示例,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧 ...2017-03-12
- 我们在使用数据库时,很少会向数据库中存储很大的内容字段。但是,MySQL 其实也为我们准备了这种类型的存储,只是我们平常用得不多而已。今天我们就来学习了解一下使用 PDO 如何操作 MySQL 中的大数据对象。...2021-06-17
- 这篇文章主要介绍了PHP5.2中PDO的简单使用方法,较为详细的分析了PHP5.2中PDO的配置与数据库的连接,查询等基本操作技巧,需要的朋友可以参考下...2016-03-27
- 这篇文章的代码是用此前一个名为MyPDO的类改写的,引入了单例模式来保证在全局调用中不会重复实例化这个类,降低系统资源的浪费。有需要的朋友们可以参考借鉴,下面来一起看看吧。...2016-10-02
php使用PDO下exec()函数查询执行后受影响行数的方法
这篇文章主要介绍了php使用PDO下exec()函数查询执行后受影响行数的方法,结合实例形式分析了php在使用pdo进行增删改操作时exec()函数查询操作执行后受影响行数的相关实现技巧与注意事项,需要的朋友可以参考下...2017-04-03