用PDO操作MySQL数据库

这篇文章介绍的内容是关于用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,'june',1,23,1),(8,'linda',2,22,1),(9,'lisa',2,22,1),(10,'liz',2,23,1);

然后新建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`= ? )");  $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-&<mark>（本文来）源gaodaimacom搞#^代%!码&网(</mark><pre>搞gaodaima代码

gt;rollBack();//事务回滚 //相关错误处理 throw $e; }

相关推荐：

PHP数据库基于PDO操作类（mysql）

PDO一次查询一行数据

以上就是用PDO操作MySQL数据库的详细内容，更多请关注搞代码gaodaima其它相关文章！

喜欢 (0)赏

[搞代码]

分享 (0)