Spring的数据访问策略
异常
- Spring JDBC不同于JDBC，提供了比较丰富的数据异常类型。
- Spring的数据异常并没有与特定的持久化方式相关联，所以异常对于不同的持久化方式都是一致的
- Spring的数据异常都继承自DataAccessException，这种异常是非检查型异常。即，不一定非要捕获Spring所抛出的数据访问异常。
数据访问模板化
Spring在数据访问过程中，采用了模板方法设计模式。
它将数据访问过程分为两块：模板和回调。模板管理过程中固定的部分，而回调处理自定义的数据访问代码。
下图中，左边属于模板固定部分，右边属于模板回调部分。
spring数据访问流程
对于不同的持久化平台，Spring提供了多个可选的模板。
模板类表
使用DAO支持类
基于模板-回调设计，Spring提供了DAO支持类，而将业务本身的DAO类作为它的子类。
下图展示了模板类、DAO支持类以及自定义DAO实现之间的关系。
DAO关系图
Spring不仅提供了多个数据模板实现类，还为每种模板提供了对应的DAO支持类。
DAO支持类表
配置数据源
使用JNDI数据源
如果Spring应用部署在支持JNDI的WEB服务器上（如WebSphere、JBoss、Tomcat等），就可以使用JNDI获取数据源。
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:jee="http://www.springframework.org/schema/jee"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-3.2.xsd
http://www.springframework.org/schema/jee
http://www.springframework.org/schema/jee/spring-jee-3.2.xsd">
<!-- 1.使用bean配置jndi数据源 -->
<bean id="dataSource" class="org.springframework.jndi.JndiObjectFactoryBean">
<property name="jndiName" value="java:comp/env/jdbc/orclight" />
</bean>
<!-- 2.使用jee标签配置jndi数据源，与1等价，但是需要引入命名空间 -->
<jee:jndi-lookup id="dataSource" jndi-name=" java:comp/env/jdbc/orclight" />
</beans>
使用数据源连接池
<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource"destroy-method="close">
<property name="driverClassName" value="oracle.jdbc.driver.OracleDriver" />
<property name="url" value="jdbc:oracle:thin:@iphost:port:project"/>
<property name="username" value="******" />
<property name="password" value="******" />
</bean>
基于JDBC驱动的数据源
<bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
<property name="driverClassName" value="com.mysql.jdbc.Driver" />
<property name="url" value="jdbc:mysql://127.0.0.1:3306/testdb"/>
<property name="username" value="root" />
<property name="password" value="root" />
</bean>
完整实例
ContextHelper.java
import org.springframework.context.support.ClassPathXmlApplicationContext;
public final class ContextHelper {
private static ClassPathXmlApplicationContext _ctx;
static {
_ctx = new ClassPathXmlApplicationContext("ApplicationContext.xml");
}
private ContextHelper() {
}
public static ClassPathXmlApplicationContext getContext() {
return _ctx;
}
}
DBUtil.java
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.SQLException;
import java.sql.CallableStatement;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public final class DBUtil {
private static Logger log = LoggerFactory.getLogger(DBUtil.class);
/**
* 获取系统的数据源
*
* @return DataSource
*/
public static DataSource getDataSource() {
DataSource dataSource = null;
try {
dataSource = (DataSource) ContextHelper.getContext()
.getBean("dataSource");
} catch (Exception e) {
log.error("获取数据源出错，请检查Spring数据源配置！");
}
return dataSource;
}
/**
* 获取数据库连接
*
* @return Connection
*/
public static Connection makeConnection() {
Connection conn = null;
try {
conn = getDataSource().getConnection();
} catch (SQLException e) {
log.error("通过数据源获取数据库连接发生异常！");
e.printStackTrace();
}
return conn;
}
/**
* 执行没有参数的SQL过程
*
* @param procedureName
*存储过程名字
* @return boolean 返回存储过程执行的结果,true表示执行成功,false表示执行失败.
*/
public static boolean executeBSDProcedure(String procedureName) {
boolean flag = false;
String sqlStr = "{call " + procedureName + "()}";
CallableStatement cs;
Connection conn = makeConnection();
try {
cs = (CallableStatement) conn.prepareStatement(sqlStr);
cs.executeUpdate(sqlStr);
flag = true;
} catch (SQLException e) {
log.error("调用存储过程" + sqlStr + "失败！");
e.printStackTrace();
}
return flag;
}
}
Test.java
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* 14:41:49 Spring 数据源应用测试
*/
public class Test {
private static Logger log = LoggerFactory.getLogger(Test.class);
public static void main(String args[]) {
Test.test();
}
public static void test() {
String testSql = "select * from t_user";
Connection conn = DBUtil.makeConnection();
Statement stmt = null;
try {
stmt = conn.createStatement(ResultSet.TYPE_FORWARD_ONLY,
ResultSet.CONCUR_READ_ONLY,
ResultSet.CLOSE_CURSORS_AT_COMMIT);
ResultSet rs = stmt.executeQuery(testSql);
while (rs.next()) {
String firstName = rs.getString("firstname");
String lastName = rs.getString("lastname");
System.out.println(firstName + " " + lastName);
}
} catch (SQLException e) {
e.printStackTrace();
} finally {
if (stmt != null) {
try {
stmt.close();
} catch (SQLException e) {
log.info("关闭Statement对象出现异常！");
e.printStackTrace();
}
}
if (conn != null) {
try {
conn.close();
} catch (SQLException e) {
log.error("关闭数据库连接失败！");
e.printStackTrace();
}
}
}
}
}
在ApplicationContext.xml中添加一个bean
<bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
<property name="driverClassName" value="com.mysql.jdbc.Driver" />
<property name="url" value="jdbc:mysql://127.0.0.1:3306/testdb"/>
<property name="username" value="root" />
<property name="password" value="root" />
</bean>
运行Test.java中的main方法。
参考
Spring实战（第三版）
