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; // 发生异常
	    }
	}



	
}