JNDI技术简介和Apache—DBUtils框架(QueryRunner类)

这里拷一下PPT中的内容。

JNDI技术简介

JNDI(JavaNaming and Directory Interface)，Java命名和目录接口，它对应于J2SE中的javax.naming包，
这套API的主要作用在于：它可以把Java对象放在一个容器中（JNDI容器），并为容器中的java对象取一个名称，以后程序想获得Java对象，只需通过名称检索即可。
其核心API为Context，它代表JNDI容器，其lookup方法为检索容器中对应名称的对象。
 

JNDI技术老师只是简单的提了一下（应用于大型服务器），没有做深入讲解。这里百度了一下它的作用。

JNDI的作用

1、JNDI 提出的目的是为了解藕，是为了开发更加容易维护，容易扩展，容易部署的应用。

2、JNDI 是一个sun提出的一个规范(类似于jdbc),具体的实现是各个j2ee容器提供商，sun   只是要求，j2ee容器必须有JNDI这样的功能。

3、JNDI 在j2ee系统中的角色是“交换机”，是J2EE组件在运行时间接地查找其他组件、资源或服务的通用机制。

4、JNDI 是通过资源的名字来查找的，资源的名字在整个j2ee应用中(j2ee容器中)是唯一的。

 

commons-dbutils

 

简介

commons-dbutils 是 Apache 组织提供的一个开源 JDBC工具类库，它是对JDBC的简单封装，学习成本极低，并且使用dbutils能极大简化jdbc编码的工作量，同时也不会影响程序的性能。因此dbutils成为很多不喜欢hibernate的公司的首选。
 
API介绍：
•org.apache.commons.dbutils.QueryRunner
•org.apache.commons.dbutils.ResultSetHandler
•工具类
•org.apache.commons.dbutils.DbUtils、。   
 

DbUtils类

DbUtils：提供如关闭连接、装载JDBC驱动程序等常规工作的工具类，里面的所有方法都是静态的。主要方法如下：
•public static void close(…)throws java.sql.SQLException：　DbUtils类提供了三个重载的关闭方法。这些方法检查所提供的参数是不是NULL，如果不是的话，它们就关闭Connection、Statement和ResultSet。
•public static voidcloseQuietly(…): 这一类方法不仅能在Connection、Statement和ResultSet为NULL情况下避免关闭，还能隐藏一些在程序中抛出的SQLEeception。
•public static voidcommitAndCloseQuietly(Connection conn)： 用来提交连接，然后关闭连接，并且在关闭连接时不抛出SQL异常。

•public static booleanloadDriver(java.lang.String driverClassName)：这一方装载并注册JDBC驱动程序，如果成功就返回true。使用该方法，你不需要捕捉这个异常ClassNotFoundException。
 

QueryRunner类

该类简单化了SQL查询，它与ResultSetHandler组合在一起使用可以完成大部分的数据库操作，能够大大减少编码量。
QueryRunner类提供了两个构造方法：
•默认的构造方法
•需要一个javax.sql.DataSource来作参数的构造方法。
 

QueryRunner类的主要方法

publicObject query(Connection conn, String sql, Object[] params, ResultSetHandlerrsh) throws SQLException：执行一个查询操作，在这个查询中，对象数组中的每个元素值被用来作为查询语句的置换参数。该方法会自行处理PreparedStatement 和 ResultSet 的创建和关闭。
publicObject query(String sql, Object[] params, ResultSetHandler rsh) throwsSQLException:　几乎与第一种方法一样；唯一的不同在于它不将数据库连接提供给方法，并且它是从提供给构造方法的数据源(DataSource) 或使用的setDataSource 方法中重新获得Connection。
publicObject query(Connection conn, String sql, ResultSetHandler rsh) throwsSQLException : 执行一个不需要置换参数的查询操作。
publicint update(Connection conn, String sql, Object[] params) throws SQLException:用来执行一个更新（插入、更新或删除）操作。
publicint update(Connection conn, String sql) throws SQLException：用来执行一个不需要置换参数的更新操作。
 

ResultSetHandler接口

该接口用于处理java.sql.ResultSet，将数据按要求转换为另一种形式。
ResultSetHandler 接口提供了一个单独的方法：Object handle (java.sql.ResultSet .rs)。
ResultSetHandler 接口的实现类

