10 12 25

Добавил таблицы для геолокации

shine-server-db/src/main/java/shine/db/dao/IpGeoCacheDAO.java

@@ -0,0 +1,99 @@
+package shine.db.dao;
+
+import shine.db.SqliteDbController;
+import shine.db.entities.IpGeoCacheEntry;
+
+import java.sql.*;
+
+/**
+ * DAO для таблицы ip_geo_cache.
+ *
+ * Таблица:
+ *  - ip            TEXT PRIMARY KEY
+ *  - geo           TEXT
+ *  - updated_at_ms INTEGER NOT NULL
+ */
+public final class IpGeoCacheDAO {
+
+    private static volatile IpGeoCacheDAO instance;
+    private final SqliteDbController db = SqliteDbController.getInstance();
+
+    private IpGeoCacheDAO() {
+    }
+
+    public static IpGeoCacheDAO getInstance() {
+        if (instance == null) {
+            synchronized (IpGeoCacheDAO.class) {
+                if (instance == null) {
+                    instance = new IpGeoCacheDAO();
+                }
+            }
+        }
+        return instance;
+    }
+
+    /**
+     * UPSERT по ip.
+     * Если записи нет — вставляем.
+     * Если есть — обновляем geo и updated_at_ms.
+     */
+    public void upsert(IpGeoCacheEntry entry) throws SQLException {
+        String sql = """
+            INSERT INTO ip_geo_cache (ip, geo, updated_at_ms)
+            VALUES (?, ?, ?)
+            ON CONFLICT(ip)
+            DO UPDATE SET
+                geo           = excluded.geo,
+                updated_at_ms = excluded.updated_at_ms
+            """;
+
+        try (PreparedStatement ps = db.getConnection().prepareStatement(sql)) {
+            ps.setString(1, entry.getIp());
+            ps.setString(2, entry.getGeo());
+            ps.setLong(3, entry.getUpdatedAtMs());
+            ps.executeUpdate();
+        }
+    }
+
+    /**
+     * Получить запись по IP.
+     * Если нет — возвращает null.
+     */
+    public IpGeoCacheEntry getByIp(String ip) throws SQLException {
+        String sql = """
+            SELECT ip, geo, updated_at_ms
+            FROM ip_geo_cache
+            WHERE ip = ?
+            """;
+
+        try (PreparedStatement ps = db.getConnection().prepareStatement(sql)) {
+            ps.setString(1, ip);
+            try (ResultSet rs = ps.executeQuery()) {
+                if (!rs.next()) {
+                    return null;
+                }
+                return mapRow(rs);
+            }
+        }
+    }
+
+    /**
+     * Опционально — очистка старых записей.
+     * Можно вызывать по расписанию, если нужно.
+     */
+    public int deleteOlderThan(long thresholdMs) throws SQLException {
+        String sql = "DELETE FROM ip_geo_cache WHERE updated_at_ms < ?";
+
+        try (PreparedStatement ps = db.getConnection().prepareStatement(sql)) {
+            ps.setLong(1, thresholdMs);
+            return ps.executeUpdate();
+        }
+    }
+
+    private IpGeoCacheEntry mapRow(ResultSet rs) throws SQLException {
+        String ip = rs.getString("ip");
+        String geo = rs.getString("geo");
+        long updatedAtMs = rs.getLong("updated_at_ms");
+        return new IpGeoCacheEntry(ip, geo, updatedAtMs);
+    }
+}