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

@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

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

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

Новые блоги и статьи Все статьи Все блоги /
Модель микоризы: классовый агентный подход anaschu 02.01.2026 Раньше это было два гриба и бактерия. Теперь три гриба, растение. И на уровне агентов добавится между грибами или бактериями взаимодействий. До того я пробовал подход через многомерные массивы,. . .	Учёным и волонтёрам проекта «Einstein@home» удалось обнаружить четыре гамма-лучевых пульсара в джете Млечного Пути Programma_Boinc 01.01.2026 Учёным и волонтёрам проекта «Einstein@home» удалось обнаружить четыре гамма-лучевых пульсара в джете Млечного Пути Сочетание глобально распределённой вычислительной мощности и инновационных. . .	Советы по крайней бережливости. Внимание, это ОЧЕНЬ длинный пост. Programma_Boinc 28.12.2025 Советы по крайней бережливости. Внимание, это ОЧЕНЬ длинный пост. Налог на собак: https:/ / ********/ gallery/ V06K53e Финансовый отчет в Excel: https:/ / ********/ gallery/ bKBkQFf Пост отсюда. . .	Кто-нибудь знает, где можно бесплатно получить настольный компьютер или ноутбук? США. Programma_Boinc 26.12.2025 Нашел на реддите интересную статью под названием Anyone know where to get a free Desktop or Laptop? Ниже её машинный перевод. После долгих разбирательств я наконец-то вернула себе. . .	Thinkpad X220 Tablet — это лучший бюджетный ноутбук для учёбы, точка. Programma_Boinc 23.12.2025 Рецензия / Мнение/ Перевод Нашел на реддите интересную статью под названием The Thinkpad X220 Tablet is the best budget school laptop period . Ниже её машинный перевод. Thinkpad X220 Tablet —. . .
PhpStorm 2025.3: WSL Terminal всегда стартует в ~ and_y87 14.12.2025 PhpStorm 2025. 3: WSL Terminal всегда стартует в ~ (home), игнорируя директорию проекта Симптом: После обновления до PhpStorm 2025. 3 встроенный терминал WSL открывается в домашней директории. . .	Как объединить две одинаковые БД Access с разными данными VikBal 11.12.2025 Помогите пожалуйста !! Как объединить 2 одинаковые БД Access с разными данными.	Новый ноутбук volvo 07.12.2025 Всем привет. По скидке в "черную пятницу" взял себе новый ноутбук Lenovo ThinkBook 16 G7 на Амазоне: Ryzen 5 7533HS 64 Gb DDR5 1Tb NVMe 16" Full HD Display Win11 Pro	Музыка, написанная Искусственным Интеллектом volvo 04.12.2025 Всем привет. Некоторое время назад меня заинтересовало, что уже умеет ИИ в плане написания музыки для песен, и, собственно, исполнения этих самых песен. Стихов у нас много, уже вышли 4 книги, еще 3. . .	От async/await к виртуальным потокам в Python IndentationError 23.11.2025 Армин Ронахер поставил под сомнение async/ await. Создатель Flask заявляет: цветные функции - провал, виртуальные потоки - решение. Не threading-динозавры, а новое поколение лёгких потоков. Откат?. . .

@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