Exam/pengchen-exam-java-localhost
4
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

【新增】导出学生作答mysql记录

Browse Source
This commit is contained in:
huababa1
2025-07-03 15:21:22 +08:00
parent 0acce243db
commit 42882f7cd1
6 changed files with 254 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/com/example/exam/exam/controller/auto/AutoController.java
View File

@@ -82,7 +82,11 @@ public class AutoController {
public Result<Double> judgementForMysql(@RequestBody StuInfoVo stuInfoVo) throws SQLException, IOException {
return Result.success(autoForMysqlService.autoForMysql(stuInfoVo));
}
// Mysql文件
@PostMapping("/judgementForMysqlFile")
public Result judgementForMysqlFile(@RequestBody StuInfoVo stuInfoVo) throws SQLException, IOException {
return Result.success(autoForMysqlService.autoForMysqlFile(stuInfoVo));
}
/**
* 删除 本地学生的连接和库
* @param tNames

6
src/main/java/com/example/exam/exam/service/autoformysql/AutoForMysqlService.java
View File

@@ -11,8 +11,12 @@ import java.sql.SQLException;
public interface AutoForMysqlService {
/**
* 自动判题 C语言
* 自动判题 Mysql
* @param stuInfoVo 学生信息
*/
Double autoForMysql(StuInfoVo stuInfoVo) throws SQLException, IOException;
String autoForMysqlFile(StuInfoVo stuInfoVo);
}

25
src/main/java/com/example/exam/exam/service/autoformysql/AutoForMysqlServiceImpl.java
View File

@@ -111,4 +111,29 @@ public class AutoForMysqlServiceImpl implements AutoForMysqlService {
}
return score;
}
@Override
public String autoForMysqlFile(StuInfoVo stuInfoVo) {
// 1、获取到学生文件路径
String filePath = stuInfoVo.getFilePath();
File folder = new File(filePath);
// 2、获取到学生文件
File[] files = folder.listFiles();
for (File file : files) {
File csFiles = new File(file.getPath());
String quId = csFiles.getName();
File[] csFileList = csFiles.listFiles();
for (File one_file : csFileList) {
String name = one_file.getName();
if ("程序设计".equals(name)) {
File mysql_file = new File(one_file.getPath());
ExamQuestion examQuestion = examQuestionService.selectExamQuestionByQuId(quId);
mysqlLocalService.JudgementFile( mysql_file, examQuestion);
break;
}
}
}
return "导出成功";
}
}

2
src/main/java/com/example/exam/exam/service/mysql/IMysqlLocalService.java
View File

@@ -16,4 +16,6 @@ public interface IMysqlLocalService {
void delMysqlConnect(List<String> tNames);
SourceAndText Judgement(double sorce, File file, ExamQuestion examQuestion, String judgementStr) throws IOException, SQLException;
void JudgementFile(File mysqlFile, ExamQuestion examQuestion);
}

19
src/main/java/com/example/exam/exam/service/mysql/IMysqlLocalServiceImpl.java
View File

