connect_error) { echo "Connection Database error: ".$sql->connect_error; return null; } $global_sql->query("SET NAMES 'utf8'"); $global_sql->query("USE ".$_SESSION["DB_NAME"]); return $global_sql; } // class SQLSelect // { // private $field_array=null; // // private $where=null; // private $limit_start=0; // private $limit_count=0; // // public // };//class SQLSelect // // class SQLTable // { // private $sql=null; // private $table_name=null; // private $insert_id=0; // // private $field_array=null; // // public function __construct($s,$tn) // { // $this->sql=$s; // $this->table_name=$tn; // } // // public function get_field_list() // { // if($field_array) // return $field_array; // // $sql_result=$this->sql->query("DESC ".$this->table_name); // // if(!$sql_result) // return null; // // $this->field_list=array(); // while ($row = $sql_result->fetch_object()) // $this->field_list[] = $row->Field; // // return $this->field_list; // } // };//class SQLTable // // class SQLConnect // { // private $sql=null; // // public function __construct() // { // $sql=get_sql(); // } // // public function OpenTable($table_name) // { // if(!$sql) // return(null); // // return(new SQLTable($sql,$table)); // } // };//class SQLConnect function get_field_list($sql,$table_name) { if($sql==null)return null; $sql_result=$sql->query("DESC ".$table_name); if(!$sql_result) return null; $field_array=array(); while ($row = $sql_result->fetch_object()) $field_array[] = $row->Field; return $field_array; } function select_table()//$sql,$table_name,$field_array,$where,$start,$count) { $sql =func_get_arg(0); $table_name =func_get_arg(1); $field_array =func_get_arg(2); if(func_num_args()>3)$where=func_get_arg(3);else $where=null; if(func_num_args()>4) { $start=func_get_arg(4); $count=func_get_arg(5); } else { $start=0; $count=0; } if($sql==null)return; $sql_string="SELECT"; if($field_array==null) { $sql_string=$sql_string." * FROM ".$table_name; } else { for($i=0;$i3) $sql_string=$sql_string." WHERE ".$where; if($count!=0)$sql_string=$sql_string." LIMIT ".$start.",".$count; $sql_result=$sql->query($sql_string); if($sql_result) return $sql_result; echo 'SQL Query error,SQLString: '.$sql_string.'
'; echo 'SQL Error: '.$sql->error; return null; } function select_table_to_array()//$sql,$table_name,$field_array,$where,$start,$count) { $sql =func_get_arg(0); $table_name =func_get_arg(1); $field_array =func_get_arg(2); if(func_num_args()>3)$where=func_get_arg(3); if(func_num_args()>4) { $start=func_get_arg(4); $count=func_get_arg(5); } else { $start=0; $count=0; } $sql_result=select_table($sql,$table_name,$field_array,$where,$start,$count); if(!$sql_result)return(null); $result=array(); $index=0; while($row=$sql_result->fetch_row()) { $result[$index]=$row; $index++; } $sql_result->close(); return $result; } function select_field($sql,$table_name,$field,$where) { if($sql==null)return; $sql_string="SELECT ".$field." FROM ".$table_name." WHERE ".$where; $sql_result=$sql->query($sql_string); if(!$sql_result) return null; $row=$sql_result->fetch_object(); $sql_result->close(); return $row; } /** * 向一个表中插入数据，使用array的kv模式表示字段和数据 */ function sql_insert()//$sql,$table_name,$data_array) { $sql=func_get_arg(0); if($sql==null)return null; $table_name=func_get_arg(1); $data_array=func_get_arg(2); if(func_num_args()==4) $resultmode=func_get_arg(3); else $resultmode=MYSQLI_STORE_RESULT; $sql_string="INSERT INTO ".$table_name." SET"; $count=0; foreach($data_array as $field=>$value) { if($count==0) $sql_string=$sql_string.' '.$field.'="'.$value.'"'; else $sql_string=$sql_string.','.$field.'="'.$value.'"'; ++$count; } $sql_result=$sql->query($sql_string); if($sql_result) return $sql_result; echo 'SQL Insert error,SQLString: '.$sql_string.'
'; echo 'SQL Error: '.$sql->error; return null; } /** * 向一个表中插入数据，字段数据来自于post */ function sql_insert_by_post()//$sql,$table_name,$field_array [,$resultmode=MYSQLI_STORE_RESULT]) { $sql=func_get_arg(0); if($sql==null)return null; $data_array=array(); $table_name=func_get_arg(1); $field_array=func_get_arg(2); if(func_num_args()==4) $resultmode=func_get_arg(3); else $resultmode=MYSQLI_STORE_RESULT; foreach($field_array as $field) { if(isset($_POST[$field])&&strlen($_POST[$field])>0) $data_array[$field]=$_POST[$field]; } return sql_insert($sql,$table_name,$data_array,$resultmode); } function sql_update($sql,$table_name,$where,$field_array) { if(!$sql)return null; if(!$where||strlen($where)<3)return null; if(!$field_array||!is_array($field_array)||count($field_array)<=0)return null; $sql_string='UPDATE '.$table_name.' SET '; $first_field=true; foreach($field_array as $field=>$value) { if(!$first_field) $sql_string.=','; else $first_field=false; $sql_string.=$field.'="'.$value.'"'; } $sql_string.=" WHERE ".$where; // echo 'SQL Update SQLString: '.$sql_string.'
'; $sql_result=$sql->query($sql_string); if($sql_result) return $sql_result; echo 'SQL Update error,SQLString: '.$sql_string.'
'; echo 'SQL Error: '.$sql->error; return null; } function sql_update_by_post($sql,$table_name,$where,$field_array) { if(!$sql)return null; if(!$where||strlen($where)<3)return null; if(!$field_array||!is_array($field_array)||count($field_array)<=0)return null; $data_array=array(); foreach($field_array as $field) { if(isset($_POST[$field])&&strlen($_POST[$field])>0) $data_array[$field]=$_POST[$field]; } return sql_update($sql,$table_name,$where,$data_array); } function sql_get_field_term($sql,$table_name,$field,$term,$where) { if(!$sql)return null; if($where) $sql_result=$sql->query("select ".$term."(".$field.") from ".$table_name." where ".$where); else $sql_result=$sql->query("select ".$term."(".$field.") from ".$table_name); $result=$sql_result->fetch_row(); $sql_result->close(); return $result[0]; } function sql_get_field_min($sql,$table_name,$field,$where) { return sql_get_field_term($sql,$table_name,$field,"MIN",$where); } function sql_get_field_max($sql,$table_name,$field,$where) { return sql_get_field_term($sql,$table_name,$field,"MAX",$where); } function sql_get_field_count($sql,$table_name,$field,$where) { return sql_get_field_term($sql,$table_name,$field,"COUNT",$where); } function sql_get_field_sum($sql,$table_name,$field,$where) { return sql_get_field_term($sql,$table_name,$field,"SUM",$where); } function sql_get_field_avg($sql,$table_name,$field,$where) { return sql_get_field_term($sql,$table_name,$field,"AVG",$where); } function sql_get_field_distinct($sql,$table_name,$field) { if(!$sql)return null; $sql_result=$sql->query("select DISTINCT(".$field.") from ".$table_name.' ORDER BY '.$field); $result=array(); while($obj=$sql_result->fetch_row()) array_push($result,$obj[0]); $sql_result->close(); return $result; } ?>