树形递归求和（查询）！

beer.li

1、需求：在treeGrid，目前只存储了末级数据，而客户需要能自动逐级求和到根节点。

2、实现：我目前希望通过扩充query动作实现。请问如何实现？

3、我的概念及关系如下：

fID	Pid	Code	NameS	Num	NT	NL
C93D3B5381254D13A43E82E7E40E8E4E		01	01			0
EC83EB6C9AEC4AEE8C1F0D0C19868634	C93D3B5381254D13A43E82E7E40E8E4E	0101	0101			1
701299C8475F443E849E37A365D61F57	EC83EB6C9AEC4AEE8C1F0D0C19868634	010101	010101	1	nkLeaf	2
69519A6398D9493CA97AC14EA0E5026F	C93D3B5381254D13A43E82E7E40E8E4E	0102	0102			1
615E8F1F0FD54DFAA6F3118610E8C2BD	69519A6398D9493CA97AC14EA0E5026F	010201	010201	6	nkLeaf	2
2473CA8DC482495EB7F7910ACBD897B7		02	02	5	nkLeaf	0

jishuang

参考http://bbs.justep.com/forum.php?mod=viewthread&tid=37202

beer.li

这种方法解决不了需求呀。

jholy

两个方案
   1、数据库运算：数据库里构造一个视图，在视图里算出各级的合计
   2、代码运算：SQL查出数据，增加一个自定义合计列，用代码遍历数据集，合计出各级的合计

beer.li

希望第二种方式，但是不知道怎么动手。

beer.li

能否直接在query中扩充？

beer.li

系统提醒hehongbo已经回复，怎么进来了看不到呢？

hehongbo

1. 
   
2. //当不需要生成级别，就是数据表中已经维护了级别的情况下，就输入如下代码
   
3. public static void Sum() throws Exception{
   
4.        int max=getMaxLevel();
   
5.        while(max>0)
   
6.       {
   
7.              updateNum(max);//参照等级，依次更新它们的数量
   
8.              max--;
   
9.        }
   
10. }
    
11. 
    
12. 需要调用的方法代码如下：
    
13. public static void getMaxLevel() throws Exception{
    
14.       java.sql.Connection conn = null;
    
15.       java.sql.PreparedStatement pstmt = null
    
16.       ResultSet rs=null;
    
17.       int max=0;         
    
18.        try {
    
19.           // 取得数据库连接
    
20.                 conn = com.justep.model.ModelUtils.getConnectionInTransaction("/ParentSon/ParentSon/data");
    
21.                 pstmt = conn.prepareStatement("select max(fLevel) as tLevel from PA_FZ");
    
22.                 rs=pstmt.executeQuery();
    
23.                 rs.next();
    
24.                max=rs.getInt("tLevel");
    
25.             } catch (NamingException e) {
    
26.                      throw new RuntimeException(e);
    
27.             } catch (SQLException e) {
    
28.                     throw new RuntimeException(e);
    
29.             } finally {
    
30.                     rs.close();
    
31.                     rs=null;
    
32.                   try {
    
33.                             if (pstmt != null) {
    
34.                                    pstmt.close();
    
35.                              }
    
36.                       } catch (SQLException e) {
    
37.                               throw new RuntimeException(e);
    
38.                          }
    
39.                 }
    
40.                  return max;
    
41. }
    
42. 
    
43. //参照等级，依次更新它们的数量
    
44. public static void updateNum(int init) throws Exception{
    
45.       java.sql.Connection conn = null;
    
46.       java.sql.PreparedStatement pstmt = null;
    
47.           try {
    
48.           // 取得数据库连接
    
49.                 conn = com.justep.model.ModelUtils.getConnectionInTransaction("/ParentSon/ParentSon/data");
    
50.                 pstmt = conn.prepareStatement("update PA_FZ, (select fParent,sum(fNum) as tNum from PA_FZ where fLevel=? group by fParent) b set fNum=b.tNum where b.fParent = PA_FZ.fID ");
    
51.                pstmt.setInt(1, init);
    
52.                pstmt.execute();
    
53.             } catch (NamingException e) {
    
54.                     throw new RuntimeException(e);
    
55.             } catch (SQLException e) {
    
56.                     throw new RuntimeException(e);
    
57.             } finally{
    
58.                      try {
    
59.                                if (pstmt != null) {
    
60.                                       pstmt.close();
    
61.                                 }
    
62.                     } catch (SQLException e) {
    
63.                              throw new RuntimeException(e);
    
64.                     }
    
65.            }
    
66.                
    
67. }
    

复制代码

hehongbo

//数据库中级别需要自己来维护的，数据库增加级别字段且写如下代码：
public static void Sum() throws Exception{
        updateRootLevel();//设置根目录的级别
        int level=1;
        while(hasChildLevel(level)>0)//判断该级别下边是否有子节点
        {
               updateLevel(level);//逐级设置级别等级
               level++;
        }
       while(level>0)
       {
              updateNum(level);//参照等级，依次更新它们的数量
              level--;
       }
}

