【Mysql左右值】左右值法實現Mysql無限級分類

數據表結構和數據

表結構

 

[sql] view plaincopy

1. CREATE TABLE `classify` (  
2. `id` INT(10) UNSIGNED NOT NULL AUTO_INCREMENT,  
3. `name` VARCHAR(20) NOT NULL COLLATE 'utf8_general_ci',  
4. `lft` INT(11) NOT NULL,  
5. `rgt` INT(11) NOT NULL,  
6. `parentId` INT(11) NOT NULL,  
7. PRIMARY KEY (`id`),  
8. INDEX `scope` (`lft`, `rgt`)  
9. )  
10. COLLATE='utf8_bin'  
11. ENGINE=InnoDB  
12. AUTO_INCREMENT=13;  

測試數據

 

[sql] view plaincopy

1. INSERT INTO `classify` VALUES (1, '鄭州', 1, 16, -1);  
2. INSERT INTO `classify` VALUES (19, '滎陽', 10, 15, 1);  
3. INSERT INTO `classify` VALUES (20, '滎陽東', 13, 14, 19);  
4. INSERT INTO `classify` VALUES (21, '滎陽西', 11, 12, 19);  
5. INSERT INTO `classify` VALUES (22, '開封', 2, 9, 1);  
6. INSERT INTO `classify` VALUES (23, '開封東', 7, 8, 22);  
7. INSERT INTO `classify` VALUES (24, '開封西', 5, 6, 22);  
8. INSERT INTO `classify` VALUES (25, '開封府', 3, 4, 22);  

 

文件結構

 

[html] view plaincopy

1. /——  
2. 　　|--index.php 入口文件  
3. 　　|--conf.php  配置文件  
4. 　　/db  
5. 　　|--DB.class.php 數據庫操做類  
6. 　　/lib  
7. 　　|--ClassifyTree.class.php 左右樹操做文件【core】  

 

index.php 代碼

 

[php] view plaincopy

