subjectdaobean.java

来自「基于Spring2.5的精品课程网站」· Java 代码 · 共 104 行

package org.adam.dao.impl;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import org.adam.DataSource.DBControl;
import org.adam.bean.SubjectBean;
import org.adam.dao.SubjectDAO;

public class SubjectDAOBean implements SubjectDAO {

	private DBControl db;
	
	public void delete(int subject_id) {
		String sql="delete from subject where subject_id="+subject_id;
		db.setDataInfo(sql);
	}

	public SubjectBean getSubject(int subject_id) {
		String sql="select * from subject where subject_id="+subject_id;
		ResultSet rs=db.getDataInfo(sql);
		SubjectBean subject=new SubjectBean();
		try {
			while(rs.next()){
				subject.setSubject_id(rs.getInt("subject_id"));
				subject.setTeacher_id(rs.getInt("teacher_id"));
				subject.setSubjectname(rs.getString("subjectname"));
				subject.setSubjectcontext(rs.getString("subjectcontext"));
			}
			return subject;
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			return null;
		}finally{
			db.closeConnection();
		}
	}

	public List<SubjectBean> getSubjects() {
		String sql="select * from subject";
		ResultSet rs=db.getDataInfo(sql);
		SubjectBean subject;
		List<SubjectBean> list=new ArrayList<SubjectBean>();
		try {
			while(rs.next()){
				subject=new SubjectBean();
				subject.setSubject_id(rs.getInt("subject_id"));
				subject.setTeacher_id(rs.getInt("teacher_id"));
				subject.setSubjectname(rs.getString("subjectname"));
				subject.setSubjectcontext(rs.getString("subjectcontext"));
				list.add(subject);
			}
			return list;
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			return null;
		}finally{
			db.closeConnection();
		}
	}

	public void insert(SubjectBean subject) {
		String sql="insert into subject(teacher_id,subjectname,subjectcontext) values("+subject.getTeacher_id()+",'"+subject.getSubjectname()+"','"+subject.getSubjectcontext()+"')";
		db.setDataInfo(sql);
	}

	public DBControl getDb() {
		return db;
	}

	public void setDb(DBControl db) {
		this.db = db;
	}

	public List<SubjectBean> getSubjects(int teacher_id) {
		String sql="select * from subject where teacher_id="+teacher_id;
		ResultSet rs=db.getDataInfo(sql);
		SubjectBean subject;
		List<SubjectBean> list=new ArrayList<SubjectBean>();
		try {
			while(rs.next()){
				subject=new SubjectBean();
				subject.setSubject_id(rs.getInt("subject_id"));
				subject.setTeacher_id(rs.getInt("teacher_id"));
				subject.setSubjectname(rs.getString("subjectname"));
				subject.setSubjectcontext(rs.getString("subjectcontext"));
				list.add(subject);
			}
			return list;
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			return null;
		}finally{
			db.closeConnection();
		}
	}

}