看到Hibernate你給一個物件，他就能動態的建立配置檔案裡面指定的表名，然後把資料錄入到資料庫，當初感覺是很神奇，不過，好像Hibernate不能動態的分表建立表和錄入資料

我這裡寫了一個公用的類，你給一個物件，告訴我按年還是按月生成表，並告訴我那個欄位是不需要在表中建立的，該類就可以動態的分表建立需要的表，並錄入資料

注意：

由於業務需要，這裡對於欄位的支援只有int和Integer，double和Double

還有String，同時對於String統一建立為了Varchar(100)的欄位

表會統一建立一個id自增主鍵

1. package com.xd.nms.util;  
2. import java.lang.reflect.Field;  
3. import java.text.SimpleDateFormat;  
4. import java.util.Date;  
5. import java.util.Map;  
6. import java.util.Set;  
7. import org.apache.commons.logging.Log;  
8. import org.apache.commons.logging.LogFactory;  
9. import org.springframework.jdbc.core.JdbcTemplate;  
10. /** 
11.  * @說明 動態插入資料和建立表
     
12.  * @author 崔素強 
13.  * @version 1.0 
14.  * @since 
15.  */  
16. public class CommonTableInsert {  
17.     public static Log logger = LogFactory.getLog(CommonTableInsert.class);  
18.     /** 
19.      * 入口方法 
20.      * @param tableName 表字首 
21.      * @param dateFormat 格式化方法 
22.      * @param obj 儲存的物件 
23.      * @return 
24.      */  
25.     @SuppressWarnings
    ("unchecked")  
26.     public static int insertObject(String tableName,String dateFormat,Object obj, Map noCol){  
27.         int re = 0;          
28.         try {     
29.             JdbcTemplate jt = (JdbcTemplate) SpringFactory.getObject("jdbcTemplate");  
30.             SimpleDateFormat format = new SimpleDateFormat(dateFormat);               
31.             String tname = tableName + "_" + format.format(new Date());  
32.             if(CommonDBUtil.getAllTableName(jt,tname)){ // 如果有某表  
33.                 re = saveObj(jt,tname,obj, noCol); // 儲存資料     
34.             }else{  
35.                 re = createTable(jt,tname,obj, noCol); // 動態建立表  
36.                 if(re == 1){  
37.                     re = saveObj(jt,tname,obj, noCol); // 儲存資料  
38.                 }  
39.             }                
40.         } catch (Exception e) {     
41.             logger.error("公用方法插入資料入口方法錯誤", e);  
42.         }            
43.         return re;     
44.     }  
45.     /**   
46.      * 儲存方法，注意這裡傳遞的是實際的表的名稱   
47.      */    
48.     @SuppressWarnings("unchecked")  
49.     private static int saveObj(JdbcTemplate jt,String tableName,Object obj, Map noCol){     
50.         int re = 0;  
51.         StringBuffer sb = new StringBuffer("");  
52.         try{                 
53.             sb.append(" insert into " + tableName + " (");     
54.             Map<String,String> map = ObjectUtil.getProAndValMap(obj); // 物件的屬性和屬性值  
55.             Map<String,String> mapType = ObjectUtil.getProTypeMap(obj); // 物件的屬性型別列表  
56.             Set<String> set = map.keySet();     
57.             for(String key : set){  
58.                 // 如果該列不是 非處理列  
59.                 if(noCol.get(key) == null){  
60.                     sb.append(key + ",");  
61.                 }  
62.             }     
63.             sb.append(" tableName ) ");                  
64.             sb.append(" values ( ");     
65.             for(String key : set){  
66.                 if(noCol.get(key) == null){  
67.                     if(mapType.get(key).equals("class java.lang.String")){  
68.                         sb.append("'" + (map.get(key) + "',"));  
69.                     }else{  
70.                         sb.append(map.get(key) + ",");  
71.                     }  
72.                 }  
73.             }     
74.             sb.append("'" + tableName + "'); ");   
75.             re = jt.update(sb.toString());             
76.         } catch (Exception e) {     
77.             logger.error("公用方法錄入資料時錯誤", e);  
78.             logger.error("公用方法錄入資料語句：" + sb.toString());  
79.         }            
80.         return re;     
81.     }  
82.     /**   
83.      * 根據表名稱 和 實體屬性 建立一張表 
84.      * @param tableName   
85.      * @param obj 具體生成什麼樣的表看該物件 
86.      */    
87.     @SuppressWarnings("unchecked")  
88.     private static int createTable(JdbcTemplate jt,String tableName,Object obj, Map noCol){     
89.         StringBuffer sb = new StringBuffer("");     
90.         sb.append("CREATE TABLE `" + tableName + "` (");     
91.         sb.append(" `id` int(11) NOT NULL AUTO_INCREMENT,");  
92.         Class c = obj.getClass();  
93.         Field field[] = c.getDeclaredFields();  
94.         for (Field f : field) {  
95.             if(noCol.get(f.getName()) == null){  
96.                 String type = f.getType().toString();  
97.                 if(type.equals("class java.lang.String")){// Str  
98.                      sb.append("`" + f.getName() + "` varchar(100) DEFAULT NULL,");     
99.                 }else if(type.equals("int") || type.equals("class java.lang.Integer")){// int  
100.                     sb.append("`" + f.getName() + "` int(11) DEFAULT NULL,");     
101.                 }else if(type.equals("double") || type.equals("class java.lang.Double")){// double  
102.                     sb.append("`" + f.getName() + "` double DEFAULT NULL,");     
103.                 }  
104.             }  
105.         }  
106.         sb.append(" `tableName` varchar(255) DEFAULT NULL,");  
107.         sb.append(" PRIMARY KEY (`id`)");     
108.         sb.append(") ENGINE=InnoDB DEFAULT CHARSET=utf8;");     
109.         try {     
110.             jt.update(sb.toString());     
111.             return 1;     
112.         } catch (Exception e) {  
113.             logger.error("公用方法生成表時錯誤", e);  
114.             logger.error("公用方法生成表語句：" + sb.toString());  
115.         }     
116.         return 0;     
117.     }   
118. }  

這個對於之前寫的那個動態建表，新增了過濾不需要在表中建立的欄位

原理就是讀取物件的各個欄位屬性，如果能加以配置檔案或者讀取物件屬性的標記，那其實能做到基本和Hibernate一致，不但能支援多種型別，還能做欄位校驗等