Spring 3.0MVC JDBC 单表操作示例.rar

package com.iflysse.dao; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.util.ArrayList; import org.apache.log4j.Logger; import org.springframework.stereotype.Repository; import com.iflysse.model.Student; import com.ifysse.util.ConnDB; @Repository // 持久层 public class StudentDao implements StudentDaoInterface { Logger logger = Logger.getLogger(StudentDao.class); @Override public ArrayList<Student> getStudentList() { ArrayList<Student> students = new ArrayList<Student>(); try { Connection conn = null; try { String sql = "SELECT id,name FROM student"; conn = ConnDB.getConnection(); Statement stat = conn.createStatement(); ResultSet rst = stat.executeQuery(sql); while (rst.next()) { Student student = new Student(); student.setId(rst.getInt(1)); student.setName(rst.getString(2)); students.add(student); } stat.close(); rst.close(); } finally { if (conn != null) { conn.close(); } logger.info("学生列表获取成功！"); } } catch (SQLException e) { logger.error("学生列表获取失败!" + e); e.printStackTrace(); } return students; } @Override public void addStudent(Student student) { try { Connection conn = null; String name = student.getName(); try { String sql = "INSERT INTO student (NAME) VALUES (?)"; conn = ConnDB.getConnection(); PreparedStatement pst = conn.prepareStatement(sql); pst.setString(1, name); pst.executeUpdate(); pst.close(); } finally { if (conn != null) { conn.close(); } } logger.info("学生添加成功！"); } catch (Exception e) { logger.info("学生添加失败！" + e); e.printStackTrace(); } } @Override public void delStudentById(Student student) { try { Connection conn = null; try { String sql = "DELETE FROM student WHERE id=?"; conn = ConnDB.getConnection(); PreparedStatement pst = conn.prepareStatement(sql); pst.setInt(1, student.getId()); pst.executeUpdate(); pst.close(); } finally { if (conn != null) { conn.close(); } } logger.info("学生删除成功！"); } catch (Exception e) { logger.info("学生删除失败！" + e); e.printStackTrace(); } } @Override public Student getStudentById(int id) { Student student = new Student(); try { Connection conn = null; try { String sql = "SELECT id,name FROM student WHERE id=?"; conn = ConnDB.getConnection(); PreparedStatement pst = conn.prepareStatement(sql); pst.setInt(1, id); ResultSet rst = pst.executeQuery(); while (rst.next()) { student.setId(rst.getInt(1)); student.setName(rst.getString(2)); } pst.close(); rst.close(); } finally { if (conn != null) { conn.close(); } logger.info("单个学生获取成功！"); } } catch (SQLException e) { logger.error("单个学生获取失败!" + e); e.printStackTrace(); } return student; } @Override public void editStudent(Student student) { try { Connection conn = null; String name = student.getName(); try { String sql = "UPDATE student SET name=? WHERE id=?"; conn = ConnDB.getConnection(); PreparedStatement pst = conn.prepareStatement(sql); pst.setString(1, name); pst.setInt(2, student.getId()); pst.executeUpdate(); pst.close(); } finally { if (conn != null) { conn.close(); } } logger.info("学生修改成功！"); } catch (Exception e) { logger.info("学生修改失败！" + e); e.printStackTrace(); } } }