operatecourse.java

JSF 演示代码

import java.util.Vector;

import java.sql.ResultSet;
import java.sql.Connection;
import java.sql.Statement;
import java.sql.SQLException;

/*
 * 实现对课程表的相关操作
 */
public class OperateCourse
{
    private Statement stmt = null;
    private Connection con = null;
    private ResultSet rs = null;
    
    //添加课程记录
    public int addCourse(String courseId, 
                         String courseName,
                         String courseTeacher,
                         String courseDescription)
    {
        StringBuffer sql = new StringBuffer();
        sql.append("insert into course(course_id,course_name,course_teacher,course_des)");
        sql.append("values ('" +courseId + "', '" + courseName + "', '");
        sql.append(courseTeacher + "', '" + courseDescription + "')");
        return execAction(sql.toString());
    }
    
    //删除课程记录
    public int deleteCourse(String courseId)
    {
        StringBuffer sql = new StringBuffer();
        sql.append("delete from course where course_id='" + courseId + "'");
        return execAction(sql.toString());
    }
    
    //查询所有课程记录    
    public CourseStorage queryAllCourse()
    {
        StringBuffer sql = new StringBuffer();
        sql.append("select course_id from course");
        
        CourseStorage store = new CourseStorage();
        Vector vec = new Vector();
        con = GetDBConnection.getConnection();
        try
        {
            stmt = con.createStatement();
            rs = stmt.executeQuery(sql.toString());
            
            while(rs.next())
            {
                String courseId = rs.getString("course_id");
                Course one = new Course(courseId);
                
                vec.add(one);                
            }
            rs.close();
            store.setCourseVec(vec);
        }
        catch (SQLException ex)
        {
            System.out.println("不能创建该连接的会话！！！");
            ex.printStackTrace();
        }
        GetDBConnection.destroyConnection(con, stmt);
        return store;
    }
    
    
    //查询单条课程记录
    public Course queryOneCourse(String courseId)
    {
        StringBuffer sql = new StringBuffer();
        sql.append("select * from course where course_id='" + courseId + "'");
        
        Course oneCourse = null;
        con = GetDBConnection.getConnection();
        try
        {
            stmt = con.createStatement();
            rs = stmt.executeQuery(sql.toString());
            
            while(rs.next())
            {
                String courseName = rs.getString("course_name");
                String courseTeacher = rs.getString("course_teacher");
                String courseDes = rs.getString("course_des");
                oneCourse = new Course(courseId, courseName, courseTeacher, courseDes);              
            }
            rs.close();
        }
        catch (SQLException ex)
        {
            System.out.println("不能创建该连接的会话！！！");
            ex.printStackTrace();
        }
        GetDBConnection.destroyConnection(con, stmt);
        return oneCourse;
    }
        
    private int execAction(String sql)
    {
        int i = 0;
        con = GetDBConnection.getConnection();
        try
        {
            stmt = con.createStatement();
            i = stmt.executeUpdate(sql);
        }
        catch (SQLException ex)
        {
            System.out.println("操作记录出错！！！");
            ex.printStackTrace();
        }
        GetDBConnection.destroyConnection(con, stmt);
        return i;
    }
}