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      }

  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 

  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.likecs_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