本文主要是介绍PDO 数据库相关操作,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
<?phpPDO 数据库相关操作
header("content-type:text/html;charset=utf-8");
// 格式 数据库类型(冒号)host=主机名(分号)dbname=数据库名
$dsn = "mysql:host=localhost;dbname=test";# try{} catch(){} 试运行
try{// 第四个参数就是 setAttribute(); 设置属性,可以写数字类型// $pdo = new PDO($dsn,'root','123456',array('3'=>'2')); $pdo = new PDO($dsn,'root','123456');
}catch(PDOException $error){ 异常$error->getMessage(); 获取异常消息内容$error->getPrevious(); 返回异常链中的前一个异常$error->getCode(); 获取异常代码$error->getFile(); 获取发生异常的程序文件名称$error->getLine(); 获取发生异常的代码在文件中的行号$error->getTrace(); 获取异常追踪信息$error->getTraceAsString(); 获取字符串类型的异常追踪信息echo $error; 将异常对象转换为字符串,可以直接打印Exception::__clone(); 异常克隆 尝试克隆异常,这将导致一个致命错误。
}// setAttribute 设置错误处理模式
$pdo->setAttribute(3,1);
/*
echo PDO::ATTR_ERRMODE; // 3 错误报告。
echo PDO::ERRMODE_SILENT; // 0 仅设置错误代码。
echo PDO::ERRMODE_WARNING; // 1 引发 E_WARNING 错误
echo PDO::ERRMODE_EXCEPTION; // 2 抛出 exceptions 异常
$pdo->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_SILENT);
$pdo->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_WARNING);
$pdo->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
*//* getAttribute() 检索一个语句属性 ,无实意
echo $pdo->getAttribute(PDO::ATTR_AUTOCOMMIT);
PDO::ATTR_AUTOCOMMIT
PDO::ATTR_CASE
PDO::ATTR_CLIENT_VERSION
PDO::ATTR_CONNECTION_STATUS
PDO::ATTR_DRIVER_NAME
PDO::ATTR_ERRMODE
PDO::ATTR_ORACLE_NULLS
PDO::ATTR_PERSISTENT
PDO::ATTR_PREFETCH
PDO::ATTR_SERVER_INFO
PDO::ATTR_SERVER_VERSION
PDO::ATTR_TIMEOUT
*/$pdo->exec("set names utf8"); 设置字符集 $pdo->quote($sql); 安全转义。安全的插入到数据库中。$result = $pdo->query($sql); 执行一个SQL语句,返回一个结果集作为一个PDOStatement对象
$row = $pdo->exec($sql); 执行一条 SQL 语句,并返回受影响的行数
$stmt = $pdo->prepare($sql); 预处理语句使用,要结合 $stmt->execute(); 返回一个PDOStatement对象//MySQL 表引擎 MyISAM InnoDB
//查看表引擎 show create table 表名;
//修改表引擎 alter table 表名 engine = InnoDB;
$pdo->beginTransaction(); 开启一个事务
$pdo->commit(); 提交一个事务
$pdo->rollBack(); 回滚一个事务
$pdo->inTransaction(); 检查是否在一个事务内,返回ture或者false--------?号占位符 预处理(问号) -------
$sql = "insert into 表 (字段,字段,字段) values (?,?,?) ";
$stmt = $pdo->prepare($sql); 准备sql语句。可以操作 PDOStatement 类 # 一 : 第一种绑定值的方式 ,变量绑定。
// 绑定参数,从第一个参数开始 1, 第二个参数只能是变量不能直接给值。$变量
$stmt->bindParam(1,$one);
$stmt->bindParam(2,$two);
$stmt->bindParam(3,$three);// 给参数赋值,只要在 execute() 发送数据之前就可以。
$one = '值一';
$two = '值二';
$three = '值三';
// 发送数据,成功返回真,失败返回假。
$bool = $stmt->execute(); #二: 第二种绑定值的方式 ,数组绑定
$data = array('值一','值二','值三');
$stmt->execute($data);---------------------- :占位符,预处理(冒号)----------------
// 注意:sql语句中占位符不能加引号 :value 冒号必须有,值的名字是自定义的。
# 一变量的方式绑定。
$sql = "insert into 表 (字段,字段,字段) values (:one,,:two,:three)";
$stmt->prepare($sql);
// 绑定参数的时候,冒号可有可无,但是得加上引号
$stmt->bindValue(':one',"值一");
$stmt->bindValue('two',"值二");
$stmt->bindValue('three',"值三");// 发送数据。成功返回真,失败返回假。
$bool = $stmt->execute();#二 传入一个关联数组,下标就是占位符名称 ,占位符不加引号
$sql = "update 表名 set 字段= :one ,字段= :two ,字段= :three where 条件";
$stmt->prepare($sql);
$data = array('one'=>'值一','two'=>'值二','three'=>'值三');
$bool = $stmt->execute($data);绑定数据的区别。一个只能是变量一个只能是值,还有一个绑定到列。
$stmt->bindParam('',变量);
$stmt->bindValue('',值);
$stmt->bindColumn(第几列,PHP变量) $id = $pdo->lastInsertId(); 返回最后插入的 id insert语句有效$stmt->setFetchMode(PDO::FETCH_ASSOC); 设置默认的获取模式,索引或者关联$stmt->fetchAll(); 获取所有数据
// fetchAll(PDO::FETCH_COLUMN,1); 获取一列数据,默认从0开始,但是列的的数据时从1开始,所以要指定列。
// PDO::FETCH_GROUP // 数据分组
// PDO::FETCH_ASSOC // 关联数组
// PDO::FETCH_NUM // 索引数组
// PDO::FETCH_BOUND // 返回 TRUE ,并分配结果集中的列值给 PDOStatement::bindColumn() 方法绑定的 PHP 变量$stmt->fetch(PDO::FETCH_ASSOC); 返回一条数据。参数fetchAll()$stmt->fetchColumn(1); 返回结果集中单独的一行。$stmt->debugDumpParams(); 打印一条 SQL 预处理命令 $stmt->errorCode() — 获取跟上一次语句句柄操作相关的 SQLSTATE
$stmt->errorInfo() — 获取跟上一次语句句柄操作相关的扩展错误信息$stmt->columnCount(); 返回结果集中的列数 $stmt->rowCount(); // 返回受上一个 SQL 语句影响的行数 DELETE、 INSERT, UPDATE 语句受影响的行数。 //===================== 示例语句,======================================
# 数据匹配
// $sql = "select * from user where id < ?";
$sql = "select * from user where name like ?";
$stmt = $pdo->prepare($sql);
$stmt->bindParam(1,$key);
$key = "%pipei%";
$bool = $stmt->execute(); # 插入数据$sql = "insert into user (name,money,txt) values (?,?,?)";
$stmt = $pdo->prepare($sql);
$data = array('我的名字','3000','我爱文化');
$bool = $stmt->execute($data);
$id = $pdo->lastInsertId();# 查询数据
$sql = "select * from user";
$stmt = $pdo->prepare($sql);
$stmt->execute();第一种获取结果的方式
$result = $stmt->fetchAll(PDO::FETCH_ASSOC);
第二种获取结果的方式
while($row = $stmt->fetch(PDO::FETCH_ASSOC)){ // fetch 只能获取一条,加上while就可以获取所有。echo "<pre>";print_r($row);echo "</pre>";
}
第三种获取结果的方式
foreach($stmt as $val){echo "<pre>";print_r($val);echo "</pre>";
}
获取一条数据$result = $stmt->fetch(PDO::FETCH_ASSOC);
获取一行数据$stmt->fetchColumn(1); 返回结果集中单独的一行。$stmt = $pdo->query("select * from user");
echo $stmt; # 直接输出$stmt 就是当前的sql语句
print_r($stmt->fetchAll()); // 打印所有数据。# 绑定参数到列
list($name,$age) = array('xiaoli','18');
$stmt->bindColumn(2,$name);
$stmt->bindColumn(3,$age);# 事物操作 表引擎必须是InnoDB
//启动事物 $pdo->beginTransaction(); begin; 自动提交就关闭了 直到手动提交或回滚 结束这次事物
$pdo->beginTransaction();
//中间可以做一系列操作 这一系列操作是一个整体 任何一个环节失败,则整体算失败
$num = 100;
$sql = "update user set money = money + {$num} where id= 1";
$rows = $pdo->exec($sql);
$sql = "update user set money = money - {$num} where id= 2";
$rows += $pdo->exec($sql);
if($rows == 2){$pdo->commit(); //结束一个事物
}else{$pdo->rollBack(); // 回滚一个事物
}# 数据库
drop table if exists user;create table user(
id int unsigned not null auto_increment,
name varchar(50) not null ,
money int not null default 1000,
txt text not null,
primary key(`id`)
)engine=MyISAM charset=utf8;# 修改表引擎为InnoDB
alter table user engine=InnoDB;
这篇关于PDO 数据库相关操作的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!