1. <?php  
2. /** 
3.  * action 
4.  * showAll      查看整個分類樹 
5.  * showOne      查看某個分類的子類 
6.  * showPath     查看某個子類到根分類的路徑 
7.  * showAdd      顯示增長分類的界面 
8.  * add          增長子分類 
9.  * delete       刪除分類 
10.  * showModify   顯示修改分類信息的界面 
11.  * modify       修改分類信息 
12.  * 
13.  * 假設已經有個  根分類  鄭州 
14.  */  
15. (isset($_GET['action']) && $action = $_GET['action'] ) || $action = 'showAll';  
16. header('Content-type:text/html;charset=utf-8');  
17.   
18. //實例化分類操做類  
19. include_once './db/DB.class.php';  
20. $conf = include_once './conf.php';  
21. include_once './lib/ClassifyTree.class.php';  
22. $tree = new ClassifyTree($conf);  
23.   
24. /** 
25.  * [顯示增長分類的界面] 
26.  * @return [boolean] [插入成功，返回true；不然，返回false] 
27.  */  
28. function add(){  
29.     global $tree;  
30.     $parentId = $_GET['parent'];  
31.     $name     = $_GET['name'];  
32.     $result   = $tree->insertNew($parentId, $name);  
33.     return $result;  
34. }  
35.   
36. /** 
37.  * [顯示增長分類頁面] 
38.  */  
39. function showAdd(){  
40.     $parentId = $_GET['parent'];  
41.     echo '<form action="." method="get">';  
42.     echo '<input type="hidden" name="action" value="add">';  
43.     echo '<br/>名稱：<input type="text" name="name" style="width:200px;">';  
44.     echo '<input type="hidden" name="parent" value="'.$parentId.'">';  
45.     echo '<br/><input type="submit" style="width:130px;height:25px;"></form>';  
46. }  
47.   
48. /** 
49.  * [顯示一個子分類下的全部分類] 
50.  */  
51. function showOne(){  
52.     global $tree;  
53.     $id = $_GET['id'];  
54.     $classifyInfo = $tree->getOne($id);  
55.     //遞歸顯示分類信息  
56.     displayClassify($classifyInfo);  
57. }  
58.   
59. /** 
60.  * [顯示某個分類到根分類的路徑] 
61.  */  
62. function showPath(){  
63.     global $tree;  
64.     $id = $_GET['id'];  
65.     $pathArr = $tree->getPath($id);  
66.     displayPath($pathArr);  
67. }  
68.   
69. function getPath($id){  
70.     global $tree;  
71.     $pathArr = $tree->getPath($id);  
72.     displayPath($pathArr);  
73. }  
74.   
75. /** 
76.  * [顯示全部的分類信息] 
77.  * @return [type] [description] 
78.  */  
79. function showAll(){  
80.     global $tree;  
81.     $classifyArr = $tree->getAll();  
82.     displayClassify($classifyArr);  
83. }  
84.   
85. /** 
86.  * [刪除一個分類] 
87.  * @return [boolean] [刪除成功，則返回true；不然，則返回false] 
88.  */  
89. function delete(){  
90.     global $tree;  
91.     $id = $_GET['id'];  
92.     $result = $tree->delete($id);  
93.     return $result;  
94. }  
95.   
96. /** 
97.  * [顯示修改id的界面] 
98.  * @return [bolean] [若是查詢失敗，則返回false] 
99.  */  
100. function showModify(){  
101.     global $tree;  
102.     $id = $_GET['id'];  
103.     $info = $tree->searchById($id);  
104.     if(false === $info){  
105.         return false;  
106.     }  
107.     echo '<form action="." method="get">';  
108.     echo '<input type="hidden" name="action" value="modify">';  
109.     echo '名稱：<input type="text" name="name" value="'.$info['name'].'" style="width:200px;height:25px;">';  
110.     echo '<input type="hidden" name="id" value="'.$info['id'].'">';  
111.     echo '<br/><input type="submit" style="width:120px;height:25px;">';  
112.     echo '</form>';  
113. }  
114.   
115. /** 
116.  * [修改分類信息] 
117.  * @return [boolean] [修改爲功，則返回true；不然，返回false] 
118.  */  
119. function modify(){  
120.     global $tree;  
121.     $name = $_GET['name'];  
122.     $id   = $_GET['id'];  
123.     $result = $tree->modify($name, $id);  
124.     return $result;  
125. }  
126. /** 
127.  * [輸出路徑數組] 
128.  * @param  [array] $path [路徑數組] 
129.  */  
130. function displayPath($path){  
131.     foreach($path as $oneStep){  
132.         echo '<a href="?action=showPath&id='.$oneStep['id'].'">'.$oneStep['name'].'</a> >> ';  
133.     }  
134. }  
135.   
136. /** 
137.  * [遞歸顯示分類信息] 
138.  * @param  [array] $classify [分類信息] 
139.  * @param  [int]   $interval [縮進長度] 
140.  */  
141. function displayClassify($classify, $interval=0){  
142.     foreach($classify as $key=>$val){  
143.         for($i=0;$i<$interval;$i++){  
144.             echo '    ';  
145.         }  
146.         echo $key;  
147.         if(is_array($val)){  
148.             echo ' => array(<br/>';  
149.             displayClassify($val, $interval+1);  
150.             indentation($interval);  
151.             echo ')<br/>';  
152.         }else{  
153.             echo ' => '.$val;  
154.             if('id' == $key){  
155.                 echo ' <a href="?action=showAdd&parent='.$val.'">增長子節點</a>';  
156.                 echo ' <a href="?action=showModify&id='.$val.'">修改節點</a>';  
157.                 echo ' <a href="?action=delete&id='.$val.'">刪除節點</a>';  
158.                 echo '<br/>';  
159.                 indentation($interval);  
160.                 getPath($val);  
161.             }  
162.             echo '<br/>';  
163.         }  
164.     }  
165. }  
166.   
167. function indentation($interval){  
168.     for($i=0;$i<$interval;$i++){  
169.         echo '    ';  
170.     }  
171. }  
172. //執行請求  
173. $result = $action();  
174.   
175. if(false === $result){  
176.     echo 'failed<br/>';  
177.     echo $tree->getError();  
178. }else{  
179.     echo 'success';  
180. }  

 

conf.php 文件

 

[php] view plaincopy

