DataSource--DBCP--C3P0--DBUtils

一.DataSource 接口(javax.sql)
     1.连接池:
         由于与数据库连接的创建和销毁非常占用资源,因此提出了连接池技术,用于提升java程序操作数据库的性能;连接池是创建和管理一个连接的缓冲池的技术，这些连接准备好被任何需要它们的线程使用。
     2.介绍:DataSource是java提供的一个接口,规范着所有的想写连接池的人需要做的事情;具体的连接池都需要实现该接口;程序员可以面向Datasource操作具体的连接池对象;
     3.定义:public interface DataSource extends CommonDataSource, Wrapper
     4.常用方法:只有一个getConnection()
         Connection getConnection() throws SQLException{}: Attempts to establish a connection with the data source that this
             DataSource object represents.
         Connection getConnection(String username,String password) throws SQLException{}:
     5.具体的连接池实现技术主要有两类:DBCP和C3P0

二.DBCP--（DataBase Connection Pool）
     1.介绍:
     数据库连接池，是java数据库连接池的一种，由Apache开发，通过数据库连接池，可以让程序自动管理数据库连接的创建。
     2.使用步骤:
         1):下载并解压zip;(DBCP有两个zip文件)
         2):复制核心的jar包到工程中;(commons-dbcp-1.4.jar, commons-pool-1.5.6.jar)
         3):添加到本地;
         4):复制配置文件到src目录下;并修改配置文件的信息;(该配置文件的名称和位置可以任意)
         5):使用核心类;
     3.核心类介绍:BasicDataSourceFactory
         定义:public class BasicDataSourceFactory extends Object implements ObjectFactory
         构造方法:只有一个空参构造
             public BasicDataSourceFactory()
         常用方法:
             public static DataSource createDataSource(Properties properties) throws Exception{}:
             注意参数为Properties类的实例化对象,返回值为DataSource;
     4.自定义DBCP工具类:配置文件("dbcp.properties")需放在工程根目录下;

  1  //需要首先导入包:mysql-connector-java-5.1.39-bin.jar(mysql驱动),commons-dbcp-1.4.jar,commons-pool-1.5.6.jar

  2      import java.io.FileInputStream;

  3      import java.sql.Connection;

  4      import java.sql.SQLException;

  5      import java.util.Properties;

  6      import javax.sql.DataSource;

  7      import org.apache.commons.dbcp.BasicDataSourceFactory;

  8

  9      public class MyDBCPUtils {

 10          private static DataSource ds = null;

 11          //使用静态代码块技术初始化ds对象(成员变量)

 12          static {

 13              // 获取DataSource

 14              try {

 15                  FileInputStream in = new FileInputStream("dbcp.properties");

 16                  Properties p = new Properties();

 17                  p.load(in);

 18                  ds = BasicDataSourceFactory.createDataSource(p);//面向DBCP核心类,调用createDataSource()方法,返回DataSource

 19              } catch (Exception e) {

 20                  e.printStackTrace();

 21              }

 22          }

 23          // 获取Connection

 24          public static Connection getConnection() {

 25              Connection c = null;

 26              try {

 27                  c = ds.getConnection();

 28              } catch (SQLException e) {

 29                  e.printStackTrace();

 30              }

 31              return c;

 32          }

 33      }

三.C3P0
     1.介绍:
     C3P0是一个开源的JDBC连接池，它实现了数据源和JNDI绑定，支持JDBC3规范和JDBC2的标准扩展。目前使用它的开源项目有Hibernate，Spring等。c3p0与dbcp区别:c3p0有自动回收空闲连接功能,dbcp做不到.
     2.使用步骤:
         1):下载并解压zip;
         2):复制核心jar包到工程中即可:c3p0-0.9.1.2.jar;
         3):添加到本地;
         4):复制配置文件必须到src目录下,且配置文件的名称(c3p0-config.xml)不能改变;
         5):直接创建ComboPooledDataSource核心类对象即可使用;
     3.核心类 ComboPooledDataSource 类(com.mchange.v2.c3p0)
         定义:public final class ComboPooledDataSource extends com.mchange.v2.c3p0.impl.AbstractPoolBackedDataSource
                                                     implements PooledDataSource, java.io.Serializable, javax.naming.Referenceable
              public interface PooledDataSource extends javax.sql.DataSource

                 ComboPooledDataSource类实现了PooledDataSource接口,该接口继承了DataSource接口;
         构造方法:
                 public ComboPooledDataSource()
         配置文件选项(补充):

