2020-06-18

SSM-Spring【IOC进阶一】

字数统计: 1.3k字 | 阅读时长: 6分

一、前言

在入门的文章中已经总结过通过XML方式的入门，那么本篇文章主要通过一个案例来进行进阶练习。

二、需求

假设有一个和账户相关的项目，现需要实现基本的CRUD操作。

三、实现

（一）技术选择

持久层选用 dbUtils、数据库连接池选用 c3p0.

（二）项目结构

项目结构

（三）数据库

数据库spring中的account表的结构与数据如下图所示：
account表的结构：

account表的数据：

（四）domain实现

public class Account implements Serializable {
    private int id;
    private String name;
    private float money;

    public int getId() {
        return id;
    }

    public void setId(int 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 +
                '}';
    }
}

（五）dao层实现

IAccountDao.java

/**
 * 操作账户的dao接口
 */
public interface IAccountDao {
    /**
     * 查询所有
     * @return
     */
    List<Account> findAll();

    /**
     * 根据id进行查询
     * @param id
     * @return
     */
    Account findById(Integer id);

    /**
     * 添加账户
     * @param account
     */
    void addAccount(Account account);

    /**
     * 删除账户
     * @param id
     */
    void delAccount(Integer id);

    /**
     * 修改账户信息
     * @param account
     */
    void updateAccount(Account account);
}

AccountDaoImpl.java

public class AccountDaoImpl implements IAccountDao {

    private QueryRunner runner;

    public void setRunner(QueryRunner runner) {
        this.runner = runner;
    }

    /**
     * 查询所有
     * @return
     */
    public List<Account> findAll() {
        try {
            return runner.query("select * from account", new BeanListHandler<Account>(Account.class));
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }
        return null;
    }

    /**
     * 根据id进行查询
     * @param id
     * @return
     */
    public Account findById(Integer id) {
        try {
            return runner.query("select * from account where id = ?", new BeanHandler<Account>(Account.class), id);
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }
        return null;
    }

    /**
     * 添加账户
     * @param account
     */
    public void addAccount(Account account) {
        try {
            runner.update("insert into account(name, money) values(?, ?)", account.getName(), account.getMoney());
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }
    }

    /**
     * 删除账户
     * @param id
     */
    public void delAccount(Integer id) {
        try {
            runner.update("delete from account where id = ?", id);
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }
    }

    /**
     * 更新账户信息
     * @param account
     */
    public void updateAccount(Account account) {
        try {
            runner.update("update account set name=?, money=? where id=?", account.getName(), account.getMoney(), account.getId());
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }
    }
}

（六）service层实现

IAccountService.java

public interface IAccountService {
    /**
     * 查询所有
     * @return
     */
    List<Account> findAll();

    /**
     * 根据id进行查询
     * @param id
     * @return
     */
    Account findById(Integer id);

    /**
     * 添加账户
     * @param account
     */
    void addAccount(Account account);

    /**
     * 删除账户
     * @param id
     */
    void delAccount(Integer id);

    /**
     * 修改账户信息
     * @param account
     */
    void updateAccount(Account account);
}

AccountServiceImpl.java

public class AccountServiceImpl implements IAccountService {

    private IAccountDao accountDao;

    public void setAccountDao(IAccountDao accountDao) {
        this.accountDao = accountDao;
    }

    /**
     * 查询所有账户
     * @return
     */
    public List<Account> findAll() {
        return accountDao.findAll();
    }

    /**
     * 根据id查找单个账户
     * @param id
     * @return
     */
    public Account findById(Integer id) {
        return accountDao.findById(id);
    }

    /**
     * 添加账户
     * @param account
     */
    public void addAccount(Account account) {
        accountDao.addAccount(account);
    }

    /**
     * 删除账户
     * @param id
     */
    public void delAccount(Integer id) {
        accountDao.delAccount(id);
    }

    /**
     * 更新账户信息
     * @param account
     */
    public void updateAccount(Account account) {
        accountDao.updateAccount(account);
    }
}

（七）利用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">
    <!-- 进行spring的基本配置 -->

    <!-- service层的基本配置 -->
    <bean id="accountService" class="com.zuobiao.service.impl.AccountServiceImpl">
        <property name="accountDao" ref="accountDao"></property>
    </bean>

    <!-- dao层的配置 -->
    <bean id="accountDao" class="com.zuobiao.dao.impl.AccountDaoImpl">
        <property name="runner" ref="runner"></property>
    </bean>

    <!-- 配置runner -->
    <!-- 此处记得最好配置为多例模式，否则可能会有线程安全问题-->
    <bean id="runner" class="org.apache.commons.dbutils.QueryRunner" scope="prototype"> 
        <constructor-arg name="ds" ref="dataSource"></constructor-arg>
    </bean>

    <!-- 配置数据源 -->
    <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
        <property name="driverClass" value="com.mysql.cj.jdbc.Driver"></property>
        <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/spring?serverTimezone=UTC"></property>
        <property name="user" value="root"></property>
        <property name="password" value="123456"></property>
    </bean>
</beans>

（八）测试

public class test {
    //获取容器
    ApplicationContext ac = new ClassPathXmlApplicationContext("bean.xml");
    //获取对象
    IAccountService accountService = (AccountServiceImpl)ac.getBean("accountService");

    @Test
    public void testFindAll(){
        //调用方法
        List<Account> accounts = accountService.findAll();
        //对数据进行处理
        for (Account account : accounts) {
            System.out.println(account);
        }
    }

    @Test
    public void testFindById() {
        Account account = accountService.findById(2);
        System.out.println(account);
    }

    @Test
    public void testAddAccount() {
        Account account = new Account();
        account.setName("跑调大叔");
        account.setMoney(19000f);
        accountService.addAccount(account);
    }

    @Test
    public void testDelAccount() {
        accountService.delAccount(4);
    }

    @Test
    public void testUpdateAccount() {
        Account account = new Account();
        account.setName("跑调大叔");
        account.setMoney(20000000f);
        account.setId(4);
        accountService.updateAccount(account);
    }
}

四、总结

1、该案例中accountService、accountDao、runner、dataSource对象的创建都是由spring来进行管理的，因此都要在配置文件中进行配置；
2、在进行配置时，一个对象通常都会使用另外一个对象来进行依赖注入，因此一定要注意之间的关系；
3、在进行测试的代码中，我们会发现，我们需要使用accountService对象时还需要手动获取容器，而我们进行测试时，通常更希望只关注测试代码，这些繁琐的细节不应该由我们手动实现。基于这一理念，Spring其实有对junit进行整合，这样我们就不需要手动获取容器。
参考文章：SSM-Spring【对junit的整合】

Java新手，若有错误，欢迎指正！

| 阅读量次