ArrayHandler：把结果集中的第一行数据转成对象数组。
ArrayListHandler：把结果集中的每一行数据都转成一个数组，再存放到List中。
BeanHandler：将结果集中的第一行数据封装到一个对应的JavaBean实例中。
BeanListHandler：将结果集中的每一行数据都封装到一个对应的JavaBean实例中，存放到List里。
ColumnListHandler：将结果集中某一列的数据存放到List中。
KeyedHandler(name)：将结果集中的每一行数据都封装到一个Map里，再把这些map再存到一个map里，其key为指定的key。
MapHandler：将结果集中的第一行数据封装到一个Map里，key是列名，value就是对应的值。
MapListHandler：将结果集中的每一行数据都封装到一个Map里，然后再存放到List。
 

代码奉上：

这里会用到C3p0连接池，由于在本博客文章中的连接池中已经贴出，所以这里不再重复！

四个jar包

c3p0-0.9.1.2.jar      commons-dbutils-1.4.jar     commons-dbutils-ext.jar      mysql-connector-java-5.1.5-bin.jar

 

简单的DbUtilsHello.java来初识dbutils

package cn.hncu.dbUtilsDemo;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;

import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import org.junit.Test;

import cn.hncu.domain.Stud;
import cn.hncu.pubs.C3p0Utils;

public class DbUtilsHello {
@Test
public void dbQuery0() throws Exception{
//法1：底层自己读取数据，然后进行封装
Connection con=C3p0Utils.getConn();
Statement st=con.createStatement();
String sql="select * from stud";
ResultSet rs=st.executeQuery(sql);
List<Stud> studs=new ArrayList<Stud>();
while(rs.next()){
String id=rs.getString("id");
String name=rs.getString("name");
Stud stud=new Stud();
stud.setId(id);
stud.setName(name);
studs.add(stud);
}
System.out.println("这是方法1拿到的内容："+studs);
rs.close();
st.close();
con.close();
}
@Test
public void dbQuery_ByDbUtils() throws Exception{
//法2：通过QueryRunner类来查询
QueryRunner run=new QueryRunner(C3p0Utils.getDataSource());
String sql="select * from stud";
List<Stud> studs=run.query(sql, new BeanListHandler<Stud>(Stud.class));

System.out.println("这是方法2拿到的内容："+studs);
}
}

 

由图可以看出，无论是底层自己封装还是QueryRunner的方法，查询出来的内容都是一样的，但是通过QueryRunner类查询的代码更简单和安全。



 

两个值对象Person.java和Stud.java

Person.java

package cn.hncu.domain;

import org.apache.commons.dbutils.ext.Column;
import org.apache.commons.dbutils.ext.Id;
import org.apache.commons.dbutils.ext.Table;
@Table(value="person")
public class Person {
@Id
private String id;
@Column
private String name;
@Column
private String addr;
@Column
private Integer age;

public String getId() {
return id;
}

public void setId(String id) {
this.id = id;
}

public String getName() {
return name;
}

public void setName(String name) {
this.name = name;
}

public String getAddr() {
return addr;
}

public void setAddr(String addr) {
this.addr = addr;
}

public Integer getAge() {
return age;
}

public void setAge(Integer age) {
this.age = age;
}

@Override
public String toString() {
return "Person [id=" + id + ", name=" + name + ", address=" + addr
+ ", age=" + age + "]";
}

}

Stud.java

package cn.hncu.domain;

import org.apache.commons.dbutils.ext.Column;
import org.apache.commons.dbutils.ext.Id;
import org.apache.commons.dbutils.ext.Table;

@Table(value="stud")
public class Stud {
@Id
private String id;
@Column
private String name;

public String getId() {
return id;
}

public void setId(String id) {
this.id = id;
}

public String getName() {
return name;
}

public void setName(String name) {
this.name = name;
}

@Override
public String toString() {
return  id + ", " + name ;
}

}

 

DbUtilsDemo.java

package cn.hncu.dbUtilsDemo;

import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
import java.util.Map;

import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.ext.Column;
import org.apache.commons.dbutils.ext.ExtQueryRunner;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import org.apache.commons.dbutils.handlers.MapListHandler;
import org.junit.Test;

import cn.hncu.domain.Person;
import cn.hncu.domain.Stud;
import cn.hncu.pubs.C3p0Utils;

