Автоматическое обновление данных из БД на странице

@Vladder · Регистрация: 23.03.2016

Студворк — интернет-сервис помощи студентам

Добрый вечер. Реализую небольшой maven-проект с выводом данных из БД. Проект основан на MVC архитектуре и суть его такова: на главной странице (index.jsp) находится таблица с информацией о фильмах, кроме того здесь же присутствует возможность редактирования каждого из них, удаления и добавления нового. В качестве модели используются класс film и класс filmsDatabase, который получает данные из БД (использую PostgreSQL):

Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
public class Film {
    public int id;
    public String title;
    public String genre;
    public String director;
    public int year;
    public int rating;
 
    public Film(String title, String genre, String director, int year, int rating) {
        this.title = title;
        this.genre = genre;
        this.director = director;
        this.year = year;
        this.rating = rating;
    }
 
    public void setId(int id) {
        this.id = id;
    }
 
    public int getId() {
        return id;
    }
 
    public String getTitle() {
        return title;
    }
 
    public String getGenre() {
        return genre;
    }
 
    public String getDirector() {
        return director;
    }
 
    public int getYear() {
        return year;
    }
 
    public int getRating() {
        return rating;
    }
}
 
import java.sql.*;
import java.sql.SQLException;
import java.util.*;
 
public class FilmsDatabase {
    private static final String DB_URL = "jdbc:postgresql://localhost/test";
    private static final String USER = "postgres";
    private static final String PASS = "*";
 
    private static Connection getDBConnection() {
        Connection dbConnection = null;
        try {
            Class.forName("org.postresql.Driver");
        } catch (ClassNotFoundException e) {
            System.out.println(e.getMessage());
        }
 
        //System.out.println("PostgreSQL JDBC Driver successfully connected");
 
        try {
            dbConnection = DriverManager.getConnection(DB_URL, USER, PASS);
        } catch (SQLException e) {
            System.out.println(e.getMessage());
        }
 
        if (dbConnection != null) {
            //System.out.println("You successfully connected to database now");
        }
 
        return dbConnection;
    }
 
    public static ArrayList<Film> select() throws SQLException{
        ArrayList<Film> films = new ArrayList<>();
        String query = "SELECT * FROM films ORDER BY id";
 
        try (Connection dbConnection = getDBConnection(); Statement stmt = dbConnection.createStatement()) {
            ResultSet rs = stmt.executeQuery(query);
            while(rs.next()) {
                int id = rs.getInt("id");
                String title = rs.getString("title");
                String genre = rs.getString("genre");
                String director = rs.getString("director");
                int year = rs.getInt("year");
                int rating = rs.getInt("rating");
                Film film = new Film(title, genre, director, year, rating);
                films.add(film);
                film.setId(id);
            }
        } catch(SQLException e) {
            System.out.println(e.getMessage());
        }
        return films;
    }
 
    public static void insert(Film film) throws SQLException {
        String query = "INSERT INTO films(title, genre, director, year, rating) VALUES(?, ?, ?, ?, ?)";
 
        try (Connection dbConnection = getDBConnection(); PreparedStatement statement = dbConnection.prepareStatement(query)) {
            statement.setString(1, film.getTitle());
            statement.setString(2, film.getGenre());
            statement.setString(3, film.getDirector());
            statement.setInt(4, film.getYear());
            statement.setInt(5, film.getRating());
            statement.executeUpdate();
        } catch (SQLException e) {
            System.out.println(e.getMessage());
        }
    }
 
    public static Film selectOne(int id) {
        String query = "SELECT * FROM films WHERE id = ?";
        Film film = null;
 
        try (Connection dbConnection = getDBConnection(); PreparedStatement stmt = dbConnection.prepareStatement(query)) {
            stmt.setInt(1, id);
            ResultSet rs = stmt.executeQuery();
            if (rs.next()){
                String title = rs.getString("title");
                String genre = rs.getString("genre");
                String director = rs.getString("director");
                int year = rs.getInt("year");
                int rating = rs.getInt("rating");
                film = new Film(title, genre, director, year, rating);
            }
        } catch(SQLException e) {
            System.out.println(e.getMessage());
        }
        return film;
    }
 
