50 lines
1.7 KiB
Java
50 lines
1.7 KiB
Java
package example.dao;
|
|
|
|
import example.model.User;
|
|
import example.utils.DBUtils;
|
|
import org.apache.commons.dbutils.QueryRunner;
|
|
import org.apache.commons.dbutils.handlers.BeanHandler;
|
|
import org.apache.commons.dbutils.handlers.BeanListHandler;
|
|
|
|
import java.util.List;
|
|
|
|
public class UserDao {
|
|
private final QueryRunner queryRunner = new QueryRunner(DBUtils.getDataSource());
|
|
|
|
public int addUser(String username, String phone,String password) throws Exception {
|
|
String sql = "INSERT INTO user (username,phone, password,role) VALUES (?, ?,?,?)";
|
|
return queryRunner.update(sql, username, phone,password,"user");
|
|
}
|
|
|
|
public User getUserById(int id) throws Exception {
|
|
String sql = "SELECT * FROM user WHERE id = ?";
|
|
return queryRunner.query(sql, new BeanHandler<>(User.class), id);
|
|
}
|
|
|
|
public User getUserByUsername(String username) throws Exception {
|
|
String sql = "SELECT * FROM user WHERE username = ?";
|
|
return queryRunner.query(sql, new BeanHandler<>(User.class), username);
|
|
}
|
|
|
|
public List<User> getAllUser() throws Exception {
|
|
String sql = "SELECT * FROM user";
|
|
return queryRunner.query(sql, new BeanListHandler<>(User.class));
|
|
}
|
|
|
|
public int updateUser(int id, String name, String email) throws Exception {
|
|
String sql = "UPDATE user SET username = ?, password = ? WHERE id = ?";
|
|
return queryRunner.update(sql, name, email, id);
|
|
}
|
|
|
|
public int deleteUser(int id) throws Exception {
|
|
String sql = "DELETE FROM user WHERE id = ?";
|
|
return queryRunner.update(sql, id);
|
|
}
|
|
|
|
public static void main(String[] args) throws Exception {
|
|
UserDao userDao = new UserDao();
|
|
System.out.println(userDao.getAllUser());
|
|
}
|
|
|
|
}
|