teainfodao.java

在本系统中

package jin.dao;

import java.sql.*;
import java.util.*;

import jin.bean.*;
import jin.config.*;
import jin.conn.*;

import jin.bean.*;

public class TeaInfoDAO
{
	private Connection conn=null;
	
	//查询
	public ArrayList excuteQuery(String sql)
	{
		//String sql="select * from majorInfo";
		Statement stat=null;
		ResultSet rs=null;
		ArrayList teaInfos=new ArrayList(20);
		TeaInfoBean teaInfoBean=null;
		
		try
		{
			if(conn==null)
			{
				conn=new DBConnection().getConnection(new TextParser());
				if(conn==null)
				{
					System.out.println("连接失败");
				}
				
				else
					System.out.println("连接成功");	
			}
			stat=conn.createStatement(ResultSet.TYPE_FORWARD_ONLY,ResultSet.CONCUR_READ_ONLY);
			rs=stat.executeQuery(sql);
			//学生学号、初始密码、班级名称、姓名、院系名称、专业名称、状态
			while(rs.next())
			{
				teaInfoBean=new TeaInfoBean();
				
 				teaInfoBean.setTeaID(rs.getString("teaID"));				
				teaInfoBean.setTeaName(rs.getString("teaName"));
				
				teaInfoBean.setMajorID(rs.getString("majorID"));				
				teaInfoBean.setState(rs.getString("state"));
				teaInfoBean.setDelRecord(rs.getString("delRecord"));
				teaInfos.add(teaInfoBean);
							
			}			
		}
		
		catch(SQLException sqle)
		{
			sqle.printStackTrace();
		}
		
		return teaInfos;
	}
	
	//增加
	public boolean insert(String sql)  //MajorInfoBean majorInfoBean
	{
		//String sql="insert into majorInfo(majorID, majorName, belongTo, state) values("+majorInfoBean.getMajorID()+","+majorInfoBean.getMajorName()+","+majorInfoBean.getBelongTo()+","+majorInfoBean.getState()+")";
		Statement stat=null;
		int returnValue=0;
		
		try
		{
			if(conn==null)
			{
				conn=new DBConnection().getConnection(new TextParser());
			}
			stat=conn.createStatement();
			returnValue=stat.executeUpdate(sql);
			
		}
		catch(SQLException sqle)
		{
			sqle.printStackTrace();
		}
		
		if(returnValue>0)
		{
			return true;
		}
		else
		{
			return false;
		}
	}
	
	//删除
	public boolean delete(String sql)
	{
		return insert(sql);
	}
	
	//更新
	public boolean update(String sql)
	{
		return insert(sql);
	}
}