欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

封装JDBC通用工具类jdbc-utils

程序员文章站 2022-07-12 16:09:53
...

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

 

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