package cn.zut.dao.impl;
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 cn.zut.dao.LoginDao;
import cn.zut.model.Employees;
import cn.zut.model.User;
import cn.zut.mysql.DBUtil;
public class LoginDaoImpl implements LoginDao {
// 登录
@Override
public User findUserByLogin(String username, String password) throws SQLException {
User user = null;
Connection connection = null;
//操作数据库的对象
PreparedStatement preparedStatement = null;
//储存结果集
ResultSet resultSet = null;
//连接数据库
connection = DBUtil.connectionMysql();
String sql = "select * from login_info WHERE username= ? and password = ?;";
try {
preparedStatement = connection.prepareStatement(sql);
preparedStatement.setString(1, username);
preparedStatement.setString(2, password);
//执行SQL语句返回结果,若查到,返回结果,查不到,返回null
resultSet = preparedStatement.executeQuery();
} catch (SQLException e) {
// TODO 自动生成的 catch 块
e.printStackTrace();
}
while (resultSet.next()) {
user = new User();
user.setUsername(resultSet.getString("username"));
user.setPassword(resultSet.getString("password"));
user.setName(resultSet.getString("name"));
user.setEmail(resultSet.getString("email"));
user.setAddress(resultSet.getString("address"));
user.setPhone_number(resultSet.getString("phone_number"));
}
DBUtil.closeAll(connection, preparedStatement, resultSet);
return user;
}
@Override
public List<Employees> getEmployeesInfo(String name) throws SQLException {
Employees employees = null;
List<Employees> list = new ArrayList<Employees>();
String sql = "select * from employees where name ='" + name + "';";
ResultSet resultSet = DBUtil.getResult(sql);
while (resultSet.next()) {
employees = new Employees();
employees.setId(resultSet.getString(1));
employees.setDepartment(resultSet.getString(2));
employees.setName(resultSet.getString(3));
employees.setSex(resultSet.getString(4));
employees.setSalary(resultSet.getString(5));
employees.setEmail(resultSet.getString(7));
employees.setPhoneNumber(resultSet.getString(6));
list.add(employees);
}
return list;
}
@Override
public List<Employees> getAllEmployeesInfo() throws SQLException {
List<Employees> list = new ArrayList<Employees>();
Employees employees = null;
ResultSet resultSet = null;
String sql = "select * from employees;";
resultSet = DBUtil.getResult(sql);
while (resultSet.next()) {
employees = new Employees();
employees.setId(resultSet.getString(1));
employees.setDepartment(resultSet.getString(2));
employees.setName(resultSet.getString(3));
employees.setSex(resultSet.getString(4));
employees.setSalary(resultSet.getString(5));
employees.setEmail(resultSet.getString(7));
employees.setPhoneNumber(resultSet.getString(6));
list.add(employees);
}
return list;
}
@Override
public void deleteEmployeesInfo(String id) {
String sql = "delete from employees where id='" + id + "';";
Connection connection = DBUtil.connectionMysql();
Statement statement = null;
try {
statement = connection.createStatement();
} catch (SQLException e) {
e.printStackTrace();
}
try {
statement.execute(sql);
} catch (SQLException e) {
e.printStackTrace();
}
try {
connection.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
// 更新
public Employees update(String id) throws SQLException {
Employees employees = null;
System.out.println("update : id" + id);
String sql = "select * from employees where id = '" + id + "';";
ResultSet resultSet = DBUtil.getResult(sql);
while (resultSet.next()) {
employees = new Employees();
employees.setId(resultSet.getString(1));
employees.setDepartment(resultSet.getString(2));
employees.setName(resultSet.getString(3));
employees.setSex(resultSet.getString(4));
employees.setSalary(resultSet.getString(5));
employees.setEmail(resultSet.getString(7));
employees.setPhoneNumber(resultSet.getString(6));
}
System.out.println("update employees:" + employees);
return employees;
}
@Override
public boolean doUpdate(Employees e) throws SQLException {
Connection connection = DBUtil.connectionMysql();
PreparedStatement preparedStatement = null;
// preparedStatement 的sql 语句中不能用单引号
String sql = " update employees set department = ? , name=? , sex=? , salary=? , phoneNumber=?,email=? where id = ?;";
boolean flag = false;
preparedStatement = connection.prepareStatement(sql);
preparedStatement.setString(1, e.getDepartment());
preparedStatement.setString(2, e.getName());
preparedStatement.setString(3, e.getSex());
preparedStatement.setString(4, e.getSalary());
preparedStatement.setString(5, e.getPhoneNumber());
preparedStatement.setString(6, e.getEmail());
preparedStatement.setString(7, e.getId());
preparedStatement.executeUpdate();
DBUtil.closeAll(connection, preparedStatement, null);
return flag;
}
// 插入
public void insertEmployeesInfo(Employees e) throws SQLException {
Connection connection = DBUtil.connectionMysql();
PreparedStatement preparedStatement = null;
String sql = "insert into employees values( ?, ?, ?, ?, ?, ?,?);";
try {
preparedStatement = connection.prepareStatement(sql);
preparedStatement.setString(1, e.getId());
preparedStatement.setString(2, e.getDepartment());
preparedStatement.setString(3, e.getName());
preparedStatement.setString(4, e.getSex());
preparedStatement.setString(5, e.getSalary());
preparedStatement.setString(6, e.getPhoneNumber());
preparedStatement.setString(7, e.getEmail());
preparedStatement.execute();
} catch (Exception e1) {
e1.printStackTrace();
}
DBUtil.closeAll(connection, preparedStatement, null);
}
@Override
public void addAdmin(User user) {
Connection connection = DBUtil.connectionMysql();
PreparedStatement preparedStatement = null;
String sql = "insert into login_info values( ?, ?, ?, ?, ?, ?);";
try {
preparedStatement = connection.prepareStatement(sql);
preparedStatement.setString(1, user.getUsername());
preparedStatement.setString(2, user.getPassword());
preparedStatement.setString(3, user.getName());
preparedStatement.setString(4, user.getEmail());
preparedStatement.setString(5, user.getPhone_number());
preparedStatement.setString(6, user.getAddress());
preparedStatement.execute();
} catch (Exception e1) {
e1.printStackTrace();
}
DBUtil.closeAll(connection, preparedStatement, null);
}
@Override
public List<User> getAllAddminInfo() throws SQLException {
List<User> list = new ArrayList();
User user = null;
String sql = "select * from login_info";
ResultSet resultSet = DBUtil.getResult(sql);
while (resultSet.next()) {
user = new User();
user.setUsername(resultSet.getString(1));
user.setPassword(resultSet.getString(2));
user.setName(resultSet.getString(3));
user.setEmail(resultSet.getString(4));
user.setPhone_number(resultSet.getString(5));
user.setAddress(resultSet.getString(6));
list.add(user);
}
return list;
}
@Override
public User getAdmin(String username, String password) throws SQLException {
User user = null;
String sql = "select * from login_info where username = '" + username + "' and password = '" + password + "';";
ResultSet resultSet = DBUtil.getResult(sql);
while (resultSet.next()) {
user = new User();
user.setUsername(resultSet.getString(1));
user.setPas
没有合适的资源?快使用搜索试试~ 我知道了~
资源推荐
资源详情
资源评论
收起资源包目录
员工信息管理系统.zip (91个子文件)
MyProject
src
cn
zut
dao
impl
LoginDaoImpl.java 9KB
LoginDao.java 1KB
model
Employees.java 1KB
User.java 1KB
serviceimpl
LoginServiceImpl.java 3KB
service
LoginService.java 1KB
mysql
DBUtil.java 3KB
TestUtil.java 67B
servlet
UpdateAddminInfo.java 2KB
DeleteAddmin.java 1KB
AddEmployeesInfo.java 3KB
UpdateEmployeesInfo.java 3KB
GetUpdateAllEmployeesInfo.java 1KB
DeleteEmployeesInfo.java 878B
LoginServlet.java 1KB
GetEmployeesInfo.java 1KB
GetUpdateAllAddmin.java 1KB
Test.java 1KB
GetAllAddminInfo.java 1KB
Test3.java 3KB
GetAllEmployeesInfo.java 1KB
AddAddmin.java 2KB
.classpath 1KB
build
.settings
org.eclipse.wst.jsdt.ui.superType.container 49B
org.eclipse.wst.common.project.facet.core.xml 343B
org.eclipse.core.resources.prefs 111B
org.eclipse.wst.jsdt.ui.superType.name 6B
org.eclipse.wst.common.component 479B
.jsdtscope 567B
org.eclipse.jdt.core.prefs 358B
WebContent
classes
cn
zut
dao
LoginDao.class 1KB
impl
LoginDaoImpl.class 8KB
model
Employees.class 2KB
User.class 2KB
serviceimpl
LoginServiceImpl.class 4KB
service
LoginService.class 978B
mysql
DBUtil.class 3KB
TestUtil.class 275B
servlet
UpdateAddminInfo.class 3KB
GetAllAddminInfo.class 2KB
AddAddmin.class 3KB
GetUpdateAllAddmin.class 2KB
GetEmployeesInfo.class 2KB
DeleteEmployeesInfo.class 2KB
GetUpdateAllEmployeesInfo.class 2KB
DeleteAddmin.class 2KB
GetAllEmployeesInfo.class 2KB
LoginServlet.class 2KB
AddEmployeesInfo.class 3KB
UpdateEmployeesInfo.class 3KB
Test.class 2KB
Test3.class 1KB
META-INF
MANIFEST.MF 39B
updateAddmin.jsp 7KB
searchErr.html 235B
allSearch.jsp 6KB
addAdminErr2.html 227B
addAdminErr.html 261B
js
loginErro.html 221B
Test.jsp 1KB
css
bootstrap.min.css 141KB
login.jsp 2KB
insert.jsp 6KB
index.html 8KB
insertErr2.html 225B
update.jsp 6KB
searchResult.jsp 5KB
insertErr.html 300B
update2.jsp 6KB
insert2.jsp 6KB
img
星空.jpg 1.25MB
民主.PNG 21KB
登录.png 2KB
注册.png 2KB
查询.png 2KB
问题反馈.png 3KB
编辑.png 2KB
退出登录.png 4KB
3.jpg 74KB
管理.png 2KB
富强.PNG 21KB
search.jsp 5KB
addAdmin.jsp 6KB
allSearchAddmin.jsp 6KB
WEB-INF
lib
jstl.jar 20KB
standard.jar 384KB
mysql-connector-java-5.1.11-bin.jar 715KB
web.xml 9KB
jstl.jar 20KB
standard.jar 384KB
.project 909B
共 91 条
- 1
资源评论
- Next码云2019-02-28没什么用,老古董
Souane
- 粉丝: 12
- 资源: 21
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功