Aidar/SHiNE-server
SHA256
2
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

08 01 25

Browse Source 
ещё помелочи
This commit is contained in:
AidarKC 2026-01-09 00:03:40 +03:00
parent 4c87207129
commit aba86fc687
1 changed files with 53 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

66
shine-server-db/src/main/java/shine/db/DatabaseInitializer.java
View File

@ -26,6 +26,46 @@ import java.sql.Statement;
*/ */
public class DatabaseInitializer { public class DatabaseInitializer {
/* ===================== TEXT (msg_type=1) ===================== */
/** Новое сообщение (начало ветки). */
public static final short TEXT_NEW = 1;
/** Ответ на сообщение (reply). */
public static final short TEXT_REPLY = 2;
/** Репост (repost). */
public static final short TEXT_REPOST = 3;
/** Редактирование (edit). ВАЖНО: серверное значение = 10. */
public static final short TEXT_EDIT = 10;
/* ===================== REACTION (msg_type=2) ===================== */
/** Лайк (LIKE). */
public static final short REACTION_LIKE = 1;
/* ===================== CONNECTION (msg_type=3) ===================== */
/** Добавить в друзья. */
public static final short CONNECTION_FRIEND = 10;
/** Удалить из друзей. */
public static final short CONNECTION_UNFRIEND = 11;
/** Подписаться (follow). */
public static final short CONNECTION_FOLLOW = 20;
/** Отписаться (unfollow). */
public static final short CONNECTION_UNFOLLOW = 21;
/** Заблокировать. */
public static final short CONNECTION_BLOCK = 30;
/** Разблокировать. */
public static final short CONNECTION_UNBLOCK = 31;
public static void createNewDB(String[] args) { public static void createNewDB(String[] args) {
AppConfig config = AppConfig.getInstance(); AppConfig config = AppConfig.getInstance();
String dbPath = config.getParam("db.path"); String dbPath = config.getParam("db.path");
@ -311,18 +351,18 @@ public class DatabaseInitializer {
END; END;
""".formatted( """.formatted(
(int) MsgSubType.CONNECTION_FRIEND, (int) CONNECTION_FRIEND,
(int) MsgSubType.CONNECTION_FOLLOW, (int) CONNECTION_FOLLOW,
(int) MsgSubType.CONNECTION_BLOCK, (int) CONNECTION_BLOCK,
(int) MsgSubType.CONNECTION_UNFRIEND, (int) MsgSubType.CONNECTION_FRIEND, (int) CONNECTION_UNFRIEND, (int) CONNECTION_FRIEND,
(int) MsgSubType.CONNECTION_UNFOLLOW, (int) MsgSubType.CONNECTION_FOLLOW, (int) CONNECTION_UNFOLLOW, (int) CONNECTION_FOLLOW,
(int) MsgSubType.CONNECTION_UNBLOCK, (int) MsgSubType.CONNECTION_BLOCK, (int) CONNECTION_UNBLOCK, (int) CONNECTION_BLOCK,
(int) MsgSubType.CONNECTION_UNFRIEND, (int) CONNECTION_UNFRIEND,
(int) MsgSubType.CONNECTION_UNFOLLOW, (int) CONNECTION_UNFOLLOW,
(int) MsgSubType.CONNECTION_UNBLOCK (int) CONNECTION_UNBLOCK
)); ));
// 9) message_stats (to_block_hash -> BLOB) + edits_count // 9) message_stats (to_block_hash -> BLOB) + edits_count
st.executeUpdate(""" st.executeUpdate("""
@ -384,7 +424,7 @@ public class DatabaseInitializer {
DO UPDATE SET DO UPDATE SET
likes_count = message_stats.likes_count + 1; likes_count = message_stats.likes_count + 1;
END; END;
""".formatted((int) MsgSubType.REACTION_LIKE)); """.formatted((int) REACTION_LIKE));
// 11) Trigger: REPLY // 11) Trigger: REPLY
st.executeUpdate(""" st.executeUpdate("""
@ -415,7 +455,7 @@ public class DatabaseInitializer {
DO UPDATE SET DO UPDATE SET
replies_count = message_stats.replies_count + 1; replies_count = message_stats.replies_count + 1;
END; END;
""".formatted((int) MsgSubType.TEXT_REPLY)); """.formatted((int) TEXT_REPLY));
// 12) Trigger: EDIT — пометить исходный блок + увеличить edits_count // 12) Trigger: EDIT — пометить исходный блок + увеличить edits_count
st.executeUpdate(""" st.executeUpdate("""
@ -456,7 +496,7 @@ public class DatabaseInitializer {
DO UPDATE SET DO UPDATE SET
edits_count = message_stats.edits_count + 1; edits_count = message_stats.edits_count + 1;
END; END;
""".formatted((int) MsgSubType.TEXT_EDIT)); """.formatted((int) TEXT_EDIT));
} }
} }
} }