JDF bean模块想法交流

今天做了一个JDF的bean的简单实现，由于不利用配置文件存放信息，所以bean里面存放的内容还是蛮多的，下面就介绍下我的bean的设计。

首先申明了一个原始bean的接口

package com.db.beans;

import java.util.HashMap;
import java.util.List;

public interface BeanInterface {
	//获取表名
	public String getTable();
	//逻辑删除设置
	public void deleteLogic();
	//保存
	public void save();
	//物理删除
	public void deletePhysics();	
	//输出各个变量的值
	public String toString();
	//获取主键的ID
	public  HashMap getPriKeyName();
	//获取主键值
	public  HashMap getPriKeyValue();
	//判断是否是从数据库读出填充的bean
	public boolean isGetBean();
	//设置bean的状态，是否是从数据库中读取
	public void isGetBean(boolean b);
}

然后是一个AbstractBean，集成于这个接口，其实类似于数据容器。

package com.db.beans;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;

import org.apache.commons.lang.StringUtils;


import net.chinacsharp.proxy.ConnectionProxy;

public abstract class AbstractBean implements BeanInterface {
	
	public HashMap cMap = null; //bean 的每个字段，以及对应的值
	public HashMap uMap = null;//修改列，以及值保存
	public HashMap cName = null; //每个字段的ID
	public long flag = -1; //0 逻辑删除，-1 ，物理删除， 1 add 2 update
	
	public void init(HashMap map,HashMap umap,HashMap cName){
		cMap = map;
		this.uMap = umap;
		this.cName = cName;
	}	
	
	public AbstractBean(){
		System.out.println("AbstractBean");
	}
	
	
	public void deleteLogic() {
		// TODO Auto-generated method stub

	}

	public void save() {
		
	}

	public void deletePhysics() {
		// TODO Auto-generated method stub

	}

	
	public String toString(){
		StringBuffer buffer = new StringBuffer();
		for ( Iterator i = cMap.keySet().iterator(); i.hasNext();) {
		    Object key = i.next();
		    Object value = cMap.get(key);
		    buffer.append(key).append("=").append(value).append("\n");
		}
		return buffer.toString();
	}

		
	protected BeanInterface getBean(BeanInterface o,Object id_) throws IllegalArgumentException, IllegalAccessException, InvocationTargetException{
				
		List list = new ArrayList();
		HashMap map = new HashMap();
		java.lang.reflect.Method[] m = o.getClass().getMethods();
		for (int i = 0; i < m.length; i++) {
			map.put(m[i].getName(),m[i]);
			if(cName.get(m[i].getName())!=null){
				list.add(m[i]);
				
			}
		}
		
		Method[] m1 = (Method[])list.toArray(new Method[0]);
		HashMap keyMap = o.getPriKeyName();
		String key = "";
		String type = "";
		for ( Iterator i = keyMap.keySet().iterator(); i.hasNext();) {
		     key = (String) i.next();
		     type = (String) keyMap.get(key);		    
		}		
		
		String sql = "select * from "+ o.getTable()+" where "+key+"=?";
		try {
			Connection con = getMysql();
			PreparedStatement st = con.prepareStatement(sql);
			if(type.equals("long"))
			st.setLong(1,Long.parseLong(id_.toString()));
			else
			st.setString(1,id_.toString());
			
			ResultSet rs = st.executeQuery();
			while (rs.next()) {
					for (int i = 0; i < m1.length; i++) {		
						String name = cName.get(m1[i].getName()).toString();
						type = m1[i].getParameterTypes()[0].getName();
						if(type.equals("java.lang.String")) {
							m1[i].invoke(o,new Object[]{rs.getString(name)});
						} else if(type.equals("long")){
							m1[i].invoke(o,new Object[]{new Long(rs.getLong(name))});
						}
					}
					o.isGetBean(true);	
			}
			rs.close();
			con.close();
			return o;
			
		}  catch (Throwable e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
		return null;
	}
	private  Connection getMysql() throws Exception, Throwable, ClassNotFoundException{
		Class.forName("com.mysql.jdbc.Driver").newInstance();
		Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "root", "admin");		
		conn.setAutoCommit(false);
		return ConnectionProxy.newInstance(conn);
	}
	private boolean isGet = false;
	
	public boolean isGetBean() {
		return isGet;
	}

	public void isGetBean(boolean b) {
		isGet = b;
		
	}

}

然后对应的Bean 是

package com.db.beans;

