波多在线播放_激情深爱五月_久久欧美精品_成人超碰_国产久_www.pixiv.moe

以文本方式查看主題

-  曙海教育集團(tuán)論壇  (http://www.022-oo.cn/bbs/index.asp)
--  Oracle數(shù)據(jù)庫(kù)  (http://www.022-oo.cn/bbs/list.asp?boardid=65)
----  4月14日 從文件(*.csv或*.txt)導(dǎo)入Oracle數(shù)據(jù)庫(kù)Java源代碼  (http://www.022-oo.cn/bbs/dispbbs.asp?boardid=65&id=2507)

--  作者:wangxinxin
--  發(fā)布時(shí)間:2010-12-11 11:11:37
--  4月14日 從文件(*.csv或*.txt)導(dǎo)入Oracle數(shù)據(jù)庫(kù)Java源代碼
近期由于項(xiàng)目需要,實(shí)現(xiàn)了從.csv或者.txt文件中讀取每行信息后插入到Oracle數(shù)據(jù)庫(kù)中的功能,特共享出來(lái)。用到第三方開(kāi)源工具包:opencsv-1.8.jar和commons-dbutils-1.1.jar,需單獨(dú)下載。
首先需要配置XML文件,如下:
<?xml version="1.0" encoding="UTF-8"?>
<root>
<DefaultImport>Employee</DefaultImport>
<TargetTable tableName="EMPLOYEE_TEST">
<!--表中對(duì)應(yīng)文件的列名和類(lèi)型信息-->
<ColumnFileInfo>
   <Column name="ID" type="String"/>
   <Column name="DEP" type="String"/>
   <Column name="NAME" type="String"/>
   <Column name="AREA" type="String"/>
   <Column name="AGE" type="Number"/>
   <Column name="SEX" type="String"/>
   <Column name="XUELI" type="String"/>
   <Column name="SALARY" type="Number"/>
   <Column name="PRIX" type="Date"/>
</ColumnFileInfo>
</TargetTable>

<TargetTable tableName="YFJBXX_TEST">
   <ColumnFileInfo>
    <Column name="GLGXZJ" type="String"/>
   <Column name="YXTZJ" type="String"/>  
   <Column name="YFXM" type="String"/>   
   <Column name="JZDZ" type="String"/>   
   <Column name="JZDXZQH_DM" type="String"/>   
   <Column name="HJDZ" type="String"/>   
   <Column name="HJDXZQH_DM" type="String"/>   
   <Column name="SFZH" type="String"/>     
   <Column name="CSRQ" type="String"/>  
   <Column name="MZ_DM" type="String"/>   
   <Column name="WHCD_DM" type="String"/>
   <Column name="HKXZ_DM" type="String"/>
   <Column name="HYZK_DM" type="String"/>
   <Column name="CHRQ" type="String"/>   
   <Column name="JRXTRQ" type="String"/>
   <Column name="TCXTRQ" type="String"/>
   <Column name="TCYY_DM" type="String"/>
   <Column name="ZF_XM" type="String"/>  
   <Column name="ZF_JJDZ" type="String"/>   
   <Column name="ZF_JJDXZQHDM_DM" type="String"/>   
   <Column name="ZF_HJDZ" type="String"/>   
   <Column name="ZF_HJDXZQH_DM" type="String"/>   
   <Column name="ZF_SFZH" type="String"/>   
   <Column name="ZF_CSRQ" type="String"/>   
   <Column name="ZF_MZ_DM" type="String"/>   
   <Column name="ZF_WHCD_DM" type="String"/>
   <Column name="ZF_HKXZ_DM" type="String"/>
   <Column name="LGRZRQ" type="String"/>      
</ColumnFileInfo>
<ColumnCodeInfo>
    <Column name="LRSJ" type="Date"/>
   <Column name="SBPCH" type="String"/>
   <Column name="SBDWXZQH_DM" type="String"/>
</ColumnCodeInfo>
</TargetTable>

<ImportDealClassList>
   <Bean name="ImportDirectImpl" class="fileimport.ImportDirectImpl"/>
   <Bean name="ImportWISImpl" class="fileimport.ImportWISImpl"/>
</ImportDealClassList>
<MaxCommitNumber>5000</MaxCommitNumber>
</root>

文件中描述了2個(gè)導(dǎo)入工作:(1)表EMPLOYEE_TEST(2)表YFJBXX_TEST,文件中每張表的列名和類(lèi)型需要和導(dǎo)入的目標(biāo)表一致,且順序和文件中要導(dǎo)入的內(nèi)容相匹配,例如下面的csv文件:

"ID","DEP","NAME","AREA","AGE","SEX","XUELI","SALARY","PRIX"
"001","研發(fā)","張三","北京","34","女","本科","4546","1"
"002","銷(xiāo)售","李四","天津","45","男","專(zhuān)科","4456","2"

可以看到導(dǎo)入的順序和上述XML文件中的列名一致。

如果從文件導(dǎo)入到數(shù)據(jù)庫(kù)中完全匹配,只需配置文件中的<Bean name="ImportDirectImpl" class="fileimport.ImportDirectImpl"/>即可,代碼中調(diào)用示例:
    //設(shè)置XML配置文件所在位置
    FileImportInitFactory.setConfigFileName("E:/EclipseProjects/WISImport/bin/fileimport/FileImportConfig.xml");
&nb

sp;   FileImportInitFactory.init();
    HashMap h = new HashMap(1,1);
    //如果有日期型的列,需要設(shè)置DateFormat并放入HashMap中
    h.put("DateFormat","yyyy-MM-dd HH:mm:ss");
    //執(zhí)行導(dǎo)入工作
    new ImportFileEntry().importFile("導(dǎo)入的文件路徑及名稱(chēng).csv","YFJBXX_TEST",false,"ImportDirectImpl",h);

ImportFileEntry()的importFile方法說(shuō)明:
/**
   * 從文件導(dǎo)入到指定表中
   * @param fileName String 要導(dǎo)入文件名
   * @param tableName String 導(dǎo)入目標(biāo)表名
   * @param firstLineRead boolean 是否讀取第一行
   * @param dealClass 處理類(lèi)名稱(chēng)(例如配置文件中Bean name="ImportDirectImpl")
   * @param aHashMap 擴(kuò)展用,需特殊處理時(shí)可置入變量
   * @throws Exception
   */
public void importFile(String fileName, String tableName, boolean firstLineRead,String dealClass,HashMap aHashMap) throws Exception ;

至此,一個(gè)簡(jiǎn)單的不需做任何處理直接從文件導(dǎo)入數(shù)據(jù)庫(kù)對(duì)應(yīng)表的功能就實(shí)現(xiàn)了。

但是有些時(shí)候我們需要進(jìn)行特殊的處理,例如表中的當(dāng)前操作日期列在導(dǎo)入文件中沒(méi)有,需要在代碼中加入,這時(shí)就需要實(shí)現(xiàn)FileImportInterface接口并加入到配置文件中例如:<Bean name="ImportWISImpl" class="fileimport.ImportWISImpl"/>,ImportWISImpl的實(shí)現(xiàn)代碼見(jiàn)后續(xù)代碼清單。

t;);
            columnListInfoCode[i][0] = columnName;
            columnListInfoCode[i][1] = columnType;
            System.out.println("Code columnName:" + columnName + " columnType:" + columnType);
          }
        }
        //生成實(shí)例
        ImportTableInfoBO importAction = new ImportTableInfoBO();
        importAction.setTableName(tableName);
        importAction.setColumnNamesFile(columnListInfoFile);
        if (columnListInfoCode != null) {
          importAction.setColumnNamesCode(columnListInfoCode);
        }
        //放入靜態(tài)容器中
        importJobList.put(tableName, importAction);
      }
      //2.其他配置信息
      Element importDealClassList = (Element) eroot.getElementsByTagName("ImportDealClassList").item(0);
      String className;
      String classFullName;
      NodeList beanList = importDealClassList.getElementsByTagName("Bean");
      for (int j=0; j < beanList.getLength(); j++){
        className = ( (Element) beanList.item(j)).getAttribute("name");
        classFullName = ( (Element) beanList.item(j)).getAttribute("class");
        dealClassList.put(className,classFullName);
      }
     
      System.out.println("importJobList.size()" + importJobList.size());
      System.out.println("dealClassList.size()" + dealClassList.size());

 

