jdbc与druid连接池 jdbc与druid连接池的使用详解
m0_52000372 人气:0想了解jdbc与druid连接池的使用详解的相关内容吗,m0_52000372在本文为您仔细讲解jdbc与druid连接池的相关知识和一些Code实例,欢迎阅读和指正,我们先划重点:jdbc与druid连接池,jdbc与druid连接池使用,下面大家一起来学习吧。
使用jdbc实现对数据库的操作
Ⅰ 获取数据库连接
package org.example.utils; import java.sql.*; public class JavaDateConnection { /** * 获取数据库连接 * @return Connection */ public Connection getConn() { //project为数据库名 String url = "jdbc:mysql://localhost:3306/project"; //用户名 String username = "root"; //密码 String password = "Hyk59308"; Connection conn = null; try { //注册驱动 Class.forName("com.mysql.jdbc.Driver"); //classLoader,加载对应驱动 conn = DriverManager.getConnection(url, username, password); } catch (ClassNotFoundException e) { e.printStackTrace(); } catch (SQLException e) { e.printStackTrace(); } return conn; }
Ⅱ编写SQL语句对数据库进行操作
String sql1="insert into myTable values(?,?,?,?)";//定义sql语句 String sql2="select * from myTable"; //定义sql语句 int result=0; //修改操作的返回值是一个整数,即受影响的行数 ``/** * PreparedStatement继承自Statement接口,PreparedStatement的对象已预编译过, * 执行速度快于Statement对象,创建其对象时,需要SQL命令字符串作为对象 */ PreparedStatement ps=connection.prepareStatement(sql1); ps.setString(1,"tanker"); ps.setString(2, "m"); ps.setString(3,"1991-11-20"); ps.setString(4, "Franch"); result=ps.executeUpdate(); if(result>0) System.out.println("插入成功"); else System.out.println("插入失败"); //Statement用于将sql语句发送到数据库 Statement statement=connection.createStatement(); //执行数据库操作返回的结果集,其定义的是数据库游标 ResultSet results=statement.executeQuery(sql2); System.out.println("name"+" "+"sex"+" "+"birth"+" "+"birthaddr"); System.out.println("------------------------"); while(results.next()) { System.out.println(results.getString("name")+" "+ results.getString("sex")+" "+ results.getString("birth")+" "+ results.getString("birthaddr")); } System.out.println("搞定!");
Ⅲ关闭相关资源
* 关闭Connection PreparedStatement * @param connection * @param preparedStatement */ public static void closeConnection(Connection connection, PreparedStatement preparedStatement, ResultSet resultSet){ if (resultSet != null) { try { resultSet.close(); } catch (SQLException e) { e.printStackTrace(); } } if (preparedStatement != null) { try { preparedStatement.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } if (connection != null) { try { connection.close(); } catch (SQLException e) { e.printStackTrace(); } } }
使用Druid连接池u对数据库进行操作
Ⅰ创建Druid连接池对象并获取
package util; import com.alibaba.druid.pool.DruidDataSourceFactory; import javax.sql.DataSource; import java.io.IOException; import java.io.InputStream; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.util.Properties; public class DBUtil { private static DataSource ds; static { //1.加载配置文件 Properties pro = new Properties(); try { pro.load(DBUtil.class.getClassLoader().getResourceAsStream("/db.properties")); //获取DataSource ds = DruidDataSourceFactory.createDataSource(pro); } catch (IOException e) { e.printStackTrace(); } catch (Exception e) { e.printStackTrace(); } } //获取连接 public static Connection getConnection() throws SQLException { return ds.getConnection(); }
Ⅱ创建SQL语句实现对数据库的操作
/** * @param sql SQL语句 * @param objs SQL语句占位符实参,如果没有参数则传入null * @return 返回增删改的结果,类型为int */ public static int executeDML(String sql,Object...objs){ // 声明jdbc变量 Connection conn = null; PreparedStatement ps = null; int i = -1; try { // 获取连接对象 conn = DBUtil.getConnection(); // 开启事务管理 conn.setAutoCommit(false); // 创建SQL命令对象 ps = conn.prepareStatement(sql); // 给占位符赋值 if(objs!=null){ for(int j=0;j<objs.length;j++){ ps.setObject(j+1,objs[j]); } } // 执行SQL i = ps.executeUpdate(); conn.commit(); } catch (Exception e) { try { conn.rollback(); } catch (SQLException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } e.printStackTrace(); } finally { DBUtil.closeAll(null, ps, conn); } return i; }
Ⅲ关闭相关资源
//关闭资源 public static void closeAll(ResultSet rs,Statement stmt,Connection conn){ try { if(rs!=null){ rs.close(); } } catch (SQLException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } try { stmt.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } try { conn.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }
加载全部内容