封装JDBC通用工具类jdbc-utils_JAVA_编程开发_程序员俱乐部

1、jdbc.properties? 数据库配置文件

?

class="java">jdbc.driverClassName=oracle.jdbc.driver.OracleDriver
jdbc.url=jdbc:oracle:thin:@localhost:1521:orcl
jdbc.userName=netrep_txv6
jdbc.password=netrep_txv6_epsoft

2、log4j.properties 文件

log4j.rootCategory=INFO,standard
log4j.appender.standard=org.apache.log4j.ConsoleAppender
log4j.appender.standard.layout=org.apache.log4j.PatternLayout
log4j.appender.standard.layout.ConversionPattern=%-5p\: %d{ISO8601}\: %C{1}[line\:%L}\: %m%n

?

?

3、DBConfig.java 读取配置信息? ??

?

package com.insigma.jdbc.util.dbUtil;

import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;

import org.apache.log4j.Logger;

public class DBConfig {
	private static Logger logger=Logger.getLogger(DBConfig.class);
	private String driverClassName;
	private String userName;
	private String password;
	private String url;
	
	
	public DBConfig() {
		  //读取db.properties文件
		     	              
/*		    Properties props = new Properties();
			  代表java命令运行的目录
			  在java项目下，. java命令的运行目录从项目的根目录开始
			  在web项目下，  . java命令的而运行目录从tomcat/bin目录开始
			   所以不能使用点.
			 FileInputStream in = new FileInputStream("./src/db.properties");
			 使用类路径的读取方式
			  斜杠表示classpath的根目录
			  在java项目下，classpath的根目录从bin目录开始
			  在web项目下，classpath的根目录从WEB-INF/classes目录开始
			 InputStream in = DBConfig.class.getResourceAsStream("/db.properties");*/
			  
			InputStream inStream=DBConfig.class.getResourceAsStream("/jdbc.properties");
			Properties properties=new Properties();
			try {
				properties.load(inStream);
			} catch (IOException e) {
				logger.error("加载数据库配置文件时发生异常："+e.getMessage(),e);
			}
			this.driverClassName = properties.getProperty("jdbc.driverClassName");
			this.userName = properties.getProperty("jdbc.userName");
			this.password = properties.getProperty("jdbc.password");;
			this.url = properties.getProperty("jdbc.url");
	}
	
	
	
	public DBConfig(String driverClassName, String userName, String password,
			String url) {
		super();
		this.driverClassName = driverClassName;
		this.userName = userName;
		this.password = password;
		this.url = url;
	}



	public String getDriverClassName() {
		return driverClassName;
	}
	public void setDriverClassName(String driverClassName) {
		this.driverClassName = driverClassName;
	}
	public String getUserName() {
		return userName;
	}
	public void setUserName(String userName) {
		this.userName = userName;
	}
	public String getPassword() {
		return password;
	}
	public void setPassword(String password) {
		this.password = password;
	}
	public String getUrl() {
		return url;
	}
	public void setUrl(String url) {
		this.url = url;
	}

	
	
}

?

?

4、JDBCUtil.java 封装JDBC访问数据库等信息

package com.insigma.jdbc.util.dbUtil;

import java.beans.IntrospectionException;
import java.beans.PropertyDescriptor;
import java.lang.reflect.Field;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.math.BigDecimal;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;

import org.apache.log4j.Logger;

public class JDBCUtil {
	private static Logger logger=Logger.getLogger(JDBCUtil.class);
	private static Connection conn=null;
	private static PreparedStatement pstmt=null;
	private static ResultSet rs=null;
	private static  String driverClassName="";
	private static  String url="";
	private static  String userName="";
	private static  String password="";
	
	private static void loadConfig(){
		DBConfig config=new DBConfig();
		driverClassName=config.getDriverClassName();
		url=config.getUrl();
		userName=config.getUserName();
		password=config.getPassword();
				
	}
	
	static{
		try {
			loadConfig();
			Class.forName(driverClassName);
		} catch (ClassNotFoundException e) {
			logger.error("数据库驱动类加载异常："+e.getMessage(),e);
		}
	}
	
