orcllogindao.java

这是一个基于大唐电信的一个任务管理模块程序

package com.datang.struts.dao;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import com.datang.struts.common.DbCommon;
import com.datang.struts.daoface.LoginDao;
import com.datang.struts.dto.TangEmployee;
import com.datang.struts.dto.TangUser;
import com.datang.struts.util.DbUtil;

public class OrclLoginDao implements LoginDao{
	public TangUser selectTangUser(TangUser user){
		Connection conn = DbUtil.getConnection();
		String sql ="SELECT * FROM tang_user WHERE user_id=? AND user_psw=?";
		PreparedStatement pstmt = null;
		ResultSet rs = null;
		try {
			pstmt = conn.prepareStatement(sql);
			pstmt.setString(1, user.getUser_id());
			pstmt.setString(2, user.getUser_psw());
			rs = pstmt.executeQuery();
			if(rs.next()){
				TangUser newuser = new TangUser();
				newuser.setUser_id(rs.getString(1));
				newuser.setUser_psw(rs.getString(2));
				return newuser;
			}else{
				return null;
			}
		} catch (SQLException e) {
			if(DbCommon.DEBUG)
				e.printStackTrace();
			return null;
		}finally{
			try {
				rs.close();
			} catch (SQLException e) {
				if(DbCommon.DEBUG)
					e.printStackTrace();
			}
			try {
				pstmt.close();
			} catch (SQLException e) {
				if(DbCommon.DEBUG)
					e.printStackTrace();
			}
			try {
				conn.close();
			} catch (SQLException e) {
				if(DbCommon.DEBUG)
					e.printStackTrace();
			}
		}	
	}
	
	public TangEmployee selectTangEmployee(TangEmployee employee){
		Connection conn = DbUtil.getConnection();
		String sql = "SELECT * FROM tang_employee WHERE employee_id=? AND employee_password=? AND employee_position=?";
		PreparedStatement pstmt = null;
		ResultSet rs = null;
		try {
			pstmt = conn.prepareStatement(sql);
			pstmt.setString(1, employee.getEmployee_id());
			pstmt.setString(2, employee.getEmployee_password());
			pstmt.setString(3, employee.getEmployee_position());
			rs = pstmt.executeQuery();
			if(rs.next()){
				TangEmployee newemployee = new TangEmployee();
				newemployee.setEmployee_id(rs.getString(1));
				newemployee.setEmployee_password(rs.getString(2));
				newemployee.setEmployee_name(rs.getString(3));
				newemployee.setEmployee_sex(rs.getString(4));
				newemployee.setEmployee_birthday(rs.getDate(5));
				newemployee.setEmployee_position(rs.getString(6));
				newemployee.setEmployee_hire_date(rs.getDate(7));
				newemployee.setManager_id(rs.getString(8));
				newemployee.setEmployee_experience(rs.getString(9));
				newemployee.setEmployee_major(rs.getString(10));
				newemployee.setEmployee_degree(rs.getString(11));
				return newemployee;
			}else{
				return null;
			}
		} catch (SQLException e) {
			if(DbCommon.DEBUG)
				e.printStackTrace();
			return null;
		}finally{
			try {
				rs.close();
			} catch (SQLException e) {
				if(DbCommon.DEBUG)
					e.printStackTrace();
			}
			try {
				pstmt.close();
			} catch (SQLException e) {
				if(DbCommon.DEBUG)
					e.printStackTrace();
			}
			try {
				conn.close();
			} catch (SQLException e) {
				if(DbCommon.DEBUG)
					e.printStackTrace();
			}
		}	
	}
}