SSM框架之Spring（5）JdbcTemplate及spring事务控制

ゞ浴缸里的玫瑰 2022-02-03 16:43 181阅读 0赞

# Spring（5）JdbcTemplate及spring事务控制 #

\#\#1、JdbcTmeplate

> 它是 spring 框架中提供的一个对象，是对原始 Jdbc API 对象的简单封装。spring 框架为我们提供了很多的操作模板类。  
> 操作关系型数据的：  
> JdbcTemplate  
> HibernateTemplate  
> 操作 nosql 数据库的：  
> RedisTemplate  
> 操作消息队列的：  
> JmsTemplate  
> 我们今天的主角在 spring-jdbc-5.0.2.RELEASE.jar 中，我们在导包的时候，除了要导入这个 jar 包外，还需要导入一个 spring-tx-5.0.2.RELEASE.jar（它是和事务相关的）。

### 1.1、JdbcTemplate 对象的创建 ###

我们可以参考它的源码，来一探究竟：

public JdbcTemplate() { 
    }
    public JdbcTemplate(DataSource dataSource) { 
    	setDataSource(dataSource);
    	afterPropertiesSet();
    }
    public JdbcTemplate(DataSource dataSource, boolean lazyInit) { 
    	setDataSource(dataSource);
    	setLazyInit(lazyInit);
    	afterPropertiesSet();
    }

除了默认构造函数之外，都需要提供一个数据源。既然有set方法，依据我们之前学过的依赖注入，我们可以在配置文件中配置这些对象。

#### 1.1.1、通过代码配置 ####

import org.springframework.jdbc.core.JdbcTemplate;
    import org.springframework.jdbc.datasource.DriverManagerDataSource;
    
    public class JdbcTemplateDemo1 { 
        public static void main(String[] args) { 
            //使用spring自己提供的数据源创建
            DriverManagerDataSource ds = new DriverManagerDataSource();
            ds.setDriverClassName("com.mysql.jdbc.Driver");
            ds.setUrl("jdbc:mysql:///spring");
            ds.setUsername("root");
            ds.setPassword("123456");
    
            JdbcTemplate jt = new JdbcTemplate();
            jt.setDataSource(ds);
    
            jt.execute("insert into account(name,money) values ('ccc',111111)");
        }
    }

这样配置安全性低，所有在正式使用时，不会采用这种方式，而是采用xml配置

#### 1.1.2、通过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" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">
    
        <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
            <property name="dataSource" ref="dataSource"></property>
        </bean>
    
        <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
            <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
            <property name="url" value="jdbc:mysql:///spring"/>
            <property name="username" value="root"/>
            <property name="password" value="123456"/>
        </bean>
    
        
        <bean id="accountDao" class="wf.dao.impl.AccountImpl">
            <property name="jdbcTemplate" ref="jdbcTemplate"/>
        </bean>
    </beans>

### 1.2、JdbcTemplate的CRUD操作 ###

JdbcTemplate的增删改操作都由updata方法及其重载操作实现

#### 1.2.1、插入操作 ####

public class JdbcTemplateDemo2 { 
    public static void main(String[] args) { 
    	//1.获取 Spring 容器
    	ApplicationContext ac = new ClassPathXmlApplicationContext("bean.xml");
    	//2.根据 id 获取 bean 对象
    	JdbcTemplate jt = (JdbcTemplate) ac.getBean("jdbcTemplate");
    	//3.执行操作
    	jt.execute("insert into account(name,money)values('eee',500)");
    }
    }

#### 1.2.2、更新操作 ####

#### 1.2.3、删除操作 ####

#### 1.2.4、 查询操作 ####

