卫监接口项目一些零碎

把字符串写入XML文件

/** * 创建文件夹 * @param filePath * @return */ public boolean makeDirs() { String folderName = IReportServer.getTempDir() + File.separator + "hubei"; if (StrFunc.isNull(folderName)) { return false; } File folder = new File(folderName); return (folder.exists() && folder.isDirectory()) ? true : folder.mkdirs(); } /** * 向工作目录写XML文件保存数据 * @return * @throws Exception */ public void writeXml2WorkRoot(String xmlStr) throws Exception { Document document = DocumentHelper.parseText(xmlStr); //写入.xml文件 writerDocumentToNewFile(document); } //document写入新的文件 private void writerDocumentToNewFile(Document document) throws Exception { //输出格式 OutputFormat format = OutputFormat.createPrettyPrint(); //设置编码 format.setEncoding("UTF-8"); //XMLWriter 指定输出文件以及格式 if (makeDirs()) { XMLWriter writer = new XMLWriter(new OutputStreamWriter(new FileOutputStream(new File(IReportServer.getTempDir() + File.separator + "hubei" + File.separator + System.currentTimeMillis() + ".xml")), "UTF-8"), format); try { System.out.println("写入XML成功"); //写入新文件 writer.write(document); writer.flush(); } finally { writer.close(); } } else { System.out.println("写入XML失败"); } }

根据不同的数据解析XML文件，一种直接解析XML文件，另外一种解析XML格式的字符串

/** * 解析XML * @param url * @return * @throws Exception */ public List readXml(String url) throws Exception { List messages = new ArrayList(); SAXReader reader = new SAXReader(); File file = new File(url); Document document = reader.read(file); Element root = document.getRootElement(); List childElements = root.elements(); ArrayList list = new ArrayList(); initList(list); Connection conn = IReportServer.getInstance().getConnection(); try { //clearTable(conn); /** * 解析XML文件，存入Data中 */ Iterator iterator = childElements.iterator(); do { Element child = (Element) iterator.next(); HashMap map = new HashMap(); String id = child.elementText("ID"); for (int i = 0; i < keys.length; i++) { map.put(keys[i], child.elementText(keys[i])); } Data data = new Data(id, map); Message message = data.check(); if (message == null) { messages.add(insertData(messages, data, conn, list)); } else { messages.add(message); } } while (iterator.hasNext()); } finally { conn.close(); } return messages; } /** * 根据字符串解析 * @param xml * @return * @throws Exception */ public List readXmlByString(String xml) throws Exception { List messages = new ArrayList(); Document document = DocumentHelper.parseText(xml); Element root = document.getRootElement(); List childElements = root.elements(); ArrayList list = new ArrayList(); initList(list); Connection conn = IReportServer.getInstance().getConnection(); try { //clearTable(conn); /** * 解析XML文件，存入Data中 */ Iterator iterator = childElements.iterator(); do { Element child = (Element) iterator.next(); HashMap map = new HashMap(); String id = child.elementText("ID"); for (int i = 0; i < keys.length; i++) { map.put(keys[i], child.elementText(keys[i])); } Data data = new Data(id, map); Message message = data.check(); if (message == null) { messages.add(insertData(messages, data, conn, list)); } else { messages.add(message); } } while (iterator.hasNext()); } finally { conn.close(); } return messages; }

插入数据

/** * 插入数据 * @param data * @param conn * @param list * @return * @throws Exception */ public Message insertData(List Messages, Data data, Connection conn, List list) throws Exception { //返回错误消息 Message message = new Message(); dataMap = data.getDataMap(); message.setId(data.getID()); //已知属性名情况下 if (!list.contains(data.getID())) { list.add(data.getID()); excuteDone(insertSql, 2, conn, data, dataMap); //设置成功 message.setIsSuccess(0); message.setReason("插入成功"); } else { //设置失败 message.setIsSuccess(1); message.setReason("已存在"); //更新数据 //System.out.println(deleteSql); PreparedStatement pstat = conn.prepareStatement(deleteSql); try { pstat.setString(1, data.getID()); pstat.executeQuery(); } finally { pstat.close(); } excuteDone(insertSql, 2, conn, data, dataMap); message.setIsSuccess(0); message.setReason("已存在但更新成功"); } return message; } /** * 执行sql语句拼接加上操作 * @param sql * @param index * @param conn * @param data * @throws SQLException * @throws ParseException */ public void excuteDone(String sql, int index, Connection conn, Data data, HashMap dataMap) throws SQLException, ParseException { if (!StrFunc.isNull(sql)) { PreparedStatement pstat = conn.prepareStatement(sql); try { pstat.setString(1, data.getID()); for (int i = 0; i < keys.length; i++) { if ("VARCHAR".equals(types[i])) { pstat.setString(i + index, (String) dataMap.get(keys[i])); } else if ("CLOB".equals(types[i])) { //pstat.setClob(i + 2, (oracle.sql.CLOB) data.getDataMap().get(keys[i])); pstat.setString(i + index, (String) dataMap.get(keys[i])); } else if ("DATE".equals(types[i])) { if (StrFunc.isNull((String) dataMap.get(keys[i]))) { pstat.setDate(i + index, null); } else { pstat.setDate(i + index, string2Date((String) dataMap.get(keys[i]))); } } else if ("TIMESTAMP".equals(types[i])) { if (!StrFunc.isNull((String) dataMap.get(keys[i]))) { pstat.setTimestamp(i + index, string2Time((String) dataMap.get(keys[i]))); } else { pstat.setTimestamp(i + index, null); } } } pstat.executeQuery(); } finally { pstat.close(); } } else { System.out.println("sql为空"); } }

用TRUNCATE清楚表笔DELETE好

/** * 清除表 * @param conn * @throws SQLException */ private void clearTable(Connection conn) throws SQLException { Statement deleteState = conn.createStatement(); try { deleteState.executeUpdate(truncateSql); } finally { deleteState.close(); } }

将String类型转换成可以存到数据库的类型

/** * String转型到Timestamp * @param dateString * @return * @throws java.text.ParseException */ public Timestamp string2Time(String dateString) throws java.text.ParseException { DateFormat dateFormat; dateFormat = new SimpleDateFormat("yyyy/MM/dd HH:mm:ss", Locale.CHINESE);// 设定格式 dateFormat.setLenient(false);// 严格控制输入 比如2010－02－31，根本没有这一天 ，也会认为时间格式不对。 Date timeDate = dateFormat.parse(dateString);// util类型 Timestamp dateTime = new Timestamp(timeDate.getTime());// Timestamp类型,timeDate.getTime()返回一个long型 return dateTime; } /** * String转型到Date 而且是java.util.Date到java.sql.Date * @param str * @return * @throws ParseException */ public java.sql.Date string2Date(String str) throws ParseException { SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd");//小写的mm表示的是分钟 Date date = sdf.parse(str); java.sql.Date sqlDate = new java.sql.Date(date.getTime()); return sqlDate; }

返回的时候一种字符串的拼接

/** * 转换成JSON数据给返回 * @param messages * @return */ public String toJSON(List messages) { System.out.println(messages.size()); if (messages.size() == 0) { return "数据为空"; } else { StringBuffer str = new StringBuffer(); str.append("["); Iterator iterator = messages.iterator(); do { Message message = (Message) iterator.next(); //组装一个对象 开始 str.append("{\"id\":"); str.append("\"" + message.getId() + "\","); str.append("\"reason\":"); str.append("\"" + message.getReason() + "\","); str.append("\"isSuccess\":"); str.append("\"" + message.getIsSuccess() + "\"}"); //判断是否为最后一条数据，不是最后一条数据不需要加逗号---加了逗号也不影响，可以不判断 str.append(","); //一个对象组装结束 message.toString(); } while (iterator.hasNext()); str.append("]"); return str.toString(); } }