|
|
|
@ -3,6 +3,7 @@ package de.srsoftware.cal.db;
@@ -3,6 +3,7 @@ package de.srsoftware.cal.db;
|
|
|
|
|
|
|
|
|
|
import static de.srsoftware.tools.Optionals.allEmpty; |
|
|
|
|
import static de.srsoftware.tools.Optionals.nullable; |
|
|
|
|
import static de.srsoftware.tools.Strings.camelCase; |
|
|
|
|
|
|
|
|
|
import de.srsoftware.cal.BaseAppointment; |
|
|
|
|
import de.srsoftware.cal.api.Appointment; |
|
|
|
@ -13,16 +14,17 @@ import java.sql.DriverManager;
@@ -13,16 +14,17 @@ import java.sql.DriverManager;
|
|
|
|
|
import java.sql.SQLException; |
|
|
|
|
import java.sql.Timestamp; |
|
|
|
|
import java.util.ArrayList; |
|
|
|
|
import java.util.HashMap; |
|
|
|
|
import java.util.List; |
|
|
|
|
import java.util.Set; |
|
|
|
|
|
|
|
|
|
public class MariaDB implements Database { |
|
|
|
|
private static final String SELECT_APPOINTMENTS = "SELECT * FROM appointments"; |
|
|
|
|
private static final String SELECT_APPOINTMENTS_WITH_HASHES = SELECT_APPOINTMENTS + " a LEFT JOIN appointment_hashes h ON a.aid = h.aid"; |
|
|
|
|
private static final String SELECT_VERSION = "SELECT value FROM config WHERE keyname = 'dbversion'"; |
|
|
|
|
private static final String CREATE_HASHES = "CREATE TABLE appointment_hashes (aid INT NOT NULL, hash VARCHAR(255) NOT NULL, UNIQUE(aid), UNIQUE(hash))"; |
|
|
|
|
private static final String INSERT_HASH = "INSERT INTO appointment_hashes (aid, hash) values (?, ?) ON DUPLICATE KEY UPDATE hash=hash;"; |
|
|
|
|
private static final String UPDATE_DB_VERSION = "UPDATE config SET value = ? WHERE keyname = 'dbversion'"; |
|
|
|
|
private static final String SELECT_APPOINTMENTS = "SELECT * FROM appointments"; |
|
|
|
|
private static final String SELECT_VERSION = "SELECT value FROM config WHERE keyname = 'dbversion'"; |
|
|
|
|
private static final String ADD_SLUG = "ALTER TABLE appointments ADD slug VARCHAR(255) UNIQUE"; |
|
|
|
|
private static final String INSERT_HASH = "INSERT INTO appointment_hashes (aid, hash) values (?, ?) ON DUPLICATE KEY UPDATE hash=hash;"; |
|
|
|
|
private static final String UPDATE_DB_VERSION = "UPDATE config SET value = ? WHERE keyname = 'dbversion'"; |
|
|
|
|
private static final String INSERT_SLUG = "UPDATE IGNORE appointments SET slug = ? WHERE aid = ?"; |
|
|
|
|
private static Connection connection; |
|
|
|
|
|
|
|
|
|
private MariaDB(Connection conn) throws SQLException { |
|
|
|
@ -46,34 +48,33 @@ public class MariaDB implements Database {
@@ -46,34 +48,33 @@ public class MariaDB implements Database {
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
private void update1() throws SQLException { |
|
|
|
|
var list = new ArrayList<Appointment>(); |
|
|
|
|
var results = Query.of(SELECT_APPOINTMENTS).execute(connection); |
|
|
|
|
while (results.next()) { |
|
|
|
|
var id = results.getInt("aid"); |
|
|
|
|
var title = results.getString("title"); |
|
|
|
|
var description = results.getString("description"); |
|
|
|
|
if (allEmpty(title, description)) continue; |
|
|
|
|
var stamp = results.getTimestamp("start"); |
|
|
|
|
var start = nullable(stamp).map(Timestamp::toLocalDateTime).orElse(null); |
|
|
|
|
var end = nullable(results.getTimestamp("end")).map(Timestamp::toLocalDateTime).orElse(null); |
|
|
|
|
var location = results.getString("location"); |
|
|
|
|
Calc //
|
|
|
|
|
.hash(start + "@" + location) |
|
|
|
|
.map(hash -> new BaseAppointment(id, title, description, start, end, location, hash)) |
|
|
|
|
.ifPresent(list::add); |
|
|
|
|
} |
|
|
|
|
results.close(); |
|
|
|
|
var list = new ArrayList<Appointment>(); |
|
|
|
|
connection.setAutoCommit(false); |
|
|
|
|
|
|
|
|
|
Query.of(CREATE_HASHES).statement(connection).execute(); |
|
|
|
|
for (var appointment : list) { |
|
|
|
|
var stmt = Query.of(INSERT_HASH).statement(connection); |
|
|
|
|
stmt.setLong(1, appointment.id()); |
|
|
|
|
stmt.setString(2, appointment.hash()); |
|
|
|
|
Query.of(ADD_SLUG).statement(connection).execute(); |
|
|
|
|
var slugMap = new HashMap<Long, String>(); |
|
|
|
|
var rs = Query.of(SELECT_APPOINTMENTS).execute(connection); |
|
|
|
|
while (rs.next()) { |
|
|
|
|
var id = rs.getLong("aid"); |
|
|
|
|
var location = nullable(rs.getString("location")); |
|
|
|
|
if (location.isEmpty()) continue; |
|
|
|
|
var title = rs.getString("title"); |
|
|
|
|
var descr = rs.getString("description"); |
|
|
|
|
if (allEmpty(title, descr)) continue; |
|
|
|
|
var start = nullable(rs.getTimestamp("start")); |
|
|
|
|
if (start.isEmpty()) continue; |
|
|
|
|
var slug = "%s@%s".formatted(start.get().toLocalDateTime(), camelCase(location.get())); |
|
|
|
|
if (slug.length() > 250) slug = slug.substring(0, 250); |
|
|
|
|
slugMap.put(id, slug); |
|
|
|
|
} |
|
|
|
|
rs.close(); |
|
|
|
|
var stmt = Query.of(INSERT_SLUG).statement(connection); |
|
|
|
|
for (var entry : slugMap.entrySet()) { |
|
|
|
|
stmt.setString(1, entry.getValue()); |
|
|
|
|
stmt.setLong(2, entry.getKey()); |
|
|
|
|
stmt.execute(); |
|
|
|
|
} |
|
|
|
|
connection.commit(); |
|
|
|
|
var stmt = Query.of(UPDATE_DB_VERSION).statement(connection); |
|
|
|
|
stmt = Query.of(UPDATE_DB_VERSION).statement(connection); |
|
|
|
|
stmt.setLong(1, 2); |
|
|
|
|
stmt.execute(); |
|
|
|
|
connection.setAutoCommit(true); |
|
|
|
@ -97,7 +98,7 @@ public class MariaDB implements Database {
@@ -97,7 +98,7 @@ public class MariaDB implements Database {
|
|
|
|
|
@Override |
|
|
|
|
public List<Appointment> list(Integer count, Integer offset) throws SQLException { |
|
|
|
|
var list = new ArrayList<Appointment>(); |
|
|
|
|
var results = Query.of(SELECT_APPOINTMENTS_WITH_HASHES).execute(connection); |
|
|
|
|
var results = Query.of(SELECT_APPOINTMENTS).execute(connection); |
|
|
|
|
while (results.next()) { |
|
|
|
|
var id = results.getInt("aid"); |
|
|
|
|
var title = results.getString("title"); |
|
|
|
@ -106,9 +107,9 @@ public class MariaDB implements Database {
@@ -106,9 +107,9 @@ public class MariaDB implements Database {
|
|
|
|
|
var start = results.getTimestamp("start").toLocalDateTime(); |
|
|
|
|
var end = nullable(results.getTimestamp("end")).map(Timestamp::toLocalDateTime).orElse(null); |
|
|
|
|
var location = results.getString("location"); |
|
|
|
|
var hash = results.getString("hash"); |
|
|
|
|
if (hash == null) hash = Calc.hash(start + "@" + location).orElse(null); |
|
|
|
|
list.add(new BaseAppointment(id, title, description, start, end, location, hash)); |
|
|
|
|
var slug = results.getString("slug"); |
|
|
|
|
if (slug == null) slug = Calc.hash(start + "@" + location).orElse(null); |
|
|
|
|
list.add(new BaseAppointment(id, title, description, start, end, location, slug)); |
|
|
|
|
} |
|
|
|
|
results.close(); |
|
|
|
|
return list; |
|
|
|
|