面向对象的mysql数据库操作php类.zip

<?php class database { var $host = NULL; var $username = NULL; var $password = NULL; var $databaseName = NULL; var $link = NULL; var $queries = NULL; var $errors = NULL; var $databaseExtras = NULL; function __construct($host, $username, $password, $database) { $this->database($host, $username, $password, $database); } function database($host, $username, $password, $database) { /*$this->database = array ( "host" => $host, "username" => $username, "password" => $password, "database" => $database, "link" => "", "queries" => array (), "errors" => array () );*/ $this->host = $host; $this->username = $username; $this->password = $password; $this->databaseName = $database; $this->link = ""; $this->queries = array (); $this->errors = array (); $this->databaseExtras = new stdClass; $this->link = mysql_connect($this->host, $this->username, $this->password) or die("Could not connect to Database"); mysql_select_db($this->databaseName); } function justquery($sql) { $this->queries[] = $sql; return mysql_query($sql, $this->link); } function loadResult($sql) { if (!($cur = $this->justquery($sql))) { return null; } $ret = null; if ($row = mysql_fetch_row( $cur )) { $ret = $row[0]; } mysql_free_result( $cur ); return $ret; } function loadFirstRow($sql) { if (!($cur = $this->justquery($sql))) { return null; } $ret = null; if ($row = mysql_fetch_object( $cur )) { $ret = $row; } mysql_free_result( $cur ); return $ret; } function insertid() { return mysql_insert_id( $this->link ); } function query($sql, $key = "", $returns = true, $batch = false) { $result = array (); switch ($batch) { default: case true: foreach ($sql as $index => $query) { $this->queries[] = $query; $answer = mysql_query($query, $this->link); if (!$answer) { $this->errors[] = mysql_error($this->link); } else { if ($returns != false) { if (mysql_num_rows($answer) > 0){ while ($row = mysql_fetch_object($answer)) { if ($key != ""){ $result[$index][$row->$key] = $row; } else { $result[$index][] = $row; } } } else {} } else {} } } break; case false: $this->queries[] = $sql; $answer = mysql_query($sql, $this->link); if (!$answer) { $this->errors[] = mysql_error($this->link); $result = false; } else { if ($returns != false) { if (mysql_num_rows($answer) > 0){ while ($row = mysql_fetch_object($answer)) { if ($key != ""){ $result[$row->$key] = $row; } else { $result[] = $row; } } } else {} } else { $result = true; } } break; } return $result; } function loadObject( $sql, &$object ) { if ($object != null) { if (!($cur = $this->justquery($sql))) { return false; } else {} if ($array = mysql_fetch_assoc( $cur )) { mysql_free_result( $cur ); $this->bindArrayToObject( $array, $object); return true; } else { return false; } } else { if ($cur = $this->justquery($sql)) { if ($object = mysql_fetch_object( $cur )) { mysql_free_result( $cur ); return true; } else { $object = null; return false; } } else { return false; } } } function bindArrayToObject( $array, &$obj) { if (!is_array( $array ) || !is_object( $obj )) { return (false); } foreach (get_object_vars($obj) as $k => $v) { if( substr( $k, 0, 1 ) != '_' ) { $ak = $k; if (isset($array[$ak])) { $obj->$k = $array[$ak]; } } } return true; } function formatCSVCell($data) { $useQuotes = false; $quotable = array ( "\"" => "\"\"", "," => ",", "\n" => "\n" ); foreach ($quotable as $char => $repl) { if (eregi($char, $data)) { $useQuotes = true; } else {} } if ($useQuotes == true) { foreach ($quotable as $char => $repl) { $data = str_replace($char, $repl, $data); } $data = "\"" . $data . "\""; } else { } return $data; } } ?>