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

cnangel

数据表参考:

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

复制代码