teacherio.java

成绩查询系统（学校期末的作业） Struts+jdbc+mysql+tomcat 开发工具为BEA WORKSHOP 功能无非就是增删查改加用户权限判断

package sfs.entity.io;

import java.lang.reflect.InvocationTargetException;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import sfs.connection.ConnIO;
import sfs.connection.ResToObj;
import sfs.entity.Teacher;

public class TeacherIo extends ConnIO {

	public TeacherIo() throws ClassNotFoundException, SQLException {
		
	}
	
	/*******************查询***********************/
	public  List query() throws SQLException{
		String sql="select * from user_teacher";
		List list=new ArrayList();
		ResultSet res;
		res = conn.createStatement().executeQuery(sql);
			while(res.next()){
				if(!res.getString("authority").endsWith("2")){
				list.add(ResToObj.excute("user_teacher",res));		
				}
			}
		res.close();
		
		return list;		
	}
	
	public  List queryByid(int id) throws SQLException, NumberFormatException, IllegalAccessException, InvocationTargetException, NoSuchMethodException{
		String sql="select * from user_teacher where id="+id;
		return super.Query(sql,"user_teacher");
	}
	
	public  List queryBynumber(String number) throws SQLException, NumberFormatException, IllegalAccessException, InvocationTargetException, NoSuchMethodException{
		String sql="select * from user_teacher where number="+number;
		return super.Query(sql,"user_teacher");
	}
	
	public Teacher queryByLoginnameAndPswd(String number,String password) throws SQLException{
		String sql="select * from user_teacher where number="+"\""+number+"\""+" and password="+"\""+password+"\"";
		ResultSet res=conn.createStatement().executeQuery(sql);		
		if(res.next()){
			Teacher te=(Teacher)ResToObj.excute("user_teacher",res);
			return te;	
		}
		return null;
		
	}
	
	public Teacher queryByLoginname(String number) throws SQLException{
		String sql="select * from user_teacher where number="+"\""+number+"\"";
		ResultSet res=conn.createStatement().executeQuery(sql);
		if(res.next()){
			Teacher te=(Teacher)ResToObj.excute("user_teacher",res);
			System.err.println(te);
			return te;
		}
		return null;
	}
	/**************************删除****************************/
	public  boolean deletByid(Teacher te) throws SQLException, IllegalAccessException, InvocationTargetException, NoSuchMethodException{
		super.DeletById("user_teacher",te);
		return true;
	}
	public  boolean deletBynumber(Teacher te) throws SQLException, IllegalAccessException, InvocationTargetException, NoSuchMethodException{
		super.DeletByNumber("user_teacher",te);
		return true;
	}
	
	/***********************增加或修改*************************/
	public  boolean saveorupdata(Teacher te) throws SQLException, NumberFormatException, IllegalAccessException, InvocationTargetException, NoSuchMethodException{
		//查询对象，如果为空则增加，不为空则更新
		if(this.QueryById("user_teacher",te)==null){			
			//增加记录
			System.out.print("增加记录");               
			String sql="insert  user_teacher (number,password,authority,realname) values (?,?,?,?)";
			PreparedStatement prepar = conn.prepareStatement(sql);
			prepar.setString(1,te.getNumber());
			prepar.setString(2,te.getPassword());
			prepar.setString(3,te.getAuthority());
			prepar.setString(4,te.getRealname());
			prepar.executeUpdate();
			prepar.close();	
			return true;
		}else{
			//更新			
			System.out.print("更新");               
			//是否需要按照用户名修改更新??
			Teacher temp=(Teacher)this.QueryByNumber("user_teacher",te).get(0);
			String sql="update user_teacher set number=? ,password=? ,authority=? ,realname=?  where id=?";
			PreparedStatement prepar = conn.prepareStatement(sql);
			prepar.setString(1,te.getNumber());
			prepar.setString(2,te.getPassword());
			prepar.setString(3,te.getAuthority());
			prepar.setString(4,te.getRealname());
			prepar.setInt(5,temp.getId());
			prepar.execute();
			prepar.close();	
			return true;
		}

}
	public void updatePassword(String password,int id) throws SQLException{
		String sql="update user_teacher set password="+"\""+password+"\""+" where id="+"\""+id+"\"";
		conn.createStatement().executeUpdate(sql);
	}
//	
//	public void updataLoginname(String oldLoginname,String newLoginname) throws SQLException {
//		String sql="update hr_adminuser set loginname="+"\""+newLoginname+"\""+" where loginname="+"\""+oldLoginname+"\"";
//		conn.createStatement().executeUpdate(sql);
//	}
}