	public static Connection getConn() throws SQLException{
		try{
			conn=DriverManager.getConnection(url,userName,password);
		}catch(RuntimeException re){
			logger.error("获取数据库连接异常："+re.getMessage(),re);
			throw re;
		}
		return conn;
	}
	
	public static PreparedStatement getStmt(String sql) throws SQLException{
		try{
			pstmt=conn.prepareStatement(sql);
		}catch(RuntimeException re){
			logger.error("获取数据库处理命令异常："+re.getMessage(),re);
			throw re;
		}
		return pstmt;
	}
	
	public static void setParams(List<Object>params) throws SQLException{
		try{
			//if(params!=null&&params.size()>0){ 数据库最底层，不进行任何逻辑判断，也只捕获RuntimeExcepiton  并重新抛出
				for(int i=0;i<params.size();i++){
					pstmt.setObject(i+1, params.get(i));
				}
			//}
		}catch(RuntimeException re){
			logger.error("设置查询参数发生异常："+re.getMessage(),re);
			throw re;
		}
	}
	
	public static ResultSet getRs() throws SQLException{
		try{
			rs=pstmt.executeQuery();
		}catch(RuntimeException re){
			logger.error("获取查询结果发生异常："+re.getMessage(),re);
			throw re;
		}
		return rs;
	}

	public static void closeAll() throws SQLException{
		try{
			if(rs!=null)rs.close();
			if(pstmt!=null)pstmt.close();
			if(conn!=null)conn.close();
		}catch(RuntimeException re){
			logger.error("数据库关闭项异常："+re.getMessage(),re);
			throw re;
		}
	}
	
	private static ResultSetMetaData prepareRsmd(String sql, List<Object> params)
			throws SQLException {
		prepareRs(sql, params);
		ResultSetMetaData rsmd=rs.getMetaData();
		return rsmd;
	}

	private static void prepareRs(String sql, List<Object> params)
			throws SQLException {
		preparePstmt(sql, params);
		getRs();
	}

	private static void preparePstmt(String sql, List<Object> params)
			throws SQLException {
		getConn();
		getStmt(sql);
		if(params!=null&&params.size()>0) setParams(params);
	}
	
	/**
	 * 封装结果集为：List<HashMap<String,Object>>
	 * @param sql
	 * @param params   List<Object>
	 * @return  list<HashMap<String,Object>>
	 * @throws SQLException
	 */
    public static List<HashMap<String,Object>> getListHashMap(String sql,List<Object>params) throws SQLException{
    	List<HashMap<String,Object>>list=new ArrayList<HashMap<String,Object>>();
    	try{
        	HashMap<String,Object>hashMap=null;
        	ResultSetMetaData rsmd = prepareRsmd(sql, params);
        	int columnCount=rsmd.getColumnCount();
        	while(rs.next()){
        		hashMap=new HashMap<String, Object>();
        		for(int i=0;i<columnCount;i++){
        			hashMap.put((rsmd.getColumnLabel(i+1)).toLowerCase(),rs.getObject(i+1));
        		}
        		list.add(hashMap);
        	}
    	}catch(RuntimeException re){
    		logger.error("获取查询结果集异常："+re.getMessage(),re);
    		throw re;
    	}finally{
    		closeAll();
    	}
    	return list;
    }
	
