自写的PHP操作MYSQL的函数,利用MYSQLI库

56 阅读 0 评论 37 点赞

我是靠谱客的博主忧郁流沙，最近开发中收集的这篇文章主要介绍自写的PHP操作MYSQL的函数,利用MYSQLI库，觉得挺不错的，现在分享给大家，希望可以做个参考。

概述

自写的

mysqlTableArr 自带表格显示结果集

//将结果集列表显示,并返回转存的二维数组.
//$arr=array("127.0.0.1","root","","","3306");
//$arr=array();
//mysqlTableArr1();

function mysqlTableArr($loca=array("h"=>"127.0.0.1","u"=>"root","p"=>"","db"=>"mysql","pt"=>"3306"),$sql="show databases;")
{
	echo "<pre>";
	print_r($loca);
	echo "</pre>";
	echo "<br>".$loca['h'];
	//1、连接MYSQL服务器
	//参数顺序：MYSQL地址loca  登录名user  登录密码pass 使用数据库dbas  端口port
	$con=mysqli_connect($loca['h'],$loca['u'],$loca['p'],$loca['db'],$loca['pt']);

	if(mysqli_connect_errno($con))
	{
		echo "<br>连接失败：".mysqli_connect_error();
	}
	else
	{
		//echo "<br>连接成功！！！";
		//执行命令
		//2.设置连接字符
		mysqli_set_charset($con,"utf8");
		//3选择数据库
		if(!mysqli_select_db($con,$loca['db']))
		{
			echo "<br>选择（ＵＳＥ）的数据库  {$loca['db']}  不存在";
		}
		else
		{
			echo "<br>已经打开数据库{$loca['db']}";
			//4.执行ＳＱＬ命令
			$sql="select * from help_category;";

			$rs=mysqli_query($con,$sql);
			echo "<pre>";
			print_r($rs);
			echo "</pre>";

			//5.关闭连接
			mysqli_close($con);
			
			if($rs==false)
			{
				echo "<br>命令失败".mysql_error();
			}
			else
			{
				echo "<br>执行SQL命令成功,成功关闭连接!!!";
				
				
				
				//**************************************************
				//**************************************************
				//**************************************************
				//6处理结果集$rs
				$arr1=array();//将结果导入二维数据
				$n=0;//记录一共多少条数据,第0行是字段名


				$fieldCount = mysqli_num_fields($rs);//取得字段总数
				echo "<table border='1'>";
				//输出表头
				echo "<tr>";
				for($i=0;$i<$fieldCount;$i++)
				{
					//$fieldName=mysql_field_name($rs,$i);//取得字段名
					$field= mysqli_fetch_field_direct($rs,$i);
					echo "<td>$field->name</td>";
					//----------------------------------------
					$arr1[$n][$i]=$field->name;//记录字段名字
					//----------------------------------------
				}
				echo "</tr>";
				//从结果集中取得一行作为数字数组或关联数组：
				while($rec=mysqli_fetch_array($rs))
				{
					//----------------------------------------
					$n++;//行数自增1
					//----------------------------------------
					echo "<tr>";
					for($i=0;$i<$fieldCount;$i++)
					{
						echo "<td>$rec[$i]</td>";
						//----------------------------------------
						$arr1[$n][$i]=$rec[$i];//记录每一条记录
						//----------------------------------------
					}
					echo "</tr>";
				}
				echo "</table>";
				//**************************************************
				//**************************************************
				//**************************************************
				//----------------------------------------
				echo "<pre>";
				print_r($arr1);//输出数组
				echo "</pre>";	
				//----------------------------------------

				return $arr1;
			}
		}
	}
}

mysqlArr将结果集变成数组,返回结果一个二维数组,二维数组首行是字段名,下面是数据.

<?php
//将结果集存入二维数据,并返回数组
//$arr1=mysqlArr();
//echo "<pre>";
//print_r($arr1);
//echo "</pre>";

