读取增量xml数据到数据库
作者：Vashon
时间：20160323
昨天接到领导安排的任务：将系统产生的增量xml数据插入到另一个项目中的数据库中（数据库表结构一样）。
网上查找了许多例子，都是没有考虑到数据类型或其他的细节，如果改变数据库表则再需要修改程序，这显得很麻烦。以下是本人经过一天的时间做出来的一个小工具类，方便以后使用。
增量xml数据格式（该xml样例只包含两条目标插入数据，实际文件中是包含很多条的。）如下：
<?xml version="1.0" encoding="utf-8"?> <project> <corporation_info> <corp_info_id>20100816215830297313</corp_info_id> <organ_code>765955335</organ_code> <entity_id>270000032004080500176</entity_id> <corp_name>上海煌虹建筑装饰设计工程有限公司</corp_name> <corp_type>00010100</corp_type> <person_name>黄XXXX</person_name> <address>上海市松江区泖港镇中南路7号B区186号</address> <area_code>松江</area_code> <zip>201607</zip> <telephone>62418078</telephone> <establish_date>2004-08-05T00:00:00</establish_date> <reg_capital>600</reg_capital> <currency>人民币</currency> <business_scope>建筑装饰装修工程与设计</business_scope> <person_cert_type></person_cert_type> <person_cert_code></person_cert_code> <industry_code>E5010</industry_code> <organizers></organizers> <funding_src></funding_src> <reg_no>310227001057592</reg_no> <receiving_organ>270000</receiving_organ> <repeal_reason></repeal_reason> <repeal_date></repeal_date> <change_date>2016-03-16T13:33:00</change_date> <change_item></change_item> <repeal_organ></repeal_organ> <branch_num></branch_num> <represent_num></represent_num> <reg_upd_date></reg_upd_date> <taxpayers_code>310227765955335</taxpayers_code> <tax_code>13102275103</tax_code> <tax_reg_date>2004-08-13</tax_reg_date> <tax_chge_content>纳税人名称,财务负责人姓名XXXXX</tax_chge_content> <tax_chge_date>2015-01-22</tax_chge_date> <tax_repeal_reason></tax_repeal_reason> <tax_repeal_date></tax_repeal_date> <tax_repeal_organ ></tax_repeal_organ > <business_address>上海市长宁区玉屏南路520弄15号</business_address> <tax_upd_date></tax_upd_date> <organcode_date></organcode_date> <orgcode_chgdate>2010-03-12</orgcode_chgdate> <orgcode_repealdate></orgcode_repealdate> <qs_upd_date></qs_upd_date> <uni_sc_id>913101177659553356</uni_sc_id> </corporation_info> <corporation_info> <corp_info_id>20100816215830455984</corp_info_id> <organ_code>557439256</organ_code> <entity_id>270000032010062100052</entity_id> <corp_name>上海翔晟包装材料有限公司</corp_name> <corp_type>00010100</corp_type> <person_name>张XX</person_name> <address>上海市松江区泖港镇松金公路8238号2幢</address> <area_code>松江</area_code> <zip>201607</zip> <telephone>15000428729</telephone> <establish_date>2010-06-21T00:00:00</establish_date> <reg_capital>100</reg_capital> <currency>人民币</currency> <business_scope>包装材料、泡沫制品批发零售；塑料制品加工及销售</business_scope> <person_cert_type></person_cert_type> <person_cert_code></person_cert_code> <industry_code>F5141</industry_code> <organizers></organizers> <funding_src></funding_src> <reg_no>310227001548657</reg_no> <receiving_organ>270000</receiving_organ> <repeal_reason></repeal_reason> <repeal_date></repeal_date> <change_date>2016-03-16T13:30:00</change_date> <change_item></change_item> <repeal_organ></repeal_organ> <branch_num></branch_num> <represent_num></represent_num> <reg_upd_date></reg_upd_date> <taxpayers_code>310227557439256</taxpayers_code> <tax_code>13102275100</tax_code> <tax_reg_date></tax_reg_date> <tax_chge_content>注册地址,生产经营地址,经营范围</tax_chge_content> <tax_chge_date>2014-03-24</tax_chge_date> <tax_repeal_reason></tax_repeal_reason> <tax_repeal_date></tax_repeal_date> <tax_repeal_organ ></tax_repeal_organ > <business_address>上海市松江区泖港镇松金公路7836号</business_address> <tax_upd_date></tax_upd_date> <organcode_date>2010-06-22</organcode_date> <orgcode_chgdate></orgcode_chgdate> <orgcode_repealdate></orgcode_repealdate> <qs_upd_date></qs_upd_date> <uni_sc_id>91310117557439256R</uni_sc_id> </corporation_info> </project>
以上作为xml文件的例子，在根节点<project>下面有多个子节点<corporation_info>，该子节点是数据库表名称。<corporation_info>下面的子节点是表的字段和对应的字段内容。
现在需要将这些增量数据插入到另一系统对应的数据库中（数据库表结构一样）。
分析：先获取数据库表结构，遍历表中的字段名称及字段类型，根据条件分别对他们进行处理以及根据属性名称在xml文件中检索。
package com.ywx; import java.io.File; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.ResultSetMetaData; import java.sql.sqlException; import java.util.Iterator; import org.dom4j.Document; import org.dom4j.DocumentException; import org.dom4j.Element; import org.dom4j.io.SAXReader; /** * 读取增量xml数据到数据中. * @author Vashon * */ public class XmlToDbMain { public static void main(String args[]){ XmlToDb xml = new XmlToDb(); xml.execute(); } } class XmlToDb{ private static final String DBDRIVER="oracle.jdbc.driver.OracleDriver"; private static final String DBURL="jdbc:oracle:thin:@10.1.8.73:1521:ORCL"; private static final String DBUSER="sjsjzx"; private static final String DBPASS="sjsjzx"; private Connection conn = null; private PreparedStatement pstmt = null; /*********************根据需求修改以下两个常量*************************/ /**需要导入到的数据库表名**/ public static final String DATA_TABLE = "CORP_INFO"; /**xml文件路径**/ public static final String FILE_PATH = "e:\\import\\dest\\702016031711431764.xml"; /*************************************************************/ /**类型为NUBMBER或DATE**/ public static final String IS_NUMBER_OR_DATE = "1"; public XmlToDb(){ try { Class.forName(DBDRIVER);//加载驱动程序 conn=DriverManager.getConnection(DBURL,DBUSER,DBPASS); } catch (Exception e) { e.printStackTrace(); } } /** * 取得连接. * @return */ public Connection getConnection(){ return this.conn; } /** * 读取xml并获取根节点. */ public Element getRoot(){ Element root = null; try { SAXReader sax=new SAXReader();//创建一个SAXReader对象 File xmlFile=new File(FILE_PATH);//根据指定的路径创建file对象 sax.setEncoding("gbk"); Document document; document = sax.read(xmlFile); root=document.getRootElement();//获取根节点 } catch (DocumentException e) { e.printStackTrace(); } return root; } /** * 执行批量插入方法. */ public void execute(){ try { //现在应该根据根节点找到全部的子节点 Iterator<?> iter = getRoot().elementIterator(); boolean flag = false; int count = 0;//插入数据量 while(iter.hasNext()){ ++count; Element item = (Element) iter.next(); //=========获取数据库表字段名========= String sql = "select * from "+DATA_TABLE; //拼装sql StringBuffer insertsql = new StringBuffer("insert into "+DATA_TABLE+"("); pstmt = getConnection().prepareStatement(sql); ResultSet rs = pstmt.executeQuery(sql); ResultSetMetaData data = rs.getMetaData(); for(int i=1;i<=data.getColumnCount();i++){ //获得所有列的数目及实际列数 int columnCount = data.getColumnCount(); //获得指定列的列名 String columnName = data.getColumnName(i); //获得指定列的数据类型名 String columnTypeName = data.getColumnTypeName(i); insertsql.append(columnName).append(","); } insertsql.deleteCharAt(insertsql.length()-1).append(") values("); //循环判断字段类型并给值 for(int i=1; i<=data.getColumnCount(); i++){ String value = null;//接受字符串或日期格式 String isNumber = "";//是否是NUMBER或DATE类型(0:不是,1:是) //获得指定列的列名 String columnName = data.getColumnName(i); //获得指定列的数据类型名 String columnTypeName = data.getColumnTypeName(i); if("VARCHAR2".equals(columnTypeName)){ if("".equals(item.elementText(columnName.toLowerCase())) || "null".equals(item.elementText(columnName.toLowerCase())) ||item.elementText(columnName.toLowerCase())==null){ value = "NULL"; }else{ value = item.elementText(columnName.toLowerCase()); } System.out.println("共【"+data.getColumnCount()+"】列；给第【"+i+"】列,类型为：【"+columnTypeName+"】的:【"+columnName+"】赋值内容为:【"+value+"】"); } if("DATE".equals(columnTypeName)){ //如果从xml中取出的时间值为null时,拼接的sql不需要"'". isNumber = IS_NUMBER_OR_DATE; if("".equals(item.elementText(columnName.toLowerCase())) || "null".equals(item.elementText(columnName.toLowerCase())) || item.elementText(columnName.toLowerCase())==null){ value = "to_date(NULL,'yyyy-MM-dd HH:mi:ss')"; }else{ value = "to_date("+"'"+item.elementText(columnName.toLowerCase()).replace("T"," ")+"'"+",'yyyy-mm-dd HH24:mi:ss')"; } System.out.println("共【"+data.getColumnCount()+"】列；给第【"+i+"】列,类型为：【"+columnTypeName+"】的:【"+columnName+"】赋值内容为:【"+value+"】"); } if("NUMBER".equals(columnTypeName)){ isNumber = IS_NUMBER_OR_DATE; if("".equals(item.elementText(columnName.toLowerCase())) || "null".equals(item.elementText(columnName.toLowerCase())) || item.elementText(columnName.toLowerCase())==null){ value="NULL"; }else{ value = item.elementText(columnName.toLowerCase()); } System.out.println("共【"+data.getColumnCount()+"】列；给第【"+i+"】列,类型为：【"+columnTypeName+"】的:【"+columnName+"】赋值内容为:【"+value+"】"); } if(IS_NUMBER_OR_DATE.equals(isNumber)){ insertsql.append(value).append(","); }else{ insertsql.append("'"+value+"'").append(","); } } insertsql.deleteCharAt(insertsql.length()-1).append(")"); System.out.println("执行的sql语句为:"+insertsql); conn = getConnection(); pstmt = conn.prepareStatement(insertsql.toString()); flag = pstmt.execute(); } if (!flag) { System.out.println("****************成功插入【"+count+"】条数据!****************"); this.closeConn(conn); } } catch (Exception e) { e.printStackTrace(); } } /** * 关闭连接. */ public void closeConn(Connection conn){ if(conn != null){ try { conn.close(); } catch (sqlException e) { e.printStackTrace(); } } } }
控制台打印结果：
共【68】列；给第【1】列,类型为：【VARCHAR2】的:【CORP_INFO_ID】赋值内容为:【20100816215830297313】 共【68】列；给第【2】列,类型为：【VARCHAR2】的:【ORGAN_CODE】赋值内容为:【765955335】 共【68】列；给第【3】列,类型为：【VARCHAR2】的:【ENTITY_ID】赋值内容为:【270000032004080500176】 共【68】列；给第【4】列,类型为：【VARCHAR2】的:【CORP_NAME】赋值内容为:【上海煌虹建筑装饰设计工程有限公司】 共【68】列；给第【5】列,类型为：【VARCHAR2】的:【CORP_TYPE】赋值内容为:【00010100】 共【68】列；给第【6】列,类型为：【VARCHAR2】的:【PERSON_NAME】赋值内容为:【黄从高】 共【68】列；给第【7】列,类型为：【VARCHAR2】的:【ADDRESS】赋值内容为:【上海市松江区泖港镇中南路7号B区186号】 共【68】列；给第【8】列,类型为：【VARCHAR2】的:【AREA_CODE】赋值内容为:【松江】 共【68】列；给第【9】列,类型为：【VARCHAR2】的:【ZIP】赋值内容为:【201607】 共【68】列；给第【10】列,类型为：【VARCHAR2】的:【TELEPHONE】赋值内容为:【62418078】 共【68】列；给第【11】列,类型为：【DATE】的:【ESTABLISH_DATE】赋值内容为:【to_date('2004-08-05 00:00:00','yyyy-mm-dd HH24:mi:ss')】 共【68】列；给第【12】列,类型为：【NUMBER】的:【REG_CAPITAL3】赋值内容为:【NULL】 共【68】列；给第【13】列,类型为：【VARCHAR2】的:【CURRENCY】赋值内容为:【人民币】 共【68】列；给第【14】列,类型为：【VARCHAR2】的:【BUSINESS_SCOPE】赋值内容为:【建筑装饰装修工程与设计】 共【68】列；给第【15】列,类型为：【VARCHAR2】的:【PERSON_CERT_TYPE】赋值内容为:【NULL】 共【68】列；给第【16】列,类型为：【VARCHAR2】的:【PERSON_CERT_CODE】赋值内容为:【NULL】 共【68】列；给第【17】列,类型为：【VARCHAR2】的:【INDUSTRY_CODE】赋值内容为:【E5010】 共【68】列；给第【18】列,类型为：【VARCHAR2】的:【ORGANIZERS】赋值内容为:【NULL】 共【68】列；给第【19】列,类型为：【VARCHAR2】的:【FUNDING_SRC】赋值内容为:【NULL】 共【68】列；给第【20】列,类型为：【VARCHAR2】的:【REG_NO】赋值内容为:【310227001057592】 共【68】列；给第【21】列,类型为：【VARCHAR2】的:【RECEIVING_ORGAN】赋值内容为:【270000】 共【68】列；给第【22】列,类型为：【VARCHAR2】的:【REPEAL_REASON】赋值内容为:【NULL】 共【68】列；给第【23】列,类型为：【DATE】的:【REPEAL_DATE】赋值内容为:【to_date(NULL,'yyyy-MM-dd HH:mi:ss')】 共【68】列；给第【24】列,类型为：【DATE】的:【CHANGE_DATE】赋值内容为:【to_date('2016-03-16 13:33:00','yyyy-mm-dd HH24:mi:ss')】 共【68】列；给第【25】列,类型为：【VARCHAR2】的:【CHANGE_ITEM】赋值内容为:【NULL】 共【68】列；给第【26】列,类型为：【VARCHAR2】的:【REPEAL_ORGAN】赋值内容为:【NULL】 共【68】列；给第【27】列,类型为：【NUMBER】的:【BRANCH_NUM】赋值内容为:【NULL】 共【68】列；给第【28】列,类型为：【NUMBER】的:【REPRESENT_NUM】赋值内容为:【NULL】 共【68】列；给第【29】列,类型为：【DATE】的:【REG_UPD_DATE】赋值内容为:【to_date(NULL,'yyyy-MM-dd HH:mi:ss')】 共【68】列；给第【30】列,类型为：【VARCHAR2】的:【TAXPAYERS_CODE】赋值内容为:【310227765955335】 共【68】列；给第【31】列,类型为：【VARCHAR2】的:【TAX_CODE】赋值内容为:【13102275100】 共【68】列；给第【32】列,类型为：【DATE】的:【TAX_REG_DATE】赋值内容为:【to_date('2004-08-13','yyyy-mm-dd HH24:mi:ss')】 共【68】列；给第【33】列,类型为：【VARCHAR2】的:【TAX_CHGE_CONTENT】赋值内容为:【纳税人名称,财务负责人姓名XXXXX】 共【68】列；给第【34】列,类型为：【DATE】的:【TAX_CHGE_DATE】赋值内容为:【to_date('2015-01-22','yyyy-mm-dd HH24:mi:ss')】 共【68】列；给第【35】列,类型为：【VARCHAR2】的:【TAX_REPEAL_REASON】赋值内容为:【NULL】 共【68】列；给第【36】列,类型为：【DATE】的:【TAX_REPEAL_DATE】赋值内容为:【to_date(NULL,'yyyy-MM-dd HH:mi:ss')】 共【68】列；给第【37】列,类型为：【VARCHAR2】的:【TAX_REPEAL_ORGAN】赋值内容为:【NULL】 共【68】列；给第【38】列,类型为：【VARCHAR2】的:【BUSINESS_ADDRESS】赋值内容为:【上海市长宁区玉屏南路520弄15号】 共【68】列；给第【39】列,类型为：【DATE】的:【TAX_UPD_DATE】赋值内容为:【to_date(NULL,'yyyy-MM-dd HH:mi:ss')】 共【68】列；给第【40】列,类型为：【DATE】的:【ORGANCODE_DATE】赋值内容为:【to_date(NULL,'yyyy-MM-dd HH:mi:ss')】 共【68】列；给第【41】列,类型为：【DATE】的:【ORGCODE_CHGDATE】赋值内容为:【to_date('2010-03-12','yyyy-mm-dd HH24:mi:ss')】 共【68】列；给第【42】列,类型为：【DATE】的:【ORGCODE_REPEALDATE】赋值内容为:【to_date(NULL,'yyyy-MM-dd HH:mi:ss')】 共【68】列；给第【43】列,类型为：【DATE】的:【QS_UPD_DATE】赋值内容为:【to_date(NULL,'yyyy-MM-dd HH:mi:ss')】 共【68】列；给第【44】列,类型为：【VARCHAR2】的:【BD_RESULT】赋值内容为:【NULL】 共【68】列；给第【45】列,类型为：【VARCHAR2】的:【QYK_ID】赋值内容为:【NULL】 共【68】列；给第【46】列,类型为：【DATE】的:【UPD_TIME】赋值内容为:【to_date(NULL,'yyyy-MM-dd HH:mi:ss')】 共【68】列；给第【47】列,类型为：【VARCHAR2】的:【TRIM_CORP_NAME】赋值内容为:【NULL】 共【68】列；给第【48】列,类型为：【VARCHAR2】的:【FUNDS_CODE】赋值内容为:【NULL】 共【68】列；给第【49】列,类型为：【DATE】的:【FUNDS_OPEN_DATE】赋值内容为:【to_date(NULL,'yyyy-MM-dd HH:mi:ss')】 共【68】列；给第【50】列,类型为：【DATE】的:【FUNDS_REPEAL_DATE】赋值内容为:【to_date(NULL,'yyyy-MM-dd HH:mi:ss')】 共【68】列；给第【51】列,类型为：【DATE】的:【FUNDS_UPD_DATE】赋值内容为:【to_date(NULL,'yyyy-MM-dd HH:mi:ss')】 共【68】列；给第【52】列,类型为：【VARCHAR2】的:【FUNDSADD_CODE】赋值内容为:【NULL】 共【68】列；给第【53】列,类型为：【DATE】的:【FUNDSADD_OPEN_DATE】赋值内容为:【to_date(NULL,'yyyy-MM-dd HH:mi:ss')】 共【68】列；给第【54】列,类型为：【DATE】的:【FUNDSADD_REPEAL_DATE】赋值内容为:【to_date(NULL,'yyyy-MM-dd HH:mi:ss')】 共【68】列；给第【55】列,类型为：【DATE】的:【FUNDSADD_UPD_DATE】赋值内容为:【to_date(NULL,'yyyy-MM-dd HH:mi:ss')】 共【68】列；给第【56】列,类型为：【VARCHAR2】的:【SOCIAL_SECURITY_CODE】赋值内容为:【NULL】 共【68】列；给第【57】列,类型为：【DATE】的:【SOCIAL_SECURITY_OPEN_DATE】赋值内容为:【to_date(NULL,'yyyy-MM-dd HH:mi:ss')】 共【68】列；给第【58】列,类型为：【DATE】的:【SOCIAL_SECURITY_REPEAL_DATE】赋值内容为:【to_date(NULL,'yyyy-MM-dd HH:mi:ss')】 共【68】列；给第【59】列,类型为：【DATE】的:【SOCIAL_SECURITY_UPD_DATE】赋值内容为:【to_date(NULL,'yyyy-MM-dd HH:mi:ss')】 共【68】列；给第【60】列,类型为：【VARCHAR2】的:【LK_STATUS】赋值内容为:【NULL】 共【68】列；给第【61】列,类型为：【VARCHAR2】的:【IS_ZMQ】赋值内容为:【NULL】 共【68】列；给第【62】列,类型为：【DATE】的:【INSERT_TIME】赋值内容为:【to_date(NULL,'yyyy-MM-dd HH:mi:ss')】 共【68】列；给第【63】列,类型为：【VARCHAR2】的:【CORP_STATUS】赋值内容为:【NULL】 共【68】列；给第【64】列,类型为：【VARCHAR2】的:【IS_GSL】赋值内容为:【NULL】 共【68】列；给第【65】列,类型为：【VARCHAR2】的:【IS_RECENTLY_ZMQ】赋值内容为:【NULL】 共【68】列；给第【66】列,类型为：【VARCHAR2】的:【IS_WEB_SEND】赋值内容为:【NULL】 共【68】列；给第【67】列,类型为：【VARCHAR2】的:【UNI_SC_ID】赋值内容为:【913101177659553356】 共【68】列；给第【68】列,类型为：【NUMBER】的:【REG_CAPITAL】赋值内容为:【600】 执行的sql语句为:insert into CORP_INFO_TEST(CORP_INFO_ID,ORGAN_CODE,ENTITY_ID,CORP_NAME,CORP_TYPE,PERSON_NAME,ADDRESS,AREA_CODE,ZIP,TELEPHONE,ESTABLISH_DATE,REG_CAPITAL3,CURRENCY,BUSINESS_SCOPE,PERSON_CERT_TYPE,PERSON_CERT_CODE,INDUSTRY_CODE,ORGANIZERS,FUNDING_SRC,REG_NO,RECEIVING_ORGAN,REPEAL_REASON,REPEAL_DATE,CHANGE_DATE,CHANGE_ITEM,REPEAL_ORGAN,BRANCH_NUM,REPRESENT_NUM,REG_UPD_DATE,TAXPAYERS_CODE,TAX_CODE,TAX_REG_DATE,TAX_CHGE_CONTENT,TAX_CHGE_DATE,TAX_REPEAL_REASON,TAX_REPEAL_DATE,TAX_REPEAL_ORGAN,BUSINESS_ADDRESS,TAX_UPD_DATE,ORGANCODE_DATE,ORGCODE_CHGDATE,ORGCODE_REPEALDATE,QS_UPD_DATE,BD_RESULT,QYK_ID,UPD_TIME,TRIM_CORP_NAME,FUNDS_CODE,FUNDS_OPEN_DATE,FUNDS_REPEAL_DATE,FUNDS_UPD_DATE,FUNDSADD_CODE,FUNDSADD_OPEN_DATE,FUNDSADD_REPEAL_DATE,FUNDSADD_UPD_DATE,SOCIAL_SECURITY_CODE,SOCIAL_SECURITY_OPEN_DATE,SOCIAL_SECURITY_REPEAL_DATE,SOCIAL_SECURITY_UPD_DATE,LK_STATUS,IS_ZMQ,INSERT_TIME,CORP_STATUS,IS_GSL,IS_RECENTLY_ZMQ,IS_WEB_SEND,UNI_SC_ID,REG_CAPITAL) values('20100816215830297313','765955335','270000032004080500176','上海煌虹建筑装饰设计工程有限公司','00010100','黄从高','上海市松江区泖港镇中南路7号B区186号','松江','201607','62418078',to_date('2004-08-05 00:00:00','yyyy-mm-dd HH24:mi:ss'),NULL,'人民币','建筑装饰装修工程与设计','NULL','E5010','310227001057592','270000',to_date(NULL,'yyyy-MM-dd HH:mi:ss'),to_date('2016-03-16 13:33:00','310227765955335','13102275100',to_date('2004-08-13','纳税人名称,财务负责人姓名XXXXX',to_date('2015-01-22','上海市长宁区玉屏南路520弄15号',to_date('2010-03-12','913101177659553356',600) 共【68】列；给第【1】列,类型为：【VARCHAR2】的:【CORP_INFO_ID】赋值内容为:【20100816215830455984】 共【68】列；给第【2】列,类型为：【VARCHAR2】的:【ORGAN_CODE】赋值内容为:【557439256】 共【68】列；给第【3】列,类型为：【VARCHAR2】的:【ENTITY_ID】赋值内容为:【270000032010062100052】 共【68】列；给第【4】列,类型为：【VARCHAR2】的:【CORP_NAME】赋值内容为:【上海翔晟包装材料有限公司】 共【68】列；给第【5】列,类型为：【VARCHAR2】的:【PERSON_NAME】赋值内容为:【张瑞勤】 共【68】列；给第【7】列,类型为：【VARCHAR2】的:【ADDRESS】赋值内容为:【上海市松江区泖港镇松金公路8238号2幢】 共【68】列；给第【8】列,类型为：【VARCHAR2】的:【TELEPHONE】赋值内容为:【15000428739】 共【68】列；给第【11】列,类型为：【DATE】的:【ESTABLISH_DATE】赋值内容为:【to_date('2010-06-21 00:00:00',类型为：【VARCHAR2】的:【BUSINESS_SCOPE】赋值内容为:【包装材料、泡沫制品批发零售；塑料制品加工及销售】 共【68】列；给第【15】列,类型为：【VARCHAR2】的:【INDUSTRY_CODE】赋值内容为:【F5141】 共【68】列；给第【18】列,类型为：【VARCHAR2】的:【REG_NO】赋值内容为:【310227001548657】 共【68】列；给第【21】列,类型为：【DATE】的:【CHANGE_DATE】赋值内容为:【to_date('2016-03-16 13:30:00',类型为：【VARCHAR2】的:【TAXPAYERS_CODE】赋值内容为:【310227557439256】 共【68】列；给第【31】列,类型为：【DATE】的:【TAX_REG_DATE】赋值内容为:【to_date(NULL,'yyyy-MM-dd HH:mi:ss')】 共【68】列；给第【33】列,类型为：【VARCHAR2】的:【TAX_CHGE_CONTENT】赋值内容为:【注册地址,经营范围】 共【68】列；给第【34】列,类型为：【DATE】的:【TAX_CHGE_DATE】赋值内容为:【to_date('2014-03-24',类型为：【VARCHAR2】的:【BUSINESS_ADDRESS】赋值内容为:【上海市松江区泖港镇松金公路7836号】 共【68】列；给第【39】列,类型为：【DATE】的:【ORGANCODE_DATE】赋值内容为:【to_date('2010-06-22','yyyy-mm-dd HH24:mi:ss')】 共【68】列；给第【41】列,类型为：【DATE】的:【ORGCODE_CHGDATE】赋值内容为:【to_date(NULL,'yyyy-MM-dd HH:mi:ss')】 共【68】列；给第【42】列,类型为：【VARCHAR2】的:【UNI_SC_ID】赋值内容为:【91310117557439256R】 共【68】列；给第【68】列,类型为：【NUMBER】的:【REG_CAPITAL】赋值内容为:【100】 执行的sql语句为:insert into CORP_INFO_TEST(CORP_INFO_ID,REG_CAPITAL) values('20100816215830455984','557439256','270000032010062100052','上海翔晟包装材料有限公司','张瑞勤','上海市松江区泖港镇松金公路8238号2幢','15000428739',to_date('2010-06-21 00:00:00','包装材料、泡沫制品批发零售；塑料制品加工及销售','F5141','310227001548657',to_date('2016-03-16 13:30:00','310227557439256','注册地址,经营范围',to_date('2014-03-24','上海市松江区泖港镇松金公路7836号',to_date('2010-06-22','91310117557439256R',100)
再来查看数据库是否插入成功：
两条数据已经成功插入到数据库中。
以上增量xml数据是包含有两个<corporation_info>节点的数据，如果xml中包含有多少个该节点，则数据库中就对应插入多少条数据。
进入实战操作：
需要导入的源数据：增量数据xml如下：
以下是导入数据的结果截图，一个程序将大量的结构化数据在短时间内导入，大大提高工作效率。
再看看数据库截图：
说明："懒人"有懒人的方式。
