PHP使用PDO扩展操作mysql数据库

2024-08-29 00:58

本文主要是介绍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扩展操作mysql数据库的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!


原文地址:
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.chinasem.cn/article/1116383

相关文章

MySQL多实例管理如何在一台主机上运行多个mysql

《MySQL多实例管理如何在一台主机上运行多个mysql》文章详解了在Linux主机上通过二进制方式安装MySQL多实例的步骤,涵盖端口配置、数据目录准备、初始化与启动流程,以及排错方法,适用于构建读... 目录一、什么是mysql多实例二、二进制方式安装MySQL1.获取二进制代码包2.安装基础依赖3.清

C++中detach的作用、使用场景及注意事项

《C++中detach的作用、使用场景及注意事项》关于C++中的detach,它主要涉及多线程编程中的线程管理,理解detach的作用、使用场景以及注意事项,对于写出高效、安全的多线程程序至关重要,下... 目录一、什么是join()?它的作用是什么?类比一下:二、join()的作用总结三、join()怎么

mybatis中resultMap的association及collectio的使用详解

《mybatis中resultMap的association及collectio的使用详解》MyBatis的resultMap定义数据库结果到Java对象的映射规则,包含id、type等属性,子元素需... 目录1.reusltmap的说明2.association的使用3.collection的使用4.总

详解MySQL中JSON数据类型用法及与传统JSON字符串对比

《详解MySQL中JSON数据类型用法及与传统JSON字符串对比》MySQL从5.7版本开始引入了JSON数据类型,专门用于存储JSON格式的数据,本文将为大家简单介绍一下MySQL中JSON数据类型... 目录前言基本用法jsON数据类型 vs 传统JSON字符串1. 存储方式2. 查询方式对比3. 索引

Spring Boot配置和使用两个数据源的实现步骤

《SpringBoot配置和使用两个数据源的实现步骤》本文详解SpringBoot配置双数据源方法,包含配置文件设置、Bean创建、事务管理器配置及@Qualifier注解使用,强调主数据源标记、代... 目录Spring Boot配置和使用两个数据源技术背景实现步骤1. 配置数据源信息2. 创建数据源Be

Java中使用 @Builder 注解的简单示例

《Java中使用@Builder注解的简单示例》@Builder简化构建但存在复杂性,需配合其他注解,导致可变性、抽象类型处理难题,链式编程非最佳实践,适合长期对象,避免与@Data混用,改用@G... 目录一、案例二、不足之处大多数同学使用 @Builder 无非就是为了链式编程,然而 @Builder

在MySQL中实现冷热数据分离的方法及使用场景底层原理解析

《在MySQL中实现冷热数据分离的方法及使用场景底层原理解析》MySQL冷热数据分离通过分表/分区策略、数据归档和索引优化,将频繁访问的热数据与冷数据分开存储,提升查询效率并降低存储成本,适用于高并发... 目录实现冷热数据分离1. 分表策略2. 使用分区表3. 数据归档与迁移在mysql中实现冷热数据分

mybatis-plus QueryWrapper中or,and的使用及说明

《mybatis-plusQueryWrapper中or,and的使用及说明》使用MyBatisPlusQueryWrapper时,因同时添加角色权限固定条件和多字段模糊查询导致数据异常展示,排查发... 目录QueryWrapper中or,and使用列表中还要同时模糊查询多个字段经过排查这就导致只要whe

SpringBoot集成MyBatis实现SQL拦截器的实战指南

《SpringBoot集成MyBatis实现SQL拦截器的实战指南》这篇文章主要为大家详细介绍了SpringBoot集成MyBatis实现SQL拦截器的相关知识,文中的示例代码讲解详细,有需要的小伙伴... 目录一、为什么需要SQL拦截器?二、MyBATis拦截器基础2.1 核心接口:Interceptor

Python使用openpyxl读取Excel的操作详解

《Python使用openpyxl读取Excel的操作详解》本文介绍了使用Python的openpyxl库进行Excel文件的创建、读写、数据操作、工作簿与工作表管理,包括创建工作簿、加载工作簿、操作... 目录1 概述1.1 图示1.2 安装第三方库2 工作簿 workbook2.1 创建:Workboo