我在网上找了一段代码如下，我可以直接把conn.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`= ? )");
- $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;
- }
-
-
-
-
|
运维要高效，装宝塔
