<?php
class mysql{
/**
* 连接 MYSQL 函数
* 连接 MYSQL 函数, 通过常量的形式来连接数据库
* 自定义配置文件,配置文件中自定义常量,包含需要使用的信息
* @return resource
*/
function connect2 (){
// 连接 mysql
$link=@mysql_connect(DB_HOST,DB_USER,DB_PWD) or die ('数据库连接失败 <br/>ERROR'.mysql_errno().':'.mysql_error());
// 设置字符集
mysql_set_charset(DB_CHARSET);
// 打开指定的数据库
mysql_select_db(DB_DBNAME) or die('指定的数据库打开失败');
return $link;
}
/* array(
'username'=>'cy',
'password'=>'123456',
'email'=>'cy@qq.com'
) */
/**
* 插入记录的操作
* @param array $array
* @param string $table
* @return boolean
*/
function insert($array,$table){$keys=join(',',array_keys($array));
$values="'".join("','", array_values($array))."'";
$sql="insert {$table}({$keys}) VALUES ({$values})";
$res=mysql_query($sql);
if($res){return mysql_insert_id();
}else{return false;}
}
/**
* MYSQL 更新操作
* @param array $array
* @param string $table
* @param string $where
* @return number|boolean
*/
function update($array,$table,$where=null){foreach ($array as $key=>$val){$sets.=$key."='".$val."',";}
$sets=rtrim($sets,','); // 去掉 SQL 里的最后一个逗号
$where=$where==null?'':' WHERE '.$where;
$sql="UPDATE {$table} SET {$sets} {$where}";
$res=mysql_query($sql);
if ($res){return mysql_affected_rows();
}else {return false;}
}
/**
* 删除记录的操作
* @param string $table
* @param string $where
* @return number|boolean
*/
function delete($table,$where=null){
$where=$where==null?'':' WHERE '.$where;
$sql="DELETE FROM {$table}{$where}";
$res=mysql_query($sql);
if ($res){return mysql_affected_rows();
}else {return false;}
}
/**
* 查询一条记录
* @param string $sql
* @param string $result_type
* @return boolean
*/
function fetchOne($sql,$result_type=MYSQL_ASSOC){$result=mysql_query($sql);
if ($result && mysql_num_rows($result)>0){return mysql_fetch_array($result,$result_type);
}else {return false;}
}
/**
* 得到表中的所有记录
* @param string $sql
* @param string $result_type
* @return boolean
*/
function fetchAll($sql,$result_type=MYSQL_ASSOC){$result=mysql_query($sql);
if ($result && mysql_num_rows($result)>0){while ($row=mysql_fetch_array($result,$result_type)){$rows[]=$row;
}
return $rows;
}else {return false;}
}
/** 取得结果集中的记录的条数
* @param string $sql
* @return number|boolean
*/
function getTotalRows($sql){$result=mysql_query($sql);
if($result){return mysql_num_rows($result);
}else {return false;}
}
/** 释放结果集
* @param resource $result
* @return boolean
*/
function freeResult($result){return mysql_free_result($result);
}
/** 断开 MYSQL
* @param resource $link
* @return boolean
*/
function close($link=null){return mysql_close($link);
}
/** 得到客户端的信息
* @return string
*/
function getClintInfo(){return mysql_get_client_info();
}
/** 得到 MYSQL 服务器端的信息
* @return string
*/
function getServerInfo($link=null){return mysql_get_server_info($link);
}
/** 得到主机的信息
* @return string
*/
function getHostInfo($link=null){return mysql_get_host_info($link);
}
/** 得到协议信息
* @return string
*/
function getProtoInfo($link=null){return mysql_get_proto_info($link);
}
}
?>
<?php define('DB_HOST', 'localhost'); define('DB_USER', 'root'); define('DB_PWD', 'ybzl1234'); define('DB_CHARSET', 'UTF8'); define('DB_DBNAME', 'jpbaike');
?>
<?php
$db = new mysql();
$link = $db->connect2();
$sql = "SELECT * FROM baike WHERE id ='".$id."'";
$rs = $db->fetchAll($sql);
$rs =$rs[0];
if (empty($rs)) {
$dataout = $datax;
$db->insert($dataout,"baike");
}
else { $dataout=$rs;
} ?>
正文完
发表至: PHP代码
2017-09-11