首頁  >  文章  >  Java  >  Java如何實作BaseDao實例講解

Java如何實作BaseDao實例講解

巴扎黑
巴扎黑原創
2017-09-08 09:37:312792瀏覽

下面小編就為大家帶來一篇Java利用自訂註解、反射實作簡單BaseDao實例。小編覺得蠻不錯的,現在就分享給大家,也給大家做個參考。一起跟隨小編過來看看吧

在常見的ORM框架中,大都提供了使用註解方式來實現entity與資料庫的映射,這裡簡單地使用自訂註解與反射來產生可執行的sql語句。

這是整體的目錄結構,本來是為複習註解建立的項目^.^

好的,首先我們來確定思路。

1. 自訂@Table @Column註解,

#我們稍微模仿hibernate,讓@Table作用於類別上,來表示實體類別與資料表的映射關係,且讓@Table中的屬性value映射為資料表的名稱tableName;讓@Column作用於屬性上(這裡沒實作作用於set方法上),表示屬性與資料表欄位的映射關係,且讓@Column中的屬性value映射為資料表的某個欄位columnName。

2. 我們需要模仿一個Dao層,

這時候我們先定義一個實體User,有name和password屬性,然後定義一個UserDao,UserDao中存在一個save(User user)的方法,當我們實例化一個UserDao和User,我們調用UserDao的save方法,傳入我們的User對象,返回一段sql,這段sql我們將它簡單設定為“insert into user (name,password) VALUES('cai','123456')”,其中user為我們的資料表名稱,name,password為資料表字段,'cai','123456'為User對象的屬性。

--------------------------------0.0程式碼分割線-------- --------------------------------------

//Column .java


package com.shu.annotation;
import java.lang.annotation.Documented;
import java.lang.annotation.ElementType;
import java.lang.annotation.Inherited;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;

@Target({ElementType.FIELD})
@Retention(RetentionPolicy.RUNTIME)
@Inherited
@Documented
public @interface Column {
 String value();
}

//Table.java


##

package com.shu.annotation;
import java.lang.annotation.Documented;
import java.lang.annotation.ElementType;
import java.lang.annotation.Inherited;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;

@Target({ElementType.METHOD,ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Inherited
@Documented
public @interface Table {
 String value();
 
}

//User.java


package com.shu.entity;
import com.shu.annotation.Column;
import com.shu.annotation.Table;

@Table("t_user")
public class User {
 
 @Column("name")
 private String name;
 @Column("password")
 private String password;
 
 public String getName() {
  return name;
 }
 public String getPassword() {
  return password;
 }
 public void setName(String name) {
  this.name = name;
 }
 public void setPassword(String password) {
  this.password = password;
 }
 
}

//IBaseDao.java

##

package com.shu.dao;
import java.lang.reflect.Field;

import com.shu.annotation.Column;
import com.shu.annotation.Table;

public interface IBaseDao<T> {
 
 //最终目标:insert into user (NAME,password) VALUES(&#39;cai&#39;,&#39;123456&#39;);
 default String save(T entity) throws IllegalArgumentException, IllegalAccessException{
  //sql用于存放最终返回的sql语句
  StringBuilder sql = new StringBuilder("insert into ");
  //tableName用于存放sql语句中表名部分
  StringBuilder tableName;
  //columnName用于存放sql语句的字段部分
  StringBuilder columnName = new StringBuilder("(");
  //values用于存放sql语句中的赋值部分
  StringBuilder values = new StringBuilder("(");
  //获取对象user的class对象
  Class clazz = entity.getClass();
  //判断该User类是否有@Table注解
  boolean isTable = clazz.isAnnotationPresent(Table.class);
  if(isTable) {
   //获取User类@Table注解的值value,该值我们定义为User表的表名称
   Table t = (Table) clazz.getAnnotation(Table.class);
   tableName = new StringBuilder(t.value());
   //拼接表名
   sql.append(tableName+" ");
   //获取user对象的属性列表
   Field[] fieldList = clazz.getDeclaredFields();
   //遍历属性列表,分别拿出属性列表中被@Column注解的属性,并获取属性的值
   for(int i=0;i<fieldList.length;i++){
    Field f = fieldList[i];
    boolean isColumn = f.isAnnotationPresent(Column.class);
    if(!isColumn){
     continue;
    }
    Column column = f.getAnnotation(Column.class);
     f.setAccessible(true); 
    Object columnValue = f.get(entity);
    if(i==fieldList.length-1){
     columnName.append(column.value()+") VALUES ");
     values.append("&#39;"+columnValue+"&#39;)");
     sql.append(columnName);
     sql.append(values);
     continue;
    }
    columnName.append(column.value()+", ");
    values.append("&#39;"+columnValue+"&#39;,");
   }
   
//   boolean isColumn = clazz.isAnnotationPresent(annotationClass);
  }
  return sql.toString();
 }


}

//UserDao.java

package com.shu.dao;

import com.shu.entity.User;

public class UserDao implements IBaseDao<User> {

}

//UserService.java

##
package com.shu.service;
import com.shu.dao.UserDao;
import com.shu.entity.User;

public class UserService {
 
 public static void main(String[] args) {
  // TODO Auto-generated constructor stub

  UserDao userDao = new UserDao();
  User user = new User();
  user.setName("cai");
  user.setPassword("123456");
  try {
   System.out.println(userDao.save(user));
  } catch (IllegalArgumentException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  } catch (IllegalAccessException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  }
 }
 
}

--------------------------------0.0程式碼分割線-------- --------------------------------------

在這裡我們最後定義了一個Service層,讓它去呼叫dao層然後產生對應的sql語句,你可以自訂其他的Entity,像是我目錄中的Order,然後定義一個OrderDao實作IBaseDao接口,定義一個OrderService呼叫OrderDao的save方法,同樣可以產生order表對應的sql語句。

這裡總結一下不足:

1.hibernate的註解可以不用賦值,所以我認為要實作無需賦值直接取得表格的名稱或欄位的名稱,可以利用反射的方法來取得。

2.這裡只做了save方法,而且只是動態生成了sql語句,並沒有和資料庫交互,可以包裝一個factory,提供持久化方法來實現對sql語句的執行。

3.這裡對sql的拼接比較粗糙,各位可以想想有沒有其他更有效率的方法。

以上是Java如何實作BaseDao實例講解的詳細內容。更多資訊請關注PHP中文網其他相關文章!

陳述:
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn