本文分享一个好用的php与mysql操作类,此mysql类与其它类的不同在于,可以设置表的读、写锁。有需要的朋友参考下吧。
分享一个php与mysql操作类,代码: <?php /** * mysql操作类 * by bbs.it-home.org */ // 定义常量 /** * 是否开启调试模式 */ define("DEBUG", FALSE); /** * 以下变量不要改动 */ /** * 设定表的读锁 */ define("LOCKED_FOR_READ", "READ"); /** * 设定表的写锁 */ define("LOCKED_FOR_WRITE", "WRITE"); /** * HOWTO */ class mySQL { /** * The connection resource id * * @var object */ var $connection; /** * The selected database * * @var object */ var $selectedDb; /** * The result from a select-query * * @var object */ var $result; /** * Flag that tells if you are connected to the database or not * * @var boolean */ var $isConnected; /** * Flag that tells if you the tables are locked or not * * @var boolean */ var $isLocked; /** *This will indicate what querytype the last query was * * @var string */ var $queryType; /** * This is the constructor of this mysql class. * It creates a connection to the database, and if possible it sets the database to * You can specify if you want to use persistant connections or not. * * @param string The host to the mySQL server * @param string The username you use to log on to the mySQL server * @param string The password you use to log on to the mySQL server * @param string The name of the database you wish to use * @param boolean TRUE if you want to use persistant connections. Default is TRUE * @return boolean TRUE when connection was successfull * @access public */ function mySQL($sHost, $sUser, $sPassword, $sDatabase="", $bPersistant=TRUE) { $conFunc = ""; if(!defined("DEBUG")) { define("DEBUG", FALSE); } if($this->getConnected()) { $this->closeConnection(); } if($this->connection = ($bPersistant ? mysql_pconnect($sHost, $sUser, $sPassword) : mysql_connect($sHost, $sUser, $sPassword))) { $this->setConnected(TRUE); if($sDatabase) { $this->setDb($sDatabase); } return TRUE; } else { $this->setConnected(FALSE); return FALSE; } } /** * This is the destructor of this class. It frees the result of a query, * it unlocks all locked tables and close the connection to the database * It does not return anything at all, so you will not know if it was sauccessfull * * @access public */ function _mySQL() { if($this->result) { $this->freeResult(); } if($this->getLocked()) { $this->unlock(); } if($this->getConnected()) { $this->closeConnection(); } } /** * This function frees the result from a query if there is any result. * * @access public */ function freeResult() { if($this->result) { @mysql_free_result($this->result); } } /** * This function executes a query to the database. * The function does not return the result of the query, you must call the * function getQueryResult() to fetch the result * * @param string The query-string to execute * @return boolean TRUE if the query was successfull * @access public */ function query($query) { if(strlen(trim($query)) == 0) { $this->printError("No query got in function query()"); return FALSE; } if(!$this->getConnected()) { $this->printError("Not connected in function query()"); return FALSE; } $queryType = substr(trim($query), 0, strpos($query, " ")); $this->setQueryType($queryType); $this->result = mysql_query($query, $this->connection); if($this->result) { return TRUE; } return FALSE; } /** * Sets the querytype of the last query executed * For example it can be SELECT, UPDATE, DELETE etc. * * @access private */ function setQueryType($type) { $this->queryType = strtoupper($type); } /** * Returns the querytype * * @return string * @access private */ function getQueryType() { return $this->queryType; } /** * This function returns number of rows got when executing a query * * @return mixed FALSE if there is no query-result. * If the queryType is SELECT then it will use the function MYSQL_NUM_ROWS * Otherwise it uses the MYSQL_AFFECTED_ROWS * @access public */ function getNumRows() { if($this->result) { if(DEBUG==TRUE) { print("<font style=\"background-color: red\">".$this->getQueryType()."</font><br>"); } return mysql_affected_rows($this->connection); } return FALSE; } /** * The function returns the result from a call to the query() function * * @return object * @access public */ function getQueryResult() { return $this->result; } /** * This function returns the query result as an array for each row in the query result * * @return array * @access public */ function fetchArray() { if($this->result) { return mysql_fetch_array($this->result); } return FALSE; } /** * This function returns the query result as an object for each row in the query result * * @return object * @access public */ function fetchObject() { if($this->result) { return mysql_fetch_object($this->result); } return FALSE; } /** * This function returns the query result as an array for each row in the query result * * @return array * @access public */ function fetchRow() { if($this->result) { return mysql_fetch_row($this->result); } return FALSE; } /** * This function sets the database * * @return boolean TRUE if the database was set * @access public */ function setDb($sDatabase) { if(!$this->getConnected()) { $this->printError("Not connected in function setDb()"); return FALSE; } if($this->selectedDb = mysql_select_db($sDatabase, $this->connection)) { return TRUE; } return FALSE; } /** * This function returns a flag so you can see if you are connected to the database * or not * * @return boolean TRUE when connected to the database * @access public */ function getConnected() { return $this->isConnected; } /** * This function sets the flag so you can see if you are connected to the database * * @param $bStatus The status of the connection. TRUE if you are connected, * FALSE if you are not * @access public */ function setConnected($bStatus) { $this->isConnected = $bStatus; } /** * The function unlocks tables if there are locked tables and the closes the * connection to the database. * * @access public */ function closeConnection() { if($this->getLocked()) { $this->unlock(); } if($this->getConnected()) { mysql_close($this->connection); $this->setConnected(FALSE); } } /** * Unlocks all tables that are locked * * @access public */ function unlock() { if(!$this->getConnected()) { $this->setLocked(FALSE); } if($this->getLocked()) { $this->query("UNLOCK TABLES"); $this->setLocked(FALSE); } } /** * This function locks the table(s) that you specify * The type of lock must be specified at the end of the string. * * @param string a string containing the table(s) to lock, * as well as the type of lock to use (READ or WRITE) * at the end of the string * @return boolean TRUE if the tables was successfully locked * @access private */ function lock($sCommand) { if($this->query("LOCK TABLE ".$sCommand)) { $this->setLocked(TRUE); return TRUE; } $this->setLocked(FALSE); return FALSE; } /** * This functions sets read lock to specified table(s) * * @param string a string containing the table(s) to read-lock * @return boolean TRUE on success */ function setReadLock($sTable) { return $this->lock($sTable." ".LOCKED_FOR_READ); } /** * This functions sets write lock to specified table(s) * * @param string a string containing the table(s) to read-lock * @return boolean TRUE on success */ function setWriteLock($sTable) { return $this->lock($sTable." ".LOCKED_FOR_WRITE); } /** * Sets the flag that indicates if there is any tables locked * * @param boolean The flag that will indicate the lock. TRUE if locked */ function setLocked($bStatus) { $this->isLocked = $bStatus; } /** * Returns TRUE if there is any locked tables * * @return boolean TRUE if there are locked tables */ function getLocked() { return $this->isLocked; } /** * Prints an error to the screen. Can be used to kill the application * * @param string The text to display * @param boolean TRUE if you want to kill the application. Default is FALSE */ function printError($text, $killApp=FALSE) { if($text) { print("<b>Error</b><br />".$text); } if($killApp) { exit(); } } /** * Display any mysql-error * * @return mixed String with the error if there is any error. * Otherwise it returns FALSE */ function getMysqlError() { if(mysql_error()) { return "<br /><b>Mysql Error Number ".mysql_errno()."</b><br />".mysql_error(); } return FALSE; } } ?> Copier après la connexion |