ADD file via upload

Classmdaoimpqsy.java

@@ -0,0 +1,112 @@
+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.Classmdaoqsy;
+import com.WR.StudentMS.model.Classmqsy;
+
+
+public class Classmdaoimpqsy implements Classmdaoqsy {
+
+	@Override
+	public List<Classmqsy> findAllqsy() {
+		String sql = "select id,name,zhuanye_id from t_banji";
+		List<Classmqsy> classmqsy = new ArrayList<Classmqsy>();
+
+		try (
+				
+				Connection conn = DBHelper.getConnection();
+				
+				PreparedStatement pstmt = conn.prepareStatement(sql);
+				
+				
+				ResultSet rs = pstmt.executeQuery()) {
+
+			
+			while (rs.next()) {
+                Classmqsy classm = new Classmqsy();
+                classm.setClassidqsy(rs.getString("id"));
+                classm.setClassnameqsy(rs.getString("name"));
+                classm.setMajoridqsy(rs.getString("zhuanye_id"));
+                classmqsy.add(classm);
+			}
+
+		} catch (SQLException e) {
+			e.printStackTrace();
+		}
+		return classmqsy;
+	}
+
+	@Override
+	public Classmqsy findByClassId(String classId) {
+	    String sql = "SELECT id, name, zhuanye_id FROM t_banji WHERE id = ?";
+	    List<Classmqsy> classmqsy = new ArrayList<>();
+	    try (
+	        Connection conn = DBHelper.getConnection();
+	        PreparedStatement pstmt = conn.prepareStatement(sql);
+	    ) {
+	        pstmt.setString(1, classId);
+	        ResultSet rs = pstmt.executeQuery();
+	        if (rs.next()) {
+	            Classmqsy classm = new Classmqsy();
+	            classm.setClassidqsy(rs.getString("id"));
+	            classm.setClassnameqsy(rs.getString("name"));
+	            classm.setMajoridqsy(rs.getString("zhuanye_id"));
+	            return classm;
+	        }
+	    } catch (SQLException e) {
+	        e.printStackTrace();
+	    }
+	    return null;
+	}
+
+	@Override
+	public int createqsy(Classmqsy classm) {
+	    String sql = "insert into t_banji (id, name, zhuanye_id) values (?,?,?)";
+	    try (
+	            Connection conn = DBHelper.getConnection();
+	            PreparedStatement pstmt = conn.prepareStatement(sql)
+	    ) {
+	        pstmt.setString(1, classm.getClassidqsy());
+	        pstmt.setString(2, classm.getClassnameqsy());
+	        pstmt.setString(3, classm.getMajoridqsy());
+
+	        int affectedRows = pstmt.executeUpdate();
+	            System.out.println("成功插入数据。");
+		        return affectedRows; // 返回插入的行数
+	        } catch (SQLException e) {
+	            // 打印其他类型的SQL异常信息
+	            e.printStackTrace();
+	            return 0; 
+	        
+	    }
+	}
+	
+
+	@Override
+	public int removeqsy(Classmqsy classm) {
+	    String sql = "DELETE FROM t_banji WHERE id = ?";
+	    try (Connection conn = DBHelper.getConnection();
+	         PreparedStatement pstmt = conn.prepareStatement(sql)) {
+	        pstmt.setString(1, classm.getClassidqsy());
+	        int affectedRows = pstmt.executeUpdate();
+	        if (affectedRows > 0) {
+	            return affectedRows; // 返回受影响的行数
+	        } else {
+	            return 0; // 没有记录被删除
+	        }
+	    } catch (SQLException e) {
+	        e.printStackTrace();
+	        return -1; // 发生异常
+	    }
+	}
+
+
+
+	
+}