首页 / MYSQL / 封装数据库mysql, mysqli

封装数据库mysql, mysqli

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了封装数据库mysql, mysqli，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含8142字，纯文字阅读大概需要12分钟。

内容图文

<?php

header("content-type:text/html;charset=utf-8");

class db{
 //私有的静态属性
 private static $dbcon = false ;
 //私有的构造方法
 private function __construct($dbname){
 $dbcon = @mysql_connect(‘127.0.0.1‘, ‘root‘, ‘root‘);
 mysql_select_db($dbname, $dbcon) or die("mysql connect error");
 mysql_query("set names utf8", $dbcon);
 }
 //私有的克隆方法
 private function __clone(){}
 //公共的静态方法, 数据库连接对象
 public static function getInstance($dbname){
 if(self::$dbcon == false){
 self::$dbcon = new db($dbname);
 }
 return self::$dbcon;
 }
 /**
 * 执行语句
 * @param $sql
 * @return source
 */
 public function query($sql){
 return mysql_query($sql);
 }
 /**
 * 查询某个字段, 例如 select count(*), select username
 * @param $sql
 * @return string or int
 */
 public function getOne($sql){
 $query = $this->query($sql);
 return mysql_result($query, 0);
 }
 /**
 * 获取一行记录
 * @param $sql
 * @return array 一维
 */
 public function getRow($sql, $type=‘assoc‘){
 $query = $this->query($sql);
 if(!in_array($type, array("assoc", "array", "row"))){
 die("mysql_query error");
 }
 $functionname = "mysql_fetch_".$type;
 return $functionname($query);
 }
 /**
 * 前置条件:通过资源获取一条记录
 * @param $query source
 * @return array 一维
 */
 public function getRowFromSource($query, $type="assoc"){
 if(!in_array($type, array("assoc", "array", "row"))){
 die("mysql_query error");
 }
 $functionname = "mysql_fetch_".$type;
 return $functionname($query);
 }
 /**
 * 获取所有记录
 * @param $sql
 * @return array 二维
 */
 public function getAll($sql){
 $query = $this->query($sql);
 $list = array();
 while ($row = $this->getRowFromSource($query)) {
 $list[] = $row;
 }
 return $list;
 }
 /*
 * 新增数据方法
 * @param1 $table, $data 表名数据
 * @return 上一次增加操做产生ID值
 */
 public function insert($table, $data){
 //遍历数组，得到每一个字段和字段的值
 $kstr = ‘‘ ;
 $vstr = ‘‘ ;
 foreach ($data as $key => $val) {
 //$key是字段名, $val是对应的值
 $kstr = $key."," ;
 $vstr = "‘$val‘,";
 }
 $kstr = rtrim($kstr, ‘,‘);
 $vstr = rtrim($vstr, ‘,‘);
 //添加的sql语句
 $sql = "insert into $table ($kstr) values ($vstr)";
 //执行
 $this->query($sql);
 //返回上一次增加操做产生ID值
 return $this->getInsertId();
 }
 /*
 * 删除一条数据方法
 * @param1 $table, $where=array(‘id‘=>‘1‘) 表名条件
 * @return 受影响的行数
 */
 public function deleteOne($table, $where){
 if(is_array($where)){
 foreach ($where as $key => $val) {
 $condition = $key.‘=‘.$val;
 }
 } else {
 $condition = $where;
 }
 $sql = "delete from $table where $condition";
 $this->query($sql);
 //返回受影响的行数
 return mysql_affected_rows();
 }
 /*
 * 删除多条数据方法
 * @param1 $table, $where 表名条件
 * @return 受影响的行数
 */
 public function deleteAll($table, $where){
 if(is_array($where)){
 foreach ($where as $key => $val) {
 if(is_array($val)){
 $condition = $key.‘ in (‘.implode(‘,‘, $val) .‘)‘;
 } else {
 $condition = $key. ‘=‘ .$val;
 }
 }
 } else {
 $condition = $where;
 }
 $sql = "delete from $table where $condition";
 $this->query($sql);
 //返回受影响的行数
 return mysql_affected_rows();
 }
 /*
 * 修改数据方法
 * @param1 $table,$data,$where 表名数据条件
 * @return 受影响的行数
 */
 public function update($table,$data,$where){
 //遍历数组，得到每一个字段和字段的值
 $str=‘‘;
 foreach($data as $key=>$v){
 $str.="$key=‘$v‘,";
 }
 $str=rtrim($str,‘,‘);
 //修改的SQL语句
 $sql="update $table set $str where $where";
 $this->query($sql);
 //返回受影响的行数
 return mysql_affected_rows();
 }
 /**
 * 获取刚插入数据的id
 * @return int
 */
 public function getInsertId(){
 return mysql_insert_id();
 }
 /**
 * print_r 打印数据
 */
 public function p($arr){
 echo "<pre>";
 print_r($arr);
 echo "</pre>";
 }
 /**
 * var_dump 打印数据
 */
 public function v($arr){
 echo "<pre>";
 var_dump($arr);
 echo "</pre>";
 }

}
// $dbname = ‘yii2_project‘;
// $db = db::getInstance($dbname);
// // where article_id=1
// $sql = "select * from article";
// $arr = $db->getAll($sql);
// $db->p($arr);