public class JdbcTemplateDemo3 { 
        public static void main(String[] args) { 
            //1.获取 Spring 容器
            ApplicationContext ac = new ClassPathXmlApplicationContext("bean.xml");
            //2.根据 id 获取 bean 对象
            JdbcTemplate jt = (JdbcTemplate) ac.getBean("jdbcTemplate");
            //3.执行操作
            //查询所有
            List<Account> accounts = jt.query("select * from account where money > ? ",
            new AccountRowMapper(), 500);
            for(Account o : accounts){ 
            	System.out.println(o);
            }
        }
    }
    public class AccountRowMapper implements RowMapper<Account>{ 
        @Override
        public Account mapRow(ResultSet rs, int rowNum) throws SQLException { 
            Account account = new Account();
            account.setId(rs.getInt("id"));
            account.setName(rs.getString("name"));
            account.setMoney(rs.getFloat("money"));
            return account;
        }
    }
    ======================================================================================
    使用 RowMapper  的方式：常用的方式
    public class JdbcTemplateDemo3 { 
        public static void main(String[] args) { 
            //1.获取 Spring 容器
            ApplicationContext ac = new ClassPathXmlApplicationContext("bean.xml");
            //2.根据 id 获取 bean 对象
            JdbcTemplate jt = (JdbcTemplate) ac.getBean("jdbcTemplate");
            //3.执行操作
            //查询一个
            List<Account> as = jt.query("select * from account where id = ? ",
            new AccountRowMapper(), 55);
            System.out.println(as.isEmpty()?"没有结果":as.get(0));
        }
    }
    用 使用 ResultSetExtractor  的方式: 不常用的方式
    public class JdbcTemplateDemo3 { 
        public static void main(String[] args) { 
            //1.获取 Spring 容器
            ApplicationContext ac = new ClassPathXmlApplicationContext("bean.xml");
            //2.根据 id 获取 bean 对象
            JdbcTemplate jt = (JdbcTemplate) ac.getBean("jdbcTemplate");
            //3.执行操作
            //查询一个
            Account account = jt.query("select * from account where id = ?",
            new AccountResultSetExtractor(),3);
            System.out.println(account);
        }
    }

### 1.3、dao中使用JdbcTemplate ###

//实体类
    import java.io.Serializable;
    
    public class Account implements Serializable { 
        private Integer id;
        private String name;
        private Float money;
    
        public Integer getId() { 
            return id;
        }
    
        public void setId(Integer id) { 
            this.id = id;
        }
    
        public String getName() { 
            return name;
        }
    
        public void setName(String name) { 
            this.name = name;
        }
    
        public Float getMoney() { 
            return money;
        }
    
        public void setMoney(Float money) { 
            this.money = money;
        }
    
        @Override
        public String toString() { 
            return "Account{" +
                    "id=" + id +
                    ", name='" + name + '\'' +
                    ", money=" + money +
                    '}';
        }
    }
    ===============================================================================
    import wf.domain.Account;
    
    public interface AccountDao { 
        Account slelctAccountById(Integer id);
    
        Account selectAccountByName(String name);
    
        void updateAccount(Account account);
    }
    =================================================================================
    import org.springframework.jdbc.core.BeanPropertyRowMapper;
    import org.springframework.jdbc.core.JdbcTemplate;
    import wf.dao.AccountDao;
    import wf.domain.Account;
    
    import java.util.List;
    
    public class AccountImpl implements AccountDao { 
    
        private JdbcTemplate jdbcTemplate;
    
        public void setJdbcTemplate(JdbcTemplate jdbcTemplate) { 
            this.jdbcTemplate = jdbcTemplate;
        }
    
        public Account slelctAccountById(Integer id) { 
            List<Account> query = jdbcTemplate.query("select * from account where id = ?", new BeanPropertyRowMapper<Account>(Account.class), id);
            return query.isEmpty()?null:query.get(0);
        }
    
        public Account selectAccountByName(String name) { 
            List<Account> query = jdbcTemplate.query("select * from account where name = ?", new BeanPropertyRowMapper<Account>(Account.class), name);
            if (query.isEmpty())return null;
            else if (query.size()>1)throw new RuntimeException("结果集不唯一");
            else return query.get(0);
        }
    
        public void updateAccount(Account account) { 
            jdbcTemplate.update("update account set name = ?,money = ? where id = ?",account.getName(),account.getMoney(),account.getId());
        }
    }

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" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">
    
        <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
            <property name="dataSource" ref="dataSource"></property>
        </bean>
    
        <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
            <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
            <property name="url" value="jdbc:mysql:///spring"/>
            <property name="username" value="root"/>
            <property name="password" value="123456"/>
        </bean>
    
        
        <bean id="accountDao" class="wf.dao.impl.AccountImpl">
            <property name="jdbcTemplate" ref="jdbcTemplate"/>
        </bean>
    </beans>

