解析xml數(shù)據(jù)存入bean映射到數(shù)據(jù)庫的 需求解決過程
package com.iflytek.zhejiang.hangzhou.qlsx.serviceimpl; import java.util.List; import org.apache.commons.configuration.Configuration;
import org.apache.commons.configuration.ConfigurationException;
import org.apache.commons.configuration.XMLConfiguration; public class XMLParserSample { public static XMLParserSample getConf() { try { return parse();} catch (ConfigurationException e) {e.printStackTrace();} return null ;} private static XMLParserSample parse()
throws ConfigurationException {Configuration config =
new XMLConfiguration(XMLParserSample.
class .getClassLoader().getResource("conf.xml"
));String ip = config.getString("dataBaseURI"
);String account = config.getString("account"
);String password = config.getString("password"
);String runTime = config.getString("runTime"
);List <?> tasks = config.getList("tasks.table[@name]"
); // List<Table> tblLst = new ArrayList<Table>();
// for (int i = 0; i < tasks.size(); i++) {
//
// Table tbl = new Table();
// tbl.setName(config.getString(String.format(
// "tasks.table(%d)[@name]", i)));
// tbl.setInfo(config.getString(String.format(
// "tasks.table(%d)[@info]", i)));
// tbl.setPrimary(config.getString(String.format(
// "tasks.table(%d)[@primary]", i)));
// tbl.setColumns(config.getList(String.format(
// "tasks.table(%d).columns", i)));
// tbl.setTemplate(config.getString(String.format(
// "tasks.table(%d)[@template]", i)));
// tbl.setWaitTime(config.getString(String.format(
// "tasks.table(%d)[@waitTime]", i)));
// tbl.setRunTime(config.getString(String.format(
// "tasks.table(%d)[@runTime]", i)));
// tbl.setSingle(config.getString(String.format(
// "tasks.table(%d)[@single]", i)));
// tbl.setUrl(config.getString(String.format("tasks.table(%d).url", i)));
//
// if ( StringUtils.equals(TaskType.MULTI_GETTER, tbl.getTemplate())) {
// TableItem item = new TableItem();
//
// item.setName(config.getString(String.format(
// "tasks.table(%d).item[@name]", i)));
// item.setInfo(config.getString(String.format(
// "tasks.table(%d).item[@info]", i)));
// item.setRef(config.getString(String.format(
// "tasks.table(%d).item[@ref]", i)));
// item.setColumns(config.getList(String.format(
// "tasks.table(%d).item.columns", i)));
// item.setUrl(config.getString(String.format("tasks.table(%d).item.url", i)));
//
// tbl.setItem(item);
// }
//
// tblLst.add(tbl);
// }
//
// gc.setTblLst(tblLst);
//
// return gc;
// return null ;}
} 有以下幾點不理解：
demo中的實體bean Table類，demo中沒有對應的代碼，也沒有conf.xml文件，還有最后的那個gc，都不知道是干啥的，導致我很不理解疑問①的遍歷getList()到底是什么原理。一臉懵。循環(huán)體中無非就是從xml取出對應數(shù)據(jù)封裝到實體bean的屬性里面，dao層用的hibernate，但是demo里面沒有sql，所以我才猜測是利用的hibernate和數(shù)據(jù)庫表的映射關系來存儲數(shù)據(jù)的，個人也沒有學習過hibernate，只是有點接觸。最后返回的對象是什么gc是什么也是一頭霧水。以上為開發(fā)前對demo的整體感受簡述。
開發(fā)需求說明：
<? xml version="1.0" encoding="utf-8" ?>
< DATAAREA > < CHANGE_FLAG > 1
</ CHANGE_FLAG > < MATERIALS > < MATERIAL > < MATERIALGUID > 2fadsfdsfsdc22ed9d
</ MATERIALGUID > < NAME > 水電費水電費水電費
</ NAME > < FORMAT > 1
</ FORMAT > < DETAIL_REQUIREMENT > 一份
</ DETAIL_REQUIREMENT > < NECESSITY > 1
</ NECESSITY > < NECESSITY_DESC /> < MATERIAL_RES /> < IS_RQ /> < EMPTYTABLE > < FILENAME /> < FILECONTENT /> < FILEURL /> </ EMPTYTABLE > < EXAMPLETABLE > < FILENAME /> < FILECONTENT /> < FILEURL /> </ EXAMPLETABLE > < BAK /> </ MATERIAL > < MATERIAL > < MATERIALGUID > 1fsdfdsfsd07a525a
</ MATERIALGUID > < NAME > 發(fā)送到發(fā)的所發(fā)生的
</ NAME > < FORMAT > 1
</ FORMAT > < DETAIL_REQUIREMENT > 1份
</ DETAIL_REQUIREMENT > < NECESSITY > 1
</ NECESSITY > < NECESSITY_DESC /> < MATERIAL_RES /> < IS_RQ /> < EMPTYTABLE > < FILENAME /> < FILECONTENT /> < FILEURL /> </ EMPTYTABLE > < EXAMPLETABLE > < FILENAME /> < FILECONTENT /> < FILEURL /> </ EXAMPLETABLE > < BAK /> </ MATERIAL > ......等多個 < MATERIAL ></ MATERIAL > </ MATERIALS >
</ DATAAREA >
DROP TABLE IF EXISTS `material_info`;
CREATE TABLE `material_info` (
`MATERIALGUID` varchar (
255 )
NOT NULL COMMENT
' 主鍵 材料標識 ' ,
`QLSX_ROWGUID` varchar (
50 )
NOT NULL COMMENT
' AAAA 表中的rowguid對應的字段值 ' ,
`QLSX_UPDATE_DATE` datetime NOT NULL COMMENT
' AAAA 表中的update_date對應的字段值 ' ,
`NAME` varchar (
512 )
NOT NULL COMMENT
' 材料名稱 ' ,
`FORMAT` varchar (
8 ) COMMENT
' 材料形式，代碼項：材料形式 ' ,
`DETAIL_REQUIREMENT` varchar (
100 ) COMMENT
' 材料詳細要求 ' ,
`NECESSITY` varchar (
8 ) COMMENT
' 材料必要性，代碼項：材料必要性 ' ,
`NECESSITY_DESC` varchar (
255 ) COMMENT
' 材料必要性描述 ' ,
`IS_RQ` varchar (
255 ) COMMENT
'' ,
`BAK` varchar (
512 ) COMMENT
' 備注 ' ,
`UPDATE_DATE` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP ,
PRIMARY KEY (`materialguid`)
) ENGINE = InnoDB
DEFAULT CHARSET
= utf8 COMMENT
= ' 權力事項庫-申報材料主表 ' ; DROP TABLE IF EXISTS `material_res`;
CREATE TABLE `material_res` (
`ID` bigint unsigned auto_increment COMMENT
' 物理主鍵，無意義 ' ,
`MATERIALGUID` varchar (
255 )
NOT NULL COMMENT
' 邏輯主鍵，參照material_info表中對應的materialguid字段值 ' ,
`MATERIAL_RES` varchar (
255 ) COMMENT
' 材料出具單位 ' ,
`EXAMPLETABLE` CHAR (
1 )
default ' 0 ' NOT NULL COMMENT
' FILENAME、FILECONTENT、FILEURL的xml中的父標簽是否為EXAMPLETABLE 1是 0不是 ' ,
`FILENAME` varchar (
255 ) COMMENT
' 空白表格文件名稱（完整文件名，帶后綴） ' ,
`FILECONTENT` longtext COMMENT ' 文件內(nèi)容，BASE64編碼格式 ' ,
`FILEURL` varchar (
255 ) COMMENT
' 附件鏈接地址（公有云地址） ' ,
`UPDATE_DATE` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP ,
PRIMARY KEY (`id`)
) ENGINE = InnoDB
DEFAULT CHARSET
= utf8 COMMENT
= ' 權力事項庫-申報材料出具單位和材料信息表 ' ; DROP TABLE IF EXISTS `material_trans_log`;
CREATE TABLE `material_trans_log` (
`ID` bigint unsigned auto_increment COMMENT
' 物理主鍵，無意義 ' ,
`QLSX_ROWGUID` varchar (
50 )
NOT NULL COMMENT
' AAAA 表中的rowguid對應的字段值 ' ,
`QLSX_UPDATE_DATE` datetime NOT NULL COMMENT
' AAAA 表中的update_date對應的字段值 ' ,
`QLSX_CHANGE_FLAG` varchar (
10 )
NOT NULL COMMENT
' 0：未變化，1：變化 ' ,
`CREATE_TIME` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP ,
PRIMARY KEY (`id`)
) ENGINE = InnoDB
DEFAULT CHARSET
= utf8 COMMENT
= ' 權力事項庫-申報材料解析入庫的日志表 ' ;
?
取出三個字段的值，做參數(shù)傳給自己寫的xml解析方法parse()；在解析方法中進行xml解析并進行對應bean的封裝。
public XmlParserVO parse(String rowguid,Timestamp updatedate,String materialinfo)
throws DocumentException {
// 參數(shù)就是剛剛?cè)〕龅娜齻€字段的值
Document document = DocumentHelper.parseText(materialinfo);
// materialinfo 為xml格式字符串 // 一個xml就一個 CHANGE_FLAG 標簽，不在material標簽內(nèi)部，故在遍歷前取出 String changeFlag = document.selectSingleNode("/DATAAREA/CHANGE_FLAG"
).getText(); // materialinfo MaterialInfo MaterialTransLog 為新建三張表對應的類bean List<MaterialRes> listRes =
new ArrayList<MaterialRes>
();List <MaterialInfo> listInfo =
new ArrayList<MaterialInfo>
();MaterialTransLog materialtrauslog =
new MaterialTransLog();materialtrauslog.setQLSX_ROWGUID(rowguid);materialtrauslog.setQLSX_UPDATE_DATE(updatedate);materialtrauslog.setQLSX_CHANGE_FLAG(changeFlag); // 獲取MATERIALS節(jié)點 Node nodeMaterials = document.selectSingleNode("/DATAAREA/MATERIALS"
); // 取得MATERIALS節(jié)點下所有名為“MATERIAL”的子節(jié)點，并進行遍歷. 遍歷后每一個元素就是一組 MATERIAL 標簽中的值 List listMaterial = ((Element) nodeMaterials).elements("MATERIAL"
); for (Iterator it =
listMaterial.iterator(); it.hasNext();) { Element elmMaterial = (Element) it.next();
// 獲取一個 MATERIAL 節(jié)點 // 提前取出materialRes、materialGuid，供下面material_res復用 String materialRes = elmMaterial.element("MATERIAL_RES"
).getText();String materialGuid = elmMaterial.element("MATERIALGUID"
).getText();MaterialInfo materialInfo =
new MaterialInfo();materialInfo.setMATERIALGUID(materialGuid);materialInfo.setQLSX_ROWGUID(rowguid);materialInfo.setQLSX_UPDATE_DATE(updatedate);materialInfo.setNAME(elmMaterial.element( "NAME"
).getText());materialInfo.setFORMAT(elmMaterial.element( "FORMAT"
).getText());materialInfo.setDETAIL_REQUIREMENT(elmMaterial.element( "DETAIL_REQUIREMENT"
).getText());materialInfo.setNECESSITY(elmMaterial.element( "NECESSITY"
).getText());materialInfo.setNECESSITY_DESC(elmMaterial.element( "NECESSITY_DESC"
).getText());materialInfo.setIS_RQ(elmMaterial.element( "IS_RQ"
).getText());materialInfo.setBAK(elmMaterial.element( "BAK"
).getText());listInfo.add(materialInfo); /* * EMPTYTABLE EXAMPLETABLE 標簽(可能有多個)下 均有FILENAME、FILECONTENT、FILEURL子標簽，* 會產(chǎn)生多個數(shù)據(jù)，遍歷后在每一個數(shù)據(jù)下再進行bean的創(chuàng)建封裝，以對應每一條記錄。 */ List listEmptytable = elmMaterial.elements("EMPTYTABLE"
); for (Iterator it2 =
listEmptytable.iterator(); it2.hasNext();) { Element elmEmptytable = (Element) it2.next();
// 獲取一個 EMPTYTABLE 節(jié)點 MaterialRes materialres =
new MaterialRes();materialres.setMATERIALGUID(materialGuid);materialres.setMATERIAL_RES(materialRes);materialres.setEXAMPLETABLE(EnumNumber.NUMZERO.getNumber()); // 枚舉類型 值為0 materialres.setFILENAME(elmEmptytable.element("elmEmptytable"
).getText());materialres.setFILECONTENT(elmEmptytable.element( "FILECONTENT"
).getText());materialres.setFILEURL(elmEmptytable.element( "FILEURL"
).getText());listRes.add(materialres);}List listExampletable = elmMaterial.elements("EXAMPLETABLE"
); for (Iterator it3 =
listExampletable.iterator(); it3.hasNext();) { Element elmExampletable = (Element) it3.next();
// 獲取一個 EXAMPLETABLE 節(jié)點 MaterialRes materialres =
new MaterialRes();materialres.setMATERIALGUID(materialGuid);materialres.setMATERIAL_RES(materialRes);materialres.setEXAMPLETABLE(EnumNumber.NUMONE.getNumber()); // 枚舉類型 值為1 materialres.setFILENAME(elmExampletable.element("elmEmptytable"
).getText());materialres.setFILECONTENT(elmExampletable.element( "FILECONTENT"
).getText());materialres.setFILEURL(elmExampletable.element( "FILEURL"
).getText());listRes.add(materialres);} } // 返回封裝好的數(shù)據(jù)集合 XmlParserVO xmlparservo =
new XmlParserVO(listRes, listInfo, materialtrauslog); return xmlparservo;
我把一些細節(jié)以及修改在代碼中用注釋進行了標注，以便于理解。
[java] view plain copy
<code
class ="language-java">@SuppressWarnings("rawtypes"
)
public class GetMaterialInfoDao
extends HibernateEntityDao { private SessionFactory sessionFactory; public SessionFactory getSessionFactory() { return sessionFactory; } public void setSessionFactory(SessionFactory sessionFactory) { this .sessionFactory =
sessionFactory; super .sessionFactory =
sessionFactory; } @SuppressWarnings( "unchecked"
) @Transactional public void saveDate(Object obj){ Session session =
sessionFactory.getCurrentSession(); session.save(obj); } } </code>
這段代碼其實就是我不會用hibernate的體現(xiàn)。-save()方法還用在dao層自己寫嗎？？？￣□￣｜｜
---------------------------------------------------------
開發(fā)過程中考慮的不嚴謹不周全，【關于這一點，還有，在把解析出的數(shù)據(jù)存入庫之前，再做一個驗證，去material_info表里面查詢一下這條數(shù)據(jù)是否已經(jīng)存在，如果已存在，刪了，再把現(xiàn)在剛解析出的數(shù)據(jù)插入進去，這一點也是我不曾考慮到的】，雖然對業(yè)務流程不熟悉，畢竟只是單一接到功能需求，大范圍業(yè)務流程背景并不清楚，但是嚴謹周全的工作思路還是必須的。不然就是一堆bug了。。。。
private static final int LIMIT = 50
; private final static Executor executor = Executors.newCachedThreadPool();
// 啟用多線程
@Override public void dataHanding() {Long countNum =
qltQlsxDao.getCountNum(); int times = 0
; if ( 0 == countNum %
LIMIT ){times = (
int ) (countNum /
LIMIT);} else {times = (
int ) (countNum / LIMIT) +1
;} // int times = (int) Math.floor(countNum / LIMIT); // 分頁查詢 避免內(nèi)存溢出 for (
int i = 1; i <= times; i++
) {
// List<QltQlsxNewDto> dataLst = qltQlsxDao.getMaterialInfo((i - 1) * LIMIT, LIMIT);
// if ( null == dataLst || dataLst.isEmpty() ) {
// logger.info("無數(shù)據(jù)需要處理");
// return ;
// } final int j=
i; executor.execute( new Runnable() {@Override public void run() { try {List <QltQlsxNewDto> dataLst = qltQlsxDao.getMaterialInfo((j - 1) *
LIMIT, LIMIT); if (
null == dataLst ||
dataLst.isEmpty() ) {logger.info( "無數(shù)據(jù)需要處理"
); return ;}parseXMLInfoAndSave(dataLst);} catch (Exception e){}}}); }}
6、在新建dao層service層時，注意為以后的業(yè)務擴展考慮，不同表的增刪改查操作方法不要寫在一個dao里面，按照業(yè)務新建dao。其它層次也是同理。說到這想起了之前在北京的一位同事，當時給我講解傳參的場景，客戶需求總是變來變?nèi)?#xff0c;有時候參數(shù)傳遞自己不要寫的那么死，給自己留條路，便于自己修改，也利于項目代碼優(yōu)化。
?
轉(zhuǎn)載于:https://www.cnblogs.com/dxxdsw/p/10673640.html
總結
以上是生活随笔 為你收集整理的解析xml数据存入bean映射到数据库的 需求解决过程 的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
如果覺得生活随笔 網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔 推薦給好友。