import java.lang.reflect.InvocationTargetException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;

public class Person extends AbstractBean {

	public final static String TABLE_NAME="PERSON";
	private long personId = -1;
	private long age = -1;
	private String firstName = null;
	private String lastName = null;
	private long state = -1;
	private PersonEmail personEmail = null;
	
	public String C_PERSON_ID = "PERSON_ID";
	public String C_AGE = "AGE";
	public String C_FIRSTNAME = "FIRSTNAME";
	public String C_LASTNAME = "LASTNAME";
	public String C_STATE = "STATE";
	
	private HashMap cName = new HashMap();	
	private HashMap cMap = new HashMap();//存放列和值的对应
	private HashMap uMap = new HashMap();//存放修改列的值	
	private HashMap relateBean = new HashMap();
	public Person(){	
		cName.put("setAge",C_AGE);
		cName.put("setFirstName",C_FIRSTNAME);
		cName.put("setLastName",C_LASTNAME);
		cName.put("setPersonId",C_PERSON_ID);
		cName.put("setState",C_STATE);	
		relateBean.put(PersonEmail.class,"array");
		init(cMap,uMap,cName);
	}
	
	public long getState() {
		return state;
	}

	public void setState(long state) {
		if(this.state!=-1&&this.state!=state){			
			uMap.put(C_STATE,new Long(state));
		}
		cMap.put(C_STATE,new Long(state));
		this.state = state;
	}
	
	public long getAge() {
		return age;
	}
	public void setAge(long age) {
		if(this.age!=-1&&this.age!=age){			
			uMap.put(C_AGE,new Long(age));
		}
		cMap.put(C_AGE,new Long(age));
		this.age = age;
	}
	public String getFirstName() {
		return firstName;
	}
	public void setFirstName(String firstName) {
		if(this.firstName!=null&&!this.firstName.equals(firstName)){			
			uMap.put(C_FIRSTNAME,firstName);
		}
		cMap.put(C_FIRSTNAME,firstName);
		this.firstName = firstName;
	}
	public String getLastName() {
		return lastName;
	}
	public void setLastName(String lastName) {
		
		if(this.lastName!=null&&!this.lastName.equals(lastName)){			
			uMap.put(C_LASTNAME,lastName);
		}
		cMap.put(C_LASTNAME,lastName);
		this.lastName = lastName;
	}
	public long getPersonId() {
		return personId;
	}
	public void setPersonId(long personId) {
		cMap.put(C_PERSON_ID,new Long(personId));
		this.personId = personId;
	}

	public HashMap getPriKeyName() {
		HashMap map = new HashMap();
		map.put("PERSON_ID","NUMBER");
		return map;
	}
	
	public HashMap getPriKeyValue() {
		HashMap map = new HashMap();
		map.put("PERSON_ID",new Long(personId));
		return map;
	}

	public String getTable() {
		return TABLE_NAME;
	}
	
	public static Person getPerson(long personId) throws IllegalArgumentException, IllegalAccessException, InvocationTargetException{
		Person p = new Person();
		return (Person) p.getBean(p,new Long(personId));

	}
	
	public Person getPerson(String cond,HashMap map){
		return null;
	}

	
	
	
	


}

写个Main函数跑跑

public static void main(String[] args) throws IllegalArgumentException, IllegalAccessException, InvocationTargetException {
		
		Person p = Person.getPerson(1);
		System.out.println(p.getFirstName());
		System.out.println(p.toString());
}

输出 ：

AbstractBean
ConnectionId=100000
ConnectionId=100000 Preparing Statement: select * from PERSON where PERSON_ID=?
PreparedStatementId=100001 Executing Statement: select * from PERSON where PERSON_ID=?
PreparedStatementId=100001 Parameters: [1]
PreparedStatementId=100001 Types: [java.lang.Long]
ResultSetId = 100002 ResultSet
ResultSetId =100002 Header: [AGE, FIRSTNAME, LASTNAME, PERSON_ID, STATE]
ResultSetId =100002 Result: [22, sun, lei, 1, 0]
sun
STATE=0
PERSON_ID=1
AGE=22
LASTNAME=lei
FIRSTNAME=sun

以上代码值得看的就是 protected BeanInterface getBean(BeanInterface o,Object id_) 方法

这个方法通过Method.invoke 来把每个字段set到bean里面，类似于dbutils里面原理。

明天继续，欢迎大家讨论。

http://blog.csdn.net/keyboardsun

作者KEYBOARDSUN