userdao.java

固定资产管理系统 资产的增删改查 借出 管理 自动报废 统计功能等等

/*
 * @(#)UserDAO.java Aug 8, 2007
 * Copyright 2007 ThinkJ organization, Inc. All rights reserved
 */
package com.qrsx.asset.dao;

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

import com.qrsx.asset.model.User;

/**
 * 
 * Author  : 王希涛<br>
 * Company : 青软实训<br>
 * Version : 1.0<br>
 * Date    : Aug 8, 2007<br>
 */
public class UserDAO extends BaseDAO{

    /**
     * 创建用户
     * @param User
     */
    public void create( User user ) throws SQLException{
        String sql = "Insert Into user(loginName, password, name, sex, age, address, postcard, telephone) Values(?, ?, ?, ?, ?, ?, ?, ?)";

        //设置参数值
        ps=conn.prepareStatement(sql);
        ps.setString(1, user.getLoginName());
        ps.setString(2, user.getPassword());
        ps.setString(3, user.getName());
        ps.setString(4, user.getSex());
        ps.setInt(   5, user.getAge());
        ps.setString(6, user.getAddress());
        ps.setString(7, user.getPostcard());
        ps.setString(8, user.getTelephone());
        
        //执行
        ps.executeUpdate();
    }
    
    /**
     * 更新用户
     * @param User
     */
    public void update( User user ) throws SQLException{
        String sql = "Update user set loginName=?, password=?, name=?, sex=?, age=?, address=?, postcard=?, telephone=? where id=? ";

        //设置参数值
        ps=conn.prepareStatement(sql);
        ps.setString(1, user.getLoginName());
        ps.setString(2, user.getPassword());
        ps.setString(3, user.getName());
        ps.setString(4, user.getSex());
        ps.setInt(   5, user.getAge());
        ps.setString(6, user.getAddress());
        ps.setString(7, user.getPostcard());
        ps.setString(8, user.getTelephone());
        ps.setInt(   9, user.getId());

        //执行
        ps.executeUpdate();
    }
    
    /**
     * 删除用户
     * @param UserId 要删除的用户主键
     * @return 删除的用户数目
     */
    public int delete( Integer userId ) throws SQLException{
        String sql = "Delete from user where id=? ";

        //设置参数值
        ps=conn.prepareStatement(sql);
        ps.setInt(1, userId);

        //执行
        int total = ps.executeUpdate();
        return total;
    }

    /**
     * 根据主键检索用户
     * @param UserId 要检索的用户主键
     * @return 检索到的用户
     */
    public User findById( Integer userId ) throws SQLException{
        String sql = "Select * from user where id=? ";

        //设置参数值并执行查询
        ps=conn.prepareStatement(sql);
        ps.setInt(1, userId);
        ResultSet rs = ps.executeQuery();
        
        User user = null;
        if( rs.next() ){
        	user = new User();
        	user.setId( rs.getInt("id") );
        	user.setLoginName( rs.getString("loginName") );
        	user.setPassword( rs.getString("password") );
        	user.setName( rs.getString("name") );
        	user.setSex( rs.getString("sex") );
        	user.setAge( rs.getInt("age") );
        	user.setAddress( rs.getString("address") );
        	user.setPostcard( rs.getString("postcard") );
        	user.setTelephone( rs.getString("telephone") );
        }
        
        return user;
    }

    /** 
     * 根据登录名称和密码检索用户
     * @param loginName
     * @param password
     * @return
     * @throws SQLException
     */
    public User findForLogon( String loginName , String password ) throws SQLException{
        String sql = "Select * from user where loginName=? and password=? ";

        //设置参数值并执行查询
        ps=conn.prepareStatement(sql);
        ps.setString(1, loginName);
        ps.setString(2, password);
        ResultSet rs = ps.executeQuery();
        
        User user = null;
        if( rs.next() ){
        	user = new User();
        	user.setId( rs.getInt("id") );
        	user.setLoginName( rs.getString("loginName") );
        	user.setPassword( rs.getString("password") );
        	user.setName( rs.getString("name") );
        	user.setSex( rs.getString("sex") );
        	user.setAge( rs.getInt("age") );
        	user.setAddress( rs.getString("address") );
        	user.setPostcard( rs.getString("postcard") );
        	user.setTelephone( rs.getString("telephone") );
        }
        
        return user;
    }

    /**
     * 检索用户
     * @param User
     * @return
     */
    public List<User> findAll() throws SQLException{
        String sql = "Select * from user ";
        
        //执行查询
        ps=conn.prepareStatement(sql);
        ResultSet rs = ps.executeQuery();
        
        //将查询结果组装至User实体对象
        User user = null; 
        List<User> list = new ArrayList<User>();
        while( rs.next() ){
        	user = new User();
        	user.setId( rs.getInt("id") );
        	user.setLoginName( rs.getString("loginName") );
        	user.setPassword( rs.getString("password") );
        	user.setName( rs.getString("name") );
        	user.setSex( rs.getString("sex") );
        	user.setAge( rs.getInt("age") );
        	user.setAddress( rs.getString("address") );
        	user.setPostcard( rs.getString("postcard") );
        	user.setTelephone( rs.getString("telephone") );
            list.add(user);
        }
        
        return list;
    }
    
    /**
     * 检索用户
     * @param User
     * @return
     */
    public List<User> list( User user ) throws SQLException{
        String sql = "Select * from user where 1=1 ";
        
        //根据书名检索
        if( user.getName()!=null && !user.getName().equals("") ){
            sql = sql + " and name like '%" + user.getName() + "%'";
        }

        //执行查询
        ps=conn.prepareStatement(sql);
        ResultSet rs = ps.executeQuery();
        
        //将查询结果组装至User实体对象
        User user1 = null;
        List<User> list = new ArrayList<User>();
        while( rs.next() ){
        	user1 = new User();
        	user1.setId( rs.getInt("id") );
        	user1.setLoginName( rs.getString("loginName") );
        	user1.setPassword( rs.getString("password") );
        	user1.setName( rs.getString("name") );
        	user1.setSex( rs.getString("sex") );
        	user1.setAge( rs.getInt("age") );
        	user1.setAddress( rs.getString("address") );
        	user1.setPostcard( rs.getString("postcard") );
        	user1.setTelephone( rs.getString("telephone") );
            list.add(user1);
        }
        
        return list;
    }
}