C3P0学习的学习

domain：只是定义一个javabean。

dao：对于数据库的操作，都放到dao层，也就是dao里面通常是对数据库的增、删、改、查等操作。

service：完成相应的业务逻辑处理，调用dao层。

servlet：完成界面请求、对界面进行跳转等等。servlet调用service层。

一、准备     

JAR包：

既然是连接数据库第一个最重要的就是数据库的驱动包mysql-connection-java-5.1.44-bin.jar      

接着就是C3P0-0.9.2.1.jar以及mchange-commons-java-0.2.3.4.jar

然后还少不了dbutils 使用的是commons-dbutils-1.7.jar   

一共是4个JAR包

二、配置 

配置数据库连接:

创建c3p0-config.xml的配置文件，里面包含连接数据库的信息

<?xml version="1.0" encoding="UTF-8"?>
<c3p0-config>
 <default-config>
 <property name="driverClass">com.mysql.jdbc.Driver</property>
 <property name="jdbcUrl">jdbc:mysql://localhost:3306/mybatis</property>
 <property name="user">root</property>
 <property name="password">123</property>
 <property name="acquireIncrement">5</property>
 <property name="initialPoolSize">10</property>
 <property name="minPoolSize">5</property>
 <property name="maxPoolSize">20</property>
 </default-config>
</c3p0-config>

创建C3P0Util.java 使用getDataSource()的对象获取数据库连接

package com.utils;

import java.sql.Connection;
import java.sql.SQLException;

import javax.sql.DataSource;

import com.mchange.v2.c3p0.ComboPooledDataSource;

public class C3P0Utils {
    private static ComboPooledDataSource dataSource=new ComboPooledDataSource("itheima");
    public static DataSource getDataSource(){
        return dataSource;
    }
    public static Connection getConnection(){
        try {
            return dataSource.getConnection();
        } catch (SQLException e) {            
            throw new RuntimeException(e);
        }
    }
}

 由于没有使用Mybatis的逆向工程，这里需要手动创建body.java 用于获取数据库表的所有列

package com.Domain;
public class body {
    private int id;
    private String notifyType;
    private String requestId;
    private String deviceId;
    private String gatewayId;
    private String service;

    public int getid() {
        return id;
    }
    public void setid(int id) {
        this.id = id;
    }
    public String getnotifyType(){
        return notifyType;
    
    }
    public void setnotifyType(String notifyType) {
        this.notifyType = notifyType;
    }
    public String getrequestId(){
        return requestId;
    
    }
    public void setrequestId(String requestId) {
        this.requestId = requestId;
    }
    public String getdeviceId(){
        return deviceId;
    
    }
    public void setdeviceIde(String deviceId) {
        this.deviceId = deviceId;
    }
    public String getgatewayId(){
        return gatewayId;
    
    }
    public void setgatewayId(String gatewayId) {
        this.gatewayId = gatewayId;
    }
    public String getservice(){
        return service;
    
    }
    public void setservice(String service) {
        this.service = service;
    }
}

 dao层DBUtils简化了JDBC的开发步骤，使得我们可以用更少量的代码实现连接数据库的功能。参考连接：https://blog.csdn.net/simonforfuture/article/details/90480147

DBUtils封装了JDBC的操作，核心功能如下：
Dbutils三个核心功能介绍

1、QueryRunner中提供对sql语句操作的API.

2、ResultSetHandler接口，用于定义select操作后，怎样封装结果集.

3、DbUtils类是一个工具类，定义了关闭资源与事务处理的方法

ResultSetHandler结果集处理类

package cn.simon.jdbc.demo03_DBUtils的使用;

import java.sql.SQLException;
import java.util.List;
import java.util.Map;

import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.ArrayHandler;
import org.apache.commons.dbutils.handlers.ArrayListHandler;
import org.apache.commons.dbutils.handlers.BeanHandler;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import org.apache.commons.dbutils.handlers.ColumnListHandler;
import org.apache.commons.dbutils.handlers.MapHandler;
import org.apache.commons.dbutils.handlers.MapListHandler;
import org.apache.commons.dbutils.handlers.ScalarHandler;

import cn.simon.jdbc.domain.Category;

