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 { } }