    public static void update(Film film) {
        String query = "UPDATE films SET title = ?, genre = ?, director = ?, year = ?, rating = ? WHERE id = ?";
 
        try (Connection dbConnection = getDBConnection(); PreparedStatement stmt = dbConnection.prepareStatement(query)) {
            stmt.setString(1, film.getTitle());
            stmt.setString(2, film.getGenre());
            stmt.setString(3, film.getDirector());
            stmt.setInt(4, film.getYear());
            stmt.setInt(5, film.getRating());
            stmt.setInt(6, film.getId());
            stmt.executeUpdate();
        } catch(SQLException e) {
            System.out.println(e.getMessage());
        }
    }
 
    public static void main(String[] args) {
        System.out.println(selectOne(1));
    }
 
    public static void delete(int id) {
        String query = "DELETE FROM films WHERE id = ?";
 
        try(Connection dbConnection = getDBConnection(); PreparedStatement stmt = dbConnection.prepareStatement(query)) {
            stmt.setInt(1, id);
            stmt.executeUpdate();
        } catch(SQLException e) {
            System.out.println(e.getMessage());
        }
    }
}

Для реализации контроллеров я использовал java servlet. Как пример, страница добавления нового фильма и соответствующий ей CreateServlet:

HTML5
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
<%@ page contentType="text/html;charset=UTF-8" language="java" %>
<html>
<head>
    <title>Добавление нового фильма</title>
</head>
<body>
<h2>Добавление нового фильма</h2>
<form method="post">
    <label>Название фильма</label><br>
    <input name="title"/><br><br>
    <label>Жанр фильма</label><br>
    <input name="genre"/><br><br>
    <label>Режиссер фильма</label><br>
    <input name="director"/><br><br>
    <label>Год выхода фильма</label><br>
    <input name="year" type="number"/><br><br>
    <label>Рейтинг фильма</label><br>
    <input name="rating" type="number"/><br><br>
    <input type="submit" value="Сохранить"/>
</form>
 
</body>
</html>

Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
 
public class CreateServlet extends HttpServlet {
    @Override
    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        getServletContext().getRequestDispatcher("/create.jsp").forward(request, response);
    }
 
    @Override
    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        try {
            request.setCharacterEncoding("utf-8");
            String title = request.getParameter("title");
            String genre = request.getParameter("genre");
            String director = request.getParameter("director");
            int year = Integer.parseInt(request.getParameter("year"));
            int rating = Integer.parseInt(request.getParameter("rating"));
            Film film = new Film(title, genre, director, year, rating);
            FilmsDatabase.insert(film);
            response.sendRedirect(request.getContextPath() + "/index");
        } catch(Exception ex) {
            getServletContext().getRequestDispatcher("/create.jsp").forward(request, response);
        }
    }
}

Теперь же возникла необходимость реализовать автоматическое обновление главной страницы при любом обновлении информации в БД. Т.е. например если открыть две одинаковые вкладки в браузере и в одной изменить информацию - вторая должна автоматически обновиться (ну или хотя бы вывести предупреждение, что мол "информация обновилась, не хотите ли вы обновить страницу?"). И тут возник вопрос как это реализовать. Пытался гуглить в интернете, находил множество примеров с онлайн-чатами, но так и не смог понять алгоритм, по которому мне это нужно сделать. Пока что пришел лишь к выводу, что скорее всего нужно использовать websocket. Попробовал реализовать ServerEndpoint класс, но дальше дело не продвинулось...

Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
import javax.websocket.*;
import javax.websocket.server.ServerEndpoint;
import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
 
@ServerEndpoint("/ws")
public class PushUpdates {
    private static final Set<Session> SESSIONS = ConcurrentHashMap.newKeySet();
 
