孤魂居

出自DISCUZ的PHP MYSQL操作类

Navicat for MySQL 简体中文版 8.0.29 & 注册机

Mysql 关联表查询更新方法

MySQL数据表字段内容的批量修改、复制命令

联系孤魂

日志分类

搜索文章

最新评论

博客信息

博主推荐

PHP代码

<?php
//include("config.php");
define('db_host','localhost'); //数据库服务器
define('db_user','root'); //数据库用户名
define('dbpw',''); //数据库密码
define('dbname','test'); //数据库名
define('dbcharset','utf8'); //数据库编码,不建议修改
//$db = new mysql($dbhost='', $dbuser='', $dbpw='', $dbname = 'test222', $pconnect = 0);
/**
include("inc/mysql.class.php");
$db = new mysql();
$query = $db->query("select * from test order by ID DESC");
//取一条记录
$res = $db->fetch_row($query);
//取所有记录
$res = $db->fetch_all($query);
//插入
$db->query("insert into test values (3,'测试222222222','test','fffff')");
//mysql_result 只取一个时
$query = $db->query("select title from test order by ID DESC");
$rs = $db->result($query,0);
print_r($rs);
//查询
$query = $db->query("select * from test order by ID DESC");
while($rw = $db->fetch_array($query))
{
print_r($rw);
}
**/
/**
* mysql查询类
* 改造自discuz的mysql查询类
*/
class mysql {
/**
* 查询总次数
*
* @var int
*/
var $querynum = 0;
/**
* 连接句柄
*
* @var object
*/
var $link;
/**
* 定义一些默认的变量
*/
private $dbhost = db_host;
private $dbname = dbname;
private $dbuser = db_user;
private $dbpw = dbpw;
private $dbcharset = dbcharset;
/**
* 构造函数
*
* @param string $dbhost 主机名
* @param string $dbuser 用户
* @param string $dbpw 密码
* @param string $dbname 数据库名
* @param int $pconnect 是否持续连接
*/
function mysql($dbhost='', $dbuser='', $dbpw='', $dbname = '', $pconnect = 0) {
$dbhost==''?$dbhost=$this->dbhost:$dbhost;
$dbuser==''?$dbuser=$this->dbuser:$dbuser;
$dbpw==''?$dbpw=$this->dbpw:$dbpw;
$dbname==''?$dbname=$this->dbname:$dbname;
if($pconnect) {
if(!$this->link = @mysql_pconnect($dbhost, $dbuser, $dbpw)) {
$this->halt('Can not connect to MySQL server');
}
} else {
if(!$this->link = @mysql_connect($dbhost, $dbuser, $dbpw)) {
$this->halt('Can not connect to MySQL server');
}
}
if($this->version() > '4.1') {
if($this->dbcharset) {
mysql_query("SET character_set_connection=$this->dbcharset, character_set_results=$this->dbcharset, character_set_client=binary", $this->link);
}
if($this->version() > '5.0.1') {
mysql_query("SET sql_mode=''", $this->link);
}
}
if($dbname) {
mysql_select_db($dbname, $this->link);
}
}
/**
* 选择数据库
*
* @param string $dbname
* @return
*/
function select_db($dbname) {
return mysql_select_db($dbname, $this->link);
}
/**
* 取出结果集中一条记录
*
* @param object $query
* @param int $result_type
* @return array
*/
function fetch_array($query, $result_type = MYSQL_ASSOC) {
return mysql_fetch_array($query, $result_type);
}
/**
* 取出所有结果
*
* @param object $query
* @param int $result_type
* @return array
*/
function fetch_all($query, $result_type = MYSQL_ASSOC) {
$result = array();
$num = 0;
while($ret = mysql_fetch_array($query, $result_type))
{
$result[$num++] = $ret;
}
return $result;
}
/**
* 从结果集中取得一行作为枚举数组
*
* @param object $query
* @return array
*/
function fetch_row($query) {
$query = mysql_fetch_row($query);
return $query;
}
/**
* 返回查询结果
*
* @param object $query
* @param string $row
* @return mixed
*/
function result($query, $row) {
$query = @mysql_result($query, $row);
return $query;
}
/**
* 查询SQL
*
* @param string $sql
* @param string $type
* @return object
*/
function query($sql, $type = '') {
$func = $type == 'UNBUFFERED' && @function_exists('mysql_unbuffered_query') ?
'mysql_unbuffered_query' : 'mysql_query';
if(!($query = $func($sql, $this->link)) && $type != 'SILENT') {
$this->halt('MySQL Query Error: ', $sql);
}
$this->querynum++;
return $query;
}
/**
* 取影响条数
*
* @return int
*/
function affected_rows() {
return mysql_affected_rows($this->link);
}
/**
* 返回错误信息
*
* @return array
*/
function error() {
return (($this->link) ? mysql_error($this->link) : mysql_error());
}
/**
* 返回错误代码
*
* @return int
*/
function errno() {
return intval(($this->link) ? mysql_errno($this->link) : mysql_errno());
}
/**
* 结果条数
*
* @param object $query
* @return int
*/
function num_rows($query) {
$query = mysql_num_rows($query);
return $query;
}
/**
* 取字段总数
*
* @param object $query
* @return int
*/
function num_fields($query) {
return mysql_num_fields($query);
}
/**
* 释放结果集
*
* @param object $query
* @return bool
*/
function free_result($query) {
return mysql_free_result($query);
}
/**
* 返回自增ID
*
* @return int
*/
function insert_id() {
return ($id = mysql_insert_id($this->link)) >= 0 ? $id : $this->result($this->query("SELECT last_insert_id()"), 0);
}
/**
* 从结果集中取得列信息并作为对象返回
*
* @param object $query
* @return object
*/
function fetch_fields($query) {
return mysql_fetch_field($query);
}
/**
* 返回mysql版本
*
* @return string
*/
function version() {
return mysql_get_server_info($this->link);
}
/**
* 关闭连接
*
* @return bool
*/
function close() {
return mysql_close($this->link);
}
/**
* 输出错误信息
*
* @param string $message
* @param string $sql
*/
function halt($message = '', $sql = '') {
echo $message . ' ' . $sql;
exit;
}
}
?>

« 2010年09月 »