1 需求和技术要求

1.1 需求

  • 实现账户的CRUD。

1.2 技术要求

  • 使用Spring的IOC实现对象的管理。
  • 使用QueryRunner作为持久层的解决方案。
  • 使用C3p0作为数据源。

2 搭建环境并配置

2.1 导入所需要的依赖jar包的maven坐标

<dependency>

    <groupId>org.springframework</groupId>

    <artifactId>spring-context</artifactId>

    <version>5.2.0.RELEASE</version>

</dependency>

<dependency>

    <groupId>org.springframework</groupId>

    <artifactId>spring-test</artifactId>

    <version>5.2.0.RELEASE</version>

    <scope>test</scope>

</dependency>

<dependency>

    <groupId>junit</groupId>

    <artifactId>junit</artifactId>

    <version>4.12</version>

</dependency>

<dependency>

    <groupId>mysql</groupId>

    <artifactId>mysql-connector-java</artifactId>

    <version>8.0.17</version>

</dependency>

<dependency>

    <groupId>commons-dbutils</groupId>

    <artifactId>commons-dbutils</artifactId>

    <version>1.7</version>

</dependency>

<dependency>

    <groupId>com.mchange</groupId>

    <artifactId>c3p0</artifactId>

    <version>0.9.5.4</version>

</dependency>

2.2 数据库脚本

SET NAMES utf8mb4;

SET FOREIGN_KEY_CHECKS = 0;

-- ----------------------------

-- Table structure for account

-- ----------------------------

DROP TABLE IF EXISTS `account`;

CREATE TABLE `account`  (

  `id` int(11) NOT NULL AUTO_INCREMENT COMMENT '主键',

  `name` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT '名称',

  `money` double(11, 0) NULL DEFAULT NULL COMMENT '余额',

  PRIMARY KEY (`id`) USING BTREE

) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic;

-- ----------------------------

-- Records of account

-- ----------------------------

INSERT INTO `account` VALUES (1, 'aaa', 1000);

INSERT INTO `account` VALUES (2, 'bbb', 1000);

SET FOREIGN_KEY_CHECKS = 1;

2.3 编写实体类

  • Account.java
package com.sunxiaping.spring5.domain;

import java.io.Serializable;

/**

 * 账户

 */

public class Account implements Serializable {

    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;

    }

}

2.4 编写持久层代码

  • IAccountDao.java
package com.sunxiaping.spring5.dao;

import com.sunxiaping.spring5.domain.Account;

import java.util.List;

/**

 * 账户的持久层接口

 */

public interface IAccountDao {

    /**

     * 保存账户

     *

     * @param account

     */

    void save(Account account);

    /**

     * 更新账户

     *

     * @param account

     */

    void update(Account account);

    /**

     * 删除账户

     *

     * @param id

     */

    void delete(Integer id);

    /**

     * 根据主键查询账户信息

     *

     * @param id

     * @return

     */

    Account findById(Integer id);

    /**

     * 查询所有

     *

     * @return

     */

    List<Account> findAll();

}
  • AccountDaoImpl.java
package com.sunxiaping.spring5.dao.impl;

import com.sunxiaping.spring5.dao.IAccountDao;

import com.sunxiaping.spring5.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;

@Repository

public class AccountDaoImpl implements IAccountDao {

    @Autowired

    private QueryRunner queryRunner;

    @Override

    public void save(Account account) {

        try {

            queryRunner.update("insert into account(name,money) values (?,?)", account.getName(), account.getMoney());

        } catch (SQLException e) {

            e.printStackTrace();

        }

    }

    @Override

    public void update(Account account) {

        try {

            queryRunner.update("update account set name=?,money=? where id = ?", account.getName(), account.getMoney(), account.getId());

        } catch (SQLException e) {

            e.printStackTrace();

        }

    }

    @Override

    public void delete(Integer id) {

        try {

            queryRunner.update("delete from account where id = ?", id);

        } catch (SQLException e) {

            e.printStackTrace();

        }

    }

    @Override

    public Account findById(Integer id) {

        try {

            return queryRunner.query("select * from account where id = ?", new BeanHandler<>(Account.class), id);

        } catch (SQLException e) {

            e.printStackTrace();

        }

        return null;

    }

    @Override

    public List<Account> findAll() {

        try {

            return queryRunner.query("select * from account", new BeanListHandler<>(Account.class));

        } catch (SQLException e) {

            e.printStackTrace();

        }

        return null;

    }

}

2.5 编写业务层代码

  • IAccountService.java
package com.sunxiaping.spring5.service;

import com.sunxiaping.spring5.domain.Account;

import java.util.List;

public interface IAccountService {

    /**

     * 保存账户

     *

     * @param account

     */

    void save(Account account);

    /**

     * 更新账户

     *

     * @param account

     */

    void update(Account account);

    /**

     * 删除账户

     *

     * @param id

     */

    void delete(Integer id);

    /**

     * 根据主键查询账户信息

     *

     * @param id

     * @return

     */

    Account findById(Integer id);

    /**

     * 查询所有

     *

     * @return

     */

