?? 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;
}
}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -