package com.tedu.dao;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;
import com.tedu.po.User;
import com.tedu.utils.DbConnFinal;
public class UserDaoImpl implements UserDao{
@Override
public boolean insertUser(User user) throws SQLException {
Connection conn = DbConnFinal.getConn();
String sql = "insert into user values(null,?,?,?,?,?,?)";
PreparedStatement ps = conn.prepareStatement(sql);
ps.setString(1,user.getUsername());
ps.setString(2, user.getPassword());
ps.setString(3,user.getNickname());
ps.setString(4,user.getGender());
ps.setInt(5,user.getAge());
ps.setString(6,user.getCity());
int index = ps.executeUpdate();
if(index > 0) {
return true;
}else {
return false;
}
}
@Override
public boolean updateUser(User user) throws SQLException {
// TODO 自动生成的方法存根
return false;
}
@Override
public User queryBylogin(String username, String password) throws SQLException {
User user = null;
Connection conn = DbConnFinal.getConn();
String sql = "select * from user where username = ? and password = ?";
PreparedStatement ps = conn.prepareStatement(sql);
ps.setString(1,username);
ps.setString(2,password);
ResultSet rs = ps.executeQuery();
if(rs.next()) {
user = new User(rs.getInt("id"),rs.getString("username"),rs.getString("password")
,rs.getString("nickname"),rs.getString("gender"),rs.getInt("age"),
rs.getString("city"));
}
DbConnFinal.close(conn, ps, rs);
return user;
}
@Override
public List<User> queryListUser() throws SQLException {
List<User> userlist = new ArrayList();
Connection conn = DbConnFinal.getConn();
String sql = "select * from user";
Statement st = conn.createStatement();
ResultSet rs = st.executeQuery(sql);
User user = null;
while(rs!=null&&rs.next()) {
user = new User(rs.getInt("id"),
rs.getString("username"),
rs.getString("password"),
rs.getString("nickname"),
rs.getString("gender"),
rs.getInt("age"),
rs.getString("city"));
userlist.add(user);
}
return userlist;
}
@Override
public boolean deletUserById(String id) throws SQLException {
Connection conn = DbConnFinal.getConn();
String sql = "delete from user where id = ?";
PreparedStatement ps = conn.prepareStatement(sql);
ps.setString(1,id);
ps.execute();
return true;
}
}