SRSoftware/Umbrella
1
0
Fork 0
Code Issues Pull Requests Actions Projects Releases Wiki Activity

prepared database for bookmark service

Browse Source
This commit is contained in:
Stephan Richter
2025-08-02 20:28:56 +02:00
parent fd107546d8
commit 125a8c2266
11 changed files with 118 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
bookmark/src/main/java/de/srsoftware/umbrella/bookmarks/BookmarkApi.java Normal file
View File

@@ -0,0 +1,21 @@
/* © SRSoftware 2025 */
package de.srsoftware.umbrella.bookmarks;
import static de.srsoftware.umbrella.bookmarks.Constants.CONFIG_DATABASE;
import static de.srsoftware.umbrella.core.ConnectionProvider.connect;
import static de.srsoftware.umbrella.core.exceptions.UmbrellaException.missingFieldException;
import de.srsoftware.configuration.Configuration;
import de.srsoftware.umbrella.core.BaseHandler;
import de.srsoftware.umbrella.core.api.UserService;
public class BookmarkApi extends BaseHandler {
private final BookmarkDb db;
private final UserService users;
public BookmarkApi(Configuration config, UserService userService) {
var dbFile = config.get(CONFIG_DATABASE).orElseThrow(() -> missingFieldException(CONFIG_DATABASE));
db = new SqliteDb(connect(dbFile));
users = userService;
}
}

5
bookmark/src/main/java/de/srsoftware/umbrella/bookmarks/BookmarkDb.java Normal file
View File

@@ -0,0 +1,5 @@
/* © SRSoftware 2025 */
package de.srsoftware.umbrella.bookmarks;
public interface BookmarkDb {
}

9
bookmark/src/main/java/de/srsoftware/umbrella/bookmarks/Constants.java Normal file
View File

@@ -0,0 +1,9 @@
/* © SRSoftware 2025 */
package de.srsoftware.umbrella.bookmarks;
public class Constants {
public static final String CONFIG_DATABASE = "umbrella.modules.bookmark.database";
public static final String TABLE_URLS = "urls";
public static final String TABLE_URL_COMMENTS = "url_comments";
}

59
bookmark/src/main/java/de/srsoftware/umbrella/bookmarks/SqliteDb.java Normal file
View File

@@ -0,0 +1,59 @@
/* © SRSoftware 2025 */
package de.srsoftware.umbrella.bookmarks;
import static de.srsoftware.umbrella.bookmarks.Constants.TABLE_URLS;
import static de.srsoftware.umbrella.bookmarks.Constants.TABLE_URL_COMMENTS;
import static de.srsoftware.umbrella.core.Constants.*;
import static de.srsoftware.umbrella.core.Constants.ERROR_FAILED_CREATE_TABLE;
import static java.lang.System.Logger.Level.ERROR;
import de.srsoftware.umbrella.core.BaseDb;
import java.sql.Connection;
import java.sql.SQLException;
public class SqliteDb extends BaseDb implements BookmarkDb {
public SqliteDb(Connection conn) {
super(conn);
}
@Override
protected int createTables() {
var version = createSettingsTable();
switch (version){
case 0:
createUrlsTable();
createUrlCommentsTable();
}
return setCurrentVersion(1);
}
private void createUrlCommentsTable() {
var sql = """
CREATE TABLE IF NOT EXISTS "url_comments" (
`url_hash` VARCHAR ( 255 ) NOT NULL,
`user_id` LONG NOT NULL,
`comment` TEXT NOT NULL,
PRIMARY KEY (`url_hash`,`user_id`)
)""";
try {
var stmt = db.prepareStatement(sql);
stmt.execute();
stmt.close();
} catch (SQLException e) {
LOG.log(ERROR, ERROR_FAILED_CREATE_TABLE, TABLE_URL_COMMENTS, e);
throw new RuntimeException(e);
}
}
private void createUrlsTable() {
var sql = "CREATE TABLE IF NOT EXISTS urls (hash VARCHAR(255) PRIMARY KEY, url TEXT NOT NULL)";
try {
var stmt = db.prepareStatement(sql);
stmt.execute();
stmt.close();
} catch (SQLException e) {
LOG.log(ERROR, ERROR_FAILED_CREATE_TABLE, TABLE_URLS, e);
throw new RuntimeException(e);
}
}
}