员工管理(新增员工)、事务管理和文件上传(阿里云OSS)

员工管理(新增员工)思路就是就是新增的员工基本信息和批量保存员工的工作经历信息也就是后端对应了两条sql语句1.保存员工基本信息Emp实体类中新添一个字段用于保存员工工作经历//封装工作经历 private ListEmpExpr exprList;(1)Controller层/** * 添加员工信息 */ PostMapping public Result save(RequestBodyEmp emp){ log.info(添加员工信息:{}, emp); empService.save(emp); return Result.success(); }json格式数据用RequestBody封装(2)Service层Override public void save(Emp emp) { //1.保存员工基本信息 emp.setCreateTime(LocalDateTime.now()); emp.setUpdateTime(LocalDateTime.now()); empMapper.insert(emp); }处理业务逻辑设置添加事件和更新时间(3)Mapper层/** * 添加员工数据 */ Insert(insert into emp(username,password,name,gender,phone,job,salary,image,entry_date,dept_id,create_time,update_time) values(#{username},#{password},#{name},#{gender},#{phone},#{job},#{salary},#{image},#{entryDate},#{deptId},#{createTime},#{updateTime})) void insert(Emp emp);占位符中是我们的属性名所以命名要与封装类的属性一致2.保存员工工作经历信息只需要针对我们的Service层和Mapper层进行修改(1)Service层Autowired private EmpMapper empMapper; Autowired private EmpExprMapper empExprMapper;Override public void save(Emp emp) { // 1.保存员工基本信息 emp.setCreateTime(LocalDateTime.now()); emp.setUpdateTime(LocalDateTime.now());empMapper.insert(emp);// 2.批量保存员工工作经历 ListEmpExpr exprList emp.getExprList(); // 判断集合是否为空 if (!(CollectionUtils.isEmpty(exprList))) {empExprMapper.insertBatch(exprList);}}运用了CollectionUtils这个工具类的isEmpty方法来判断集合是否为空当然也有别的方法同样的因为我们将Emp对象中的EmpExpr这个对象提取了出来所以调用Mapper接口的方法时也应该调用其自己的Mapper接口也就是一个Mapper接口对应一个表(2)Mapper层Mapper层我们现在需要考虑EmpExprMapper接口的sql语句如何编写因为是批量保存所以这里我们引入一个新技术为动态SQL中的foreach/foreachcollection后面的集合名是接口名中需要循环的集合item是给每一条循环到的List元素起名字separator则是循环输入的sql语句之间用什么符号分割这里我们基于sql语句选择 , (3)注意事项-主键回显-Options这里我们不难发现员工工作经历是需要一个字段emp_id的也就是员工表的主键id但这里我们的前端数据并不会直接传入这个字段我们又该怎么获取呢这里介绍一个技术点叫主键回显Options当Mapper层插入Emp表数据之后Emp数据库便会给出一个Emp.id字段这个时候我们需要返回Emp.id传入我们的EmpExpr表中也就是所谓的主键回显如何拿到主键则借助我们的注解OptionsOptions注解有两个参数一个是useGeneratedKeys true这个注解即开启返回主键另一个是keyProperty 属性名即拿到了主键值之后这个值要赋给哪个属性这里当然是赋值给我们emp对象中的id字段keyProperty id之后我们在Service层则只需要遍历exprList集合然后把拿到的主键字段赋值给empId即可if (!(CollectionUtils.isEmpty(exprList))) { exprList.forEach(empExpr - empExpr.setEmpId(emp.getId())); empExprMapper.insertBatch(exprList); }最后我们开始使用Options这个注解有个非常重要的注意事项Options注解必须和Insert注解一起使用不能混用或者就是在xml中一起配置也就是如下1全xmlmapper namespaceEmpMapper insert idinsertuseGeneratedKeystrue keyPropertyid insert into emp(...) values(...) /insert /mapper2全注解形式Insert(insert into emp(...) values(...))Options(useGeneratedKeys true, keyProperty id)void insert(Emp emp);不能混用一半xml一半注解不允许事务管理介绍事务控制在我们的项目中如何控制呢Spring事务管理-TransationalTransactional 加在 类上→这个类里 所有 public 方法都有事务Transactional 加在 接口上→只有实现类里【重写接口的方法】才有事务→实现类自己的方法 不生效而什么时候进行事务管理我们一般推荐当该方法多次增删改操作的时候进行事务管理因为这个时候需要考虑数据的统一性了。配置日志信息-Grep Console由于我们之前将项目的总体日志管理级别设置为了INFO因此如果想单独查看事务管理的底层日志时就需要在application.yml文件中单独配置#配置日志信息查看Spring事务管理的底层日志 logging: level: org.springframework.jdbc.support.JdbcTransactionManager: debug我们可以安装一个插件Grep Console搜索控制台中关键信息可以设置调整各类信息的背景色以及字体颜色日志级别正则规则字体色Foreground背景色BackgroundERROR.*ERROR.*#000000黑色#FFD700亮黄WARN.*WARN.*#000000黑色#FFFF99浅黄INFO.*INFO.*#000000黑色#90EE90浅绿DEBUG.*DEBUG.*#000000黑色#87CEEB浅蓝这里我们一般将ERROR调整其余自便也可以将某个关键字单独设置高亮选中想要设置的部分右键-Add Highlight事务进阶-rollbackFor为什么要引入这个参数因为默认的Transational的rollback回滚是遇到运行时异常RunTimeException才会回滚所以我们的rollbackFor就是为了指定遇到什么样的异常才回滚可以直接设置为Exception.class事务进阶-propagation操作场景如下准备工作简述即可这里简述过程(主要测试回滚情况)我们设置了finally所以无论如何empLogService.insertLog(empLog)这一步都会执行而且insertLog()这个方法也是被事务管理的但为什么最终执行回滚的时候这个方法也跟着一起回滚了因为Transational中有一个参数是propagation他默认参数是Propagation.REQUIRED这个意思如上述图即有事务则加入无事务则创建事务而我们的EmpServiceImpl的这个save()方法它本身也有事务管理所以insertLog()方法便会一起加入事务管理那么就导致了一起rollback回滚所以我们需要将这个参数设置为Propagation.REQUIRED_NEW,事务传播行为则改为无论有无事务自己都独立创建一个事务finally只能保证代码 “执行”不能保证 “提交”finally块里的代码确实会执行但它执行时依然在同一个主事务 A中。事务回滚是在方法执行结束后Spring 层面的统一操作和finally执行顺序无关。事务是绑定在当前线程的不是绑定在方法的 try-catch 块上save()方法开启的事务 A在整个方法执行期间都绑定在当前线程上。finally里调用的insertLog()拿到的还是同一个事务连接所以操作也被纳入事务管理。事务管理四大特性ACID文件上传介绍前端上传三要素method请求方式设置为postenctype照抄固定在表单项要设置一个file并且指明其名字我们后端需要和这个名字相绑定前端上传后端如何接收关注接收文件这个对象MultipartFilefile这个名字需要和我们前端表单中命名的名字一样如果不一样则需要RequestParam绑定我们用debug进行断点测试可以再这里面看到file的临时存放路径但当你运行完毕之后这些文件就消失了因为没有完全保存只是临时存放。本地存储项目开发中经常遇到文件上传需求比如上传头像、图片、文档、视频等。如果直接使用用户原文件名保存并发场景下容易出现同名文件覆盖问题。本文采用UUID 随机文件名 保留原文件后缀方案实现安全、不覆盖的本地文件上传附带完整代码、原理解析、大小配置、接口测试注意事项。1.完整上传接口代码PostMapping(/upload) public Result upload(String name, Integer age, MultipartFile file) throws IOException { log.info(上传文件:{},{},{}, name, age, file); //获取原始文件名 String originalFilename file.getOriginalFilename(); //组装新的随机文件名 String extensionoriginalFilename.substring(originalFilename.lastIndexOf(.)); String newFileName UUID.randomUUID().toString() extension; //保存文件 file.transferTo(new File(D:/images/ newFileName)); return Result.success(); }2.代码核心原理详解(1) MultipartFile 介绍Spring 提供的文件上传封装类专门用于接收前端上传的文件内置获取文件名、截取文件流、保存文件等常用方法。(2) 获取原始文件名String originalFilename file.getOriginalFilename();获取前端上传文件的完整原名例如test.jpg、笔记.docx、视频.mp4。(3) 截取文件后缀String extension originalFilename.substring(originalFilename.lastIndexOf(.));lastIndexOf(.)找到最后一个小数点的位置substring()从小数点开始截取保留文件后缀作用保证新文件格式不变能正常打开预览(4)为什么不用原文件名项目都是多用户并发访问多人可能上传一模一样的文件名。直接保存会出现后上传的文件覆盖之前的文件造成数据丢失。(5)UUID 生成唯一文件名String newFileName UUID.randomUUID().toString() extension;UUID 生成全球唯一随机字符串拼接原文件后缀彻底解决文件名重复覆盖问题。(6)文件落地保存file.transferTo(new File(D:/images/ newFileName));transferTo()是文件上传核心方法指定本地磁盘路径 新文件名直接将文件写入本地磁盘。3.配置文件上传大小限制SpringBoot 默认单个文件、请求总大小只有1MB大文件会直接报错需要在application.yml手动配置ymlspring: servlet: multipart: max-file-size: 10MB # 单个文件最大限制 max-request-size: 100MB # 整个请求所有参数文件总大小限制配置说明配置项作用默认值max-file-size限制单个上传文件的最大大小1MBmax-request-size限制一次请求中所有表单参数 所有文件总和大小10MB4.Apifox 接口测试注意事项请求方式使用POST请求参数格式必须选form-data不能用 JSON、普通 Param后端接收参数名file必须和前端 / 测试工具的参数名保持一致提前手动创建本地文件夹D:/images/否则会报路径不存在异常。5.核心总结文件上传核心类MultipartFile落地保存核心方法transferTo()解决文件覆盖UUID 随机名称 保留原后缀大文件必须配置multipart大小限制接口测试固定使用form-data格式传文件。阿里云对象存储服务(OSS)准备工作1.账号准备注册阿里云账户注册完成后需要实名认证https://account.aliyun.com/login/login.htm?oauth_callbackhttps%3A%2F%2Fwww.aliyun.com%2F注册完账号之后就可以登录阿里云控制台中打开对象存储OSS要充值之后我们能进入阿里云OSS控制台2.创建Bucket点击左侧的 Bucket列表创建一个Bucket创建完修改为公共读3.获取AccessKey(创建)4.配置AccessKey配置环境变量set OSS_ACCESS_KEY_IDset OSS_ACCESS_KEY_SECRET让更改生效setx OSS_ACCESS_KEY_ID %OSS_ACCESS_KEY_ID%setx OSS_ACCESS_KEY_SECRET %OSS_ACCESS_KEY_SECRET%配置完之后验证echo %OSS_ACCESS_KEY_ID%echo %OSS_ACCESS_KEY_SECRET%当然你也可以手动配置5.配置SDK配置SDK无论使用什么都要基于官方文档根据官方文档安装这里我们采用阿里云最新版配置OSS Java SDK V2https://mvnrepository.com/之后再maven仓库中查询最新版本复制依赖代码粘贴到pom文件即可入门程序简单入门上传文件复制代码粘贴即可import com.aliyun.oss.*; import com.aliyun.oss.common.auth.*; import com.aliyun.oss.common.comm.SignVersion; import com.aliyun.oss.model.*; import java.io.ByteArrayInputStream; public class Demo { public static void main(String[] args) throws Exception { // Endpoint以华东1杭州为例其它Region请按实际情况填写。 String endpoint https://oss-cn-hangzhou.aliyuncs.com; // 从环境变量中获取访问凭证。运行本代码示例之前请确保已设置环境变量OSS_ACCESS_KEY_ID和OSS_ACCESS_KEY_SECRET。 EnvironmentVariableCredentialsProvider credentialsProvider CredentialsProviderFactory.newEnvironmentVariableCredentialsProvider(); // 填写Bucket名称例如examplebucket。 String bucketName examplebucket; // 填写Object完整路径完整路径中不能包含Bucket名称例如exampledir/exampleobject.txt。 String objectName exampledir/exampleobject.txt; // 填写Bucket所在地域。以华东1杭州为例Region填写为cn-hangzhou。 String region cn-hangzhou; // 创建OSSClient实例。 // 当OSSClient实例不再使用时调用shutdown方法以释放资源。 ClientBuilderConfiguration clientBuilderConfiguration new ClientBuilderConfiguration(); clientBuilderConfiguration.setSignatureVersion(SignVersion.V4); OSS ossClient OSSClientBuilder.create() .endpoint(endpoint) .credentialsProvider(credentialsProvider) .clientConfiguration(clientBuilderConfiguration) .region(region) .build(); try { // 填写字符串。 String content Hello OSS你好世界; // 创建PutObjectRequest对象。 PutObjectRequest putObjectRequest new PutObjectRequest(bucketName, objectName, new ByteArrayInputStream(content.getBytes())); // 如果需要上传时设置存储类型和访问权限请参考以下示例代码。 // ObjectMetadata metadata new ObjectMetadata(); // metadata.setHeader(OSSHeaders.OSS_STORAGE_CLASS, StorageClass.Standard.toString()); // metadata.setObjectAcl(CannedAccessControlList.Private); // putObjectRequest.setMetadata(metadata); // 上传字符串。 PutObjectResult result ossClient.putObject(putObjectRequest); } 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(); } } } }这里只需要注意点的1.修改参数2.上传文件// 填写字符串。String content Hello OSS你好世界;// 创建PutObjectRequest对象。PutObjectRequest putObjectRequest new PutObjectRequest(bucketName, objectName,new ByteArrayInputStream(content.getBytes()));如果我们想要上传的是一个文件就需要获取这个文件的字节数组所以改为//获取如下文件byte数组File file new File(C:\\Users\\86137\\Desktop\\图\\d559604d948dbd0f2f2df00e5d40213c.jpg);byte[] content Files.readAllBytes(file.toPath());// 创建PutObjectRequest对象。 PutObjectRequest putObjectRequest new PutObjectRequest(bucketName, objectName, new ByteArrayInputStream(content));案例集成(上传文件)1.阿里云上传工具类/** * 阿里云OSS操作工具类 */ Slf4j public class AliyunOSSUtils { // 改成自己的accessKeyId private static String accessKeyId ; // 改成自己的accessKeySecret private static String accessKeySecret ;/** * 上传文件 * param endpoint endpoint域名 * param bucketName 存储空间的名字 * param content 内容字节数组 * param extName 文件后缀 */ public static String upload(String endpoint, String bucketName, byte[] content, String extName) throws Exception { // 填写Object完整路径完整路径中不能包含Bucket名称例如exampledir/exampleobject.txt。//以年月为分割的目录名 yyyy/MM String dir LocalDate.now().format(DateTimeFormatter.ofPattern(yyyy/MM)); String objectName dir/UUID.randomUUID() extName; // 创建OSSClient实例。 OSS ossClient new OSSClientBuilder().build(endpoint, accessKeyId,accessKeySecret); try { // 创建PutObjectRequest对象。 PutObjectRequest putObjectRequest new PutObjectRequest(bucketName, objectName, new ByteArrayInputStream(content)); // 创建PutObject请求。 PutObjectResult result ossClient.putObject(putObjectRequest); } catch (OSSException oe) { log.error(Caught an OSSException, which means your request made it to OSS, but was rejected with an error response for some reason.); log.error(Error Message: oe.getErrorMessage()); log.error(Error Code: oe.getErrorCode()); log.error(Request ID: oe.getRequestId()); log.error(Host ID: oe.getHostId()); } catch (ClientException ce) { log.error(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.); log.error(Error Message: ce.getMessage()); } finally { if (ossClient ! null) { ossClient.shutdown(); } } //拼接返回地址 returnendpoint.split(//)[0] // bucketName . endpoint.split(//)[1] / objectName; //} }2.改进后UploadMapperSlf4j RestController public class UploadController { private String endpoint https://oss-cn-beijing.aliyuncs.com;//以自己的节点为主 private String bucketName 你的Bucket名字; PostMapping(/upload) public Result upload(MultipartFile file) throws Exception { log.info(文件上传: {}, file.getOriginalFilename()); String extName file.getOriginalFilename().substring(file.getOriginalFilename().lastIndexOf(.)); String url AliyunOSSUtils.upload(endpoint, bucketName, file.getBytes(), extName); return Result.success(url); } }优化1.改进传入的路径参数url—参数配置化—Value我们一般将这些容易变动的文件配置在yml文件中#配置阿里云参数url aliyun: oss: endpoint: bucketName: region:Value注入RestController public class UploadController {Value(${aliyun.oss.endpoint})private String endpoint; Value(${aliyun.oss.bucketName}) private String bucketName; Value(${aliyun.oss.region}) private String region; }2.改进Value的繁琐如果配置文件中的参数过多我们注入的过程便会更加的繁琐因此我们引入ConfigurationProperties这个注解配合这个注解我们将这些个可变动的配置参数封装进一个类ConfigurationProperties注解中的参数prefix即说明配置文件的前缀是什么创建AliyunOSSProperties类NoArgsConstructor AllArgsConstructor Data Component ConfigurationProperties(prefix aliyun.oss) public class AliyunOSSProperties { private String endpoint; private String bucketName; private String region; }改动后Mapper层Slf4j RestController public class UploadController {Autowired private AliyunOSSProperties aliyunOSSUtils;PostMapping(/upload) public Result upload(MultipartFile file) throws Exception { log.info(文件上传: {}, file.getOriginalFilename());String endpoint aliyunOSSUtils.getEndpoint(); String bucketName aliyunOSSUtils.getBucketName();String extName file.getOriginalFilename().substring(file.getOriginalFilename().lastIndexOf(.)); String url AliyunOSSUtils.upload(endpoint, bucketName, file.getBytes(), extName); return Result.success(url); } }3.总结配置项不多用Value多的话ConfigurationProperties配置类封装