    /**
     * 封装结果集为：List<T>  T为实体bean的泛型
     * 因为没有对特殊类型做处理，不支持特殊类型的查询字段：比如：数字类型，日期类型等
     * 主要用于支持字符串类型
     * @param sql
     * @param clazz   实体类的Class，T.calss
     * @param params List<Object>
     * @return   List<T> T为实体bean的泛型
     * @throws InstantiationException
     * @throws IllegalAccessException
     * @throws SQLException
     */
	public static <T>List<T> getListBean(String sql,Class<T> clazz,List<Object>params) throws InstantiationException, IllegalAccessException, SQLException{
		List<T>list=new ArrayList<T>();
		T t=null;
		try{
			Field [] fields=clazz.getDeclaredFields();
			ResultSetMetaData rsmd = prepareRsmd(sql, params);
			int columnCount=rsmd.getColumnCount();
			while(rs.next()){
				t=(T) clazz.newInstance();
				for(int i=0;i<columnCount;i++){
					String columnName=rsmd.getColumnLabel(i+1);
					for(int j=0;j<fields.length;j++){
						Field field=fields[j];
						if(!(field.getName().equalsIgnoreCase(columnName))) continue;
						
						boolean bFlag=field.isAccessible();
						field.setAccessible(true);//打开javabean的访问权限
						field.set(t, rs.getObject(i+1));
						field.setAccessible(bFlag);
					}
				}
				list.add(t);
			}
		}catch(RuntimeException re){
			logger.error("获取查询结果集异常："+re.getMessage(),re);
			throw re;
		}finally{
			closeAll();
		}

		return list;
	}
	
	/**
	 * 查询实体类的list结果集
	 * @param sql  查询语句
	 * @param clazz  实体类的Class
	 * @param params 查询参数值：List<Object>
	 * @return  List<T>  T 实体类
	 * @throws InstantiationException
	 * @throws IllegalAccessException
	 * @throws SQLException
	 */
	public static <T>List<T> getListCommBean(String sql,Class<T> clazz,List<Object>params) throws  InstantiationException, IllegalAccessException, SQLException{
		List<T> list=new ArrayList<T>();
		T t=null;
		try{
			ResultSetMetaData rsmd = prepareRsmd(sql, params);
			int columnCount=rsmd.getColumnCount();
			Field [] fields=clazz.getDeclaredFields();
			while(rs.next()){
				t=(T) clazz.newInstance();
				for(int i=0;i<columnCount;i++){
					String columnName=rsmd.getColumnLabel(i+1);
					for(int j=0;j<fields.length;j++){
						Field field=fields[j];
						Class<?>fieldType=field.getType();//取得成员变量的数据类型的 Class
						String fieldTypeString=fieldType.toString().toLowerCase();//成员变量数据类型的class的字符串只，并小写化
						String fieldName=field.getName();//取得成员变量名
						if(!fieldName.equalsIgnoreCase(columnName)) continue;//成员变量名，不等于查询出的字段的标签名称（忽略大小写），继续下次循环
						setBeanValue(t, i, field, fieldTypeString);//设置值
					}
				}
				list.add(t);
			}
			
		}catch(RuntimeException re){
			logger.error("获取查询结果集异常："+re.getMessage(),re);
			throw re;
		}finally{
			closeAll();
		}
		return list;
	}

	/**
	 * 同用实体类查询方法 ：只返回一条记录的sql语句，如果有多条，只返回第一条记录
	 * @param clazz  实体类的Class
	 * @param sql  查询语句，只返回一条记录的sql语句，如果有多条，只返回第一条记录
	 * @param params  查询语句的参数：list<Object>
	 * @return  实体类：只返回一条记录的sql语句，如果有多条，只返回第一条记录
	 * @throws SQLException
	 * @throws InstantiationException
	 * @throws IllegalAccessException
	 * @throws IntrospectionException
	 * @throws InvocationTargetException
	 */
	public static  <T> T getResultBean(Class<T> clazz,String sql,List<Object>params) throws SQLException, InstantiationException, IllegalAccessException, IntrospectionException, InvocationTargetException {
		T t=null;
		try{
			Field [] fields=clazz.getDeclaredFields();//取得实体类成员变量对象
			ResultSetMetaData rsmd=prepareRsmd(sql, params);
			int columnCount=rsmd.getColumnCount();//取得数据列数
			while(rs.next()){
				t=clazz.newInstance();
				for(int i=0;i<columnCount;i++){
					String columnLabelName=rsmd.getColumnLabel(i+1);//取得查询数据类的标签名：即as 后面的别名，如果没有别名，则为字段名称，取出的为大写格式
					for(Field field:fields){
						String propertyName=field.getName();//取得实体类成员变量的名称
						String propertyType=field.getType().toString().toLowerCase();//通过Field取得实体类变量 类型
						if(!propertyName.equalsIgnoreCase(columnLabelName)) continue;
						invokeBeanValue(t, i, propertyType, propertyName);//对带有指定参数的指定对象调用由此 Method 对象表示的底层方法invoke初始化值。t 实体类对象 - 从中调用底层方法的对象 args - 用于方法调用的参数 
					}
				}
				break;//此处，直接终止本次循环，只返回第一条结果。
			}
			
		}catch(RuntimeException re){
			throw re;
		}finally{
			closeAll();
		}
		return t;
	}

