论坛徽章:: 0

电梯直达

1楼 [收藏(0)] [报告]

发表于 2006-03-31 13:56 |只看该作者 |倒序浏览

若有什么想法，欢迎探讨指教~~ 使用灵活，可以按常规的配置（见程序最后的例用），也可这样： //数据库类型名称://入口帐号:入口密码@数据库主机名:端口号/数据库名/是否总是打开新的连接 $dsn = "MySQL://Dummy:admin@localhost:3306/tetx/false"; [PHP]splitDSN($DBHost); $DBTpye = $dsn[0]; $DBHost = $dsn[1].":".$dsn[2]; $DBUser = $dsn[3]; $DBPswd = $dsn[4]; $DBName = $dsn[5]; $newLink = $dsn[6] == ''?$newLinkdsn[6]; } $this->DBHost = empty($DBHost)?$this->DBHostDBHost; $this->DBUser = empty($DBUser)?$this->DBUserDBUser; $this->DBPswd = empty($DBPswd)?$this->DBPswdDBPswd; $this->DBName = empty($DBName)?$this->DBNameDBName; if(!empty($DBHost)){ $this->connect($this->DBHost, $this->DBUser, $this->DBPswd, $newLink); } if(!empty($DBName)){ $this->selectDB($DBName); } } function splitDSN($dsn){ //$dsn = "数据库类型名称://入口帐号:入口密码@数据库主机名:端口号/数据库名/是否总是打开新的连接"; //$dsn = "MySQL://Dummy:123@localhost:3306/tetx/false"; $dsn = preg_split("/[:\/@]/", $dsn); $DBTpye = ''; $DBHost = ''; $DBPort = ''; $DBUser = ''; $DBPswd = ''; $DBName = ''; $DBNewLink = false; $DBTpye = $dsn[0]; $DBHost = $dsn[5]; $DBPort = $dsn[6]; $DBUser = $dsn[3]; $DBPswd = $dsn[4]; $DBName = $dsn[7]; $DBNewLink = $dsn[8]; return array($DBTpye, $DBHost, $DBPort, $DBUser, $DBPswd, $DBName, $DBNewLink); } function affectedRows(){ /* 取得前一次 MySQL 操作所影响的记录行数 */ return mysql_affected_rows($this->LinkId); } function changeUser($user, $password){ /* 改变活动连接中登录的用户 */ return mysql_change_user($user, $password, $this->DBName, $this->LinkId); } function clientEncoding(){ /* 返回字符集的名称 */ return mysql_client_encoding($this->LinkId); } function close(){ /* 关闭 MySQL 连接 */ $close = mysql_close($this->LinkId); $this->LinkId = NULL; $this->Result = NULL; $this->Record = NULL; return $close; } function connect($DBHost = '', $DBUser = '', $DBPswd = '', $newLink = false){//, int client_flags){ /* 打开一个到 MySQL 服务器的连接 */ $connect = @mysql_connect(empty($DBHost)?$this->DBHostDBHost, empty($DBUser)?$this->DBUserDBUser, empty($DBPswd)?$this->DBPswdDBPswd, $newLink); if(!is_resource($connect)){ $this->halt("连接数据库失败！
", 1); return false; } $this->LinkId = $connect; return true; } function createDB($DBName){ /* 新建一个 MySQL 数据库 */ return @mysql_create_db($DBName, $this->LinkId) or die($this->halt("创建数据库 ".$DBName." 失败！")); } function dataSeek($rowNumber){ /* 移动内部结果的指针 */ return mysql_data_seek($this->Result, $rowNumber); } function dbName($row, $field = NULL){ /* 取得结果数据 */ if(empty($field)){ return mysql_db_name($this->Result, $row); } return mysql_db_name($this->Result, $row, $field); } function dbQuery($DBName, $queryString){ /* 发送一条 MySQL 查询 */ $this->Result = mysql_db_query($DBName, $queryString, $this->LinkId); return $this->Result?true:false; } function dropDB($DBName){ /* 丢弃（删除）一个 MySQL 数据库 */ return mysql_drop_db($DBName, $this->LinkId); } function errno(){ /* 返回上一个 MySQL 操作中的错误信息的数字编码 */ return mysql_errno($this->LinkId); } function error(){ /* 返回上一个 MySQL 操作产生的文本错误信息 */ return mysql_error($this->LinkId); } function escapeString($unescapedString){ /* 转义一个字符串用于 mysql_query */ return mysql_escape_string($unescapedString); } function fetchArray($Rows = 0, $resultType = MYSQL_BOTH){ /* 从结果集中取得一行作为关联数组，或数字数组，或二者兼有 */ if(!is_resource($this->Result)){ return false; } $fetchArray = mysql_fetch_array($this->Result, $resultType); if($fetchArray && $Rows){$this->Rows++;} return $fetchArray; } function fetchAssoc($Rows = 0){ /* 从结果集中取得一行作为关联数组 */ if(!is_resource($this->Result)){ return false; } $fetchAssoc = mysql_fetch_assoc($this->Result); if($fetchAssoc && $Rows){$this->Rows++;} return $fetchAssoc; } function fetchField($fieldOffset = NULL){ /* 从结果集中取得列信息并作为对象返回 */ if(empty($fieldOffset)){ return mysql_fetch_field($this->Result, $fieldOffset); } return mysql_fetch_field($this->Result); } function fetchLengths(){ /* 取得结果集中每个输出的长度 */ return mysql_fetch_lengths($this->Result); } function fetchObject($Rows = 0){ /* 从结果集中取得一行作为对象 */ if(!is_resource($this->Result)){ return false; } $fetchObject = mysql_fetch_object($this->Result); if(is_object($fetchObject) && $Rows){$this->Rows++;} return is_object($fetchObject)?$fetchObject:false; } function fetchRow($Rows = 0){ /* 从结果集中取得一行作为枚举数组 */ if(!is_resource($this->Result)){ return false; } $fetchRow = mysql_fetch_row($this->Result); if($fetchRow && $Rows){$this->Rows++;} return $fetchRow; } function fieldFlags($fieldOffset){ /* 从结果中取得和指定字段关联的标志 */ return mysql_field_flags($this->Result, $fieldOffset); } function fieldLen($fieldOffset){ /* 返回指定字段的长度 */ return mysql_field_len($this->Result, $fieldOffset); } function fieldName($fieldIndex){ /* 取得结果中指定字段的字段名 */ return mysql_field_name($this->Result, $fieldIndex); } function fieldSeek($fieldOffset){ /* 将结果集中的指针设定为制定的字段偏移量 */ return mysql_field_seek($this->Result, $fieldOffset); } function fieldTable($fieldOffset){ /* 取得指定字段所在的表名 */ return mysql_field_table($this->Result, $fieldOffset); } function fieldType($fieldOffset){ /* 取得结果集中指定字段的类型 */ return mysql_field_type($this->Result, $fieldOffset); } function freeResult(){ /* 释放结果内存 */ return mysql_free_result($this->Result); } function getClientInfo(){ /* 取得 MySQL 客户端信息 */ return mysql_get_client_info(); } function getHostInfo(){ /* 取得 MySQL 主机信息 */ return mysql_get_host_info($this->LinkId); } function getProtoInfo(){ /* 取得 MySQL 协议信息 */ return mysql_get_proto_info($this->LinkId); } function getServerInfo(){ /* 取得 MySQL 服务器信息 */ return mysql_get_server_info($this->LinkId); } function info(){ /* 取得最近一条查询的信息 */ return mysql_info($this->LinkId); } function insertId(){ /* 取得上一步 INSERT 操作产生的 ID */ return mysql_insert_id($this->LinkId); } function listDBs(){ /* 列出 MySQL 服务器中所有的数据库 */ $this->Result = mysql_list_dbs($this->LinkId); return $this->Result?true:false; } function listFields($DBName, $tableName){ /* 列出 MySQL 结果中的字段 */ $this->Result = mysql_list_fields($DBName, $tableName, $this->LinkId); return $this->Result?true:false; } function listProcesses(){ /* 列出 MySQL 进程 */ $this->Result = mysql_list_processes($this->LinkId); return $this->Result?true:false; } function listTables($DBName = ''){ /* 列出 MySQL 数据库中的表 */ $DBName = empty($DBName)?$this->DBNameDBName; $this->Result = mysql_list_tables($DBName, $this->LinkId); return $this->Result?true:false; } function numFields(){ /* 取得结果集中字段的数目 */ return mysql_num_fields($this->Result); } function numRows(){ /* 取得结果集中行的数目 */ return mysql_num_rows($this->Result); } function pconnect($DBHost = '', $DBUser = '', $DBPswd = ''){ /* 打开一个到 MySQL 服务器的持久连接 */ $connect = @mysql_pconnect(empty($DBHost)?$this->DBHostDBHost, empty($DBUser)?$this->DBUserDBUser, empty($DBPswd)?$this->DBPswdDBPswd); if(!is_resource($connect)){ $this->halt("连接数据库失败！",1); return false; } $this->LinkId = $connect; return true; } function ping(){ /* Ping 一个服务器连接，如果没有连接则重新连接 */ return mysql_ping($this->LinkId); } function query($queryString){ /* 发送一条 MySQL 查询 */ if(empty($queryString)){ $this->halt("SQL 语句为空！", 1); return false; } if(!is_resource($this->LinkId)){ $this->halt("请先确保数据库已经连接上！", 1); return false; } $this->Result = mysql_query($queryString, $this->LinkId);// or die(mysql_error());//print_r($this); return $this->Result?true:false; } function realEscapeString($unescapedString){ /* 转义 SQL 语句中使用的字符串中的特殊字符，并考虑到连接的当前字符集 */ return mysql_real_escape_string($unescapedString, $this->LinkId); } function result($row, $field = NULL){ /* 取得结果数据 */ if(empty($field)){ return mysql_result($this->Result, $row, $field); } return mysql_result($this->Result, $row); } function selectDB($DBName = 'test'){ /* 选择 MySQL 数据库 */ return mysql_select_db(empty($DBName)?$this->$DBNameDBName, $this->LinkId); } function stat(){ /* 取得当前系统状态 */ return mysql_stat($this->LinkId); } function tablename($index){ /* 取得表名 */ return mysql_tablename($this->Result, $index); } function threadId(){ /* 返回当前线程的 ID */ return mysql_thread_id($this->LinkId); } function unbufferedQuery($queryString){ /* 向 MySQL 发送一条 SQL 查询，并不获取和缓存结果的行 */ $this->Result = mysql_unbuffered_query($queryString,$this->LinkId); return $this->Result?true:false; } /*-- 上面的方法名跟手册上 MySQL 的那些函数名是一对一的，除了“splitDSN”和“构造函数” --*/ /*-- 下面是扩展，也就是说下面的这些方法在手册上是找不到影子的 --*/ function free(){ /* 释放结果内存，效果 freeResult 一样，只是这样简单些，少写几个字母，算是别名吧~ ^_^ */ return $this->freeResult(); } function setMustBeHalt($MustBeHalt = false){ $this->MustBeHalt = $MustBeHalt; } function getMustBeHalt(){ return $this->MustBeHalt; } /* 以下是支持事物扩展 */ function setAutoCommit($AutoCommit = 1){ /* 默认为不支持事务 */ mysql_query("SET AUTOCOMMIT = ".$AutoCommit); } function begin(){ /* 事务开始 */ @mysql_query("LOCK TABLES"); @mysql_query("UNLOCK TABLES"); $this->setAutoCommit(0); mysql_query("BEGIN"); } function rollback(){ /* 回滚，继续默认的不支持事务 */ mysql_query("ROLLBACK"); @mysql_query("UNLOCK TABLES"); $this->setAutoCommit(1); } function commit(){ /* 事务结束，继续默认的不支持事务 */ mysql_query("COMMIT"); @mysql_query("UNLOCK TABLES"); $this->setAutoCommit(1); } /* 以上是支持事物扩展 */ function getRows(){ /* 取得已经读出的数据记录数 */ return $this->Rows; } function getDBName(){ return $this->DBName; } function nextRecord($resultType = 0){ /* 跟 phplib 接轨，同 phplib 的 next_record */ $record = NULL; switch($resultType){ case 1: $record = @mysql_fetch_assoc($this->Result); $this->RecordCase = 1; break; case 2: $record = @mysql_fetch_row($this->Result); $this->RecordCase = 2; break; case 3: $record = @mysql_fetch_object($this->Result); $this->RecordCase = 3; break; default: $record = @mysql_fetch_array($this->Result); $this->RecordCase = 0; break; } if(is_resource($record)){ $this->Record = $record; }else{ return false; } } function f($fieldName){ /* 跟 phplib 接轨 */ switch($this->RecordCase){ case 3: return is_object($this->Record)?$this->Record->$fieldName:NULL; break; default: return $this->Record[$fieldName]; break; } } function setTest($IsTest){ if(is_bool($IsTest)){ $this->IsTest = $IsTest; }else{ die('$IsTest 值不对！'); } } function getTest(){ return $this->IsTest; } /* 下面的自己可以定义格式 */ function halt($msg = "未知错误！", $MustBeHalt = 0){ echo $msg; if($MustBeHalt !== 0 || $this->getMustBeHalt()){ if($this->getTest()){ echo "
";
print_r($this);
echo "
"; } die(); } } /* 下面的可要可不要，因为得PHP5才行 */ function __get($nm){ if(isset($this->$nm)){ // }else{ $this->halt("没有的成员变量：$nm\n",1); } } function __set($nm, $val){ // } function __call($m, $a){ print "
--------------------------------------------------------------------------------
调用不存在的方法——".$m."(".join(",",$a).")！\n"; echo '
';
  var_dump($a);
  echo '
