JDBC连接池的工具类

布满荆棘的人生 2022-06-02 09:47 217阅读 0赞

package com.yanshu.utils;  
  
  
import java.io.IOException;  
import java.io.InputStream;  
import java.sql.CallableStatement;  
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.sql.Statement;  
import java.util.ArrayList;  
import java.util.HashMap;  
import java.util.List;  
import java.util.Map;  
import java.util.Properties;  
  
  
  
  
  
  
  
  
  
  
/\*\*  
 \* JDBC连接数据库的工具类  
 \* @author Administrator  
 \*  
 \*/  
public class JdbcUtil \{  
//第一步:声明所有需要的静态的全局变量  
private static final long serialVersionUID =1L;  
private static final String JDBC\_DRIVER;  
private static final String DB\_URL;  
private static final String USER;  
private static final String PASS;  
private static final Properties pros;  
public JdbcUtil() \{  
// TODO Auto-generated constructor stub  
\}  
//第2不加载读取配置文件，并初始化静态变量  
static   
\{  
//读取和处理资源文件的信息  
pros=new Properties();  
try \{  
pros.load(Thread.currentThread().getContextClassLoader().getResourceAsStream("application.properties"));  
\} catch (IOException e) \{  
// TODO Auto-generated catch block  
e.printStackTrace();  
\}  
JDBC\_DRIVER=pros.getProperty("spring.datasource.driver-class-name");  
DB\_URL=pros.getProperty("spring.datasource.url");  
USER = pros.getProperty("spring.datasource.username");  
PASS = pros.getProperty("spring.datasource.password");  
\}  
//第二步要加载数据驱动  
static\{  
try \{  
Class.forName(JDBC\_DRIVER);  
\} catch (ClassNotFoundException e) \{  
// TODO Auto-generated catch block  
e.printStackTrace();  
\}  
\}  
  
/\*InputStream inputStream=JDBCUtil.class.getClassLoader().getResourceAsStream("jdbc.properties");  
Properties pro=new Properties();  
try \{  
pro.load(inputStream);  
\} catch (IOException e) \{  
// TODO Auto-generated catch block  
e.printStackTrace();  
\}  
  
  
String diver=pro.getProperty("jdbc.driver");  
String url=pro.getProperty("jdbc.url");  
String user=pro.getProperty("jdbc.username");  
String password=pro.getProperty("jdbc.password");\*/  
  
  
/\*\*  
\* 获得数据库连接  
\* getConn()  
\* @return 返回数据库连接  
\*/  
//第3步获得数据库连接  
public static Connection getConn()  
\{  
try \{  
return DriverManager.getConnection(DB\_URL,USER,PASS);  
\} catch (SQLException e) \{  
// TODO Auto-generated catch block  
e.printStackTrace();  
\}  
return null;  
\}  
  
  
/\*\*  
\* 释放资源  
\* @param rs 释放结果集ResultSet  
\* @param cs 释放存储过程 CallableStatement  
\* @param sta 释放执行sql的对象，静态的  
\* @param ps 释放执行sql的对象，预编译的  
\* @param conn 关闭连接  
\*/  
//第4步释放资源  
public static void closeConn(ResultSet rs, CallableStatement cs,Statement sta, PreparedStatement ps, Connection conn)  
\{  
try \{  
if(rs!=null)  
\{  
rs.close();    
\}  
\} catch (SQLException e) \{  
// TODO Auto-generated catch block  
e.printStackTrace();  
\}  
try \{  
if(cs!=null)  
\{  
cs.close();    
\}  
\} catch (SQLException e) \{  
// TODO Auto-generated catch block  
e.printStackTrace();  
\}  
try \{  
if(sta != null)  
\{  
sta.close();    
\}  
\} catch (SQLException e) \{  
// TODO Auto-generated catch block  
e.printStackTrace();  
\}  
try \{  
if(ps != null)  
\{  
ps.close();    
\}  
\} catch (SQLException e) \{  
// TODO Auto-generated catch block  
e.printStackTrace();  
\}  
try \{  
if(conn != null)  
\{  
  
  
conn.close();    
\}  
\} catch (SQLException e) \{  
// TODO Auto-generated catch block  
e.printStackTrace();  
\}  
  
  
  
  
  
  
  
  
  
\}  
  
//==========================执行增删改的方法start================================================  
/\*\*  
\* 执行增删改的方法  
\* @param ps  
\* @param par  
\*/  
public static void setUpdate(PreparedStatement ps,Object \[\] par)  
\{  
if(par==null) return;  
try \{  
for(int i=0;i<par.length;i++)  
\{  
ps.setObject(i+1, par\[i\]);  
  
\}  
\} catch (SQLException e) \{  
// TODO Auto-generated catch block  
e.printStackTrace();  
\}  
  
\}  
  
/\*\*  
\* 通用的查询方法：可以根据传入的 SQL、Class 对象返回 SQL 对应的记录的对象  
\* @param clazz: 描述对象的类型  
\* @param sql: SQL 语句。可能带占位符  
\* @param args: 填充占位符的可变参数。  
\* @return  
\*/  
public static <T>T findObject(Class<T> clapar,String sql,Object ...objects)  
\{  
T entity=null;  
Connection conn=null;  
PreparedStatement ps=null;  
ResultSet rs=null;  
try \{  
conn=JdbcUtil.getConn();  
ps=conn.prepareStatement(sql);  
for(int i=0;i<objects.length;i++)  
\{  
ps.setObject(i+1, objects\[i\]);  
\}  
rs=ps.executeQuery();  
ResultSetMetaData rsmd = rs.getMetaData();  
Map<String, Object> map = new HashMap<>();  
while(rs.next())  
\{  
for(int i=0;i<rsmd.getColumnCount();i++)  
\{  
String columnLabel=rsmd.getColumnLabel(i+1);  
Object columnValue=rs.getObject(i+1);  
map.put(columnLabel, columnValue);  
\}  
\}  
//5. 若 Map 不为空集, 利用反射创建 clazz 对应的对象  
  
if(map.size()>0)  
\{  
entity=clapar.newInstance();  
//5. 遍历 Map 对象, 利用反射为 Class 对象的对应的属性赋值.   
for(Map.Entry<String, Object> en:map.entrySet())  
\{  
String fieldName = en.getKey();  
Object value = en.getValue();  
ReflectionUtils.setFieldValue(entity, fieldName, value);  
\}  
\}  
  
  
  
\} catch (Exception e) \{  
// TODO Auto-generated catch block  
e.printStackTrace();  
\}  
finally  
\{  
JdbcUtil.closeConn(rs, null, ps, ps, conn);  
\}  
  
  
  
  
return entity;  
  
\}  
  
  
  
  
  
  
  
  
  
  
  
  
  
  
  
  
  
  
  
  
  
  
  
  
  
  
\}