【Spring框架学习】综合案例巩固

时间：2020-05-05 14:05:00 阅读：74 评论：0 收藏：0 [点我收藏+]

标签：gconf logo out wired 方法 imp autowired dao man

技术图片

spring框架综合案例：

首先是保存实体类信息的entity层：

entity层：

UserInfo类

package edu.youzg.entity;

public class UserInfo {
    private int id;
    private String name;
    private String password;
    private float balance;

    public UserInfo() {
    }

    public UserInfo(String name) {
        this.name = name;
    }

    public UserInfo(String name, String password) {
        this.password = password;
        this.name = name;
    }

    public UserInfo(int id, String name, int balance) {
        this.id = id;
        this.name = name;
        this.balance = balance;
    }

    public UserInfo(int id, String name, String password, int balance) {
        this.id = id;
        this.name = name;
        this.password = password;
        this.balance = balance;
    }

    public int getId() {
        return id;
    }

    public UserInfo setId(int id) {
        this.id = id;
        return this;
    }

    public String getName() {
        return name;
    }

    public UserInfo setName(String name) {
        this.name = name;
        return this;
    }

    public String getPassword() {
        return password;
    }

    public UserInfo setPassword(String password) {
        this.password = password;
        return this;
    }

    public float getBalance() {
        return balance;
    }

    public UserInfo setBalance(float balance) {
        this.balance = balance;
        return this;
    }

    @Override
    public String toString() {
        StringBuffer str = new StringBuffer();
        str.append("账户[").append(name).append("]目前余额为：[").append(balance).append("]元");
        return str.toString();
    }

}

接下来是联系数据库的dao层：

dao层：

IUserDao接口

package edu.youzg.dao;

import edu.youzg.entity.UserInfo;

public interface IUserDao {
    void saveUser(String name, String password);
    void updateInfo(String name, String password, int id);
    void updateBalance(int id, float deltaMoney);
    UserInfo queryByLoginName(String name);
    UserInfo queryByID(int id);
    void deleteUser(String name, int id);
}

UserDao类

package edu.youzg.dao;

import edu.youzg.entity.UserInfo;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;

import java.util.List;

/**
 * 用户的数据库访问类
 */
@Repository
public class UserDao implements IUserDao {

    @Autowired
    private JdbcTemplate jt;

    @Override
    public void saveUser(String name, String password) {
        String sql = "insert into account(name, password, balance) values(?, ?, ?)";
        jt.update(sql, name, password, 0);
    }

    @Override
    public void updateInfo(String name, String password, int id) {
        String sql = "update account set name=?, password=? where id=?";
        jt.update(sql, name, password, id);
    }

    @Override
    public void updateBalance(int id, float deltaMoney) {
        String sql = "update account set balance=balance+? where id=?";
        jt.update(sql, deltaMoney, id);
    }

    @Override
    public UserInfo queryByLoginName(String name) {
        String sql = "select * from account where name=? ";
        List<UserInfo> list = jt.query(sql, new BeanPropertyRowMapper<UserInfo>(UserInfo.class), name);
        if (list!=null && list.size()>=1){
            return list.get(0);
        }
        return null;
    }


    @Override
    public UserInfo queryByID(int id) {
        String sql="select * from account where id=?";
        //返回一条数据
        // return jt.queryForObject(sql,new BeanPropertyRowMapper<UserInfo>(UserInfo.class),name);
        List<UserInfo> list = jt.query(sql, new BeanPropertyRowMapper<UserInfo>(UserInfo.class), id);
        if(list!=null && list.size()>=1){
            return list.get(0);
        }
        return null;
    }

    @Override
    public void deleteUser(String name, int id) {
        String sql = "delete from account where name=? and id=?";
        jt.update(sql, name, id);
    }

}

然后是提供对外功能的service层：

service层：

IUserService接口：

package edu.youzg.service;

import edu.youzg.entity.UserInfo;

/**
 * @Author: Youzg
 * @CreateTime: 2020-05-05 10:06
 * @Description:带你深究Java的本质！
 */
public interface IUserService {
    // 用户功能
    UserInfo register(UserInfo user);
    UserInfo login(UserInfo user);
    void saveMoney(UserInfo user, float money);
    boolean withdrawMonney(UserInfo user, float money);
    float queryBalance(UserInfo user);
    void transfer(UserInfo fromUser, UserInfo toUser, float money);

    // 管理员功能
    void deleteUser(UserInfo user);
}

UserService类

package edu.youzg.service;

import edu.youzg.dao.IUserDao;
import edu.youzg.entity.UserInfo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

/**
 * 用户业务逻辑
 */
@Transactional	//添加 事务控制
@Service("userService")
public class UserService implements IUserService {

    //数据库访问对象
    @Autowired
    private IUserDao dao;

    @Override
    public UserInfo register(UserInfo user) {
        String name = user.getName();
        String pass = user.getPassword();
        UserInfo userInfo = dao.queryByLoginName(name);
        if (null!=userInfo) {
            System.out.println("用户名已存在！");
            return new UserInfo().setId(-1);
        }
        dao.saveUser(name, pass);

        // 获取id，以便上层处理
        UserInfo res = dao.queryByLoginName(name);

        return res;
    }

    @Override
    public UserInfo login(UserInfo user) {
        UserInfo userInfo = dao.queryByLoginName(user.getName());
        if (userInfo.getId() > 0) {
            return userInfo;
        }
        return null;
    }

    @Override
    public void saveMoney(UserInfo user, float money) {
        UserInfo userInfo = dao.queryByLoginName(user.getName());
        if (null==userInfo || userInfo.getId() <= 0) {
            return;
        }
        dao.updateBalance(userInfo.getId(), money);
    }