'; $this->halt("
--------------------------------------------------------------------------------
"); } } // End DummyMySQLClass ?> query("SELECT * FROM `purchase_product` LIMIT 1"); while($fetchObject = $DMC->fetchObject(3)){ echo $DMC->fieldName(0).'
'; // 效果如：ID echo $DMC->fieldType(0).'
'; echo $DMC->fieldLen(0).'
'; // 效果如：9 print_r($DMC->fieldFlags(0)); // 效果如：not_null primary_key auto_increment echo '
--------------------------------------------------------------------------------
合起来的效果：
'; echo '`'.$DMC->fieldName(0).'` '.$DMC->fieldType(0).'('.$DMC->fieldLen(0).') '.str_replace(array("NOT_NULL","PRIMARY_KEY"),array("NOT NULL","PRIMARY KEY"),strtoupper($DMC->fieldFlags(0))).",\n
"; } //下面这是秘籍！！^_^ */ //--------------------------------------------------------- /**4 echo "getHostInfo() --- ".$DMC->getHostInfo().'
'; echo "getClientInfo() - ".$DMC->getClientInfo().'
'; echo "getProtoInfo() -- ".$DMC->getProtoInfo().'
'; echo "getServerInfo() - ".$DMC->getServerInfo().'
'; echo "info() ---------- ".$DMC->info().'
'; */ //--------------------------------------------------------- /**3 //取得指定库的所有表 $DMC->listTables("test"); while($row = $DMC->fetchRow()){ print "Table: ".$row[0]."\n"; } //下面for的效果跟上面while的一样 for ($i = 0; $i numRows(); $i++){ printf ("Table: %s\n", $DMC->tablename($i)); } */ //--------------------------------------------------------- /**2 //数据查询 $DMC->query("SELECT * FROM `purchase_product` LIMIT 1"); while($fetchObject = $DMC->fetchObject(3)){ print_r($fetchObject); print_r($DMC->fetchLengths()); // 是记录的长度，不是字段的长度 //print_r($DMC); } */ //--------------------------------------------------------- /**1 // 取得指定库指定表名称的字段 $DMC->listFields("test","purchase_product"); $a = $DMC->numFields(); for($i=0; $ifieldName($i).' '; } */ ///////////////////////////////////////////////// // // // 环境：PHP5.0.3 + APACHE：2.0.52 +Win2Kp_sp4 // // // ///////////////////////////////////////////////// ?> [/PHP]

