Advertisement
Guest User

Untitled

a guest
Aug 31st, 2016
108
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Java 2.58 KB | None | 0 0
  1. package by.redlaw.db;
  2.  
  3. // этот класс прсто для тестирования в процессе разработки
  4.  
  5. import by.redlaw.formsData.User;
  6. import org.springframework.beans.factory.annotation.Autowired;
  7. import org.springframework.stereotype.Component;
  8.  
  9. import javax.annotation.PostConstruct;
  10. import javax.annotation.PreDestroy;
  11. import java.sql.ResultSet;
  12. import java.sql.SQLException;
  13. import java.sql.Statement;
  14. import java.util.ArrayList;
  15. import java.util.List;
  16.  
  17. @Component
  18. public class DBOperations {
  19.  
  20.     private final MySqlConnection mySqlConnection;
  21.  
  22.     private Statement statement;
  23.  
  24.     @Autowired
  25.     public DBOperations(MySqlConnection mySqlConnection) {
  26.         this.mySqlConnection = mySqlConnection;
  27.     }
  28.  
  29.     @PostConstruct
  30.     private void initStatement() {
  31.  
  32.         statement = mySqlConnection.getStatement();
  33.     }
  34.  
  35.     //получаем всех существующий юзеров в БД
  36.     public List<User> selectAll() {
  37.  
  38.         List<User> allTheUsers = new ArrayList<User>();
  39.  
  40.         String selectAllQuery = "SELECT * FROM users;";
  41.  
  42.         try {
  43.             ResultSet rs = statement.executeQuery(selectAllQuery);
  44.  
  45.             while (rs.next()) {
  46.                 String login = rs.getString("login");
  47.                 String password = rs.getString("password");
  48.                 String firstName = rs.getString("firstName");
  49.                 String lastName = rs.getString("lastName");
  50.                 String email = rs.getString("email");
  51.  
  52.                 User user = new User();
  53.                 user.setLogin(login);
  54.                 user.setPassword(password);
  55.                 user.setFirstName(firstName);
  56.                 user.setLastName(lastName);
  57.                 user.setEmail(email);
  58.  
  59.                 allTheUsers.add(user);
  60.             }
  61.             rs.close();
  62.         } catch (SQLException e) {
  63.             e.printStackTrace();
  64.         }
  65.         return allTheUsers;
  66.     }
  67.  
  68.     // добавляем юзера, если его нет в БД
  69.     public void addUser(String firstName, String lastName, String email, String login, String password) {
  70.  
  71.         String addQuery = String.format("INSERT INTO users (firstName, lastName, email, login, password) " +
  72.                 "VALUES ('%s', '%s', '%s', '%s', '%s')", firstName, lastName, email, login, password);
  73.         try {
  74.  
  75.             statement.execute(addQuery);
  76.  
  77.         } catch (SQLException e) {
  78.             e.printStackTrace();
  79.         }
  80.     }
  81.  
  82.  
  83.     @PreDestroy
  84.     public void closeAll() {
  85.         mySqlConnection.CloseAllActivity();
  86.     }
  87. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement