当前位置： 首页 > news >正文

【JavaWeb学习Day17】

news 来源：原创 2025/5/21 15:18:09

Tlias智能学习系统（员工管理）

新增员工：

三层架构职责：

Controller：1.接收请求参数（员工信息）；2.调用service方法；3.响应结果。

具体实现：

/**
 *新增员工
 */
@PostMapping
public Result save(@RequestBody Emp emp){
    log.info("新增员工：{}",emp);
    empService.save(emp);
    return Result.success();
​
}

Service：1.保存员工基本信息；2.批量保存员工的工作经历信息。

具体实现：

@Override
    public void save(Emp emp) {
        //1.保存员工的基本信息
        emp.setCreateTime(LocalDateTime.now());
        emp.setUpdateTime(LocalDateTime.now());
        empMapper.insert(emp);
​
        //2.保存员工的工作经历信息
        List<EmpExpr> exprList = emp.getExprList();
        if(!CollectionUtils.isEmpty(exprList)){
            //遍历集合，为empId赋值
            exprList.forEach(empExpr -> {
                empExpr.setEmpId(emp.getId());
            });
            empExprMapper.insertBatch(exprList);//Batch批量保存
        }
    }

Mapper：

-- 新增员工
-- 保存员工基本信息 emp
insert into emp(username, name, gender, phone, job, salary, image, entry_date, dept_id, create_time, update_time)
    values ('linpingzhi','林平之',1,'13309091234',1,600,'1.jpg','2020-01-01',1,'2024-10-01 00:00:00','2024-10-01 00:00:00');
-- 保存员工工作经历信息 emp_expr
insert into emp_expr(emp_id, begin, end, company, job)
    values (37,'2020-01-01','2021-01-01','百度','java开发'),(37,'2021-01-01','2022-01-01','字节','java开发');

具体实现：

EmpMapper：

    /**
     * 新增员工基本信息
     * @param emp
     */
    @Options(useGeneratedKeys = true,keyProperty = "id") //获取到生成的主键 -- 主键返回
    @Insert("insert into emp(username, name, gender, phone, job, salary, image, entry_date, dept_id, create_time, update_time)" +
            "    values (#{username},#{name},#{gender},#{phone},#{job},#{salary},#{image},#{entryDate},#{deptId},#{createTime},#{updateTime})")
    void insert(Emp emp);

EmpExprMapper：

/**
 * 批量插入员工工作经历信息
 */
void insertBatch(List<EmpExpr> exprList);

批量插入员工的工作经历用到配置文件（动态SQL）：

EmpExprMapper.xml：