    @OnOpen
    public void onOpen(Session session) {
        SESSIONS.add(session);
    }
 
    @OnClose
    public void onClose(Session session) {
        SESSIONS.remove(session);
    }
 
    public static void sendAll(Film film) {
        synchronized (SESSIONS) {
            for (Session session : SESSIONS) {
                if (session.isOpen()) {
                    session.getAsyncRemote().sendObject(film);
                }
            }
        }
    }
}

Не могли ли вы мне подсказать как это можно реализовать?

@JavaDoc · 14.12.2019, 15:01

Ajax. Там можно задать чтобы метод срабатывал каждые три секунды

@Vladder · 14.12.2019, 15:30 **[ТС]**

Хотелось бы реализовать обновление именно при изменении содержимого, а не по таймеру.

@sdasdaw · 14.12.2019, 15:34

Сообщение от Vladder

открыть две одинаковые вкладки в браузере и в одной изменить информацию - вторая должна автоматически обновиться

сделать соединение с сервером по сокету, и при обновлении информации, отправлять сигнал всем кто на линии.

Новые блоги и статьи Все статьи Все блоги /
Почему дизайн решает? Neotwalker 09.01.2026 В современном мире, где конкуренция за внимание потребителя достигла пика, дизайн становится мощным инструментом для успеха бренда. Это не просто красивый внешний вид продукта или сайта — это. . .	Модель микоризы: классовый агентный подход 3 anaschu 06.01.2026 aa0a7f55b50dd51c5ec569d2d10c54f6/ O1rJuneU_ls https:/ / vkvideo. ru/ video-115721503_456239114	Owen Logic: О недопустимости использования связки «аналоговый ПИД» + RegKZR ФедосеевПавел 06.01.2026 Owen Logic: О недопустимости использования связки «аналоговый ПИД» + RegKZR ВВЕДЕНИЕ Введу сокращения: аналоговый ПИД — ПИД регулятор с управляющим выходом в виде числа в диапазоне от 0% до. . .	Модель микоризы: классовый агентный подход 2 anaschu 06.01.2026 репозиторий https:/ / github. com/ shumilovas/ fungi ветка по-частям. коммит Create переделка под биомассу. txt вход sc, но sm считается внутри мицелия. кстати, обьем тоже должен там считаться. . . .
Расчёт токов в цепи постоянного тока igorrr37 05.01.2026 / * Дана цепь постоянного тока с сопротивлениями и напряжениями. Надо найти токи в ветвях. Программа составляет систему уравнений по 1 и 2 законам Кирхгофа и решает её. Последовательность действий:. . .	Новый CodeBlocs. Версия 25.03 palva 04.01.2026 Оказывается, недавно вышла новая версия CodeBlocks за номером 25. 03. Когда-то давно я возился с только что вышедшей тогда версией 20. 03. С тех пор я давно снёс всё с компьютера и забыл. Теперь. . .	Модель микоризы: классовый агентный подход anaschu 02.01.2026 Раньше это было два гриба и бактерия. Теперь три гриба, растение. И на уровне агентов добавится между грибами или бактериями взаимодействий. До того я пробовал подход через многомерные массивы,. . .	Советы по крайней бережливости. Внимание, это ОЧЕНЬ длинный пост. Programma_Boinc 28.12.2025 Советы по крайней бережливости. Внимание, это ОЧЕНЬ длинный пост. Налог на собак: https:/ / ********/ gallery/ V06K53e Финансовый отчет в Excel: https:/ / ********/ gallery/ bKBkQFf Пост отсюда. . .

@JavaDoc 25 / 21 / 6 Регистрация: 10.12.2018 Сообщений: 115
	14.12.2019, 15:01
	Ajax. Там можно задать чтобы метод срабатывал каждые три секунды 0

@Vladder 0 / 0 / 0 Регистрация: 23.03.2016 Сообщений: 16
	14.12.2019, 15:30 [ТС]
	Хотелось бы реализовать обновление именно при изменении содержимого, а не по таймеру. 0