package dao; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.ArrayList; import java.util.List; public class userDao{ private Connection con = null; private PreparedStatement ps = null; static { try { Class.forName("com.mysql.jdbc.Driver"); } catch (ClassNotFoundException e) { e.printStackTrace(); } } private void prepareConnection() { try { if (con == null || con.isClosed()) { con = DriverManager.getConnection("jdbc:mysql://localhost:3306/student", "root", "111111"); } } catch (SQLException e) { throw new RuntimeException("连接异常 :" + e.getMessage()); } } private void close() { try { if (ps != null) { ps.close(); } if (con != null) { con.close(); } } catch (SQLException e) { throw new RuntimeException("关闭连接异常:" + e.getMessage()); } } private void rollback() { try { con.rollback(); } catch (SQLException e) { throw new RuntimeException("回滚失败:" + e.getMessage()); } } public boolean yzUser(sUser suser){ boolean val = false; try { prepareConnection(); ps = con.prepareStatement("select * from s_user "); ResultSet rs = ps.executeQuery(); while (rs.next()) { if(rs.getString(2).equals(suser.getS_word()) && rs.getString(3).equals(suser.getS_pass())){ val = true; } } } catch (SQLException e) { e.printStackTrace(); } finally { close(); } return val; } public int zcUser(sUser suser){ int i =0; try { prepareConnection(); con.setAutoCommit(false); String sql = "insert into s_user (s_word,s_pass,s_name,s_bj,s_xy) values(?,?,?,?,?)"; ps = con.prepareStatement(sql); ps.setString(1, suser.getS_word()); ps.setString(2, suser.getS_pass()); ps.setString(3, suser.getS_name()); ps.setInt(4, suser.getS_bj()); ps.setString(5, suser.getS_xy()); i = ps.executeUpdate(); con.commit(); } catch (SQLException e) { rollback(); e.printStackTrace(); }finally{ close(); } return i; } public List<kUser> getAllkUser() { List<kUser> kusers = new ArrayList<kUser>(); try { prepareConnection(); ps = con.prepareStatement("select * from k_user "); ResultSet rs = ps.executeQuery(); while (rs.next()) { kUser kuser = new kUser(); kuser.setK_id(rs.getInt(1)); kuser.setK_kcm(rs.getString(2)); kuser.setK_js(rs.getString(3)); kuser.setK_jxl(rs.getInt(4)); kuser.setK_sj(rs.getString(5)); kuser.setK_xf(rs.getInt(6)); kusers.add(kuser); // 如果结果集中含有记录,就将记录封装成为一个User对象并添加到集合List中 } } catch (SQLException e) { e.printStackTrace(); } finally { close(); } return kusers; } public kUser getkUserById(Integer id){ kUser kuser = null; try { prepareConnection(); ps = con.prepareStatement("select * from k_user where k_id=?"); ps.setInt(1, id); ResultSet rs = ps.executeQuery(); if (rs.next()) { kuser = new kUser(); kuser.setK_id(rs.getInt(1)); kuser.setK_kcm(rs.getNString(2)); kuser.setK_js(rs.getString(3)); kuser.setK_jxl(rs.getInt(4)); kuser.setK_sj(rs.getString(5)); kuser.setK_xf(rs.getInt(6)); // 如果结果集中含有记录,就将记录封装成为一个User对象 } } catch (SQLException e) { e.printStackTrace(); } finally { close(); } return kuser; } public Integer getNameByid(sUser suser){ Integer a = null; try { prepareConnection(); ps = con.prepareStatement("select * from s_user where s_word=?"); ps.setString(1, suser.getS_word()); ResultSet rs = ps.executeQuery(); if (rs.next()) { a = rs.getInt(7); } } catch (SQLException e) { e.printStackTrace(); } finally { close(); } return a; } public kUser getIdByKc(Integer a){ kUser kuser = null; try { prepareConnection(); ps = con.prepareStatement("select * from k_user where k_id=?"); ps.setInt(1, a); ResultSet rs = ps.executeQuery(); if (rs.next()) { kuser = new kUser(); kuser.setK_id(rs.getInt(1)); kuser.setK_kcm(rs.getNString(2)); kuser.setK_js(rs.getString(3)); kuser.setK_jxl(rs.getInt(4)); kuser.setK_sj(rs.getString(5)); kuser.setK_xf(rs.getInt(6)); // 如果结果集中含有记录,就将记录封装成为一个User对象 } } catch (SQLException e) { e.printStackTrace(); } finally { close(); } return kuser; } public kUser getkUserByName(String name){ kUser kuser = null; try { prepareConnection(); ps = con.prepareStatement("select * from k_user where k_kcm=?"); ps.setString(1, name); ResultSet rs = ps.executeQuery(); if (rs.next()) { kuser = new kUser(); kuser.setK_id(rs.getInt(1)); kuser.setK_kcm(rs.getNString(2)); kuser.setK_js(rs.getString(3)); kuser.setK_jxl(rs.getInt(4)); kuser.setK_sj(rs.getString(5)); kuser.setK_xf(rs.getInt(6)); // 如果结果集中含有记录,就将记录封装成为一个User对象 } } catch (SQLException e) { e.printStackTrace(); } finally { close(); } return kuser; } public int bcId(sUser suser) { int i = 0; try { prepareConnection(); con.setAutoCommit(false); ps = con .prepareStatement("update s_user set s_xk=? where s_word=?"); ps.setInt(1, suser.getS_xk()); ps.setString(2, suser.getS_word()); i = ps.executeUpdate(); con.commit(); } catch (SQLException e) { rollback(); e.printStackTrace(); } finally { close(); } return i; } public boolean adminUser(User user){ boolean val = false; try { prepareConnection(); ps = con.prepareStatement("select * from admin "); ResultSet rs = ps.executeQuery(); while (rs.next()) { if(rs.getString(2).equals(user.getU_word()) && rs.getString(3).equals(user.getU_pass())){ val = true; } } } catch (SQLException e) { e.printStackTrace(); } finally { close(); } return val; } public int addkUser(kUser kuser) { int i = 0; try { prepareConnection(); con.setAutoCommit(false); ps = con.prepareStatement("insert into k_user (k_kcm,k_js,k_jxl,k_sj,k_xf) values(?,?,?,?,?)"); ps.setString(1, kuser.getK_kcm()); ps.setString(2, kuser.getK_js()); ps.setInt(3, kuser.getK_jxl()); ps.setString(4, kuser.getK_sj()); ps.setInt(5, kuser.getK_xf()); i = ps.executeUpdate(); con.commit(); } catch (SQLException e) { rollback(); e.printStackTrace(); } finally { close(); } return i; } public int deletekUser(kUser kuser) { int i = 0; try { prepareConnection(); con.setAutoCommit(false); ps = con.prepareStatement("delete from k_user where k_id=?"); ps.setInt(1, kuser.getK_id()); i = ps.executeUpdate(); con.commit(); } catch (SQLException e) { rollback(); e.printStackTrace(); } finally { close(); } return i; } public int updatekUser(kUser kuser) { int i = 0; try { prepareConnection(); con.setAutoCommit(false); ps = con.prepareStatement("update k_user set k_kcm=?,k_js=?,k_jxl=?,k_sj=?,k_xf=? where k_id=?"); ps.setString(1, kuser.getK_kcm()); ps.setString(2, kuser.getK_js()); ps.setInt(3, kuser.getK_jxl()); ps.setString(4, kuser.getK_sj()); ps.setInt(5, kuser.getK_xf()); ps.setInt(6, kuser.getK_id()); i = ps.executeUpdate(); con.commit(); } catch (SQLException e) { rollback(); e.printStackTrace(); } finally { close(); } return i; } // public List<User> getAllUsers() { // List<User> users = new ArrayList<User>(); // try { // prepareConnection(); // ps = con.prepareStatement("select * from u_user "); // ResultSet rs = ps.executeQuery(); // while (rs.next()) { // User user = new User(); // user.setId(rs.getInt(1)); // user.setU_name(rs.getString(2)); // user.setU_age(rs.getInt(3)); // user.setU_sex(rs.getString(4)); // user.setU_xk(rs.getString(5)); // user.setU_fdy(rs.getString(6)); // user.setU_js(rs.getString(7)); // // users.add(user); // // 如果结果集中含有记录,就将记录封装成为一个User对象并添加到集合List中 // } // } catch (SQLException e) { // e.printStackTrace(); // } finally { // close(); // } // return users; // } // // public User getUserById(Integer id) { // User user = null; // try { // prepareConnection(); // ps = con.prepareStatement("select * from t_user where id=?"); // ps.setInt(1, id); // ResultSet rs = ps.executeQuery(); // if (rs.next()) { // user = new User(); // user.setId(rs.getInt(1)); // user.setU_name(rs.getString(2)); // user.setU_age(rs.getInt(3)); // user.setU_sex(rs.getString(4)); // user.setU_xk(rs.getString(5)); // user.setU_fdy(rs.getString(6)); // user.setU_js(rs.getString(7)); // // 如果结果集中含有记录,就将记录封装成为一个User对象 // } // } catch (SQLException e) { // e.printStackTrace(); // } finally { // close(); // } // return user; // } }
最近下载更多
asddwh LV12
2023年12月26日
2036495585 LV9
2023年9月25日
qwqwqw12345 LV3
2023年6月20日
ppooppoo932 LV4
2023年6月7日
1WQAQW1 LV2
2023年6月7日
qiangmin1223 LV11
2023年4月24日
KrisNo10000 LV2
2023年3月1日
linkai8165 LV8
2023年1月30日
微信网友_6248713511227392 LV11
2022年12月5日
韩健威 LV2
2022年11月30日
最近浏览更多
Lilei66
前天
暂无贡献等级
logan123
3月17日
暂无贡献等级
222dsff
1月5日
暂无贡献等级
asddwh LV12
2023年12月26日
WBelong LV6
2023年12月25日
微信网友_6791526949031936
2023年12月24日
暂无贡献等级
3501855841
2023年12月23日
暂无贡献等级
17693282606 LV11
2023年12月20日
颜菜菜 LV2
2023年12月19日
yuanshun LV6
2023年12月19日