学步园

<?php</p> <p>/**<br /> * Mysql DB<br /> *<br /> * @author Administrator<br /> * @package defaultPackage<br /> */<br /> class MySqlDB{<br /> private $_db;<br /> private static $_instance;<br /> private function __construct(&$db_type){<br /> global $connectionstr;<br /> $conn_db=$connectionstr[$db_type];<br /> $this->_db=mysql_pconnect($conn_db["servername"],$conn_db["usernmae"],$conn_db["pwd"]);<br /> if(!$this->_db){<br /> die("'Could not connect: ".mysql_error());<br /> }<br /> mysql_select_db($conn_db["dbname"],$this->_db);<br /> }<br /> private function __clone(){</p> <p> }<br /> public static function getInstance(&$db_type){<br /> if(!(self::$_instance instanceof self)){<br /> self::$_instance=new self($db_type);<br /> }<br /> return self::$_instance;<br /> }<br /> function query($sql){<br /> mysql_query("SET NAMES 'GBK'",$this->_db);<br /> return mysql_query($sql,$this->_db);<br /> }<br /> function get_result_sql($sql){<br /> return $this->query($sql);<br /> }<br /> /***根据sql，返回数组数据,有错误提示***/<br /> function getarray($sql){<br /> $result_ay=array();<br /> if($re=$this->query($sql)){<br /> while ($row=mysql_fetch_array($re)) {<br /> $result_ay[]=$row;<br /> }<br /> }<br /> else {<br /> js_msg("数据访问有错！",-1);<br /> }<br /> return $result_ay;<br /> }<br /> /***根据sql，返回数组数据***/<br /> function getarray_no_msg($sql){<br /> $result_ay=array();<br /> if($re=$this->query($sql)){<br /> while ($row=mysql_fetch_array($re)) {<br /> $result_ay[]=$row;<br /> //mysql_fetch_array,mysql_fetch_row,<br /> }<br /> }<br /> return $result_ay;<br /> }<br /> /***批量查询,字段相同，返回一数组***/<br /> function getarray_sqls($sql){<br /> $result_ay=array();<br /> if(is_array($sql)){<br /> //print_r($sql);<br /> foreach ($sql as $k=>$v){<br /> if($re=$this->query($v)){<br /> while ($row=mysql_fetch_array($re)) {<br /> $result_ay[]=$row;<br /> }<br /> }<br /> }<br /> }<br /> else {<br /> $result_ay=$this->getarray_no_msg($sql);<br /> }<br /> return $result_ay;<br /> }<br /> /**<br /> * 获取多个结果集<br /> *<br /> * @param array sqls<br /> * @return array<br /> */<br /> function getarrays_sqls($sql){<br /> $result_ay=array();<br /> if(is_array($sql)){<br /> foreach ($sql as $k=>$v){<br /> $temary=array();<br /> if($re=$this->query($v)){<br /> while ($row=mysql_fetch_array($re)) {<br /> $temary[]=$row;<br /> }<br /> }<br /> $result_ay[]=$temary;<br /> }<br /> }<br /> else {<br /> $result_ay=$this->getarray_no_msg($sql);<br /> }<br /> return $result_ay;<br /> }<br /> /***返回第一行第一列***/<br /> function ExecuteScalar($sql){<br /> if($re=$this->query($sql)){<br /> $row=mysql_fetch_row($re);<br /> return $row[0];<br /> }<br /> else {<br /> //echo $sql;<br /> die("sql执行错误！");<br /> }<br /> }<br /> /***执行Sql***/<br /> function ExecSql($sql,$IsLastId=false){<br /> if(is_array($sql)){<br /> //多条sql<br /> $t=0;//成功<br /> foreach ($sql as $k=>$v){<br /> if(!empty($v)){<br /> if($re=$this->query($v)){<br /> $t=$t+mysql_affected_rows();<br /> }<br /> }<br /> }<br /> return $t;<br /> }<br /> else{<br /> //执行单条sql<br /> if($re=$this->query($sql)){<br /> if($IsLastId){<br /> return $this->last_id($this->query("select last_insert_id()"));<br /> }<br /> else {<br /> return mysql_affected_rows();<br /> }<br /> }<br /> else {<br /> mysql_error();<br /> die("数据执行错误！");<br /> return 0;<br /> }<br /> }<br /> }<br /> function fetchrows($sql){<br /> $result_ay=array();<br /> if($re=$this->query($sql)){<br /> while ($row=mysql_fetch_array($re,MYSQL_ASSOC)) {<br /> $result_ay[]=$row;<br /> }<br /> }<br /> return $result_ay;<br /> }<br /> function last_id(&$re){<br /> $id=0;<br /> while ($row=mysql_fetch_row($re)){<br /> $id=$row[0];<br /> }<br /> return $id;<br /> }<br /> }<br /> ?>