JHPHP框架，精小的PHP开发框架 PHP快速开发框架

<?php /* * * 作者：joyphper * 博客：www.joyphper.net * QQ：97142822 * Copyright (C) 2011 - 2011 joyphper.net * */ if (! defined ( 'App_PATH' ))exit ( 'request error' ); class mysql{ private $dbHost; private $dbPort; private $dbName; private $dbUser; private $dbPwd; private $dbprefix; private $language; private $queryString; private $linkID; private $result; public function __construct($conf) { $this->dbHost = $conf["Host"]; $this->dbPort = $conf["Port"]; $this->dbName = $conf["Database"]; $this->dbUser = $conf["User"]; $this->dbPwd = $conf["Pwd"]; $this->dbprefix = $conf["Prefix"]; $this->language = $conf["Language"]; $this->linkID = 0; $this->result = array (); $this->openMysql(); } private function openMysql() { $this->linkID = @mysql_connect ( $this->dbHost.":".$this->dbPort, $this->dbUser, $this->dbPwd ); if (! $this->linkID) { appFun::ERROR ( '系统错误警告：连接数据库失败，可能数据库密码不对或数据库服务器出错！' ); } $selectDb = @mysql_select_db ( $this->dbName ); if (! $selectDb) { appFun::ERROR( '系统错误警告：选择数据库失败，请确认' . $this->dbName . '是否存在' ); } @mysql_query ( "SET NAMES '" . $this->language . "', character_set_client=binary, sql_mode='', interactive_timeout=3600 ;", $this->linkID ); return true; } //设置SQL语句，会自动把SQL语句里的#_替换为$this->dbPrefix(在配置文件中为$cfg_dbprefix) public function setQuery($queryStr) { $prefix = "#_"; $queryStr = str_replace ( $prefix, $this->dbprefix, $queryStr ); $this->queryString = $queryStr; } //执行一个带返回结果的SQL语句，如SELECT，SHOW等 public function execute($sql = '', $id = 'me') { if (! empty ( $sql )) { $this->setQuery ( $sql ); } $this->result [$id] = mysql_query ( $this->queryString, $this->linkID ); if ($this->result [$id] === false) { appFun::ERROR ( '系统错误警告：' . $this->getError () . $sql . ' 执行错误' ); } } //boolean 执行一个不返回结果的SQL语句，如update,delete,insert等 public function execNoneQuery($queryStr = '') { if (! empty ( $queryStr )) { $this->setQuery ( $queryStr ); } else { return false; } return mysql_query ( $this->queryString, $this->linkID ); } //int 执行一个返回影响记录条数的SQL语句，如update,delete,insert等 public function execNoneQuery2($queryStr = '') { if (! empty ( $queryStr )) { $this->setQuery ( $queryStr ); } @mysql_query ( $this->queryString, $this->linkID ); return mysql_affected_rows ( $this->linkID ); } public function getArray($queryStr, $acctype = MYSQL_ASSOC) { $exeID=time(); $this->execute($queryStr,$exeID); if ($this->result [$exeID] == 0) { return false; } else { while(false!=($row=$this->fetch($exeID))) { $rows[]=$row; } return $rows; } } //返回当前的一条记录并把游标移向下一记录 // MYSQL_ASSOC、MYSQL_NUM、MYSQL_BOTH public function fetch($id = 'me', $acctype = MYSQL_ASSOC) { if ($this->result [$id] == 0) { return false; } else { return mysql_fetch_array ( $this->result [$id], $acctype ); } } //以对象的方式返回一条记录游标移向下一条记录 function fetchObject($id = "me") { if ($this->result [$id] == 0) { return false; } else { return mysql_fetch_object ( $this->result [$id] ); } } //执行一个SQL语句,返回前一条记录或仅返回一条记录 public function getOne($sql = '', $rtype="arr",$acctype = MYSQL_ASSOC) { if (! empty ( $sql )) { if (! eregi ( "limit", $sql )) { $this->setQuery ( eregi_replace ( "[,;]$", '', trim ( $sql ) ) . " limit 0,1;" ); } else { $this->setQuery ( $sql ); } } $this->execute ( $this->queryString, 'one' ); if (!$this->result ["one"]) { return false; } else { if($rtype=="arr") { $arr = $this->fetch( 'one', $acctype ); @mysql_free_result ( $this->result ["one"] ); return $arr; } elseif($rtype=="obj") { $obj= $this->fetchObject("one"); @mysql_free_result ( $this->result ["one"] ); return $obj; } else { appFun::ERROR ( '错误类型：' . $rtype ); } } } //获取记录条数 public function getNumRows($id = 'me') { if ($this->result [$id] == 0) { return 0; } else { return mysql_num_rows ( $this->result [$id] ); } } //获取上一步INSERT操作产生的ID public function getInsertId() { return @mysql_insert_id ( $this->linkID ); } //释放记录集占用的资源 public function freeResult($id = "me") { @mysql_free_result ( $this->result [$id] ); } //释放所有记录集占用的资源 public function freeResultAll() { if (! is_array ( $this->result )) { $this->freeResult (); } foreach ( $this->result as $vv ) { if ($vv) { @mysql_free_result ( $vv ); } } } //事物回滚 public function transaction() { mysql_query("START TRANSACTION;", $this->linkID); mysql_query("SET AUTOCOMMIT=0;", $this->linkID); } public function commit() { mysql_query("COMMIT;", $this->linkID); } public function rollback() { mysql_query("ROLLBACK;", $this->linkID); } //获取mysql执行错误 public function getError() { return mysql_error () . ':' . mysql_errno (); } //关闭连接 public function closeMysql() { return mysql_close ( $this->linkID ); } } ?>