1 沒有利用反射來對資料庫進行操作

建立工具類：JDBCConnection（使用單列設計模式）

package com.test.connection; import java.sql.Connection; import java.sql.DriverManager; public class JDBCConnection { private static final String DBURL = "jdbc:oracle:thin:@localhost:1521:orcl"; //資料庫地址 private static final String DBDRIVER = "oracle.jdbc.driver.OracleDriver"; //資料庫驅動類 private static final String DBUSER = "nieguohui" ; //資料庫 private static final String DBPAW = "nieguohui" ; private static Connection connection = null; //構造方法私有化，實現單例模式 private JDBCConnection() { try { Class.forName(DBDRIVER); this.connection = DriverManager.getConnection(DBURL, DBUSER, DBPAW); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } } /** * 取得Connection * @return Connection 例項化物件 */ public static Connection getConnection(){ if (connection == null) { new JDBCConnection(); } return connection ; } }

建立IBaseDao介面（Dao中常用的操作方法）

package com.test.idao; public interface IBaseDao<t> { /** * 向資料庫新增一條記錄 * 每個表中都存在的方法 * @param t 要新增的物件 * @return 影響資料庫的條數 */ public int add(T t); } </t>

建立IStudentDao介面，讓其繼承BaseDao介面

package com.test.idao; import com.test.vo.Student; public interface IStudentDao extends BaseDao<student>{ /** * StudentDao中的特有的方法 * @return */ public Student findStudent(); } </student>

建立ITeacherDao介面，讓其繼承BaseDao介面

package com.test.idao; import com.test.vo.Teacher; public interface ITeacherDao extends BaseDao<teacher>{ /** * TeacherDao中特殊的方法 */ public void findTeacher(); } </teacher>

建立StudentDao類，實現IStudentDao介面

package com.test.dao; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.SQLException; import com.test.connection.JDBCConnection; import com.test.idao.IStudentDao; import com.test.vo.Student; public class StudentDao implements IStudentDao { @Override public int add(Student t) { int len = 0 ; Connection connection = JDBCConnection.getConnection(); String sql = "INSERT INTO student(id,name,address) values(STUDENT_SEQ.nextval,?,?)" ; try { PreparedStatement preparedStatement = connection.prepareStatement(sql); preparedStatement.setString(1, t.getName()); preparedStatement.setString(2, t.getAddress()); len = preparedStatement.executeUpdate(); preparedStatement.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } try { connection.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return len; } @Override public Student findStudent() { return null; } }

建立TeacherDao類，實現IStudentDao介面

package com.test.dao; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.SQLException; import com.test.connection.JDBCConnection; import com.test.idao.ITeacherDao; import com.test.vo.Teacher; public class TeacherDao implements ITeacherDao{ @Override public int add(Teacher t) { int len = 0 ; Connection connection = JDBCConnection.getConnection(); String sql = "INSERT INTO teacher(tid,tname,subject) values(TEACHER_SEQ.nextval,?,?)" ; try { PreparedStatement preparedStatement = connection.prepareStatement(sql); preparedStatement.setString(1, t.getTname()); preparedStatement.setString(2, t.getSubject()); len = preparedStatement.executeUpdate(); preparedStatement.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } try { connection.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return len; } @Override public void findTeacher() { // TODO Auto-generated method stub } }

單元測試與實體類略，如果你喜歡，也可以新增一個工廠類來進行操作。在本組程式碼中，我們要關注的是IBaseDao中定義的方法，如我們這次定義的add()方法，我們通過分析程式碼，可以發現裡面的很多程式碼可以重用，只有在SQL語句與使用setString(int parameterIndex, String x)這個方法的時候有所變化。SQL中也是表名與表的欄位有所不同，如果你開發的實體類中的屬性與表中列的命名是一致的話，完全可以通過反射來進行取得屬性，然後進行字串的拼接；setString(int parameterIndex, String x)的設定，可以通過迴圈反射得到的陣列進行字串的拼接來得到get的方法，但是遇到注意的是，因為我們的Id一般不是手動設定的，為了能很好的設定對應的值，我們在開發實體類的時候，必須把Id這個屬性放到開頭。

2 使用反射對上面的程式碼進行修改

建立BaseDao類，來實現IBaseDao介面，同時記StudentDao與TeacherDao繼承它（同時還要刪除之前我們實現的add方法的實現，不然這樣就沒有什麼意義了，當然如果你不想使用在BaseDao實現的add方法，可能履寫add方法）。每個表IXXDao也不需要再繼承IBaseDao這個介面。

package com.test.dao; import java.lang.reflect.Field; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.SQLException; import com.test.connection.JDBCConnection; public class BaseDao<t> implements com.test.idao.IBaseDao<t> { @Override public int add(T t) { int len = 0 ; Connection connection = JDBCConnection.getConnection(); // 通過已經例項化好物件的getClass方法取得 Class<?> class1 =t.getClass(); //使用StringBuffer拼接字串 StringBuffer sql = new StringBuffer("INSERT INTO "); //加入表名 sql.append(class1.getSimpleName()) ; sql.append(" ( ") ; //得到所有的私有屬性 Field [] fields = class1.getDeclaredFields(); //進行屬性的拼接 StringBuffer property = new StringBuffer(); //後面的佔位字條串拼接 StringBuffer value = new StringBuffer() ; //因為我這裡使用的Oracle序列生成主鍵，所以要把Id也要設定值 property.append(fields[0].getName()); //我設定的序列名為 表名_seq value.append(class1.getSimpleName()).append("_seq.nextval"); for (int i = 1 ; i < fields.length ; i ++) { property.append(" , ").append(fields[i].getName()) ; value.append(", ?"); } sql.append(property).append(" ) values ( ").append(value).append(")"); System.out.println(sql.toString()); try { PreparedStatement preparedStatement = connection.prepareStatement(sql.toString()); //進行資料的設值 for(int i = 1; i < fields.length ; i ++ ){ try { //取消屬性的封裝 fields[i].setAccessible(true); preparedStatement.setObject(i, fields[i].get(t)); } catch (IllegalAccessException e) { e.printStackTrace(); } } len = preparedStatement.executeUpdate(); preparedStatement.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } try { connection.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return len; } } </t></t>

現在你無論新增多少表，對應的DAo只需要繼承BaseDao類，就可以實現這個表新增操作