package cn.jbit.dao.impl;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;
import cn.jbit.dao.UserDao;
import cn.jbit.entity.Page;
import cn.jbit.entity.User;
/**
* 用户的方法体
*
* @author kyaccp
*
*/
public class UserDaoImpl extends BaseDao implements UserDao {
// 根据Id查询所有的所有的
public User findUserById(String id) {
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
String sql = "select * from dbo.EASYBUY_USER where EU_USER_ID = ?";
User user = null;
try {
conn = this.getConnection();
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, id);
rs = pstmt.executeQuery();
if (rs.next()) {
user = new User();
// user.setUserId(rs.getString("eu_user_id"));
user.setUserName(rs.getString("eu_user_name"));
user.setPassword(rs.getString("eu_password"));
user.setMale(rs.getString("eu_sex").equals("T"));
user.setBirthday(rs.getDate("eu_birthday"));
user.setIdentityCode(rs.getString("eu_identity_code"));
user.setEmail(rs.getString("eu_email"));
user.setMobile(rs.getString("eu_mobile"));
user.setAddress(rs.getString("eu_address"));
user.setStatus(rs.getInt("eu_status"));
user.setLogin(rs.getBoolean("eu_login"));
}
} catch (Exception e) {
e.printStackTrace();
} finally {
closeAll(rs, pstmt, conn);
}
return user;
}
// 增加一个新用户
public int addUser(User user) {
int count = 0;
try {
String sql = " insert [dbo].[EASYBUY_USER]( EU_USER_NAME, EU_PASSWORD, EU_EMAIL, EU_MOBILE) values(?,?,?,?)";
Object[] params = { user.getUserName(), user.getPassword(),
user.getEmail(), user.getMobile() };
count = runNonQuerySql(sql, params);
} catch (Exception e) {
e.printStackTrace();
}
return count;
}
// 更新一个用户的信息
public int updateUser(User user) {
int count=-1;
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
String sql = "update dbo.EASYBUY_USER set EU_PASSWORD=? where EU_USER_ID=?";
try {
conn = this.getConnection();
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, user.getPassword());
pstmt.setInt(2, user.getUserId());
count=pstmt.executeUpdate();
} catch (Exception e) {
e.printStackTrace();
} finally {
closeAll(rs, pstmt, conn);
}
return 0;
}
// 删除一个用户的信息
public int deleteUser(String userId) {
// TODO Auto-generated method stub
return 0;
}
// 查询用户的记录数
public int getUserRowCount() {
// TODO Auto-generated method stub
return 0;
}
// 新增用户信息
public int addAddress(User user, String address) {
// TODO Auto-generated method stub
return 0;
}
// 设置用户登录状态
public void setLogin(User user, boolean isLogin) {
// TODO Auto-generated method stub
}
// 得到所有的用户集合
public List<User> getUserList() {
List<User> userList = new ArrayList<User>();
String sql = "select * from dbo.EASYBUY_USER";
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
try {
conn = getConnection();
pstmt = conn.prepareStatement(sql);
rs = pstmt.executeQuery();
while (rs.next()) {
User user = new User();
user.setUserId(rs.getInt("EU_USER_ID"));
user.setUserName(rs.getString("EU_USER_NAME"));
user.setEmail(rs.getString("EU_EMAIL"));
userList.add(user);
}
} catch (Exception e) {
e.printStackTrace();
} finally {
closeAll(rs, pstmt, conn);
}
return userList;
}
@Override
public User getNewsUserByNameAndPwd(String name, String pwd) {
// 用户对象
User newsUser = null;
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
try {
conn = getConnection();
// 拼接sql
String sql = "select EU_USER_ID, EU_USER_NAME from dbo.EASYBUY_USER where EU_USER_NAME=? and EU_PASSWORD=? and EU_STATUS=1";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, name);
pstmt.setString(2, pwd);
rs = pstmt.executeQuery();
if (rs.next()) {
newsUser = new User(rs.getInt("EU_USER_ID"),
rs.getString("EU_USER_NAME"));
}
} catch (Exception e) {
e.printStackTrace();
} finally {
closeAll(rs, pstmt, conn);
}
return newsUser;
}
@Override
public int updateStateOK(User u) {
int count = 0;
String sql = " update dbo.EASYBUY_USER set EU_STATUS=2 where EU_USER_ID=?";
Object[] params = { u.getUserId() };
try {
count = this.runNonQuerySql(sql, params);
} catch (Exception e) {
// TODO: handle exception
}
return count;
}
@Override
public int updateStateNot(User u) {
int count = 0;
String sql = " update dbo.EASYBUY_USER set EU_STATUS=1 where EU_USER_ID=?";
Object[] params = { u.getUserId() };
try {
count = this.runNonQuerySql(sql, params);
} catch (Exception e) {
// TODO: handle exception
}
return count;
}
/*
* 冻结(non-Javadoc)
*
* @see cn.jbit.dao.UserDao#dongUser(int)
*/
@Override
public int dongUser(int userId) {
int count = 0;
try {
String sql = "update dbo.EASYBUY_USER set EU_STATUS =2 where EU_USER_ID=?";
Object[] params = { userId };
count = this.runNonQuerySql(sql, params);
} catch (Exception e) {
e.printStackTrace();
}
return count;
}
/*
* 解冻(non-Javadoc)
*
* @see cn.jbit.dao.UserDao#jeiDongUser(int)
*/
@Override
public int jeiDongUser(int userId) {
int count = 0;
try {
String sql = "update dbo.EASYBUY_USER set EU_STATUS =1 where EU_USER_ID=?";
Object[] params = { userId };
count = this.runNonQuerySql(sql, params);
} catch (Exception e) {
e.printStackTrace();
}
return count;
}
/*
* 分页查询用户(non-Javadoc)
*
* @see cn.jbit.dao.UserDao#getUser(cn.jbit.entity.Page)
*/
@Override
public List<User> getUser(Page page) {
List<User> userList = new ArrayList<User>();
String sql = "select top "
+ Page.SIZE
+ " EU_USER_ID, EU_USER_NAME,EU_EMAIL, EU_MOBILE, EU_ADDRESS, EU_STATUS,EU_LOGIN from dbo.EASYBUY_USER where EU_USER_ID not in( "
+ "select top " + (page.getCurrent() - 1) * Page.SIZE
+ " EU_USER_ID from dbo.EASYBUY_USER)";
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
try {
conn = getConnection();
pstmt = conn.prepareStatement(sql);
rs = pstmt.executeQuery();
// select EU_USER_ID, EU_USER_NAME,
// EU_EMAIL, EU_MOBILE,
// EU_ADDRESS, EU_STATUS from dbo.EASYBUY_USER
while (rs.next()) {
User user = new User(rs.getInt("EU_USER_ID"),
rs.getString("EU_USER_NAME"), rs.getString("EU_EMAIL"),
rs.getString("EU_ADDRESS"), rs.getString("EU_MOBILE"),
rs.getInt("EU_STATUS"), rs.getBoolean("EU_LOGIN"));
userList.add(user);
}
} catch (Exception e) {
e.printStackTrace();
} finally {
closeAll(rs, pstmt, conn);
}
return userList;
}
/*
* 查询用户总数(non-Javadoc)
*
* @see cn.jbit.dao.UserDao#getMessageTotal()
*/
@Override
public int getMessageTotal() {
int count = 0;
String sql = "select COUNT(*) from dbo.EASYBUY_USER";
ResultSet rs = null;
Connection conn = null;
PreparedStatement pstmt = null;
try {
conn = this.getConnection();
pstmt = conn.prepareStatement(sql);
rs = pstmt.executeQuery();
if (rs.next()) {
count = rs.getInt(1);
}
} catch (Exception e) {
e.printStackTrace();
} finally {
this.closeAll(rs, pstmt, conn);
}
return count;
}
@Override
public List<User> userByName(String name) {
List<User> userList = new ArrayList<User>();
String sql = "select EU_USER_ID, EU_USER_NAME,"
+ " EU_EMAIL, EU_MOBILE,"
+ " EU_ADDRESS, EU_STATUS,EU_LOGIN from dbo.EASYBUY_USER wher
评论0
最新资源