consultationbean.java

sql+struts+jsp 提供考试的一般需求

package users;
import javax.sql.DataSource;
import java.sql.*;
import java.util.*;
import users.questionForm;
import java.io.*;
import javax.servlet.http.HttpSession;

public class consultationBean {
    HttpSession session=null;
    Connection conn=null;
    public consultationBean(DataSource ds)throws Exception {
        conn=ds.getConnection();
    }
    //发表问题select questions.*,users.username from questions,users where questions.s_id=users.username order by questions.q_time desc
        public void insert(String stuno,String topic,String question){
            try {
                Statement stmt = conn.createStatement();
                System.out.print(stuno);
                stmt.execute(
                        "insert into questions(s_id,topic,q_time,question) values('" +
                        stuno +"','"+topic+ "',getdate(),'" + question + "')");
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        //查询问题主题信息
        public ResultSet secrch() throws Exception{
                ArrayList a = new ArrayList();
                ResultSet rst=null;
//                try {
                    Statement stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_READ_ONLY);
                    rst = stmt.executeQuery("select questions.*,stuinfo.name from questions,stuinfo where questions.s_id=stuinfo.stuno order by questions.q_time desc");
//                    while (rst.next()) {
//                        questionForm q = new questionForm();
//                        q.setId(rst.getString(1));
//                        q.setName(rst.getString(8));
//                        q.setTopic(rst.getString(3));
//                        q.setTime(rst.getString(5));
//                        q.setQuestion(rst.getString(4));
//                        q.setReply(rst.getString(6));
//                        q.setR_time(rst.getString(7));
//                        a.add(q);
                        //session.setAttribute("rst",String.valueOf(rst));

//                    }
//                } catch (Exception e) {
//                    e.printStackTrace();
//
//                }
                return rst;
        }
        //回复问题
        public void reply(String q_id,String reply){
            try{
                Statement stmt=conn.createStatement();
                stmt.execute("insert into question(reply,r_time) values('"+reply+"',getdate()) where id='"+q_id+"'");
            }catch(Exception e){
                e.printStackTrace();
            }
        }
        //查询问题内容信息
        public ArrayList qsecrch(String qid) throws Exception{
            ArrayList a = new ArrayList();
            ResultSet rst=null;
                try {
                   Statement stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_READ_ONLY);
                    rst = stmt.executeQuery("select a.*,b.name from questions a,stuinfo b where a.s_id=b.stuno and a.id="+qid);

                        while (rst.next()) {
                        questionForm q = new questionForm();
                        q.setId(rst.getString(1));
                        q.setName(rst.getString(8));
                        q.setTopic(rst.getString(3));
                        q.setTime(rst.getString(5));
                        q.setQuestion(rst.getString(4));
                        q.setReply(rst.getString(6));
                        q.setR_time(rst.getString(7));
                        a.add(q);

                    }
                } catch (Exception e) {
                    e.printStackTrace();
                }
               return a;
       }


}