Advertisement
mc_zefirka

class User, interface UsersDAO, class UsersDAOImpl

Apr 4th, 2021
540
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
  1. package com.itstep.mvn.app.model;
  2.  
  3.  
  4. import java.sql.Timestamp;
  5.  
  6. import lombok.Data;
  7.  
  8. @Data
  9. public class User {
  10.     private int id;
  11.     private String name;       
  12.     private String lastName;   
  13.     private int age;           
  14.     private String email;      
  15.     private int officeId;  
  16.     private int accId;
  17.     private Timestamp createdTs;
  18.    
  19.     public User(int id, String name, String lastName, int age, String email, int officeId, int accId,
  20.             Timestamp createdTs) {
  21.         super();
  22.         this.id = id;
  23.         this.name = name;
  24.         this.lastName = lastName;
  25.         this.age = age;
  26.         this.email = email;
  27.         this.officeId = officeId;
  28.         this.accId = accId;
  29.         this.createdTs = createdTs;
  30.     }
  31.    
  32.    
  33. }
  34.  
  35.  
  36. package com.itstep.mvn.app.jdbc.dao;
  37.  
  38. import java.util.List;
  39.  
  40. import com.itstep.mvn.app.model.User;
  41.  
  42. public interface UsersDAO {
  43.     List<User> getAllUsers();
  44. }
  45.  
  46.  
  47.  
  48.  
  49.  
  50. package com.itstep.mvn.app.jdbc.dao;
  51.  
  52. import java.sql.Connection;
  53. import java.sql.ResultSet;
  54. import java.sql.SQLException;
  55. import java.sql.Statement;
  56. import java.sql.Timestamp;
  57. import java.util.ArrayList;
  58. import java.util.List;
  59.  
  60. import com.itstep.mvn.app.model.User;
  61. import com.itstep.mvn.app.util.DBUtils;
  62.  
  63. public class UsersDAOImpl implements UsersDAO {
  64.  
  65.     @Override
  66.     public List<User> getAllUsers() {
  67.         List<User> users = new ArrayList<User>();
  68.         Connection conn = DBUtils.getConnection();
  69.         Statement stmt = null;
  70.         ResultSet rs = null;
  71.         try {
  72.             stmt = conn.createStatement();
  73.             rs = stmt.executeQuery("SELECT * FROM test_db.USERS");
  74.             while(rs.next()) {
  75.                 int id = rs.getInt(1);
  76.                 String name = rs.getString("NAME");
  77.                 String lastName = rs.getString("LAST_NAME");
  78.                 String email = rs.getString("EMAIL");
  79.                 int age = rs.getInt("AGE");
  80.                 int officeId = rs.getInt("OFFICE_ID");
  81.                 int accId = rs.getInt("acc_id");
  82.                 Timestamp createdTs = rs.getTimestamp(8);
  83.                 users.add(
  84.                         new User(id, name, lastName, age,
  85.                                 email, officeId, accId, createdTs));
  86.             }
  87.         } catch (SQLException e) {
  88.             e.printStackTrace();
  89.         } finally {
  90.             DBUtils.release(conn, stmt, rs);
  91.         }
  92.        
  93.         return users;
  94.     }
  95.  
  96. }
  97.  
  98.  
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement