偶前段时间写的数据库类,希望有用
<? /* 数据库类,适用于多种数据库:Mysql,Psql,Mssql */ class database { var $databaseType,$host,$userName,$password,$db; /* 构造函数 */ function database($databaseType,$host,$userName,$password,$db) { $this->databaseType=$databaseType; $this->host=$host; $this->userName=$userName; $this->password=$password; $this->db=$db; } /* 连接数据库函数 */ function connectDB() { switch($this->databaseType) { case("psql"): $conn_string="host=".$this->host." dbname=".$this->db." user=".$this->userName." password=".$this->password; return pg_connect($conn_string); break; case("mysql"): return mysql_connect($this->host,$this->userName,$this->password); break; case("mssql"): return mssql_connect($this->host,$this->userName,$this->password); break; //default: // return -1; //Invalid Databasethis->databaseType; // break; } } /* 选择相关的数据库函数 */ function selectDB($db) { switch($this->databaseType) { case("psql"): return 1; break; case("mysql"): return mysql_select_db($db); break; case("mssql"): return mssql_select_db($db); break; //default: // return -1; //Invalid Databasedb; // break; } } /* 查询相关的数据库记录 */ function queryDB($query) { switch($this->databaseType) { case("psql"): if(!$result=@pg_exec($query)) $result=0; break; case("mysql"): if(!$result=@mysql_query($query)) $result=0; break; case("mssql"): if(!$result=@mssql_query($query)) $result=0; break; //default: // return -1; //Invalid Databasedb; // break; } return $result; } /* 把查询后的结果处理后存入相关数组的函数 */ function return_fetch_array($result) { switch($this->databaseType) { case("psql"): if(!$array=@pg_fetch_array($result)) $array=0; break; case("mysql"): if(!$array=@mysql_fetch_array($result)) $array=0; break; case("mssql"): if(!$array=@mssql_fetch_array($result)) $array=0; break; //default: // return -1; //Invalid Database:$db; // break; } return $array; } /* 返回查询结果的记录数函数 */ function return_num_rows($result) { switch($this->databaseType) { case("psql"): if(!$rows=@pg_numrows($result)) return 0; else return $rows; break; case("mysql"): if(!$rows=@mysql_num_rows($result)) return 0; else return $rows; break; case("mssql"): if(!$rows=@mssql_num_rows($result)) return 0; else return $rows; break; //default: // return -1; //Invalid Database:$db; // break; } } function closeDB($dbconn) { switch($this->databaseType) { case("psql"): if(!@pg_close($dbconn)) return 0; else return 1; break; case("mysql"): if(!@mysql_close($dbconn)) return 0; else return 1; break; case("mssql"): if(!@mssql_close($dbconn)) return 0; else return 1; break; //default: // return -1; //Invalid Database:$db; // break; } } } ?>
|