require_once "../include.php";
//链接数据库
function connect()
{
   $link = mysqli_connect(DB_HOST, DB_PWD) or die("数据库打开失败error:" . mysqli_connect_errno());
   mysqli_set_charset($link, DB_CHARSET);
   mysqli_select_db($link, DB_DBNAME);
   return $link;
}

//数据插入
function insert($table,$array){
   $link =  connect();
   $keys =join(",",array_keys($array));
   $vals = array_values($array);
   $name = '"'.$vals[0].'"';
   $key = '"'.$vals[1].'"';
   $email = '"'.$vals[2].'"';
   $sql = "insert into {$table}($keys) values($name,$key,$email)";
//    echo $sql;
   mysqli_query($link,$sql);
   //   echo mysqli_errno($link);
   return mysqli_insert_id($link);
}
function insertB($table,$array){
   $link =  connect();
   $keys="`".join("','",array_keys($array))."`";
   $vals="'".join("','",array_values($array))."'";
   $sql="INSERT  INTO `{$table}`($keys) VALUES ({$vals})";
   echo  $sql;
   mysqli_query($link,$sql);
   return mysqli_insert_id($link);
}
//记录更新
//update imooc_admin set username='king' where id=1
function update($table, $array, $where=null){
   $link =  connect();
   $str = '';
   foreach ($array as $key => $val){
       if ($str == null) {
           $sep = "";
       } else {
           $sep = ",";
       }
       $str.=$sep."`".$key."`"."='".$val."'";
   }
   $sql = "UPDATE `{$table}` SET {$str}"." ".($where == null? null:"WHERE". " "."`{$table}`".".".$where);
   $result = mysqli_query($link,$sql);
   if ($result){
       return mysqli_affected_rows($link);
   } else {
       return false;
   }
}

//删除记录
function delete ($table,$where){
   $link =  connect();
   $where = $where==null? null:"where"."`".$table."`".".".$where;
   $sql = "delete from `{$table}` {$where}";
   //echo ($sql);
   $reslt =  mysqli_query($link,$sql);
   if ($reslt){
       return mysqli_affected_rows($link);
   } else {
       return false;
   }

}

//得到一条记录
function fetchOne ($sql,$result_type=MYSQLI_ASSOC) {
   $link =  connect();
   $result = mysqli_query($link,$sql);
   if (mysqli_errno($link)){
       die(mysqli_errno($link));
       $mes =  mysqli_errno($link);
       echo "<script>alert('{$mes}');</script>";
   }
   $row = mysqli_fetch_array($result);
   return $row;
}
//等到结果所有的数据
function fetchAll($sql,$result_type=MYSQLI_ASSOC){
   $link =  connect();
   $result = mysqli_query($link,$sql);
   if (mysqli_errno($link)){
       die(mysqli_errno($link));
   } else {
       while ($row = mysqli_fetch_array($result,$result_type)){
           $rows [] = $row;
       }
       return $rows;
   }
}

//得到结果的条数
function getResultNum ($sql) {
   $link = connect();
   $result = mysqli_query($link,$sql);
   if ($result) {
       return mysqli_num_rows($result);
   } else {
       return null;
   }

}

//得到上一步插入数据的id号码
function getInsertId(){
   $link = connect();
   return mysqli_insert_id($link);
}