1.首先定義一個實體類Book

public class Book {
	private Integer bookId;
	private String bookName;
	private String bookAuthor;
	private BigDecimal bookPrice;
	private Date bookDate;
//省略set/get方法
}

2.寫一個數據庫通用工具類：

public class DBUtil {
/**
 * 資料庫操作工具類
 */
	private static String DRIVER_CLASS="com.mysql.jdbc.Driver";
	private static String URL="jdbc:mysql:///bbs";
	private static String USER="root";
	private static String PASSWORD="123456";
	//封裝載入驅動
		static {
			try {
				Class.forName(DRIVER_CLASS);
			}catch(ClassNotFoundException e) {
				e.printStackTrace();
			}
		}
		//封裝連線資料庫
		public static Connection getConnection() {
			try {
				return DriverManager.getConnection(URL, USER, PASSWORD);
			}catch(SQLException e) {
				e.printStackTrace();
			}
			return null;
		}
		//定義通用的增刪改的方法
		//parameters佔位符sql語句對應的值組成的陣列
		public static int executeUpdate(String sql,Object...parameters) {
			int row=0;
			Connection conn=getConnection();
			PreparedStatement pst=null;
			try {
				pst=conn.prepareStatement(sql);
				//判斷有沒有引數需要設定
				if(parameters.length>0) {
					for(int i=0;i<parameters.length;i++) {
						//引數型別如何判斷呢。所有類都是object子類
						pst.setObject(i+1, parameters[i]);
					}
				}
				//執行sql語句
				row=pst.executeUpdate();
			}catch(Exception e) {
				e.printStackTrace();
			}finally {
				try {
					if(pst!=null) {
					pst.close();
					}
				}catch(SQLException e) {
					e.printStackTrace();
				}
				try {
					if(conn!=null) {
					conn.close();
					}
				}catch(SQLException e) {
					e.printStackTrace();
				}
			}
			return row;
		}
    }
 

3.現在我們寫一個測試方法

@Test
	public void testInsert() {
		String insertSQL="insert into book(bookAuthor,bookName,bookPrice,bookDate)values(?,?,?,?)";
		Object[] parameters= {
				"小李",
				"新的圖書",
				new BigDecimal(45.6),
				new Date()
		};
		int row=DBUtil.executeUpdate(insertSQL, parameters);
		System.out.println(row>0?"成功":"失敗");
	}
 

4.現在我們是可以測試成功的，可以看出來我們需要實現的其實就是sql語句和引數，下面我們手動實現底層程式碼

public class BeanUtil {
//通用持久化物件的方法實現
	public<T> int persist(T entity) throws MyORMException{
		StringBuilder sqlBuilder=new StringBuilder("INSERT INTO ");
		//儲存引數的集合列表
		List<Object>parameters=new ArrayList<Object>();
		//獲取當前操作類的名稱
		Class<?> cl=entity.getClass();
		String name=cl.getSimpleName();
		sqlBuilder.append(name).append("(");
		//獲取當前操作類中定義的屬性
		Field[] fields=cl.getDeclaredFields();
		if(fields!=null&&fields.length>0) {
			for(int i=0;i<fields.length;i++) {
			Field field=fields[i];
			//獲取欄位對應值
			field.setAccessible(true);
			Object value = null;
			try {
				value = field.get(entity);
			} catch (Exception e) {
				throw new MyORMException("獲取"+field.getName()+"欄位值的時候出現異常"+e.getMessage());
				
			}
			//判斷值是否為空
			if(value!=null) {
				sqlBuilder.append(field.getName()).append(",");
				parameters.add(value);
			}
			}
			//刪除最後一個逗號
			sqlBuilder.deleteCharAt(sqlBuilder.length()-1);
		}
		sqlBuilder.append(")").append("values (");
		//組裝引數列表
		for(int i=0;i<parameters.size();i++) {
			sqlBuilder.append("?,");
		}
		//刪除最後一個逗號
		sqlBuilder.deleteCharAt(sqlBuilder.length()-1).append(")");
		System.out.println(sqlBuilder);		
		return DBUtil.executeUpdate(sqlBuilder.toString(), parameters.toArray(new Object[parameters.size()]));
	}

}
 

5.測試方法，現在使用者只需要傳入物件不需要寫sql語句就可以實現儲存了

@Test
	public void testSave() {
		BookDAOImpl dao=new BookDAOImpl();
		Book book=new Book();
		book.setBookAuthor("張三");
		book.setBookDate(new Date());
		book.setBookName("我的圖書");
		book.setBookPrice(new BigDecimal(34.5));
		int row=dao.saveBook(book);
		System.out.println(row>0?"成功":"失敗");
	}

6.框架肯定少不了異常處理，自己寫一個全域性異常處理，裡面是重寫了父類的構造方法

public class MyORMException extends RuntimeException{

	public MyORMException() {
		super();
		// TODO Auto-generated constructor stub
	}

	public MyORMException(String arg0, Throwable arg1, boolean arg2, boolean arg3) {
		super(arg0, arg1, arg2, arg3);
		// TODO Auto-generated constructor stub
	}

	public MyORMException(String arg0, Throwable arg1) {
		super(arg0, arg1);
		// TODO Auto-generated constructor stub
	}

	public MyORMException(String arg0) {
		super(arg0);
		// TODO Auto-generated constructor stub
	}

	public MyORMException(Throwable arg0) {
		super(arg0);
		// TODO Auto-generated constructor stub
	}
	 
}