dbencodingutil.java

sla性能采集

package com.asiainfo.ainx.slaconf.util;

import java.beans.PropertyDescriptor;
import java.io.UnsupportedEncodingException;
import java.lang.reflect.InvocationTargetException;
import java.util.ArrayList;
import java.util.List;

import org.apache.commons.beanutils.BeanUtils;
import org.apache.commons.beanutils.PropertyUtils;


/**
 * 此类用于处理db字符串转换的工作，如果配置文件中的数据库编码设为"ISO8859-1"，<br>
 * 则我们认为这个类的编码为单字节编码，在从数据库中读取和写入时需要进行数据库转码。
 * 
 * @author zhujian
 * 
 */
public class DBEncodingUtil {
	private static boolean needConvert = false;

	private static final String ZH_ENCODING = "GB2312";

	private static final String EN_ENCODING = "ISO8859-1";
	static {
		// 如果配置文件中配置的数据库编码为ISO8859-1，则认为其为单字节编码，需要在写入和读出时进行转换
//		if (ReportConfigUtil.getProperty(ReportConsts.RP_DBCONN_ENCODING)
//				.equalsIgnoreCase(EN_ENCODING)) {
			needConvert = true;
		//}
	}
	
	/**
	 * 对需要插入数据库的对象进行转码<br>
	 * 此方法支持如下格式的转码：<br>
	 * 1、list接口的<B>String</B>数组<br>
	 * 2、pojo中的String类型的成员变量<br>
	 * 3、String[]<br>
	 * 
	 * @param o
	 */
	public static Object toDBobj(Object o) {
		if (needConvert) {
			if(o instanceof String){
				return toDBString((String)o);
			}
			else if (o.getClass().isArray()) {
				// 如果是字符串数组
				return toDbStringArray((Object[]) o);
			} else if (o instanceof List) {
				// 如果是字符串的List
				return toDbStringList((List) o);
			} else {
				// 如果是普通的VO
				return toDBStringObject(o);
			}
		}
		return o;
	}

	/**
	 * 对从数据库中读出的字段进行转码<br>
	 * 此方法支持如下格式的转码：<br>
	 * 1、list接口的String数组<br>
	 * 2、pojo中的String类型的成员变量，不包括list或数组接口的成员变量<br>
	 * 3、String[]<br> 
	 * 4、String类型
	 * @param o
	 * @return 进行转码后的Object。
	 */
	public static Object fromDBobj(Object o) {
		if (needConvert) {
			if(o instanceof String){
				return fromDBString((String)o);
			}
			else if (o.getClass().isArray()) {
				// 如果是字符串数组
				return fromDbStringArray((Object[]) o);
			} else if (o instanceof List) {
				// 如果是字符串的List
				return fromDbStringList((List) o);
			} else {
				// 如果是普通的VO
				return fromDBStringObject(o);
			}
		}
		return o;
	}

	/**
	 * 对需要插入数据库的数据进行转码
	 * @param src 
	 * @return 完成转换的数据
	 */
	public static String toDBString(String src) {
		if (needConvert) {
			if (src == null || src.length() == 0)
				return src;
			String res = null;
			try {
				res = new String(src.getBytes(ZH_ENCODING), EN_ENCODING);
			} catch (UnsupportedEncodingException e) {
				e.printStackTrace();
			}
			return res;
		}
		return src;
	}

	/**
	 * 转换从数据库中读出的数据
	 * @param src
	 * @return 转换后的数据
	 */
	public static String fromDBString(String src) {
		if (needConvert) {
			if (src == null || src.length() == 0)
				return src;
			String res = null;
			try {
				res = new String(src.getBytes(EN_ENCODING), ZH_ENCODING);
			} catch (UnsupportedEncodingException e) {
				e.printStackTrace();
			}
			return res;
		}
		return src;
	}
	
	private static Object[] toDbStringArray(Object[] ss) {
		if (ss.length > 0 && ss[0] instanceof String) {
			for (int i = 0; i < ss.length; i++) {
				ss[i] = toDBString((String) ss[i]);
			}
		}
		return ss;
	}
	
	private static List toDbStringList(List ss) {
		if (ss != null && ss.size() > 0 && ss.get(0) instanceof String) {
			for (int i = 0; i < ss.size(); i++) {
				ss.set(i, toDBString((String) ss.get(i)));
			}
		}
		return ss;
	}
	
	private static Object toDBStringObject(Object o) {
		PropertyDescriptor[] beanDesc = PropertyUtils.getPropertyDescriptors(o);
		for (int i = 0; i < beanDesc.length; i++) {
			if (beanDesc[i].getPropertyType() == String.class) {
				try {
					PropertyUtils.setProperty(o, beanDesc[i].getName(),
							toDBString((String)PropertyUtils.getProperty(o, beanDesc[i].getName()) ));
				} catch (IllegalAccessException e) {
					e.printStackTrace();
				} catch (InvocationTargetException e) {
					e.printStackTrace();
				} catch (NoSuchMethodException e) {
					e.printStackTrace();
				}
			}
		}
		return o;
	}

	private static Object[] fromDbStringArray(Object[] ss) {
		if (ss.length > 0 && ss[0] instanceof String) {
			for (int i = 0; i < ss.length; i++) {
				ss[i] = fromDBString((String) ss[i]);
			}
		}
		return ss;
	}

	private static List fromDbStringList(List ss) {
		if (ss != null && ss.size() > 0 && ss.get(0) instanceof String) {
			for (int i = 0; i < ss.size(); i++) {
				ss.set(i, fromDBString((String) ss.get(i)));
			}
		}
		return ss;
	}

	private static Object fromDBStringObject(Object o) {
		PropertyDescriptor[] beanDesc = PropertyUtils.getPropertyDescriptors(o);
		for (int i = 0; i < beanDesc.length; i++) {
			if (beanDesc[i].getPropertyType() == String.class) {
				try {
					PropertyUtils.setProperty(o, beanDesc[i].getName(),
							fromDBString((String)PropertyUtils.getProperty(o, beanDesc[i].getName()) ));
				} catch (IllegalAccessException e) {
					e.printStackTrace();
				} catch (InvocationTargetException e) {
					e.printStackTrace();
				} catch (NoSuchMethodException e) {
					e.printStackTrace();
				}
			}
		}
		return o;
	}
	

	
	
}