	/**
	 * 对带有指定参数的指定对象调用由此 Method 对象表示的底层方法invoke初始化值。 
	 * @param t  t 实体类对象 
	 * @param i
	 * @param propertyType
	 * @param propertyName
	 * @throws IllegalAccessException
	 * @throws InvocationTargetException
	 * @throws IntrospectionException
	 * @throws SQLException
	 */
	private static <T> void invokeBeanValue(T t, int i, String propertyType,String propertyName) throws IllegalAccessException, InvocationTargetException, IntrospectionException, SQLException {
		//对带有指定参数的指定对象调用由此 Method 对象表示的底层方法invoke初始化值。t 实体类对象 - 从中调用底层方法的对象 args - 用于方法调用的参数 
		PropertyDescriptor propdscrp=new PropertyDescriptor(propertyName, t.getClass());//通过调用 get 和 set 存取方法，为符合标准 Java 约定的属性构造一个 PropertyDescriptor,成员变量aab001,则标准为：getAab001,setAab001。
		Method method=propdscrp.getWriteMethod();//读取写入方法，即：set方法
		if(propertyType.indexOf("byte")>0){
			method.invoke(t, rs.getByte(i+1));
		}else if(propertyType.indexOf("boolean")>0){
			method.invoke(t,rs.getBoolean(i+1));
		}else if(propertyType.indexOf("short")>0){
			method.invoke(t,rs.getShort(i+1));
		}else if(propertyType.indexOf("int")>0||propertyType.indexOf("integer")>0){
			method.invoke(t,rs.getInt(i+1));
		}else if(propertyType.indexOf("long")>0){
			method.invoke(t,rs.getLong(i+1));
		}else if(propertyType.indexOf("float")>0){
			method.invoke(t,rs.getFloat(i+1));
		}else if(propertyType.indexOf("double")>0){
			method.invoke(t,rs.getDouble(i+1));
		}else if(propertyType.indexOf("string")>0){
			method.invoke(t,rs.getString(i+1));
		}else if(propertyType.indexOf("date")>0){
			method.invoke(t,rs.getDate(i+1));
		}else if(propertyType.indexOf("time")>0){
			method.invoke(t,rs.getTime(i+1));
		}else if(propertyType.indexOf("timestamp")>0){
			method.invoke(t,rs.getTimestamp(i+1));
		}else if(propertyType.indexOf("bigdecimal")>0){
			method.invoke(t,rs.getBigDecimal(i+1));
		}else if(propertyType.indexOf("clob")>0){
			method.invoke(t,rs.getClob(i+1));
		}else if(propertyType.indexOf("blob")>0){
			method.invoke(t,rs.getBlob(i+1));//一般用：rs.getBinaryStream(i+1);
		}else{
			method.invoke(t,rs.getObject(i+1));
		}
	}
	
