spring框架学习-个人案例（借助dbutils实现数据库操作）

Posted 2022-05-02 ccoonngg

（）前期工作，在mysql中创建数据库相关

create database cong
use cong;
create table account(
    id int primary key auto_increment,
    name varchar(40),
    money float
)character set utf8 collate utf8_general_ci;

insert into account(name,money) values(‘aaa‘,1000);
insert into account(name,money) values(‘bbb‘,1000);
insert into account(name,money) values(‘ccc‘,1000);

1.创建maven工程

2.在pom.xml中添加相关依赖

 1 <?xml version="1.0" encoding="UTF-8"?>
 2 <project xmlns="http://maven.apache.org/POM/4.0.0"
 3          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 4          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
 5     <modelVersion>4.0.0</modelVersion>
 6 
 7     <groupId>com.cong</groupId>
 8     <artifactId>spring_person_ioc_xml</artifactId>
 9     <version>1.0-SNAPSHOT</version>
10     <packaging>jar</packaging>
11     <dependencies>
12         <dependency>
13             <groupId>org.springframework</groupId>
14             <artifactId>spring-context</artifactId>
15             <version>5.0.2.RELEASE</version>
16         </dependency>
17         <!-- dbutils的依赖 -->
18         <dependency>
19             <groupId>commons-dbutils</groupId>
20             <artifactId>commons-dbutils</artifactId>
21             <version>1.4</version>
22         </dependency>
23         <dependency>
24             <groupId>mysql</groupId>
25             <artifactId>mysql-connector-java</artifactId>
26             <version>5.1.6</version>
27         </dependency>
28         <!-- 连接池的依赖 -->
29         <dependency>
30             <groupId>c3p0</groupId>
31             <artifactId>c3p0</artifactId>
32             <version>0.9.1.2</version>
33         </dependency>
34         <dependency>
35             <groupId>junit</groupId>
36             <artifactId>junit</artifactId>
37             <version>4.10</version>
38         </dependency>
39     </dependencies>
40 </project>

3.在java目录下创建com.cong.pojo.Account类

 1 package com.cong.pojo;
 2 
 3 public class Account 
 4     private int id;
 5     private String name;
 6     private float money;
 7 
 8     public int getId() 
 9         return id;
10     
11 
12     public void setId(int id) 
13         this.id = id;
14     
15 
16     public String getName() 
17         return name;
18     
19 
20     public void setName(String name) 
21         this.name = name;
22     
23 
24     public float getMoney() 
25         return money;
26     
27 
28     public void setMoney(float money) 
29         this.money = money;
30     
31 
32     @Override
33     public String toString() 
34         return "Account" +
35                 "id=" + id +
36                 ", name=‘" + name + ‘\\‘‘ +
37                 ", money=" + money +
38                 ‘‘;
39     
40 

4.在java目录下创建com.cong.dao.AccountDao接口

 1 package com.cong.dao;
 2 
 3 import com.cong.pojo.Account;
 4 
 5 import java.util.List;
 6 
 7 public interface AccountDao 
 8     List<Account> findAllAccount();//find all
 9     Account findAccountById(int id);//find one
10     void saveAccount(Account account);//save
11     void updateAccount(Account account);//update
12     void deleteAccount(int id);//delete
13 

5.在dao目录下创建实现类AccountDaoImpl

 1 package com.cong.dao;
 2 
 3 import com.cong.pojo.Account;
 4 import org.apache.commons.dbutils.QueryRunner;
 5 import org.apache.commons.dbutils.handlers.BeanHandler;
 6 import org.apache.commons.dbutils.handlers.BeanListHandler;
 7 
 8 import java.util.List;
 9 