/**
 *  DBUtils执行数据库查询操作
 *      1.QueryRunner(DataSource)
 *      2.query(String sql, ResultSetHandler<T> rsh, Object... params); // 主要执行查询
 */

public class DBUtilsDemo {
    public static void main(String[] args) throws SQLException {
        // TODO Auto-generated method stub

//        queryDemo01();
//        queryDemo02();
//        queryDemo03();
//        queryDemo04();
//        queryDemo05();
        queryDemo06();
//        queryDemo07();
//        queryDemo08();
    }
    
    // ArrayHandler处理类的使用
    public static void queryDemo01() throws SQLException{
        // 1.创建QueryRunner对象
        QueryRunner qr = new QueryRunner(C3P0Utils.getDataSource());
        // 2.执行查询
        Object[] objs = qr.query("select * from category where cid = ?", new ArrayHandler(), 1);
        for(Object o: objs){        // object[]中保存了object对象
            System.out.println(o);
        }
    }
    
    // ArrayListHandler
    public static void queryDemo02() throws SQLException{
        // 1.创建QueryRunner对象
        QueryRunner qr = new QueryRunner(C3P0Utils.getDataSource());
        // 2.执行查询
        List<Object[]> objs = qr.query("select * from category ", new ArrayListHandler());
        for (Object[] objects : objs) {
            System.out.println(objects[0]+"	"+objects[1]);
        }
    }
    
    // BeanHandler处理类的使用
    public static void queryDemo03() throws SQLException{
        // 1.创建QueryRunner对象
        QueryRunner qr = new QueryRunner(C3P0Utils.getDataSource());
        // 2.执行查询
        String sql = "select * from category";
        Category c = qr.query(sql, new BeanHandler<Category>(Category.class));
        System.out.println(c);
    }
    
    // BeanListHandler
    public static void queryDemo04() throws SQLException{
        // 1.创建QueryRunner对象
        QueryRunner qr = new QueryRunner(C3P0Utils.getDataSource());
        // 2.执行查询
        String sql = "select * from category";
        List<Category> c = qr.query(sql, new BeanListHandler<Category>(Category.class));
        for (Category category : c) {
            System.out.println(category);
        }
    }
    
    // ColumnListHandler处理类的使用
    public static void queryDemo05() throws SQLException{
        // 1.创建QueryRunner对象
        QueryRunner qr = new QueryRunner(C3P0Utils.getDataSource());
        // 2.执行查询
        String sql = "select * from category";
        List<Object> c = qr.query(sql, new ColumnListHandler<Object>("cname"));
        System.out.println(c);
    }
    
    // MapHandler处理类的使用
    public static void queryDemo06() throws SQLException{
        // 1.创建QueryRunner对象
        QueryRunner qr = new QueryRunner(C3P0Utils.getDataSource());
        // 2.执行查询
        String sql = "select * from category";
        Map<String, Object> map = qr.query(sql, new MapHandler());
        // 3.
        System.out.println(map);
    }
    
    // MapListHandler处理类的使用
    public static void queryDemo07() throws SQLException{
        // 1.创建QueryRunner对象
        QueryRunner qr = new QueryRunner(C3P0Utils.getDataSource());
        // 2.执行查询
        String sql = "select * from category";
        List<Map<String, Object>> maps = qr.query(sql, new MapListHandler());
        // 3.List
        System.out.println(maps);
    }
    
    // MapListHandler处理类的使用
    public static void queryDemo08() throws SQLException{
        // 1.创建QueryRunner对象
        QueryRunner qr = new QueryRunner(C3P0Utils.getDataSource());
        // 2.执行查询
        String sql = "select count(*) from category";
        Long count = qr.query(sql, new ScalarHandler<Long>());
        // 3.List
        System.out.println(count);
    }
       public  String  bodyvalue()  throws SQLException{
                 // 1.创建QueryRunner对象
                 QueryRunner qr = new QueryRunner(C3P0Utils.getDataSource());
                 // 2.执行查询（查询表中最后一句）
                 String sql = "select * from body order by id desc limit 1";
                 Map<String, Object> map =  qr.query(sql, new MapHandler());
                //通过转换成字符串用get方法获得键值对
                 String service = (String) map.get("service");
                 return service;
}