首页 数据库 mysql教程 PDO中执行SQL语句

PDO中执行SQL语句

Feb 25, 2017 am 10:33 AM
pdo sql语句

exec()方法

exec()方法返回执行后受影响行数,语法如下:

int PDO::exec(string statement)
登录后复制

参数statement是要执行的SQL语句。该方法返回执行查询时受影响的行数,通常情况下用于INSERT,DELETE和UPDATE语句中。

例如:

$dbms='mysql';//数据库类型
$dbName='admin';//使用的数据库
$user='root';//数据库连接用户名
$pwd='password';//数据库连接密码
$host='localhost';//数据库主机名
$dsn="$dbms:host=$host;port=3306;dbname=$dbName";
try{
$pdo=new PDO($dsn,$user,$pwd);//初始化一个PDO对象,就是创建了数据库连接对象$pdo
$query="insert into user(username,password) values('admin','123456')";//需要执行的sql语句
$res=$pdo->exec($query);//执行添加语句并返回受影响行数
echo "数据添加成功,受影响行数为: ".$res;
}catch(Exception $e){
die("Error!:".$e->getMessage().&#39;<br>&#39;);
}
登录后复制

运行结果为:

数据添加成功,受影响行数为:
 1
登录后复制

query()方法

query()方法用于返回执行查询后的结果集,语法如下

PDOStatement
 PDO::query(string statement)
登录后复制

参数statement 是要执行的SQL语句。它返回的是一个PDOStatement对象

例如:

$dbms=&#39;mysql&#39;;
$dbName=&#39;admin&#39;;
$user=&#39;root&#39;;
$pwd=&#39;905407339&#39;;
$host=&#39;localhost&#39;;
$dsn="$dbms:host=$host;port=3306;dbname=$dbName";
try{
$pdo=new PDO($dsn,$user,$pwd);
$query="select * from user";
$res=$pdo->query($query);
print_r($res);
}catch(Exception $e){
die("Error!:".$e->getMessage().&#39;<br>&#39;);
}
登录后复制

运行结果为:

PDOStatement
 Object ( [queryString] => select * from user )
登录后复制

如果要看查询的具体结果,可以通过foreach语句完成循环输出

例如:

foreach($res as $val){
echo $val[&#39;username&#39;]."----".$val[&#39;password&#39;].&#39;<br>&#39;;
}
登录后复制

运行结果为:

107lab----e10adc3949ba59abbe56e057f20f883e
admin----123456
登录后复制

说明:如果要查看foreach的详细用法请查看:http://www.php.cn/

query()与exec()

query可以实现所有exec的功能
登录后复制

例如:

$dbms=&#39;mysql&#39;;//数据库类型
$dbName=&#39;admin&#39;;//使用的数据库
$user=&#39;root&#39;;//数据库连接用户名
$pwd=&#39;905407339&#39;;//数据库连接密码
$host=&#39;localhost&#39;;//数据库主机名
$dsn="$dbms:host=$host;port=3306;dbname=$dbName";
try{
$pdo=new PDO($dsn,$user,$pwd);//初始化一个PDO对象,就是创建了数据库连接对象$pdo
$query="insert into user(username,password) values(&#39;admin&#39;,&#39;123456&#39;)";//需要执行的sql语句
$res=$pdo->query($query);//执行添加语句并返回受影响行数
echo "数据添加成功,受影响行数为: ".$res->rowCount();
}catch(Exception $e){
die("Error!:".$e->getMessage().&#39;<br>&#39;);
}
登录后复制

运行结果为:

数据添加成功,受影响行数为: 1
登录后复制

注:

1、query和exec都可以执行所有的sql语句,只是返回值不同而已。

2、query可以实现所有exec的功能。

3、当把select语句应用到 exec 时,总是返回 0

预处理语句----prepare()语句和execute()语句

预处理语句包括prepare()和execute()两种方法。首先,通过prepare()方法做查询准备工作,然后通过execute()方法执行查询,并且还可以通过bindParam()方法来绑定参数给execute()方法,语法如下:

PDOStatement
 PDO::prepare(string statement[,array driver_options])
bool
 PDOStatement::execute([array input_parameters])
登录后复制

例如:

在PDO中通过预处理语句prepare()和execute()执行SQL查询语句,并且应用while()语句和fetch()方法完成数据的循环输出

$dbms=&#39;mysql&#39;;//数据库类型
$dbName=&#39;admin&#39;;//使用的数据库
$user=&#39;root&#39;;//数据库连接用户名
$pwd=&#39;905407339&#39;;//数据库连接密码
$host=&#39;localhost&#39;;//数据库主机名
$dsn="$dbms:host=$host;port=3306;dbname=$dbName";
try{
    $pdo=new PDO($dsn,$user,$pwd);//初始化一个PDO对象,就是创建了数据库连接对象$pdo
    $query="select * from user";//需要执行的sql语句
    $res=$pdo->prepare($query);//准备查询语句
    $res->execute();
    while($result=$res->fetch(PDO::FETCH_ASSOC)){
        echo $result[&#39;id&#39;]." ".$result[&#39;username&#39;]." ".$result[&#39;password&#39;].&#39;<br>&#39;;
    }
}catch(Exception $e){
    die("Error!:".$e->getMessage().&#39;<br>&#39;);
}
登录后复制

运行结果为:

1
 107lab e10adc3949ba59abbe56e057f20f883e
4 admin 123456
5 admin 123456
登录后复制

关于PDO中获取结果集的方法正在创作阶段,敬请期待。


 以上就是PDO中执行SQL语句的内容,更多相关内容请关注PHP中文网(www.php.cn)!



本站声明
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

热AI工具

Undresser.AI Undress

Undresser.AI Undress

人工智能驱动的应用程序,用于创建逼真的裸体照片

AI Clothes Remover

AI Clothes Remover

用于从照片中去除衣服的在线人工智能工具。

Undress AI Tool

Undress AI Tool

免费脱衣服图片

Clothoff.io

Clothoff.io

AI脱衣机

AI Hentai Generator

AI Hentai Generator

免费生成ai无尽的。

热门文章

R.E.P.O.能量晶体解释及其做什么(黄色晶体)
3 周前 By 尊渡假赌尊渡假赌尊渡假赌
R.E.P.O.最佳图形设置
3 周前 By 尊渡假赌尊渡假赌尊渡假赌
R.E.P.O.如果您听不到任何人,如何修复音频
3 周前 By 尊渡假赌尊渡假赌尊渡假赌
WWE 2K25:如何解锁Myrise中的所有内容
3 周前 By 尊渡假赌尊渡假赌尊渡假赌

热工具

记事本++7.3.1

记事本++7.3.1

好用且免费的代码编辑器

SublimeText3汉化版

SublimeText3汉化版

中文版,非常好用

禅工作室 13.0.1

禅工作室 13.0.1

功能强大的PHP集成开发环境

Dreamweaver CS6

Dreamweaver CS6

视觉化网页开发工具

SublimeText3 Mac版

SublimeText3 Mac版

神级代码编辑软件(SublimeText3)

可以在 Windows 7 上安装 mysql 吗 可以在 Windows 7 上安装 mysql 吗 Apr 08, 2025 pm 03:21 PM

是的,可以在 Windows 7 上安装 MySQL,虽然微软已停止支持 Windows 7,但 MySQL 仍兼容它。不过,安装过程中需要注意以下几点:下载适用于 Windows 的 MySQL 安装程序。选择合适的 MySQL 版本(社区版或企业版)。安装过程中选择适当的安装目录和字符集。设置 root 用户密码,并妥善保管。连接数据库进行测试。注意 Windows 7 上的兼容性问题和安全性问题,建议升级到受支持的操作系统。

mysql 是否要付费 mysql 是否要付费 Apr 08, 2025 pm 05:36 PM

MySQL 有免费的社区版和收费的企业版。社区版可免费使用和修改,但支持有限,适合稳定性要求不高、技术能力强的应用。企业版提供全面商业支持,适合需要稳定可靠、高性能数据库且愿意为支持买单的应用。选择版本时考虑的因素包括应用关键性、预算和技术技能。没有完美的选项,只有最合适的方案,需根据具体情况谨慎选择。

mysql安装后怎么使用 mysql安装后怎么使用 Apr 08, 2025 am 11:48 AM

文章介绍了MySQL数据库的上手操作。首先,需安装MySQL客户端,如MySQLWorkbench或命令行客户端。1.使用mysql-uroot-p命令连接服务器,并使用root账户密码登录;2.使用CREATEDATABASE创建数据库,USE选择数据库;3.使用CREATETABLE创建表,定义字段及数据类型;4.使用INSERTINTO插入数据,SELECT查询数据,UPDATE更新数据,DELETE删除数据。熟练掌握这些步骤,并学习处理常见问题和优化数据库性能,才能高效使用MySQL。

mysql优化锁定表吗 mysql优化锁定表吗 Apr 08, 2025 pm 01:51 PM

MySQL使用共享锁和排他锁管理并发,提供表锁、行锁和页锁三种锁类型。行锁可提高并发性,使用FOR UPDATE语句可给行加排他锁。悲观锁假设冲突,乐观锁通过版本号判断数据修改。常见锁表问题表现为查询缓慢,使用SHOW PROCESSLIST命令查看锁持有的查询。优化措施包括选择合适索引、减少事务范围、批量操作和优化SQL语句。

mysql 能处理多个连接吗 mysql 能处理多个连接吗 Apr 08, 2025 pm 03:51 PM

MySQL能处理多个并发连接,利用多线程/多进程为每个客户端请求分配独立执行环境,确保不受干扰。但并发连接数量受系统资源、MySQL配置、查询性能、存储引擎和网络环境影响。优化需要考虑代码层面(编写高效SQL)、配置层面(调整max_connections)、硬件层面(提升服务器配置)等多方面因素。

mysql安装后如何进行数据库备份与恢复 mysql安装后如何进行数据库备份与恢复 Apr 08, 2025 am 11:45 AM

MySQL数据库备份恢复方案没有绝对最佳,需根据数据量、业务重要性、RTO和RPO选择。1.逻辑备份(mysqldump)简单易用,适合小型数据库,但速度慢,文件巨大;2.物理备份(xtrabackup)速度快,适合大型数据库,但使用较复杂。备份策略需考虑备份频率(RPO决定)、备份方法(数据量、时间要求决定)和存储位置(异地存储更安全),并定期测试备份和恢复流程,避免备份文件损坏、权限问题、存储空间不足、网络中断和未测试等问题,确保数据安全。

mysql 需要服务器吗 mysql 需要服务器吗 Apr 08, 2025 pm 02:12 PM

对于生产环境,通常需要一台服务器来运行 MySQL,原因包括性能、可靠性、安全性和可扩展性。服务器通常拥有更强大的硬件、冗余配置和更严格的安全措施。对于小型、低负载应用,可在本地机器运行 MySQL,但需谨慎考虑资源消耗、安全风险和维护成本。如需更高的可靠性和安全性,应将 MySQL 部署到云服务器或其他服务器上。选择合适的服务器配置需要根据应用负载和数据量进行评估。

navicat如何写sql语句 navicat如何写sql语句 Apr 08, 2025 pm 11:24 PM

Navicat 编写 SQL 语句的步骤:连接数据库新建查询窗口编写 SQL 语句执行查询保存查询示例 SQL 语句:SELECT * FROM table_name;INSERT INTO table_name (column1, column2) VALUES (value1, value2);UPDATE table_name SET column1 = value1 WHERE column2 = value2;DELETE FROM table_name WHERE column1 =

See all articles