用反射模拟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

保存成功