From ef6a72b70906f93971c698ad02f2825800e8d94a Mon Sep 17 00:00:00 2001 From: nxist2202005056 <3387603540@qq.com> Date: Wed, 26 Jun 2024 09:30:33 +0800 Subject: [PATCH] ADD file via upload --- Registrationdaoimplwmm.java | 200 ++++++++++++++++++++++++++++++++++++ 1 file changed, 200 insertions(+) create mode 100644 Registrationdaoimplwmm.java diff --git a/Registrationdaoimplwmm.java b/Registrationdaoimplwmm.java new file mode 100644 index 0000000..924f136 --- /dev/null +++ b/Registrationdaoimplwmm.java @@ -0,0 +1,200 @@ +package com.WR.StudentMS.dao.mysql; + +import java.sql.Connection; +import java.sql.PreparedStatement; +import java.sql.ResultSet; +import java.sql.SQLException; +import java.util.ArrayList; +import java.util.List; + +import com.WR.StudentMS.dao.RegistrationDaowmm; + +import com.WR.StudentMS.model.Registrationwmm; + + + +//用户管理DAO +public class Registrationdaoimplwmm implements RegistrationDaowmm { + + @Override + public List findAll() { + String sql = "select* from registration"; + List xuejiList = new ArrayList(); + + try ( + // 2.创建数据库连接 + Connection conn = DBHelper.getConnection(); + // 3. 创建语句对象 + PreparedStatement pstmt = conn.prepareStatement(sql); + // 4. 绑定参数 + // 5. 执行查询（R） + ResultSet rs = pstmt.executeQuery()) { + + // 6. 遍历结果集 + while (rs.next()) { + Registrationwmm xueji = new Registrationwmm(); + xueji.setStudentidwmm(rs.getString("studentid")); + xueji.setNamewmm(rs.getString("name")); + xueji.setSexwmm(rs.getString("sex")); + xueji.setAgewmm(rs.getString("age")); + xueji.setClasswmm(rs.getString("class")); + xueji.setAdmissionwmm(rs.getString("admission")); + xueji.setGraduationwmm(rs.getString("graduation")); + xueji.setLengthwmm(rs.getString("length")); + xueji.setCollegewmm(rs.getString("college")); + xuejiList.add(xueji); + } + + } catch (SQLException e) { + e.printStackTrace(); + } + return xuejiList; + } + + + @Override + public Registrationwmm findById(String studentid) { + + Connection conn = null; + PreparedStatement pstmt = null; + ResultSet rs = null; + Registrationwmm account = null; + try { + // 2.创建数据库连接 + conn = DBHelper.getConnection(); + // 3. 创建语句对象 + String sql = "select studentid,name,sex,age,class,admission,graduation,length,college" + + " from registration where studentid = ?"; + pstmt = conn.prepareStatement(sql); + // 4. 绑定参数 + pstmt.setString(1, studentid); + // 5. 执行查询（R） + rs = pstmt.executeQuery(); + // 6. 遍历结果集 + if (rs.next()) { + account = new Registrationwmm(); + + account.setStudentidwmm(rs.getString("studentid")); + account.setNamewmm(rs.getString("name")); + account.setSexwmm(rs.getString("sex")); + account.setAgewmm(rs.getString("age")); + account.setClasswmm(rs.getString("class")); + account.setAdmissionwmm(rs.getString("admission")); + account.setGraduationwmm(rs.getString("graduation")); + account.setLengthwmm(rs.getString("length")); + account.setCollegewmm(rs.getString("college")); + + return account; + } + + } catch (SQLException e) { + e.printStackTrace(); + } finally { // 释放资源 + if (rs != null) { + try { + rs.close(); + } catch (SQLException e) { + } + } + if (pstmt != null) { + try { + pstmt.close(); + } catch (SQLException e) { + } + } + if (conn != null) { + try { + conn.close(); + } catch (SQLException e) { + } + } + } + + return null; + } + + @Override + public int create(Registrationwmm xuejim) { + String sql = "insert into registration (studentid, name, sex, age, class, admission, graduation, length, college) "+ "values (?, ?, ?, ?, ?, ?, ?, ?, ?)"; + try ( + Connection conn = DBHelper.getConnection(); + PreparedStatement pstmt = conn.prepareStatement(sql) + ) { + // 绑定参数到SQL语句的占位符 + pstmt.setString(1, xuejim.getStudentidwmm()); + pstmt.setString(2, xuejim.getNamewmm()); + pstmt.setString(3, xuejim.getSexwmm()); + pstmt.setString(4, xuejim.getAgewmm()); // 假设age是整型 + pstmt.setString(5, xuejim.getClasswmm()); + pstmt.setString(6, xuejim.getAdmissionwmm()); + pstmt.setString(7, xuejim.getGraduationwmm()); + pstmt.setString(8, xuejim.getLengthwmm()); // 假设length是整型 + pstmt.setString(9, xuejim.getCollegewmm()); + + // 执行插入操作 + int affectedRows = pstmt.executeUpdate(); + System.out.printf("成功插入%d条数据。\n", affectedRows); + return affectedRows; // 返回插入的行数 + } catch (SQLException e) { + e.printStackTrace(); // 打印异常信息 + return -1; // 发生异常时返回-1 + } + } + + @Override + public int modify(Registrationwmm xuejim) { + // 假设所有字段都是字符串类型，如果不是，需要根据实际类型使用setInt等方法 + String sql = "UPDATE registration SET " + + "studentid = ?, " + + "name = ?, " + + "sex = ?, " + + "age = ?, " + + "class = ?, " + + "admission = ?, " + + "graduation = ?, " + + "length = ?, " + + "college = ? " + + "WHERE studentid = ?"; // 注意：这里的WHERE studentid = ?是第11个参数 + + try ( + Connection conn = DBHelper.getConnection(); + PreparedStatement pstmt = conn.prepareStatement(sql); + ) { + // 设置参数值，从1开始计数，需要确保每个占位符都有对应的值 + pstmt.setString(1, xuejim.getStudentidwmm()); // studentid + pstmt.setString(2, xuejim.getNamewmm()); // name + pstmt.setString(3, xuejim.getSexwmm()); // sex + pstmt.setString(4, xuejim.getAgewmm()); // age + pstmt.setString(5, xuejim.getClasswmm()); // class + pstmt.setString(6, xuejim.getAdmissionwmm()); // admission + pstmt.setString(7, xuejim.getGraduationwmm()); // graduation + pstmt.setString(8, xuejim.getLengthwmm()); // length + pstmt.setString(9, xuejim.getCollegewmm()); // college + pstmt.setString(10, xuejim.getStudentidwmm()); // WHERE条件的studentid + + // 执行更新操作 + int affectedRows = pstmt.executeUpdate(); + System.out.printf("成功修改了%d条数据。\n", affectedRows); + return affectedRows; // 返回实际受影响的行数 + } catch (SQLException e) { + e.printStackTrace(); + return -1; // 发生异常时返回-1 + } + } + + @Override + public int remove(Registrationwmm xuejim) { + String sql = "DELETE FROM registration WHERE studentid = ?"; + try (Connection conn = DBHelper.getConnection(); + PreparedStatement pstmt = conn.prepareStatement(sql)) { + pstmt.setString(1, xuejim.getStudentidwmm()); // 只设置 studentid 作为删除条件 + int affectedRows = pstmt.executeUpdate(); + System.out.printf("成功删除%d条数据。\n", affectedRows); + return affectedRows; + } catch (SQLException e) { + e.printStackTrace(); + return -1; + } + } + +} \ No newline at end of file