@@ -10,6 +10,7 @@ import com.example.exam.exam.service.mysql.IMysqlLocalService;
import com.example.exam.exam.service.mysql.vo.MysqlBooleanVo;
import com.example.exam.exam.service.mysql.vo.MysqlVo;
import com.example.exam.exam.utils.HtmlAppender;
import com.example.exam.exam.utils.mysql.MySQLExporterUtil;
import com.example.exam.exam.utils.zip.ZipUtil;
import io.micrometer.common.util.StringUtils;
import jakarta.annotation.Resource;
@@ -1070,6 +1071,24 @@ public class IMysqlLocalServiceImpl implements IMysqlLocalService {
sourceAndText.setText(judgementStr);
return sourceAndText;
}
@Override
public void JudgementFile(File mysqlFile, ExamQuestion examQuestion) {
String stuDataName=examQuestion.getTname();
String fileStu = mysqlFile.getAbsolutePath();
String user = "root";
String password = "";
// String stuAnswerPath = "D:\\Desktop\\202504211120_mysql\\71\\MYS_010_122\\考试素材\\考试素材\\Student\\db\\db_escape.myd";
File stuDbDir = new File(fileStu, "db");
// 设置导出文件路径（放在dbDir下）
String exportFileName = stuDataName + ".myd";
File exportFile = new File(stuDbDir, exportFileName);
// 执行导出
MySQLExporterUtil exporter = new MySQLExporterUtil(stuDataName, user, password, exportFile.getAbsolutePath());
exporter.export();
}
public static String convertAlertToSelectWhere(String sql) {
if (sql == null || sql.trim().isEmpty()) return null;

198
src/main/java/com/example/exam/exam/utils/mysql/MySQLExporterUtil.java Normal file
View File

@@ -0,0 +1,198 @@
package com.example.exam.exam.utils.mysql;
import java.io.File;
import java.io.FileWriter;
import java.io.IOException;
import java.sql.*;
import java.util.ArrayList;
import java.util.List;
public class MySQLExporterUtil {
private final String databaseName;
private final String jdbcUrl;
private final String user;
private final String password;
private final String outputFilePath;
public MySQLExporterUtil(String databaseName, String user, String password,String outputFilePath) {
this.databaseName = databaseName;
this.jdbcUrl = "jdbc:mysql://localhost:6033/" + databaseName + "?useSSL=false&serverTimezone=Asia/Shanghai";
this.user = user;
this.password = password;
this.outputFilePath = outputFilePath;
}
public void export() {
// 确保父目录存在
File outputFile = new File(outputFilePath);
File parentDir = outputFile.getParentFile();
if (parentDir != null && !parentDir.exists()) {
parentDir.mkdirs();
}
try (Connection conn = DriverManager.getConnection(jdbcUrl, user, password);
FileWriter writer = new FileWriter(outputFile)) {
// 2. 如果目标文件已存在，先删除（确保是新文件）
if (outputFile.exists()) {
// 3. 清空文件内容
try {
// 方法一：使用FileWriter（自动清空）
new FileWriter(outputFile, false).close(); // false表示覆盖模式
} catch (IOException e) {
throw new RuntimeException("无法清空文件内容: " + outputFilePath, e);
}
}
// 连接数据库
switchDatabase(conn);
// 导出表结构
exportTables(conn, writer);
// 导出视图结构
exportViews(conn, writer);
// 导出存储过程
// exportProcedures(conn, writer);
// 导出所有触发器
// exportTriggers(conn,writer);
writer.write("\nSET FOREIGN_KEY_CHECKS=1;\n");
System.out.println("导出成功！文件路径: " + outputFile);
} catch (Exception e) {
e.printStackTrace();
}
}
private void switchDatabase(Connection conn) throws SQLException {
try (Statement stmt = conn.createStatement()) {
stmt.execute("USE " + databaseName);
}
}
private void exportTables(Connection conn, FileWriter writer) throws SQLException, IOException {
DatabaseMetaData meta = conn.getMetaData();
try (ResultSet tables = meta.getTables(databaseName, null, "%", new String[]{"TABLE"})) {
while (tables.next()) {
String tableName = tables.getString("TABLE_NAME");
writer.write(getCreateTableSQL(conn, tableName) + ";\n\n");
exportTableData(conn, tableName, writer);
}
}
}
private String getCreateTableSQL(Connection conn, String tableName) throws SQLException {
try (Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery("SHOW CREATE TABLE " + tableName)) {
// 获取 CREATE TABLE 语句
String createTableSQL = rs.next() ? rs.getString("Create Table") : "";
// // 移除 AUTO_INCREMENT 部分
// createTableSQL = createTableSQL.replaceAll("AUTO_INCREMENT=\\d+", "");
//
// // 移除 ENGINE, CHARSET 和 ROW_FORMAT 部分
// createTableSQL = createTableSQL.replaceAll("ENGINE=[^ ]+|DEFAULT CHARSET=[^ ]+|ROW_FORMAT=[^ ]+", "");
//
// // 清理多余的空格
// createTableSQL = createTableSQL.trim();
return createTableSQL;
}
}
/**
* 导出所有触发器
*/
private void exportTriggers(Connection conn, FileWriter writer) throws SQLException, IOException {
List<String> triggers = getAllTriggers(conn);
for (String trigger : triggers) {
String ddl = getTriggerDDL(conn,trigger);
writer.write(ddl + ";\n\n");
}
}
private void exportTableData(Connection conn, String tableName, FileWriter writer) throws SQLException, IOException {
String query = "SELECT * FROM " + tableName;
try (Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery(query)) {
ResultSetMetaData metaData = rs.getMetaData();
int columnCount = metaData.getColumnCount();
while (rs.next()) {
StringBuilder sb = new StringBuilder("INSERT INTO " + tableName + " (");
for (int i = 1; i <= columnCount; i++) {
sb.append(metaData.getColumnName(i)).append(i < columnCount ? ", " : ") VALUES (");
}
for (int i = 1; i <= columnCount; i++) {
sb.append(rs.getString(i) == null ? "NULL" : "'" + rs.getString(i).replace("'", "''") + "'")
.append(i < columnCount ? ", " : ");\n");
}
writer.write(sb.toString());
}
}
}
private void exportViews(Connection conn, FileWriter writer) throws SQLException, IOException {
DatabaseMetaData meta = conn.getMetaData();
try (ResultSet views = meta.getTables(databaseName, null, "%", new String[]{"VIEW"})) {
while (views.next()) {
String viewName = views.getString("TABLE_NAME");
writer.write(getCreateViewSQL(conn, viewName) + ";\n\n");
}
}
}
private String getCreateViewSQL(Connection conn, String viewName) throws SQLException {
try (Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery("SHOW CREATE VIEW " + viewName)) {
return rs.next() ? rs.getString("Create View") : "";
}
}
private void exportProcedures(Connection conn, FileWriter writer) throws SQLException, IOException {
DatabaseMetaData meta = conn.getMetaData();
try (ResultSet procedures = meta.getProcedures(databaseName, null, "%")) {
while (procedures.next()) {
String procedureName = procedures.getString("PROCEDURE_NAME");
writer.write(getCreateProcedureSQL(conn, procedureName) + ";\n\n");
}
}
}
private String getCreateProcedureSQL(Connection conn, String procedureName) throws SQLException {
try (Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery("SHOW CREATE PROCEDURE " + procedureName)) {
if (rs.next()) {
return rs.getString("Create Procedure");
}
return "";
}
}
/**
* 获取触发器的DDL语句
*/
private String getTriggerDDL(Connection conn,String triggerName) throws SQLException {
try (Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery("SHOW CREATE TRIGGER `" + triggerName + "`")) {
if (rs.next()) {
return rs.getString(3); // 创建语句在第3列
}
}
return "";
}
/**
* 获取所有触发器
*/
private List<String> getAllTriggers(Connection conn) throws SQLException {
List<String> triggers = new ArrayList<>();
try (Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery("SHOW TRIGGERS FROM " + databaseName)) {
while (rs.next()) {
triggers.add(rs.getString("Trigger"));
}
}
return triggers;
}
}