<!DOCTYPE mapper
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.itheima.mapper.EmpExprMapper">
<!--    批量保存员工工作经历-->
    <insert id="insertBatch">
        insert into emp_expr(emp_id, begin, end, company, job) values
            <foreach collection="exprList" item="expr" separator=",">
                (#{expr.empId},#{expr.begin},#{expr.end},#{expr.company},#{expr.job})
            </foreach>
    </insert>
</mapper>

动态SQL：<foreach>属性说明：

1.collection：集合名称

2.item：集合遍历出来的元素/项

3.separator：每一次遍历使用的分隔符

4.open：遍历开始前拼接的片段

5.close：遍历结束后拼接的片段

事务管理：

问：保存员工的基本信息成功了，而保存工作经历失败了，是否OK？

答：不可以，因为这是属于一个业务操作，如果保存员工信息成功了，保存工作经历信息失败了，就会造成数据库数据的不完整、不一致。

介绍&操作：

概念：事务是一组操作的集合，它是一个不可分割的工作单位。事务会把所有的操作作为一个整体一起向系统提交或撤销操作请求，即这些操作，要么同时成功，要么同时失败。

（注意：默认MySQL的事务是自动提交的，也就是说，当执行一条DML语句，MySQL会立即隐式的提交事务。）

操作：事务控制主要三步操作：开启事务、提交事务/回滚事务。

-- 开启事务
start transaction; / begin;
​
-- 1. 保存员工基本信息
insert into emp values (39, 'Tom', '123456', '汤姆', 1, '13300001111', 1, 4000, '1.jpg', '2023-11-01', 1, now(), now());
​
-- 2. 保存员工的工作经历信息
insert into emp_expr(emp_id, begin, end, company, job) values (39,'2019-01-01', '2020-01-01', '百度', '开发'),                                                                                                       (39,'2020-01-10', '2022-02-01', '阿里', '架构');
​
-- 提交事务(全部成功)
commit;
​
-- 回滚事务(有一个失败)
rollback;

Spring事务管理：

注解：@Transactional

作用：将当前方法交给spring进行事务管理，方法执行前，开启事务；成功执行完毕，提交事务；出现异常，回滚事务

位置：业务（service）层的方法上、类上、接口上（推荐使用在方法上）

@Transactional //事务管理 - 默认出现运行时异常RunTimeException才会回滚
@Override
public void save(Emp emp) {
    //1.保存员工的基本信息
    emp.setCreateTime(LocalDateTime.now());
    emp.setUpdateTime(LocalDateTime.now());
    empMapper.insert(emp);
​
    //2.保存员工的工作经历信息
    List<EmpExpr> exprList = emp.getExprList();
    if(!CollectionUtils.isEmpty(exprList)){
        //遍历集合，为empId赋值
        exprList.forEach(empExpr -> {
            empExpr.setEmpId(emp.getId());
        });
        empExprMapper.insertBatch(exprList);//Batch批量保存
    }
}

事务进阶：

1.rollbackFor属性用于控制出现何种异常类型，回滚事务。

@Transactional(rollbackFor = {Exception.class}) //事务管理 所有异常都回滚

2.事务传播行为（propagation）：指的是当一个事务方法被另一个事务方法调用时，这个事务方法应该如何进行事务控制。

@Transactional(propagation = Propagation.REQUIRED)

案例：新增员工信息，记录日志（propagation）

需求：在新增员工信息时，无论是成功还是失败，都要记录操作日志。

步骤：1.准备日志表emp_log、实体类Emplog、Mapper接口EmpLogMapper；2.在新增员工时记录日志

@Transactional(rollbackFor = {Exception.class}) //事务管理 - 默认出现运行时异常RunTimeException才会回滚
@Override
public void save(Emp emp) {
    try{
        //1.保存员工的基本信息
        emp.setCreateTime(LocalDateTime.now());
        emp.setUpdateTime(LocalDateTime.now());
        empMapper.insert(emp);
​
        //2.保存员工的工作经历信息
        List<EmpExpr> exprList = emp.getExprList();
        if(!CollectionUtils.isEmpty(exprList)){
            //遍历集合，为empId赋值
            exprList.forEach(empExpr -> {
                empExpr.setEmpId(emp.getId());
            });
            empExprMapper.insertBatch(exprList);//Batch批量保存
        }
​
    }finally {
        //记录操作日志
        EmpLog empLog = new EmpLog(null,LocalDateTime.now(),"新增员工"+emp);
        empLogService.insertLog(empLog);
​
    }
​
​
}
@Service
public class EmpLogServiceImpl implements EmpLogService {
​
    @Autowired
    private EmpLogMapper empLogMapper;
    @Transactional(propagation = Propagation.REQUIRES_NEW)
    @Override
    public void insertLog(EmpLog empLog) {
        empLogMapper.insert(empLog);
    }
}

四大特性（ACID）：

原子性Atomicity：事务是不可分割的最小单元，要么全部成功，要么全部失败

一致性Consistency：事务完成时，必须使所有的数据都保持一致状态

隔离性Isolation：数据库系统提供的隔离机制，保证事务在不受外部并发操作影响的独立环境下运行

持久性Durability：事务一旦提交或回滚，他对数据库中的数据的改变就是永久的

文件上传：

简介：

文件上传：是指将本地的图片、视频、音频等文件上传到服务器，供其他用户浏览或者下载的过程。

文件上传在项目中应用非常广泛，我们经常发微博、发微信朋友圈都用到了文件上传功能。

本地存储：

@Slf4j
@RestController
public class UploadController {
    @PostMapping("/upload")
    public Result upload(String name, Integer age, MultipartFile file) throws IOException {
        log.info("接收到的参数：{},{},{}",name,age,file);
        //获取原始文件名
        String originalFileName  = file.getOriginalFilename();
​
​
        //新的文件名
        String extension = originalFileName.substring(originalFileName.lastIndexOf("."));
        String newFileName = UUID.randomUUID().toString() + extension;
​
        //保存文件
        file.transferTo(new File("D:\\xxzl\\java\\file\\"+originalFileName));
         return Result.success();
    }
}

（注意：上传文件大小受限去设置yml文件）

spring:
    servlet:
        multipart:
            #最大单个文件大小
            max-file-size: 10MB
            #最大请求大小（包括所有文件和表单数据）
            max-request-size: 100MB

阿里云OSS：

阿里云：阿里云是阿里巴巴集团旗下全球领先的云计算公司，也是全球最大的云服务提供商。

阿里云OSS：阿里云对象存储OSS（Object Storage Service），是一款海量、安全、低成本、高可靠的云储存服务。使用OSS，您可以通过网络随时存储和调用包括文本、图片、音频和视频等在内的各种文件。

第三方服务-通用思路：准备工作->参照官方SDK编写入门程序->集成使用

(SDK:Software Development Kit的缩写，软件开发工具包，包括辅助软件开发的依赖（jar包），示例代码等，都可以叫SDK)

阿里云OSS—使用步骤：

准备工作：注册阿里云（实名认证）->充值->开通对象存储服务OSS->创建bucket->获取并配置AccessKey（密钥）

(Bucket：存储空间是用户用于存储对象（Object，就是文件）的容器，所有的对象都必须隶属于某个存储空间)

入门程序：

package com.itheima;
​
import com.aliyun.oss.*;
import com.aliyun.oss.common.auth.CredentialsProviderFactory;
import com.aliyun.oss.common.auth.EnvironmentVariableCredentialsProvider;
import com.aliyun.oss.common.comm.SignVersion;
​
import java.io.ByteArrayInputStream;
import java.io.File;
import java.nio.file.Files;
​
public class Demo {
​
    public static void main(String[] args) throws Exception {
        // Endpoint以华东1（杭州）为例，其它Region请按实际情况填写。
        String endpoint = "https://oss-cn-beijing.aliyuncs.com";
        // 从环境变量中获取访问凭证。运行本代码示例之前，请确保已设置环境变量OSS_ACCESS_KEY_ID和OSS_ACCESS_KEY_SECRET。
        EnvironmentVariableCredentialsProvider credentialsProvider = CredentialsProviderFactory.newEnvironmentVariableCredentialsProvider();
        // 填写Bucket名称，例如examplebucket。
        String bucketName = "java-ai";
        // 填写Object完整路径，例如exampledir/exampleobject.txt。Object完整路径中不能包含Bucket名称。
        String objectName = "001.jpg";
        // 填写Bucket所在地域。以华东1（杭州）为例，Region填写为cn-hangzhou。
        String region = "cn-beijing";
​
        // 创建OSSClient实例。
        ClientBuilderConfiguration clientBuilderConfiguration = new ClientBuilderConfiguration();
        clientBuilderConfiguration.setSignatureVersion(SignVersion.V4);
        OSS ossClient = OSSClientBuilder.create()
            .endpoint(endpoint)
            .credentialsProvider(credentialsProvider)
            .clientConfiguration(clientBuilderConfiguration)
            .region(region)
            .build();
​
        try {
            File file = new File("C:\\Users\\deng\\Pictures\\1.jpg");
            byte[] content = Files.readAllBytes(file.toPath());
​
            ossClient.putObject(bucketName, objectName, new ByteArrayInputStream(content));
        } catch (OSSException oe) {
            System.out.println("Caught an OSSException, which means your request made it to OSS, "
                    + "but was rejected with an error response for some reason.");
            System.out.println("Error Message:" + oe.getErrorMessage());
            System.out.println("Error Code:" + oe.getErrorCode());
            System.out.println("Request ID:" + oe.getRequestId());
            System.out.println("Host ID:" + oe.getHostId());
        } catch (ClientException ce) {
            System.out.println("Caught an ClientException, which means the client encountered "
                    + "a serious internal problem while trying to communicate with OSS, "
                    + "such as not being able to access the network.");
            System.out.println("Error Message:" + ce.getMessage());
        } finally {
            if (ossClient != null) {
                ossClient.shutdown();
            }
        }
    }
}

阿里云OSS-案例集成：

1.引入阿里云OSS文件上传工具类（由官方的示例代码改造而来）

package com.itheima.utils;
​
import com.aliyun.oss.*;
import com.aliyun.oss.common.auth.CredentialsProviderFactory;
import com.aliyun.oss.common.auth.EnvironmentVariableCredentialsProvider;
import com.aliyun.oss.common.comm.SignVersion;
import org.springframework.stereotype.Component;
import java.io.ByteArrayInputStream;
import java.time.LocalDate;
import java.time.format.DateTimeFormatter;
import java.util.UUID;
​
@Component
public class AliyunOSSOperator {
​
    private String endpoint = "https://oss-cn-beijing.aliyuncs.com";
    private String bucketName = "java-ai-0770";
    private String region = "cn-beijing";
​
    public String upload(byte[] content, String originalFilename) throws Exception {
        // 从环境变量中获取访问凭证。运行本代码示例之前，请确保已设置环境变量OSS_ACCESS_KEY_ID和OSS_ACCESS_KEY_SECRET。
        EnvironmentVariableCredentialsProvider credentialsProvider = CredentialsProviderFactory.newEnvironmentVariableCredentialsProvider();
​
        // 填写Object完整路径，例如202406/1.png。Object完整路径中不能包含Bucket名称。
        //获取当前系统日期的字符串,格式为 yyyy/MM
        String dir = LocalDate.now().format(DateTimeFormatter.ofPattern("yyyy/MM"));
        //生成一个新的不重复的文件名
        String newFileName = UUID.randomUUID() + originalFilename.substring(originalFilename.lastIndexOf("."));
        String objectName = dir + "/" + newFileName;
​
        // 创建OSSClient实例。
        ClientBuilderConfiguration clientBuilderConfiguration = new ClientBuilderConfiguration();
        clientBuilderConfiguration.setSignatureVersion(SignVersion.V4);
        OSS ossClient = OSSClientBuilder.create()
                .endpoint(endpoint)
                .credentialsProvider(credentialsProvider)
                .clientConfiguration(clientBuilderConfiguration)
                .region(region)
                .build();
​
        try {
            ossClient.putObject(bucketName, objectName, new ByteArrayInputStream(content));
        } finally {
            ossClient.shutdown();
        }
​
        return endpoint.split("//")[0] + "//" + bucketName + "." + endpoint.split("//")[1] + "/" + objectName;
    }
​
}

2.上传文件接口开发

@Autowired
private AliyunOSSOperator aliyunOSSOperator;
@PostMapping("/upload")
public Result upload(MultipartFile file) throws Exception {
    log.info("文件上传：{}",file.getOriginalFilename());
    //将文件交给OSS存储管理
    String url = aliyunOSSOperator.upload(file.getBytes(), file.getOriginalFilename());
    log.info("文件上传OSS，url：{}",url);
    return Result.success(url);
}

参数配置化：

指将一些需要灵活变化得参数，配置在配置文件中，然后通过@Value注解来注入外部配置得属性。

#阿里云OSS
aliyun:
  oss:
    endpoint: https://oss-cn-beijing.aliyuncs.com
    bucketName: java-ai-0770
    region: cn-beijing
@Value("${aliyun.oss.endpoint}")
private String endpoint ;
@Value("${aliyun.oss.bucketName}")
private String bucketName ;
@Value("${aliyun.oss.region}")
private String region ;

使用@Value注解注入配置文件得配置项，如果配置项多，注入繁琐，不便于维护管理和复用。使用@ConfigurationProperties

@Data
@Component
@ConfigurationProperties(prefix = "aliyun.oss")
public class AliyunOSSProperties {
    private String endpoint;
    private String bucketName;
    private String region;
}
@Autowired
private AliyunOSSProperties aliyunOSSProperties;

		String endpoint = aliyunOSSProperties.getEndpoint();
        String bucketName = aliyunOSSProperties.getBucketName();
        String region = aliyunOSSProperties.getRegion();

相关文章：

  • 深度解析：网站快速收录与服务器性能的关系
  • 【datax系列】datax-web容器化部署搭建（①）
  • 【20250221更新】WebStorm2024.3.3版本安装+使用方法
  • windwos与linux环境下Iperf3带宽测试工具的安装、使用
  • 【前端开发者如何有效利用 deepSeek 为自己服务】
  • 关于Transparent native-to-ascii conversion
  • 算法很美笔记（Java）——动态规划
  • 重启——二分
  • Windows 下免费开源的多格式文件差异对比工具
  • php处理图片出现内存溢出（Allowed memory size of 134217728 bytes exhausted）
  • Redis存储⑩Redis的事务_弱化的原子性
  • DeepSeek 提示词：定义、作用、分类与设计原则
  • 内容中台架构下智能推荐系统的算法优化与分发策略
  • Vue3 状态管理 - Pinia
  • 基于深度学习模型`U-Net`和`segment_anything`（SAM）库的实现示例
  • DuodooBMS源码解读之 cncw_ledger模块
  • Python连接MySQL数据库图文教程，Python连接数据库MySQL入门教程
  • 我的世界1.20.1forge开发教程（6）——自定义燃料，熔炼规则、配方
  • 【JavaScript】《JavaScript高级程序设计 (第4版) 》笔记-Chapter19-表单脚本
  • 《Python实战进阶》专栏 No.3：Django 项目结构解析与入门DEMO
  • 上海地铁：9号线因雨天打滑，佘山往九亭方向部分列车限速运行
  • 围绕加快科创中心建设，上海市委中心组学习会听取专题辅导报告
  • 西安碑林“石刻艺术室”焕新：从汉画像石看到唐代石虎
  • 上海国际电影电视节 | 奔赴电影之城，开启光影新程
  • 河南发布高温橙警：郑州、洛阳等地最高气温将达40℃以上
  • 复旦建校120周年大型义诊举行，百余名专家服务市民超三千人次