原文连接:http://www.yiidian.com/dbutil...html
org.apache.commons.dbutils.BeanListHandler
是ResultSetHandler接口的实现,并负责ResultSet结果级的全部记录转换成JavaBean的List集合。此类是线程安全的。java
List<Customer> custList= queryRunner.query(conn, "SELECT * FROM customer", resultHandler);
package com.yiidian.domain; /** * 一点教程网 - http://www.yiidian.com */ public class Customer { private Integer id; private String name; private String gender; private String telephone; private String address; public Integer getId() { return id; } public void setId(Integer id) { this.id = id; } public String getName() { return name; } public void setName(String name) { this.name = name; } public String getGender() { return gender; } public void setGender(String gender) { this.gender = gender; } public String getTelephone() { return telephone; } public void setTelephone(String telephone) { this.telephone = telephone; } public String getAddress() { return address; } public void setAddress(String address) { this.address = address; } }
MainApp:mysql
package com.yiidian.dbutils; import com.yiidian.domain.Customer; import org.apache.commons.dbutils.AsyncQueryRunner; import org.apache.commons.dbutils.DbUtils; import org.apache.commons.dbutils.QueryRunner; import org.apache.commons.dbutils.ResultSetHandler; import org.apache.commons.dbutils.handlers.BeanHandler; import org.apache.commons.dbutils.handlers.BeanListHandler; import java.sql.*; import java.util.Arrays; import java.util.List; import java.util.concurrent.Executors; import java.util.concurrent.Future; import java.util.concurrent.TimeUnit; /** * 一点教程网 - http://www.yiidian.com */ public class MainApp { // 驱动程序 static final String JDBC_DRIVER = "com.mysql.jdbc.Driver"; // URL链接 static final String DB_URL = "jdbc:mysql://localhost:3306/test"; //数据库信息 static final String USER = "root"; static final String PASS = "root"; public static void main(String[] args) throws SQLException { Connection conn = null; QueryRunner queryRunner = new QueryRunner(); DbUtils.loadDriver(JDBC_DRIVER); conn = DriverManager.getConnection(DB_URL, USER, PASS); ResultSetHandler<List<Customer>> resultHandler = new BeanListHandler<Customer>(Customer.class); try { List<Customer> custList = queryRunner.query(conn, "SELECT * FROM customer", resultHandler); for(Customer customer: custList ) { System.out.print("编号: " + customer.getId()); System.out.print(", 用户名: " + customer.getName()); System.out.print(", 性别: " + customer.getGender()); System.out.print(", 联系电话: " + customer.getTelephone()); System.out.println(", 住址: " + customer.getAddress()); } } finally { DbUtils.close(conn); } } }
欢迎关注个人公众号::一点教程。得到独家整理的学习资源和平常干货推送。
若是您对个人系列教程感兴趣,也能够关注个人网站: yiidian.com