1. <?php  
2. return array(  
3.         'dbHost'=>'localhost',  
4.         'dbName'=>'classify_infinite',  
5.         'dbUser'=>'root',  
6.         'dbPass'=>'root',  
7.         'dbCharset'=>'utf8'  
8.     );  

 

DB.class.php  文件

 

[php] view plaincopy

1. <?php  
2. /** 
3.  * 數據庫操做類 
4.  * 執行數據庫的增刪改查操做 
5.  */  
6. class DB {  
7.     private $dbHost;//數據庫主機名  
8.     private $dbName;//數據庫名稱  
9.     private $username;//數據庫用戶  
10.     private $password;//數據庫密碼  
11.     private $charset;//數據庫字符集編碼  
12.     private $link;//數據庫鏈接資源  
13.     private $error = null;//錯誤信息  
14.     /** 
15.      * 構造函數 
16.      * 根據傳遞進來的conf數組給局部變量賦初值 
17.      * 鏈接數據庫 
18.      * @param array $conf 
19.      */  
20.     public function __construct($conf) {  
21.         if(!isset($conf['dbHost']) || !isset($conf['dbName']) || !isset($conf['dbUser']) || !isset($conf['dbPass']) || !isset($conf['dbCharset'])){  
22.             $this->error = '配置不完整';  
23.         }else{  
24.             $this->dbHost  = $conf['dbHost'];  
25.             $this->dbName  = $conf['dbName'];  
26.             $this->username = $conf['dbUser'];  
27.             $this->password = $conf['dbPass'];  
28.             $this->charset = $conf['dbCharset'];  
29.             //鏈接數據庫服務器  
30.             $this->link = mysql_connect($this->dbHost,$this->username,$this->password);  
31.             mysql_query("SET NAMES '{$this->charset}'");  
32.             if(false === $this->link){  
33.                 $this->error = '鏈接數據庫失敗';  
34.             }elseif(!mysql_select_db($this->dbName,$this->link)){//選擇數據庫  
35.                 $this->error = '鏈接數據庫失敗';  
36.             }  
37.         }  
38.     }  
39.     /** 
40.      * 執行查詢操做 
41.      * @param string $sql   要執行的sql 
42.      * @param [boolean] $key [若是標記爲true,將結果以id爲主鍵返回；若是標記爲false，將結果以數字爲主鍵返回] 
43.      * @return boolean|array   若是執行出錯，則記錄錯誤，返回false；不然，返回查詢獲得的結果集 
44.      */  
45.     public function queryList($sql, $key=false){  
46.         $resource = mysql_query($sql);  
47.         if(false === $resource){  
48.             $this->error = mysql_error();  
49.             return false;  
50.         }  
51.         $result = array();  
52.         while ($row = mysql_fetch_assoc($resource)) {  
53.             if(false === $key){  
54.                 array_push($result,$row);  
55.             }else{  
56.                 $result[$row['id']] = $row;  
57.             }  
58.         }  
59.         return $result;  
60.     }  
61.     /** 
62.      * [執行查詢操做，返回一個結果數組] 
63.      * @param  [string] $sql [要執行的sql] 
64.      * @return [array|false]      [查詢獲得的結果集；若是查詢出錯，返回false] 
65.      */  
66.     public function queryOne($sql){  
67.         $resource = mysql_query($sql);  
68.         if(false === $resource){  
69.             $this->error = mysql_error();  
70.             return false;  
71.         }  
72.         $result = mysql_fetch_assoc($resource);  
73.         return $result;  
74.     }  
75.     /** 
76.      * 執行插入操做 
77.      * @param string $sql   要執行的sql 
78.      * @return boolean      若是執行出錯,則記錄錯誤並返回false；若是執行成功，則直接返回插入的數據的id 
79.      */  
80.     public function insert($sql){  
81.         $result = mysql_query($sql);  
82.         if(false === $result){  
83.             $this->error = mysql_error();  
84.             return false;  
85.         }else{  
86.             return mysql_insert_id();  
87.         }  
88.     }  
89.     /** 
90.      * 執行更新操做 
91.      * @param string $sql   要執行的sql 
92.      * @return boolean      若是執行出錯，則記錄錯誤信息並返回false；若是執行成功，則直接返回所影響的行數 
93.      */  
94.     public function update($sql){  
95.         $result = mysql_query($sql);  
96.         if(false === $result){  
97.             $this->error = mysql_error();  
98.             return false;  
99.         }else{  
100.             return mysql_affected_rows();  
101.         }  
102.     }  
103.     /** 
104.      * 執行刪除操做 
105.      * 調用更新操做來完成 
106.      */  
107.     public function delete($sql){  
108.         return $this->update($sql);  
109.     }  
110.     /** 
111.      * 獲取錯誤信息 
112.      * 若是錯誤信息不存在，則返回null 
113.      * @return string   返回值；返回當前的錯誤信息 
114.      */  
115.     public function getError(){  
116.         return $this->error;  
117.     }  
118.     public function __destruct(){  
119.         mysql_close($this->link);  
120.     }  
121.     /** 
122.      * 開啓事務 
123.      */  
124.     public function begin()  
125.     {  
126.         mysql_query('begin');  
127.     }  
128.     /** 
129.      * 事務回滾 
130.      */  
131.     public function rollBack()  
132.     {  
133.         mysql_query('rollback');  
134.     }  
135.     /** 
136.      * 事務提交 
137.      */  
138.     public function submit()  
139.     {  
140.         mysql_query('commit');  
141.     }  
142. }  

 

