Spring(七)持久層

原文出自：http://www.cnblogs.com/liunanjava/p/4412408.html

 

1、Spring對DAO的支持

 DAO:Data Access Object

Spring提供了DAO框架，讓開發人員無須耦合特定的數據庫技術，就能進行應用程序的開發。

Spring封閉了操做Oracle，MySql，DB2，SQL等數據庫的用法。

它們都實現同一接口，方法也是同樣的。

優點：

因爲依賴於接口，能夠經過依賴注入隨時替換DAO接口的實現類，而應用程序徹底不用瞭解接口與底層數據庫操做細節。

應用程序----調用-----》DAO接口《---實現--DAO接口實現類----操做------》數據庫

2、Spring注入數據源

2.一、 DataSource(數據源)

鏈接數據的方式稱爲「數據庫」。好比JDBC，鏈接池或者JNDI

Spring經過依賴注入方式配置數據源

不一樣系統，數據源的管理更可能是針對底層的行爲，這些行爲不該該影響業務。

更換數據只需修改Bean定義的內容，而不須要修改任何一行代碼。

2.二、配置數據源

applicationContext.xml配置數據源

<?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:p="http://www.springframework.org/schema/p" xmlns:aop="http://www.springframework.org/schema/aop" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.1.xsd"> <!--數據源 --> <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource"> <!--驅動 --> <property name="driverClassName" value="oracle.jdbc.driver.OracleDriver"/> <!--URL --> <property name="url" value="jdbc:oracl:thin:@localhost:1521:orcl"/> <!--鏈接的用戶名 --> <property name="username" value="accp"></property> <!--鏈接的密碼 --> <property name="password" value="accp"></property> </bean> </beans>

 JDBC操做：

