欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识！
您现在的位置是： 首页

05 使用spring的IoC完成crud

程序员文章站 2022-04-23 15:57:13
...

目录

 

5 使用spring的IoC完成CRUD

5.1 基于xml的IoC完成CRUD

5.1.1 导入依赖

5.2.1 编写实体类

5.2.2 编写持久层接口与实现类

5.2.3 编写业务层接口与实现类

5.2.4 编写配置文件

5.2.5 编写测试类测试

5.2 基于部分使用注解的IoC完成CRUD

5.2.1 修改配置文件

5.2.2 给实现类添加注解

5 使用spring的IoC完成CRUD

5.1 基于xml的IoC完成CRUD

5.1.1 导入依赖

  • 向pom.xml中添加
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>5.0.2.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.6</version>
        </dependency>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.12</version>
        </dependency>
        <dependency>
            <groupId>commons-dbutils</groupId>
            <artifactId>commons-dbutils</artifactId>
            <version>1.7</version>
        </dependency>
        <dependency>
            <groupId>c3p0</groupId>
            <artifactId>c3p0</artifactId>
            <version>0.9.1.2</version>
        </dependency>

5.2.1 编写实体类

  • Account实体类

/**
 * 用于封装账户信息的实体类
 * @author MaRui
 * @date 2021-04-28 0:02
 */
public class Account {
    private Integer id;
    private String name;
    private Double 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 Double getMoney() {
        return money;
    }

    public void setMoney(Double money) {
        this.money = money;
    }

    @Override
    public String toString() {
        return "Account{" +
                "id=" + id +
                ", name='" + name + '\'' +
                ", money=" + money +
                '}';
    }
}

5.2.2 编写持久层接口与实现类

  • IAccountDao接口
import com.marui.domain.Account;

import java.util.List;

/**
 * 账户的持久层接口
 * @author MaRui
 * @date 2021-04-27 23:56
 */
public interface IAccountDao {
    /**
     * 查询所用账户的方法
     */
    List<Account> findAll();

    /**
     * 根据id查询账户的方法
     *
     * @param id
     * @return
     */
    Account findById(int id);

    /**
     * 保存账户的方法
     *
     * @param account
     */
    void saveAccount(Account account);

    /**
     * 修改账户的操作
     *
     * @param account
     */
    void updateAccount(Account account);

    /**
     * 删除账户的操作
     *
     * @param id
     */
    void deleteAccount(int id);
}
  • AccountDaoImpl实现类
import com.marui.dao.IAccountDao;
import com.marui.domain.Account;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanHandler;
import org.apache.commons.dbutils.handlers.BeanListHandler;

import java.sql.SQLException;
import java.util.List;

/**
 * 账户持久层实现类
 * @author MaRui
 * @date 2021-04-27 23:56
 */
public class AccountDaoImpl implements IAccountDao {
    private QueryRunner queryRunner;

    public void setQueryRunner(QueryRunner queryRunner) {
        this.queryRunner = queryRunner;
    }

