Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package by.redlaw.db;
- // этот класс прсто для тестирования в процессе разработки
- import by.redlaw.formsData.User;
- import org.springframework.beans.factory.annotation.Autowired;
- import org.springframework.stereotype.Component;
- import javax.annotation.PostConstruct;
- import javax.annotation.PreDestroy;
- import java.sql.ResultSet;
- import java.sql.SQLException;
- import java.sql.Statement;
- import java.util.ArrayList;
- import java.util.List;
- @Component
- public class DBOperations {
- private final MySqlConnection mySqlConnection;
- private Statement statement;
- @Autowired
- public DBOperations(MySqlConnection mySqlConnection) {
- this.mySqlConnection = mySqlConnection;
- }
- @PostConstruct
- private void initStatement() {
- statement = mySqlConnection.getStatement();
- }
- //получаем всех существующий юзеров в БД
- public List<User> selectAll() {
- List<User> allTheUsers = new ArrayList<User>();
- String selectAllQuery = "SELECT * FROM users;";
- try {
- ResultSet rs = statement.executeQuery(selectAllQuery);
- while (rs.next()) {
- String login = rs.getString("login");
- String password = rs.getString("password");
- String firstName = rs.getString("firstName");
- String lastName = rs.getString("lastName");
- String email = rs.getString("email");
- User user = new User();
- user.setLogin(login);
- user.setPassword(password);
- user.setFirstName(firstName);
- user.setLastName(lastName);
- user.setEmail(email);
- allTheUsers.add(user);
- }
- rs.close();
- } catch (SQLException e) {
- e.printStackTrace();
- }
- return allTheUsers;
- }
- // добавляем юзера, если его нет в БД
- public void addUser(String firstName, String lastName, String email, String login, String password) {
- String addQuery = String.format("INSERT INTO users (firstName, lastName, email, login, password) " +
- "VALUES ('%s', '%s', '%s', '%s', '%s')", firstName, lastName, email, login, password);
- try {
- statement.execute(addQuery);
- } catch (SQLException e) {
- e.printStackTrace();
- }
- }
- @PreDestroy
- public void closeAll() {
- mySqlConnection.CloseAllActivity();
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement