返回列表 回复 发帖
cnangel

管理员

Rank: 9Rank: 9Rank: 9

UID
1 
威望
1240 点 
金钱
24019 金币 
点卡
317 点 
1#
打印
tT
发表于 2004-5-18 15:50 | 只看该作者

无限分类&树型论坛的实现(数据库)

数据表参考:
  1. CREATE TABLE `mf_sort` (
  2. `sortid` SMALLINT( 3 ) UNSIGNED NOT NULL AUTO_INCREMENT ,
  3. `main` TINYINT( 2 ) UNSIGNED NOT NULL ,
  4. `parentid` SMALLINT( 3 ) UNSIGNED NOT NULL ,
  5. `layer` SMALLINT( 3 ) UNSIGNED NOT NULL ,
  6. `orders` TINYINT( 2 ) UNSIGNED NOT NULL ,
  7. `sort` VARCHAR( 100 ) NOT NULL ,
  8. PRIMARY KEY ( `sortid` ) ,
  9. INDEX ( `main` , `parentid` , `layer` , `orders` )
  10. );
  12. #sortid 类别编号
  13. #main  根分类
  14. #parentid 父ID
  15. #layer 分类等级
  16. #orders 排列顺序
复制代码
主要函数，用于添加分类时用，根分类除外:
  1. function get_main_layer_orders($parentid)
  2. {
  3.     global $x_db;
  4.     $sql  = "select `main`, `layer`, `orders` ";
  5.     $sql .= "from `mf_sort` ";
  6.     $sql .= "where `postid`='$parentid'";
  7.     $x_db->exec($sql);
  8.     $data   = $x_db->get_data();
  9.     $layer  = $data[0]['layer']+1;
  10.     $main   = $data[0]['main'];
  11.     $orders = $data[0]['orders'];
  13.     $sql  = "select `sortid` from `mf_sort` ";
  14.     $sql .= "where `parentid`='$parentid'";
  15.     $x_db->exec($sql);
  16.     $n = $x_db->n;
  17.     if ($n>0)
  18.     {
  19.         $lastid = $parentid;
  20.         get_lastid($lastid);
  21.         $sql    = "select `orders` from `mf_sort` ";
  22.         $sql   .= "where `sortid`='$lastid'";
  23.         $x_db->exec($sql);
  24.         $data   = $x_db->get_data();
  25.         $orders = $data[0][0];
  26.         $sql    = "update `mf_sort` ";
  27.         $sql   .= "set `orders`=`orders`+1 ";
  28.         $sql   .= "where `orders`>$orders and `main`='$main'";
  29.         $x_db->exec($sql);
  30.         $orders = $orders + 1;
  31.         return array($main, $layer, $orders);
  32.     }
  33.     else
  34.     {
  35.         $sql    = "update `mf_sort` ";
  36.         $sql   .= "set `orders`=`orders`+1 ";
  37.         $sql   .= "where `orders`>$orders and `main`='$main'";
  38.         $x_db->exec($sql);
  39.         return array($main, $layer, $orders+1);
  40.     }
  41. }
  43. //取得最后一个有效sortid
  44. function get_lastid(&$parentid)
  45. {
  46.     global $x_db;
  47.     $pre  = $parentid;
  48.     $sql  = "select max(`sortid`) as `id` ";
  49.     $sql .= "from `mf_sort` ";
  50.     $sql .= "where `parentid` = '$parentid'";
  51.     $x_db->exec($sql);
  52.     $data = $x_db->get_data();
  53.     $id   = $data[0]['id'];
  54.     if (empty($id))
  55.     {
  56.         $parentid = $pre;
  57.     }
  58.     else
  59.     {
  60.         $parentid = $id;
  61.         get_lastid($parentid);
  62.     }
  63. }
