/**
*
*/
package user.dao;
import java.sql.*;
import user.entity.User;
/**
* 用户数据访问层
*
* @author Administrator
*
*/
public class UserDAO {
/**
* 根据用户名和密码查找用户,找到了返回user对象,否则返回nall
*
* @param user
* @return 查找结果
*/
public User finduserByusernameandpassword(User user) {
String driverName = "com.microsoft.sqlserver.jdbc.SQLServerDriver"; // 加载JDBC驱动
String dbURL = "jdbc:sqlserver://localhost:1433; DatabaseName=Salary"; // 连接服务器和数据库
String userName = "qiu"; // 默认用户名
String userPwd = "12345"; // 密码
Connection dbConn;
try {
Class.forName(driverName);
dbConn = DriverManager.getConnection(dbURL, userName, userPwd);
Statement stmt = dbConn.createStatement();// 建立Statement对象
String username = user.getUsername();
String password = user.getPassword();
String sqlString = formSQLString(username, password);
ResultSet rs = stmt.executeQuery(sqlString);
if (rs != null && rs.next()) {
// 读到数据,生成实体类
user.setUsername(rs.getString("员工号"));
user.setPassword(rs.getString("密码"));
user.setName(rs.getString("姓名"));
user.setDepartment(rs.getInt("岗位"));
user.setSkill(rs.getInt("技能"));
user.setPercentage(rs.getFloat("比例"));
user.setLenservice(rs.getInt("年限"));
user.setLenpay(rs.getInt("金额"));
user.setNonfarm(rs.getFloat("非农补贴"));
user.setBamonpay(rs.getFloat("基本月工资"));
user.setBaadd(rs.getFloat("基本月增资"));
user.setYearadd(rs.getFloat("年增资"));
user.setMonpay(rs.getFloat("月工资"));
user.setMonths(rs.getInt("发放月数"));
user.setTrpay(rs.getFloat("实领金额"));
user.setShpay(rs.getFloat("应发金额"));
user.setInsurepay(rs.getFloat("合计"));
user.setMedical(rs.getFloat("大额医疗"));
user.setUnemploy(rs.getFloat("失业"));
user.setEndowment(rs.getFloat("养老"));
user.setRemake(rs.getString("备注"));
return user;
}
} catch (Exception e) {
e.printStackTrace();
}
return null;
}
public User finduserByusername(String username) {
String driverName = "com.microsoft.sqlserver.jdbc.SQLServerDriver"; // 加载JDBC驱动
String dbURL = "jdbc:sqlserver://localhost:1433; DatabaseName=Salary"; // 连接服务器和数据库
String userName = "qiu"; // 默认用户名
String userPwd = "12345"; // 密码
Connection dbConn;
try {
Class.forName(driverName);
dbConn = DriverManager.getConnection(dbURL, userName, userPwd);
Statement stmt = dbConn.createStatement();// 建立Statement对象
User user = new User();
String sqlString = findSQLString(username);
ResultSet rs = stmt.executeQuery(sqlString);
if (rs != null && rs.next()) {
// 读到数据,生成实体类
user.setUsername(rs.getString("员工号"));
user.setPassword(rs.getString("密码"));
user.setName(rs.getString("姓名"));
user.setDepartment(rs.getInt("岗位"));
user.setSkill(rs.getInt("技能"));
user.setPercentage(rs.getFloat("比例"));
user.setLenservice(rs.getInt("年限"));
user.setLenpay(rs.getInt("金额"));
user.setNonfarm(rs.getFloat("非农补贴"));
user.setBamonpay(rs.getFloat("基本月工资"));
user.setBaadd(rs.getFloat("基本月增资"));
user.setYearadd(rs.getFloat("年增资"));
user.setMonpay(rs.getFloat("月工资"));
user.setMonths(rs.getInt("发放月数"));
user.setTrpay(rs.getFloat("实领金额"));
user.setShpay(rs.getFloat("应发金额"));
user.setInsurepay(rs.getFloat("合计"));
user.setMedical(rs.getFloat("大额医疗"));
user.setUnemploy(rs.getFloat("失业"));
user.setEndowment(rs.getFloat("养老"));
user.setRemake(rs.getString("备注"));
return user;
}
} catch (Exception e) {
e.printStackTrace();
}
return null;
}
public User insertuser(User user) {
String driverName = "com.microsoft.sqlserver.jdbc.SQLServerDriver"; // 加载JDBC驱动
String dbURL = "jdbc:sqlserver://localhost:1433; DatabaseName=Salary"; // 连接服务器和数据库
String userName = "qiu"; // 默认用户名
String userPwd = "12345"; // 密码
Connection dbConn;
try {
Class.forName(driverName);
dbConn = DriverManager.getConnection(dbURL, userName, userPwd);
Statement stmt = dbConn.createStatement();// 建立Statement对象
String sqlString = insertSQLString(user);
stmt.executeQuery(sqlString);
return user;
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
public int deleteuser(String username) {
String driverName = "com.microsoft.sqlserver.jdbc.SQLServerDriver"; // 加载JDBC驱动
String dbURL = "jdbc:sqlserver://localhost:1433; DatabaseName=Salary"; // 连接服务器和数据库
String userName = "qiu"; // 默认用户名
String userPwd = "12345"; // 密码
Connection dbConn;
try {
Class.forName(driverName);
dbConn = DriverManager.getConnection(dbURL, userName, userPwd);
Statement stmt = dbConn.createStatement();// 建立Statement对象
String sqlString = deleteSQLString(username);
stmt.executeQuery(sqlString);
return 1;
} catch (Exception e) {
e.printStackTrace();
}
return 0;
}
public void editpassword(User user, String pass) {
String driverName = "com.microsoft.sqlserver.jdbc.SQLServerDriver"; // 加载JDBC驱动
String dbURL = "jdbc:sqlserver://localhost:1433; DatabaseName=Salary"; // 连接服务器和数据库
String userName = "qiu"; // 默认用户名
String userPwd = "12345"; // 密码
Connection dbConn;
try {
Class.forName(driverName);
dbConn = DriverManager.getConnection(dbURL, userName, userPwd);
Statement stmt = dbConn.createStatement();// 建立Statement对象
String sqlString = editSQLString(user, pass);
stmt.executeQuery(sqlString);
} catch (Exception e) {
e.printStackTrace();
}
}
private String formSQLString(String username, String password) {
// TODO Auto-generated method stub
/*
* String sqlString = "select * from 员工 " + "where 员工号 =" + "\'" +
* username +"\'"+ "and 密码 =" + "\'" + password + "\'";
*/
String sqlString = "select * from 员工 " + "where 员工号 ='" + username
+ "' and 密码 ='" + password + "'";
return sqlString;
}
private String findSQLString(String username) {
// TODO Auto-generated method stub
String sqlString = "select * from 员工 " + "where 员工号 ='" + username
+ "'";
return sqlString;
}
private String editSQLString(User user, String password) {
// TODO Auto-generated method stub
String sqlString = "update 员工 set 密码 ='" + password + "' where 员工号 = '"
+ user.getUsername() + "'";
return sqlString;
}
private String deleteSQLString(String username) {
// TODO Auto-generated method stub
String sqlString = "delete from 员工 " + "where 员工号 ='" + username
+ "'";
return sqlString;
}
private String insertSQLString(User user) {
// TODO Auto-generated method stub
String sqlString = "insert into 保险金(养老,失业,大额医疗,合计) values('"
+ user.getEndowment()
+ "','"
+ user.getUnemploy()
+ "','"
+ user.getMedical()
+ "','"
+ user.getInsurepay()
+ "') "
+ "insert into 工龄补贴(年限,金额) values('"
+ user.getLenservice()
+ "','"
+ user.getLenpay()
+ "') "
+ "insert into 员工(员工号,密码,姓名,岗位,技能,比例,年限,金额,非农补贴,基本月工资,基本月增资,年增资,月工资,发放月数,实领金额,应发金额,合计,大额医疗,失业,养老,备注) values('"
+ user.getUsername() + "','" + user.getPassword() + "','"
+ user.getName() + "'," + user.getDepartment() + ","
+ user.getSkill() + ",'" + user.getPercentage() + "',"
+ user.getLenservice() + "," + user.getLenpay() + ",'"
+ user.getNonfarm() + "','" + user.getBamonpay() + "','"
+ user.getBaadd() + "','" + user.getYearadd() + "','"
+ user.getMonpay() + "','" + user.getMonths() + "','"
+ user.g
- 1
- 2
前往页