最近想实现用户自定义数据库中的字段，我想大部分人第一想到的就是EAV(Entity-Attribute-Value)，这种方式对于写一个小的毕业设计应该还可以使用，当然也有很多CMS系统采用这种方式，毕竟其中Value表中的数据会猛增，同样，会涉及到查询优化问题，暂不考虑。
其次，在J2EE中，如果使用spring+hbiernate+springMVC(struts2)，Entity类有两种方式和数据库进行映射，一种是注解方式，一种是*.hbm.xml配置文件方式。
①注解方式，对于注解方式，因为最终目的是根据自定义的字段可以实时的在数据库表中对其字段进行生成，然后可以使用，最初想到的解决方法是重写相应实体类的.class文件，然后根据最新的.class文件生成相应的*.hbm.xml文件，利用configuration重新读取*.hbm.xml文件来建立buildSessionFactory(下面会给出详细代码)，最后发现即使实现了增加字段，也无法通过这种方式删除字段，不过还是看看往.class文件中写入field以及其getter/setter方法的java语句吧。
1 /* * 添加字段
3 */
4 public class AddFieldAdapter extends ClassAdapter {
5
6 private int accessModifier;
7 private String name;
8 private String desc;
9 private boolean isFieldPresent;
10
11 public AddFieldAdapter(ClassVisitor cv, int accessModifier, String name,
12 String desc) {
13 super(cv);
14 this.accessModifier = accessModifier;
15 this.name = name;
16 this.desc = desc;
17 }
18
19 public FieldVisitor visitField(int access, String name, String desc,
20 String signature, Object value) {
21 if (name.equals(this.name)) {
22 isFieldPresent = true;
23 }
24 return cv.visitField(access, name, desc, signature, value);
25 }
26
27 public void visitEnd() {
28 if (!isFieldPresent) {
29 FieldVisitor fv = cv.visitField(accessModifier, name, desc, null,
30 null);
31
32 if (null != fv) {
33 fv.visitEnd();
34 }
35 }
36 cv.visitEnd();
37 }
39 }
1 // 创建get,public,无参数，有返回值
2 MethodVisitor mv = cWriter.visitMethod(Opcodes.ACC_PUBLIC, "get"
3 + StringUtils.capitalize(filedName), "()" + type, null,//type为返回的类型
4 null);
5 mv.visitCode();
6 mv.visitVarInsn(Opcodes.ALOAD, 0);//将this压栈
7 mv.visitFieldInsn(Opcodes.GETFIELD,
8 this.entityClass.getSimpleName(), filedName, type);
9 mv.visitInsn(Opcodes.ARETURN);
10 mv.visitMaxs(1, 1);
11 mv.visitEnd();
12
13 // 创建set方法，public，传递一个参数
14 mv = cWriter.visitMethod(Opcodes.ACC_PUBLIC,//方法名为public
15 "set" + StringUtils.capitalize(filedName), "(" + type //传递一个参数
16 + ")V", null, null);//V表示返回的是void
17 mv.visitCode();//开始执行
18 mv.visitVarInsn(Opcodes.ALOAD, 0);//将this压栈
19 mv.visitVarInsn(Opcodes.ALOAD, 1);//将局部变量压栈
20 mv.visitFieldInsn(Opcodes.PUTFIELD,
21 this.entityClass.getSimpleName(), filedName, type);
22 mv.visitInsn(Opcodes.ARETURN);
23 mv.visitMaxs(2, 2);
24 mv.visitEnd();//执行结束
关于如何将.class文件生成*.hbm.xml可以从网上找相关模板，借助模板将class文件转换生成xml配置文件方式，因为重点不采用这种方式，所以简单介绍下如何重写class文件即可，关于如何从*.hbm.xml文件重构sessionfactory映射到数据库中在稍后贴出代码。
②配置文件方式，配置文件的方式对于项目中使用本身就不是特别方便的（相对于注解来说），所有这种方式也是一开始只是为了尝试在重写了*.hbm.xml后是否可以通过代码的方式，在不重启服务器的情况下，将修改的内容实时的反映到我们的数据库中，所以在一开始的时候定义model或者entity时候，就应该写个与之对应的*.hbm.xml，例如下面这样。
/**
*实体类
*/
public class Contact extends CustomizableEntity { /**
* ID
*/
private int id; /**
* 名称
*/
private String name; public int getId() {
return id;
} public String getName() {
return name;
} public void setId(int id) {
this.id = id;
} public void setName(String name) {
this.name = name;
}
}
<?xml version="1.0" encoding="UTF-8" standalone="no"?><!DOCTYPE hibernate-mapping PUBLIC "-//Hibernate/Hibernate Configuration DTD//EN" "http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd">
<hibernate-mapping auto-import="true" default-access="property"
default-cascade="none" default-lazy="true"> <class abstract="false" dynamic-insert="false" dynamic-update="false"
mutable="true" name="com.hfmx.model.Contact" optimistic-lock="version"
polymorphism="implicit" select-before-update="false" table="tb_contact">
<id column="fld_id" name="id">
<generator class="native" />
</id> <property column="fld_name" generated="never" lazy="false"
name="name" optimistic-lock="true" type="string" unique="false" />
<dynamic-component insert="true" name="customProperties"
optimistic-lock="true" unique="false" update="true">
</dynamic-component>
</class>
</hibernate-mapping>
上面的实体类中继承了一个父类，以及XML文件中的标签dynamic-component都是为了可以自定义字段做准备的，我们暂且忽略这部分内容，主要看看如何重构sessionFactory，其实这个实现的方式也是从网上找到的，当然为了能够与hibernate4.0结合，部分地方作了修改，下面把代码贴出来，重点地方会做点注释。
public class HibernateUtil {
private static HibernateUtil instance;
private Configuration configuration;
private SessionFactory sessionFactory;
private Session session;
public synchronized static HibernateUtil getInstance() {
if (null == instance) {
instance = new HibernateUtil();
}
return instance;
}
private synchronized SessionFactory getSessionFactory() {
if (null == sessionFactory) {
Configuration _configuration = this.getConfiguration();
ServiceRegistry serviceRegistry = new ServiceRegistryBuilder()
.applySettings(_configuration.getProperties())
.buildServiceRegistry();
sessionFactory = _configuration
.buildSessionFactory(serviceRegistry);
}
return sessionFactory;
}
public synchronized Session getCurrentSession() {
if (null == session) {
session = getSessionFactory().openSession();
session.setFlushMode(FlushMode.COMMIT);
}
return session;
}
private synchronized Configuration getConfiguration() {
if (null == configuration) {
try {
// 默认加载hibernate.cfg.xml
configuration = new Configuration().configure();
Class entityClass = Contact.class;
String filePath = entityClass.getResource(
entityClass.getSimpleName() + ".hbm.xml").getPath();
// 替换空格
filePath = filePath.replace("%20", " ");
File file = new File(filePath);
// 通过class加载会发现在j2ee中不行
// configuration.addClass(entityClass);
//通过加载classes文件夹下面的文件，获取实时修改后的XML文件
configuration.addFile(file);
} catch (HibernateException e) {
e.printStackTrace();
}
}
return configuration;
}
/**
* 重置
*/
public void reset() {
Session session = getCurrentSession();
if (null != session) {
session.flush();
if (session.isOpen()) {
session.close();
}
}
SessionFactory sf = getSessionFactory();
if (null != sf) {
sf.close();
}
this.configuration = null;
this.sessionFactory = null;
this.session = null;
}
public PersistentClass getClassMapping(Class entityClass) {
return getConfiguration().getClassMapping(entityClass.getName());
}
}
这种方式即可在修改完XML后立即加载修改后的XML，对其进行映射到数据库中，然后生成新添加的字段，这种方式存在的弊端也在文章一开始做了介绍，无法删除字段，同时，配置文件在实际项目中越来越多的被Annotation所替代掉。所以，需要有一种新的方式来实现自定义字段，下面将重点介绍这种方式，同时，下面的内容也是对此配置方式的一个补充。如果看到这里觉得配置文件方式介绍的不够详细，可以在下面找出其中很多知识点。
现在，着重讲解通过纯的sql来实现数据库的自定义字段功能….
首先，我们来看下环境，我用的是springMVC+spring3+hibernate4.0
同时，对应新增的字段，要通过key-value的方式进行保存，即放在Map集合中，这样方便后期的读写
/**
* 支持自定义字段的业务实体类基类
*
* @author wy
*
*/
public abstract class CustomizableEntity { private Map<String, Object> customProperties; public Map<String, Object> getCustomProperties() {
if (null == customProperties)
customProperties = new HashMap<String, Object>();
return customProperties;
} public void setCustomProperties(Map<String, Object> customProperties) {
this.customProperties = customProperties;
} public Object getValueOfCustomField(String name) {
return getCustomProperties().get(name);
} public void setValueOfCustomField(String name, Object value) {
getCustomProperties().put(name, value);
}
}
/**
* 实体类MyUser继承CustomizableEntity，这个类里面已存在字段可视为固定字段
*/
@Entity
public class MyUser extends CustomizableEntity { /**
* ID
*/
private int id; /**
* 姓名
*/
private String userName; @Id
@GeneratedValue
public int getId() {
return id;
} public String getUserName() {
return userName;
} public void setId(int id) {
this.setValueOfCustomField("id", id);
this.id = id;
} public void setUserName(String userName) {
this.setValueOfCustomField("username", userName);
this.userName = userName;
}
}
完成上面两个类，在启动项目后，数据库中会添加一个myuser表，同时拥有两个字段(ID,userName)。
此时，我们来尝试看，看可否往myuser表中添加一个字段，通过下面简单的方式。
/**
* 添加字段列（UserDefineField是一个简单的实体类，包括自定义字段的name，*type以及中文名称，描述等等）
*/
public void addFieldColumn(Class clazz, UserDefineField userDefine) {
try {
Session session = this.sessionFactory.getCurrentSession(); String sql = "";
//验证字段是否已经存在
sql = "select count(*) as c from userdefinefield where tableName='"
+ clazz.getCanonicalName()
+ "' and fieldName='"
+ userDefine.getFieldName() + "'";
Query countQuery = session.createSQLQuery(sql);
List<Object> list = countQuery.list();
long count = 0;
if (list.size() > 0) {
Object object = list.get(0);
if (null != object) {
count = Long.parseLong(object.toString());
}
}
System.out.println("count:" + count); if (count <= 0) {
// 字段不存在是添加字段
sql = "alter table " + clazz.getSimpleName() + " add column "
+ userDefine.getFieldName() + " "
+ userDefine.getFieldType();
Query query = session.createSQLQuery(sql);
query.executeUpdate(); // 修改自定义字段表
sql = "insert into userdefinefield (tableName,fieldName,fieldType,fieldCN,fieldDesc) values('"
+ clazz.getCanonicalName()
+ "','"
+ userDefine.getFieldName()
+ "','"
+ userDefine.getFieldType()
+ "','"
+ userDefine.getFieldCN()
+ "','"
+ userDefine.getFieldDesc() + "')";
query = session.createSQLQuery(sql);
query.executeUpdate();
}
} catch (Exception e) {
System.out.println("纯数据库方式动态添加字段名称失败");
e.printStackTrace();
}
}
执行完后我们会发现数据库表中确实已经增加了一个新的字段，那对于删除字段，当然也就类似了，简单的看下代码
/**
* 删除字段列
*
* @param clazz
* @param fieldName
*/
public void delFieldColumn(Class clazz, String fieldName) {
Session session = this.sessionFactory.getCurrentSession();
try {
// 删除字段
String sql = "alter table " + clazz.getSimpleName()
+ " drop column " + fieldName + "";
Query query = session.createSQLQuery(sql);
query.executeUpdate(); sql = "delete from userdefinefield where tableName='"
+ clazz.getCanonicalName() + "' and fieldName='"
+ fieldName + "'";
query = session.createSQLQuery(sql);
query.executeUpdate(); } catch (Exception e) {
System.out.println("纯数据库方式动态删除字段名称失败");
e.printStackTrace();
}
}
看到这里，很多人会不会想，这样实现只要会sql的人都可以，主要是如何对数据进行CRUD的操作，是的，光看上面的代码肯定觉得so easy，接下来看看如果查询、保存、修改、删除吧
① 查询
1 /**
* 根据ID进行用户查询
*
* @param clazz
* @param id
* @return
*/
public MyUser searchMyUser(Class clazz, int id) {
MyUser myUser = new MyUser();
try {
Session session = this.sessionFactory.getCurrentSession();
String sql = "SELECT * FROM (select * from myuser where id="
+ id
+ " ) m join (select * from userdefinefield where tableName='"
+ clazz.getCanonicalName() + "') AS define"; Query query = session.createSQLQuery(sql).setResultTransformer(
Transformers.ALIAS_TO_ENTITY_MAP);
List<Map<String, Object>> list = (List<Map<String, Object>>) query
.list(); if (list.size() > 0) {
Map<String, Object> map = list.get(0); // 固有属性
myUser.setId(Integer.parseInt(map.get("id").toString()));
myUser.setUserName(map.get("userName").toString());
} for (Map<String, Object> map : list) { // 自定义列名
String fieldName = map.get("fieldName").toString(); myUser.setValueOfCustomField(fieldName, (null == map
.get(fieldName)) ? "" : map.get(fieldName).toString()); UserDefine define = new UserDefine(map);
myUser.setValueOfExctalyCustomProp(fieldName, define);
} return myUser;
} catch (Exception e) {
System.out.println("根据ID进行查询出现错误");
e.printStackTrace();
return null;
}
}
查询后，在control中打印出来看看效果
1 // ****查询信息
MyUser myUser = this.myservice.searchMyUser(MyUser.class, id); System.out.println("******查询结果******");
System.out.println("id:" + myUser.getId());
System.out.println("name:" + myUser.getUserName());
//自定义字段key-value显示
for (String key : myUser.getCustomPropties.keySet()) {
System.out.println("" + key + ":"+key+” value:” + myUser.getValueOfCustomField(key));
}
② 保存
/**
* 保存信息
*
* @param myuser
*/
public void saveMyUser(MyUser myuser) {
try {
Session session = this.sessionFactory.getCurrentSession(); String sql = "insert into " + myuser.getClass().getSimpleName()
+ " ";
int index = 0;
for (String key : myuser.getCustomProperties().keySet()) {
if (index == 0) {
sql += "(" + key + "";
} else {
if (index == myuser.getCustomProperties().size() - 1) {
sql += "," + key + ") ";
} else {
sql += "," + key + "";
}
}
index++;
} index = 0;
for (String key : myuser.getCustomProperties().keySet()) {
if (index == 0) {
sql += "values('" + myuser.getCustomProperties().get(key)
+ "'";
} else {
if (index == myuser.getCustomProperties().size() - 1) {
sql += ",'" + myuser.getCustomProperties().get(key)
+ "')";
} else {
sql += ",'" + myuser.getCustomProperties().get(key)
+ "'";
}
}
index++;
} System.out.println("保存用户信息的sql：" + sql);
Query query = session.createSQLQuery(sql);
query.executeUpdate(); } catch (Exception e) {
System.out.println("保存用户信息出错:" + e.getMessage());
e.printStackTrace();
}
}
③ 修改
/**
* 修改信息
*
* @param myUser
*/
public void updateMyUser(MyUser myUser) {
try {
Session session = this.sessionFactory.getCurrentSession(); String sql = "update myuser set userName='" + myUser.getUserName()
+ "'";
if (myUser.getCustomProperties().size() > 0) {
for (String key : myUser.getCustomProperties().keySet()) {
sql += "," + key + "='"
+ myUser.getCustomProperties().get(key) + "'";
}
}
sql += " where id=" + myUser.getId(); System.out.println("修改用户信息的sql：" + sql); Query query = session.createSQLQuery(sql);
query.executeUpdate(); } catch (Exception e) {
System.out.println("修改用户信息出错:" + e.getMessage());
e.printStackTrace();
}
}
④ 删除
删除如果是根据ID删除，那就一点影响都没有了，如果是根据动态列内容去删除，那也就是和保存和修改时候处理方式一样，这里就不列出来了。（哈哈，感觉重复的代码有点多了）
综上所述，初步觉得，如果采用这种方式应该可以对项目本身改动的地方不大，同时，表结构基本上能够很好的维护。在多表联合查询的时候，也同样没有太复杂的sql代码。当然，目前没有运用到大的系统中，不知道可否在后面会遇到问题。
如果其他童鞋有其他更好的方法，希望可以一起分享！！！！！！