Util和utils

2024-05-26 13:52
文章标签 util utils

本文主要是介绍Util和utils,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

Util

FieldStats

这段代码定义了一个名为`FieldStats`的Java类,位于`com.cqupt.software_1.Util`包中。它使用了`lombok`库的`@Data`和`@AllArgsConstructor`注解,这些注解帮助生成了`getter`、`setter`、`toString`等方法,以及包含所有参数的构造函数。类中有三个字段:
- `missingRate`:表示缺失率。
- `mean`:表示平均值。
- `variance`:表示方差。构造函数接受这三个字段作为参数,并将它们赋值给对应的字段。这个类主要用于存储字段的统计信息,例如在数据分析中计算每个字段的缺失率、平均值和方差等统计数据。
package com.cqupt.software_1.Util;import lombok.AllArgsConstructor;
import lombok.Data;@Data
@AllArgsConstructor
public class FieldStats {private double missingRate;private double mean;private double variance;
}

ImportXlsxToMysql

这段代码是一个Java程序,它用于将Excel文件(.xlsx格式)中的数据导入到MySQL数据库中。让我详细介绍一下:1. `ImportXlsxToMysql` 类包含了 `main` 方法,是程序的入口点。它主要负责读取Excel文件中的数据,并将数据插入到MySQL数据库中。2. 在 `main` 方法中,首先定义了一些变量,如 `xlsxFilePath` 存储了Excel文件的路径,`dbUrl` 存储了数据库的URL,`username` 和 `password` 分别是数据库的用户名和密码,`tableName` 是要插入数据的表名。3. 在 `try-with-resources` 语句中,打开文件输入流 `fileInputStream`,并使用 `WorkbookFactory.create(fileInputStream)` 创建一个 Workbook 对象,用于处理 Excel 文件。然后,通过 `DriverManager.getConnection` 方法建立数据库连接。4. 通过 `workbook.getSheetAt(0)` 获取Excel文件的第一个工作表,并通过 `sheet.getRow(0)` 获取表头行,从中获取列数。5. 构建 SQL 插入语句。通过遍历表头行的每一列,获取列名,并构建插入语句的列部分。然后通过遍历列数,构建插入语句的值部分,同时使用占位符 '?'。6. 执行插入操作。通过准备好的 SQL 插入语句创建 `PreparedStatement` 对象,然后遍历 Excel 文件的每一行,设置参数值,并执行插入操作。7. `getCellValueAsString` 方法用于将单元格的值以字符串的形式返回。它接受一个 `Cell` 对象作为参数,首先检查单元格的类型,然后将其值转换为相应类型的字符串,并返回。8. 最后,在 `catch` 块中捕获可能出现的异常,例如 `IOException` 和 `SQLException`,并打印异常信息。这个程序的功能是将 Excel 文件中的数据导入到 MySQL 数据库中的指定表中,它支持包含不同数据类型的单元格值,并能处理空单元格。
package com.cqupt.software_1.Util;import org.apache.poi.ss.usermodel.*;import java.io.FileInputStream;
import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;public class ImportXlsxToMysql {public static void main(String[] args) {String xlsxFilePath = "C:\\Users\\hp\\Desktop\\example.xlsx";String dbUrl = "jdbc:mysql://10.16.48.219:3306/result_save";String username = "root";String password = "111111";String tableName = "";try (FileInputStream fileInputStream = new FileInputStream(xlsxFilePath);Workbook workbook = WorkbookFactory.create(fileInputStream);Connection connection = DriverManager.getConnection(dbUrl, username, password)) {Sheet sheet = workbook.getSheetAt(0);// 获取表头行Row headerRow = sheet.getRow(0);int columnCount = headerRow.getLastCellNum();// 构建 SQL 插入语句StringBuilder sqlBuilder = new StringBuilder();sqlBuilder.append("INSERT INTO ").append(tableName).append(" (");for (int i = 0; i < columnCount; i++) {String columnName = getCellValueAsString(headerRow.getCell(i));sqlBuilder.append(columnName);if (i < columnCount - 1) {sqlBuilder.append(", ");}}sqlBuilder.append(") VALUES (");for (int i = 0; i < columnCount; i++) {sqlBuilder.append("?");if (i < columnCount - 1) {sqlBuilder.append(", ");}}sqlBuilder.append(")");String insertSql = sqlBuilder.toString();// 准备插入语句try (PreparedStatement statement = connection.prepareStatement(insertSql)) {// 遍历行for (int rowIndex = 1; rowIndex <= sheet.getLastRowNum(); rowIndex++) {Row row = sheet.getRow(rowIndex);// 设置参数值for (int columnIndex = 0; columnIndex < columnCount; columnIndex++) {Cell cell = row.getCell(columnIndex);String cellValue = getCellValueAsString(cell);statement.setString(columnIndex + 1, cellValue);}// 执行插入操作statement.executeUpdate();}}System.out.println("Data imported successfully!");} catch (IOException | SQLException e) {e.printStackTrace();}}private static String getCellValueAsString(Cell cell) {if (cell == null) {return "";}CellType cellType = cell.getCellType();String cellValue;if (cellType == CellType.STRING) {cellValue = cell.getStringCellValue();} else if (cellType == CellType.NUMERIC) {cellValue = String.valueOf(cell.getNumericCellValue());} else if (cellType == CellType.BOOLEAN) {cellValue = String.valueOf(cell.getBooleanCellValue());} else if (cellType == CellType.FORMULA) {cellValue = cell.getCellFormula();} else {cellValue = "";}return cellValue;}
}

SecurityUtil

这段代码定义了一个名为`SecurityUtil`的Java类,它包含了一个静态方法`hashDataSHA256`,用于对输入的字符串数据使用SHA-256算法进行哈希加密。`hashDataSHA256`方法接受一个`String`类型的参数`data`,这是需要被加密的原始数据。方法内部首先尝试获取SHA-256算法的实例,如果获取失败(例如,因为Java环境不支持该算法),则通过`NoSuchAlgorithmException`异常处理。如果算法实例成功获取,方法将原始数据转换为字节数组,并使用`MessageDigest`的`digest`方法对其进行加密。`digest`方法返回一个字节数组,该数组包含了SHA-256算法加密后的结果。接下来,方法将加密后的字节数组转换为十六进制的字符串表示形式。它使用`StringBuilder`类来构建这个十六进制字符串,并通过`String.format`方法将每个字节转换为两个字符的十六进制形式。最后,方法返回生成的十六进制字符串,该字符串代表了原始数据的SHA-256哈希值。如果发生异常,方法将打印堆栈跟踪信息并返回`null`。`SecurityUtil`类可以被其他Java程序调用,以便对数据进行SHA-256加密。这通常用于密码加密、数据完整性校验等安全相关的应用场景。
package com.cqupt.software_1.Util;import java.nio.charset.StandardCharsets;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;public class SecurityUtil {/****  SHA-256  加密对密码* @param data* @return*/public static String hashDataSHA256(String data) {try {MessageDigest md = MessageDigest.getInstance("SHA-256");byte[] hashInBytes = md.digest(data.getBytes(StandardCharsets.UTF_8));// Convert the byte array to a hexadecimal stringStringBuilder sb = new StringBuilder();for (byte b : hashInBytes) {sb.append(String.format("%02x", b));}return sb.toString();} catch (NoSuchAlgorithmException e) {e.printStackTrace();return null;}}
}

utils

HTTPUtils

这段代码定义了一个名为 `HTTPUtils` 的 Java 类,它包含了一个静态方法 `postRequest`,用于向指定的 HTTP 服务器发送 POST 请求,并返回服务器响应的 JSON 数据。
`postRequest` 方法接受两个参数,第一个参数是要发送的数据对象 `paramData`,第二个参数是请求路径 `path`。
方法首先构建了一个 URI 对象,表示请求的完整路径,这个路径由 `rootPath` 和传入的 `path` 拼接而成。
然后,创建了一个 `HttpPost` 对象,用于执行 POST 请求,同时创建了一个 `HttpClient` 对象来执行 HTTP 请求。
接下来,使用 `ObjectMapper` 对象将传入的 `paramData` 对象转换为 JSON 格式的字符串 `jsonData`。在转换过程中,允许非数值字符的存在,这一特性通过 `objectMapper.configure(JsonParser.Feature.ALLOW_NON_NUMERIC_NUMBERS, true)` 实现。
接着,将 JSON 数据设置到请求的实体中,同时设置请求体的编码为 UTF-8。
设置请求头部为 `application/json; charset=UTF-8`,指明请求体的类型和编码格式。
执行 HTTP 请求,得到服务器的响应对象 `response`,然后将响应实体中的数据转换为字符串 `responseData`。
最后,使用 `ObjectMapper` 将响应数据字符串转换为 JSON 对象 `JsonNode`,并返回该对象。
这个 `HTTPUtils` 类提供了一个方便的工具方法,可以用于在 Java 程序中向指定的 HTTP 服务器发送 POST 请求,并获取服务器返回的 JSON 数据。
package com.cqupt.software_1.utils;import com.fasterxml.jackson.core.JsonParser;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.apache.http.HttpHeaders;
import org.apache.http.HttpResponse;
import org.apache.http.client.HttpClient;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;
import java.io.IOException;
import java.net.URI;
import java.net.URISyntaxException;
import java.nio.charset.StandardCharsets;public class HTTPUtils {public static final String rootPath = "http://localhost:5000/";public static JsonNode postRequest(Object paramData, String path) throws URISyntaxException, IOException {URI uri = new URI(rootPath+path);// 创建http POSTHttpPost httpPost = new HttpPost(uri);HttpClient httpClient = HttpClients.createDefault();ObjectMapper objectMapper = new ObjectMapper();objectMapper.configure(JsonParser.Feature.ALLOW_NON_NUMERIC_NUMBERS, true);String jsonData = objectMapper.writeValueAsString(paramData);//        httpPost.setHeader(HttpHeaders.CONTENT_TYPE,"application/json");
//        httpPost.setEntity(new StringEntity(jsonData)); // 设置请求体// 设置请求体编码为 UTF-8StringEntity entity = new StringEntity(jsonData, StandardCharsets.UTF_8);httpPost.setEntity(entity);httpPost.setHeader(HttpHeaders.CONTENT_TYPE, "application/json; charset=UTF-8"); // 设置请求头部// 执行请求HttpResponse response = httpClient.execute(httpPost);String responseData = EntityUtils.toString(response.getEntity());JsonNode jsonNode = objectMapper.readValue(responseData, JsonNode.class);return jsonNode;}
}

这篇关于Util和utils的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1004654

相关文章

任务调度--使用java.util.Timer实现

任务调度是指基于给定时间点,给定时间间隔或者给定执行次数自动执行任务。 举个例子,比如说我们希望一个系统每周日晚上9点都将数据库文件备份一次,这时我们就可以使用任务调度来实现。为了更加的方便,我们需要在tomcat启动后,自动开始这个调度。 下面是TimerTask的API: 下面是Timer类的API 下面的例子中实现了两个功能: 1.监测tomcat的web容器的启动与关闭

SpringBoot单元测试报错:java.lang.NoSuchMethodError: org.junit.platform.commons.util.ReflectionUtils

当我在SpringBoot项目中想做单元测试时,运行就报以下错误     我的配置信息都是正确的,瞬间懵逼了,网上都说是Junit5与IDEA版本不兼容,需要升级IDEA的版本,或者使用Junit4来进行单元测试。IDEA升级怕又要破解,很是蛋疼,所以还是想想使用Junit4来做测试了。     网上也找了半天也没有太全的说明,自己研究了下,竟然搞成了,前戏完成,上菜了

java.util.Properties类操作properties文件

文章目录 1 Properties类1.1 认识properties文件1.2 了解Properties类1.3 properties文件与Properties类的关系1.4 使用Properties类1.4.1 操作properties1.4.2 操作XML文件1.4.3 java读取properties文件的九种方法 1 Properties类 由于java.util.P

Java中synchronized与java.util.concurrent.locks.Lock区别

相同点:Lock能完成synchronized所实现的所有功能 区别:Lock比synchronized更精确的线程语义和性能;chronized会自动释放锁,而Lock需要程序员手动释放,而且必须在finally从句中释放。Lock更强大的功能,如tryLock方法可以非阻塞方式去拿锁: import java.util.concurrent.locks.Lock;import jav

使用 java.util.TreeMap 类 tailMap headMap fisrtKey lastKey

TreeMap 类不仅实现了 Map 接口,还实现了 Map 接口的子接口 java.util.SortedMap。  TreeMap 类中不允许键对象为 null 或是 基本数据类型,这是因为 TreeMap 中的对象必须是可排序的(即对象需要实现 java.lang.Comparable 接口)  TreeMap 类通过实现 SortedMap 接口得到的方法如表1所示:  方法名称返

Java面试题:讨论synchronized关键字和java.util.concurrent包中的同步工具,如Lock和Semaphore

在 Java 中,synchronized 关键字和 java.util.concurrent 包中的同步工具都是用来控制多线程环境下的并发访问,以防止数据竞争和确保线程安全。下面是对 synchronized 关键字和 java.util.concurrent 包中的一些同步工具的讨论,包括它们的特点和使用场景。 synchronized 关键字 基本概念: synchronized 是 J

java lang NoClassDefFoundError org springframework util MimeType

缺少spring-core.jar这个包,我是maven项目 ,故在pom.xml里面添加了该jar包的依赖就好了

java.util.concurrent中的Callable,Future

Java中存在Runnable、Callable、Future、FutureTask这几个与线程相关的类或者接口,在Java中也是比较重要的几个概念,我们通过下面的简单示例来了解一下它们的作用于区别。 Runnable 其中Runnable应该是我们最熟悉的接口,它只有一个run()函数,用于将耗时操作写在其中,该函数没有返回值。然后使用某个线程去执行该runnable即可实现多线程,Th

java.util.concurrent包中的BlockingQuene

BlockingQueue最终会有四种状况,抛出异常、返回特殊值、阻塞、超时,下表总结了这些方法:  抛出异常特殊值阻塞超时插入add(e)offer(e)put(e)offer(e, time, unit)移除remove()poll()take()poll(time, unit)检查element()peek()不可用不可用        BlockingQueu

java.util.concurrent的线程池

自JDK5之后,Java推出了一个并发包,java.util.concurrent,在Java开发中,我们接触到了好多池的技术,String类的对象池、Integer的共享池、连接数据库的连接池、Struts1.3的对象池等等,池的最终目的都是节约资源,以更小的开销做更多的事情,从而提高性能。         我们的web项目都是部署在服务器上,浏览器端的每一个request就是一个线程,那