2020-06-18

SSM-Spring【IOC进阶二】

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

一、前言

SSM-Spring【IOC进阶一】主要总结了通过xml实现的基本CRUD操作，本篇文章则主要总结xml和注解结合来实现CRUD操作。

二、需求

假设有一个和账户相关的项目，现需要实现基本的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
注意：需要添加注解
对于类需要添加：@Repository(“accountDao”)
对于成员变量runner需要添加：@Autowired

@Repository("accountDao")
public class AccountDaoImpl implements IAccountDao {

    @Autowired
    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
注意：需要添加注解
对于类需要添加：@Service(“accountService”)
对于成员变量runner需要添加：@Resource(name = “accountDao”)

@Service("accountService")
public class AccountServiceImpl implements IAccountService {

//    @Autowired (此处只有一个，可以使用)
    @Resource(name = "accountDao")
    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 version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:context="http://www.springframework.org/schema/context"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/context
        http://www.springframework.org/schema/context/spring-context.xsd">
    <!-- 进行spring的基本配置 -->

    <!-- 告诉spring：在创建容器时需要扫描的包 -->
    <context:component-scan base-package="com.zuobiao"></context:component-scan>

    <!-- 配置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>

其实该种方式可以理解为：自己编写的类可以使用注解，使用外部的类则必须通过xml文件进行配置

（八）测试

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、对于自己编写的类，一定要记得添加注解，并且在配置文件中告诉Spring，当它创建容器时，要扫描哪些包；
2、对于外部的类，由于无法直接添加注解，所以需要在配置文件中进行配置；
3、其实该种方法比较灵活，在没有技术限制时，可以优先考虑该种方式；
4、同样，在使用junit进行测试时，可以使用整合后的方式。
参考文章：SSM-Spring【对junit的整合】

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

| 阅读量次