4.自定义C3P0工具类:导入包:mysql-connector-java-5.1.39-bin.jar,c3p0-0.9.1.2.jar

  1  /*配置文件必须到src目录下,且配置文件的名称(c3p0-config.xml)不能改变,程序中不会出现,但是会自动读取.

  2      如果报超时错误,有可能是1.包没导入/2.文件没找到/3.数据库服务未开启*/

  3

  4         import java.sql.Connection;

  5          import javax.sql.DataSource;

  6         import com.mchange.v2.c3p0.ComboPooledDataSource;

  7

  8          public class MyC3P0Utils {

  9              // 定义DataSource

 10              private static DataSource ds = new ComboPooledDataSource(); // 多态,子类实例赋值给父类的父类

 11

 12              // 获取Connection

 13              public static Connection getConnection() throws Exception {

 14                  Connection c = ds.getConnection();

 15                  return c;

 16              }

 17              // 返回连接池对象

 18             public static DataSource getDataSource() {

 19                  return ds;

 20              }

 21          }

 22

四.DBUtils--工具类,commons-dbutils-1.6.jar
     1.概述:Commons DbUtils是Apache组织提供的一个对JDBC进行简单封装的开源工具类库，使用它能够简化JDBC应用程序的开发，同时也不会影响程序的性能。
     2.使用步骤:
         1):下载并解压zip;
         2):复制核心jar包到工程中即可:commons-dbutils-1.6.jar;
         3):添加到本地;
         4):直接创建核心类对象即可使用;
     3.核心类3个:
         1):QueryRunner,用于封装sql执行对象;
         2):ResultSetHandler用于封装ResultSet;
         3):DButils, 用于事务的控制;
     4.QueryRunner
         定义:public class QueryRunner extends AbstractQueryRunner
         构造方法:
             public QueryRunner()
             public QueryRunner(DataSource ds)
         常用方法:
         public <T> T query(Connection conn, String sql, ResultSetHandler<T> rsh, Object... params)throws SQLException{}:
         public <T> T query(String sql, ResultSetHandler<T> rsh, Object... params)throws SQLException{}:

         public int update(Connection conn, String sql, Object... params)throws SQLException{}:Execute an SQL INSERT, UPDATE, or DELETE query.返回值为数据表里受影响的行数(int类型);
         public int update(String sql, Object... params)throws SQLException{}:Executes the given INSERT, UPDATE, or DELETE SQL statement. The Connection is retrieved from the DataSource set in the constructor. This Connection must be in auto-commit mode or the update will not be saved.
     5.ResultSetHandler
         定义:public interface ResultSetHandler<T>
         子类:根据取出数据的不同选择不同的容器接收.前三个较为常用.
             BeanHandler:将结果集中第一条记录封装到一个指定的javaBean中.
             BeanListHandler:将结果集中每一条记录封装到指定的javaBean中，将这些javaBean在封装到List集合中.
             ScalarHandler:它是用于单个数据。例如select count(*) from 表操作.
             ArrayHandler:将结果集中的第一条记录封装到一个Object[]数组中,数组中的每一个元素就是这条记录中的每一个字段的值.
             ArrayListHandler:将结果集中的每一条记录都封装到一个Object[]数组中，将这些数组在封装到List集合中.
             ColumnListHandler:将结果集中指定的列的字段值，封装到一个List集合中.
             MapHandler:将结果集中第一条记录封装到了Map<    String,Object>集合中,key就是字段名称,value就是字段值.
             MapListHandler:将结果集中每一条记录封装到了Map<String,Object>集合中，key就是字段名称，value就是字段值，在将这些Map封装到List集合中.
             KeyedHandler:将结果集中每一条记录封装到Map<String,Object>,在将这个map集合做为另一个Map的value,另一个Map集合的key是指定的字段的值.

6.DbUtils
         定义:public final class DbUtils extends Object
         构造方法:public DbUtils()
         静态方法:
         public static void close(Connection conn/ResultSet rs/Statement stmt)throws SQLException{}:此方法有重载(共3个),可以关闭Connection/Statement/ResultSet.
         public static void closeQuietly(Connection conn,Statement stmt,ResultSet rs){}:关闭资源,避免异常,此方法有重载(共4个),可以一次关闭3个,也可以分别关闭.

public static void commitAndClose(Connection conn)throws SQLException{}:Commits a Connection then closes it, avoid closing if null.
public static void commitAndCloseQuietly(Connection conn){}:Commits a Connection then closes it, avoid closing if null and hide any SQLExceptions that occur.

