01MySqlUtils

package edu.must.uh.util;

import java.beans.BeanInfo;
import java.beans.Introspector;
import java.beans.PropertyDescriptor;
import java.lang.reflect.Method;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.Date;
import java.util.List;
import java.util.Map;
import org.apache.commons.dbutils.DbUtils;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import org.apache.commons.dbutils.handlers.MapListHandler;
import org.apache.log4j.Logger;

public class MySqlUtils {
    
    private static Logger logger = Logger.getLogger(MySqlUtils.class);
    
    public static <T> int save(String table,T bean) throws Exception {     
          
            String sql= getSaveSQL(table,bean);            
            System.out.println(sql);
            logger.info(sql);
            QueryRunner qr = new QueryRunner();  
            //调用QueryRunner方法update
            Connection conn = MysqlManager.getConnection();
            int row = qr.update(conn, sql);
            System.out.printf("已经有[%d]发生了改变",row);
            DbUtils.closeQuietly(conn);
            return row;
    }
    
    
    public static int disOrEnAble(String table,String enabledMark,String keyFields,String keyValue)throws SQLException{
        String sql=  "UPDATE "+ table+ "SET EnabledMark = "+enabledMark+" WHERE "+ keyFields + "= '"+keyValue+"'";
        System.out.println(sql);      
        logger.info(sql);
        QueryRunner qr = new QueryRunner();        
        Connection conn = MysqlManager.getConnection();
        int row = qr.update(conn, sql);
        System.out.printf("已经有[%d]发生了改变",row);     
        DbUtils.closeQuietly(conn);
        return row;
    }    

    
    
    public static int delete(String table,String keyFields,String keyValue)throws SQLException{
        String sql=  "UPDATE "+ table+ "SET DeleteMark = 1 WHERE "+ keyFields + "= '"+keyValue+"'";
        System.out.println(sql);      
        logger.info(sql);
        QueryRunner qr = new QueryRunner();        
        Connection conn = MysqlManager.getConnection();
        int row = qr.update(conn, sql);
        System.out.printf("已经有[%d]发生了改变",row);     
        DbUtils.closeQuietly(conn);
        return row;
    }
    
    public static int deleteTrue(String table,String keyFields,String keyValue)throws SQLException{
        String sql=  "DELETE FROM "+ table+ " WHERE "+ keyFields + "= '"+keyValue+"'";
        System.out.println(sql);      
        logger.info(sql);
        QueryRunner qr = new QueryRunner();        
        Connection conn = MysqlManager.getConnection();
        int row = qr.update(conn, sql);
        System.out.printf("已经有[%d]发生了改变",row);     
        DbUtils.closeQuietly(conn);
        return row;
    }
    
    private static String getUpdateSQL(String table,Object obj) throws Exception {
        StringBuilder  sqlString = new StringBuilder();
        BeanInfo beanInfo = Introspector.getBeanInfo(obj.getClass());
        PropertyDescriptor[] propertyDescriptors = beanInfo.getPropertyDescriptors();
        for (PropertyDescriptor property : propertyDescriptors) {
            String fieldName = property.getName();
            String key = fieldName.substring(0, 1).toUpperCase() + fieldName.substring(1);            
            Method getter = property.getReadMethod();
            Object valueObject = getter.invoke(obj); 
            if(key.toUpperCase().equals("CLASS")) {
                continue;
            }
            if(valueObject !=null) {               
                if(property.getPropertyType() == java.util.Date.class) {
                    valueObject = ToolsOfDate.toYYYYMMDDHHMISS((Date)valueObject);
                }
                sqlString.append( key+" = '"+ valueObject +"',");               
            }
        }
        return sqlString.deleteCharAt(sqlString.length()-1).toString() ;
    }
    /*
     *  定义方法,使用QueryRunner类的方法update将数据表的数据修改
     */
    public static <T> int update(String table,T bean,String keyFields,String keyValue)throws Exception{
        
        String updateFieldString = getUpdateSQL(table,bean);
        String sql=  "UPDATE "+ table+ " SET "+updateFieldString+" WHERE "+ keyFields + "= '"+keyValue+"'";
        System.out.println(sql);
        logger.info(sql);
        //创建QueryRunner类对象
        QueryRunner qr = new QueryRunner(); 
        //调用QueryRunner方法update
        Connection conn = MysqlManager.getConnection();
        int row = qr.update(conn, sql);
        System.out.printf("已经有[%d]发生了改变",row);
        DbUtils.closeQuietly(conn);        
        return row;
    }
    
    public static  Integer update(String sql) throws Exception {
        QueryRunner qr = new QueryRunner(); 
        //调用QueryRunner方法update
        Connection conn = MysqlManager.getConnection();
        int row = qr.update(conn, sql);
        System.out.printf("已经有[%d]发生了改变",row);
        DbUtils.closeQuietly(conn);        
        return row;
       
    }
    
    
    //INSERT INTO table_name (列1, 列2,...) VALUES (值1, 值2,....)
    private  static String getSaveSQL(String table,Object obj) throws Exception {
        StringBuilder  sqlString = new StringBuilder();
        StringBuilder  keyString = new StringBuilder();
        keyString.append(" ( ");
        StringBuilder  valString = new StringBuilder();
        valString.append(" ( ");
        sqlString.append("INSERT INTO " + table);
        BeanInfo beanInfo = Introspector.getBeanInfo(obj.getClass());
        PropertyDescriptor[] propertyDescriptors = beanInfo.getPropertyDescriptors();
        for (PropertyDescriptor property : propertyDescriptors) {
            String fieldName = property.getName();
            String key = fieldName.substring(0, 1).toUpperCase() + fieldName.substring(1);            
            Method getter = property.getReadMethod();
            Object valueObject = getter.invoke(obj); 
            if(key.toUpperCase().equals("CLASS")) {
                continue;
            }
            if(valueObject !=null) {
                keyString.append( key+",");
                if(property.getPropertyType() == java.util.Date.class) {
                    valueObject = ToolsOfDate.toYYYYMMDDHHMISS((Date)valueObject);
                }
                valString.append("'"+ valueObject +"',");
            }
        }
        return sqlString.toString() + keyString.deleteCharAt(keyString.length()-1).append(")").toString()+"VALUES"+ valString.deleteCharAt(valString.length()-1).append(")").toString();
    }
    
    
    /*
     *  结果集第八种处理方法,MapListHandler
     *  将结果集每一行存储到Map集合,键:列名,值:数据
     *  Map集合过多,存储到List集合
     */
    public static List<Map<String,Object>> getlist(String sql)throws SQLException{
        QueryRunner qr = new QueryRunner();   
        System.out.printf(sql);
        logger.info(sql);
        //调用方法query,传递结果集实现类MapListHandler
        //返回值List集合, 存储的是Map集合 
        Connection conn = MysqlManager.getConnection();
        List<Map<String,Object>> list = qr.query(conn, sql, new MapListHandler()); 
        DbUtils.closeQuietly(conn);
        return list;       
        
    }
    
    public static <T> List<T>  getlist(String sql, Class<T> oclass) throws Exception {       
      
        QueryRunner qr = new QueryRunner(); 
        logger.info(sql);
        T beanT = oclass.newInstance();
        Connection conn = MysqlManager.getConnection();
        List<T> list = qr.query(sql, new BeanListHandler<T>((Class<? extends T>) beanT.getClass()));
        DbUtils.closeQuietly(conn);
        return list;
    }
   

}