From bd6b518aae61608ddc2d82b43ccc283dc95b9c54 Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期三, 11 三月 2026 13:59:33 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/system/config/UserPasskeySchemaInitializer.java | 56 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 56 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/zy/system/config/UserPasskeySchemaInitializer.java b/src/main/java/com/zy/system/config/UserPasskeySchemaInitializer.java
new file mode 100644
index 0000000..077e5b6
--- /dev/null
+++ b/src/main/java/com/zy/system/config/UserPasskeySchemaInitializer.java
@@ -0,0 +1,56 @@
+package com.zy.system.config;
+
+import org.springframework.stereotype.Component;
+
+import jakarta.annotation.PostConstruct;
+import javax.sql.DataSource;
+import java.sql.Connection;
+import java.sql.DatabaseMetaData;
+import java.sql.ResultSet;
+import java.sql.Statement;
+
+@Component
+public class UserPasskeySchemaInitializer {
+
+ private final DataSource dataSource;
+
+ public UserPasskeySchemaInitializer(DataSource dataSource) {
+ this.dataSource = dataSource;
+ }
+
+ @PostConstruct
+ public void init() {
+ ensureColumn("sys_user", "passkey_name", "VARCHAR(100)");
+ ensureColumn("sys_user", "passkey_credential_id", "VARCHAR(255)");
+ ensureColumn("sys_user", "passkey_public_key", "TEXT");
+ ensureColumn("sys_user", "passkey_algorithm", "INT");
+ ensureColumn("sys_user", "passkey_sign_count", "BIGINT DEFAULT 0");
+ ensureColumn("sys_user", "passkey_transports", "VARCHAR(255)");
+ ensureColumn("sys_user", "passkey_bound_time", "DATETIME NULL");
+ ensureColumn("sys_user", "passkey_last_used_time", "DATETIME NULL");
+ }
+
+ private void ensureColumn(String tableName, String columnName, String columnDefinition) {
+ try (Connection connection = dataSource.getConnection()) {
+ if (hasColumn(connection, tableName, columnName)) {
+ return;
+ }
+ try (Statement statement = connection.createStatement()) {
+ statement.executeUpdate("ALTER TABLE " + tableName + " ADD COLUMN " + columnName + " " + columnDefinition);
+ }
+ } catch (Exception ignored) {
+ }
+ }
+
+ private boolean hasColumn(Connection connection, String tableName, String columnName) throws Exception {
+ DatabaseMetaData metaData = connection.getMetaData();
+ try (ResultSet resultSet = metaData.getColumns(connection.getCatalog(), null, tableName, null)) {
+ while (resultSet.next()) {
+ if (columnName.equalsIgnoreCase(resultSet.getString("COLUMN_NAME"))) {
+ return true;
+ }
+ }
+ }
+ return false;
+ }
+}
--
Gitblit v1.9.1