/*
DBConnection
*/
package com.accp.db; import import import import import import import java.sql.DriverManager; java.sql.Connection; java.sql.SQLException; java.sql.Statement; java.sql.PreparedStatement; java.sql.ResultSet; org.apache.log4j.Logger;
public class DBConnection { //SQLServer驱动名 驱动名 private static final String JDBC_DRIVER="com.microsoft.sqlserver.jdbc.SQLServerDriver"; //驱动路径 驱动路径 private static final String URL="jdbc:sqlserver://localhost:1433;databaseName=JSP_ALL;user=sa;pass
word=sasa "; public static Connection GetConnection(){ Connection conn=null; Logger logger = Logger.getLogger(DBConnection.class.getName()); try { //加载驱动 加载驱动 Class.forName(JDBC_DRIVER); try { //连接 连接 conn=DriverManager.getConnection(URL); logger.debug("连接 连接hao"); 连接 } catch (SQLException e) { logger.debug("连接失败 连接失败:"+e.getMessage()); 连接失败 } } catch (ClassNotFoundException e) { logger.error("驱动加载错误 驱动加载错误"+e.getMessage()); 驱动加载错误 } return conn; } public static void CloseDB(Connection conn,Statement stmt,PreparedStatement pstmt,ResultSet rs) throws Exception{ //从小往大关闭 从小往大关闭 //关闭结果集 关闭结果集 if (rs!=null){ rs.close(); } //关闭 关闭Statement --无参数的 关闭 无参数的 if (stmt!=null){ stmt.close(); } //关闭 关闭PreparedStatement --有参数的 有参数的 关闭 if (pstmt!=null){ pstmt.close(); } //最后关闭连接 最后关闭连接 if (conn!=null){ conn.close(); } }
/*
StudentDao
*/
package com.accp.logic; import import import import import import java.util.ArrayList; java.
sql.Connection; java.sql.SQLException; java.sql.Statement; java.sql.PreparedStatement; java.sql.ResultSet;
import org.omg.CORBA.Request; import com.accp.beans.StudentBean; import com.accp.db.DBConnection; public class StudentDao { //显示的 sql 语句 显示的 private static final String SQL_LIST = "SELECT studID,studName,studAge,studSex FROM Student"; //插入的 sql 语句 插入的 private static final String SQL_ADD = "INSERT INTO Student (studName,studAge,studSex) VALUES(?, ?, ?)"; //删除的 sql 语句 删除的 private static final String SQL_DELETE = "DELETE FROM Student WHERE studID= ? "; //根据查询 根据查询 private static final String SQL_GET_STUDENT="SELECT studID,studName,studAge,studSex FROM Student WHERE studID=?"; //根据修改 根据修改 private static final String SQL_UPDATE = "UPDATE Student SET studName=?,studAge=?,studSex=? WHERE studID=?"; public ArrayList ListStudent(Connection conn) throws Exception { //从数据库取出所有学生的信息存放在 arrayList 中 从数据库取出所有学生的信息存放在 ArrayList arraylist = new ArrayList(); Statement stmt = conn.createStatement(); ResultSet rs = stmt.executeQuery(SQL_LIST); //循环添加 循环添加 while (rs.next()) { StudentBean sb = new StudentBean(); sb.setStudID(rs.getInt
("studID")); sb.setStudName(rs.getString("studName")); sb.setStudAge(rs.getInt("studAge")); sb.setStudSex(rs.getString("studSex")); arraylist.add(sb); } //关闭连接 关闭连接 DBConnection.CloseDB(conn, stmt, null, rs); return arraylist; } public boolean AddStudent(Connection conn, StudentBean sb) throws Exception { boolean success = false; PreparedStatement pstmt = null; //传入 Bean,把 Bean 中的信息添加进数据库 传入 把 try