userinfo.java~43~

来自「用户的注册 用户的登陆 发布用户的相关信息 浏览网站介绍的其他酒店的」· JAVA~43~ 代码 · 共 338 行

package dao;

import java.util.*;
import domain.*;
import java.sql.Connection;
import java.sql.Statement;
import java.sql.ResultSet;
import tool.SQLCode;
import tool.EidetSql;
import tool.Conn;
import java.sql.*;
import tool.DateTime;

public class UserInfo implements UserInfoDao {
    EidetSql ed = null;
    public UserInfo() {
        ed = new EidetSql();
    }

    /*******************************************
     * method name:check
     * method function :核查个人用户
     * return type:boolean
     * datetime : 2007-09-15
     *******************************************/

    public boolean check(UserInfoForm user) {
        Connection con = null;
        Statement st = null;
        ResultSet rs = null;
        Conn cn = new Conn();
        SQLCode sc = new SQLCode();
        String sql = sc.getSQLCode("sql.userInfo.check");
        sql = ed.editSqlStr(sql, user.getUserId());
        sql = ed.editSqlStr(sql, user.getPassword());
        boolean isCheck = false;
        try {
            con = cn.getConnection();
            st = con.createStatement();
            rs = st.executeQuery(sql);
            if (rs.next()) {
                isCheck = true;
            }
            rs.close();
            st.close();
            con.close();
        } catch (SQLException ex) {
            System.out.println("核查用户sql:" + ex.getMessage());
        } catch (ClassNotFoundException ex) {
            System.out.println("类加载:" + ex.getMessage());
        }
        return isCheck;
    }

    /*******************************************
     * method name:count
     * method function :统计个人用户记录
     * return type:int
     * datetime : 2007-09-15
     *******************************************/

    public int count() {
        Connection con = null;
        Statement st = null;
        ResultSet rs = null;
        Conn cn = new Conn();
        SQLCode sc = new SQLCode();
        String sql = sc.getSQLCode("sql.userInfo.count");
        int row = 0;
        try {
            con = cn.getConnection();
            st = con.createStatement();
            rs = st.executeQuery(sql);
            if (rs.next()) {
                row = rs.getInt(1);
            }
            rs.close();
            st.close();
            con.close();
        } catch (SQLException ex) {
            System.out.println("统计个人用户记录sql:" + ex.getMessage());
        } catch (ClassNotFoundException ex) {
            System.out.println("类加载:" + ex.getMessage());
        }
        return row;
    }

    /*******************************************
     * method name:delete
     * method function :删除个人用户
     * return type:int
     * datetime : 2007-09-15
     *******************************************/

    public int delete(UserInfoForm user) {
        Connection con = null;
        Statement st = null;
        Conn cn = new Conn();
        SQLCode sc = new SQLCode();
        String sql = sc.getSQLCode("sql.userInfo.delete");
        sql = ed.editSqlStr(sql, user.getUserId());
        int row = 0;
        try {
            con = cn.getConnection();
            st = con.createStatement();
            row = st.executeUpdate(sql);
            st.close();
            con.close();
        } catch (SQLException ex) {
            System.out.println("删除用户sql:" + ex.getMessage());
        } catch (ClassNotFoundException ex) {
            System.out.println("类加载:" + ex.getMessage());
        }
        return row;
    }

    /*******************************************
     * method name:insert
     * method function :注册用户
     * return type:int
     * datetime : 2007-09-15
     *******************************************/
    public int insert(UserInfoForm user) {
        Connection con = null;
        Statement st = null;
        ResultSet rs = null;
        Conn cn = new Conn();
        SQLCode sc = new SQLCode();
        String sql = sc.getSQLCode("sql.userInfo.insert");
        sql = ed.editSqlStr(sql, user.getUserId());
        sql = ed.editSqlStr(sql, user.getPassword());
        sql = ed.editSqlStr(sql, user.getName());
        sql = ed.editSqlStr(sql, user.getQuestion());
        sql = ed.editSqlStr(sql, user.getAnswer());
        sql = ed.editSqlStr(sql, user.getImageId());
        sql = ed.editSqlStr(sql, user.getSex());
        sql = ed.editSqlInt(sql, user.getAge());
        sql = ed.editSqlStr(sql, user.getTel());
        sql = ed.editSqlStr(sql, user.getEmail());
        sql = ed.editSqlStr(sql, user.getAddress());
        int row = 0;
        try {
            con = cn.getConnection();
            st = con.createStatement();
            row = st.executeUpdate(sql);
            st.close();
            con.close();
        } catch (SQLException ex) {
            System.out.println("注册用户sql:" + ex.getMessage());
        } catch (ClassNotFoundException ex) {
            System.out.println("类加载:" + ex.getMessage());
        }
        return row;
    }

    /*******************************************
     * method name:select
     * method function :查询所有用户
     * return type:int
     * datetime : 2007-09-15
     *******************************************/

