<dfn id="is4kg"></dfn>
  • <ul id="is4kg"></ul>
  • <abbr id="is4kg"></abbr>
  • <ul id="is4kg"></ul>
    <bdo id="is4kg"></bdo>
    以文本方式查看主題

    -  曙海教育集團論壇  (http://www.hufushizhe.com/bbs/index.asp)
    --  Oracle數據庫  (http://www.hufushizhe.com/bbs/list.asp?boardid=65)
    ----  4月14日 從文件(*.csv或*.txt)導入Oracle數據庫Java源代碼  (http://www.hufushizhe.com/bbs/dispbbs.asp?boardid=65&id=2507)

    --  作者:wangxinxin
    --  發布時間:2010-12-11 11:11:37
    --  4月14日 從文件(*.csv或*.txt)導入Oracle數據庫Java源代碼
    近期由于項目需要,實現了從.csv或者.txt文件中讀取每行信息后插入到Oracle數據庫中的功能,特共享出來。用到第三方開源工具包:opencsv-1.8.jar和commons-dbutils-1.1.jar,需單獨下載。
    首先需要配置XML文件,如下:
    <?xml version="1.0" encoding="UTF-8"?>
    <root>
    <DefaultImport>Employee</DefaultImport>
    <TargetTable tableName="EMPLOYEE_TEST">
    <!--表中對應文件的列名和類型信息-->
    <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個導入工作:(1)表EMPLOYEE_TEST(2)表YFJBXX_TEST,文件中每張表的列名和類型需要和導入的目標表一致,且順序和文件中要導入的內容相匹配,例如下面的csv文件:

    "ID","DEP","NAME","AREA","AGE","SEX","XUELI","SALARY","PRIX"
    "001","研發","張三","北京","34","女","本科","4546","1"
    "002","銷售","李四","天津","45","男","?","4456","2"

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

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

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

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

    至此,一個簡單的不需做任何處理直接從文件導入數據庫對應表的功能就實現了。

    但是有些時候我們需要進行特殊的處理,例如表中的當前操作日期列在導入文件中沒有,需要在代碼中加入,這時就需要實現FileImportInterface接口并加入到配置文件中例如:<Bean name="ImportWISImpl" class="fileimport.ImportWISImpl"/>,ImportWISImpl的實現代碼見后續代碼清單。

    t;);
                columnListInfoCode[i][0] = columnName;
                columnListInfoCode[i][1] = columnType;
                System.out.println("Code columnName:" + columnName + " columnType:" + columnType);
              }
            }
            //生成實例
            ImportTableInfoBO importAction = new ImportTableInfoBO();
            importAction.setTableName(tableName);
            importAction.setColumnNamesFile(columnListInfoFile);
            if (columnListInfoCode != null) {
              importAction.setColumnNamesCode(columnListInfoCode);
            }
            //放入靜態容器中
            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();
          //---寫入數據庫待加入----
          //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;
        }
    }

    }


    八、調用示例
    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";


    主站蜘蛛池模板: 最近日本免费观看直播| 在线观看成人网站| 日本成人在线免费| 又爽又黄又无遮挡的视频| 99视频免费播放| 成人免费在线视频| 亚洲色偷偷综合亚洲av伊人| 精品国产精品国产| 国产男女插插一级| baoyu777永久免费视频| 成人欧美一区二区三区在线观看| 亚洲人成影院77777| 波多野结衣加勒比| 国产91在线播放动漫| 麻豆国产尤物AV尤物在线观看| 天天天天躁天天爱天天碰2018| 久久国产香蕉视频| 欧美三级欧美一级| 免费一级在线观| 老司机永久免费视频| 国产欧美另类久久精品蜜芽| a级毛片免费网站| 小蝌蚪视频在线免费观看| 久久精品国产大片免费观看| 欧美丰满熟妇XXXX性ppX人交| 再深点灬舒服灬免费观看| 老少交欧美另类| 国产成人高清视频| 99久久国产免费福利| 好妈妈5韩国电影高清中字| 久久亚洲AV成人无码| 日韩视频一区二区在线观看| 亚洲欧美日韩国产综合| 真实国产精品视频国产网| 国产三级在线观看免费| 韩国理论片久久电影网| 国产青年摘花xxx| zzzzzzz中国美女| 少妇被又大又粗又爽毛片久久黑人| 久久天天躁日日躁狠狠躁| 日韩美女一级毛片|