데이터베이스 작업 PHP 클래스

 /*
 * 작성자 Molong
 * 시간 2010년 12월 2일 15:50:35
 */

 $db = new mysql($db_host,$db_user,$db_password,$db_table,$db_conn,$pre,$coding)

 class mysql{

 private $ db_host
 private $db_user;
 private $db_table;
 private $db_conn; //쿼리 명령 실행 결과; 🎜> private $sql; //sql 실행문
 private $pre; //데이터베이스 테이블 접두사
 private $coding; //데이터베이스 인코딩, GBK, UTF8, gb2312

 function __construct($ db_host,$db_user,$db_password,$db_table,$db_conn,$pre,$coding){

 $this->db_host = $db_host
 $this->db_user = $db_user;
 $this->db_password = $db_password;
 $this->db_table = $db_table; $this->db_conn = $db_conn; pre;
 $this->coding = $coding;
 $this->connect()

 함수 연결(){

 $this->db_conn = @mysql_connect($this->db_host,$this->db_user,$this->db_password) 또는 die($this->show_error("데이터베이스 링크 오류입니다. 확인해주세요) 데이터베이스 링크 구성! "));
 if(!mysql_select_db($this->db_table,$this->db_conn)){

 echo "데이터 테이블을 찾을 수 없습니다:".$this->db_table;
 }
 mysql_select_db($this->db_table,$this->db_conn)
 $this->query("SET NAMES $this->coding");

 /*SQL문을 실행하는 함수*/
 function query($sql){

 if(emptyempty($sql)){
 $this->show_error( "SQL 문은 비워둘 수 없습니다!");
 }else{
 $this->sql = $sql;
 }
 $result = mysql_query($this->sql,$this->db_conn);

 return $this->result = $result;
 }

 /*새 데이터베이스 생성 및 추가*/
 public function create_database($database_name){
 $database=$database_name;
 $sqlDatabase = '데이터베이스 생성'.$database;
 return $this->query($sqlDatabase)
 }

 // 쿼리 결과 기반 선택 시 결과 세트의 결과 수를 계산합니다
 public function db_num_rows(){
 if($this->result==null){
 if($this->show_error){
 $this-> ;show_error("SQL 문 오류!");
 }
 }else{
 return mysql_num_rows($this->result)
 }
 }

 / *서버의 모든 데이터베이스 쿼리*/
 //보다 직관적인 표시를 위해 시스템 데이터베이스와 사용자 데이터베이스를 분리하시겠습니까?
 public function show_databases(){
 $this-> ;query("데이터베이스 표시");
 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->db_conn );
 $i=0;
 $cnt=mysql_num_rows($rsPtr)
 while($i<$cnt)
 {
 $ rs[]=mysql_db_name($rsPtr, $i);
 $i ;
 }
 return print_r($rs)

 /*아래의 모든 테이블 쿼리 데이터베이스*/
 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_".$
 echo "$i $row[$columnName]"
 echo ""
 $i
 }
 } 🎜>
 /*
 mysql_fetch_row() 배열 $row[0],$row[1],$row[2]
 mysql_fetch_array() 배열 $row[0] 또는 $row[id]
 mysql_fetch_assoc() 배열 사용 $ row->content 필드는 대소문자를 구분합니다
 mysql_fetch_object() 객체는 $row[id]를 사용하고 $row[content] 필드는 대소문자를 구분합니다
 */
 /*레코드 세트 가져오기, 배열 인덱스 가져오기 및 연관 가져오기, $row['content'] 사용 */
 공개 함수 fetch_array()
 {
 return @mysql_fetch_array($this->result );
 }

 //연관 배열을 가져오고 $row['필드 이름']을 사용합니다.
 public function fetch_ass()
 {
 return @mysql_fetch_assoc($this- >result);
 }

 //숫자 인덱스 배열을 가져오고 $row[0],$row[1],$row[2] 사용
 공용 함수 fetch_row()
 {
 return @mysql_fetch_row($this-> ;result);
 }

 //객체 배열을 가져오고 $row->content 사용
 공용 함수 fetch_Object()
 {
 return @mysql_fetch_object($this-> ;result)
 }

 //간단화된 쿼리 select
 public function findall($table){
 $table = $this->fulltablename($table);
 $this->query("$table에서 * 선택");
 }

 공개 함수 select($table,$columnName ,$condition){
 $table = $this-> ;fulltablename($table);
 if(emptyempty($columnName)){
 $columnName = "*" }
 $this->query("SELECT $columnName FROM $table $condition")
 }

 //단순 삽입
 function insert($table,$arr){
 $table = $this->fulltablename($table);
 $sql = "$table에 삽입"
 if(!is_array($arr)){
 $this->show_error( "매개변수 배열을 입력해주세요!");
 }else{
 $k = "";
 $v = "";
 foreach($arr as $key => $value){
 $k . = "`$key`,";
 $v .= "'".$value."',"
 }
 }
 $sql = $sql." (".substr($k,0,-1).") VALUES (".substr($v,0,-1).")";
 $this->query($sql);
 }
 //완전한 업데이트
 function update($table,$arr,$where){
 $table = $this->fulltablename($table)
 $sql = "$table SET 업데이트";
 if(!is_array($arr)){
 $this->show_error("请输入参数数组！");
 }else{
 foreach($arr as $key => $value){
 $sql .= "`".$key."` = '".$value." ' ,";
 }
 }
 $sql = substr($sql,0,-1)." where ".$where;
 return $this->query($sql) ;
 }
 // 简化的delete
 function delete($table,$where = ""){
 $table = $this->fulltablename($table);
 if (emptyempty($where)){
 $this->show_error("조건 불능 为空!");
 }else{
 $where = " where ".$where;
 }
 $sql = "DELETE FROM $table ".$where;
 //echo $sql;
 return $this->query($sql);
 }

 // 획득上一步 INSERT 操作产生的ID
 public function insert_id(){
 return mysql_insert_id(); fulltablename($table){
 return $table = $this->pre.$table;
 }

 // 查询字段数量
 public function num_fields($table){
 $table = $this->fulltablename($table);
 $this->query("select * from $table");
 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 (); //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 协议信息

 default:
 return mysql_get_client_info(); // 默认 취득 mysql판본신식 > /*public function __destruct()
 {
 if(!empty($this->result)){
 $this->free();
 }
 mysql_close( $this->$db_conn);
 }*/

 /* 진득 객관단 진연적 IP 지자*/
 function getip(){
 if(getenv("HTTP_CLIENT_IP) ) && strcasecmp(getenv("HTTP_CLIENT_IP"), "unknown"))
 {
 $ip = getenv("HTTP_CLIENT_IP");
 }
 else if (getenv("HTTP_X_FOR strcasecmp(getenv("HTTP_X_FORWARDED_FOR"), "unknown")){
 $ip = getenv("HTTP_X_FORWARDED_FOR");
 }
 else if (getenv("REMOTE_ADDR") && 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 show_error($str){
 echo "";
 }

 }
 ?>


 复制代码







PHP