function mysqlArr($loca=array("h"=>"127.0.0.1","u"=>"root","p"=>"","db"=>"mysql","pt"=>"3306"),$sql="show databases;")
{
	//1、连接MYSQL服务器
	//参数顺序：MYSQL地址loca  登录名user  登录密码pass 使用数据库dbas  端口port
	$con=mysqli_connect($loca['h'],$loca['u'],$loca['p'],$loca['db'],$loca['pt']);

	if(mysqli_connect_errno($con))
	{
		echo "<br>连接失败：".mysqli_connect_error();
	}
	else
	{
		//echo "<br>连接成功！！！";
		//执行命令
		//2.设置连接字符
		mysqli_set_charset($con,"utf8");
		//3选择数据库
		if(!mysqli_select_db($con,$loca['db']))
		{
			echo "<br>选择（ＵＳＥ）的数据库  {$loca['db']}  不存在";
		}
		else
		{
			//echo "<br>已经打开数据库{$loca['db']}";
			//4.执行ＳＱＬ命令
			//$sql="select * from help_category;";
			$rs=mysqli_query($con,$sql);
			//5.关闭连接
			mysqli_close($con);
			
			if($rs==false)
			{
				echo "<br>命令失败".mysql_error();
			}
			else
			{
				//echo "<br>执行SQL命令成功,成功关闭连接!!!";
				//6处理结果集$rs
				$arr1=array();//将结果导入二维数据
				$n=0;//记录一共多少条数据,第0行是字段名

				$fieldCount = mysqli_num_fields($rs);//取得字段总数
				for($i=0;$i<$fieldCount;$i++)
				{
					//$fieldName=mysql_field_name($rs,$i);
					$field= mysqli_fetch_field_direct($rs,$i);//取得字段名
					$arr1[$n][$i]=$field->name;//记录字段名字
				}

				while($rec=mysqli_fetch_array($rs))
				{
					$n++;//行数自增1
					for($i=0;$i<$fieldCount;$i++)
					{	
						$arr1[$n][$i]=$rec[$i];//记录每一条记录
					}
				}
				

				return $arr1;
			}
		}
	}
}

?>

mysqlre直接返回结果集,不作任何处理.

<?php
//只返回结果集无处理
//$arr1=mysqlre();
//echo "<pre>";
//print_r($arr1);
//echo "</pre>";
function mysqlre($loca=array("h"=>"127.0.0.1","u"=>"root","p"=>"","db"=>"mysql","pt"=>"3306"),$sql="show databases;")
{
	//1、连接MYSQL服务器
	//参数顺序：MYSQL地址loca  登录名user  登录密码pass 使用数据库dbas  端口port
	//加@可以去掉此条MYSQL语句的报错信息.
	$con=@mysqli_connect($loca['h'],$loca['u'],$loca['p'],$loca['db'],$loca['pt']);

	if(mysqli_connect_errno($con))
	{
		echo "<br>a.php连接失败：".mysqli_connect_error();
		return;
	}
	else
	{
		//echo "<br>连接成功！！！";
		//执行命令
		//2.设置连接字符
		mysqli_set_charset($con,"utf8");
		//3选择数据库
		if(!mysqli_select_db($con,$loca['db']))
		{
			echo "<br>选择（ＵＳＥ）的数据库  {$loca['db']}  不存在";
			return;
		}
		else
		{
			//echo "<br>已经打开数据库{$loca['db']}";
			//4.执行ＳＱＬ命令
			//$sql="select * from help_category;";
			$rs=mysqli_query($con,$sql);
			//5.关闭连接
			mysqli_close($con);
			
			if($rs==false)
			{
				echo "<br>命令失败".mysql_error();
				return;
			}
			else
			{
				//echo "<br>执行SQL命令成功,成功关闭连接!!!";
				//6返回结果集$rs
				return $rs;
			}
		}
	}
}

?>