SHOW:
|
|
- or go back to the newest paste.
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 |