| ＜%@ page contentType="text/html; charset=GBK" %＞ ＜%@ page import="java.sql.*" %＞ ＜%@ page import="javax.naming.*" %＞ ＜%@ page import="javax.sql.*" %＞ ＜%@ page import="tool.*" %＞ ＜%@ page import="orgNew.*" %＞ ＜%@ page import="org.w3c.dom.*" %＞ //上面主要是引用一些java类 ＜% try{ //request.setCharacterEncoding("GBK"); Document doc = XmlTool.createDocumentFromRequest(request); //建立web面文档请求的文档对象 Connection conn = ConnTool.getConnectionFromPool(); //获取请求的方法名 String mode=request.getParameter("mode"); //out.println("ccc"); //如果方法中没有其它参数则读取组织树数据 if(mode == null){ /* int OrgId = Integer.parseInt(request.getParameter("id")); String str = orgManager.getChildOrg(OrgId, conn); out.println(str); */ String str = orgManager.getTree(conn); //out.println(str); out.println(str); }else if(mode.equals("createOrg")){ //如果是createOrg方法则建立一个组织 int parentOrgId = Integer.parseInt(request.getParameter("parentOrgId")); //取出传递来的第一个参数parentOrgId int OrgId = orgManager.createOrg(parentOrgId, conn); //调用orgManager 类的createOrg方法来建立一个组织 out.println(OrgId); //返回结果 } conn.close(); } catch(Exception e){ e.printStackTrace(); } %＞ |
| public static Connection getConnectionFromPool() throws Exception { Context ctx = new InitialContext(); DataSource ds = (DataSource) ctx.lookup("java:/erpds"); return ds.getConnection(); } /** * 取数据库链接对象 * @return Connection 数据库链接对象 * @throws Exception */ /* public static Connection getDirectConnection() throws Exception { Class.forName("com.sybase.jdbc2.jdbc.SybDriver"); String url = "jdbc:sybase:Tds:19.64.13.16:4100/wydb?charset=iso_1"; String user = "sa"; String password = "2860008"; Connection conn = DriverManager.getConnection(url, user, password); return conn; } */ |
| package orgNew;// Java类所打的包 import tool.*; import java.sql.*; import java.util.*; // 引用Java类的 public class orgManager { public orgManager() { } public static void main(String[] args) throws Exception { Connection conn = tool.ConnTool.getDirectConnection();// 引用数据访问类 conn.setAutoCommit(false); orgManager orgManager1 = new orgManager(); orgManager1.createOrg(0, conn); //测试建立组织是否正确 } //建立一个组织 public static int createOrg(int parentOrgId, Connection conn) throws Exception { String sql = "insert into Org (OrgName, parentOrgId) values('新组织', ?)"; PreparedStatement pstat = conn.prepareStatement(sql); pstat.setInt(1, parentOrgId); pstat.executeUpdate(); pstat.close(); Statement stat = conn.createStatement(); String sql2 = "select max(OrgId) from Org"; ResultSet rs = stat.executeQuery(sql2); rs.next(); int OrgId = rs.getInt(1); rs.close(); stat.close(); System.out.println(OrgId); return OrgId; } } //通过递归得到组织信息的XML格式的数据 public static String getTree(Connection conn) throws Exception { StringBuffer ret = new StringBuffer();//定义可缓冲的字符流 ret.append("＜?xml version='1.0' encoding='gb2312'?＞＜tree id='0'＞");//定义XML格式的头信息 ret.append(" ＜item child='1' text='组织' id='1' ＞");//插入结点体。注树结点以item为标记 ret.append(getChildTree(1, conn)); ret.append("＜/item＞");//结点体结束标记 ret.append("＜/tree＞");//树结束标记 return ret.toString();//返回字符流 } public static String getChildTree(int OrgId, Connection conn) throws Exception { StringBuffer ret = new StringBuffer(); String sql = "select a.OrgId, a.OrgName, a.OrgCode,count(b.parentOrgId) from Org a " + "left join Org b on a.OrgId = b.parentOrgId " + "where a.parentOrgId = ? " + "group by a.OrgId, a.OrgName"; PreparedStatement pstat = conn.prepareStatement(sql); pstat.setInt(1, OrgId); ResultSet rs = pstat.executeQuery(); while (rs.next()) { int childOrgId = rs.getInt(1); String childOrgName = rs.getString(2); String childOrgCode = rs.getString(3); if (childOrgCode == null) { childOrgCode = " "; } if (childOrgName == null) { childOrgName = "新组织"; } int childCount = rs.getInt(3); if (childCount ＞ 0) { childCount = 1; } ret.append("＜item child='" + childCount + "' text='" + childOrgName + "' id='" +childOrgId + "' code='"+childOrgCode+"'＞"); ret.append(getChildTree(childOrgId, conn)); ret.append("＜/item＞"); } rs.close(); pstat.close(); return ret.toString(); } |
