loginfodao.java

用户通过注册后进行登录

package com.svse.dao;

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

import com.svse.entity.LogInfo;
import com.svse.util.DBConnect;

public class LogInfoDao {
	private Connection conn;
	private PreparedStatement pstmt;
	private ResultSet rs;
	
	/*
	 * 通过用户名和密码查询进行登录
	 */
	public LogInfo logOn(String userName,String userPwd){
		LogInfo loginfo=null;
		String sql="select * from logInfo where userName=? and userPwd=?";
		conn=DBConnect.getConnect();
		try {
			pstmt=conn.prepareStatement(sql);
			//解释SQL语句中的？(设置参数)
			pstmt.setString(1, userName);
			pstmt.setString(2, userPwd);
			//查询数据库，返回查询的记录
			rs=pstmt.executeQuery();
			if(rs.next()){
				loginfo=new LogInfo();
				loginfo.setUserName(rs.getString("userName").trim());
				loginfo.setUserPwd(rs.getString("userPwd").trim());
				loginfo.setSex(rs.getString("sex"));
				loginfo.setHobby(rs.getString("hobby"));
				loginfo.setAddress(rs.getString("address"));
				loginfo.setEvaluate(rs.getString("evaluate"));
			}
		} catch (SQLException e) {
			System.out.println("查询失败！\n消息："+e.getMessage());
		}finally{
			DBConnect.closeConnect(conn);
		}
		return loginfo;
	}
	
	/*
	 * 插入数据实现注册
	 */
	public int login(LogInfo loginfo){
		int result=0;
		String sql="insert into logInfo values(?,?,?,?,?,?)";
		conn=DBConnect.getConnect();
		try {
			pstmt=conn.prepareStatement(sql);
			//解释SQL语句中的？设置参数
			pstmt.setString(1, loginfo.getUserName());
			pstmt.setString(2, loginfo.getUserPwd());
			pstmt.setString(3, loginfo.getSex());
			pstmt.setString(4, loginfo.getHobby());
			pstmt.setString(5, loginfo.getAddress());
			pstmt.setString(6, loginfo.getEvaluate());
			//更新数据库，返回当前执行SQL语句对数据库影响的行数
			result=pstmt.executeUpdate();
		} catch (SQLException e) {
			System.out.println("插入失败！\n消息："+e.getMessage());
		}finally{
			DBConnect.closeConnect(conn);
		}
		return result;
	}
}