jdbc与连接池使用

JDBC使用

• 导包

将mysql-connector-java.jar导入项目

• 注册驱动

    Class.forName("com.mysql.jdbc.Driver");//推荐
    DriverManager.registerDriver(new com.mysql.jdbc.Driver());//不推荐，此方法会注册两次，硬编码不利于维护
  

• 获取链接

    Connection conn=DriverManager.getConnection("jdbc:mysql:localhost:3306/web08","root","root");
    //参数一为
    //jdbc:  mysql:    localhost:  3306  /  web08     ?   useUnicode=true   characherEncoding=UTF8
    //协议  数据库类型      地址      端口     数据库名称     使用Unicode字符集        使用UTF8编码
    //参数二为登录账号
    //参数三位登录密码
    //返回值为连接对象
  

• 创建执行sql语句的对象

  Statement会有注入漏洞，不推荐使用

    Statement stmt=conn.createStatement();
  

  预处理对象PreparedStatement，解决了注入漏洞，提高可读性，维护性， 效率

    PreparedStatement psmt=conn.prepareStatement(sql);
  

• 执行sql语句

1. 使用Statement

    
    > 这里的sql语句中参数必须拼接好
    
        

2. 使用PreparedStatement

    > 这里的sql语句参数用 ? 当占位符，再用以下方法设置

        //设置参数
        psmt.setString(int index,String value);//参数一为位置从1开始，参数二为值

• 获取结果中的数据

    ResultSet executeQuery("sql语句");//执行select(DQL)
    int executeUpdate("sql语句");//执行insert update delete(DML),返回影响行数
    
    boolean execute(String sql);//执行DML返回true,执行其他返回false
        如果返回true使用getResultSet()返回结果集
        如果返回false使用getUpdateCount()获得影响行数
  
    //批处理
    addBatch(String sql);
    clearBatch();
    executeBatch();
  
    //ResultSet有以下方法
    boolean next();//有数据会返回true
    Object getObject(int col);//获得任意对象
    String getString(int col);//获得字符串
    int getInt(int col);//获得整形
    double getDouble(int col);//获得双精度浮点型
  

• 释放资源

  先得到的后关闭

    rs.close();
    stmt.close();
    con.close();
  

• 事务

    Connection#setAutoCommit(boolean isAutoCommit);//关闭事务自动提交
    
    Connection#commit();//提交事务
  
    Connection#rollback();//回滚事务， 一般放在异常内
  

连接池

自定义连接池

• 继承 javax.sql.DataSource

• 创建连接池

    LinkedList<Connection> pool =new LinkedList<>();
  

  这里使用LinkedList因为连接池增删多，查询少

• 初始化链接池

    static {
        for(...){
            pool.add(conn)//这里会循环获取Connection并且放入链接池中
        }
    }
  

• 获取连接对象

    @Override
    Connection getConnection(){
        if(pool.size()==0){
            //给连接池增加Connection
        }
        
        //返回连接池内的Connection
        return pool.remove(0);
    }
  

• 归还连接对象

    void backConnection(Connection conn){
        pool.add(conn);
    }
  

C3P0连接池

需要一个配置文件(xml,properties)，然后一行代码即可获取连接池对象

• 导包 c3p0-0.9.1.2.jar

• 创建c3p0-config.xml配置文件，位于src下或者classpath下

    <?xml version="1.0" encoding="UTF-8"?>
    <c3p0-config>
    
      <default-config>
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <property name="jdbcUrl">jdbc:mysql:///web_07</property>
        <property name="user">root</property>
        <property name="password">123</property>
        <property name="initialPoolSize">5</property>
        <property name="maxPoolSize">20</property>
      </default-config>
      
      <named-config name="test"> 
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <property name="jdbcUrl">jdbc:mysql:///web_07</property>
        <property name="user">root</property>
        <property name="password">123</property>
      </named-config>
      
    
    </c3p0-config>
  

• 使用

    ComboPooledDataSource dataSource = new ComboPooledDataSource(String name);//参数不填写会使用配置文件中的default-config，填写则会寻找配置文件中对应的
  

DBCP连接池

需要一个配置文件(properties),并且自己创造工具类，将properties文件读取并放入BaseicDataSourceFactory#createDataSource中创建连接池，提供连接池对象方法以及连接对象方法

• 导包commons-dbcp-1.4.jar 以及 commons-pool-1.5.6.jar

• 创建db.properties

    driver=com.mysql.jdbc.Driver
    url=jdbc:mysql://localhost:3306/web08?useUnicode=true&characterEncoding=utf8
    username=root
    password=root
  

• 写一个DBCPUtils工具类加载db.properties文件

    static DataSource dataSource;
    static{
        InputStream is = DBCPUtils.class.getClassLoader().getResourceAsStream("db.properties");
        Properties props = new Properties();
        props.load(is);
        dataSource = BaseicDataSourceFactory.createDataSource(props);//核心，DBCP仅提供能接受 Properties 对象的构造
    }
  
    DataSource getDataSource(){return dataSource;}
    
    Connection getConnection(){
        return dataSource.getConnection();
    }