	/**
	 * 对带有指定参数的指定对象调用由此 Method ,实体类对象属性Field 的set方法。 
	 * @param t
	 * @param i
	 * @param field
	 * @param fieldTypeString
	 * @throws IllegalAccessException
	 * @throws SQLException
	 */
	private static <T> void setBeanValue(T t, int i, Field field,String fieldTypeString) throws IllegalAccessException, SQLException {
		boolean bFlag=field.isAccessible();
		field.setAccessible(true);//打开javabean的访问权限
		if(fieldTypeString.indexOf("byte")>0){
			field.set(t, rs.getByte(i+1));
		}else if(fieldTypeString.indexOf("boolean")>0){
			field.set(t,rs.getBoolean(i+1));
		}else if(fieldTypeString.indexOf("short")>0){
			field.set(t,rs.getShort(i+1));
		}else if(fieldTypeString.indexOf("int")>0||fieldTypeString.indexOf("integer")>0){
			field.set(t,rs.getInt(i+1));
		}else if(fieldTypeString.indexOf("long")>0){
			field.set(t,rs.getLong(i+1));
		}else if(fieldTypeString.indexOf("float")>0){
			field.set(t,rs.getFloat(i+1));
		}else if(fieldTypeString.indexOf("double")>0){
			field.set(t,rs.getDouble(i+1));
		}else if(fieldTypeString.indexOf("string")>0){
			field.set(t,rs.getString(i+1));
		}else if(fieldTypeString.indexOf("date")>0){
			field.set(t,rs.getDate(i+1));
		}else if(fieldTypeString.indexOf("time")>0){
			field.set(t,rs.getTime(i+1));
		}else if(fieldTypeString.indexOf("timestamp")>0){
			field.set(t,rs.getTimestamp(i+1));
		}else if(fieldTypeString.indexOf("bigdecimal")>0){
			field.set(t,rs.getBigDecimal(i+1));
		}else if(fieldTypeString.indexOf("clob")>0){
			field.set(t,rs.getClob(i+1));
		}else if(fieldTypeString.indexOf("blob")>0){
			field.set(t,rs.getBlob(i+1));//一般用：rs.getBinaryStream(i+1);
		}else{
			field.set(t,rs.getObject(i+1));
		}
		field.setAccessible(bFlag);
	}
	
	
	/**
	 * INSERT, UPDATE or DELETE  ,增、删、改 通用查询方法
	 * @param clazz 待更新的实体类的Class
	 * @param sql 数据库操作语句： SQL Data Manipulation Language (DML) statement,必须是数据库DML 语句
	 * @param params 查询语句参数：List<Object>
	 * @return 1、有数据被更新：则返回更新的记录数；2、没有记录被更新：返回0；     either (1) the row count for SQL Data Manipulation Language (DML) statements or (2) 0 for SQL statements that return nothing
	 * @throws SQLException
	 */
	public static int updateRecord(String sql,List<Object>params) throws SQLException{
		int iNum=0;
		try{
			preparePstmt(sql, params);
			iNum=pstmt.executeUpdate();//更新成功，返回更新的记录数，没有更新返回0
		}catch(RuntimeException re){
			logger.error("更新数据库记录异常:"+re.getMessage());
			throw re;
		}finally{
			closeAll();
		}
		return iNum;
	}
	
}

?

5、test_user 测试表

create table  test_user ( 
  user_id number primary key, 
  user_name varchar2(20) not null, 
  user_password varchar2(20) not null
 ) 

?

6、UserBean.java 测试实体类

package com.insigma.jdbc.util.test;

@SuppressWarnings("serial")
public class UserBean implements java.io.Serializable{
	private String userId;
	private String userName;
	private String userPassword;
	public String getUserId() {
		return userId;
	}
	public void setUserId(String userId) {
		this.userId = userId;
	}
	public String getUserName() {
		return userName;
	}
	public void setUserName(String userName) {
		this.userName = userName;
	}
	public String getUserPassword() {
		return userPassword;
	}
	public void setUserPassword(String userPassword) {
		this.userPassword = userPassword;
	}
	public UserBean(String userId, String userName, String userPassword) {
		super();
		this.userId = userId;
		this.userName = userName;
		this.userPassword = userPassword;
	}
	public UserBean() {
		super();
	}
	@Override
	public int hashCode() {
		final int prime = 31;
		int result = 1;
		result = prime * result + ((userId == null) ? 0 : userId.hashCode());
		result = prime * result
				+ ((userName == null) ? 0 : userName.hashCode());
		result = prime * result
				+ ((userPassword == null) ? 0 : userPassword.hashCode());
		return result;
	}
	@Override
	public boolean equals(Object obj) {
		if (this == obj)
			return true;
		if (obj == null)
			return false;
		if (getClass() != obj.getClass())
			return false;
		UserBean other = (UserBean) obj;
		if (userId == null) {
			if (other.userId != null)
				return false;
		} else if (!userId.equals(other.userId))
			return false;
		if (userName == null) {
			if (other.userName != null)
				return false;
		} else if (!userName.equals(other.userName))
			return false;
		if (userPassword == null) {
			if (other.userPassword != null)
				return false;
		} else if (!userPassword.equals(other.userPassword))
			return false;
		return true;
	}
	@Override
	public String toString() {
		return "UserBean [userId=" + userId + ", userName=" + userName
				+ ", userPassword=" + userPassword + "]";
	}
	

}