public class DbUtilsDemo {
/**
* 增、删、改和事务
*/
/*
* 数据库中的person表结构
*  CREATE TABLE person(
id VARCHAR(32) PRIMARY KEY,
NAME VARCHAR(30),
address VARCHAR(120),
age INT
);
*/
//insert,update,delete ----都是run.update()方法
@Test
public void save() throws Exception{
QueryRunner run=new QueryRunner(C3p0Utils.getDataSource());
//		参数写死了------类似于Statement方式
//		String sql ="insert into person(id,name,address,age) values('P001','啸天','中国湖南',22)";
//		run.update(sql);
//参数写活了------PreparedStatement方式       这里参数和占位符"?"要一一对应，不然会出错
//		run.update("insert into person(id,name,address) values(?,?,?)", "P002","王某","湖南益阳");
run.update("insert into person(id,name,address,age) values(?,?,?,?)", "P004","小伙","北京朝阳区",33);
}

//这里进行事务的演示------通过在调用run.update()时，给同一个Connection对象，就可以实现事务的提交或者回滚
@Test
public void saveTx() throws Exception{
QueryRunner run=new QueryRunner(C3p0Utils.getDataSource());
Connection con=C3p0Utils.getConn();
try {
con.setAutoCommit(false);
run.update(con, "insert into person(id,name,address,age) values(?,?,?,?)", "P007","铁蛋","河南郑州",25);
run.update(con, "insert into person(id,name,address,age) values(?,?,?,?)", "P006","二牛","湖北武汉",39);
con.commit();
} catch (SQLException e) {
con.rollback();
}finally{
con.setAutoCommit(true);
con.close();
}
}

/**
* 查询
*/
@Test
public void query1() throws Exception{//把查询数据封装成MapList
QueryRunner run=new QueryRunner(C3p0Utils.getDataSource());
List<Map<String,Object>> persons=run.query("select * from person", new MapListHandler());
System.out.println(persons);
}

 

MapList查询出的数据：



 

 

@Test
public void query2() throws Exception{//把查询数据封装成BeanList
QueryRunner run=new QueryRunner(C3p0Utils.getDataSource());
List<Person> persons=run.query("select * from person", new BeanListHandler<Person>(Person.class));
System.out.println(persons);
}

BeanList查询出的数据：



 

@Test
public void query3() throws Exception{
/*
* 当表字段名和值对象的属性名不一致时。    在sql语句中用表字段的别名(在开发过程中尽量全部都一致)
* 例如在这里，我的值对象中变量addr与数据库中的address不一致
*/
QueryRunner run=new QueryRunner(C3p0Utils.getDataSource());
List<Person> persons=run.query("select id,name,address addr,age from person", new BeanListHandler<Person>(Person.class));
System.out.println(persons);
}
@Test
public void query4() throws Exception{//带条件的查询(带参数)
QueryRunner run=new QueryRunner(C3p0Utils.getDataSource());
List<Person> persons=run.query("select id,name,address addr,age from person where name like ? and age>?", new BeanListHandler<Person>(Person.class),"%二%",25);
System.out.println(persons);
}

 

带条件的查询数据库表内容：



 

查询到的内容：

 



 

/**
* 批处理
*/
@Test
public void batch() throws Exception{
QueryRunner run=new QueryRunner(C3p0Utils.getDataSource());
for(int i=0;i<100;i++){
//100次批处理，每次批处理包含3条sql语句(params[][]的行数代表sql语句的条数，列数代表sql语句中参数的个数)
String sql="insert into stud values(?,?)";
String[][] params={{"E0"+i,"FFF"+i},{"G5"+i,"HHH"+i},{"G80"+i,"KKK"+i}};
run.batch(sql, params);
}
}

 

批处理往数据库中增加大量数据：



 

////////////////////////扩展包的功能----ExtQueryRunner/////////////////////////////////////
/*
* OR映射功能------不用sql语句，直接用Object(对象)来映射Relation(表，关系)查询，
* 但是值对象要添加@Table  @Id   @Column等注解(实现Hibernat中映射文件的功能)
*/
@Test
public void query5() throws Exception{
ExtQueryRunner run=new ExtQueryRunner(C3p0Utils.getDataSource());
List<Person> persons=run.query(Person.class);
System.out.println(persons);
}
@Test
public void save2() throws Exception{
ExtQueryRunner run=new ExtQueryRunner(C3p0Utils.getDataSource());
Stud stud=new Stud();
stud.setId("S1111");
stud.setName("@#$%");
run.save(stud);
}
}

 

查询到的内容与前面查询到的一样，这里图片不再贴出。

保存方法：可以成功插入数据。



最后贴上类、包图：