UserDaoImpl

package com.neudeu.Dao.Impl;



import java.sql.Connection;

import java.sql.PreparedStatement;

import java.sql.ResultSet;



import com.neuedu.dao.IUserDao;

import com.neuedu.pojo.User;

import com.neuedu.util.DBUtil;



public class UserDaoImpl implements IUserDao {

    Connection conn=null;

    PreparedStatement st=null;

    ResultSet rs=null;

    @Override

    public int add(User user) {

        conn=DBUtil.getConnection();

        int i=0;

        try {

            st = conn.prepareStatement("insert into t_user values(null,?,?,?,?,?)");

            st.setString(1, user.getUsername());

            st.setString(2, user.getPassword());

            st.setString(3, user.getEmail());

            st.setString(4, user.getIdcard());

            st.setInt(5, user.getPower());

             i = st.executeUpdate();

             if(i>0){

                 System.out.println("注册成功");

             }else{

                 System.out.println("注册失败");

             }

            //System.out.println("操作成功了"+i+"条");

        } catch (Exception e) {

            e.printStackTrace();

            System.out.println("数据库操作异常");

        }finally{

            DBUtil.closeCannection(rs, st, conn);

        }

        return i;

        }











    @Override

    public User get(User user) {



            conn=DBUtil.getConnection();

            User u = null;

            try {

                st = conn.prepareStatement("select * from t_user where user_name=? and user_password=?");

                st.setString(1, user.getUsername());

                st.setString(2,user.getPassword());

                rs = st.executeQuery();

      if (rs.next()) {



                    u = new User();

                    u.setUsername(rs.getString("user_name"));

                    u.setPassword(rs.getString("user_password"));

    u.setId(rs.getInt("user_id"));

    u.setEmail(rs.getString("user_email"));

    u.setIdcard(rs.getString("user_idcard"));

u.setPower(rs.getInt("user_power"));

        } else{

            System.out.println("登录失败");

        }

            } catch (Exception e) {

                e.printStackTrace();

            }finally{

                DBUtil.closeCannection(rs, st, conn);

            }

            return u;

        }











    @Override

    public int updatePwd(User user) {

        int count = 0;

        conn = DBUtil.getConnection();

        try {

            st = conn.prepareStatement("update t_user set user_password=? where user_id=?");

            st.setString(1, user.getPassword());

            st.setInt(2, user.getId());

            count = st.executeUpdate();

            if (count > 0) {

                System.out.println("修改成功");

            } else {

                System.out.println("修改失败");

            }

        } catch (Exception e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        } finally {

            DBUtil.closeCannection(rs, st, conn);

        }

        return count;

    }











    @Override

    public int update(User user) {

        // TODO Auto-generated method stub

        int count = 0;

        conn = DBUtil.getConnection();

        try {

            st = conn.prepareStatement("update t_user set user_name=?,user_email=?,user_idcard=? where user_id=?");

            st.setString(1, user.getUsername());

            st.setString(2, user.getEmail());

            st.setString(3, user.getIdcard());

            st.setInt(4, user.getId());

            count = st.executeUpdate();

            if (count > 0) {

                System.out.println("修改成功");



            } else {

                System.out.println("修改失败");



            }

        } catch (Exception e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        } finally {

            DBUtil.closeCannection(rs, st, conn);

        }

        return count;

    }

    }