zoukankan      html  css  js  c++  java
  • DBUtils

    DBUtils

    DBUtils:连接数据库对象----jdbc辅助方法的集合类,线程安全。

    作用:控制连接,控制驱动加载类。

    QueryRunner:SQL语句的操作对象,可以设置查询结果集的封装策略,线程安全。

     2:QueryRunner:SQL语句的操作对象,可以设置查询结果集的封装策略,线程安全。
          构造方法:
          (1)QueryRunner():创建一个与数据库无关的QueryRunner对象,后期再操作数据库的会后,需要手动给一个Connection对象,它可以手动控制事务。
                    Connection.setAutoCommit(false);     设置手动管理事务
                    Connection.commit();     提交事务
    
          (2)QueryRunner(DataSource ds):创建一个与数据库关联的queryRunner对象,后期再操作数据库的时候,不需要Connection对象,自动管理事务。
                    DataSource:数据库连接池对象。
    
          构造函数与增删改查方法的组合:
     QueryRunner()
           update(Connection conn, String sql, Object... params)
           query(Connection conn, String sql, ResultSetHandler<T> rsh, Object... params)
    
     QueryRunner(DataSource ds)     
           update(String sql, Object... params)
           query(String sql, ResultSetHandler<T> rsh, Object... params)
    

      

    DBUtils进行修改操作

        //1.创建QueryRunner的实现类
        QueryRunner queryRunner = new QueryRunner();
        @Test
        public void testQueryRunnerUpdate(){
       
    
            //2.使用其update方法
            String sql = "delete from account where id in(?,?)";
    
            Connection conn = null;
    
            try {
                conn = Methods.getConnection();
                //2.使用update方法
                queryRunner.update(conn,sql,12,13);
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
                Methods.release(null,conn,null);
            }
        }
    

      

    DBUtils进行查询操作

    (3)ResultSetHandle:封装数据的策略对象------将封装结果集中的数据,转换到另一个对象
    策略:封装数据到对象的方式(示例:将数据库保存在User、保存到数组、保存到集合)
    方法介绍:handle(ResultSet rs)

    QueryRunner的query方法的返回值取决于ResultSetHandler参数的handle方法的返回值

    //1.创建QueryRunner的实现类
        QueryRunner queryRunner = new QueryRunner();
    
        class MyResultSetHandler implements ResultSetHandler{
    
            @Override
            public Object handle(ResultSet resultSet) throws SQLException {
                List<Account> accounts = new ArrayList<>();
    
                while(resultSet.next()){
                    Integer id = resultSet.getInt(1);
                    String name = resultSet.getString(2);
                    String password = resultSet.getString(3);
                    Integer balance = resultSet.getInt(4);
    
                    Account account = new Account(id,name,password,balance);
                    accounts.add(account);
                }
                return  accounts;
            }
        }
    
        @Test
        public void testQueryRunnerQuery(){
            Connection conn = null;
    
            try {
                conn = Methods.getConnection();
                String sql = "select id,name,password,balance from account";
                Object obj = queryRunner.query(conn,sql,new MyResultSetHandler());
                System.out.println(obj);//xxx
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
                Methods.release(null,conn,null);
            }
        }
    }

      

     BeanHandler():获取一条记录

        /**
         * BeanHandler:把结果集的第一条记录转换为创建BeanHandler对象时传入的Class参数对应的对象。
         */
        @Test
        public void testBeanHandler(){
            Connection conn = null;
    
            try {
                conn = Methods.getConnection();
                String sql = "select * from account where id>=?";
                Account account = (Account) queryRunner.query(conn,sql,new BeanHandler(Account.class),5);
                System.out.println(account);
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
            }
        }
    

    BeanListHandler:获取一组记录

        /**
         * BeanListHandler:把结果集转为一个List,该List不为null,但可能为空集合(size(() 方法返回0)
         * 若SQL语句的确能够查询到记录,list中存放创建BeanListHandler传入的Class对象对应的对象。
         */
    
        @Test
        public void testBeanListHandler() {
            Connection conn = null;
    
            try {
                conn = Methods.getConnection();
                String sql = "select * from account";
                List<Account> accounts = (List<Account>) queryRunner.query(conn, sql, new BeanListHandler(Account.class));
                System.out.println(accounts);
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
            }
        }
    

      

    MapHandler

        /**
         * MapHandler:返回SQL对应的第一条记录对应Map对象
         * 键:SQL查询的列名(不是列的别名),值:列的值
         */
        @Test
        public void testMapHandler(){
            Connection conn = null;
    
            try {
                conn = Methods.getConnection();
                String sql = "select * from account";
                Map<String,Object> result =  queryRunner.query(conn, sql, new MapHandler());
                System.out.println(result);
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
            }
        }
    

    MapListHandler

     /**
         * MapListHandler:将结果集转为一个Map的List
         * Map对应查询一条记录:键:SQL查询的列名(不是列的别名),值:列的值
         * 而MapListHandler:返回多条记录对应的Map的集合
         */
        @Test
        public void testMapListHandler(){
            Connection conn = null;
    
            try {
                conn = Methods.getConnection();
                String sql = "select * from account";
                List<Map<String,Object>> result =  queryRunner.query(conn, sql, new MapListHandler());
                System.out.println(result);
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
            }
       }

    ScalarHandler

        /**
         * ScalarHandler:把结果集转为一个数值(可以是任意基本数据类型和字符串,Date等)返回
         */
        @Test
        public void testScalarHandler(){
            Connection conn = null;
    
            try {
                conn = Methods.getConnection();
                String sql = "select name from account where id =?";
                Object result =  queryRunner.query(conn, sql, new ScalarHandler(),5);
                System.out.println(result);
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
            }
        }
    

      

  • 相关阅读:
    Vue.directive()方法创建全局自定义指令
    vue中通过ref属性来获取dom的引用
    v-cloak指令
    v-if和v-show
    vue中的v-on事件监听机制
    vue指令v-model
    vue中v-for系统指令的使用
    从零开始在虚拟机中搭建一个4个节点的CentOS集群(一)-----下载及配置CentOS
    MySQL-数据库创建与删除
    MySQL-PREPARE语句
  • 原文地址:https://www.cnblogs.com/yangHS/p/10846580.html
Copyright © 2011-2022 走看看