用反射模拟Hibernate保存JavaBean
用反射模拟Hibernate保存JavaBean
首先要说一下思想。就是要接收一个JavaBean实例对象，然后根据字段信息、类名信息，自己组组织成sql语句最后保存到数据库中。
组件说明：
需要一个@Table注解，自己声明，以便于用户声明的表名与数据库的表名不致的情况。
此注解应该包含一个属性，以便于指定表名。
需要声明一个@Column注解，自己声明以便于用户声明的字段名与JavaBean的列名不一致的情况。
此注解也应该包含一个属性，以便于指定字段名。如果需要还可以指定数据类型。
上代码：
1：@Table注解
package cn.itcast.anno;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
@Retention(RetentionPolicy.RUNTIME)
@Target(value=ElementType.TYPE)
public @interface Table {
public String value();//声明一个属性
}
2：@Column注解
package cn.itcast.anno;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
@Retention(RetentionPolicy.RUNTIME)
@Target(value=ElementType.FIELD)
public @interface Column {
public String value() default "";//默认值
}
3：工具类代码：接收对象，直接保存：
package cn.itcast.anno;
import java.lang.reflect.Field;
import java.sql.ParameterMetaData;
import java.sql.PreparedStatement;
import java.util.ArrayList;
import java.util.List;
/**
* 这只是保存的示例
* 应该同时提供删除，修改
* 查询的可以直接使用DbUtils
* @author <a href="mailto:wj@itcast.cn">王健</a>
*/
public class SaveUtils {
public static void save(Object o) throws Exception{
String sql = "insert into";//声明insert的头
String values = " values (";//声明values的头
Class c = o.getClass();
boolean boo = c.isAnnotationPresent(Table.class);
if(boo){ //分析是否带有Table注解，此外分析的还少一句不存在时的处理
Table t = (Table) c.getAnnotation(Table.class);
String vv = t.value();
System.err.println(vv);
sql+=" "+vv;
}
sql+="(";
Field[] f = c.getDeclaredFields();//获取所有字段，来判断是否存在@Column注解
List<Object> oo = new ArrayList<Object>();//声明参数对象
for(Field ff:f){
if(ff.isAnnotationPresent(Column.class)){
Column col = ff.getAnnotation(Column.class);
String vv = col.value();
if(vv.equals("")){
if(sql.endsWith("(")){
sql+=ff.getName();
values+="?";
}else{
sql+=","+ff.getName();
values+=",?";
}
}else{
if(sql.endsWith("(")){
sql+=vv;
values+="?";
}else{
sql+=","+vv;
values+=",?";
}
}
ff.setAccessible(true);
oo.add(ff.get(o));
}
}
sql+=")";
values+=")";
System.err.println(sql+" "+values);//组成有效的sql语句
System.err.println("处理数据....");
PreparedStatement pst = //在正式的应用场合下，所有的Connection应该由用户传递过来，以保证事务
Conn.getConn().prepareStatement(sql+values);
ParameterMetaData param = pst.getParameterMetaData();
int count = param.getParameterCount();//判断有多少参数
System.err.println("count:"+count);
for(int i=0;i<count;i++){
pst.setObject(i+1,oo.get(i));//设置参数
}
pst.execute();//执行代码
Conn.getConn().close();
}
}
<!--[if !supportLists]-->1、 <!--[endif]-->测试代码：
@Test
public void testSave() throws Exception{
Stud stud = new Stud();
stud.setName("Marray");
stud.setAge(89);
stud.setAddr("中国上海");
SaveUtils.save(stud);
}
<!--[if !supportLists]-->2、 <!--[endif]-->测试结果：
student
insert into student(name,ages,addr) values (?,?,?)
处理数据....
count:3
保存成功