你會如何去優化（無碼重複），其中有這類

Question

代碼我繼承了許多功能的Java代碼中有這種形式的許多交易代碼方法：

public void addCourseToCourses(String values) 
{ 
    try 
    { 
     conn.setAutoCommit(false); 
    } 
    catch (SQLException e) 
    { 
     Logger.getLogger(connDb.class.getName()).log(Level.SEVERE, null, e); 
     return; 
    } 
    try 
    { 
     stmt.executeUpdate("insert into courses values " + values); 
     conn.commit(); 
    } 
    catch (SQLException e) 
    { 
     try 
     { 
      conn.rollback(); 
     } 
     catch (SQLException ex) 
     { 
      Logger.getLogger(connDb.class.getName()).log(Level.SEVERE,null, ex); 
     } 
    } 
    finally 
    { 
     try 
     { 
      conn.setAutoCommit(true); 
     } 
     catch (SQLException ex) 
     { 
      Logger.getLogger(connDb.class.getName()).log(Level.SEVERE,null, ex); 
     } 
    } 
} 

如果這一方法之間不同的可變部分是

stmt.executeUpdate("insert into courses values " + values); 

有時是幾個插入，有時候是刪除。 我錯過了使用來自C++的宏，但我確信有一種方法不會爲每種方法重複所有這些事務代碼。

有幫助嗎？

（康涅狄格州和語句是類型java.sql.Connection中和java.sql.Statement中的類成員）

Answer 1

創建接受一個接口幷包裝起來異常時的處理的方法。

每個接口的匿名（或沒有）執行包含SQL調用，它的參數等

例如（非常粗略地）：

public void addCourseToCourses(final String values) { 
    handleSql(new SqlCommand() { 
     @Override public void run(Statement stmt) { 
      stmt.executeUpdate("insert into courses values " + values); 
     } 
    }); 
} 

的handleSql是形成類似靜態導入：

public class SqlWrapper { 
    public static void handleSql(SqlCommand cmd) { 
     Connection conn = // get connection; 
     try { 
      conn.setAutoCommit(false); 
     } catch (SQLException e) { 
      LOG.log(Level.SEVERE, null, e); 
      return; 
     } 

     try { 
      cmd.run(); 
      conn.commit(); 
     } catch (SQLException e) { 
      cleanRollback(); 
     } finally { 
      cleanClose(); 
     } 
    } 
} 

可以添加各種掛鉤，因爲看起來合理。通用版本將允許各種返回類型，這可能更合適，只取決於您實際需要的內容。

評論提及Runnable和Callable，IMO Runnable是專門針對線程（和基礎接口不是通用的）。 Callable是一個更好的選擇，但我希望能夠添加足夠的其他鉤子來處理特定於應用程序的特定於SQL/JDBC的功能。因人而異。

這種模式已被重新發明到處都是;採用Spring JDBC之類的東西並使用它可能更有意義。

Answer 2

爲什麼不那麼就做這樣的事情：

public void addCourseToCourses(String values) 
{ 
    callDB("insert into courses values " + values) 
} 

protected void callDB(String call) 
{ 
    try 
    { 
     conn.setAutoCommit(false); 
    } 
    catch (SQLException e) 
    { 
     Logger.getLogger(connDb.class.getName()).log(Level.SEVERE, null, e); 
     return; 
    } 
    try 
    { 
     stmt.executeUpdate(call); 
     conn.commit(); 
    } 
    catch (SQLException e) 
    { 
     try 
     { 
      conn.rollback(); 
     } 
     catch (SQLException ex) 
     { 
      Logger.getLogger(connDb.class.getName()).log(Level.SEVERE,null, ex); 
     } 
    } 
    finally 
    { 
     try 
     { 
      conn.setAutoCommit(true); 
     } 
     catch (SQLException ex) 
     { 
      Logger.getLogger(connDb.class.getName()).log(Level.SEVERE,null, ex); 
     } 
    } 
} 

這樣，所有的交易相關的代碼是在一個地方，每一個人的方法是隻用於格式化相應的聲明負責。

Answer 3

更有意思的方法是創建一個像executeSQL這樣的方法來處理常見的東西，並且只需傳遞sql（String）即可執行。

更好的方法是查看Spring並讓Spring處理事務和消息處理。

Answer 4

其實，你不需要一個新的界面。像Runnable或Callable這樣的現有產品可以做得很好。

Answer 5

您可以使用「回調」的格局，這在Java中使用匿名類完成，像這樣：

創建一個接口來完成實際工作：

interface Exec { 
    exec(PreparedStatement stmt) throws SQLException; 
} 

重構代碼創建方法與接受的Exec的通用代碼：

void perform(Exec exec) { 
    try 
    { 
     conn.setAutoCommit(false); 
    } 
    catch (SQLException e) 
    { 
     Logger.getLogger(connDb.class.getName()).log(Level.SEVERE, null, e); 
     return; 
    } 
    try 
    { 
     exec.exec(stmt); 
     conn.commit(); 
    } 
    catch (SQLException e) 
    { 
     try 
     { 
      conn.rollback(); 
     } 
     catch (SQLException ex) 
     { 
      Logger.getLogger(connDb.class.getName()).log(Level.SEVERE,null, ex); 
     } 
    } 
    finally 
    { 
     try 
     { 
      conn.setAutoCommit(true); 
     } 
     catch (SQLException ex) 
     { 
      Logger.getLogger(connDb.class.getName()).log(Level.SEVERE,null, ex); 
     } 
    } 
} 

重構你的方法是這樣的：

public void addCourseToCourses(final String values) 
{ 
    perform(new Exec() { 
     exec(PreparedStatement stmt) throws SQLException { 
      stmt.executeUpdate("insert into courses values " + values); 
     } 
    }); 
} 

Answer 6

使用SQL語句的列表：

function void executeTransaction(List<String> sqlStatements) { 
    // init transaction (as before) 
    try 
    { 
     conn.setAutoCommit(false); 
    } 
    catch (SQLException e) 
    { 
     Logger.getLogger(connDb.class.getName()).log(Level.SEVERE, null, e); 
     return; 
    } 
    try 
    { 
     // execute all statements from transaction 
     for(String statement: sqlStatements) { 
      stmt.executeUpdate("insert into courses values " + values); 
     } 
     // Commit when all succeed 
     conn.commit(); 
    } 
    catch (SQLException e) 
    { 
     try 
     { 
      // rollback on failure (as before) 
      conn.rollback(); 
     } 
     catch (SQLException ex) 
     { 
      Logger.getLogger(connDb.class.getName()).log(Level.SEVERE,null, ex); 
     } 
    } 
    finally 
    { 
     try 
     { 
      // cleanup (as before) 
      conn.setAutoCommit(true); 
     } 
     catch (SQLException ex) 
     { 
      Logger.getLogger(connDb.class.getName()).log(Level.SEVERE,null, ex); 
     } 
    } 
}