一、Spring對DAO的支持

?DAO:Data Access Object

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

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

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

優勢：

由于依賴于接口，可以通過依賴注入隨時替換DAO接口的實現類，而應用程序完全不用了解接口與底層數據庫操作細節。

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

二、Spring注入數據源

2.1、 DataSource(數據源)

連接數據的方式稱為“數據庫”。比如JDBC，連接池或者JNDI

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

不同系統，數據源的管理更多是針對底層的行為，這些行為不應該影響業務。

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

2.2、配置數據源

applicationContext.xml配置數據源

<?xml version="1.0" encoding="UTF-8"?> <beansxmlns="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.xsdhttp://www.springframework.org/schema/aophttp://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;@Overridepublic 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"?> <beansxmlns="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.xsdhttp://www.springframework.org/schema/aophttp://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>

　　

三、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查找@Overridepublic Person findById(Integer id) {Person p=null;//返回的是集合，但集合的每個元素都是一個mapString 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);}}

　　

四、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>

　　

五、JDBC Template操作數據庫

?執行DDL與更新

• 使用JdbcTemplate的execute()方法可以執行DDL語句
• 執行update或者inert，可以使用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);//通過數據源實例JdbcTemplateJdbcTemplate 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);//通過數據源實例JdbcTemplateJdbcTemplate 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() {@Overridepublic 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));}@Overridepublic int getBatchSize() {return count;}};//執行插入jt.batchUpdate(sql, bps);System.out.println("插入完成!");}}

　　

六、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();}@Overrideprotected 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);}@Overridepublic List<Person> find() {return pq.execute();}@Overridepublic void update(Person p) {//傳入參數pu.update(p.getId(),p.getName(),p.getAge());}@Overridepublic int getCount() {//函數使用run運行調用return pf.run();}}

　　applicationContext.xml

<?xml version="1.0" encoding="UTF-8"?> <beansxmlns="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());}}}

　　

轉載于:https://www.cnblogs.com/yuexiaoyun/p/9457514.html

總結

以上是生活随笔為你收集整理的Spring(七)持久层的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。