[PHP]代碼
-
class mysql {
- private $db_host; //資料庫主機
- private $db_user; //資料庫使用者名稱
- private $private $ ; //資料庫使用者名稱密碼
- private $db_database; //資料庫名稱
- private $conn; //資料庫連線識別;
- private $result; //執行query指令的結果資源識別碼
- private $sql; //sql執行語句
- private $row; //傳回的條目數
- private $coding; //資料庫編碼,GBK,UTF8,gb2312
- private $bulletin = true; //是否開啟錯誤記錄
- private $show_error = false; //測試階段,顯示所有錯誤,具有安全隱患,預設關閉
- private $is_error = false; //發現錯誤是否立即終止,預設true,建議不啟用,因為當有問題時使用者什麼也看不到是很苦惱的
-
- /*建構子*/
- 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();
- }
-
- /*資料庫連線*/
- public function connect() {
- if ($this->conn == "pconn") {
- //永久連結
- $this->conn = mysql_pconnect($this ->db_host, $this->db_user, $this->db_pwd);
- } else {
- //即使連結
- $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("資料庫不可用:", $this->db_database);
- }
- }
- mysql_query("SET NAMES $this->coding");
- }
-
- /*資料庫執行語句,可執行查詢新增修改刪除等任何sql語句*/
- public function query($sql) {
- if ($sql == "") {
- $this->show_error("SQL語句錯誤:", "SQL查詢語句為空");
- }
- $this->sql = $sql;
-
- $result = mysql_query($this->sql, $this->conn);
-
- if (!$result) {
- //調試中使用,sql語句出錯時會自動列印出來
- if ( $this->show_error) {
- $this->show_error("錯誤SQL語句:", $this->sql);
- }
- } else {
- $this->result = $ result;
- }
- return $this->result;
- }
-
- /*建立新增新的資料庫*/
- public function create_database($database_name) {
- $
- $ database = $database_name;
- $sqlDatabase = 'create database ' . $database;
- $this->query($sqlDatabase);
- }
-
- /*查詢伺服器所有資料庫*/ //將系統資料庫與使用者資料庫分開,更直覺的顯示?
- public function show_databases() {
- $this->query("show databases");
- echo "現有資料庫:" . $amount = $this->db_num_rows($rs);
- echo "
";
- $i = 1;
- while ($row = $this->fetch_array($rs)) {
- echo "$i $row[Database]";
- echo "
";
- $i ;
- }
- }
-
- //以陣列形式傳回主機中所有資料庫名稱
- public function databases() {
- $rsPtr = mysql_list_dbs($this->conn);
- $i = 0;
- $cnt = mysql_num_rows($rsPtr);
- while ($i $rs[] = mysql_db_name($rsPtr, $i);
- $i ;
- }
- return $rs;
- }
-
- /*查詢資料庫下所有的表*/
- public function show_tables($database_name) {
- $this->query("show tables");
- echo "現有資料庫:" . $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] 或$row[id]
- mysql_fetch_assoc() array用$row->content 欄位大小寫敏感
- mysql_fetch_object() object 用$row[id],$row[content] 欄位大小寫敏感
- */
-
- /*取得結果資料* /
- public function mysql_result_li() {
- return mysql_result($str);
- }
-
- /*取得記錄集,取得陣列-索引和關聯,使用$row['content' ] */
- public function fetch_array($resultt="") {
- if($resultt""){
- return mysql_fetch_array($resultt);
- }else{
- return mysql_fetch_array($this->result);
- }
- }
-
- //取得關聯陣列,使用$row['欄位名稱']
- public function fetch_assoc() {
- return mysql_fetch_assoc($this->result);
- }
-
- //取得數字索引陣列,使用$row[0],$row[1],$row[2]
- public function fetch_row() {
- return mysql_fetch_row($this->result);
- }
-
- //取得物件陣列,使用$row->content
- public function fetch_Object() {
- return mysql_fetch_object($this->result);
- }
-
- //簡化查詢select
- public function findall($table) {
- $this->query("SELECT * FROM $table");
- }
-
- //簡化查詢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");
- }
- }
-
- //簡化刪除del
- public function delete($table, $condition , $url = '') {
- if ($this->query("DELETE FROM $table WHERE $condition")) {
- if (!empty ($url))
- $this-> Get_admin_msg($url, '刪除成功! ');
- }
- }
-
- //簡化插入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, '加成功!');
- }
- }
-
- //简化修改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 "错误原因:" . mysql_error() . "
";
- echo "
";
- echo "" . $message . "";
- 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($
- }
-
- //查詢欄位數
- public function num_fields($table_name) {
- //return mysql_num_fields($this->result);
- $this->quesql_num_fields($this->result);
- $this->quesql( "select * from $table_name");
- echo "
";
- echo "字段數:" . $total = mysql_num_fields($this->result);
- echo "
- for ($i = 0; $i print_r(mysql_fetch_field($this->result, $i));
- }
- echo "";
- echo "
";
- }
-
- //取得MySQL 伺服器資訊
- public function mysql_server($num = '') {
- switch ($num) {
- case 1 :
- return mysql_get_server_info(); //MySQL 伺服器資訊
- break;
-
- case 2 :
- return mysql_getget_info(); //取得主機資訊
- break;
-
- case 3 :
- return mysql_get_client_info(); //取得MySQL 用戶端資訊
- break;
- case 客戶端資訊
- break;
- break;
- break;
- break;
- break;
- break;
- break;
- 。 (); //取得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")) {
- $ip = getenv("HTTP_CLIENT_IP"); if (getenv("HTTP_X_FORWARDED_FOR") &&strcasecmp(getenv("HTTP_X_FORWARDED_FOR"), "unknown")) {
- $ip = getenv("HTTP_X_FORWARDED_getOR"); $ip = getenv("REMOTE_ADDR");
- } else
- if (isset ($_SERVER['REMOTE_ADDR'] ) && $_SERVER['REMOTE_ADDR'] &&strcasecmp($_SERVER['REMOTE_ADDR'], "unknown")) {
- $ip = $_SERVER['REMOTE_ADDR'];
- } else {
- $ipipip = "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();
}