;      insertNum = 1;
        } else {
          insertNum++;
        }
      }
    } catch (Exception e) {
      e.printStackTrace();
      //---寫(xiě)入數(shù)據(jù)庫(kù)待加入----
      //log.error(e.getMessage());
    }
}

public void close() {
    if (conn != null) {
      try {
        if (conn != null) {
          DbUtils.commitAndClose(conn);
        System.out.println("close end");
        }
      } catch (SQLException e) {
        e.printStackTrace();
        //log.error(e.getCause());
      }
    }
}

/**
   *
   * @param dateString String
   * @param format String
   * @return Date
   */
public Date formatDate(String dateString,String format){
    try{
      SimpleDateFormat f = new SimpleDateFormat(format);
      return f.parse(dateString);
    }catch(Exception e){
      return null;
    }
}

}


八、調(diào)用示例
package fileimport;

import java.util.HashMap;

public class ImportFileExample {
public ImportFileExample() {
}
public static void main(String[] args) {
   try {
     String ls = "c:/temp/employee_test.csv";


主站蜘蛛池模板: 国产理论自拍 | 五月婷婷中文 | 国产精品人妻无码八区仙踪林 | 国产精品美女久久久久久 | 日本大片在线观看免费视频 | 精品久久洲久久久久护士免费 | 日日噜噜夜夜狠狠视频buoke | 免费人成又黄又爽的视频强 | 一级片在线视频 | 欧美一区二区三区精品国产 | 中文字幕在线一区二区三区 | 久久艹免费视频 | 欧美视频网站在线观看 | a一级黄色片 | 午夜寂寞影视在线观看 | 国产精品视频一区二区三区 | 亚洲性69影院在线观看 | 日韩欧美一二三区 | 日本aaaaa高清免费看 | 青青草成人免费视频在线 | 免费看搡女人无遮挡的视频 | 国产精品点击进入在线影院高清 | 欧美日本一道本 | 日韩精品区 | 久久免费看少妇高潮A片特黄多 | 国产亚洲精品久久久久久线投注 | 最新中文字幕日本 | 国产精品毛片一区二区三区 | 亚洲国产精品一区二区第一页 | 国产在线精彩视频 | 国产成人免费视频网站高清观看视频 | 欧美久草 | 国产精品视频播放 | 久色视频在线观看 | 国产日韩一区二区 | 欧美性影院 | 天天操91 | 午夜精品一区二区三区在线视频 | 亚洲精品久久久久一区二区三区 | 精品一区二区三区免费视频 | 成人国产精品免费视频不卡 |