PHP class to operate mysql

[PHP] code

class mysql {
 private $db_host; //Database host
 private $db_user; //Database username
 private $db_pwd; //Database username and password
 private $db_database; //Database Name
 private $conn; //Database connection identification;
 private $result; //Result identification of query command execution
 private $sql; //SQL execution statement
 private $row; //Number of entries returned
 private $ coding; //Database encoding, GBK, UTF8, gb2312
 private $bulletin = true; //Whether to enable error logging
 private $show_error = false; //During the test phase, all errors are displayed, which has security risks and is closed by default
 private $ is_error = false; //Whether to terminate immediately when an error is detected, the default is true, it is recommended not to enable it, because it is very distressing for users to not see anything when there is a problem

 /*Constructor*/
 public function __construct($db_host, $db_user, $db_pwd, $db_database, $conn, $coding) {
 $this->db_host = $db_host;
 $this->db_user = $db_user;
 $this->db_pwd = $db_pwd;
 $this->db_database = $db_database;
 $this->conn = $conn;
 $this->coding = $coding;
 $this->connect();
 }

 /*Database connection */
 public function connect() {
 if ($this->conn == "pconn") {
 //Permanent link
 $this->conn = mysql_pconnect($this->db_host, $this- >db_user, $this->db_pwd);
 } else {
 //Even if the link is
 $this->conn = mysql_connect($this->db_host, $this->db_user, $this-> db_pwd);
 }

 if (!mysql_select_db($this->db_database, $this->conn)) {
 if ($this->show_error) {
 $this->show_error("Database is not available Use: ", $this->db_database);
 }
 }
 mysql_query("SET NAMES $this->coding");
 }

 /*Database execution statement, executable query, add, modify, delete, etc. any sql Statement*/
 public function query($sql) {
 if ($sql == "") {
 $this->show_error("SQL statement error:", "SQL query statement is empty");
 }
 $this->sql = $sql;

 $result = mysql_query($this->sql, $this->conn);

 if (!$result) {
 //Used in debugging, sql statement When an error occurs, it will be printed out automatically
 if ($this->show_error) {
 $this->show_error("Error SQL statement: ", $this->sql);
 }
 } else {
 $this- >result = $result;
 }
 return $this->result;
 }

 /*Create and add a new database*/
 public function create_database($database_name) {
 $database = $database_name;
 $sqlDatabase = 'create database ' . $database;
 $this->query($sqlDatabase);
 }

 /*Query all databases on the server*/
 //Separate the system database from the user database for a more intuitive display?
 public function show_databases() {
 $this->query("show databases");
 echo "Existing database:" . $amount = $this->db_num_rows($rs);
 echo "";
 $i = 1;
 while ($row = $this->fetch_array($rs)) {
 echo "$i $row[Database]";
 echo " ";
 $i++;
 }
 }

 //Return all database names in the host as an array
 public function databases() {
 $rsPtr = mysql_list_dbs($this->conn);
 $i = 0;
 $cnt = mysql_num_rows($rsPtr);
 while ($i < $cnt) {
 $rs[] = mysql_db_name($rsPtr, $i);
 $i++;
 }
 return $rs;
 }

 /*Query all tables under the database*/
 public function show_tables($database_name) {
 $this->query("show tables");
 echo "Existing database:" . $amount = $this-> ;db_num_rows($rs);
 echo "";
 $i = 1;
 while ($row = $this->fetch_array($rs)) {
 $columnName = "Tables_in_" . $database_name;
 echo "$i $row[$columnName]";
 echo "";
 $i++;
 }
 }

 /*
 mysql_fetch_row() array $row[0], $row[1],$row[2]
 mysql_fetch_array() array $row[0] or $row[id]
 mysql_fetch_assoc() array uses $row->content field case sensitivity
 mysql_fetch_object() object uses $ row[id],$row[content] fields are case-sensitive
 */

 /*Get result data*/
 public function mysql_result_li() {
 return mysql_result($str);
 }

