<dfn id="is4kg"></dfn>
  • <ul id="is4kg"></ul>
  • <abbr id="is4kg"></abbr>
  • <ul id="is4kg"></ul>
    <bdo id="is4kg"></bdo>

    曙海教育集團論壇開發語言培訓專區Oracle數據庫 → 4月14日 從文件(*.csv或*.txt)導入Oracle數據庫Java源代碼


      共有6826人關注過本帖樹形打印

    主題:4月14日 從文件(*.csv或*.txt)導入Oracle數據庫Java源代碼

    美女呀,離線,留言給我吧!
    wangxinxin
      1樓 個性首頁 | 博客 | 信息 | 搜索 | 郵箱 | 主頁 | UC


    加好友 發短信
    等級:青蜂俠 帖子:1393 積分:14038 威望:0 精華:0 注冊:2010-11-12 11:08:23
    4月14日 從文件(*.csv或*.txt)導入Oracle數據庫Java源代碼  發帖心情 Post By:2010-12-11 11:11:37

    近期由于項目需要,實現了從.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";


    支持(0中立(0反對(0單帖管理 | 引用 | 回復 回到頂部

    返回版面帖子列表

    4月14日 從文件(*.csv或*.txt)導入Oracle數據庫Java源代碼








    簽名
    主站蜘蛛池模板: 精品丝袜人妻久久久久久| bt天堂资源在线种子| 欧美性a欧美在线| 噜噜噜狠狠夜夜躁| 麻豆亚洲av熟女国产一区二| 女人与公拘交酡全过程i| 久久精品一区二区免费看| 欧美国产中文字幕| 农民人伦一区二区三区| 草莓视频aqq| 国产精品一区二区av| chinese精品男同志浪小辉| 成人福利app| 久久综合色婷婷| 欧美jlzz18性欧美| 人妻无码久久久久久久久久久| 精品成人一区二区三区免费视频| 国产欧美一区二区久久| 99精品国产在这里白浆| 好男人神马视频在线观看| 久久伊人中文字幕| 日韩电影免费在线观看中文字幕| 亚洲欧美日韩综合一区久久| 男人让女人桶爽30分钟| 国产一级做美女做受视频| 韩国理论妈妈的朋友| 国产精品国产三级国产普通话| xl上司带翻译无马赛樱花| 性猛交xxxxx按摩欧美| 久久午夜夜伦鲁鲁片无码免费| 日韩网新片免费| 亚洲成人app| 欧美日韩国产在线人成| 免费人成视网站在线观看不卡| 精品国产亚洲一区二区三区| 国产剧情一区二区| 香蕉视频久久久| 国产精品99久久久| 91香蕉视频黄| 国内揄拍国内精品| xinjaguygurporn|