<?php

//header
header(‘content-type:text/html;charset=UTF-8‘);

class DB {
 //定义属性
 private $host;//主机名
 private $port;//端口号
 private $name;//用户名
 private $pass;//密码
 private $dbname;//数据库名
 private $charset;//设置字符集
 private $link;//连接数据库
 private static $instance;
 //初始化构造函数
 private function __construct($arr = array()){
 $this->host = isset($arr[‘host‘]) ? $arr[‘host‘] : ‘localhost‘ ;
 $this->port = isset($arr[‘port‘]) ? $arr[‘port‘] : ‘3306‘ ;
 $this->name = isset($arr[‘name‘]) ? $arr[‘name‘] : ‘root‘ ;
 $this->pass = isset($arr[‘pass‘]) ? $arr[‘pass‘] : ‘root‘ ;
 $this->dbname = isset($arr[‘dbname‘]) ? $arr[‘dbname‘] : ‘yii2_project‘ ;
 $this->charset = isset($arr[‘charset‘]) ? $arr[‘charset‘] : ‘utf8‘ ;
 //连接数据库
 $this->db_connect();
 //选择数据库
 $this->db_usedb();
 //设置字符集
 $this->db_charset();
 }
 //连接数据库
 private function db_connect(){
 //主机名:端口号 用户名密码
 $this->link = mysqli_connect($this->host.‘:‘.$this->port, $this->name, $this->pass);
 //连接失败
 if(!$this->link){
 echo ‘数据库连接失败 ‘;
 echo ‘错误编码是:‘.mysqli_errno($this->link).‘ ‘;
 echo ‘错误信息是:‘.mysqli_error($this->link).‘ ‘;
 exit;
 }
 }
 //选择数据库
 private function db_usedb(){
 mysqli_query($this->link, "use {$this->dbname}");
 }
 //设置字符集
 private function db_charset(){
 mysqli_query($this->link, "set names {$this->charset}");
 }
 //私有化克隆函数，防止外界克隆对象
 private function __clone()
 {
 }

 //单例访问统一入口
 public static function getInstance()
 {
 if(!(self::$instance instanceof self))
 {
 self::$instance = new DB();
 }
 return self::$instance;
 }
 //执行sql语句的方法
 private function db_query($sql){
 $res = mysqli_query($this->link, $sql);
 if(!$res){
 echo ‘sql语句有错误 ‘;
 echo ‘错误编码是:‘.mysqli_errno($this->link).‘ ‘;
 echo ‘错误信息是:‘.mysqli_error($this->link).‘ ‘;
 exit;
 }
 return $res;//成功返回数据
 }
 //增加操作
 public function db_insert($sql){
 $this->db_query($sql);
 //返回上一次添加的id
 return mysql_insert_id();
 }
 //删除操作
 public function db_delete($sql){
 $this->db_query($sql);
 //返回受影响的行数
 return mysqli_affected_rows($this->link);
 }
 //修改操作
 public function db_update($sql){
 $this->db_query($sql);
 //返回受影响的行数
 return mysqli_affected_rows($this->link);
 }
 //查看单条数据
 public function db_getOne($sql){
 $res = $this->db_query($sql);
 //返回数据
 return mysqli_fetch_assoc($res);
 }
 //查看多条数据
 public function db_getAll($sql){
 $res = $this->db_query($sql);
 $arr = array();
 while($row = mysqli_fetch_assoc($res)){
 $arr[] = $row;
 }
 //返回数据
 return $arr;
 }

}

封装数据库mysql, mysqli

标签：

本文系统来源：http://www.cnblogs.com/jhy-ocean/p/5424872.html

内容总结

以上是互联网集市为您收集整理的封装数据库mysql, mysqli全部内容，希望文章能够帮你解决封装数据库mysql, mysqli所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/462467.html

来源：【匿名】

【上一篇】MySQL绿色版安装（mysql-5.7.12-win32）【下一篇】用IE远程创建Mysql数据库的简易程序

更多 ►

【封装数据库mysql, mysqli】教程文章相关的互联网学习教程文章

phpmyadmin提示mysqli_real_connect(): (HY000/2002): No such file or directory错误的解决办法

