2012-04-30 66 views
0

我想用Java創建一個庫(Jar文件),它將包含我們所用數據庫的所有方法。那裏有大約60種方法,所以我想讓它更有條理。我想調用下面提供的示例方法。創建一個有組織的Java庫

db.accounts.add(username, password); or db.accounts().add(username, password); 
db.names.delete(name); or db.names().delete(name); 

在Java中這樣做的最好方法是什麼?

+0

有組織如何?我不明白這個問題。 –

+0

非常多我想擁有與管理帳戶有關的方法,當我鍵入db.accounts時,我得到與管理方法相關的方法。 – Arya

+0

我試圖做同樣的事情在這篇文章,但在Java中 http://stackoverflow.com/questions/10361877/organizing-methods-for-better-accessing-them/10361968#comment13361067_10361968 – Arya

回答

4

你可以爲自己省下不少麻煩,寫一個通用的DAO:

package persistence; 

public interface GenericDao<K, V> { 
    V find(K id); 
    List<V> find(); 
    K save(V value); 
    void update(V value); 
    void delete(V value); 
} 

我忘了寫你自己的持久化類,並使用成熟的解決方案,如Spring JDBC模板。

這個問題已經解決了很多次,很多方面。你希望做什麼來改進存在的東西?您如何證明開發,測試和維護此功能的額外費用?

+0

我問過同樣的問題,但它與c#有關,實現起來很簡單。我想你誤解了我的問題。這裏是到C#問題的鏈接。我幾乎問同樣的事情,但對於Java http://stackoverflow.com/questions/10361877/organizing-methods-for-better-accessing-them/10361968#comment13361067_10361968 – Arya

+0

不,我沒有。我的答案沒有變化。 – duffymo

1

這裏我的自定義庫的一些快照連接到數據庫:

enter image description here

PostgreConnection.java

public class PostgreConnection { 

private static Connection conn; 

public Connection makeConnection(String url, String db, String username, String password) { 
    if (conn == null) { 
     try { 
      Class.forName(Constants.POSTGRES_DRIVER); 

      conn = DriverManager.getConnection(Constants.POSTGRES_URL + url + "/" + db, username, password); 
     } catch (SQLException | ClassNotFoundException ex) { 
      Logger.getLogger(PostgreConnection.class.getName()).log(Level.SEVERE, null, ex); 
     } 
    } 

    return conn; 
} 

}

Constants.java

public class Constants { 

    public static String POSTGRES_URL = "jdbc:postgresql://"; 
    public static String POSTGRES_DRIVER = "org.postgresql.Driver"; 
} 

org.ert.model,你可以將所有Model,你需要根據你的數據庫的表。

NotifyCharts.java

public class NotifyCharts { 

private Integer Id; 
private String revName; 
private Date importDate; 
private Integer pages; 
private Boolean status; 

public Integer getId() { 
    return Id; 
} 

public void setId(Integer Id) { 
    this.Id = Id; 
} 

public Date getImportDate() { 
    return importDate; 
} 

public void setImportDate(Date importDate) { 
    this.importDate = importDate; 
} 

public Integer getPages() { 
    return pages; 
} 

public void setPages(Integer pages) { 
    this.pages = pages; 
} 

public String getRevName() { 
    return revName; 
} 

public void setRevName(String revName) { 
    this.revName = revName; 
} 

public Boolean isStatus() { 
    return status; 
} 

public void setStatus(Boolean status) { 
    this.status = status; 
} 
} 

SQLQuery爲一些基本的方法,如一個insert, update, delete, etcabstract class

SQLQuery.java

public abstract class SQLQuery<T> { 
    protected void makeStatement(String url, String db, String username, String password) { 
    PostgreConnection connect = new PostgreConnection(); 
    Connection con = connect.makeConnection(url, db, username, password); 

    try { 
     state = (Statement) con.createStatement(); 
    } catch (SQLException ex) { 
     Logger.getLogger(SQLQuery.class.getName()).log(Level.SEVERE, null, ex); 
    } 
} 

public String arrayBuilder(Object[] obj, boolean val) { 
    StringBuilder arr = new StringBuilder(); 

    arr.append("("); 
    for (int i = 0; i < obj.length; i++) { 
     if (i < obj.length - 1) { 
      if (val) { 
       arr.append("'"); 
      } 
      arr.append(obj[i]); 

      if (val) { 
       arr.append("'"); 
      } 

      arr.append(", "); 
     } else { 
      if (val) { 
       arr.append("'"); 
      } 
      arr.append(obj[i]); 
      if (val) { 
       arr.append("'"); 
      } 
     } 
    } 
    arr.append(")"); 

    return arr.toString(); 
} 

public int insertRecord() throws SQLException { 
    StringBuilder query = new StringBuilder(); 

    query.append("INSERT INTO ").append(tableName).append(arrayBuilder(columns, false)).append(" VALUES ").append(arrayBuilder(values, true)); 

    return state.executeUpdate(query.toString()); 
} 

public ResultSet getAll() throws SQLException { 
    StringBuilder query = new StringBuilder(); 

    query.append("SELECT * FROM ").append(tableName); 
    rSet = state.executeQuery(query.toString()); 

    return rSet; 
} 

public abstract void setColsAndVals(T t); 
} 

NotifyChartsSQL.java是實施abstract class的,org.ert.sql.implpackage來存儲所有您的實現你需要的。

NotifyChartsSQL.java

public class NotifyChartsSQL extends SQLQuery<NotifyCharts> { 

public NotifyChartsSQL(String url, String db, String username, String password, NotifyCharts notify) { 
    makeStatement(url, db, username, password); 
    setColsAndVals(notify); 
} 

@Override 
public final void setColsAndVals(NotifyCharts notify) { 
    Map<String, Object> objects = new HashMap<>(); 
    String[] columns; 
    Object[] values; 

    if(notify.getId() != null) 
     objects.put("id", notify.getId()); 
    if(notify.getRevName() != null) 
     objects.put("rev_name", notify.getRevName()); 
    if(notify.getImportDate() != null) 
     objects.put("import_date", notify.getImportDate()); 
    if(notify.getPages() != null) 
     objects.put("pages", notify.getPages()); 

    objects.put("status", notify.isStatus()); 

    columns = Arrays.copyOf(objects.keySet().toArray(), objects.size(), String[].class); 
    values = objects.values().toArray(); 

    setColumns(columns); 
    setValues(values); 
    setTableName("notify_charts"); 
} 

} 

而去年是test包,測試自定義庫,以確保一切正常。

TestMain。java的

public class TestMain { 

public static void main(String[] args) { 
    NotifyCharts notify = new NotifyCharts(); 
    try { 

     notify.setRevName("Test456"); 
     notify.setImportDate(new Date()); 
     notify.setPages(10); 
     notify.setStatus(false); 

     NotifyChartsSQL notCharts = new NotifyChartsSQL("localhost:5432", "charts", "username", "password", notify); 


     int status = notCharts.insertRecord(); 

     if (status == 1) { 
      System.out.println("Success Insert"); 
     } else { 
      System.out.println("Failed Insert"); 
     } 
    } catch (SQLException ex) { 
     Logger.getLogger(TestMain.class.getName()).log(Level.SEVERE, null, ex); 
    } 
} 

}

,如果你想使這個自定義庫,我建議,如果你使用手動JDBC和不使用ORMHibernate。因爲在Hibernate中已經提供了所有你需要的方法,除了你想添加一些特殊的方法,你可以像duffymo之前說的那樣做。自定義庫的這個想法來自DAOHibernate結構。

感謝閱讀,而且請了解一些Design Pattern in Java如果你想使更多的組織一些自定義庫。