php第4课：PDO操作数据库增删查改_2019.3.21

实例

<?php 
	// $dsn = 'mysql:host=127.0.0.1; dbname=user; charset=utf8; port=3306';  //获取dsn
	// $dbname = 'root';   //获取数据库名
	// $dbpw = 'root';     //获取数据库密码
	// $p = new PDO($dsn,$dbname,$dbpw);  //获取数据库全部信息

	// try {
	// 	$p;  //判断是否存在错误
	// } catch (PDOException $e) {     //如有错误将其保存至&e
	// 	print_r($e->getmessage());  //打印错误消息
	// 	exit;                      //暂停往下执行
	// }

	//第一种sql语句
	// $sql = 'SELECT * FROM `user` WHERE `id`=2';  //将sql语句保存至变量
	
	// 第一种数据获取方式：循环数组(原生类)(包含索引数组和关联数组)
	// $a = $p->query($sql);  //将执行返回的结果集保存至变量
	// $arr = [];            //创建数组用于保存输出的结果集
	// foreach($a as $v){    //循环结果集输出
	// 	$arr[] = $v;        //将循环输出的结果集保存至数组
	// }
	// print_r($arr);      //循环打印数组内部的结果集

	// 第二种数据获取方式：PDOStatement类(没有索引数组和关联数组之分)
	// $a = $p->prepare($sql);  //执行sql并返回待处理结果保存至变量
	// $a->execute();          //执行待处理结果$a
	// $a->setFetchMode(PDO::FETCH_ASSOC);  //为语句设置默认获取模式，PDO::FETCH_ASSOC把结果换做成数组
	// $ret = $a->fetchALL();  //返回结果集
	// print_r($ret);         //打印结果集
	// $ret = null;  //断开连接

	// //第二种sql语句：占位符方式获取数据
	// $sql = 'SELECT `id`,`name` FROM `user` WHERE `id`=:id';  //
	// $id = 3;
	// $a = $p->prepare($sql);   //执行sql并返回待处理结果保存至变量
	// $a->bindvalue('id',$id,PDO::PARAM_INT);  //绑定占位符，第二个参数可以是值/变量，变量必须先赋值
	// $a->bindParam('id',$id,PDO::PARAM_INT);  //绑定占位符，第二个参数必须是变量，变量可以后赋值
	// $a->execute();   //执行sql语句并返回待处理结果$a
	// $a->setFetchMode(PDO::FETCH_ASSOC);  //为语句设置默认获取模式，PDO::FETCH_ASSOC把结果换做成数组
	// $ret = $a->fetchALL();   //返回结果集
	// print_r($ret);

	// //自定义方法
	// function select($table,$where='',$order='',$limit='',$field='*'){  //不传参则调用默认初值，传参则会将值更新
	// 	//1.连接数据库
	// 	$dsn = 'mysql:host=127.0.0.1; dbname=user; charset=utf8; port=3306';
	// 	$dbname = 'root';
	// 	$dbpw = 'root';
	// 	$p = new PDO($dsn,$dbname,$dbpw);

	// 	try {
	// 		$p;  //判断是否存在错误
	// 	} catch (PDOException $e) {     //如有错误将其保存至&e
	// 		print_r($e->getmessage());  //打印错误消息
	// 		exit;                      //暂停往下执行
	// 	}
	// 	//2.存储sql语句
	// 	$sql = 'SELECT ';
	// 	if (!empty($field)) {    //判断表名不为空则执行，!取反
	// 		$sql .= rtrim($field);     //组装数据,rtrim去除末尾空格
	// 	}
	// 	$sql .= ' FROM '. $table;
	// 	if (!empty($where)) {   //判断条件不为空则执行，!取反
	// 		$sql .= ' WHERE '. $where;
	// 	}
	// 	if (!empty($order)) {   //判断条件不为空则执行，!取反
	// 		$sql .= ' ORDER BY '. $order;
	// 	}
	// 	if (!empty($limit)) {   //判断条件不为空则执行，!取反
	// 		$sql .= ' LIMIT '. $limit;
	// 	}
	// 	//3.预处理sql语句
	// 	$a = $p->prepare($sql);  //执行sql并返回待处理结果保存至变量
	// 	//4.执行sql语句
	// 	if ($a->execute()) {     //判断待处理结果$a执行是否成功
	// 		if ($a->rowcount()) { //判断是否有结果，有则输出，没有则返回false
	// 			//5.设置获取结果集模式
	// 			$a->setFetchMode(PDO::FETCH_ASSOC);  //为语句设置默认获取模式，PDO::FETCH_ASSOC把结果换做成数组
	// 			//6.返回结果集
	// 			$ret = $a->fetchALL();  //返回结果集
	// 			return $ret;           //返回自定义方法
	// 		}else{
	// 			return false; 
	// 		}
	// 	}else{
	// 		return false;
	// 	}
	// }
	// $c = select('user','id>1','age DESC','2,2');
	// print_r($c);
		

	// function add($table,$field,$val){  //自定义数据库增加数据方法
	// 	//1.连接数据库
	// 	$dsn = 'mysql:host=127.0.0.1; dbname=user; charset=utf8; port=3306';
	// 	$dbname = 'root';
	// 	$dbpw = 'root';
	// 	$p = new PDO($dsn,$dbname,$dbpw);
	// 	try {
	// 		$p;  //判断是否存在错误
	// 	} catch (PDOException $e) {     //如有错误将其保存至&e
	// 		print_r($e->getmessage());  //打印错误消息
	// 		exit;                      //暂停往下执行
	// 	}
	// 	//2.存储sql语句
	// 	$sql = 'INSERT INTO ';   //拼装数据
	// 	$sql .= $table .$field.' VALUES '.$val;
	// 	//3.预处理sql语句
	// 	$a = $p->prepare($sql);  //执行sql并返回待处理结果保存至变量
	// 	//4.执行sql语句
	// 	if ($a->execute()) {     //判断待处理结果$a执行是否成功
	// 		if ($a->rowcount()) { //判断是否有结果，有则输出，没有则返回false
	// 			//5.设置获取结果集模式
	// 			$a->setFetchMode(PDO::FETCH_ASSOC);  //为语句设置默认获取模式，PDO::FETCH_ASSOC把结果换做成数组
	// 			//6.返回结果集
	// 			$ret = $a->fetchALL();  //返回结果集
	// 			return $ret;           //返回自定义方法
	// 		}else{
	// 			return false; 
	// 		}
	// 	}else{
	// 		return false;
	// 	}
	// }
	// $c = add('user',('name,age'),('刘姓,28'));  //这里的括号该怎么处理
	// print_r($c);
	

	// function add($table,$where){  //自定义数据库删除数据方法
	// 	//1.连接数据库
	// 	$dsn = 'mysql:host=127.0.0.1; dbname=user; charset=utf8; port=3306';
	// 	$dbname = 'root';
	// 	$dbpw = 'root';
	// 	$p = new PDO($dsn,$dbname,$dbpw);
	// 	try {
	// 		$p;  //判断是否存在错误
	// 	} catch (PDOException $e) {     //如有错误将其保存至&e
	// 		print_r($e->getmessage());  //打印错误消息
	// 		exit;                      //暂停往下执行
	// 	}
	// 	//2.存储sql语句
	// 	$sql = 'DELETE FROM ';   //拼装数据
	// 	$sql .= $table .' WHERE '.$where;
	// 	//3.预处理sql语句
	// 	$a = $p->prepare($sql);  //执行sql并返回待处理结果保存至变量
	// 	//4.执行sql语句
	// 	if ($a->execute()) {     //判断待处理结果$a执行是否成功
	// 		if ($a->rowcount()) { //判断是否有结果，有则输出，没有则返回false
	// 			//5.设置获取结果集模式
	// 			$a->setFetchMode(PDO::FETCH_ASSOC);  //为语句设置默认获取模式，PDO::FETCH_ASSOC把结果换做成数组
	// 			//6.返回结果集
	// 			$ret = $a->fetchALL();  //返回结果集
	// 			return $ret;           //返回自定义方法
	// 		}else{
	// 			return false; 
	// 		}
	// 	}else{
	// 		return false;
	// 	}
	// }
	// $c = add('user','age=12');
	// print_r($c);
	 
	
	// function add($table,$fz,$where){  //自定义数据库修改数据方法
	// 	//1.连接数据库
	// 	$dsn = 'mysql:host=127.0.0.1; dbname=user; charset=utf8; port=3306';
	// 	$dbname = 'root';
	// 	$dbpw = 'root';
	// 	$p = new PDO($dsn,$dbname,$dbpw);
	// 	try {
	// 		$p;  //判断是否存在错误
	// 	} catch (PDOException $e) {     //如有错误将其保存至&e
	// 		print_r($e->getmessage());  //打印错误消息
	// 		exit;                      //暂停往下执行
	// 	}
	// 	//2.存储sql语句
	// 	$sql = 'UPDATE '.$table .' SET ';   //拼装数据
	// 	$sql .= $fz.' WHERE '.$where;
	// 	//3.预处理sql语句
	// 	$a = $p->prepare($sql);  //执行sql并返回待处理结果保存至变量
	// 	//4.执行sql语句
	// 	if ($a->execute()) {     //判断待处理结果$a执行是否成功
	// 		if ($a->rowcount()) { //判断是否有结果，有则输出，没有则返回false
	// 			//5.设置获取结果集模式
	// 			$a->setFetchMode(PDO::FETCH_ASSOC);  //为语句设置默认获取模式，PDO::FETCH_ASSOC把结果换做成数组
	// 			//6.返回结果集
	// 			$ret = $a->fetchALL();  //返回结果集
	// 			return $ret;           //返回自定义方法
	// 		}else{
	// 			return false; 
	// 		}
	// 	}else{
	// 		return false;
	// 	}
	// }
	// $c = add('user','age=12','id=3');
	// print_r($c);
?>