public static boolean loadDriver(ClassLoader classLoader,String driverClassName){}:Loads and registers a database driver class. If this succeeds, it returns true, else it returns false.有重载,可以直接传入driverClassName.

public static void rollback(Connection conn)throws SQLException{}:Rollback any changes made on the given connection.
         public static void rollbackAndClose(Connection conn)throws SQLException{}:Performs a rollback on the Connection then closes it, avoid closing if null.
         public static void rollbackAndCloseQuietly(Connection conn){}:Performs a rollback on the Connection then closes it, avoid closing if null and hide any SQLExceptions that occur.
     7.代码演示:导包mysql-connector-java-5.1.39-bin.jar,commons-dbutils-1.6.jar,c3p0-0.9.1.2.jar(使用了前面自定义的MyC3P0工具类)

  1 //定义一个类,要使用到BeanHandler类

  2 public class Vegetables {

  3      private int id;

  4      private String name;

  5      //空参构造--Eclipse快捷键:alt+shift+c

  6      public Vegetables() {

  7          super();

  8      }

  9      //满参构造--Eclipse快捷键:alt+shift+o

 10      public Vegetables(int id, String name) {

 11          super();

 12          this.id = id;

 13          this.name = name;

 14      }

 15      //覆写toString--Eclipse快捷键alt+shift+s

 16      @Override

 17      public String toString() {

 18          return "Vegetables [id=" + id + ", name=" + name + "]";

 19      }

 20      //getter/setter--Eclipse快捷键alt+shift+r

 21      public int getId() {

 22          return id;

 23      }

 24      public void setId(int id) {

 25          this.id = id;

 26      }

 27      public String getName() {

 28          return name;

 29      }

 30      public void setName(String name) {

 31          this.name = name;

 32      }

 33  }

 34

 35 import huguangqin.com.cnblogs_MyC3P0Utils.MyC3P0Utils;//使用了前面自定义的工具类

 36 import java.util.List;

 37  import org.apache.commons.dbutils.QueryRunner;

 38  import org.apache.commons.dbutils.handlers.BeanHandler;

 39  import org.apache.commons.dbutils.handlers.BeanListHandler;

 40  import org.apache.commons.dbutils.handlers.ScalarHandler;

 41

 42 public class Demo {

 43      @SuppressWarnings("all")//压制黄线警告

 44     public static void main(String[] args) throws Exception {

 45          // 获取QueryRunner对象

 46         QueryRunner qr = new QueryRunner(MyC3P0Utils.getDataSource());

 47          // 插入数据

 48         String inertSQL = "INSERT INTO dbutil(id,name) VALUES(?,?)";

 49          int i1 = qr.update(inertSQL, null, "白菜");

 50          int i2 = qr.update(inertSQL, null, "豆腐");

 51          int i3 = qr.update(inertSQL, null, "磨菇");

 52          System.out.println(i1 + i2 + i3);

 53

 54         // 修改

 55         String updateSQL = "UPDATE dbutil SET name = ? WHERE id = 1";

 56          int i4 = qr.update(updateSQL, "小白菜");

 57          System.out.println(i4);

 58

 59         // 查询1--ScalarHandler

 60          String querySQL = "SELECT name FROM dbutil WHERE name Like '___'";

 61          // 定义容器接收 ScalarHandler

 62          ScalarHandler sh = new ScalarHandler();

 63          String s = qr.query(querySQL, sh);

 64          System.out.println(s);// 只返回一个值

 65

 66         // 查询2--BeanHandler

 67          String querySQL2 = "SELECT * FROM dbutil";

 68          BeanHandler bh = new BeanHandler(Vegetables.class);

 69          Vegetables v = qr.query(querySQL2, bh);

 70          System.out.println(v);// 只返回一个实例对象

 71

 72         // 查询3--BeanListHandler

 73          BeanListHandler blh = new BeanListHandler(Vegetables.class);

 74          List<Vegetables> list = qr.query(querySQL2, blh);// 返回List

 75          for (Vegetables v1 : list) {

 76              System.out.println(v1);

 77          }

 78          // 删除

 79         String deleteSQL = "DELETE FROM dbutil";

 80          int i5 = qr.update(deleteSQL);

 81          System.out.println(i5);

 82      }

 83  }

 84

巴特西

DataSource--DBCP--C3P0--DBUtils

最新文章

热门文章