package com.pb.jdbc.dao.impl; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import javax.sql.DataSource; import com.pb.entity.Person; import com.pb.jdbc.dao.PersonDao; public class PersonDaoImpl implements PersonDao { private DataSource dataSource; @Override public Person findById(Integer id) { Connection con = null; PreparedStatement ps = null; ResultSet rs = null; Person p=null; String sql="select * from person where id=?"; Object [] params={id}; //獲取鏈接 try { con=dataSource.getConnection(); ps=con.prepareStatement(sql); if(params!=null){ for (int i = 0; i < params.length; i++) { ps.setObject(i+1, params[i]); } } rs=ps.executeQuery(); if(rs!=null){ p=new Person(); while(rs.next()){ p.setId(rs.getInt("id")); p.setName(rs.getString("name")); p.setAge(rs.getInt("age")); } } return p; } catch (SQLException e) { e.printStackTrace(); }finally{ try { if(rs!=null) rs.close(); if(ps!=null) ps.close(); if(con!=null) con.close(); } catch (SQLException e) { e.printStackTrace(); } } return null; } public void setDataSource(DataSource dataSource) { this.dataSource = dataSource; } }

更新applicationContext.xml

<?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:p="http://www.springframework.org/schema/p" xmlns:aop="http://www.springframework.org/schema/aop" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.1.xsd"> <!--數據源 --> <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource"> <!--驅動 --> <property name="driverClassName" value="oracle.jdbc.driver.OracleDriver"/> <!--URL --> <property name="url" value="jdbc:oracl:thin:@localhost:1521:orcl"/> <!--鏈接的用戶名 --> <property name="username" value="accp"></property> <!--鏈接的密碼 --> <property name="password" value="accp"></property> </bean> <!-- PersonDao接口實現類 --> <bean id="personDaoImpl" class="com.pb.jdbc.dao.impl.PersonDaoImpl"> <!-- 屬性關聯 --> <property name="dataSource" ref="dataSource"/> </bean> </beans>

 

3、JDBC Template

 爲何須要JDBCTemplate(JDBC模板)?

使用JDBC時，老是須要進行固定的步驟，好比Connection,Statement的獲取、關閉，異常處理等。

JDBCTemplate做用：

Spring將JDBC經常使用的操做封裝到JDBCTemplate中簡化了使用JDBC的開發流程，開發人員不須要關心，得到鏈接和關閉鏈接

更改上面的代碼

package com.pb.jdbc.dao.impl; import java.math.BigDecimal; import java.util.List; import java.util.Map; import javax.sql.DataSource; import org.springframework.jdbc.core.JdbcTemplate; import com.pb.entity.Person; import com.pb.jdbc.dao.PersonDao; public class JdbcTemplatePersonDaoImpl implements PersonDao { private JdbcTemplate jdbcTemplate; //根據ID查找  @Override public Person findById(Integer id) { Person p=null; //返回的是集合，但集合的每一個元素都是一個map String sql="select * from person where id=?"; //佔位符 Object [] params={id}; //調用SQL和佔位 List results=jdbcTemplate.queryForList(sql,params); for (Object object : results) { Map personMap=(Map) object; //獲取每一個map的值 Long p_id=((BigDecimal) personMap.get("ID")).longValue(); String p_name=(String) personMap.get("NAME"); Integer p_age=((BigDecimal) personMap.get("AGE")).intValue(); //聲明 p=new Person(); p.setAge(p_age); p.setId(p_id); p.setName(p_name); } return p; } //經過設置數據獲取JdbcTemplate的實例 public void setDataSource(DataSource dataSource) { jdbcTemplate=new JdbcTemplate(dataSource); } }

 

4、JDBC Template

要使用Jdbctemplate 對象來完成jdbc 操做。一般狀況下，有三種種方式獲得JdbcTemplate 對象。 

• 第一種方式：咱們能夠在本身定義的DAO 實現類中注入一個DataSource 引用來完 成JdbcTemplate 的實例化。也就是它是從外部「注入」 DataSource 　　到DAO 中，而後 本身實例化JdbcTemplate，而後將DataSource 設置到JdbcTemplate 對象中。 
• 第二種方式： 在 Spring 的 IoC 容器中配置一個 JdbcTemplate 的 bean，將 DataSource 注入進來，而後再把JdbcTemplate 注入到自定義DAO 中。 
• 第三種方式: Spring 提供了 org.springframework.jdbc.core.support.JdbcDaoSupport 類 ， 這 個 類 中 定 義 了 JdbcTemplate 屬性，也定義了DataSource 屬性，當設置DataSource 屬性的時候，會創 建jdbcTemplate 的實例，因此咱們本身編寫的DAO 只須要繼承JdbcDaoSupport 類， 而後注入DataSource 便可

 第一種

public class UserServiceImpl implements UserService { private JdbcTemplate jdbcTemplate; public JdbcTemplate getJdbcTemplate() { return jdbcTemplate; } //注入方法1 public void setJdbcTemplate(JdbcTemplate jdbcTemplate) { this.jdbcTemplate = jdbcTemplate; } //其它方法這裏省略…… } 

application.xml   前提是已經配置了dataSource 2.2配置數據源

<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate"> <property name = "dataSource" ref="dataSource"> </bean> <bean id="userService" class="com.hxzy.account.jdbcTemplate.UserServiceImpl"> <property name="jdbcTemplate" ref="jdbcTemplate"/> </bean> 

第二種 經過數據庫實例化JdbcTemplate

public class UserServiceImpl implements UserService { private JdbcTemplate jdbcTemplate; //注入方法2 public void setDataSource(DataSource dataSource) { this.jdbcTemplate = new JdbcTemplate(dataSource); } //其它方法省略…… } 

applicationContext.xml

前提是已經配置了dataSource  2.2配置數據源

spring配置文件爲：

<bean id="userService" class="com.hxzy.account.jdbcTemplate.UserServiceImpl"> <property name="dataSource" ref="dataSource"/> </bean> 

第三種：

繼承JdbcDaoSupport，其內部有個JdbcTemplate ，須要注入DataSource 屬性來實例化。

public class UserDaoImpl extends JdbcDaoSupport implements UserDao { @Override public void save(User user) { String sql = null; this.getJdbcTemplate().update(sql); } //其它方法省略…… } 

xml

<bean id="userDao" class="com.hxzy.account.jdbcTemplate.UserDaoImpl"> <property name="dataSource" ref="dataSource"/> </bean> 

 

5、JDBC Template操做數據庫

 執行DDL與更新

• 使用JdbcTemplate的execute()方法能夠執行DDL語句
• 執行update或者insert，可使用update()方法；

 

package com.pb.demo; import java.util.List; import java.util.Map; import javax.sql.DataSource; import org.springframework.context.ApplicationContext; import org.springframework.context.support.ClassPathXmlApplicationContext; import org.springframework.jdbc.core.JdbcTemplate; /** * 1.JdbcTemplate queryForXxx方法執行SQL語句 * 2. query和update均可以使用佔位符 * 3. 返回的List中的元素爲map * 4.使用update執行更新操做 * 5.使用execute方法執行DDL操做 */ public class JdbcTemplateDemo { public static void main(String[] args) { ApplicationContext context=new ClassPathXmlApplicationContext("applicationContext.xml"); //獲取數據源 DataSource dataSource=context.getBean("dataSource",DataSource.class); //經過數據源實例JdbcTemplate JdbcTemplate jt=new JdbcTemplate(dataSource); //執行佔位符的查詢語句 String sql_v="select * from person where name=? and age=?"; Object [] params={"李四",24}; //傳入參數 List result=jt.queryForList(sql_v,params); for (Object object : result) { //直接輸出對象  System.out.println(object); //或者輸出值 Map map=(Map)object; System.out.println("ID: "+map.get("ID")+"姓名："+map.get("NAME")+map.get("AGE")); } //更新 String sql_update="update person set name=? where age=?"; //年齡爲23的都更新爲張小三 Object [] pupdate={"張小三",23}; //數據庫受影響的行數 int count=jt.update(sql_update, pupdate); System.out.println("更新了"+count+"行"); //查詢總記錄數 String sql_count="select count(*) from person"; int totalcount=jt.queryForInt(sql_count); System.out.println("Person表的總記錄數: "+totalcount); //執行DDL語句 //建立一張表 String ddl="create table test(id number(4) primary key,name varchar2(50))"; jt.execute(ddl); System.out.println("建立表 成功"); //刪除表 String del_table="drop table test"; jt.execute(del_table); System.out.println("刪除表成功"); } }

配置數據如：2.2

 

package com.pb.demo; import java.sql.PreparedStatement; import java.sql.SQLException; import java.util.ArrayList; import java.util.List; import javax.sql.DataSource; import org.springframework.context.ApplicationContext; import org.springframework.context.support.ClassPathXmlApplicationContext; import org.springframework.jdbc.core.BatchPreparedStatementSetter; import org.springframework.jdbc.core.JdbcTemplate; /** * 使用批量處理數據 */ public class JdbcTemplateDemo2 { public static void main(String[] args) { ApplicationContext context=new ClassPathXmlApplicationContext("applicationContext.xml"); //獲取數據源 DataSource dataSource=context.getBean("dataSource",DataSource.class); //經過數據源實例JdbcTemplate JdbcTemplate jt=new JdbcTemplate(dataSource); //批量插入數據 final int count=200; final List id=new ArrayList(); final List name=new ArrayList(); final List password=new ArrayList(); //爲集合調定值 for (int i = 0; i < count; i++) { id.add(i); name.add("name_"+i); password.add("password_"+i); } //指處理數據 String sql="insert into users values(?,?,?)"; BatchPreparedStatementSetter bps=new BatchPreparedStatementSetter() { @Override public void setValues(PreparedStatement ps, int index) throws SQLException { ps.setObject(1, id.get(index)); ps.setObject(2, name.get(index)); ps.setObject(3, password.get(index)); } @Override public int getBatchSize() { return count; } }; //執行插入  jt.batchUpdate(sql, bps); System.out.println("插入完成!"); } }

6、JDBC Template以對象方 式操做數據庫

執行函數的類繼承：

sqlfunction

package com.pb.object; import javax.sql.DataSource; import org.springframework.jdbc.object.SqlFunction; /** * 執行函數 * */ public class PersonFunction extends SqlFunction{ public PersonFunction(DataSource ds){ //初始化 super(ds,"select count(*) from person"); //編譯  compile(); } }

執行增長或者更新的類繼承sqlupdate

package com.pb.object; import java.sql.Types; import javax.sql.DataSource; import org.springframework.jdbc.object.SqlUpdate; /** * 執行增長或者更新 * */ public class PersonUpdate extends SqlUpdate { public PersonUpdate(DataSource ds){ super(ds,"insert into person values(?,?,?)"); //設置參數爲Oracle中的數據 int [] types={Types.BIGINT,Types.VARCHAR,Types.INTEGER}; //設置參數  setTypes(types); compile(); } }

執行查詢的類繼承MappingSqlQuery

package com.pb.object; import java.sql.ResultSet; import java.sql.SQLException; import javax.sql.DataSource; import org.springframework.jdbc.object.MappingSqlQuery; import com.pb.entity.Person; /** * 對象查詢 * @author Administrator * */ public class PersonQuery extends MappingSqlQuery { public PersonQuery(DataSource ds){ super(ds,"select * from person"); compile(); } @Override protected Object mapRow(ResultSet rs, int rownum) throws SQLException { Person p=new Person(); p.setAge(rs.getInt("age")); p.setId(rs.getLong("id")); p.setName(rs.getString("name")); return p; } }

實現類和接口

package com.pb.dao; import java.util.List; import com.pb.entity.Person; public interface PersonDao { //查詢所有 public List<Person> find(); //增長 public void update(Person p); //查詢總記錄數 public int getCount(); }

實現類

package com.pb.dao.impl; import java.util.List; import javax.sql.DataSource; import com.pb.dao.PersonDao; import com.pb.entity.Person; import com.pb.object.PersonFunction; import com.pb.object.PersonQuery; import com.pb.object.PersonUpdate; public class ObjectPersonDaoImpl implements PersonDao { //3個實現類 private PersonFunction pf=null; //執行函數 private PersonQuery pq=null; //執行查詢 private PersonUpdate pu=null; //執行更新 /* *經過注入數據源實例化對象 * */ public void setDataSource(DataSource ds){ pf=new PersonFunction(ds); pq=new PersonQuery(ds); pu=new PersonUpdate(ds); } @Override public List<Person> find() { return pq.execute(); } @Override public void update(Person p) { //傳入參數  pu.update(p.getId(),p.getName(),p.getAge()); } @Override public int getCount() { //函數使用run運行調用 return pf.run(); } }

applicationContext.xml

<?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:p="http://www.springframework.org/schema/p" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd"> <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource"> <property name="driverClassName" value="oracle.jdbc.driver.OracleDriver"/> <property name="url" value="jdbc:oracle:thin:@localhost:1521:orcl"/> <property name="username" value="accp"/> <property name="password" value="accp"/> </bean> <bean id="objectPersonDao" class="com.pb.dao.impl.ObjectPersonDaoImpl"> <property name="dataSource" ref="dataSource"></property> </bean> </beans>

 

 

測試類

package com.pb.demo; import java.util.List; import org.springframework.context.ApplicationContext; import org.springframework.context.support.ClassPathXmlApplicationContext; import com.pb.dao.PersonDao; import com.pb.entity.Person; public class TestObjectJdbc { public static void main(String[] args) { ApplicationContext context=new ClassPathXmlApplicationContext("applicationContext.xml"); PersonDao opd=context.getBean("objectPersonDao",PersonDao.class); Person p=new Person(); p.setAge(99); p.setId(7); p.setName("滅絕師太"); opd.update(p); List<Person> persons=opd.find(); //調用查詢總記錄數的方法 System.out.println("總記錄數："+opd.getCount()); for (Person per : persons) { System.out.println("ID："+per.getId()+"姓名："+per.getName()+" 年齡:"+per.getAge()); } } }