    /**
     * 查询所用账户的方法
     */
    @Override
    public List<Account> findAll() {
        List<Account> list = null;
        try {
            list = queryRunner.query("select * from account", new BeanListHandler<Account>(Account.class));
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return list;
    }

    /**
     * 根据id查询账户的方法
     *
     * @param id
     * @return
     */
    @Override
    public Account findById(int id) {
        Account account = null;
        try {
            account = queryRunner.query("select * from account where id =?", new BeanHandler<Account>(Account.class), id);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return account;
    }

    /**
     * 保存账户的方法
     *
     * @param account
     */
    @Override
    public void saveAccount(Account account) {
        try {
            queryRunner.update("insert into account(name,money) values(?,?)", account.getName(), account.getMoney());
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    /**
     * 修改账户的操作
     *
     * @param account
     */
    @Override
    public void updateAccount(Account account) {
        try {
            queryRunner.update("update  account set name=?,money=? where id=?", account.getName(), account.getMoney(),account.getId());
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    /**
     * 删除账户的操作
     *
     * @param id
     */
    @Override
    public void deleteAccount(int id) {
        try {
            queryRunner.update("delete from account where id=?",id);
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

5.2.3 编写业务层接口与实现类

  • IAccountService接口
import com.marui.domain.Account;

import java.util.List;

/**
 * 账户的业务层接口
 * @author MaRui
 * @date 2021-04-27 23:56
 */
public interface IAccountService {
    /**
     * 查询所用账户的方法
     */
    List<Account> findAll();

    /**
     * 根据id查询账户的方法
     *
     * @param id
     * @return
     */
    Account findById(int id);

    /**
     * 保存账户的方法
     *
     * @param account
     */
    void saveAccount(Account account);

    /**
     * 修改账户的操作
     *
     * @param account
     */
    void updateAccount(Account account);

    /**
     * 删除账户的操作
     *
     * @param id
     */
    void deleteAccount(int id);

}
  • AccountServiceImpl实现类
import com.marui.dao.IAccountDao;
import com.marui.domain.Account;
import com.marui.service.IAccountService;

import java.util.List;

/**
 * 账户的业务层实现类
 * @author MaRui
 * @date 2021-04-27 23:57
 */
public class AccountServiceImpl implements IAccountService {
    private IAccountDao accountDao;

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

    /**
     * 查询所用账户的方法
     */
    @Override
    public List<Account> findAll() {
        return accountDao.findAll();
    }

    /**
     * 根据id查询账户的方法
     *
     * @param id
     * @return
     */
    @Override
    public Account findById(int id) {
        return accountDao.findById(id);
    }

    /**
     * 保存账户的方法
     *
     * @param account
     */
    @Override
    public void saveAccount(Account account) {
        accountDao.saveAccount(account);
    }

    /**
     * 修改账户的操作
     *
     * @param account
     */
    @Override
    public void updateAccount(Account account) {
        accountDao.updateAccount(account);
    }

    /**
     * 删除账户的操作
     *
     * @param id
     */
    @Override
    public void deleteAccount(int id) {
        accountDao.deleteAccount(id);
    }
}

5.2.4 编写配置文件

  • bean.xml

注意事项：

  • 考虑到多线程多个线程可能使用一个QueryRunner对象，会造成争抢，所有应该指定QueryRunner对象为多例获取
<?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">
    <!--配置service-->
    <bean id="accountService" class="com.marui.service.impl.AccountServiceImpl">
        <!--注入dao-->
        <property name="accountDao" ref="accountDao"></property>
    </bean>
    <!--配置dao-->
    <bean id="accountDao" class="com.marui.dao.impl.AccountDaoImpl">
        <!--注入queryRunner-->
        <property name="queryRunner" ref="queryRunner"></property>
    </bean>
    <!--配置queryRunner-->
    <bean id="queryRunner" 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.jdbc.Driver"></property>
        <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/db1"></property>
        <property name="user" value="root"></property>
        <property name="password" value="root"></property>
    </bean>
</beans>

5.2.5 编写测试类测试

  • TestJDBC测试类
import com.marui.domain.Account;
import com.marui.service.IAccountService;
import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import java.util.List;

/**
 * 基于xml的IoC案例的测试类
 * @author MaRui
 * @date 2021-04-28 0:01
 */
public class TestJDBC    {
    /**
     * 测试查询所有账户的方法
     */
    @Test
    public void testFindAll() {
        ApplicationContext context = new ClassPathXmlApplicationContext("bean.xml");
        IAccountService accountService = context.getBean("accountService", IAccountService.class);
        List<Account> list = accountService.findAll();
        for (Account account : list) {
            System.out.println(account);
        }
    }
    /**
     * 测试根据id查询账户的方法
     */
    @Test
    public void testFindById() {
        ApplicationContext context = new ClassPathXmlApplicationContext("bean.xml");
        IAccountService accountService = context.getBean("accountService", IAccountService.class);
        Account account = accountService.findById(1);
        System.out.println(account);
    }
    /**
     * 测试保存账户的方法
     */
    @Test
    public void testSaveAccount() {
        ApplicationContext context = new ClassPathXmlApplicationContext("bean.xml");
        IAccountService accountService = context.getBean("accountService", IAccountService.class);
        Account account = new Account();
        account.setMoney(5000.0);
        account.setName("ddd");
        accountService.saveAccount(account);
    }
    /**
     * 测试修改账户的方法
     */
    @Test
    public void testUpdateAccount() {
        ApplicationContext context = new ClassPathXmlApplicationContext("bean.xml");
        IAccountService accountService = context.getBean("accountService", IAccountService.class);
        Account account = new Account();
        account.setId(4);
        account.setMoney(5000.0);
        account.setName("eeee");
        accountService.updateAccount(account);
    }
    /**
     * 测试删除账户的方法
     */
    @Test
    public void testDeleteAccount() {
        ApplicationContext context = new ClassPathXmlApplicationContext("bean.xml");
        IAccountService accountService = context.getBean("accountService", IAccountService.class);
        accountService.deleteAccount(4);
    }
}

5.2 基于部分使用注解的IoC完成CRUD

5.2.1 修改配置文件

  • bean.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: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">

    <!--开启注解扫描-->
    <context:component-scan base-package="com.marui"></context:component-scan>

    <!--配置queryRunner-->
    <bean id="queryRunner" 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.jdbc.Driver"></property>
        <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/db1"></property>
        <property name="user" value="root"></property>
        <property name="password" value="root"></property>
    </bean>
</beans>

5.2.2 给实现类添加注解

  • AccountDaoImpl实现类
import com.marui.dao.IAccountDao;
import com.marui.domain.Account;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanHandler;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;

import java.sql.SQLException;
import java.util.List;

/**
 * 账户持久层实现类
 * @author MaRui
 * @date 2021-04-27 23:56
 */
@Repository(value = "accountDao")
public class AccountDaoImpl implements IAccountDao {
    @Autowired
    private QueryRunner queryRunner;

    /**
     * 查询所用账户的方法
     */
    @Override
    public List<Account> findAll() {
        List<Account> list = null;
        try {
            list = queryRunner.query("select * from account", new BeanListHandler<Account>(Account.class));
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return list;
    }

    /**
     * 根据id查询账户的方法
     *
     * @param id
     * @return
     */
    @Override
    public Account findById(int id) {
        Account account = null;
        try {
            account = queryRunner.query("select * from account where id =?", new BeanHandler<Account>(Account.class), id);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return account;
    }

    /**
     * 保存账户的方法
     *
     * @param account
     */
    @Override
    public void saveAccount(Account account) {
        try {
            queryRunner.update("insert into account(name,money) values(?,?)", account.getName(), account.getMoney());
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    /**
     * 修改账户的操作
     *
     * @param account
     */
    @Override
    public void updateAccount(Account account) {
        try {
            queryRunner.update("update  account set name=?,money=? where id=?", account.getName(), account.getMoney(),account.getId());
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    /**
     * 删除账户的操作
     *
     * @param id
     */
    @Override
    public void deleteAccount(int id) {
        try {
            queryRunner.update("delete from account where id=?",id);
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}
  • AccountServiceImpl实现类
import com.marui.dao.IAccountDao;
import com.marui.domain.Account;
import com.marui.service.IAccountService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

/**
 * 账户的业务层实现类
 * @author MaRui
 * @date 2021-04-27 23:57
 */
@Service(value = "accountService")
public class AccountServiceImpl implements IAccountService {
    @Autowired
    private IAccountDao accountDao;

    /**
     * 查询所用账户的方法
     */
    @Override
    public List<Account> findAll() {
        return accountDao.findAll();
    }

    /**
     * 根据id查询账户的方法
     *
     * @param id
     * @return
     */
    @Override
    public Account findById(int id) {
        return accountDao.findById(id);
    }

    /**
     * 保存账户的方法
     *
     * @param account
     */
    @Override
    public void saveAccount(Account account) {
        accountDao.saveAccount(account);
    }

    /**
     * 修改账户的操作
     *
     * @param account
     */
    @Override
    public void updateAccount(Account account) {
        accountDao.updateAccount(account);
    }

    /**
     * 删除账户的操作
     *
     * @param id
     */
    @Override
    public void deleteAccount(int id) {
        accountDao.deleteAccount(id);
    }
}

 

相关标签： # spring

上一篇： 15条JavaScript最佳实践小结_javascript技巧

下一篇： spring mvc rest风格的CRUD

推荐阅读