需求:有用户表,用户表中有userId,userName,password.sex,score
要求:封装注解,实现查询方法
思路,要实现面向对象的思想下的数据库操作。首先我们应该有一个父类,封装对数据库表的操作。
父类: 所有与数据库表格一 一对应的子类都要集成这个类。来集成到操作数据库的方法。
package Dao;
public class LHObject {
public static String filter(Object obj) throws Exception{//根据传入的obj,封装查询语句
return string();
}
public static String delete(Object obj) throws Exception{//根据传入的obj,封装删除语句
return string();
}
public static String update(Object obj) throws Exception{//根据传入的obj,封装修改语句
return string();
}
public static String insert(Object obj) throws Exception{//根据传入的obj,封装插入语句
return string();
}
}
子类:每个子类实现与一个表的连接和类涨属性与表中某一列的对应
package Dao;
@Table("t_user")//用@Table注解表明与那张表对应
public class User extends LHObject {
@Colment("user_id")//用@Colment注解来表明属性与表中的那一列对应
private int userId;
@Colment("user_naem")
private String userName;
@Colment("passwrod")
private String password;
@Colment("sex")
private String sex;
@Colment("score")
private float score;
//省略setter getter方法
public static void main(String[] args) throws Exception {
User user = new User();
user.setUserName("张珊珊");
user.setScore(88.5f);
user.setUserId(1);
System.out.println(User.filter(user)) ;
}
}
@Table:
package Dao;
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.TYPE}) //作用于类和接口
@Retention(RetentionPolicy.RUNTIME)//runtime时生效
@Inherited//可以被继承
@Documented//可以生成java doc
public @interface Table {
String value();
}
@Colment:
package Dao;
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 Colment {
String value();
}
以上完成了基本类的准备工作,以实现父类中filter方法为例:
public class LHObject {
public static String filter(Object obj) throws Exception{
StringBuffer sb = new StringBuffer();
//反射找到类
Class c = obj.getClass();
//找打对应的注解,如果有的话
Annotation[] anns = c.getAnnotations();
for (Annotation annotation : anns) {
if(annotation instanceof Table){
sb.append("select * from ").append(((Table) annotation).value());
sb.append(" where 1=1");//防止没有查询条件时 sql报错
}
}
if(sb.toString()==null || sb.toString().equals("")){
return null;
}
//以上完成的是类与表的联系
//下面完成添加查询条件
//获得自定义的属性
Field[] fields2 = c.getDeclaredFields();
for (Field field : fields2) {
//找到对应的表列名
Annotation[] fieldAnns = field.getAnnotations();
for (Annotation annotation : fieldAnns) {
//如果找到了列名
if(annotation instanceof Colment){
//拼接get方法
String getMethodStr = "get"+ field.getName().substring(0, 1).toUpperCase()+field.getName().substring(1);
//调用get方法取值
Method method = c.getMethod(getMethodStr);
Object value = method.invoke(obj);
if(field.getType() == String.class){
if(value!=null && !value.equals("")){
sb.append(" and ").append(((Colment) annotation).value()).append("=").append("'").append(value).append("'");
}
}else if(field.getType() == int.class){
if((int)value!=0 ){
sb.append(" and ").append(((Colment) annotation).value()).append("=").append(value);
}
}else if(field.getType() == float.class){
if((float)value!=0.0 ){
sb.append(" and ").append(((Colment) annotation).value()).append("=").append(value);
}
}
}
}
}
return sb.toString();
}
}
这样我们就实现了一个select语句的封装。只需要加入jdbc的封装 即可实现返回对象。