复制代码
$x_db 所用到的数据库类:
  1. /*****
  2. // +-------------------------------------------------
  3. // | Id: vbf_db.php                                 
  4. // +-------------------------------------------------
  5. // | Copyright (c)  
  6. // | Author：Arvan
  7. // +-------------------------------------------------
  8. // | Create Date: 2003-6-23
  9. // | Modify Date:
  10. // | Note:
  11. // |        数据库操作的类
  12. // |
  13. // |
  14. // +-------------------------------------------------
  15. *****/
  17. class TDb{
  18.         var $host;
  19.         var $user;
  20.         var $password;
  21.         var $database;
  23.         var $n;
  24.         var $result="";
  25.         var $conn="";
  27.         var $debug = true;
  28.         var $errMsg = "";
  30.         function TDb($host,$user,$password,$database){
  31.                 $this->host=$host;
  32.                 $this->user=$user;
  33.                 $this->password=$password;
  34.                 $this->conn=@mysql_connect($host,$user,$password) or die("<br><br><b>Err:</b>SQL busy,please try again later!");
  35.                
  36.                 $this->set_db($database);
  38.                 $this->errMsg ="";
  39.                 $this->n = 0;
  40.         }
  41.         //end of func tdb
  43.         function exec($sql, $db_name = ''){
  44.                 if (($db_name != '') && ($db_name != $this->database)){
  45.                         $old_db = $this->database;
  46.                         $this->set_db($db_name);
  47.                 }
  48.                 $this->n = 0;
  49.                 $this->result=@mysql_query($sql,$this->conn);
  50.                 if (mysql_error() != ""){
  51.                         $this->errMsg = mysql_error();
  52.                         if ($this->debug){
  53.                                 echo "<br><br><b>Err:</b>Fail to execute this SQL query：$sql<br><br>$this->errMsg";
  54.                         }else{
  55.                                 echo "<br><br><br><b>Err:</b>Please check the query is normal and make sure that It's allowed！";
  56.                         }
  57.                         exit;
  58.                 }
  59.                 $this->n = @mysql_affected_rows();
  60.                 if($old_db != ''){
  61.                         $this->set_db($old_db);
  62.                 }
  63.                 return true;
  64.         }
  66.         function get_data(){
  67.                 if($this->result==""){
  68.                         echo "<br><br><b>Err:</b>There is no result please run method exec(\$sql) first";
  69.                         exit;
  70.                 }
  71.                 $count=0;
  72.                 while($row=mysql_fetch_array($this->result)){
  73.                         $data[$count]=$row;
  74.                         $count++;
  75.                 }
  76.                 mysql_free_result($this->result);
  77.                 return $data;
  78.         }
  79.         //end of func get_data
  82.         function get_ins_id(){
  83.                 return mysql_insert_id();
  84.         }
  86.         function free(){
  87.                 mysql_close($this->conn);
  88.         }
  90.         function set_db($db_name){
  91.                 if($db_name != $this->database){//select new table while they are different
  92.                         @mysql_select_db($db_name) or die("<br><b>Err:</b>Fail to select $db_name table, make sure it's allowed to do this!");
  93.                         $this->database=$db_name;
  94.                 }
  95.                 return true;
  96.         }
  98.         function get_cur_db(){
  99.                 return $this->database;
  100.         }
  101. }
  102. //End of class db
复制代码
收藏 分享 评分

                     我是一个呼吸着现在的空气而生活在过去的人
               这样的注定孤独，孤独的身处闹市却犹如置身于荒漠
                                     我已习惯了孤独，爱上孤独
                                 他让我看清了自我，还原了自我
                             让我再静静的沉思中得到快乐和满足
                                   再孤独的世界里我一遍又一遍
                                   不厌其烦的改写着自己的过去
                                             延伸到现在与未来
                                       然而那只是泡沫般的美梦
                                 产生的时刻又伴随着破灭的到来
                         在灰飞烟灭的瞬间我看到的是过程的美丽
                                      而不是结果的悲哀。。。
回复 引用

订阅 TOP

返回列表