phpwind中的数据库操作类
数据库 操作 phpwind
2023-06-13 09:13:52 时间
<?php
/*来源:phpwind.net*/
Class DB {
var $query_num = 0;
function DB($dbhost, $dbuser, $dbpw, $dbname, $pconnect = 0) {
$this->connect($dbhost, $dbuser, $dbpw, $dbname, $pconnect);
}
function connect($dbhost, $dbuser, $dbpw, $dbname, $pconnect = 0) {
$pconnect==0 ? @mysql_connect($dbhost, $dbuser, $dbpw) : @mysql_pconnect($dbhost, $dbuser, $dbpw);
mysql_errno()!=0 && $this->halt("Connect($pconnect) to MySQL failed");
if($this->server_info() > "4.1" && $GLOBALS["charset"]){
mysql_query("SET NAMES "".$GLOBALS["charset"].""");
}
if($this->server_info() > "5.0"){
mysql_query("SET sql_mode=""");
}
if($dbname) {
if (!@mysql_select_db($dbname)){
$this->halt("Cannot use database");
}
}
}
function close() {
return mysql_close();
}
function select_db($dbname){
if (!@mysql_select_db($dbname)){
$this->halt("Cannot use database");
}
}
function server_info(){
return mysql_get_server_info();
}
function query($SQL,$method="") {
$GLOBALS["PW"]=="pw_" or $SQL=str_replace("pw_",$GLOBALS["PW"],$SQL);
if($method=="U_B" && function_exists("mysql_unbuffered_query")){
$query = mysql_unbuffered_query($SQL);
}else{
$query = mysql_query($SQL);
}
$this->query_num++;
//echo $SQL."<br>".$this->query_num."<br>";
if (!$query) $this->halt("Query Error: " . $SQL);
return $query;
}
function get_one($SQL){
$query=$this->query($SQL,"U_B");
$rs =& mysql_fetch_array($query, MYSQL_ASSOC);
return $rs;
}
function pw_update($SQL_1,$SQL_2,$SQL_3){
$rt=$this->get_one($SQL_1);
if($rt){
$this->update($SQL_2);
} else{
$this->update($SQL_3);
}
}
function update($SQL) {
$GLOBALS["PW"]=="pw_" or $SQL=str_replace("pw_",$GLOBALS["PW"],$SQL);
if($GLOBALS["db_lp"]==1){
if(substr($SQL,0,7)=="REPLACE"){
$SQL=substr($SQL,0,7)." LOW_PRIORITY".substr($SQL,7);
} else{
$SQL=substr($SQL,0,6)." LOW_PRIORITY".substr($SQL,6);
}
}
if(function_exists("mysql_unbuffered_query")){
$query = mysql_unbuffered_query($SQL);
}else{
$query = mysql_query($SQL);
}
$this->query_num++;
//echo $SQL."<br>".$this->query_num."<br>";
if (!$query) $this->halt("Update Error: " . $SQL);
return $query;
}
function fetch_array($query, $result_type = MYSQL_ASSOC) {
return mysql_fetch_array($query, $result_type);
}
function affected_rows() {
return mysql_affected_rows();
}
function num_rows($query) {
$rows = mysql_num_rows($query);
return $rows;
}
function free_result($query) {
return mysql_free_result($query);
}
function insert_id() {
$id = mysql_insert_id();
return $id;
}
function halt($msg="") {
require_once(R_P."require/db_mysql_error.php");
new DB_ERROR($msg);
}
}
?>
/*来源:phpwind.net*/
Class DB {
var $query_num = 0;
function DB($dbhost, $dbuser, $dbpw, $dbname, $pconnect = 0) {
$this->connect($dbhost, $dbuser, $dbpw, $dbname, $pconnect);
}
function connect($dbhost, $dbuser, $dbpw, $dbname, $pconnect = 0) {
$pconnect==0 ? @mysql_connect($dbhost, $dbuser, $dbpw) : @mysql_pconnect($dbhost, $dbuser, $dbpw);
mysql_errno()!=0 && $this->halt("Connect($pconnect) to MySQL failed");
if($this->server_info() > "4.1" && $GLOBALS["charset"]){
mysql_query("SET NAMES "".$GLOBALS["charset"].""");
}
if($this->server_info() > "5.0"){
mysql_query("SET sql_mode=""");
}
if($dbname) {
if (!@mysql_select_db($dbname)){
$this->halt("Cannot use database");
}
}
}
function close() {
return mysql_close();
}
function select_db($dbname){
if (!@mysql_select_db($dbname)){
$this->halt("Cannot use database");
}
}
function server_info(){
return mysql_get_server_info();
}
function query($SQL,$method="") {
$GLOBALS["PW"]=="pw_" or $SQL=str_replace("pw_",$GLOBALS["PW"],$SQL);
if($method=="U_B" && function_exists("mysql_unbuffered_query")){
$query = mysql_unbuffered_query($SQL);
}else{
$query = mysql_query($SQL);
}
$this->query_num++;
//echo $SQL."<br>".$this->query_num."<br>";
if (!$query) $this->halt("Query Error: " . $SQL);
return $query;
}
function get_one($SQL){
$query=$this->query($SQL,"U_B");
$rs =& mysql_fetch_array($query, MYSQL_ASSOC);
return $rs;
}
function pw_update($SQL_1,$SQL_2,$SQL_3){
$rt=$this->get_one($SQL_1);
if($rt){
$this->update($SQL_2);
} else{
$this->update($SQL_3);
}
}
function update($SQL) {
$GLOBALS["PW"]=="pw_" or $SQL=str_replace("pw_",$GLOBALS["PW"],$SQL);
if($GLOBALS["db_lp"]==1){
if(substr($SQL,0,7)=="REPLACE"){
$SQL=substr($SQL,0,7)." LOW_PRIORITY".substr($SQL,7);
} else{
$SQL=substr($SQL,0,6)." LOW_PRIORITY".substr($SQL,6);
}
}
if(function_exists("mysql_unbuffered_query")){
$query = mysql_unbuffered_query($SQL);
}else{
$query = mysql_query($SQL);
}
$this->query_num++;
//echo $SQL."<br>".$this->query_num."<br>";
if (!$query) $this->halt("Update Error: " . $SQL);
return $query;
}
function fetch_array($query, $result_type = MYSQL_ASSOC) {
return mysql_fetch_array($query, $result_type);
}
function affected_rows() {
return mysql_affected_rows();
}
function num_rows($query) {
$rows = mysql_num_rows($query);
return $rows;
}
function free_result($query) {
return mysql_free_result($query);
}
function insert_id() {
$id = mysql_insert_id();
return $id;
}
function halt($msg="") {
require_once(R_P."require/db_mysql_error.php");
new DB_ERROR($msg);
}
}
?>
相关文章
- 学生数据库管理系统
- MySQL数据库基础学习(二十一)
- SQLServer 错误 14420 日志传送主数据库 %s.%s 的备份阈值为 %d 分钟,在过去的 %d 分钟之内未执行备份日志操作。 请查看代理日志和日志传送监视器信息。 故障 处理 修复 支持远程
- mongodb数据库入门学习笔记之下载、安装、启动、连接操作解析
- MySQL命令详解:解析数据库操作的基本行动(mysql命令详解)
- Linux打开DB文件:一步步完成数据库操作(linux打开db文件)
- 快速构建Oracle数据库:使用Oracle创建数据库(用oracle创建数据库)
- MySQL数据库连接编码:正确使用方式(mysql数据库连接编码)
- MongoDB数据库增删改查操作实践(mongodb的增删改查)
- 模式创建Oracle数据库模式的本地实现(在本地创建oracle)
- Oracle函数的简单易用,快速提升数据库操作效率(oracle函数用法)
- 深入探究:MongoDB的特点与用途简介(mongodb是什么数据库)
- MySQL 数据库高阶操作指南(mysql进阶教程)
- Oracle数据库如何进行左补零操作?(oracle左补零)
- Oracle数据库中如何进行批量删除表操作(oracle批量删除表)
- 如何编写Oracle无参存储过程,提升数据库操作效率?(oracle无参存储过程)
- MSSQLServer实现两台数据库的同步(两台mssql同步数据库)
- 语言Linux环境下使用ODBC操作C语言编写数据库(linux odbc c)
- 探究MySQL存储过程的实际作用,提升数据库操作效率(mysql存储过程作用)
- 探索Oracle数据库:了解所有字段的应用和作用(oracle所有字段)
- Oracle Q操作:深入探索数据库的可能性(oracle q 操作)
- Oracle数据库表的种类及其特点(oracle表种类)
- C中MySQL数据库的插入操作(c#mysql 插入)
- 使用MySQL实现两表匹配操作增强数据库效能(mysql 两表匹配)
- Oracle数据库插入操作详解(c 插入数据oracle)
- Oracle数据库中如何操作CRS文件(crs文件 oracle)
- MySQL源码下载指南快速获得高质量数据库工具(mysql下载源码)
- Oracle数据库中的双目运算实现深度思考(oracle二目运算)
- oracle数据库中日期加一操作实战(oracle 中日期加1)
- Oracle数据库操作中的粘贴欠缺的必要性(oracle 不能粘贴)
- php中CI操作多个数据库的代码
- PHP中使用匿名函数操作数据库的例子