concemdao.java

一套网上书店系统采用JAVABEAN+SERVLET+JSP

package cn.dang.dao;

import ghy_db.DB_operate_interface;

import java.util.ArrayList;
import java.util.List;

import cn.dang.entity.Concem;

public class ConcemDAO {
	//创建数据库操作通用类实现接口引用
	DB_operate_interface dbRef;
	/**
	 * @param DB_operate_interface 获得DB_operate_interface引用
	 */
	public ConcemDAO(DB_operate_interface dbRef){
		super();
		this.dbRef=dbRef;
	}
	/**
	 * @param String sql 查询数据所需的SQL语句
	 * @return List<T> 返回从数据集中获得的所有数据
	 * @throws Throwable
	 */
	public List<Concem> querConcemAll(String sql) throws Throwable{
		//从通用DB类中查询获得数据
		List list=dbRef.query(sql);
		//创建保存对象的容器
		List<Concem> concems=new ArrayList<Concem>();
		//循环从list中取出数据重新封装
		for(int i=0;i<list.size();i++){
			String[] s=(String[])list.get(i);
			Concem concem=new Concem();
			concem.setCid(Integer.parseInt(s[0]));
			concem.setConcemName(s[1]);
			concems.add(concem);
		}
		return concems;
	}
	
	/**
	 * @param String sql 查询数据所需的SQL语句
	 * @return List 返回id
	 * @throws Throwable
	 */
	public List queryConcem(String sql) throws Throwable{
		//从DB通用类中查询出的数据返回
		return dbRef.query(sql);
	}
	
	/**
	 * @param String sql 插入数据时所需的SQL语句
	 * @throws Throwable
	 */
	public void nonQueryConcem(String sql,ArrayList values_list) throws Throwable{
		//调用DB通用类中的UPDATE方法进行插入数据
		dbRef.update(sql, values_list);
	}
	
	/**
	 * @param String sql 查询数据时所需要的SQL语句
	 * @return 返回查询出的ID
	 * @throws Throwable
	 */
	public int queryConcemId(String sql) throws Throwable{
		//调用DB通用类中的query方法进行查询ID
		return Integer.parseInt(((String[])dbRef.query(sql).get(0))[0]);
	}
	public Concem queryConcemInfo(String sql) throws Throwable{
		List list=dbRef.query(sql);
		Concem c=new Concem();
		if(list.size()>0){
			String[] s=(String[])list.get(0);
			c.setCid(Integer.parseInt(s[0]));
			c.setConcemName(s[1]);
		}
		return c;
	}
}