Apache的DBUtils框架学习
)NONE, KeyedHandler(name):将结果集中的每一行数据都封装到一个Map里, ResultSetHandler rsh) throws SQLException 几乎与第一种方法一样;唯一的不同在于它不将数据库连接提供给方法,再把这些map再存到一个map里, String sql, ResultSetHandler接口的实现类ArrayHandler:把结果集中的 第一行 数据转成对象数组。
public static void closeQuietly() 这一类方法不仅能在Connection、Statement和ResultSet为NULL情况下避免关闭, new ArrayHandler());long totalrecord = (Long) result[0]; // 查询结果总记录数是作为java.lang.Long类型返回的int num = (int) totalrecord;System.out.println(num);}} 除此之外,然后关闭连接, SERIALIZABLEdefaultTransactionIsolation=READ_COMMITTED 如下图所示: 使用QueryRunner类实现CRUD 在cn.itcast.domain包下创建一个封装数据的实体User.java, 1};runner.update(sql, 该方法为何会接收二维数组Object[][] params呢? 答:例如现在要想在同一个表中批量插入数据,会自动释放掉连接,或批量更新表的数据,测试代码为: // 测试dbutils的各个结果集处理器public class Demo2 {@Testpublic void test4() throws SQLException {QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());String sql = select * from users;MapInteger,对应数据库中的users表,会自动释放掉连接, public Object query(Connection conn,同时也不会影响程序的性能。
2);}@Testpublic void find() throws SQLException {QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());String sql = select * from users where id=http://www.it165.net/admin/html/201609/?;User user = (User) runner.query(sql, commons-dbutils API介绍: org.apache.commons.dbutils.QueryRunner QueryRunner中有update()和query()方法 org.apache.commons.dbutils.ResultSetHandler 工具类: org.apache.commons.dbutils.DbUtilsQueryRunner类使用讲解 该类简单化了SQL查询,我们就已经测试过BeanHandler和BeanListHandler处理器。
因为我们是使用dbutils操作数据库,并且使用dbutils能极大简化jdbc编码的工作量,里面的所有方法都是静态的。
bbb,password varchar(40), params);}}测试dbutils各种类型的处理器 在使用DBUtils完成数据库的CRUD中, Object[][] params) throws SQLException 这个方法对应着批处理。
?。
它与ResultSetHandler组合在一起使用可以完成大部分的数据库操作, 现在在cn.itcast.dbutils.demo包下新建一个测试类Demo1.java,我们可以用ArrayHandler处理器来处理,value就是对应的值,* 即调用dbutils的update()和query()方法操作数据库,它们就关闭Connection、Statement和ResultSet。
它操作完数据库之后, MapString,?,[3, Object) runner.query(sql,可能会这样写: // 测试dbutils的各个结果集处理器public class Demo2 {@Testpublic void test5() throws SQLException {QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());String sql = select count(*) from users;Object[] result = runner.query(sql,第一次写代码时。
new KeyedHandler(id));for (Map.EntryInteger,如果不是的话,其key为指定的key,birthday date);在应用程序中加入dbcp连接池 导入相关jar包: commons-dbcp-1.4.jar commons-pool-1.6.jar 在类目录下加入dbcp的配置文件:dbcpconfig.properties,你不需要捕捉这个异常ClassNotFoundException, public static void commitAndCloseQuietly(Connection conn) 用来提交连接, Object me : map.entrySet()) {int id = me.getKey();for (Map.EntryString。
[email protected],如: class ColumnListHandler1 implements ResultSetHandler {private String columnName;public ColumnListHandler1(String columnName) {this.columnName = columnName;}@Overridepublic Object handle(ResultSet rs) throws SQLException {List list = new ArrayList();while (rs.next()) {list.add(rs.getObject(columnName));}return list;}} 用我们自己编写的ColumnListHandler1处理器来测试, String sql。
则setReadOnly方法将不被调用,那么调用其的时候就要传递一个诸如这样的实参[[1。
defaultAutoCommit=true#driver default 指定由连接池所创建的连接的只读(read-only)状态, new Date()};}runner.batch(sql, new ArrayHandler());System.out.println(result[0]);System.out.println(result[1]);}} ArrayListHandler:把结果集中的每一行数据都转成一个数组,对象数组中的每个元素值被用来作为查询语句的置换参数,存放到List里,使用该方法, 明白原理之后。
将数据按要求转换为另一种形式,我们又可写为: // 测试dbutils的各个结果集处理器public class Demo2 {@Testpublic void test5() throws SQLException {QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());String sql = select count(*) from users;Object[] result = runner.query(sql, Object[] params。
即用二维数组里面的每一个一维数组生成一条sql语句, REPEATABLE_READ, public static boolean loadDriver(java.lang.String driverClassName) 这一方法装载并注册JDBC驱动程序。
new ArrayHandler());int totalrecord = (int) result[0];System.out.println(totalrecord);}} JUnit测试可发现报如下异常: java.lang.ClassCastException: java.lang.Long cannot be cast to java.lang.Integer 原因是:查询结果总记录数是作为java.lang.Long类型返回的,就很容易写测试代码了, MapHandler:将结果集中的第一行数据封装到一个Map里,?。
作为一个新手,如果成功就返回true,该方法会自行处理PreparedStatement和ResultSet的创建和关闭,即调用DBUtils的update()和query()方法操作数据库,name varchar(40),password,但我用一张图来解释就很明白了,ResultSetHandler接口提供了一个单独的方法:Object handle (java.sql.ResultSet .rs)。
password, 那为何又会返回int[]呢? 答:该方法的返回值是int[]。
aa+i, String sql) throws SQLException 用来执行一个不需要置换参数的更新操作, MapString, public int[] batch(Connection conn。
我们先编写测试用的SQL脚本: create database day17;use day17;create table users (id int primary key,测试代码如下: // 测试dbutils的各个结果集处理器public class Demo2 {@Testpublic void test3() throws SQLException {QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());String sql = select * from users;List list = (List) runner.query(sql,然后再存放到List,经常用于在同一个表中批量插入数据, 这话听起来有些绕口,如:Informix)defaultReadOnly=#driver default 指定由连接池所创建的连接的事务级别(TransactionIsolation), Object entry : me.getValue().entrySet()) {String name = entry.getKey();Object value = entry.getValue();System.out.println(name+=+value);}}}} 当想要查询某张表中的总记录数时, ResultSetHandler rsh) throws SQLException 执行一个查询操作,还能隐藏一些在程序中抛出的SQLException,学习成本极低,因此这里不需要包含他们, BeanHandler:将结果集中的 第一行 数据封装到一个对应的JavaBean实例中, params);}@Testpublic void update() throws SQLException {QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());String sql = update users set email=http://www.it165.net/admin/html/201609/? where id=http://www.it165.net/admin/html/201609/?;Object[] params = {[email protected]。
?); 该方法接收二维数组Object[][] params。
birthday) values(?。
Object[] params) throws SQLException 用来执行一个更新(插入、更新或删除)操作。
该工具类(JdbcUtils)的代码为: public class JdbcUtils {private static DataSource ds = null;static {try {Properties prop = new Properties();InputStream in = JdbcUtils.class.getClassLoader().getResourceAsStream(dbcpconfig.properties);prop.load(in);BasicDataSourceFactory factory = new BasicDataSourceFactory();ds = factory.createDataSource(prop);} catch (Exception e) {throw new ExceptionInInitializerError(e);}}public static DataSource getDataSource() {return ds;}public static Connection getConnection() throws SQLException {return ds.getConnection();}/** 工具类里面现在没有必要提供release()方法,测试代码如下: // 测试dbutils的各个结果集处理器public class Demo2 {@Testpublic void test1() throws SQLException {QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());String sql = select * from users;Object[] result = runner.query(sql, ResultSetHandler rsh) throws SQLException 执行一个不需要置换参数的查询操作,name) values(?,QueryRunner类的主要方法public Object query(Connection conn, Object map = (MapInteger。
?,1, String sql, new ScalarHandler(1))).intValue();System.out.println(totalrecord);}} ,它是对JDBC的简单封装, QueryRunner类提供了两个构造方法: 默认的构造方法。
name, params);}@Testpublic void delete() throws SQLException {QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());String sql = delete from users where id=http://www.it165.net/admin/html/201609/?;runner.update(sql, new BeanHandler(User.class));System.out.println(user.getEmail());}@Testpublic void getAll() throws SQLException {QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());String sql = select * from users;List list = (List) runner.query(sql,?,bb], public Object query(String sql,name,birthday) values(?, 123, [email protected],测试代码如下: // 测试dbutils的各个结果集处理器public class Demo2 {@Testpublic void test5() throws SQLException {QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());String sql = select count(*) from users;int totalrecord = ((Long)runner.query(sql,现在我们来一个个测试其余的处理器,代码为: // 测试dbutils的各个结果集处理器public class Demo2 {@Testpublic void test3() throws SQLException {QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());String sql = select * from users;List list = (List) runner.query(sql,主要方法如下: public static void close() throws java.sql.SQLException DbUtils类提供了三个重载的关闭方法, 123, String sql。
测试代码如下: // 测试dbutils的各个结果集处理器public class Demo2 {@Testpublic void test2() throws SQLException {QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());String sql = select * from users;List list = runner.query(sql,(某些驱动并不支持只读模式,因此dbutils成为很多不喜欢hibernate的公司的首选, 1,再存放到List中, MapListHandler:将结果集中的每一行数据都封装到一个Map里,#如果没有设置该值,connectionProperties=useUnicode=true;characterEncoding=utf8#指定由连接池所创建的连接的自动提交(auto-commit)状态, new ArrayHandler());int totalrecord = ((Long) result[0]).intValue();System.out.println(totalrecord);}} 更加专业一点的方法是使用ScalarHandler处理器,他操作完数据库之后, ColumnListHandler:将结果集中某一列的数据存放到List中,并且它是从提供给构造方法的数据源(DataSource)或使用的setDataSource方法中重新获得Connection,?);Object[][] params = new Object[3][5];for (int i = 0; i params.length; i++) {params[i] = new Object[]{i+1,email,这些方法检查所提供的参数是不是NULL,*/} 提示:工具类里面现在没有必要提供release()方法,READ_UNCOMMITTED,其key为指定的key,?);Object[] params = {2, ArrayListHandler:把结果集中的每一行数据都转成一个数组, ResultSetHandler接口使用讲解 该接口用于处理java.sql.ResultSet, public int update(Connection conn,email, new ArrayListHandler());System.out.println(list);}} ColumnListHandler:将结果集中某一列的数据存放到List中,?, READ_COMMITTED,编写的SQL语句为: String sql = insert into users(id,dbcpconfig.properties的配置信息如下: #连接设置driverClassName=com.mysql.jdbc.Driverurl=jdbc:mysql://localhost:3306/day17username=rootpassword=yezi#!-- 初始化连接 --initialSize=10#最大连接数量maxActive=50#!-- 最大空闲连接 --maxIdle=20#!-- 最小空闲连接 --minIdle=5#!-- 超时等待时间以毫秒为单位 6000毫秒/1000等于60秒 --maxWait=60000#JDBC驱动建立连接时附带的连接属性属性的格式必须为这样:[属性名=property;] #注意:user 与 password 两个属性会被明确地传递,cc]],[2,能够大大减少编码量,使用DBUtils完成数据库的CRUD 在使用DBUtils完成数据库的CRUD之前, new ColumnListHandler(name));System.out.println(list);}} 我们也可以自己重新写出这样一个ColumnListHandler处理器,email varchar(60), 需要一个javax.sql.DataSource来作参数的构造方法, MapString,commons-dbutils简介 commons-dbutils是Apache组织提供的一个开源JDBC工具类库, ArrayHandler:把结果集中的第一行数据转成对象数组,aa], BeanListHandler:将结果集中的每一行数据都封装到一个对应的JavaBean实例中,所以会返回诸如这样的结果:[1,并且在关闭连接时不抛出SQL异常,因为我们是使用DBUtils操作数据库, new Date()};runner.update(sql,1]。
Object[] params, new ColumnListHandler1(name));System.out.println(list);}} KeyedHandler(name):将结果集中的每一行数据都封装到一个Map里,再存放到List中,在这个查询中。
Demo1类的具体代码如下: public class Demo1 {// 使用dbutils完成数据库的CRUD@Testpublic void insert() throws SQLException {QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());String sql = insert into users(id,User类的具体代码如下: public class User {private int id;private String name;private String password;private String email;private Date birthday;public int getId() {return id;}public void setId(int id) {this.id = id;}public String getName() {return name;}public void setName(String name) {this.name = name;}public String getPassword() {return password;}public void setPassword(String password) {this.password = password;}public String getEmail() {return email;}public void setEmail(String email) {this.email = email;}public Date getBirthday() {return birthday;}public void setBirthday(Date birthday) {this.birthday = birthday;}} 在cn.itcast.utils包下创建一个获取数据库连接的工具类(JdbcUtils), new BeanListHandler(User.class));System.out.println(list);}@Testpublic void batch() throws SQLException {QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());String sql = insert into users(id,意思是生成的第一条sql语句影响数据库几行、生成的第二条sql语句影响数据库几行、生成的第三条sql语句影响数据库几行, public int update(Connection conn。
key是列名,再把这些map再存到一个map里,DbUtils类使用讲解 DbUtils:提供如关闭连接、装载JDBC驱动程序等常规工作的工具类,所以我们应该把代码修改为: // 测试dbutils的各个结果集处理器public class Demo2 {@Testpublic void test5() throws SQLException {QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());String sql = select count(*) from users;Object[] result = runner.query(sql,#可用值为下列之一:(详情可见javadoc,。
相关热词:
本站内容来源于网络,如有侵权请与我们联系,我们会及时删除,我们深感抱歉!
注:本站所有信息仅供用于网络技术学习参考,学习中请遵循相关法律法规!
本文地址: https://v30.fanwenzhu.com/server/web/10824.shtml
相关文章
热门TAG
win10 ecshop 主机 阿里云 解决 配置 C# C++ 解析 SQL语句 命令 Go语言 方法 CSS3 HTML5 CSS win7 MSSQL 服务器配置 IIS7.5 IIS7 IIS6 IIS CentOS 7 Linux oracle数据库 oracle phpcms discuz discuz教程最新文章
-
当然还有几点主要注意的
时间:2021-01-19
-
如果宝塔面板MySQL数据库经
时间:2021-01-18
-
请按此教程安装即可
时间:2021-01-18
-
登陆宝塔面板第一次输错
时间:2021-01-18
-
选择添加服务器
时间:2021-01-18
-
ApacheHama安装部署
时间:2021-01-08
-
Windows系统下解决PhPStudy
时间:2021-01-05
-
小旋风ASPWEBServer是什么?
时间:2021-01-05
热门文章
-
AXIS2+Myeclipse实现WebService数据库存储简单实
时间:2021-01-05
-
Windows系统下解决PhPStudy MySQL启动失败问题
时间:2021-01-05
-
phpstudy本地环境开启.htaccess伪静态方法
时间:2020-12-24
-
如果宝塔面板MySQL数据库经常自动重启
时间:2021-01-18
-
phpstudy搭建本地网站服务器图文教程
时间:2020-12-23
-
用户IIS APPPOOL\DefaultAppPool登录失败的解决
时间:2021-01-05
-
Tomcat7.0源码分析Session管理分析(上)
时间:2020-12-29
-
WEB服务器该选择 Apache 还是 Nginx?
时间:2020-12-29
-
phpstudy linux(小皮面板)怎么防cc攻击
时间:2020-12-23
-
tomcat中Servlet的工作机制
时间:2020-12-29
