<?php
/**
* 操作数据库mysql 的类，完成增删改查的操作
*
*/
class ms_new_mysql {
private $dbHost;
private $dbUser;
private $dbPassword;
private $dbTable;
private $dbConn;
private $result;
private $sql;
private $pre;
private $coding;
private $pcon;
private $queryNum;
private static $daoImpl;
public function __construct($dbHost, $dbUser, $dbPassword, $dbTable, $pre, $coding, $pcon) {
$this->dbHost = $dbHost;
$this->dbUser = $dbUser;
$this->dbPassword = $dbPassword;
$this->dbTable = $dbTable;
$this->pre = $pre;
$this->coding = $coding;
$this->pcon = $pcon;
$this->connect();
$this->select_db($dbTable);
}
public function __clone() {
return self::$daoImpl;
}
public static function getDaoImpl($linkConfig) {
if (empty(self::$daoImpl)) {
self::$daoImpl = new ms_new_mysql($linkConfig['db']['dbhost'], $linkConfig['db']['dbuser'], $linkConfig['db']['dbpw'], $linkConfig['db']['dbname'], $linkConfig['db']['tablepre'], $linkConfig['db']['dbcharset'], $linkConfig['db']['pconnect']);
}
return self::$daoImpl;
}
public function connect() {
$func = $this->pcon == 1 ? "mysql_pconnect" : "mysql_connect";
//$this->dbConn = @$func($this->dbHost, $this->dbUser, $this->dbPassword);
$this->dbConn = mysql_connect($this->dbHost, $this->dbUser, $this->dbPassword, $this->pcon);
if (!$this->dbConn) {
$this->halt("不能链接数据库", $this->sql);
return false;
}
if ($this->version() > '4.1') {
$serverset = $this->coding ? "character_set_connection='$this->coding',character_set_results='$this->coding',character_set_client=binary" : '';
$serverset .= $this->version() > '5.0.1' ? ((empty($serverset) ? '' : ',') . " sql_mode='' ") : '';
$serverset && mysql_query("SET $serverset", $this->dbConn);
}
return $this->dbConn;
}
/**
* 选择一个数据库
*
* @param string $dbTable
* @return boolean
*/
public function select_db($dbTable) {
if (!@mysql_select_db($dbTable, $this->dbConn)) {
$this->halt("没有" . $dbTable . "这个数据库");
return false;
} else {
$this->dbTable = $dbTable;
return true;
}
}
/**
* 查询语句，传过来一个sql，执行，如果语句正确，返回结果集资源
*
* @param string $sql
* @param string $type
* @return Resouce query
*/
public function query($sql, $type = '') {
if ($query = mysql_query($sql, $this->dbConn)) {
$this->queryNum++;
return $query;
} else {
$this->halt("Mysql 查询出错", $sql);
return false;
}
}
/**
* 插入一组数据或一条数据
*
* @param string $tableName
* @param boolean
*/
public function insert($tableName, $info) {
$this->checkFields($tableName, $info);
$insert_sql = "INSERT INTO `$tableName`(`" . implode('`,`', array_keys($info)) . "`) VALUES('" . implode("','", $info) . "')";
return $this->query("$insert_sql");
}
/**
* 更细数据库中的数据
*
* @param string $tableName
* @param array $info
* @param string $where
* @return boolean
*/
public function update($tableName, $info, $where = '') {
$this->checkFields($tableName, $info);
if ($where) {
$sql = '';
foreach ($info as $k => $v) {
$sql .= ", `$k`='$v'";
}
$sql = substr($sql, 1);
$sql = "UPDATE `$tableName` SET $sql WHERE $where";
} else {
$sql = "REPLACE INTO `$tableName`(`" . implode('`,`', array_keys($info)) . "`) VALUES('" . implode("','", $info) . "')";
}
return $this->query($sql);
}
/**
* 检查一个字段是否在这张表中存在
*
* @param string $tableName
* @param array $array
* @return message
*/
public function checkFields($tableName, $array) {
$fields = $this->getFields($tableName);
foreach ($array as $key => $val) {
if (!in_array($key, $fields)) {
$this->halt("Mysql 错误", "找不到" . $key . "这个字段在" . $tableName . "里面");
return false;
}
}
}
/**
* 获取一张表中的所有字段
*
* @param string $tableName
* @return array fileds
*/
public function getFields($tableName) {
$fields = array();
$result = $this->query("SHOW COLUMNS FROM `$tableName`");
while ($list = $this->fetchArray($result)) {
$fields[] = $list['Field'];
}
$this->freeResult($result);
return $fields;
}
/**
* 释放当前数据库结果集的内存
*
* @param Resource $result
* @return null
*/
public function freeResult($result) {
return @mysql_free_result($result);
}
/**
* 使用while 可以迭代输出 一个结果集中的所有数据
*
* @param Resouce $query
* @param result type $result_type
* @return array
*/
public function fetchArray($query, $result_type = MYSQL_ASSOC) {
return mysql_fetch_array($query, $result_type);
}
/**
* 返回一个结果集中的一条数据
*
* @param $sql $query
* @param string $type
*
*
*/
public function getOne($sql, $type = '', $expires = 3600) {
$query = $this->query($sql, $type, $expires);
$rs = $this->fetchArray($query);
$this->freeResult($rs);
return $rs;
}
/**
* 获取插入的数据的返回的insetid
*
* @return insetid
*/
public function insertId() {
return mysql_insert_id($this->dbConn);
}
/**
* 获取当前的结果集中存在多少条数据
*
* @param string $query
* @return int nums
*/
public function numRows($query) {
return @mysql_numrows($query);
}
/**
* 获取当前的结果集中，有多少个字段
*
* @param Resouce $query
* @return int fields nums
*/
public function numFields($query) {
return @mysql_num_fields($query);
}
/**
* 获取当前执行的sql总条数
*
* @return queryNum
*/
public function getQueryNum() {
return $this->queryNum;
}
/**
* 获取当前文件中的函数,传入一个当前类存在函数，单例调用
*
* @param unknown_type $funcname
* @param unknown_type $params
* @return unknown
*/
public function getFunc($funcname, $params = '') {
if (empty($params)) {
return $this->$funcname();
} else {
return $this->$funcname($this->getFuncParams($params));
}
}
/**
* 如果是一个数组，那么拼接起来，处理返回一个参数集合
*
* @param array,string $params
* @return string a,d,3
*/
public function getFuncParams($params) {
$returnStr = "";
if (is_array($params)) {
foreach ($params as $key => $val) {
$returnStr .= $val . ",";
}
return rtrim($returnStr, ",");
} else {
return $params;
}
}
/**
* 获取当前数据库的版本信息
*
* @return version
*/
public function version() {
return mysql_get_server_info($this->dbConn);
}
/**
* 获取当前mysql数据的报错号
*
* @return errorno
*/
public function errno() {
return intval(@mysql_errno($this->dbConn));
}
/**
* 获取当前数据库的 提示信息
*
* @return unknown
*/
public function error() {
return @mysql_error($this->dbConn);
}
/**
* 操作数据库出错，提示信息
*
* @param unknown_type $message
* @param unknown_type $sql
*/
function halt($message = '', $sql = '') {
$this->errormsg = "<b>MySQL Query : </b>$sql <br /><b> MySQL Error : </b>" . $this->error() . " <br /> <b>MySQL Errno : </b>" . $this->errno() . " <br /><b> Message : </b> $message";
exit($this->errormsg);
}
function showTable() {
$tables = array();
$result = $this->query("SHOW TABLES");
while ($list = $this->fetchArray($result)) {
$tables[] = $list['Tables_in_' . $this->dbTable];
}
$this->freeResult($result);
return $tables;
}
}
$dbObj = new ms_new_mysql("127.0.0.1", "root", "", "", "", "utf-8", "0");
