在常见的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
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
|
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
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
|
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
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
|
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
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
|
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('cai','123456'); 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( "'" +columnvalue+ "')" ); sql.append(columnname); sql.append(values); continue ; } columnname.append(column.value()+ ", " ); values.append( "'" +columnvalue+ "'," ); } // boolean iscolumn = clazz.isannotationpresent(annotationclass); } return sql.tostring(); } } |
//userdao.java
1
2
3
4
5
6
7
|
package com.shu.dao; import com.shu.entity.user; public class userdao implements ibasedao<user> { } |
//userservice.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
|
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实例就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持服务器之家。
原文链接:http://www.cnblogs.com/Little-tree/p/7449538.html