ClassifyTree.class.php 文件

 

[php] view plaincopy

1. <?php  
2. class ClassifyTree  
3. {  
4.     private $db;  
5.     private $error;  
6.     public function __construct($conf){  
7.         $this->db = new DB($conf);  
8.         $this->error = $this->db->getError();  
9.     }  
10.     /** 
11.      * [返回錯誤信息] 
12.      * @return [string] [錯誤信息] 
13.      */  
14.     public function getError(){  
15.         return $this->error;  
16.     }  
17.     /** 
18.      * [獲取整個分類樹結構] 
19.      * @return [array|boolean] [若是查詢失敗，則返回false；不然，返回格式化後的分類數組] 
20.      */  
21.     public function getAll(){  
22.         $sql = 'SELECT `id`,`name`,`lft`,`rgt`,`parentId` FROM `classify`';  
23.         $classifyInfo = $this->db->queryList($sql);  
24.         if(false === $classifyInfo){  
25.             $this->error = '查詢出錯。'.$this->db->getError();  
26.             return false;  
27.         }  
28.         //格式化數組  
29.         $result = $this->format($classifyInfo);  
30.         return $result;  
31.     }  
32.     /** 
33.      * [格式化檢索到的分類數據庫中的數據，將信息組織成 
34.      * array( 
35.      *      array(** 分類a **) 
36.      *      'childrens'=>array( 
37.      *              array(** 分類b **) 
38.      *              'childrens'=>array( 
39.      *                  ...... 
40.      *              ) 
41.      *          ) 
42.      * ) 
43.      * 的形式 
44.      * ] 
45.      * @param  [array]  $classifyInfo [須要格式化的數據] 
46.      * @param  [integer] $parentId [父分類的id] 
47.      * @return [array]    [格式化後的數據] 
48.      */  
49.     private function format(&$classifyInfo, $parentId=-1){  
50.         $result = array();//須要返回的結果數組  
51.         foreach($classifyInfo as $key=>$oneInfo){  
52.             if($parentId == $oneInfo['parentId']){  
53.                 $childrens = $this->format($classifyInfo, $oneInfo['id']);  
54.                 if(!empty($childrens)){  
55.                     $oneInfo['childrens'] = $childrens;  
56.                 }  
57.                 $result[] = $oneInfo;  
58.             }  
59.         }  
60.         return $result;  
61.     }  
62.     /** 
63.      * [獲取某個分類到根分類的路徑] 
64.      * @param  [int] $id [分類id] 
65.      * @return [array|boolean] [若是查詢失敗，則返回false；不然，返回路徑數組] 
66.      */  
67.     public function getPath($id){  
68.         //查詢$id的分類和根分類的左右值  
69.         $sql = 'SELECT `id`,`lft`,`rgt` FROM `classify` WHERE `id`='.$id.' or `parentId`=-1';  
70.         $classifyInfo = $this->db->queryList($sql, true);  
71.         if(false === $classifyInfo){  
72.             $this->error = '查詢失敗：'.$this->db->getError();  
73.             return false;  
74.         }  
75.         if(1 != count($classifyInfo)){  
76.             $left = $classifyInfo[$id]['lft'];  
77.             $right = $classifyInfo[$id]['rgt'];  
78.             unset($classifyInfo[$id]);  
79.             $classifyInfo = array_pop($classifyInfo);  
80.             $rootLeft = $classifyInfo['lft'];  
81.             $rootRight = $classifyInfo['rgt'];  
82.         }else{  
83.             $rootLeft = $left = $classifyInfo[$id]['lft'];  
84.             $rootRight = $right = $classifyInfo[$id]['rgt'];  
85.         }  
86.         //查詢當前節點到根節點的距離  
87.         $sql = 'SELECT `id`,`name`,`lft`,`rgt`,`parentId` '  
88.         .'FROM `classify` '  
89.         .'WHERE `lft`>='.$rootLeft.' AND `lft`<='.$left.' AND `rgt`<='.$rootRight.' AND `rgt`>='.$right  
90.         .' ORDER BY `lft` ';  
91.         $classifyPath = $this->db->queryList($sql);  
92.         if(false === $classifyPath){  
93.             $this->error = '查詢失敗:'.$this->db->getError();  
94.             return false;  
95.         }  
96.         return $classifyPath;  
97.     }  
98.     /** 
99.      * [獲取指定分類下的分類] 
100.      * @param  [int] $id [分類id] 
101.      * @return [array|boolean] [若是查詢失敗，則返回false；不然，返回格式化後的分類數組] 
102.      */  
103.     public function getOne($id){  
104.         //查詢$id分類的左右值  
105.         $sql = 'SELECT `lft`,`rgt` FROM `classify` WHERE `id`='.$id;  
106.         $oneInfo = $this->db->queryOne($sql);  
107.         if(false === $classifyInfo){  
108.             $this->error = '查詢失敗：'.$this->db->getError();  
109.             return false;  
110.         }  
111.         $left = $oneInfo['lft'];  
112.         $right = $oneInfo['rgt'];  
113.         //查詢該分類下的全部分類  
114.         $sql = 'SELECT `id`,`name`,`lft`,`rgt`,`parentId` FROM `classify` WHERE `lft`>='.$left.' AND `rgt`<='.$right;  
115.         $classifyInfo = $this->db->queryList($sql);  
116.         if(false === $classifyPath){  
117.             $this->error = '查詢失敗:'.$this->db->getError();  
118.             return false;  
119.         }  
120.         //格式化數組  
121.         $result = $this->format($classifyInfo);  
122.         return $result;  
123.     }  
124.     /** 
125.      * [在一個分類下添加子分類] 
126.      * @param  [int] $parentId [父分類的id] 
127.      * @param  [string] $name [增長的分類的名稱] 
128.      * @return [boolean] [增長成功，則返回true；不然，返回false] 
129.      */  
130.     public function insertNew($parentId, $name){  
131.         $this->db->begin();  
132.         //查詢當前分類的左右值  
133.         $sql = 'SELECT `lft` FROM `classify` WHERE `id`='.$parentId;  
134.         $oneInfo = $this->db->queryOne($sql);  
135.         if(false === $oneInfo){  
136.             $this->error = '查詢失敗：'.$this->db->getError();  
137.             $this->db->rollBack();  
138.             return false;  
139.         }  
140.         $left = $oneInfo['lft'];  
141.   
142.         //將全部左值大於當前分類左值的分類左右值加2  
143.         $sql = 'UPDATE `classify` SET `lft`=`lft`+2,`rgt`=`rgt`+2 WHERE `lft`>'.$left;  
144.         $result = $this->db->update($sql);  
145.         if(false === $result){  
146.             $this->error = '更新節點左右值失敗.'.$this->db->getError();  
147.             $this->db->rollBack();  
148.             return false;  
149.         }  
150.         //更新右節點大於當前分類左值的分類節點  
151.         $sql = 'UPDATE `classify` SET `rgt`=`rgt`+2 WHERE `rgt`>'.$left.' AND `lft`<='.$left;  
152.         $result = $this->db->update($sql);  
153.         if(false === $result){  
154.             $this->error = '更新節點右值失敗.'.$this->db->getError();  
155.             $this->db->rollBack();  
156.             return false;  
157.         }  
158.         //插入新的節點  
159.         $left += 1;  
160.         $right = $left+1;  
161.         $sql = "INSERT INTO `classify` VALUES(null, '{$name}', {$left}, {$right}, {$parentId})";  
162.         $result = $this->db->insert($sql);  
163.         if(false === $result){  
164.             $this->error = '插入新節點失敗.'.$this->db->getError();  
165.             $this->db->rollBack();  
166.             return false;  
167.         }  
168.         $this->db->submit();  
169.         return true;  
170.     }  
171.     /** 
172.      * [刪除一個分類信息] 
173.      * @param  [int] $id [分類id] 
174.      * @return [boolean] [刪除成功，則返回true；不然，返回true] 
175.      */  
176.     public function delete($id){  
177.         $this->db->begin();  
178.         //查詢當前分類的左右值  
179.         $sql = 'SELECT `lft`,`rgt` FROM `classify` WHERE `id`='.$id;  
180.         $oneInfo = $this->db->queryOne($sql);  
181.         if(false === $oneInfo){print_r(debug_backtrace());  
182.             $this->error = '查詢失敗：'.$this->db->getError();  
183.             $this->db->rollBack();  
184.             return false;  
185.         }  
186.         $left   = $oneInfo['lft'];  
187.         $right  = $oneInfo['rgt'];  
188.         $dValue = $right - $left + 1;  
189.         //刪除當前分類及其子分類  
190.         $sql = 'DELETE FROM `classify` WHERE `lft`>='.$left.' AND `rgt`<='.$right;  
191.         $result  = $this->db->delete($sql);  
192.         if(false === $result){  
193.             $this->error = '刪除失敗:'.$this->db->getError();  
194.             $this->db->rollBack();  
195.             return false;  
196.         }  
197.         //將全部左值大於當前分類左值的分類左右值加2  
198.         $sql = 'UPDATE `classify` SET `lft`=`lft`-'.$dValue.' , `rgt`=`rgt`-'.$dValue.' WHERE `lft`>'.$right;  
199.         $result = $this->db->update($sql);  
200.         if(false === $result){  
201.             $this->error = '更新節點左值失敗.'.$this->db->getError();  
202.             $this->db->rollBack();  
203.             return false;  
204.         }  
205.         //更新右節點大於當前分類左值的分類節點  
206.         $sql = 'UPDATE `classify` SET `rgt`=`rgt`-'.$dValue.' WHERE `lft`<'.$left.' AND '.' `rgt`>'.$left;  
207.         $result = $this->db->update($sql);  
208.         if(false === $result){  
209.             $this->error = '更新節點右值失敗.'.$this->db->getError();  
210.             $this->db->rollBack();  
211.             return false;  
212.         }  
213.         $this->db->submit();  
214.         return true;  
215.     }  
216.     /** 
217.      * [根據id查詢一個分類的信息] 
218.      * @param  [int] $id [分類id] 
219.      * @return [array|boolean] [查詢失敗，則返回false；不然，返回分類信息數組] 
220.      */  
221.     public function searchById($id){  
222.         //查詢當前分類的左右值  
223.         $sql = 'SELECT `id`,`name`,`lft`,`rgt`,`parentId` FROM `classify` WHERE `id`='.$id;  
224.         $oneInfo = $this->db->queryOne($sql);  
225.         if(false === $oneInfo){  
226.             $this->error = '查詢失敗：'.$this->db->getError();  
227.             return false;  
228.         }  
229.         return $oneInfo;  
230.     }  
231.     /** 
232.      * [保存修改過的分類信息] 
233.      * @param  [string] $newName [分類的新名稱] 
234.      * @param  [int] $id [分類id] 
235.      * @return [boolean] [若是修改爲功，則返回true；不然，返回false] 
236.      */  
237.     public function modify($newName, $id){  
238.         $sql = "UPDATE `classify` SET `name`='{$newName}' WHERE `id`={$id}";  
239.         $result = $this->db->update($sql);  
240.         if(false === $result){  
241.             $this->error = '更新失敗：'.$this->db->getError();  
242.             return false;  
243.         }  
244.         return true;  
245.     }  
246. }