本文共 5297 字，大约阅读时间需要 17 分钟。
public Admin_User login(Admin_User admin_User) { QueryRunner queryRunner = new QueryRunner(JDBCUtils.getDataSource()); String sql ="select * from admin_user where userid=? and passwd=?"; Admin_User existUser; try{ existUser=queryRunner.query(sql, new BeanHandler<Admin_User>(Admin_User.class),admin_User.getUserId(),admin_User.getPasswd()); }catch(SQLException e){ e.printStackTrace(); throw new RuntimeException("用户登录失败"); } return existUser; }
public List<Stb_Upgrade_Rule> getList(Stb_Upgrade_Rule stb_Upgrade_Rule) {//List
QueryRunner queryRunner = new QueryRunner(JDBCUtils.getDataSource());
String sql ="select * from stb_upgrade_rule";
List<Stb_Upgrade_Rule> ruleList = new ArrayList<Stb_Upgrade_Rule>();
try{
ruleList=(List<Stb_Upgrade_Rule>) queryRunner.query(sql, new BeanListHandler<Stb_Upgrade_Rule>(Stb_Upgrade_Rule.class));//
}catch(SQLException e){
e.printStackTrace();
throw new RuntimeException("获取规则列表失败");
}
return ruleList;
}
-------------------------------------------------------------------------------------------------------------------------------------------------------------------
相继学习了JDBC和操作之后，我们明显感到编写JDBC代码并非一件轻松的事儿。为了帮助我们更高效的学习工作，从JDBC的繁重代码中解脱出来，老佟给我们详尽介绍了一个简化JDBC操作的组件——DBUtils。我们今天主要学习了它所提供的两个类和一个接口。
组件下载地址：
DbUtils类(org.apache.commons.dbutils.DbUtils)主要负责装载驱动、关闭连接的常规工作。
1. close: 检查所提供的参数是不是NULL，如果不是的话，它们就关闭连接、声明和结果集。
2. CloseQuietly:避免连接、声明或结果集为NULL的情况被关闭。
3. CommitAndCloseQuietly(Connectionconn)：用来提交连接，然后关闭连接，并且在关闭连接时不向上抛出在关闭时发生的一些SQL异常。
4. LoadDriver(String driveClassName): 装载并注册JDBC驱动程序，如果成功就返回TRUE。
QreryRunner类(org.apache.commons.dbutils.QueryRunner)显著的简化了SQL查询，并与ResultSetHandler协同工作将使编码量大为减少。
1. query(Connection conn, String sql, Object[] params,ResultSetHandler rsh)：执行选择查询，在查询中，对象阵列的值被用来作为查询的置换参数。
2. query(String sql, Object[] params, ResultSetHandlerrsh)：方法本身不提供数据库连接，执行选择查询，在查询中，对象阵列的值被用来作为查询的置换参数。
3. query(Connection conn, String sql, ResultSetHandlerrsh)：执行无需参数的选择查询。
4. update(Connection conn, String sql, Object[]params)：被用来执行插入、更新或删除（DML）操作。
ResultSetHandler接口(org.apache.commons.dbutils.ResultSethandler)执行处理一个结果集对象，将数据转变并处理为任何一种形式，供其他应用使用。
1. Object handle (.sql.ResultSet .rs)：结果集（ResultSet）作为参数传入方法内，处理这个结果集，返回一个对象。
ArrayHandler ：将ResultSet中第一行的数据转化成对象数组 ArrayListHandler将ResultSet中所有的数据转化成List，List中存放的是Object[] BeanHandler ：将ResultSet中第一行的数据转化成类对象 BeanListHandler ：将ResultSet中所有的数据转化成List，List中存放的是类对象 ColumnListHandler ：将ResultSet中某一列的数据存成List，List中存放的是Object对象 KeyedHandler ：将ResultSet中存成映射，key为某一列对应为Map。Map中存放的是数据 MapHandler ：将ResultSet中第一行的数据存成Map映射 MapListHandler ：将ResultSet中所有的数据存成List。List中存放的是Map ScalarHandler ：将ResultSet中一条记录的其中某一列的数据存成Object 我们学习了此组件的两个类和一个接口以后，写了下列代码供参考。
import java.sql.Connection;
import java.sql.SQLException;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanListHandler;
public class TestQueryRunner {
public static void main(String[] args) throws SQLException {
// TODO Auto-generated method stub
//queryOracle();
update();
}
private static void update() throws SQLException{
QueryRunner runner = new QueryRunner();
Connection conn = DBManager.getConnection();
//删除非 manager 中工资 低于 5000 的员工
String sql = "UPDATE examstudent SET student_name = ? WHERE flow_id= ?";
Object [] params = new Object[]{"Jerry", 5000};
runner.update(conn, sql, params);
}
private static void insert() throws SQLException{
QueryRunner runner = new QueryRunner();
Connection conn = DBManager.getConnection();
//删除非 manager 中工资 低于 5000 的员工
String sql = "INSERT INTO examstudent(flow_id, type, id_card,exam_card, student_name, location, grade) VALUES(?, ?, ?, ?, ?, ?,?)";
Object [] params = new Object[]{5000, 6, "身份证", "准考证", "Tom", "北京",99};
runner.update(conn, sql, params);
}
private static void delete() throws SQLException{
QueryRunner runner = new QueryRunner();
Connection conn = DBManager.getConnection();
//删除非 manager 中工资 低于 5000 的员工
String sql = "delete from employees " +
"where employee_id not in " +
" (select distinct d.manager_id from departments d where d.manager_idis not null) " +
"and salary < ?";
System.out.println(sql);
Object [] params = new Object[]{5000};
runner.update(conn, sql, params);
}
private static void queryOracle() throws SQLException{
QueryRunner runner = new QueryRunner();
Connection conn = DBManager.getConnection();
// 中的别名可以别解析
String sql = "SELECT flow_id flowid, type, id_card idcard,exam_card examcard, student_name studentname, location, grade FROMexamstudent";
Object obj = runner.query(conn, sql, newBeanListHandler(ExamStudent.class));
System.out.println(obj);
}
private static void query() throws SQLException {
//1. 创建一个 QueryRunner 的实例
QueryRunner runner = new QueryRunner();
Connection conn = DBManager.getConnection();
String sql = "SELECT id, name, address, phone FROM customers WHEREname LIKE ?";
Class type = Customer.class;
Object [] params = new Object[]{"%%"};
//2. 查询操作
//conn: 查询需要的数据库连接, sql: 查询使用的 sql 语句, rsh: 如何转换查询得到的结果集, params:填补 sql 语句参数的数组
Object obj = runner.query(conn, sql, new BeanListHandler(type),params);
//System.out.println("^^" + obj);
sql = "SELECT flow_id flowid, type, id_card idcard, exam_cardexamcard, student_name studentname, location, grade FROMexamstudent";
type = ExamStudent.class;
obj = runner.query(conn, sql, newBeanListHandler(ExamStudent.class));
System.out.println(obj);
}
}
转载地址：http://wytti.baihongyu.com/