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("插入成功");elseSystem.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 objsSQL语句占位符实参，如果没有参数则传入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();  }

到此这篇关于jdbc与druid连接池的使用的文章就介绍到这了,更多相关jdbc与druid连接池内容请搜索以前的文章或继续浏览下面的相关文章希望大家以后多多支持！

不要识途去改变他人，同样，也不要被他人所改变。改了，就不是自己了。