 /*Get record set , Get array-index and association, use $row['content'] */
 public function fetch_array($resultt="") {
 if($resultt<>""){
 return mysql_fetch_array($resultt);
 }else{
 return mysql_fetch_array($this->result);
 }
 }

 //Get the associative array, use $row['field name']
 public function fetch_assoc() {
 return mysql_fetch_assoc($this ->result);
 }

 //Get the numeric index array, use $row[0],$row[1],$row[2]
 public function fetch_row() {
 return mysql_fetch_row($this-> ;result);
 }

 //Get the object array, use $row->content
 public function fetch_Object() {
 return mysql_fetch_object($this->result);
 }

 //Simplify query select
 public function findall($table) {
 $this->query("SELECT * FROM $table");
 }

 //Simplified query select
 public function select($table, $columnName = "*", $ condition = '', $debug = '') {
 $condition = $condition ? ' Where ' . $condition : NULL;
 if ($debug) {
 echo "SELECT $columnName FROM $table $condition";
 } else {
 $this->query("SELECT $columnName FROM $table $condition");
 }
 }

 //Simplified deletion del
 public function delete($table, $condition, $url = '') {
 if ($this->query("DELETE FROM $table WHERE $condition")) {
 if (!empty ($url))
 $this->Get_admin_msg($url, 'Delete successfully! ');
 }
 }

 //Simplify insert
 public function insert($table, $columnName, $value, $url = '') {
 if ($this->query("INSERT INTO $table ($columnName) VALUES ($value)")) {
 if (!empty ($url))
 $this->Get_admin_msg($url, 'Added successfully!');
        }
    }

    //简化修改update
    public function update($table, $mod_content, $condition, $url = '') {
        //echo "UPDATE $table SET $mod_content WHERE $condition"; exit();
        if ($this->query("UPDATE $table SET $mod_content WHERE $condition")) {
            if (!empty ($url))
                $this->Get_admin_msg($url);
        }
    }

    /*取得上一步 INSERT 操作产生的 ID*/
    public function insert_id() {
        return mysql_insert_id();
    }

    //指向确定的一条数据记录
    public function db_data_seek($id) {
        if ($id > 0) {
            $id = $id -1;
        }
        if (!@ mysql_data_seek($this->result, $id)) {
            $this->show_error("SQL语句有误：", "指定的数据为空");
        }
        return $this->result;
    }

    // 根据select查询结果计算结果集条数
    public function db_num_rows() {
        if ($this->result == null) {
            if ($this->show_error) {
                $this->show_error("SQL语句错误", "暂时为空，没有任何内容！");
            }
        } else {
            return mysql_num_rows($this->result);
        }
    }

    // 根据insert,update,delete执行结果取得影响行数
    public function db_affected_rows() {
        return mysql_affected_rows();
    }