10 public class AccountDaoImpl implements AccountDao 
11     private QueryRunner runner;
12 
13     public void setRunner(QueryRunner runner) 
14         this.runner = runner;
15     
16 
17     @Override
18     public List<Account> findAllAccount() 
19         try 
20             return runner.query("select * from account", new BeanListHandler<Account>(Account.class));
21          catch (Exception e) 
22             throw new RuntimeException(e);
23         
24     
25 
26     @Override
27     public Account findAccountById(int id) 
28         try
29             return runner.query("select * from account where id = ? ",new BeanHandler<Account>(Account.class),id);
30         catch (Exception e) 
31             throw new RuntimeException(e);
32         
33     
34 
35     @Override
36     public void saveAccount(Account account) 
37         try 
38             runner.update("insert into account(name,money) values(?,?)",account.getName(),account.getMoney());
39          catch (Exception e) 
40             throw new RuntimeException(e);
41         
42     
43 
44     @Override
45     public void updateAccount(Account account) 
46         try 
47             runner.update("update account set name = ?,money = ? where id =?",account.getName(),account.getMoney(),account.getId());
48          catch (Exception e) 
49             throw new RuntimeException(e);
50         
51     
52 
53     @Override
54     public void deleteAccount(int id) 
55         try 
56             runner.update("delete from account where id = ?",id);
57          catch (Exception e) 
58             throw new RuntimeException(e);
59         
60     
61 

6.在java目录下创建com.cong.service.AccountService接口

 1 package com.cong.service;
 2 
 3 import com.cong.pojo.Account;
 4 
 5 import java.util.List;
 6 
 7 public interface AccountService 
 8     List<Account> findAllAccount();//find all
 9     Account findAccountById(int id);//find one
10     void saveAccount(Account account);//save
11     void updateAccount(Account account);//update
12     void deleteAccount(int id);//delete
13 

7.在service目录创建实现类AccountServiceImpl

 1 package com.cong.service;
 2 
 3 import com.cong.dao.AccountDao;
 4 import com.cong.pojo.Account;
 5 
 6 import java.util.List;
 7 public class AccountServiceImpl implements AccountService 
 8     //业务层都是调用持久层的，所以需要有一个持久层的对象
 9     private AccountDao accountDao;
10 
11     public void setAccountDao(AccountDao accountDao) 
12         this.accountDao = accountDao;
13     
14 
15     @Override
16     public List<Account> findAllAccount() 
17         return  accountDao.findAllAccount();
18     
19 
20     @Override
21     public Account findAccountById(int id) 
22         return accountDao.findAccountById(id);
23     
24 
25     @Override
26     public void saveAccount(Account account) 
27         accountDao.saveAccount(account);
28     
29 
30     @Override
31     public void updateAccount(Account account) 
32         accountDao.updateAccount(account);
33     
34 
35     @Override
36     public void deleteAccount(int id) 
37         accountDao.deleteAccount(id);
38     
39 

8.在resources下面创建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"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans.xsd">
    <!-- 配置Service -->
    <bean id="accountService" class="com.cong.service.AccountServiceImpl">
        <!-- 注入dao -->
        <property name="accountDao" ref="accountDao"></property>
    </bean>

    <!--配置Dao对象-->
    <bean id="accountDao" class="com.cong.dao.AccountDaoImpl">
        <!-- 注入QueryRunner -->
        <property name="runner" ref="runner"></property>
    </bean>

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

9.在test.java目录下创建Test类进行单元测试

 1 import com.cong.pojo.Account;
 2 import com.cong.service.AccountService;
 3 import org.junit.Test;
 4 import org.springframework.context.ApplicationContext;
 5 import org.springframework.context.support.ClassPathXmlApplicationContext;
 6 
 7 import java.util.List;
 8 
 9 public class AccountServiceTest 
10     ApplicationContext context = new ClassPathXmlApplicationContext("bean.xml");
11     AccountService as = (AccountService) context.getBean("accountService");
12    @Test
13     public void testFindAll()16        List<Account> list = as.findAllAccount();
17        for (Account account : list) 
18            System.out.println(account.toString());
19        
20    
21     @Test
22     public void testFindOne()25         Account account = as.findAccountById(1);
26         System.out.println(account.toString());
27     
28     @Test
29     public void testSave()
30        Account account = new Account();
31        account.setName("cong");
32        account.setMoney(5);
33        as.saveAccount(account);
34     
35     @Test
36     public void testUpdate()
37         Account account = new Account();
38         account.setName("rainbow");
39         account.setMoney(50000);
40         account.setId(3);
41         as.updateAccount(account);
42     
43     @Test
44     public void testDelete()
45         as.deleteAccount(4);
46     
47 

10.testFindAll方法测试结果（测试了一轮，所以有点不同）

11.完整项目结构