    List<Account> findAll();

}
  • AccountServiceImpl.java
package com.sunxiaping.spring5.service.impl;

import com.sunxiaping.spring5.dao.IAccountDao;

import com.sunxiaping.spring5.domain.Account;

import com.sunxiaping.spring5.service.IAccountService;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Service;

import java.util.List;

@Service

public class AccountServiceImpl implements IAccountService {

    @Autowired

    private IAccountDao accountDao;

    @Override

    public void save(Account account) {

        accountDao.save(account);

    }

    @Override

    public void update(Account account) {

        accountDao.update(account);

    }

    @Override

    public void delete(Integer id) {

        accountDao.delete(id);

    }

    @Override

    public Account findById(Integer id) {

        return accountDao.findById(id);

    }

    @Override

    public List<Account> findAll() {

        return accountDao.findAll();

    }

}

2.6 数据库配置文件

  • jdbc.properties
jdbc.driverClass=com.mysql.cj.jdbc.Driver

jdbc.url=jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&useSSL=false&serverTimezone=GMT%2B8&allowPublicKeyRetrieval=true

jdbc.user=root

jdbc.password=123456

2.7 数据库配置类

  • JdbcConfig.java
package com.sunxiaping.spring5.config;

import com.mchange.v2.c3p0.ComboPooledDataSource;

import org.apache.commons.dbutils.QueryRunner;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.PropertySource;

import javax.sql.DataSource;

import java.beans.PropertyVetoException;

@PropertySource("classpath:jdbc.properties")

public class JdbcConfig {

    @Value("${jdbc.driverClass}")

    private String driverClass;

    @Value("${jdbc.url}")

    private String jdbcUrl;

    @Value("${jdbc.user}")

    private String user;

    @Value("${jdbc.password}")

    private String password;

    @Bean

    public DataSource dataSource() {

        try {

            ComboPooledDataSource dataSource = new ComboPooledDataSource();

            dataSource.setJdbcUrl(jdbcUrl);

            dataSource.setDriverClass(driverClass);

            dataSource.setUser(user);

            dataSource.setPassword(password);

            return dataSource;

        } catch (PropertyVetoException e) {

            throw new RuntimeException(e);

        }

    }

    @Bean

    public QueryRunner queryRunner(DataSource dataSource) {

        return new QueryRunner(dataSource);

    }

}

2.8 Spring的配置类

  • SpringConfiguration.java
package com.sunxiaping.spring5.config;

import org.springframework.context.annotation.ComponentScan;

import org.springframework.context.annotation.Configuration;

import org.springframework.context.annotation.Import;

@Configuration

@ComponentScan("com.sunxiaping.spring5")

@Import(JdbcConfig.class)

public class SpringConfiguration {

}

2.9 测试

  • 示例：
package com.sunxiaping;

import com.sunxiaping.spring5.config.SpringConfiguration;

import com.sunxiaping.spring5.service.IAccountService;

import org.junit.Test;

import org.junit.runner.RunWith;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.test.context.ContextConfiguration;

import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

@RunWith(SpringJUnit4ClassRunner.class)

@ContextConfiguration(classes = SpringConfiguration.class)

public class spring5Test {

    @Autowired

    private IAccountService accountService;

    @Test

    public void test() {

        System.out.println(accountService);

    }

}

最新文章

  1. JavaScript_js模拟键盘输入
  2. js数据类型
  3. 分布式系列之二——Adaptor设计模式
  4. interviewbit :Min Steps in Infinite GridBookmark Suggest Edit
  5. win2003域控制器密码遗忘如何修改
  6. SQL Server里一些未公开的扩展存储过程
  7. Mongodb使用
  8. Oracle11g 创建表空间、创建用户、角色授权、导入导出表以及中文字符乱码问题
  9. Mysql5.7.17中文乱码问题
  10. UVALive - 3938：&quot;Ray, Pass me the dishes!&quot;
  11. Netty中如何写大型数据
  12. mysql排序之ORDER BY IF、ORDER BY配合IN、TIMESTAMPDIFF、TIMESTAMPADD、FIELD
  13. AngualrJS中制作一个有关菜单的Directive
  14. .NET的关于人脸识别引擎分享(C#)
  15. 学习-工作：GTD
  16. Intorduction of Annotation ,about examples in Hello1.java
  17. sklearn文本特征提取
  18. sublime在混杂的log数据中提取你想要的内容
  19. Mysql隔离级别 sql示例理解
  20. 关于文件格式Fuzzing测试与漏洞挖掘的学习

热门文章

  1. tomcat gc和内存
  2. 慕课网_Java入门第二季
  3. Hibernate框架 初识 ORM概念
  4. 【JAVA系列】Google爬虫如何抓取JavaScript的？
  5. js实现动画（移动方块）
  6. 《Python编程从0到1》笔记5——图解递归你肯定看完就能懂！
  7. Synchronized及其实现原理（一）
  8. PTA(Basic Level)1012.数字分类
  9. CentOS 上面 恢复 Oracle 数据库实例的简单操作流程
  10. GTS原理、架构