dbcp连接池的一些方法

Posted 2020-10-19 zhangzonghua

　　创建连接

// 简写版： 
Connection conn =null;
         Statement st =null;
        conn = DBCP.getConnection();
            st=conn.createStatement();

 

1.批处理 addBatch（）

　　可以将多个操作数据库的字符串集中处理

　　　　String sql1="select ..... ";

　　　　String sql2="select ..... ";

　　　　..............

　　　　st.addBatch(sql1);

　　　　st.addBatch(sql2);

　　　　..............

　　　　st.executeBatch(); //集中处理

　　　　st.clearBatch();// 最好及时清理，否则字符串仍留在addBatch里面

2.事物管理 setAutoCommit(boolean);

　　某些逻辑必须在一个是事务完成：通过事务管理可以让多个逻辑在一个事务完成。

　　事物特性: ACID

　　　　Atomicty 原子性：事务必须是原子工作单元，数据的修改要么完全执行，要么全都不执行。

　　　　 Consistency 一致性: 事务完成时，必须所有数据都保持一致的状态。

　　　　Isolation 隔离性 :由并发事务所作修改必须与其他并发事务所作修改隔离。
　　　　 Durability 持久性: 事务完成后，它对系统的影响是永久性的。

　　conn.setAutoCommit( false ); //关闭自动提交，默认是true

　　　　st.executeUpdate(sql1);

　　　　st.executeUpdate(sql2);

　　　　　　conn.commit(); //手动提交，作用是操作sql1和sql2都执行，或者都不执行

3.preparedStatement :预编译的,可以有效防止注入式攻击

　　String sql="select * from emp_xx where ename = upper(?) and sal > ?";

　　　　Connection conn=DBCP.getConnection();
　　　　PreparedStatement p=conn.prepareStatement(sql);
　　　　p.setString(1, "scott");
　　　　p.setDouble(2, 1000.0);
　　　　ResultSet rs=p.executeQuery();

4.结果集

@Test
public void test8(){
    String sql ="select * from emp_xx";
    Connection conn=null;
    ResultSet rs=null;
    try {
        conn=DBCP.getConnection();
        PreparedStatement ps = conn.prepareStatement(sql);
        rs=ps.executeQuery();
        ResultSetMetaData meta =rs.getMetaData(); //获取元数据集
        int number= meta.getColumnCount();//获取结果集里的列的数量
        System.out.println(meta.getColumnTypeName(1));//获取某一列的类型  列的序号从1开始数
        for (int i = 1; i <=number; i++) {
            String columName=meta.getColumnName(i);//遍历获取结果集里的所有列名
            System.out.println(columName);
        }
        
    } catch (SQLException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
}

5.可滚动结果集

@Test
public void test9(){
    String sql ="select ename,sal from emp_xx order by sal";
    Connection conn=null;
    ResultSet rs=null;
        try {
            conn=DBCP.getConnection();
            //如果要创建可滚动结果集，statement 或者prepareStatement 创建有所不同：
//            Statement stmt = conn.createStatement(type,concurrney);
//            PreparedStatement ps = conn.prepareStatement(sql,type,concurrney);
            /**
             * 其中 type 取值：
             *     TYPE_FORWARD_ONLY: 默认，只能向下读取
             *  TYPE_SCROLL_INSENSTIVE :  可滚动，不感知数据变化
             *  TYPE_SCROLL_SENSTIVE ：可滚动，感知数据变化
             *  其中 concurrency:
             *  CONCUR_READ_ONLY: 只读，不能更新
             *  CONCUR_UPDATABLE: 可以更新的结果集
             */
            Statement stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,
                    ResultSet.CONCUR_UPDATABLE);
             rs=stmt.executeQuery(sql);
             /**
              * 移动指针的常用方法 :
              * first :指针移动到第一条
              * last :指针移动到最后一条
              * beforeFirst:
              * afterLast:
              * isFirst: 判断是否指向第一条
              * isLast:是否是最后一条
              * isbeforeFirst:
              * isafterLast:
              * relative :移动到当前指针的相对位置
              * next :移动到下一条
              * previous:移动到前一条
              * absolute:移动到绝对位置
              */
             //更新结果集数据：
             rs.absolute(3);// 指针移到第3条记录
             rs.updateDouble(2, 2000);//更新第二列数据 变成1555
//             rs.updateRow();//更新数据源数据
             rs.first();
             while(rs.next()){
                 System.out.print(rs.getString("ename")+" ");     
                 System.out.println(rs.getString("sal"));
             }
            
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            if(conn!=null){
                try {
                    conn.close();
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
        }
        
}