数据库中树结构数据,转换为Java对象树结构( 多叉树结构 )
总体就是图所表示所表示的转换,由数据库 => Java对象转换,代码比较简单,但对数据库压力可以大一点,多次查询.
主要是对象之间建立关联 No.2 : MapToTree()
思路为: 用pid(父id)作分组 ,这样每一个组的父节点是同一样,换句话说就是同一分组里,所有节点pid是相同的. 这样就针对分组操作,建立关联.
用Map做封装,key为父ID, value为分组List
用到了QueryRunner 这个是数据库工具,只要在网上找,下载就可以,能直接查询List.
QueryRunner jar包名=> commons-dbutils-1.5.jar
DTO代码:tree 类的代码.Javabean:
public class Tree{ private String AREA_ID; //主键ID private String AREA_NAME; //用来显示的名称 private String PARENT_ID; //父亲 参照AREA_ID private List<Tree> children = new ArrayList<Tree>(); //子节点
执行代码:
import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; import java.util.HashMap; import java.util.Iterator; import java.util.List; import java.util.Map; import java.util.Properties; import java.util.Set; import org.apache.commons.dbutils.DbUtils; import org.apache.commons.dbutils.QueryRunner; import org.apache.commons.dbutils.handlers.BeanListHandler; import org.apache.commons.dbutils.handlers.ColumnListHandler; /** * 数据库中树结构数据,转换为Java对象树结构( 多叉树结构 ) * @author liupengyuan * */ public class ListToTree { public static void main(String[] args) throws Exception { // No.1:从数据库中查询所以分组的节点 Map<String, List<Tree>> arrMap = queryGroupToMap(); // No.2:让节点与子节点之间彼此关联 MapToTree(arrMap); //从map里把根找到.返回List . 可能有多个根 List<Tree> list = arrMap.get("root"); System.out.println(list.size()); } /** * No.1: * 用父ID分组,用Map封装. key为父ID, value是所有父ID为KEY的节点数组array. * 每个数组里都是一组子节点,他们的根是同一个. 换句话说它们的父ID相同, 而Map的Key就是他们是父ID * @return * @throws SQLException */ @SuppressWarnings({ "deprecation", "unchecked", "rawtypes" }) public static Map<String,List<Tree>> queryGroupToMap() throws SQLException{ /* * 该表为中国地区组织,到 区县级 * 比如,中国下分:北京市,河北省,山东省... * 山东下分:济南市,青岛市,烟台市... * */ // QueryRunner 这个是数据库工具,只要在网上找下载就可以 commons-dbutils-1.5.jar QueryRunner qr = new QueryRunner(); Connection connection = getJdbcConnection("jdbc:oracle:thin:@192.168.3.34:1521:ORCL", "DSD_ZJK", "DSD_ZJK", "oracle.jdbc.driver.OracleDriver"); String sqlGroup = "select parent_id from HM_F_AREA t group by t.parent_id"; List<String> sqlGroupList = (List<String>)qr.query(connection, sqlGroup, new String[]{}, new ColumnListHandler("PARENT_ID")); Map<String,List<Tree>> arrMap = new HashMap<String,List<Tree>>(sqlGroupList.size()); for(int i=0; i <sqlGroupList.size(); i++){ String _pid = sqlGroupList.get(i); String sql = "select area_id , area_name , parent_id from HM_F_AREA t where t.parent_id = '"+_pid + "'"; List<Tree> listTree = (List<Tree>) qr.query(connection, sql, new String[]{} , new BeanListHandler(Tree.class)); arrMap.put( _pid , listTree ); } DbUtils.close(connection); return arrMap; } /** * No.2: * 让节点与子节点之间彼此关联 * 数据库格式并没有换,只是建立了关联 * @param arrMap */ public static void MapToTree(Map<String, List<Tree>> arrMap){ //所以pid的集成 Set<String> pidSet = arrMap.keySet(); //遍历所有的父ID,然后与所以的节点比对,父id与id相同的 //找出对应的tree节点,然后将该节点的 for (Iterator<String> it = pidSet.iterator(); it.hasNext();) { String pid = (String) it.next(); /* * 按分组的方式与pid比对. * 如果找到,那么将该pid分组的List,做为子节点 赋值给该找到的节点的 setChildren(list) * */ for (Iterator<String> it2 = pidSet.iterator(); it2.hasNext();) { String key = (String) it2.next(); //不查找自己的分组 if(pid.equals(key)){ break; } List<Tree> list = arrMap.get(key); // No.3:找出对应的tree节点,然后将该节点的 Tree tree = indexOfList(list , pid); //通过pid在Map里找出节点的子节点. List<Tree> list2 = arrMap.get(pid); if(tree!=null){ //TODO 这里是我自己定义的变成成,都不一样.所以需要自定义 // 把子节点List赋值给Tree节点的Children tree.setChildren(list2); } } } } /** * No.3: * 找出 list 中元素的id与pid相关的并返回.对应关系为: id与父id相同 * @param list * @param pid * @return */ public static Tree indexOfList(List<Tree> list , String pid){ for(int i=0 ;i<list.size();i++){ Tree tree = list.get(i); /* * pid:是 父ID * area_id:是 ID */ //TODO 这里是我自己定义的变成成,都不一样.所以需要自定义 if(pid.equals(tree.getAREA_ID())){ return tree; } } return null; } /** * 数据库连接 * @param url * @param username * @param password * @param driverClassName * @return */ public static Connection getJdbcConnection(String url, String username, String password, String driverClassName){ Connection connection = null; try { Properties props =new Properties(); props.put("user",username); props.put("password",password); props.put("remarksReporting","true"); try { Class.forName(driverClassName).newInstance(); } catch (InstantiationException e) { e.printStackTrace(); } catch (IllegalAccessException e) { e.printStackTrace(); } catch (ClassNotFoundException e) { e.printStackTrace(); } connection=DriverManager.getConnection(url,props); } catch (SQLException e) { e.printStackTrace(); } return connection; } }
郑重声明:本站内容如果来自互联网及其他传播媒体,其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享,并不代表本站赞同其观点和对其真实性负责,也不构成任何其他建议。