    public Collection select(UserInfoForm user, int page) {
        Connection con = null;
        Statement st = null;
        ResultSet rs = null;
        Conn cn = new Conn();
        SQLCode sc = new SQLCode();
        DateTime time = new DateTime();
        String sql = sc.getSQLCode("sql.userInfo.select");
        Collection list = new ArrayList();
        try {
            con = cn.getConnection();
            st = con.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,
                                     ResultSet.CONCUR_READ_ONLY);
            rs = st.executeQuery(sql);
            int tip = 5 * (page - 1);
            try {
                if (tip <= 0) {
                    rs.beforeFirst();
                } else {
                    if (!rs.absolute(tip)) {
                        rs.beforeFirst();
                    }
                }
            } catch (SQLException ex1) {
                System.out.println("tip" + ex1.getMessage());
            }

            for (int i = 1; rs.next() && i <= 5; i++) {
                user = new UserInfoForm();
                user.setUserId(rs.getString(1));
                user.setPassword(rs.getString(2));
                user.setName(rs.getString(3));
                user.setQuestion(rs.getString(4));
                user.setAnswer(rs.getString(5));
                user.setImageId(rs.getString(6));
                user.setSex(rs.getString(7));
                user.setAge(rs.getInt(8));
                user.setTel(rs.getString(9));
                user.setEmail(rs.getString(10));
                user.setAddress(rs.getString(11));
                user.setStatus(rs.getString(12));
                user.setTime(rs.getString(13));
                list.add(user);
            }
            rs.close();
            st.close();
            con.close();
        } catch (SQLException ex) {
            System.out.println("查询用户sql:" + ex.getMessage());
        } catch (ClassNotFoundException ex) {
            System.out.println("类加载:" + ex.getMessage());
        }
        return list;
    }

    /*******************************************
     * method name:statusUpdate
     * method function :更新用户状态
     * return type:int
     * datetime : 2007-09-15
     *******************************************/

    public int statusUpdate(UserInfoForm user) {
        Connection con = null;
        Statement st = null;
        ResultSet rs = null;
        Conn cn = new Conn();
        SQLCode sc = new SQLCode();
        String sql = sc.getSQLCode("sql.userInfo.statusUpdate");
        sql = ed.editSqlStr(sql, user.getUserId());
        int row = 0;
        try {
            con = cn.getConnection();
            st = con.createStatement();
            row = st.executeUpdate(sql);
            st.close();
            con.close();
        } catch (SQLException ex) {
            System.out.println("更新用户状态sql:" + ex.getMessage());
        } catch (ClassNotFoundException ex) {
            System.out.println("类加载:" + ex.getMessage());
        }
        return row;
    }


    /*******************************************
     * method name:update
     * method function :更新用户
     * return type:int
     * datetime : 2007-09-15
     *******************************************/

    public int update(UserInfoForm user) {
        Connection con = null;
        Statement st = null;
        ResultSet rs = null;
        Conn cn = new Conn();
        SQLCode sc = new SQLCode();
        String sql = sc.getSQLCode("sql.userInfo.update");
        sql = ed.editSqlStr(sql, user.getPassword());
        sql = ed.editSqlStr(sql, user.getName());
        sql = ed.editSqlStr(sql, user.getQuestion());
        sql = ed.editSqlStr(sql, user.getAnswer());
        sql = ed.editSqlStr(sql, user.getImageId());
        sql = ed.editSqlStr(sql, user.getSex());
        sql = ed.editSqlInt(sql, user.getAge());
        sql = ed.editSqlStr(sql, user.getTel());
        sql = ed.editSqlStr(sql, user.getEmail());
        sql = ed.editSqlStr(sql, user.getAddress());
        System.out.println(sql);
        int Row = 0;
        try {
            con = cn.getConnection();
            st = con.createStatement();
            Row = st.executeUpdate(sql);
            st.close();
            con.close();
        } catch (SQLException ex) {
            System.out.println("更新用户状态sql:" + ex.getMessage());
        } catch (ClassNotFoundException ex) {
            System.out.println("类加载:" + ex.getMessage());
        }
        return Row;
    }
    /*******************************************
    * method name:select
    * method function :查询所有用户
    * return type:int
    * datetime : 2007-09-15
    *******************************************/

   public Collection idSelect(UserInfoForm user) {
       Connection con = null;
       Statement st = null;
       ResultSet rs = null;
       Conn cn = new Conn();
       SQLCode sc = new SQLCode();
       DateTime time = new DateTime();
       String sql = sc.getSQLCode("sql.userInfo.idselect");
       sql=ed.editSqlStr(sql,user.getUserId());
       Collection list = new ArrayList();
       try {
           con = cn.getConnection();
           st = con.createStatement();
           rs = st.executeQuery(sql);
           while(rs.next()){
               user = new UserInfoForm();
               user.setUserId(rs.getString(1));
               user.setPassword(rs.getString(2));
               user.setName(rs.getString(3));
               user.setQuestion(rs.getString(4));
               user.setAnswer(rs.getString(5));
               user.setImageId(rs.getString(6));
               user.setSex(rs.getString(7));
               user.setAge(rs.getInt(8));
               user.setTel(rs.getString(9));
               user.setEmail(rs.getString(10));
               user.setAddress(rs.getString(11));
               user.setStatus(rs.getString(12));
               user.setTime(rs.getString(13));
               list.add(user);
           }
           rs.close();
           st.close();
           con.close();
       } catch (SQLException ex) {
           System.out.println("根据id查询用户sql:" + ex.getMessage());
       } catch (ClassNotFoundException ex) {
           System.out.println("类加载:" + ex.getMessage());
       }
       return list;
   }

}