实例
<?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); ?>
运行实例 »
点击 "运行实例" 按钮查看在线实例