开源数据池dbcp使用案例

╰+哭是因爲堅強的太久メ 2021-10-18 16:36 158阅读 0赞

*  需要导入jar文件

## 1. 测试类 ##

package com.cds.dbcp02;
    
    import java.sql.Connection;
    import java.sql.PreparedStatement;
    import java.sql.SQLException;
    
    import org.apache.commons.dbcp.BasicDataSource;
    import org.junit.jupiter.api.Test;
    
    import com.cds.uitl.JDBCUtil;
    
    public class DbcpDemo02 { 
    	@Test 
    	public void testDbcpDemo()  { 
    		Connection connection = null;
    		PreparedStatement ps = null;		
    		
    		try { 
    			// 1. 构建数据对象
    			BasicDataSource dataSource = new BasicDataSource();
    			dataSource.setDriverClassName("com.mysql.jdbc.Driver");
    			dataSource.setUrl("jdbc:mysql://localhost/bank");
    			dataSource.setUsername("root");
    			dataSource.setPassword("123456");
    			//2. 获得连接对象
    			connection = dataSource.getConnection();
    			String sql = "insert into account values(null,'aaa',11)";
    			ps = connection.prepareStatement(sql );
    			ps.executeUpdate();
    		} catch (SQLException e) { 
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
    		finally {  
    			JDBCUtil.release(connection, ps);
    		}
    	}
    }

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

## 2. 工具类 ##

package com.cds.uitl;
    
    import java.io.FileInputStream;
    import java.io.FileNotFoundException;
    import java.io.IOException;
    import java.io.InputStream;
    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.sql.Statement;
    import java.util.Properties;
    
    import com.mysql.jdbc.Driver;
    
    public class JDBCUtil { 
    	
    	static String driverClass = null;
    	static String url = null;
    	static String user = null;
    	static String password = null;
    	
    	static { 
    		try { 
    			
    			
    			Properties properties = new Properties();
    			InputStream in = new FileInputStream("jdbc.properties");
    			try { 
    				properties.load(in);
    			} catch (IOException e) { 
    				e.printStackTrace();
    			}
    			
    			user = properties.getProperty("user");
    			password = properties.getProperty("password");
    			url = properties.getProperty("url");
    			driverClass = properties.getProperty("driverClass");
    			
    			
    		} catch (FileNotFoundException e) { 
    			e.printStackTrace();
    		}
    	}
    	
    	public static Connection getConnection() throws ClassNotFoundException { 
    		Connection conn = null;
    		try { 
    			Class.forName(driverClass);
    			
    			conn = DriverManager.getConnection(url, user, password);
    	
    		} catch (SQLException e) { 
    			e.printStackTrace();
    		}		
    		
    		return conn;
    	}
    	
    	
    	public static void release(Connection conn,Statement st) { 
    		
    		colseConn(conn);
    		colseSt(st);
    
    	}
    	public static void release(Connection conn,Statement st,ResultSet rs) { 
    		colseConn(conn);
    		colseSt(st);
    		colseRS(rs);
    	}
    	
    	
    	
    	private static void colseRS(ResultSet rs) { 
    		if(rs!= null) { 
    			try { 
    				rs.close();
    			} catch (SQLException e) { 
    				e.printStackTrace();
    			}finally { 
    				rs = null;
    			}
    		}				
    	}
    	private static void colseSt(Statement st) { 
    		if(st!= null) { 
    			try { 
    				st.close();
    			} catch (SQLException e) { 
    				e.printStackTrace();
    			}finally { 
    				st = null;
    			}
    		}				
    	}
    	
    	private static void colseConn(Connection conn) { 
    		if(conn!= null) { 
    			try { 
    				conn.close();
    			} catch (SQLException e) { 
    				e.printStackTrace();
    			}finally { 
    				conn = null;
    			}
    		}				
    	}
    
    }