    //输出显示sql语句
    public function show_error($message = "", $sql = "") {
        if (!$sql) {
            echo "" . $message . "";
            echo "";
        } else {
            echo "";
            echo "错误信息提示:";
            echo "";
            echo "";
            echo "错误号：12142";
            echo "

";

echo "

" . $sql . "

";

$ip = $this->getip();

if ($this->bulletin) {

$time = date("Y-m-d H:i:s");

$message = $message . "\r\n$this->sql" . "\r\n客户IP:$ip" . "\r\n时间 :$time" . "\r\n\r\n";

$server_date = date("Y-m-d");

$filename = $server_date . ".txt";

$file_path = "error/" . $filename;

$error_content = $message;

//$error_content="错误的数据库，不可以链接";

$file = "error"; //设置文件保存目录

//建立文件夹

if (!file_exists($file)) {

if (!mkdir($file, 0777)) {

//默认的 mode 是 0777，意味着最大可能的访问权

die("upload files directory does not exist and creation failed");

}

}

//建立txt日期文件

if (!file_exists($file_path)) {

//echo "建立日期文件";

fopen($file_path, "w+");

//首先要确定文件存在并且可写

if (is_writable($file_path)) {

//使用添加模式打开$filename，文件指针将会在文件的开头

if (!$handle = fopen($file_path, 'a')) {

echo "不能打开文件 $filename";

exit;

}

//将$somecontent写入到我们打开的文件中。

if (!fwrite($handle, $error_content)) {

echo "不能写入到文件 $filename";

exit;

}

//echo "文件 $filename 写入成功";

echo "——错误记录被保存!";

//关闭文件

fclose($handle);

} else {

echo "文件 $filename 不可写";

}

} else {

//首先要确定文件存在并且可写

if (is_writable($file_path)) {

//使用添加模式打开$filename，文件指针将会在文件的开头

if (!$handle = fopen($file_path, 'a')) {

echo "不能打开文件 $filename";

exit;

}

//将$somecontent写入到我们打开的文件中。

if (!fwrite($handle, $error_content)) {

echo "不能写入到文件 $filename";

exit;

}

//echo "文件 $filename 写入成功";

echo "——错误记录被保存!";

//关闭文件

fclose($handle);

} else {

echo "文件 $filename 不可写";

}

}

}

echo "
";

if ($this->is_error) {

exit;

}

}

echo "";

echo "";

echo "
";

}

//释放结果集

public function free() {

@ mysql_free_result($this->result);

}

//数据库选择

public function select_db($db_database) {

return mysql_select_db($db_database);

}

//查询字段数量

public function num_fields($table_name) {

//return mysql_num_fields($this->result);

$this->query("select * from $table_name");

echo "
";

echo "字段数：" . $total = mysql_num_fields($this->result);

echo "

";</li>
<li>        for ($i = 0; $i < $total; $i++) {<li>            print_r(mysql_fetch_field($this->result, $i));</li>
<li>        }</li>
<li>        echo "

";

echo "
";

}

//取得 MySQL 服务器信息

public function mysql_server($num = '') {

switch ($num) {

case 1 :

return mysql_get_server_info(); //MySQL 服务器信息

break;

case 2 :

return mysql_get_host_info(); //取得 MySQL 主机信息

break;

case 3 :

return mysql_get_client_info(); //取得 MySQL 客户端信息

break;

case 4 :

return mysql_get_proto_info(); //取得 MySQL 协议信息

break;

default :

return mysql_get_client_info(); //默认取得mysql版本信息

}

}

//析构函数，自动关闭数据库,垃圾回收机制

public function __destruct() {

if (!empty ($this->result)) {

$this->free();

}

mysql_close($this->conn);

} //function __destruct();

/*获得客户端真实的IP地址*/

function getip() {

if (getenv("HTTP_CLIENT_IP") && strcasecmp(getenv("HTTP_CLIENT_IP"), "unknown")) {

$ip = getenv("HTTP_CLIENT_IP");

} else

if (getenv("HTTP_X_FORWARDED_FOR") &&strcasecmp(getenv("HTTP_X_FORWARDED_FOR"), "unknown")) {

$ip = getenv("HTTP_X_FORWARDED_FOR");

} else

if (getenv("REMOTE_ADDR") && strcasecmp(getenv("REMOTE_ADDR"), "unknown")) {

$ip = getenv("REMOTE_ADDR");

} else

if (isset ($_SERVER['REMOTE_ADDR']) && $_SERVER['REMOTE_ADDR'] &&strcasecmp($_SERVER['REMOTE_ADDR'], "unknown")) {

$ip = $_SERVER['REMOTE_ADDR'];

} else {

$ip = "unknown";

}

return ($ip);

}

function inject_check($sql_str) { //防止注入

$check =eregi('select|insert|update|delete|'|/*|*|../|./|union|into|load_file|outfile',$sql_str);

if ($check) {

echo "输入非法注入内容！";

exit ();

} else {

return $sql_str;

}

}

function checkurl() { //检查来路

if (preg_replace("/https?://([^:/]+).*/i", "\1", $_SERVER['HTTP_REFERER']) !== preg_replace("/([^:]+).*/", "\1", $_SERVER['HTTP_HOST'])) {

header("Location: http://www.dareng.com");

exit();

}

}

}

?>

复制代码

php, mysql