#### 1.3.2、第二种方式：让 dao 继承 JdbcDaoSupport ####

JdbcDaoSupport 是spring 框架为我们提供的一个类，该类中定义了一个 JdbcTemplate 对象，我们可以直接获取使用，但是要想创建该对象，需要为其提供一个数据源：具体源码如下：

public abstract class JdbcDaoSupport extends DaoSupport { 
    //定义对象
    private JdbcTemplate jdbcTemplate;
    //set 方法注入数据源，判断是否注入了，注入了就创建 JdbcTemplate
    public final void setDataSource(DataSource dataSource) { 
        if (this.jdbcTemplate == null || dataSource != this.jdbcTemplate.getDataSource()){   		//如果提供了数据源就创建 JdbcTemplate
        	this.jdbcTemplate = createJdbcTemplate(dataSource);
        	initTemplateConfig();
        }
    }
    //使用数据源创建 JdcbTemplate
    protected JdbcTemplate createJdbcTemplate(DataSource dataSource) { 
    	return new JdbcTemplate(dataSource);
    }
    //当然，我们也可以通过注入 JdbcTemplate 对象
    public final void setJdbcTemplate(JdbcTemplate jdbcTemplate) { 
        this.jdbcTemplate = jdbcTemplate;
    initTemplateConfig();
    }
    //使用 getJdbcTmeplate 方法获取操作模板对象
    public final JdbcTemplate getJdbcTemplate() { 
    	return this.jdbcTemplate;
    }
        ===================================================================================
    /** * 账户的接口 */
    public interface IAccountDao { 
    /** * 根据 id 查询账户信息 * @param id * @return */
    Account findAccountById(Integer id);
    /** * 根据名称查询账户信息 * @return */
    Account findAccountByName(String name);
    /** * 更新账户信息 * @param account */
    void updateAccount(Account account);
    }
        ===============================================================================
    /** * 账户的持久层实现类 * 此版本 dao，只需要给它的父类注入一个数据源 */
    public class AccountDaoImpl2 extends  JdbcDaoSupport implements IAccountDao { 
        @Override
        public Account findAccountById(Integer id) { 
            //getJdbcTemplate()方法是从父类上继承下来的。
            List<Account> list = getJdbcTemplate().query("select * from account where
            id = ? ",new AccountRowMapper(),id);
            return list.isEmpty()?null:list.get(0);
    }
    @Override
    public Account findAccountByName(String name) { 
        //getJdbcTemplate()方法是从父类上继承下来的。
        List<Account> list = getJdbcTemplate().query("select * from account where
        name = ? ",new AccountRowMapper(),name);
        if(list.isEmpty()){ 
        return null;
    	}
        if(list.size()>1){ 
        	throw new RuntimeException("结果集不唯一，不是只有一个账户对象");
        }
        return list.get(0);
    }
    @Override
    public void updateAccount(Account account) { 
        //getJdbcTemplate()方法是从父类上继承下来的。
        getJdbcTemplate().update("update account set money = ? where id = ?
        ",account.getMoney(),account.getId());
    }
    }

配置文件：

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">
        
        <bean id="accountDao2" class="com.itheima.dao.impl.AccountDaoImpl2">
            
            <property name="dataSource" ref="dataSource"></property>
        </bean>
        
        <bean  id="dataSource"class="org.springframework.jdbc.datasource.DriverManagerDataSource">
            <property name="driverClassName" value="com.mysql.jdbc.Driver"></property>
            <property name="url" value="jdbc:mysql:///spring_day04"></property>
            <property name="username" value="root"></property>
            <property name="password" value="1234"></property>
        </bean>
    </beans>

第一种在 Dao 类中定义 JdbcTemplate 的方式，适用于所有配置方式（xml 和注解都可以）。  
让 第二种让 Dao 继承 JdbcDaoSupport 的方式，只能用于基于 XML 的方式，注解用不了。