重構類似CSV處理

所以我目前正在其中包括來自數個GZIP使用JDBC壓縮CSV文件更新H2數據庫的項目。我注意到CSV文件的處理過程保持不變。只有填寫PreparedStatement對象的部分才真正有所不同。下面的代碼片段，我使用：重構類似CSV處理

InputStream in = getStream(world.getUrl(), true, Configuration.GET_PLAYER_COMPRESSED); 
Scanner sc = new Scanner(in); 
PreparedStatement stmt = con.prepareStatement(SQL_UPDATE_PLAYER); 

String[] line; 
int i = 0; 
while (sc.hasNextLine()) { 
    try { 
     line = sc.nextLine().split(","); 

    { //this code differs from the rest 
     stmt.setString(1, world.getIdentifier()); 
     stmt.setInt(2, Integer.valueOf(line[0])); 
     stmt.setString(3, URLDecoder.decode(line[1], "UTF-8")); 
     if ("0".equals(line[2])) { 
      stmt.setNull(4, Types.INTEGER); 
     } else { 
      stmt.setInt(4, Integer.valueOf(line[2])); 
     } 
    } 
    stmt.addBatch(); 
    if (++i >= 1000) { 
     stmt.executeBatch(); //execute batch every 1000 entries 
     i=0; 
    } 
    } catch (Exception e) { 
     e.printStackTrace(); 
    } 
} 
stmt.executeBatch(); 
stmt.close(); 
sc.close();

它是通過回調對象訪問此問題，就像在下面的例子中的好辦法？

Callback callback = new Callback() { 

    protected int i; 
    protected PreparedStatement stmt; 

    //called before processing 
    public void preProcess() { 
    int i = 0; 
    //initialisation or whatever 
    } 

    //called on every line 
    public void processLine(String[] line) { 
    stmt.setString(1, world.getIdentifier()); 
    // [...] 
    stmt.addBatch() 
    if(++i >= 1000) { 
     stmt.executeBatch(); 
     i = 0; 
    } 
    } 

    //called after processing lines 
    protected void postProcess() { 
    stmt.executeBatch(); 
    } 
} 

processCsv(inputStream, callback);

來源

2014-09-01 Dreistein

外包????????????????? – Leo 2014-09-01 18:27:21

我的意思是像冗餘代碼打包到一個地方。不知道英文中的確切術語。 – Dreistein 2014-09-01 18:32:00

*重構*。我已經相應地重發了你的帖子。 – khampson 2014-09-01 18:39:12

我建議使用模板方法。爲每種預準備語句的類型創建處理對象的子類。

在基類中。

protected abstract void processLine(PreparedStatement stmt, String[] line) 
    throws SQLException, UnsupportedEncodingException; 

public void parse() throws SQLException 
{ 
InputStream in = getStream(world.getUrl(), true, Configuration.GET_PLAYER_COMPRESSED); 
Scanner sc = new Scanner(in); 
PreparedStatement stmt = con.prepareStatement(SQL_UPDATE_PLAYER); 

String[] line; 
int i = 0; 
while (sc.hasNextLine()) { 
    try { 
     line = sc.nextLine().split(","); 

    { 
     processLine(stmt, line); 
    } 
    stmt.addBatch(); 
    if (++i >= 1000) { 
     stmt.executeBatch(); //execute batch every 1000 entries 
     i=0; 
    } 
    } catch (Exception e) { 
     e.printStackTrace(); 
    } 
} 
stmt.executeBatch(); 
stmt.close(); 
sc.close(); 
}

在上例中的子類中。

protected void processLine(PreparedStatement stmt, String[] line) 
     throws SQLException, UnsupportedEncodingException 
{ 
    //this code differs from the rest 
     stmt.setString(1, world.getIdentifier()); 
     stmt.setInt(2, Integer.valueOf(line[0])); 
     stmt.setString(3, URLDecoder.decode(line[1], "UTF-8")); 
     if ("0".equals(line[2])) { 
     stmt.setNull(4, Types.INTEGER); 
     } else { 
     stmt.setInt(4, Integer.valueOf(line[2])); 
     } 
}

來源

2015-01-11 17:18:37 Aaron

重構類似CSV處理

回答

相關問題