需要调用的方法如下：
//先获得父为空的数据，等级设置为1
public static void updateRootLevel() throws Exception{
           java.sql.Connection conn = null;
           java.sql.PreparedStatement pstmt = null;
          try {
                    conn = com.justep.model.ModelUtils.getConnectionInTransaction("/ParentSon/ParentSon/data");
                    pstmt = conn.prepareStatement("update PA_FZ set fLevel=1 where fParent is null");
                    pstmt.execute();
           } catch (NamingException e) {
                     throw new RuntimeException(e);
           } catch (SQLException e) {
                     throw new RuntimeException(e);
          } finally {
                     try {
                               if (pstmt != null) {
                                               pstmt.close();
                                  }
                        } catch (SQLException e) {
                                    throw new RuntimeException(e);
                        }
                    }
}

//判断该级别下边是否有子节点
public static int hasChildLevel(int init) throws Exception{
               java.sql.Connection conn = null;
               java.sql.PreparedStatement pstmt = null;
               ResultSet rs=null;
               int count=0;
                try {
                          // 取得数据库连接
                          conn = com.justep.model.ModelUtils.getConnectionInTransaction("/ParentSon/ParentSon/data");
                          pstmt = conn.prepareStatement("select count(*) as countsum from PA_FZ b where b.fParent in (select a.fID from PA_FZ a where a.fLevel=?)");
                          pstmt.setInt(1, init);
                          rs=pstmt.executeQuery();
                          rs.next();
                          count=rs.getInt("countsum");
                } catch (NamingException e) {
                             throw new RuntimeException(e);
                } catch (SQLException e) {
                             throw new RuntimeException(e);
                } finally {
                               rs.close();
                               rs=null;
                               try {
                                      if (pstmt != null) {
                                               pstmt.close();
                                      }
                                } catch (SQLException e) {
                                         throw new RuntimeException(e);
                                }
              }
                             return count;
}

//3.给子也赋值相应的等级
public static void updateLevel(int init) throws Exception{
                  java.sql.Connection conn = null;
                  java.sql.PreparedStatement pstmt = null;
                  try {
                         // 取得数据库连接
                          conn = com.justep.model.ModelUtils.getConnectionInTransaction("/ParentSon/ParentSon/data");
                          pstmt = conn.prepareStatement("update PA_FZ b,PA_FZ a set b.fLevel=? where b.fParent = a.fID and a.fLevel=? ");
                          pstmt.setInt(1, init+1);
                          pstmt.setInt(2, init);
                          pstmt.execute();
                        } catch (NamingException e) {
                                      throw new RuntimeException(e);
                        } catch (SQLException e) {
                                      throw new RuntimeException(e);
                       } finally {
                                  try {
                                       if (pstmt != null) {
                                                pstmt.close();
                                        }
                                  } catch (SQLException e) {
                                               throw new RuntimeException(e);
                                  }
                            }

}

//取得数字最大的等级
public static int getMaxLevel() throws Exception{
                java.sql.Connection conn = null;
                java.sql.PreparedStatement pstmt = null;
                ResultSet rs=null;
               int max=0;
                try {
                       // 取得数据库连接
                        conn = com.justep.model.ModelUtils.getConnectionInTransaction("/ParentSon/ParentSon/data");
                        pstmt = conn.prepareStatement("select max(fLevel) as tLevel from PA_FZ");
                        rs=pstmt.executeQuery();
                        rs.next();
                        max=rs.getInt("tLevel");
                    } catch (NamingException e) {
                                  throw new RuntimeException(e);
                    } catch (SQLException e) {
                                   throw new RuntimeException(e);
                   } finally {
                                  rs.close();
                                  rs=null;
                         try {
                                  if (pstmt != null) {
                                            pstmt.close();
                                     }
                         } catch (SQLException e) {
                                       throw new RuntimeException(e);
                         }
                   }
                         return max;
}

//参照等级，依次更新它们的数量
public static void updateNum(int init) throws Exception{
                java.sql.Connection conn = null;
                java.sql.PreparedStatement pstmt = null;
                try {
                           // 取得数据库连接
                            conn = com.justep.model.ModelUtils.getConnectionInTransaction("/ParentSon/ParentSon/data");
                            pstmt = conn.prepareStatement("update PA_FZ, (select fParent,sum(fNum) as tNum from PA_FZ where fLevel=? group by fParent) b set fNum=b.tNum where b.fParent = PA_FZ.fID ");  
                            pstmt.setInt(1, init);
                             pstmt.execute();
                      } catch (NamingException e) {
                                    throw new RuntimeException(e);
                      } catch (SQLException e) {
                                    throw new RuntimeException(e);
                      } finally {
                               try {
                                      if (pstmt != null) {
                                                pstmt.close();
                                       }
                                 } catch (SQLException e) {
                                               throw new RuntimeException(e);
                                 }
                     }

}