PHP-⽤PDO操作MySQL数据库
先建⽴数据库。复制代码到TXT⽂件，然后另存为'建⽴数据库.txt' 最后修改为'建⽴数据库.sql'，最后⽤navicat运⾏数据库⽂件。就建好数据库了。
代码如下：
CREATE TABLE `user` (
`id` int(10) unsigned NOT NULL AUTO_INCREMENT,
`name` varchar(25) NOT NULL DEFAULT '',
`gender` tinyint(1) NOT NULL DEFAULT '1',
`age` int(11) NOT NULL DEFAULT '0',
`flag` tinyint(1) NOT NULL DEFAULT '1',
PRIMARY KEY (`id`)
) ENGINE=MyISAM AUTO_INCREMENT=11 DEFAULT CHARSET=utf8;
/*Data for the table `user` */
insert into `user`(`id`,`name`,`gender`,`age`,`flag`) values (1,'allen',1,20,1),(2,'alice',2,18,1),(3,'bob',1,21,1),(4,'dave',1,25,1),(5,'eve',2,20,1),(6,'joy',1,21,1),(7,'jun 然后新建PHP⽂件。pdo.php
<?php
$db = array(
'host' => '127.0.0.1', //设置服务器地址
'port' => '3306', //设端⼝
'dbname' => 'test', //设置数据库名
'username' => 'root', //设置账号
'password' => 'yangji0321', //设置密码
'charset' => 'utf8', //设置编码格式
'dsn' => 'mysql:host=127.0.0.1;dbname=test;port=3306;charset=utf8', //这⾥不知道为什么，也需要这样再写⼀遍。
);
//连接
$options = array(
PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION, //默认是PDO::ERRMODE_SILENT, 0, (忽略错误模式)
PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC, // 默认是PDO::FETCH_BOTH, 4
);
try{
$pdo = new PDO($db['dsn'], $db['username'], $db['password'], $options);
}catch(PDOException $e){
die('数据库连接失败:' . $e->getMessage());
}
//或者更通⽤的设置属性⽅式:
//$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); //设置异常处理⽅式
//$pdo->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC); //设置默认关联索引遍历
echo '<pre/>';
//1 查询
//1)使⽤query
$stmt = $pdo->query('select * from user limit 2'); //返回⼀个PDOStatement对象
//$row = $stmt->fetch(); //从结果集中获取下⼀⾏，⽤于while循环
$rows = $stmt->fetchAll(); //获取所有
$row_count = $stmt->rowCount(); //记录数，2
print_r($rows);
echo '<br>';
//2)使⽤prepare 推荐!
$stmt = $pdo->prepare("select * from user where name = ? and age = ? ");
$stmt->bindValue(1,'allen');
$stmt->bindValue(2,20);
$stmt->execute(); //执⾏⼀条预处理语句 .成功时返回 TRUE, 失败时返回 FALSE
$rows = $stmt->fetchAll();
$row_count = $stmt->rowCount(); //记录数，2
print_r($rows);
print_r($row_count);
echo '<br>';
//2 新增、更新、删除
//A.1)普通操作
//$count = $pdo->exec("insert into user(name,gender,age)values('test',2,23)"); //返回受影响的⾏数//echo $pdo->lastInsertId();
//$count = $pdo->exec("update user set name='test2' where id = 15"); //返回受影响的⾏数
//$count = $pdo->exec("delete from user where id = 15"); //返回受影响的⾏数
//A.2)使⽤prepare 推荐!
$stmt = $pdo->prepare("insert into user(name,gender,age)values(?,?,?)");
$stmt->bindValue(1, 'test');
$stmt->bindValue(2, 2);
$stmt->bindValue(3, 23);
$stmt->execute();
$count = $stmt->rowCount();//受影响⾏数
echo 'prepare⽅法影响⾏数：'.$count;
echo '<br>';
//A.3)使⽤prepare 批量新增
$stmt = $pdo->prepare("insert into user(name,gender,age)values(?,?,?)");
$stmt->bindParam(1, $name);
$stmt->bindParam(2, $gender);
$stmt->bindParam(3, $age);
$data = array(
array('t1', 1, 22),
array('t2', 2, 23),
);
foreach ($data as $vo){
list($name, $gender, $age) = $vo;
$stmt->execute();
}
//B)更新操作
echo '<br>';
$stmt = $pdo->prepare("UPDATE `user` SET `age`=? WHERE (`name`= ? )");
$stmt->bindValue(1, '20');
$stmt->bindValue(2, 'allen');
$num = $stmt->execute();
$count = $stmt->rowCount();//受影响⾏数
echo '更新操作影响⾏数：'.$count;
//删除操作
$stmt = $pdo->prepare("DELETE FROM `user` WHERE (`name`= ? )");
php远程连接mysql数据库$stmt->bindValue(1, 't1');
$num = $stmt->execute();
$count = $stmt->rowCount();//受影响⾏数
echo '删除操作影响⾏数：'.$count;
# 【⽰例5：统计数据】：统计company表有多少条数据
echo '<br>';
$num = $pdo->query("select count(*) from user");
$count = $num->fetchColumn();
echo '共有数据：【'.$count.'】条';
>
pdo::query()⽅法
当执⾏返回结果集的select查询时，或者所影响的⾏数⽆关紧要时，应当使⽤pdo对象中的query()⽅法.
如果该⽅法成功执⾏指定的查询，则返回⼀个PDOStatement对象.
如果使⽤了query()⽅法，并想了解获取数据⾏总数，可以使⽤PDOStatement对象中的rowCount()⽅法获取.
pdo::exec()⽅法
当执⾏insert,update,delete没有结果集的查询时，使⽤pdo对象中的exec()⽅法去执⾏.
该⽅法成功执⾏时，将返回受影响的⾏数.注意，该⽅法不能⽤于select查询.
PDO事务：
$pdo->beginTransaction();//开启事务处理
try{
//PDO预处理以及执⾏语句...
$pdo->commit();//提交事务
}catch(PDOException $e){
$pdo->rollBack();//事务回滚
//相关错误处理 throw $e;
}
版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。
发表评论