phpmyadmin上传到网站目录后提示解决phpmyadmin mysqli_real_connect(): (HY000/2002): No such file or directory的错误，解决方法把phpmyadmin目录中的配置文件config.sample.inc.php改成config.inc.php 打开编辑config.inc.php 找到： $cfg[‘Servers‘][$i][‘host‘] = ‘localhost‘; 改成： $cfg[‘Servers‘][$i][‘host‘] = ‘127.0.0.1‘; 再次刷新页面就不会出现mysqli_real_connect(): (HY000/2002): No such file or...

利用mysql和mysqli取得mysql的所有数据库和库中的所有表【代码】

功能：利用mysql和mysqli两种连接数据库的方法，取得Mysql服务器上的所有数据库和库中的所有表。环境：自己用分开安装apache mysql php搭建的环境操作系统是：windows 10代码如下：<?php/** * mysqli op mysql demo *//** * 公用函数*//** * 功能：列出一个数据库的所有表* @param $dbname * @param $con */function list_tables($dbname,$con) { mysql_select_db($dbname,$con) or die("选择数据库失败!"); $re...

mysql使用mysqldump 与 mysqlimport进行数据库迁移

1.导入数据库1）sourcesource /home/platvt/product/pc2_create_tables.sql2）mysqlimport使用mysqlimport导入数据：出现情况：（1）出现 Error: 1146[platvt@qa-qd-62-180 tmp]$ mysqlimport -uroot -p --fields-terminated-by=‘\t‘ test students Enter password: mysqlimport: Error: 1146, Table ‘test.students‘ doesn‘t exist, when using table: students在导入之前必须数据库里面有对应的表，所以必须先在数据库里面...

PHP mysqli扩展库预处理技术的使用分析

1、使用mysqli扩展库预处理技术 mysqli stmt 向数据库添加3个用户复制代码代码如下:<?php //mysqli扩展库预处理技术 mysqli stmt 向数据库添加3个用户 //1、创建mysqli对象 $mysqli = new MySQLi("localhost","root","root","test"); if($mysqli->connect_error){ die($mysqli->conncet_error); } //2、创建预编译对象 $sql="insert into user1(name,password,email,age) values(?,?,?,?)"; $m...

MySql总是弹出一个mySqlInstallerConsole的窗口【图】

MySQLInstallerConsole.exe程序偶尔自动弹出执行的问题。这是一条安装命令，Installing MYSQL 5.7 using MySQLInstallerConsole.exe 使用它可以设置一些下载安装包，当然使用的是默认安装不需人工干预。关掉它也没有什么影响，win10状态下，从开始---->所有应用----->管理工具----->任务计划程序----》左侧任务计划程序库文件夹，展开文件夹----》mYsql子文件夹installer，点击。在右侧窗口右击击鼠标禁用即可，见下图。650) this....

php+mysqli批量查询多张表数据的方法

本文实例讲述了php+mysqli批量查询多张表数据的方法。分享给大家供大家参考。具体实现方法如下：注意这里使用到了两个新的函数multi_query与store_result，具体代码如下：复制代码代码如下:<?php //1、创建数据库连接对象 $mysqli = new MySQLi("localhost","root","123456","liuyan"); if($mysqli->connect_error){ die($mysqli->connect_error); } $mysqli->query("set names ‘GBK‘"); //2、查询多个数据库表 $sqls = "selec...

php使用mysql和mysqli连接查询数据【代码】

