persondaoimpl.java

留言管理系统,用JAVA JSP + MVC + DAO完成

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
package com.shx.note.dao.impl;

import com.shx.note.DBConn.DBConnection;
import com.shx.note.dao.PersonDAO;
import com.shx.note.vo.Person;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

/**
 *
 * @author Administrator
 */
public class PersonDAOImpl implements PersonDAO {

    /*
    功能：
    · 判断是否是正确的用户名或密码
    · 从数据库中取出用户的真实姓名
     */
    public boolean login(Person person) throws Exception {
        //是否成功登陆的标志
        boolean flag = false;

        String sql = "SELECT p_name FROM person WHERE p_id = ? AND p_password = ?";
        PreparedStatement pstmt = null;
        //实例化数据库连接对象
        DBConnection dbconn = new DBConnection();
        Connection conn = dbconn.getConnection();
        try {
            pstmt = conn.prepareStatement(sql);
            pstmt.setInt(1, person.getP_id());
            pstmt.setString(2, person.getP_password());
            ResultSet rs = pstmt.executeQuery();

            if (rs.next()) {
                //用户合法
                flag = true;
                person.setP_name(rs.getString(1));
            }

            //关闭连接
            rs.close();
            pstmt.close();
        } catch (SQLException sQLException) {
            throw new SQLException("操作中出现错误！！！");
        } finally {
            //关闭数据库连接对象
            conn.close();
        }
        return flag;
    }

    public void register(Person person) throws Exception {
        String sql = "INSERT INTO person(p_name,p_password,sex,email) VALUES(?,?,?,?)";
        PreparedStatement pstmt = null;
        //实例化数据库连接对象
        DBConnection dbconn = new DBConnection();
        Connection conn = dbconn.getConnection();

        String p_password = person.getP_password();
        String confirm_password = person.getConfirm_password();

        try {
            if (p_password.equals(confirm_password) && confirm_password.equals(p_password)) {
                pstmt = conn.prepareStatement(sql);
                pstmt.setString(1, person.getP_name());
                pstmt.setString(2, person.getP_password());
                pstmt.setString(3, person.getSex());
                pstmt.setString(4, person.getEmail());
                pstmt.executeUpdate();
                //关闭连接
                pstmt.close();
            }
        } catch (SQLException sQLException) {
            throw new SQLException("操作中出现错误！！！");
        } finally {
            //关闭数据库连接对象
            conn.close();
        }
    }
}