PHP中PDO的基本使用

<?php
$servername = "localhost";
$username = "username";
$password = "password";
 
try {
    $conn = new PDO("mysql:host=$servername;", $username, $password);
    echo "连接成功"; 
}
catch(PDOException $e)
{
    echo $e->getMessage();
}
?>

<?php
/*数据库配置*/
$dbconfig = array(
  'host' => 'localhost', //数据库服务器
  'port' => 3306, //数据库端口
  'user' => 'username', //数据库用户名
  'pwd' => 'password', //数据库密码
  'dbname' => 'dbname' //数据库名
);

// 检测链接
try {
  // 创建链接
  $conn = new PDO("mysql:host=" . $dbconfig['host'] . ";dbname=" . $dbconfig['dbname'] . ";port=" . $dbconfig['port'], $dbconfig['user'], $dbconfig['pwd']);
  // 设置 PDO 错误模式，用于抛出异常
  $conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
  echo "连接成功"; 
} catch (PDOException $e) {
  echo $e->getMessage();
}

// 关闭数据库链接
// $conn = null;

<?php
// 链接数据库
require_once('conn.php');
try {
  // 数据库语句
  $sql = "select * from nav";
  // 有返回结果集，使用query函数，该函数返回结果为预处理对象。
  $stmt = $conn->query($sql);
  // 默认输出
  var_dump($stmt);
  } catch (PDOException $e) {
  echo $e->getMessage();
}

<?php
// 链接数据库
require_once('conn.php');
try {
  // 数据库语句
  $sql = "select * from nav";
  // prepare+execute用于预处理，使sql语句灵活了很多，也可用防止SQL注入等问题。
  $stmt = $conn->prepare($sql);
  $stmt->execute();
  // 默认输出
  var_dump($stmt);
  } catch (PDOException $e) {
  echo $e->getMessage();
}

<?php
// 链接数据库
require_once('conn.php');
try {
  // 数据库语句
  $sql = "select * from nav";
  // 有返回结果集，使用query函数，该函数返回结果为预处理对象。
  $stmt = $conn->query($sql);
  // 使用fetch()方法，获取关联数组
  $res = $stmt->fetch(PDO::FETCH_ASSOC);
  // 输出一个关联数组
  var_dump($res);
  echo '</br></br>';
  // 只输出单个值
  echo 'id为：' . $res['id'];
  echo '</br></br>';
  // 循环输出查询到的所有结果并换行
  foreach ($res as $v) {
    echo $v . '</br>';
  }
  } catch (PDOException $e) {
  echo $e->getMessage();
}

<?php
// 链接数据库
require_once('conn.php');
try {
  // 数据库语句
  $sql = "select * from nav";
  // 有返回结果集，使用query函数，该函数返回结果为预处理对象。
  $stmt = $conn->query($sql);
  // 使用fetchall()方法，获取关联数组
  $res = $stmt->fetchAll(PDO::FETCH_ASSOC);
  // 输出一个二维数组
  var_dump($res);
  echo '</br></br>';
  // 循环输出查询到的所有结果
  foreach ($res as $v) {
    echo $v['id'] . '</br>';
    echo $v['navname'] . '</br>';
    echo $v['navlink'] . '</br>';
    echo '</br>';
  }
} catch (PDOException $e) {
  echo $e->getMessage();
}

<?php
// 链接数据库
require_once('conn.php');
try {
  // 数据库语句
  $sql = "select * from nav";
  // 有返回结果集，使用query函数，该函数返回结果为预处理对象。
  $stmt = $conn->query($sql);
  // 设置结果集为关联数组
  $stmt->setFetchMode(PDO::FETCH_ASSOC);
  //fetchAll()方法
  $res = $stmt->fetchAll();
  // 输出一个二维数组
  var_dump($res);
  echo '</br></br>';
  // 循环输出查询到的所有结果
  foreach ($res as $v) {
    echo $v['id'] . '</br>';
    echo $v['navname'] . '</br>';
    echo $v['navlink'] . '</br>';
    echo '</br>';
  }
} catch (PDOException $e) {
  echo $e->getMessage();
}

<?php
// 链接数据库
require_once('conn.php');
try {
  // 数据库语句
  $sql = "select * from nav";
  // 有返回结果集，使用query函数，该函数返回结果为预处理对象。
  $stmt = $conn->query($sql);
  // 默认获取默认获取当前行的第1列
  echo $stmt->fetchColumn();
  echo '  </br>';
  // 获取当前行第一列
  echo $stmt->fetchColumn(1);
} catch (PDOException $e) {
  echo $e->getMessage();
}

<?php
// 链接数据库
require_once('conn.php');
try {
  // 数据库语句
  $sql = "select * from nav";
  // 有返回结果集，使用query函数，该函数返回结果为预处理对象。
  $stmt = $conn->query($sql);
  // 获取总行数、总列数
  echo '总行数:' . $stmt->rowCount() . '</br>';
  echo '总列数:' . $stmt->columnCount() . '</br>';
} catch (PDOException $e) {
  echo $e->getMessage();
}

<?php
// 链接数据库
require_once('conn.php');
// 获取要修改的id
$id = $_GET['id'];
// GET接收要修改的数据
$navname = $_GET['name'];
$navlink = $_GET['link'];
try {
  // 插入数据
  $sql = "update nav set navname='$navname', navlink='$navlink' where id=$id ";
  $conn->exec($sql);
  echo '修改成功';
} catch (PDOException $e) {
  echo $e->getMessage();
}

<?php
// 链接数据库
require_once('conn.php');
// GET获取插入的数据
$navname = $_GET['name'];
$navlink = $_GET['link'];
try {
  // 插入数据
  $sql = "insert into nav(navname, navlink) values ('$navname','$navlink')";
  $conn->exec($sql);
  echo '插入成功';
} catch (PDOException $e) {
  echo $e->getMessage();
}

<?php
// 链接数据库
require_once('conn.php');
// GET获取要删除的id
$id = $_GET['id'];
try {
  // 插入数据
  $sql = "delete from nav where id=$id";
  $conn->exec($sql);
  echo '删除成功';
} catch (PDOException $e) {
  echo $e->getMessage();
}