mysql：<?php $code = $_POST[‘code‘]; $status = ""; $success = ""; $scookies = "";try {$dbname="root";$dbpass="root";$dbhost="127.0.0.1";$dbdatabase="mysql";//生成一个连接$db_connect=mysql_connect($dbhost,$dbname,$dbpass);//选择一个需要操作的数据库mysql_select_db($dbdatabase,$db_connect);// 获取查询结果$strsql="select * from `go_member_addmoney_record` where `code` = ‘$code‘ limit 1";$result=m...

PDO PDO_MYSQL MYSQLI MYSQL 的区别

MYSQL,MYSQLI 这两个扩展本身就是访问MYSQL数据库的驱动PDO则是一个抽象层概念PDO_MYSQL 和 MySQL Native(mysqlnd)是实现了PDO接口的MYSQL数据库驱动从下表可以看出他们之间是怎样的并列关系 PHP的mysqli扩展PDO (使用PDO MySQL驱动和MySQL Native驱动)PHP的mysql扩展引入的PHP版本5.05.03.0之前PHP5.x是否包含是是是MySQL开发状态活跃在PHP5.3中活跃仅维护在MySQL新项目中的建议使用程度建议 - 首选建议不建议API的字符集支持是是...

LOAD DATA INFILE & mysqlimport

+++++++++++++++++++++++++++++++++++++++++++++mysqlimport+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++其实如果用mysqlimport是mysql数据库提供的一个命令行程序，从本质来说j load data infile的命令接口，而且大多数的选项都和load data infile语法相同。shell>mysqlimport [option] db_name testfile1 [testfile2 ...] select into outfile 注意保持时以表名加.txt，以便恢复。和load data infile不同的是，...

mysqli扩展库的预处理技术 mysqli stmt【代码】【图】

思路原理代码如下： 1 <?php2//预编译演示3 //需求: 请使用预处理的方式，向数据库添加三个用户4 //1.创建mysqli对象 5$mysqli=new MySQLi("localhost","root","hsp123","test");6//2.创建预编译对象 7 $sql="insert into user1 (name,password,email,age) values(?,?,?,?)";8$mysqli_stmt=$mysqli->prepare($sql) or die($mysqli->error);9//绑定参数10$name="小倩"; 11$password="xiaoqian"; 12$email="aa@sohu.co...

PHP-MySQL,PHP-MySQLi,PDO的差异【代码】

PHP-MySQL是PHP操作MySQL数据库最原始的Extension ，PHP-MySQLi的i代表Improvement ，提供了更加高级的功能，就Extension而言，本身也增加了安全性。而PDO(PHP Data Object) 则是提供了一个 Abstraction Layer来操作数据库。我们通过代码来初步比较它们之间的差异。　　先来看一段PHP-MySQL的通用代码：<?phpmysql_connect($db_host, $db_user, $db_password);mysql_select_db($dn_name);$result = mysql_query("SELECT `name` FRO...

mysqli常用方法

//返回前一次 MySQL 操作（SELECT、INSERT、UPDATE、REPLACE、DELETE）所影响的记录行数。 //一个 > 0 的整数表示所影响的记录行数。0 表示没有受影响的记录。-1 表示查询返回错误。 int $mysqli->affected_rows; //返回MySQL客户端版本 int $mysqli->client_version; //返回最近查询的列数。 int $mysqli->field_count; //返回 MySQL 服务器主机名和连接类型。 string $mysqli->host_info; //返回MySQL服务器的版本号 str...

mysqli 封装【代码】

mysqli面向过程练手【代码】

1 代码:2//1.得到mysqli连接 3header("Content-type: text/html;charset=utf-8");4$mysqli=mysqli_connect("localhost","root","root","test");5if(!$mysqli){6die("连接失败".mysqli_connnect_error($mysqli));7 }8//2.向数据库发送sql语句(ddl,dml dql ...) 9$sql="select * from user1"; 10$res=mysqli_query($mysqli,$sql); 11//var_dump($res); 12 //3.处理得到的结果 13 //循环取出$res中的数据mysqli_fet...

PHP操作数据库出现错误：mysqli_num_rows() expects parameter 1 to be mysqli_result, boolean given in【代码】

原因在于你操作数据库出错了，但是却没有对应的出错处理。解决方法是，在$result = mysqli_query($conn, $sql);后加上这样一段代码：if (!$result) {printf("Error: %s\n", mysqli_error($conn));exit(); }之后刷新页面查看具体错误信息。参考链接：1. https://blog.csdn.net/weixin_41470917/article/details/843305812. https://www.cnblogs.com/cc18/p/6150335.html原文：https://www.cnblogs.com/lfri/p/12229694.html

首页 / MYSQL / 封装数据库mysql, mysqli

封装数据库mysql, mysqli

内容导读

内容图文

内容总结

内容备注

内容手机端

【封装数据库mysql, mysqli】教程文章相关的互联网学习教程文章

phpmyadmin提示mysqli_real_connect(): (HY000/2002): No such file or directory错误的解决办法

利用mysql和mysqli取得mysql的所有数据库和库中的所有表【代码】

mysql使用mysqldump 与 mysqlimport进行数据库迁移

PHP mysqli扩展库预处理技术的使用分析

MySql总是弹出一个mySqlInstallerConsole的窗口【图】

php+mysqli批量查询多张表数据的方法

php使用mysql和mysqli连接查询数据【代码】

PDO PDO_MYSQL MYSQLI MYSQL 的区别

LOAD DATA INFILE & mysqlimport

mysqli扩展库的预处理技术 mysqli stmt【代码】【图】

PHP-MySQL,PHP-MySQLi,PDO的差异【代码】

mysqli常用方法

mysqli 封装【代码】

mysqli面向过程练手【代码】

PHP操作数据库出现错误：mysqli_num_rows() expects parameter 1 to be mysqli_result, boolean given in【代码】

数据库 - 相关标签

封装 - 相关标签

MYSQL - 技术教程分类

MYSQL - 最新教程

MYSQL - 最热教程