?

7、JDBCUtilTest? 测试类

package com.insigma.jdbc.util.test;

import java.beans.IntrospectionException;
import java.lang.reflect.InvocationTargetException;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Set;

import org.apache.log4j.Logger;

import com.insigma.jdbc.util.dbUtil.JDBCUtil;

public class JDBCUtilTest {
	private static final Logger logger=Logger.getLogger(JDBCUtilTest.class);
	public static void main(String[] args) {
		String sql="";
		List<Object>params=null;
		logger.info("*************************新增开始*****************************");
		sql="insert into test_user values(?,?,?)";
		params=new ArrayList<Object>();
		params.add(7777);
		params.add("剑魔独孤求败");
		params.add("SuperMan-Terminator");
		testUpdateRecord(sql, params);
		logger.info("\n");
		
		logger.info("*************************testListHashMap开始********************");
		sql="select user_id userId,user_name userName,user_password userPassword from test_user where user_name=?";
		params=new ArrayList<Object>();
		params.add("剑魔独孤求败");
		testListHashMap(sql, params);
		logger.info("\n");
		
		logger.info("*************************testListCommBean开始********************");
		sql="select user_id userId,user_name userName,user_password userPassword from test_user where user_password=?";
		params=new ArrayList<Object>();
		params.add("SuperMan-Terminator");
		testListCommBean(sql, params);
		logger.info("\n");
		
		logger.info("*************************testResultRecord开始********************");
		sql="select user_id userId,user_name userName,user_password userPassword from test_user where user_id=?";
		params=new ArrayList<Object>();
		params.add(9999);
		testResultRecord(sql, params);
		
	}







	private static void testResultRecord(String sql, List<Object> params) {
		try {
			UserBean user=JDBCUtil.getResultBean(UserBean.class, sql, params);
			if(user!=null){
				logger.info("userId="+user.getUserId()+"\t userName="+user.getUserName()+"\t userPassword="+user.getUserPassword());
			}
		} catch (SQLException e) {
			logger.error("T结果查询失败："+e.getMessage(),e);
		} catch (InstantiationException e) {
			logger.error("T结果查询失败："+e.getMessage(),e);
		} catch (IllegalAccessException e) {
			logger.error("T结果查询失败："+e.getMessage(),e);
		} catch (IntrospectionException e) {
			logger.error("T结果查询失败："+e.getMessage(),e);
		} catch (InvocationTargetException e) {
			logger.error("T结果查询失败："+e.getMessage(),e);
		}
	}







	private static void testListCommBean(String sql, List<Object> params) {
		try {
			List<UserBean>listUser=JDBCUtil.getListCommBean(sql, UserBean.class, params);
			if(listUser!=null&&listUser.size()>0){
				for(UserBean user:listUser){
					logger.info("userId="+user.getUserId()+"\t userName="+user.getUserName()+"\t userPassword="+user.getUserPassword());
				}
			}else{
				logger.info("没有查询到记录");
			}
		} catch (InstantiationException e) {
			logger.error("List<T>结果集查询失败："+e.getMessage(),e);
		} catch (IllegalAccessException e) {
			logger.error("List<T>结果集查询失败："+e.getMessage(),e);
		} catch (SQLException e) {
			logger.error("List<T>结果集查询失败："+e.getMessage(),e);
		}
	}







