package cn.zhouzhou;

import java.io.IOException;

import java.io.InputStream;

import java.sql.Connection;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.util.Properties;

import javax.sql.DataSource;

import com.alibaba.druid.pool.DruidDataSource;

import com.alibaba.druid.pool.DruidDataSourceFactory;

import com.mchange.v2.c3p0.ComboPooledDataSource;

/*

 *一、Druid连接池？

 *         和之前的c3p0一样，连接池。

 *         阿里的产品。

 *

 *二、怎么用？

 *

 *         1.导包

 *             将【druid-1.0.9 jar】导入到lib目录中。

 *

 *         2.定义配置文件 .properties 仅此一种格式。

 *             1.【druid.properties】可以放在任意位置。------------------------->里面的数据库  修改成自己要用的！

 *             
　　　　　　 3.加载文件？　

 *             Properties pro01=new Properties();

 *             InputStream in01=Druid连接池.class.getClassLoader().getResourceAsStream("druid.properties");

 *             pro01.load(in01);

 *

 *         4.获得连接池对象

 *             DataSource da01=DruidDataSourceFactory.createDataSource(pro01);

 *

 *         5.获取连接

 *             Connection con01=da01.getConnection();

 *

 */

public class Druid连接池 {

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

        Properties pro01=new Properties();//1.加载文件

        InputStream in01=Druid连接池.class.getClassLoader().getResourceAsStream("druid.properties");//2.通过流的方式获取文件

        pro01.load(in01);

        DataSource da01=DruidDataSourceFactory.createDataSource(pro01);//3.连接池对象

        Connection con01=da01.getConnection();//4.获取连接

        System.out.println(con01);//4.打印地址，验证是否连接成功

        String sql01="select * from shop";

        PreparedStatement pr01=con01.prepareStatement(sql01);

        ResultSet rs01=pr01.executeQuery();

        while (rs01.next()) {

            System.out.println(rs01.getInt(1)+"  "+rs01.getString(2));

        }

        in01.close();            //关闭流

    }

}

package JdbcUtils;

import java.io.IOException;

import java.sql.Connection;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

import java.util.Properties;

import javax.sql.DataSource;

import com.alibaba.druid.pool.DruidDataSourceFactory;

/*

 * 封装一个Druid的工具类 Jdbc

 *

 */

public class Jdbc {

    private static DataSource ds;    //1.定义成员变量 DataSource

    static{

        try

        {    //2.加载配置文件 获得连接池

            Properties pro01=new Properties();

            pro01.load(Jdbc.class.getClassLoader().getResourceAsStream("druid.properties"));

            ds=DruidDataSourceFactory.createDataSource(pro01);

        } catch (Exception e) {

            e.printStackTrace();

        }

    }

    public static Connection getConnection() throws SQLException{    //获得连接

        return ds.getConnection();

    }

    public static void  close(Statement start,Connection con) {    //释放资源

        if (start!=null) {

            try {

                start.close();

            } catch (SQLException e) {

                e.printStackTrace();

            }

        }

        if (con!=null) {

            try {

                con.close();

            } catch (SQLException e) {

                e.printStackTrace();

            }

        }

    }

    public static void  close(ResultSet rs,Statement start,Connection con) {    //重载  继续释放资源。

        if (rs!=null) {

            try {

                rs.close();

            } catch (SQLException e) {

                e.printStackTrace();

            }

        }

        if (start!=null) {

            try {

                start.close();

            } catch (SQLException e) {

                e.printStackTrace();

            }

        }

        if (con!=null) {

            try {

                con.close();

            } catch (SQLException e) {

                e.printStackTrace();

            }

        }

    }

}

package cn.zhouzhou;

import java.sql.Connection;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

import JdbcUtils.Jdbc;

/*

 * 测试我们写的封装 jdbc工具类

 *

 */

public class Text01 {

    public static void main(String[] args) {

        Connection con01=null;

        PreparedStatement ps=null;

        try {

             con01=Jdbc.getConnection();//获得连接

             String sql01="insert into shop values(999,?,?,'刚把对！')";//定义SQL语句 占位子节符    在shop中 添加一条数据

             ps=con01.prepareStatement(sql01); //获得接口 执行平台

             ps.setString(1, "haha"); //设置键值对

             ps.setDouble(2, 66666);

             int i=ps.executeUpdate();//执行SQL语句

             System.out.println(i);

        } catch (SQLException e)

        {

            e.printStackTrace();

        }finally{

            Jdbc.close(ps, con01);

        }

    }

}