DB.java
上传用户:huaxinghn
上传日期:2022-04-20
资源大小:673k
文件大小:3k
源码类别:

Ajax

开发平台:

JavaScript

  1. package lilin.dao;
  2. import java.sql.Connection;
  3. import java.sql.ResultSet;
  4. import java.sql.SQLException;
  5. import java.sql.Statement;
  6. import java.sql.DriverManager;
  7. import java.util.ArrayList;
  8. import java.util.List;
  9. import java.sql.PreparedStatement;
  10. import lilin.bean.User;
  11. public class DB {
  12. private Connection conn = null;
  13. private Statement stem = null;
  14. private ResultSet rs = null;
  15. private PreparedStatement ps = null;
  16. private boolean is_true = false;
  17. private String url = "jdbc:mysql://localhost:3306/lilin";
  18. private String name = "root";
  19. private String pwd = "root";
  20. public DB() throws ClassNotFoundException, SQLException{
  21. Class.forName("com.mysql.jdbc.Driver");
  22. conn = DriverManager.getConnection(url,name,pwd);
  23. }
  24. public List select_All() throws SQLException{
  25. List user_list = new ArrayList();
  26. stem = conn.createStatement();
  27. rs = stem.executeQuery("select * from users");
  28. while(rs.next()){
  29. User user_ref = new User();
  30. user_ref.setId(rs.getInt("id"));
  31. user_ref.setUsername(rs.getString("username"));
  32. user_ref.setPassword(rs.getString("password"));
  33. user_list.add(user_ref);
  34. }
  35. return user_list;
  36. }
  37. public boolean insert_User(String name,String password) throws SQLException{
  38. ps = conn.prepareStatement("insert into users(username,password) values(?,?)");
  39. ps.setString(1, name);
  40. ps.setString(2,password);
  41. int result = ps.executeUpdate();
  42. is_true = result > 0?true:false;
  43. return is_true;
  44. }
  45. public boolean delete_User(int id) throws SQLException{
  46. ps = conn.prepareStatement("delete from users where id=?");
  47. ps.setInt(1, id);
  48. int result = ps.executeUpdate();
  49. is_true = result > 0?true:false;
  50. return is_true;
  51. }
  52. public int select_UserByNamePwd(String name,String password) throws SQLException{
  53. int id = 0;
  54. ps = conn.prepareStatement("select * from users where username=? and password=?");
  55. ps.setString(1, name);
  56. ps.setString(2, password);
  57. rs = ps.executeQuery();
  58. while(rs.next()){
  59. id = rs.getInt("id");
  60. }
  61. return id;
  62. }
  63. public boolean update_User(int id,String type,String value) throws SQLException{
  64. //System.out.println("update users set "+type+"=? where id=?");
  65. ps = conn.prepareStatement("update users set "+type+"=? where id=?");
  66. ps.setString(1, value);
  67. ps.setInt(2, id);
  68. int result = ps.executeUpdate();
  69. is_true = result > 0?true:false;
  70. return is_true;
  71. }
  72. public void closeAll(){
  73. if(conn != null){
  74. try {
  75. conn.close();
  76. } catch (SQLException e) {
  77. // TODO Auto-generated catch block
  78. e.printStackTrace();
  79. }
  80. }
  81. }
  82. }