php连接数据库查询与非查询的封装函数

<?php
header(‘content-type:text/html;charset=utf-8‘);
define(‘HOST‘,‘127.0.0.1‘);
define(‘UNAME‘,‘root‘);
define(‘PWD‘,‘123456‘);
define(‘DB‘,‘test‘);
define(‘PORT‘,3307);
function my_exec($sql){
  $link=mysqli_connect(HOST,UNAME,PWD,DB,PORT);
  if(!$link)
  {
    echo "连接失败";
    return false;
  }
  $res=mysqli_query($link,$sql);
  if($res){
    mysqli_close($link);
    return true;
  }
  else{
    echo "执行失败";
    echo mysqli_error($link);
    mysqli_close($link);
    return false;
  }
 
}





$sql="delete from stu where id=2";
$res=my_exec($sql);
if($res)
{
  echo "执行成功";
}
else{
  echo "执行失败";
}
?>

<?php
header(‘content-type:text/html;charset=utf-8‘);
define(‘HOST‘,‘127.0.0.1‘);
define(‘UNAME‘,‘root‘);
define(‘PWD‘,‘123456‘);
define(‘DB‘,‘test‘);
define(‘PORT‘,3307);

 function my_query( $sql ) {

    // 1. 建立连接
    $link = @ mysqli_connect( HOST, UNAME, PWD, DB, PORT );
    if ( !$link ) {
      echo "数据库连接失败";
      return false;
    }

    // 2. 准备 sql 语句 $sql
    // 3. 执行 sql 语句, 分析结果
    $res = mysqli_query( $link, $sql );  // 结果集 或者 false

    if ( !$res ) {
      echo "获取数据失败<br>";
      echo mysqli_error($link);
      mysqli_close( $link );
      return false;
    }

    // 得到结果集, 将结果集的所有内容取出到数组中
    $arr = [];
    while ( $row = mysqli_fetch_assoc($res) ) {
      $arr[] = $row;
    }

    mysqli_close( $link );
    return $arr; // 返回结果数组
  }

?>