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

【JavaWeb学习Day17】

article 2025/2/22 15:17:21

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();


http://www.kler.cn/a/556244.html

相关文章：

  • JUC并发—8.并发安全集合一
  • 【精调】LLaMA-Factory 快速开始4 自定义个一个sharegpt数据集并训练
  • 在Spark中，如何使用DataFrame进行高效的数据处理
  • 【Apache Paimon】-- Flink 消费 kafka 数据异常
  • Linux 核心架构与组件(2025更新中)
  • 2024.2.21总结
  • 如何排查服务器 DNS 解析失败的问题
  • 【数据挖掘】可信度
  • 图论 之 最小生成树
  • 大数据组件(四)快速入门实时数据湖存储系统Apache Paimon(3)
  • 【rt-thread】rt-thread 控制 led 的两种方式
  • 深入浅出GraphQL：现代API设计的未来
  • Unity 全局屏幕点击特效
  • Chatgpt论文润色指令整理
  • 在PyTorch中使用插值法来优化卷积神经网络（CNN）所需硬件资源
  • 小结：策略路由（Policy-based Routing，PBR）
  • 相机开发调中广角和焦距有什么不一样
  • 智能网络感知，打造极致流畅的鸿蒙原生版中国移动云盘图文体验
  • 1287. 有序数组中出现次数超过25%的元素
  • OkHttp使用和源码分析学习(二)