db类:db_mysql.php
PHP代码:--------------------------------------------------------------------------------
class mysql {
var $Host;
var $Database;
var $User;
var $Password;
var $table;                                           //数据表
var $errMes       =array();                         //记录错误信息
var $field       =array();                         //查询字段
function mysql($host, $dbuser, $dbpass, $db)
{
      $this->Host = $host; //主机
      $this->User = $dbuser; //用户
      $this->Password = $dbpass; //密码
      $this->Database = $db; //数据库名
}
var $Auto_Free = 0; ## Set to 1 for automatic mysql_free_result()
var $Debug = 0; ## Set to 1 for debugging messages.
var $Halt_On_Error = "yes"; ## "yes" (halt with message), "no" (ignore errors quietly), "report" (ignore errror, but spit a warning)
var $Seq_Table = "db_sequence";
var $Record = array();
var $Row;
var $Errno = 0;
var $Error = "";
var $type = "mysql";
var $revision = "1.2";
var $Link_ID = 0;
var $Query_ID = 0;
function DB_Sql($query = "")
{
      $this->query($query);
}
function link_id()
{
      return $this->Link_ID;
}
function query_id()
{
      return $this->Query_ID;
}
function connect($Database = "", $Host = "", $User = "", $Password = "")
{
      if ("" == $Database)
         $Database = $this->Database;
      if ("" == $Host)
         $Host = $this->Host;
      if ("" == $User)
         $User = $this->User;
      if ("" == $Password)
         $Password = $this->Password;
      if (0 == $this->Link_ID) {
         $this->Link_ID = mysql_pconnect($Host, $User, $Password);
         if (!$this->Link_ID) {
            $this->halt("pconnect($Host, $User, \$Password) failed.");
            return 0;
         }
         if (
[email=!@mysql_select_db($Database]!@mysql_select_db($Database[/email]
, $this->Link_ID)) {
            $this->halt("cannot use database " . $this->Database);
            return 0;
         }
      }
      return $this->Link_ID;
}
function free()
{
      @mysql_free_result($this->Query_ID);
      $this->Query_ID = 0;
}
function query($Query_String)
{
      if ($Query_String == "")
         return 0;
      if (!$this->connect()) {
         return 0;
      } ;
      if ($this->Query_ID) {
         $this->free();
      }
      if ($this->Debug)
         printf("Debug: query = %s
\n", $Query_String);
      $this->Query_ID = @mysql_query($Query_String, $this->Link_ID);
      $this->Row = 0;
      $this->Errno = mysql_errno();
      if (!$this->Query_ID) {
         $this->halt("Invalid SQL: " . $Query_String);
      }
      return $this->Query_ID;
}
function result()
{
      if (!$this->Query_ID) {
         $this->halt("result called with no query pending.");
         return 0;
      }
      $this->Record = @mysql_fetch_array($this->Query_ID);
      $this->Row += 1;
      $this->Errno = mysql_errno();
      $this->Error = mysql_error();
      $stat = is_array($this->Record);
      if (!$stat && $this->Auto_Free) {
         $this->free();
      }
      return $stat;
}
function seek($pos = 0)
{
      $status = @mysql_data_seek($this->Query_ID, $pos);
      if ($status)
         $this->Row = $pos;
      else {
         $this->halt("seek($pos) failed: result has " . $this->num_rows() . " rows");
         @mysql_data_seek($this->Query_ID, $this->num_rows());
         $this->Row = $this->num_rows;
         return 0;
      }
      return 1;
}
function lock($table, $mode = "write")
{
      $this->connect();
      $query = "lock tables ";
      if (is_array($table)) {
         while (list($key, $value) = each($table)) {
            if ($key == "read" && $key != 0) {
                  $query .= "$value read, ";
            } else {
                  $query .= "$value $mode, ";
            }
         }
         $query = substr($query, 0, -2);
      } else {
         $query .= "$table $mode";
      }
      $res = @mysql_query($query, $this->Link_ID);
      if (!$res) {
         $this->halt("lock($table, $mode) failed.");
         return 0;
      }
      return $res;
}
function unlock()
{
      $this->connect();
      $res = @mysql_query("unlock tables");
      if (!$res) {
         $this->halt("unlock() failed.");
         return 0;
      }
      return $res;
}
function affected_rows()
{
      return @mysql_affected_rows($this->Link_ID);
}
function num_rows()
{
      return @mysql_num_rows($this->Query_ID);
}
function num_fields()
{
      return @mysql_num_fields($this->Query_ID);
}
function nf()
{
      return $this->num_rows();
}
function np()
{
      print $this->num_rows();
}
function f($Name)
{
      return $this->Record[$Name];
}
function p($Name)
{
      print $this->Record[$Name];
}
function nextid($seq_name)
{
      $this->connect();
      if ($this->lock($this->Seq_Table)) {
         $q = sprintf("select nextid from %s where seq_name = '%s'",
            $this->Seq_Table,
            $seq_name);
         $id = @mysql_query($q, $this->Link_ID);
         $res = @mysql_fetch_array($id);
         if (!is_array($res)) {
            $currentid = 0;
            $q = sprintf("insert into %s values('%s', %s)",
                  $this->Seq_Table,
                  $seq_name,
                  $currentid);
            $id = @mysql_query($q, $this->Link_ID);
         } else {
            $currentid = $res["nextid"];
         }
         $nextid = $currentid + 1;
         $q = sprintf("update %s set nextid = '%s' where seq_name = '%s'",
            $this->Seq_Table,
            $nextid,
            $seq_name);
         $id = @mysql_query($q, $this->Link_ID);
         $this->unlock();
      } else {
         $this->halt("cannot lock " . $this->Seq_Table . " - has it been created?");
         return 0;
      }
      return $nextid;
}
function metadata($table = '', $full = false)
{
      $count = 0;
      $id = 0;
      $res = array();
      if ($table) {
         $this->connect();
         $id = @mysql_list_fields($this->Database, $table);
         if (!$id)
            $this->halt("Metadata query failed.");
      } else {
         $id = $this->Query_ID;
         if (!$id)
            $this->halt("No query specified.");
      }
      $count = @mysql_num_fields($id);
      if (!$full) {
         for ($i = 0; $i
         for ($i = 0; $i
function halt($msg)
{
      $this->Error = @mysql_error($this->Link_ID);
      $this->Errno = @mysql_errno($this->Link_ID);
      if ($this->Halt_On_Error == "no")
         return;
      $this->haltmsg($msg);
      if ($this->Halt_On_Error != "report")
         die("Session halted.");
}
function haltmsg($msg)
{
      printf("Database error: %s
\n", $msg);
      printf("MySQL Error: %s (%s)
\n",
         $this->Errno,
         $this->Error);
}
function table_names()
{
      $this->query("SHOW TABLES");
      $i = 0;
      while ($info = mysql_fetch_row($this->Query_ID)) {
         $return[$i]["table_name"] = $info[0];
         $return[$i]["tablespace_name"] = $this->Database;
         $return[$i]["database"] = $this->Database;
         $i++;
      }
      return $return;
}
function getResArray()
{
      return @mysql_fetch_array($this->Query_ID);
}
function getResTotal(){
      return @mysql_num_rows($this->Query_ID);
}

/*****************无魂扩展部分***************/

/*
      *方法 setTable
      *功能设定查询表名
      *参数 $t       表名
      *返回无
*/
function setTable($t){
      $this->table=$f;
}//end fun setTable
/*
      *方法 getField
      *功能取得要查询的记录
      *参数 $f          记录数组
      *返回 string
*/
function getField($f=array()){
      $this->field=$f;
      if(empty($f)){
         $this->errMes[]="记录不为空";
         $this->mes();
      }
      foreach($f as $v){
         $field.=$v.",";
      }
      $field=substr($field,0,-1);
      return $field;
}//end fun getField
/*
      *方法 setFiled
      *功能设定字段
      *参数 $f       字段
      *返回无
*/
function setField($f=array()){
      $this->field=$f;
}//end fun setFiled
/*
      *方法 getRes
      *功能得到用户记录
      *参数 $f       字段
      *返回无
*/
function getRes($sql){
      $this->query($sql);
      while($this->result()){
         foreach($this->field as $v){
            $res[$v][]=$this->f($v);
         }
      }
      return $res;
}//end fun getRes

/*
      *方法 getAmount
      *功能得到数量
      *参数 $t       表名
            $w       条件
      *返回 ini
*/
function getAmount($t,$w=''){
      $sql="select count(*) as tot from $t ";
      if(!empty($w))$sql.=$w;
      //echo $sql;
      $this->query($sql);
      $this->result();
      $tot=$this->f("tot");
      return $tot;
}//end fun getAmount
/*
      *方法 mes
      *功能显示错误信息
      *参数无
      *返回无
*/
function mes(){
      if(count($this->errMes)!=0){
         foreach($this->errMes as $v){
            echo '[无魂报告]:'.$v."
";
         }
         echo BACK;
         exit;
      }else{
         //echo "^_^恭喜,操作成功!
";
      }
}//end fun mes

function closeDb()
{
      @mysql_close($this->Link_ID);
}
}//end class db_mysql.php
?>

--------------------------------------------------------------------------------

然后配合我的Sql类进行得到sql语句..这里我就写了sel部分...
PHP代码:--------------------------------------------------------------------------------
var $table;                                     //表
var $where          ='';                      //条件
var $order          ='';                      //排序
var $limit;                                     //查询范围

/*
      *方法 getSql
      *功能取得Sql语句
      *参数 $field          字段值
      *返回 string
*/
function getSel($field){
      if(empty($field)){
         $this->errMes[]="参数不能为空";
         parent::mes();
      }
      $sql="select ".$field." from ".$this->table." ".$this->where." ".$this->order." ".$this->limit;
      return $sql;
}//end fun getSel
/*
      *方法 getDel
      *功能取得删除语句
      *参数 $field          字段值
      *返回 array
*/
function getDel($field){
      if(empty($field)){
         $this->errMes[]="参数不能为空";
         parent::mes();
      }
      $sql="select ".$field." from ".$this->table." ".$this->where." ".$this->order;
      return $sql;
}//end fun getDel

/* ======>set部分
/*
      *方法 setTable
      *功能设定表
      *参数 $t          表名
      *返回无
*/
function setTable($t){
      $this->table=$t;
}//end fun setTable
/*
      *方法 setWhere
      *功能设定条件
      *参数 $w          条件
      *返回无
*/
function setWhere($w){
      $this->where=$w;
}//end fun setWhere
/*
      *方法 setOrder
      *功能设定排序
      *参数 $o          排序
      *返回无
*/
function setOrder($o){
      $this->order=$o;
}//end fun setOrder
/*
      *方法 setLimit
      *功能设定排序
      *参数 $o          排序
      *返回无
*/
function setLimit($m,$f=0){
      $this->limit="limit $f,$m";
}//end fun setLimit
}//end class Sql
?>
--------------------------------------------------------------------------------
下面是Sql类用到的base类...进行错误报告和一下基本常用的功能的.....(可以不用base然后把 "class Sql extends Base{" 中的extends Base去掉..
base类:Base.class.php
PHP代码:--------------------------------------------------------------------------------
/*
*类名 Base
*功能基础类
*版本 1.0
*日期 2004-3-26
*作者无魂
*版权无魂
*说明无
*/
class Base {
var $errMes             =array();                   //记录消息

/*
      *方法 substrGb
      *功能中文截取
      *参数 $str       要截取字符串
            $start       从什么地方开始
            $len       到什么地方
      *返回 string
*/
function substrGb($str,$start,$len){
      for($i=0;$i=161 && ord($str[$i])=161 && ord($str[$i+1])=$start&&$i
/*
      *方法 getImg
      *功能上传图片并返回图片名称
      *参数 $path       物理路径
      *返回 string
      *说明需要upload.php类
*/
function getImg($img,$path){
      if(!empty($img)){
         require_once("upload.class.php");
         foreach($img as $k=>$v){
            $u=new phpUpload($v['tmp_name'],$v['name'],$path."upload/images/zixun/");
            $u->rndFileName();
            $u->size("1000");
            $u->type("jpg,gif,jpeg,JPEG");
            $res=$u->up();
            if($res[0]){
                  $len=strlen($path)-1;
                  $imgName=$u->getUsefulRf($len);
                  return $imgName;
            }
            else{
                  $this->errMes[]= "图片".$v['name']."上传失败";
                  $this->mes();
            }
         }
         unset($u);
      }
}//end fun getImg
function toHtml($str){
      $str=str_replace("","",$str);
      $str=str_replace("","","'>",$str);
      $str=str_replace("",">",$str);
      return $str;
}
/*
      *方法 mes
      *功能显示错误信息
      *参数无
      *返回无
*/
function mes(){
      if(count($this->errMes)!=0){
         foreach($this->errMes as $v){
            echo '[无魂报告]:'.$v."
";
         }
         echo '[返回] ';
         exit;
      }else{
         //echo "^_^恭喜,操作成功!
";
      }
}//end fun mes
}
?>
--------------------------------------------------------------------------------

********************************使用说明*****************************
例子:
PHP代码:--------------------------------------------------------------------------------
require_once("db_mysql.php");//引入类
require_once("sql.class.php");
$db=new mysql($host,$u,$p,$datebase)//连接数据库
$sql=new Sql;//生成sql对象
//
//方法的参数部分的说明在类里有写..可以到那里去看...
//
$sql->setTable(TB_ZX);//设定要查询的表
$sql->setOrder("order by shijian desc");//查询顺序
$sql->setLimit(5);//查询访问
$sql->setWhere($w);//查询条件
$field=$db->getField(array("id","title","article"));//查询字段
$sel=$sql->getSel($field);//得到sql语句
$res=$db->getRes($sel);//得到结果以2维数组的形式存在.
//$res[id][0]代表第一个查到的id
//$res[title][1]代表第二个查到的title
//依次类对.....
/*************不使用sql类*****************/
//如果不使用sql类应该这样写
$sql="select * from table where .....";
$db->getField(array("id","title","article"));//查询字段
$res=$db->getRes($sql);//得到结果以2维数组的形式存在.
//就这么几句.是不是很简单..快试试吧
//下面是配合smarty模板的输出部分就不写了..不过为了让朋友们看看结果加上个输出.
foreach($res[title] as $v){
   echo $v."
";
}
//如果你们使用的时候把title换成你们相应的字段.
?>

class DB_Sql
{

  /* public: connection parameters */
  var $Host    = "";
  var $Database = "";
  var $User    = "";
  var $Password = "";
  /* public: configuration parameters */
  var $Auto_Free    = 1;    ## Set to 1 for automatic mysql_free_result()
  var $Debug       = 0;    ## Set to 1 for debugging messages.
  var $Halt_On_Error = "yes"; ## "yes" (halt with message), "no" (ignore errors quietly), "report" (ignore errror, but spit a warning)
  var $PConnect    = 0;    ## Set to 1 to use persistent database connections
  var $Seq_Table    = "db_sequence";
  /* public: result array and current row number */
  var $Record = array();
  var $Row;
  /* public: current error number and error text */
  var $Errno = 0;
  var $Error = "";
  /* public: this is an api revision, not a CVS revision. */
  var $type    = "mysql";
  //var $revision = "1.2";
  /* private: link and query handles */
  var $Link_ID  = 0;
  var $Query_ID = 0;
  var $locked = false;    ## set to true while we have a lock
  /* public: constructor */
  function DB_Sql() {
$this->query($query);
  }

  /* public: some trivial reporting */
  function link_id() {
return $this->Link_ID;
  }
  function query_id() {
return $this->Query_ID;
  }
  /* public: connection management */
  function connect($Database = "", $Host = "", $User = "", $Password = "") {
/* Handle defaults */
if ("" == $Database)
   $Database = $this->Database;
if ("" == $Host)
   $Host    = $this->Host;
if ("" == $User)
   $User    = $this->User;
if ("" == $Password)
   $Password = $this->Password;

/* establish connection, select database */
if ( 0 == $this->Link_ID ) {

   if(!$this->PConnect) {
      $this->Link_ID = mysql_connect($Host, $User, $Password);
   } else {
      $this->Link_ID = mysql_pconnect($Host, $User, $Password);
   }
   if (!$this->Link_ID) {
      $this->halt("connect($Host, $User, \$Password) failed.");
      return 0;
   }
   if (
[email=!@mysql_select_db($Database,$this->Link_ID]!@mysql_select_db($Database,$this->Link_ID[/email]
)) {
      $this->halt("cannot use database ".$Database);
      return 0;
   }
}

return $this->Link_ID;
  }
  /* public: discard the query result */
  function free() {
   @mysql_free_result($this->Query_ID);
   $this->Query_ID = 0;
  }
  /* public: perform a query */
  function query($Query_String) {
/* No empty queries, please, since PHP4 chokes on them. */
if ($Query_String == "")
   /* The empty query string is passed on from the constructor,
   * when calling the class without a query, e.g. in situations
   * like these: '$db = new DB_Sql_Subclass;'
   */
   return 0;
if (!$this->connect()) {
   return 0; /* we already complained in connect() about that. */
};
# New query, discard previous result.
if ($this->Query_ID) {
   $this->free();
}
if ($this->Debug)
   printf("Debug: query = %s
\n", $Query_String);
$this->Query_ID = @mysql_query($Query_String,$this->Link_ID);
$this->Row = 0;
$this->Errno = mysql_errno();
$this->Error = mysql_error();
if (!$this->Query_ID) {
   $this->halt("Invalid SQL: ".$Query_String);
}
# Will return nada if it fails. That's fine.
return $this->Query_ID;
  }
  /* public: walk result set */
  function next_record() {
if (!$this->Query_ID) {
   $this->halt("next_record called with no query pending.");
   return 0;
}
$this->Record = @mysql_fetch_array($this->Query_ID);
$this->Row += 1;
$this->Errno  = mysql_errno();
$this->Error  = mysql_error();
$stat = is_array($this->Record);
if (!$stat && $this->Auto_Free) {
   $this->free();
}
return $stat;
  }
  /* public: position in result set */
  function seek($pos = 0) {
$status = @mysql_data_seek($this->Query_ID, $pos);
if ($status)
   $this->Row = $pos;
else {
   $this->halt("seek($pos) failed: result has ".$this->num_rows()." rows.");
   /* half assed attempt to save the day,
   * but do not consider this documented or even
   * desireable behaviour.
   */
   @mysql_data_seek($this->Query_ID, $this->num_rows());
   $this->Row = $this->num_rows();
   return 0;
}
return 1;
  }
  /* public: table locking */
  function lock($table, $mode = "write") {
$query = "lock tables ";
if(is_array($table)) {
   while(list($key,$value) = each($table)) {
      // text keys are "read", "read local", "write", "low priority write"
      if(is_int($key)) $key = $mode;
      if(strpos($value, ",")) {
      $query .= str_replace(",", " $key, ", $value) . " $key, ";
      } else {
      $query .= "$value $key, ";
      }
   }
   $query = substr($query, 0, -2);
} elseif(strpos($table, ",")) {
   $query .= str_replace(",", " $mode, ", $table) . " $mode";
} else {
   $query .= "$table $mode";
}
if(!$this->query($query)) {
   $this->halt("lock() failed.");
   return false;
}
$this->locked = true;
return true;
  }

  function unlock() {
// set before unlock to avoid potential loop
$this->locked = false;
if(!$this->query("unlock tables")) {
   $this->halt("unlock() failed.");
   return false;
}
return true;
  }
  /* public: evaluate the result (size, width) */
  function affected_rows() {
return @mysql_affected_rows($this->Link_ID);
  }
  function num_rows() {
return @mysql_num_rows($this->Query_ID);
  }
  function num_fields() {
return @mysql_num_fields($this->Query_ID);
  }
  /* public: shorthand notation */
  function nf() {
return $this->num_rows();
  }
  function np() {
print $this->num_rows();
  }
  function f($Name) {
if (isset($this->Record[$Name])) {
   return $this->Record[$Name];
}
  }
  function p($Name) {
if (isset($this->Record[$Name])) {
   print $this->Record[$Name];
}
  }
  /* public: sequence numbers */
  function nextid($seq_name) {
/* if no current lock, lock sequence table */
if(!$this->locked) {
   if($this->lock($this->Seq_Table)) {
      $locked = true;
   } else {
      $this->halt("cannot lock ".$this->Seq_Table." - has it been created?");
      return 0;
   }
}

/* get sequence number and increment */
$q = sprintf("select nextid from %s where seq_name = '%s'",
            $this->Seq_Table,
            $seq_name);
if(!$this->query($q)) {
   $this->halt('query failed in nextid: '.$q);
   return 0;
}

/* No current value, make one */
if(!$this->next_record()) {
   $currentid = 0;
   $q = sprintf("insert into %s values('%s', %s)",
               $this->Seq_Table,
               $seq_name,
               $currentid);
   if(!$this->query($q)) {
      $this->halt('query failed in nextid: '.$q);
      return 0;
   }
} else {
   $currentid = $this->f("nextid");
}
$nextid = $currentid + 1;
$q = sprintf("update %s set nextid = '%s' where seq_name = '%s'",
            $this->Seq_Table,
            $nextid,
            $seq_name);
if(!$this->query($q)) {
   $this->halt('query failed in nextid: '.$q);
   return 0;
}

/* if nextid() locked the sequence table, unlock it */
if($locked) {
   $this->unlock();
}

return $nextid;
  }
  /* public: return table metadata */
  function metadata($table = "", $full = false) {
$count = 0;
$id = 0;
$res = array();
/*
   * Due to compatibility problems with Table we changed the behavior
   * of metadata();
   * depending on $full, metadata returns the following values:
   *
   * - full is false (default):
   * $result[]:
   * [0]["table"]  table name
   * [0]["name"] field name
   * [0]["type"] field type
   * [0]["len"] field length
   * [0]["flags"]  field flags
   *
   * - full is true
   * $result[]:
   * ["num_fields"] number of metadata records
   * [0]["table"]  table name
   * [0]["name"] field name
   * [0]["type"] field type
   * [0]["len"] field length
   * [0]["flags"]  field flags
   * ["meta"][field name]  index of field named "field name"
   * This last one could be used if you have a field name, but no index.
   * Test:  if (isset($result['meta']['myfield'])) { ...
   */
// if no $table specified, assume that we are working with a query
// result
if ($table) {
   $this->connect();
   $id = @mysql_list_fields($this->Database, $table);
   if (!$id) {
      $this->halt("Metadata query failed.");
      return false;
   }
} else {
   $id = $this->Query_ID;
   if (!$id) {
      $this->halt("No query specified.");
      return false;
   }
}

$count = @mysql_num_fields($id);
// made this IF due to performance (one if is faster than $count if's)
if (!$full) {
   for ($i=0; $i
  /* public: find available table names */
  function table_names() {
$this->connect();
$h = @mysql_query("show tables", $this->Link_ID);
$i = 0;
while ($info = @mysql_fetch_row($h)) {
   $return[$i]["table_name"]    = $info[0];
   $return[$i]["tablespace_name"] = $this->Database;
   $return[$i]["database"]       = $this->Database;
   $i++;
}

@mysql_free_result($h);
return $return;
  }
  /* private: error handling */
  function halt($msg) {
$this->Error = @mysql_error($this->Link_ID);
$this->Errno = @mysql_errno($this->Link_ID);
if ($this->locked) {
   $this->unlock();
}
if ($this->Halt_On_Error == "no")
   return;
$this->haltmsg($msg);
if ($this->Halt_On_Error != "report")
   die("Session halted.");
  }
  function haltmsg($msg) {
printf("Database error: %s
\n", $msg);
printf("MySQL Error: %s (%s)
\n",
   $this->Errno,
   $this->Error);
  }

//----------------------------------
// 模块: 自定义函数
// 功能: 部分实用的数据库处理方法
// 作者: heiyeluren
// 时间: 2005-12-26
//----------------------------------
/**
  * 方法: execute($sql)
  * 功能: 执行一条SQL语句，主要针对没有结果集返回的SQL
  * 参数: $sql 需要执行的SQL语句，例如：execute("DELETE FROM table1 WHERE id = '1'")
  * 返回: 更新成功返回True，失败返回False
  */
function execute($sql)
{
  if (empty($sql))
  {
$this->error("Invalid parameter");
  }
  if (!$this->query($sql))
  {
return false;
  }
  return true;
}
/**
  * 方法: get_all($sql)
  * 功能: 获取SQL执行的所有记录
  * 参数: $sql  需要执行的SQL,例如: get_all("SELECT * FROM Table1")
  * 返回: 返回包含所有查询结果的二维数组
  */
function get_all($sql)
{
  $this->query($sql);
  $result_array = array();
  while($this->next_record())
  {

$result_array[] = $this->Record;
  }
  if (count($result_array)
/**
  * 方法: get_one($sql)
  * 功能: 获取SQL执行的一条记录
  * 参数: $sql 需要执行的SQL,例如: get_one("SELECT * FROM Table1 WHERE id = '1'")
  * 返回: 返回包含一条查询结果的一维数组
  */
function get_one($sql)
{
  $this->query($sql);
  if (!$this->next_record())
  {
return 0;
  }
  return $this->Record;
}
/**
  * 方法: get_limit($sql, $limit)
  * 功能: 获取SQL执行的指定数量的记录
  * 参数:
  * $sql  需要执行的SQL,例如: SELECT * FROM Table1
  * $limit 需要限制的记录数
  * 例如  需要获取10条记录, get_limit("SELECT * FROM Table1", 10);
  *
  * 返回: 返回包含所有查询结果的二维数组
  */
function get_limit($sql, $limit)
{
  $this->query($sql);
  $result_array = array();
  for ($i=0; $inext_record(); $i++)
  {
$result_array[] = $this->Record;
  }
  if (count($result_array)
/**
  * 方法: limit_query($sql, $start=0, $offset=20, $order="")
  * 功能: 为分页的获取SQL执行的指定数量的记录
  * 参数:
  * $sql  需要执行的SQL,例如: SELECT * FROM Table1
  * $start 记录的开始数, 缺省为0
  * $offset 记录的偏移量，缺省为20
  * $order 排序方式，缺省为空，例如：ORDER BY id DESC
  * 例如  需要获取从0到10的记录并且按照ID号倒排, get_limit("SELECT * FROM Table1", 0, 10, "ORDER BY id DESC");
  *
  * 返回: 返回包含所有查询结果的二维数组
  */
function limit_query($sql, $start=0, $offset=20, $order="")
{
  $sql = $sql ." $order  LIMIT $start,$offset";
  $this->query($sql);
  $result = array();
  while($this->next_record())
  {
$result[] = $this->Record;
  }
  if (count($result)
/**
  * 方法: count($table,$field="*", $where="")
  * 功能: 统计表中数据总数
  * 参数:
  * $table 需要统计的表名
  * $field 需要统计的字段，默认为*
  * $where 条件语句，缺省为空
  * 例如  按照ID统计所有年龄小于20岁的用户, count("user_table", "id", "user_age get_one($sql);
  if (!is_array($result))
  {
return 0;
  }
  return $result[0];
}
/**
  * 方法: insert($table,$dataArray)
  * 功能: 插入一条记录到表里
  * 参数:
  * $table  需要插入的表名
  * $dataArray 需要插入字段和值的数组，键为字段名，值为字段值，例如：array("user_name"=>"张三", "user_age"=>"20岁");
  * 例如比如插入用户张三，年龄为20, insert("users", array("user_name"=>"张三", "user_age"=>"20岁"))
  *
  * 返回: 插入记录成功返回True，失败返回False
  */
function insert($table,$dataArray)
{
  if (!is_array($dataArray) || count($dataArray)error("Invalid parameter");
  }
  while(list($key,$val) = each($dataArray))
  {
$field .= "$key,";
$value .= "'$val',";
  }
  $field = substr($field, 0, -1);
  $value = substr($value, 0, -1);
  $sql = "INSERT INTO $table ($field) VALUES ($value)";
  if (!$this->query($sql))
  {
return false;
  }
  return true;
}
/**
  * 方法: update($talbe, $dataArray, $where)
  * 功能: 更新一条记录
  * 参数:
  * $table  需要更新的表名
  * $dataArray 需要更新字段和值的数组，键为字段名，值为字段值，例如：array("user_name"=>"张三", "user_age"=>"20岁");
  * $where  条件语句
  * 例如比如更新姓名为张三的用户为李四，年龄为21
  * update("users",  array("user_name"=>"张三", "user_age"=>"20岁"),  "user_name='张三'")
  *
  * 返回: 更新成功返回True，失败返回False
  */
function update($talbe, $dataArray, $where)
{
  if (!is_array($dataArray) || count($dataArray)error("Invalid parameter");
  }
  while(list($key,$val) = each($dataArray))
  {
$value .= "$key = '$val',";
  }
  $value = substr($value, 0, -1);
  $sql = "UPDATE $talbe SET $value WHERE $where";
  if (!$this->query($sql))
  {
return false;
  }
  return true;
}
/**
  * 方法: delete($table, $where)
  * 功能: 删除一条记录
  * 参数:
  * $table  需要删除记录的表名
  * $where  需要删除记录的条件语句
  * 例如比如要删除用户名为张三的用户，delete("users",  "user_name='张三'")
  *
  * 返回: 更新成功返回True，失败返回False
  */
function delete($table, $where)
{
  if (empty($where))
  {
$this->error("Invalid parameter");
  }
  $sql = "DELETE FROM $table WHERE $where";
  if (!$this->query($sql))
  {
return false;
  }
  return true;
}
/**
  * 方法: error($msg="")
  * 功能: 显示错误信息后中止脚本
  * 参数: $msg 需要显示的错误信息
  * 返回: 无返回
  */
function error($msg="")
{
  echo "Error: $msg\n
\n";
  exit();
}
/**
  * 方法：get_insert_id()
  * 功能：获取最后插入的ID
  * 参数: 无参数
  * 返回：关闭成功返回ID，失败返回0
  */
function get_insert_id()
{
  return mysql_insert_id($this->Link_ID);
}
/**
  * 方法：close()
  * 功能：关闭当前数据库连接
  * 参数: 无参数
  * 返回：关闭成功返回true，失败返回false
  */
function close()
{
  return mysql_close($this->Link_ID);
}
}
?>

本文来自ChinaUnix博客，如果查看原文请点：http://blog.chinaunix.net/u/14986/showart_93336.html

文库|博客

返回列表

Chinaunix › 论坛 › 程序设计 › PHP › php文档中心 › 收集的db类

收集的db类 [复制链接]

浏览过的版块