    @Override
    public boolean withdrawMonney(UserInfo user, float money) {
        UserInfo userInfo = dao.queryByLoginName(user.getName());
        if (null == userInfo || userInfo.getBalance() < money) {
            return false;
        }

        dao.updateBalance(userInfo.getId(), -money);
        return true;
    }

    @Override
    public float queryBalance(UserInfo user) {
        UserInfo userInfo = dao.queryByLoginName(user.getName());
        if (null == userInfo) {
            return -1;
        }
        return userInfo.getBalance();
    }

    @Override
    public void deleteUser(UserInfo user) {
        UserInfo userInfo = dao.queryByLoginName(user.getName());
        if (null == userInfo) {
            return;
        }
        dao.deleteUser(userInfo.getName(), userInfo.getId());
    }

    // 转账业务逻辑
    @Override
    public void transfer(UserInfo fromUser, UserInfo toUser, float money)  {
        UserInfo from = dao.queryByLoginName(fromUser.getName());
        UserInfo to = dao.queryByLoginName(toUser.getName());
        if (null==from || null==to) {
            return;
        }
        //账号-钱
        dao.updateBalance(from.getId(), -money);

        //账号+钱
        dao.updateBalance(to.getId(), money);
    }

}

接下来是运用了aop技术、用于日志管理的切面层：

aspect层：

LoggerAspect

package edu.youzg.aspect;

import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.springframework.stereotype.Component;

@Component
@Aspect
public class LoggerAspect {

    @Pointcut("execution(* edu.youzg.service.*.*(..))")
    public void pointCut(){}

    @Around("pointCut()")
    public Object around(ProceedingJoinPoint pjp) throws Throwable {
        Object result = null;
        long stime = System.currentTimeMillis();
        try {
            result = pjp.proceed(pjp.getArgs());//执行目标业务逻辑
        } finally {
            long etime = System.currentTimeMillis();
            long time = etime - stime;    //方法执行耗时时间
            String mname = pjp.getSignature().getName();
            String cname = pjp.getTarget().getClass().getName();
            //输出什么类，什么方法，什么时间，什么参数被执行了
            String msg = String.format("类名：" + cname + "方法名：" + mname + "执行耗时(毫秒)：" + time);
            System.out.println(msg);
        }
        return result;
    }

}

最后是用于配置spring、开启各种注解扫描的配置层：

config层：

SpringConfig类

package edu.youzg.config;

import com.alibaba.druid.pool.DruidDataSource;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.*;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.annotation.EnableTransactionManagement;

import javax.sql.DataSource;

/**
 * 使用java类配置spring
 */

@Configuration//声明这是spring配置类
@ComponentScan("edu.youzg")//扫描包
@EnableAspectJAutoProxy//开启aop注解支持
@PropertySource("youzgDB.properties")//读取配置文件
@EnableTransactionManagement//开启事务解析器
public class SpringConfig {
    @Value("${db.username}")
    private String userName;
    @Value("${db.password}")
    private String passWord;
    @Value("${db.url}")
    private String url;
    @Value("${db.driverClassName}")
    private String driverClassName;

    //  创建数据源
    @Bean
    public DruidDataSource getDruidDataSource(){
        DruidDataSource ds=new DruidDataSource();
        ds.setUsername(userName);
        ds.setPassword(passWord);
        ds.setUrl(url);
        ds.setDriverClassName(driverClassName);
        //更多数据库连接池调优参数 根据官方文档设置即可
        return ds;
    }
    //创建jdbc模板类对象
    @Bean
    public JdbcTemplate getJdbcTemplate(DataSource ds){
        return new JdbcTemplate(ds);
    }

    //创建事务管理器
    @Bean
    public DataSourceTransactionManager getDataSourceTransactionManager(DataSource ds){
        return new DataSourceTransactionManager(ds);
    }

}

配置文件：

db.driverClassName=com.mysql.jdbc.Driver
db.url=jdbc:mysql://localhost:3306/dbstudy?serverTimezone=UTC&characterEncoding=utf-8 
db.username=root
db.password=123456

最后，本人来给出测试类：

测试类：

YouzgTest类

package edu.youzg.test;

import edu.youzg.config.SpringConfig;
import edu.youzg.dao.TransferDao;
import edu.youzg.entity.UserInfo;
import edu.youzg.service.IUserService;
import edu.youzg.service.UserService;
import org.springframework.context.ApplicationContext;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;

/**
 * @Author: Youzg
 * @CreateTime: 2020-05-03 08:50
 * @Description:带你深究Java的本质！
 */
public class YouzgTest {

    public static void main(String[] args) {
        ApplicationContext context = new AnnotationConfigApplicationContext(SpringConfig.class);
        IUserService service = context.getBean("userService", IUserService.class);
        UserInfo newUser = new UserInfo("youzg666", "123456");
        service.register(newUser);
        service.saveMoney(newUser, 100);
        service.transfer(newUser, new UserInfo("youzg"), 20);
    }

}

接下来，本人来展示下运行结果：

运行结果：

【运行前】初始账户数据

技术图片

【运行后】控制台日志

技术图片

【运行后】最终账户数据

技术图片

【Spring框架学习】综合案例巩固

标签：gconf logo out wired 方法 imp autowired dao man

原文地址：https://www.cnblogs.com/codderYouzg/p/12830495.html

踩

(0)

评论一句话评论（0）

分享档案

更多>

2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)

周排行

【Spring框架学习】综合案例 巩固

spring框架综合案例：

entity层：

UserInfo类

dao层：

IUserDao接口

UserDao类

service层：

IUserService接口：

UserService类

aspect层：

LoggerAspect

config层：

SpringConfig类

配置文件：

测试类：

YouzgTest类

运行结果：

【运行前】初始账户数据

【运行后】控制台日志

【运行后】最终账户数据

【Spring框架学习】综合案例巩固