	private static void testUpdateRecord(String sql, List<Object> params) {
		try {
			int iNum=JDBCUtil.updateRecord(sql, params);
			logger.info(iNum+"条数据新增成功!");
		} catch (SQLException e) {
			logger.info("数据新增失败："+e.getMessage(),e);
		}
	}
	
	
	
	
	
	
	
	private static void testListHashMap(String sql, List<Object> params) {
		try {
			List<HashMap<String,Object>>listHashMap=JDBCUtil.getListHashMap(sql, params);
			if(listHashMap!=null&&listHashMap.size()>0){
				for(HashMap<String,Object>hashMap:listHashMap){
					String msg="查询记录：\t";
					Set<String>keys=hashMap.keySet();
					Iterator<String>it=keys.iterator();
					while(it.hasNext()){
						String key=it.next();
						msg+=key+"="+hashMap.get(key)+"\t";
					}
					logger.info(msg);
				}
			}else{
				logger.info("没有查询到记录");
			}
		} catch (SQLException e) {
			logger.error("List<HashMap<String,Object>>结果集查询失败："+e.getMessage(),e);
		}
	}
	
	

}

?

8、执行结果：

INFO : 2017-11-17 16:45:09,425: JDBCUtilTest[line:21}: *************************新增开始*****************************

INFO : 2017-11-17 16:45:09,837: JDBCUtilTest[line:111}: 1条数据新增成功!

INFO : 2017-11-17 16:45:09,837: JDBCUtilTest[line:28}:?

?

INFO : 2017-11-17 16:45:09,837: JDBCUtilTest[line:30}: *************************testListHashMap开始********************

INFO : 2017-11-17 16:45:10,435: JDBCUtilTest[line:135}: 查询记录：userpassword=SuperMan-Terminatorusername=剑魔独孤求败userid=9999

INFO : 2017-11-17 16:45:10,435: JDBCUtilTest[line:135}: 查询记录：userpassword=SuperMan-Terminatorusername=剑魔独孤求败userid=8888

INFO : 2017-11-17 16:45:10,435: JDBCUtilTest[line:135}: 查询记录：userpassword=SuperMan-Terminatorusername=剑魔独孤求败userid=7777

INFO : 2017-11-17 16:45:10,436: JDBCUtilTest[line:35}:?

?

INFO : 2017-11-17 16:45:10,436: JDBCUtilTest[line:37}: *************************testListCommBean开始********************

INFO : 2017-11-17 16:45:10,504: JDBCUtilTest[line:88}: userId=9999 userName=剑魔独孤求败 userPassword=SuperMan-Terminator

INFO : 2017-11-17 16:45:10,504: JDBCUtilTest[line:88}: userId=8888 userName=剑魔独孤求败 userPassword=SuperMan-Terminator

INFO : 2017-11-17 16:45:10,504: JDBCUtilTest[line:88}: userId=7777 userName=剑魔独孤求败 userPassword=SuperMan-Terminator

INFO : 2017-11-17 16:45:10,506: JDBCUtilTest[line:42}:?

?

INFO : 2017-11-17 16:45:10,507: JDBCUtilTest[line:44}: *************************testResultRecord开始********************

INFO : 2017-11-17 16:45:10,550: JDBCUtilTest[line:62}: userId=9999 userName=剑魔独孤求败 userPassword=SuperMan-Terminator

?

9、数据库查询结果

SQL> select * from test_user;

? ?USER_ID USER_NAME? ? ? ? ? ? USER_PASSWORD

---------- -------------------- --------------------

? ? ? 9999 剑魔独孤求败? ? ? ? ?SuperMan-Terminator

? ? ? 8888 剑魔独孤求败? ? ? ? ?SuperMan-Terminator

? ? ? 7777 剑魔独孤求败? ? ? ? ?SuperMan-Terminator