`

封装JDBC通用工具类jdbc-utils

    博客分类:
  • JDBC
阅读更多

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

1
0
分享到:
评论

相关推荐

    jdbc-utils.rar_Utils_jdbc_jdbc封装

    "jdbc-utils.rar_Utils_jdbc_jdbc封装"这个压缩包提供了一些工具类,用于简化JDBC操作,提高代码的可读性和可维护性。下面我们将详细探讨JDBC封装处理类的原理和实现。 1. **JDBC基础** - JDBC API包括一组Java...

    commons-utils简化JDBC使用(文档+示例)

    Apache Commons DBUtils是Java开发中一个非常实用的工具库,它极大地简化了JDBC(Java Database Connectivity)的使用。这个库是Apache Commons项目的一部分,旨在提供一个简单且异常安全的方式来处理数据库操作,...

    Android 封装的工具类

    在Android开发中,工具类(Utils Class)是程序员经常创建的一种辅助代码结构,用来封装一些通用功能,提高代码的复用性和可维护性。这里提到的"Android 封装的工具类"涵盖了几种关键的模块,包括网络请求、数据库...

    jdbc Utils 常用工具集

    JDBCUtils是一个常见的辅助工具类,它封装了JDBC的一些常用操作,以简化数据库的增删查改过程,避免重复性代码,提高开发效率。这篇博客(尽管链接无法直接访问)可能详细介绍了如何构建和使用这样的工具集。 ...

    Utils工具类和配置文件类.rar

    在Java编程中,Utils工具类通常是一些包含各种静态方法的类,这些方法可以用于执行通用的任务,如数据处理、I/O操作或者如本例中与数据库交互。这里我们主要关注的是一个名为"DbUtils"的Utils工具类,它被设计来简化...

    Android收藏的工具类

    在Android开发过程中,工具类(Utils Class)是程序员经常使用的代码模块,它们封装了常见的功能,使得代码更简洁、易维护。"Android收藏的工具类"这个资源包含了多个实用工具类,涵盖了图片缓存、异步请求、数据库...

    rabbit-sql:(一个简单的jdbc utils,支持insert,query,update,delete,procedure ...)对JDBC的一个薄封装工具类,提供基本的增删改查操作

    rabbit-sql使用说明对JDBC的一个薄封装工具类,提供基本的增删改改查操作;此库以追求简单稳定高效为目标,不支持查询结果实体映射,返回对象类型统一为 , 提供了一个简单的实体相互转换,若需要复杂映射,可自行...

    Java数据库操作封装类

    在"Java Database Utils"这个标签下,我们可以理解到这个封装类主要服务于Java环境下的数据库操作,提供实用工具函数,使得开发者无需深入了解底层的JDBC操作,就能高效地完成数据库相关的工作。 至于"repositories...

    Pager(通过的分页工具类)

    标题中的“Pager(通过的分页工具类)”显然指的是一个用于实现分页功能的Java类。在这个类中,开发者通常会封装分页操作的相关逻辑,以便在各种场景下复用。现在我们来详细探讨一下分页的基本概念、设计原则以及...

    Commons-dbutils1.7 jar包.rar

    简单来讲,这个工具包就是用来更加方便我们操作数据库的,最近工作中使用了一下,感觉确实方便很多,基本告别自己封装JDBC代码对数据库进行增删改查了。代码看着也很简洁。 例如: 增删改查使用的类:QueryRunner类+...

    JavaSE-jdbc连接池-每日作业卷答案1

    训练案例3中,设计了一个C3P0工具类`C3P0Utils`,它封装了连接池的创建和管理。这个工具类包含一个私有的静态`ComboPooledDataSource`实例,用于存储连接池。提供了公共方法`getDataSource()`返回连接池对象,以及`...

    JDBCUtils工具类包括MD5加密文件

    JDBCUtils是一个常见的实用工具类,它封装了JDBC的常用操作,以简化数据库的连接、查询、关闭资源等过程,使得代码更加简洁、易读且易于维护。在给定的文件中,`JDBCUtils.java`很可能是实现这一功能的源代码。 `Md...

    沐紫剑工具类集合

    沐紫剑工具类集合是一个由多个模块组成的Java项目,它将常见的工具类进行了分类和封装,方便在实际开发中快速复用。这个集合包括了处理数据库(db)、FTP文件传输、电子邮件(mail)、XML解析、POI(用于处理...

    JavaWeb相关的工具类、Java资源

    1. **工具类(Utils)**: - **字符串处理**:如StringUtils,包含字符串的拼接、分割、检查空值等操作,是处理文本数据时常用的工具。 - **日期时间处理**:如DateTimeUtils,用于格式化、解析日期和时间,处理...

    MultiDBs-Utils:具有所有子项目可能共享的功能的实用程序类

    在这种背景下,`MultiDBs-Utils`项目应运而生,它提供了一套统一的接口和工具类,帮助开发者在不同数据库之间实现功能共享,从而提高代码的可重用性和维护性。 `MultiDBs-Utils`的核心思想是抽象出不同数据库系统的...

    JDBC学习笔记.docx

    为了方便重用,JDBC操作通常封装在静态工具类中,这样可以直接调用静态方法进行数据库操作,无需每次创建新对象。 **5. PreparedStatement与Statement** PreparedStatement是比Statement更安全、高效的接口,因为它...

    MVC总结大全

    `DbUtils`是一个轻量级的JDBC工具类,用于简化数据库操作。它可以自动处理资源关闭、异常处理等问题,使得开发者可以更加专注于业务逻辑的编写。 以上就是关于`Utils`工具类、实体类序列化、单例模式以及`DbUtils`...

    spring-utils:实用程序集合,以支持ICTS开发的Web应用程序。 旨在与Spring和Hibernate一起开发

    为了进一步提高开发效率和代码质量,开发者通常会构建一系列实用工具类,这些类集成了Spring和Hibernate的功能,形成了所谓的“Utils”库。"spring-utils"就是这样一套工具集,专为ICTS(信息技术系统)的Web应用...

    毕业设计: 心理咨询预约管理系统(javaEE)

    utils.jdbc数据库工具类,配置和得到连接池的连接 utils.mail是邮件模块 utils下的ConfigProperties是读入配置文件,ResultDate和UploadResult分别是请求响应结果和文件上传结果对象,Util封装了常用的工具 ...

Global site tag (gtag.js) - Google Analytics