[WFLY-22003] Replace JPA initialization with JDBC CDI bean

servlet-security/README-source.adoc

@@ -18,7 +18,7 @@ The `servlet-security` quickstart demonstrates the use of Jakarta EE declarative
 
 The `servlet-security` quickstart demonstrates the use of Jakarta EE declarative security to control access to Servlets and Security in {productNameFull}.
 
-When you deploy this example, two users are automatically created for you: user `quickstartUser` with password `quickstartPwd1!` and user `guest` with password `guestPwd1!`. This data is located in the `src/main/resources/import.sql` file.
+When you deploy this example, two users are automatically created for you: user `quickstartUser` with password `quickstartPwd1!` and user `guest` with password `guestPwd1!`. This data is initialized by the `DatabaseInitializer` CDI bean on application startup.
 
 This quickstart takes the following steps to implement Servlet security:
 

servlet-security/pom.xml

@@ -92,12 +92,6 @@
             <scope>provided</scope>
         </dependency>
 
-        <dependency>
-            <groupId>jakarta.persistence</groupId>
-            <artifactId>jakarta.persistence-api</artifactId>
-            <scope>provided</scope>
-        </dependency>
-
         <!-- Import test dependencies -->
         <dependency>
             <groupId>org.junit.jupiter</groupId>

servlet-security/src/main/java/org/jboss/as/quickstarts/servlet_security/DatabaseInitializer.java

@@ -0,0 +1,126 @@
+/*
+ * Copyright The WildFly Authors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+package org.jboss.as.quickstarts.servlet_security;
+
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.SQLException;
+import java.sql.Statement;
+import java.util.logging.Level;
+import java.util.logging.Logger;
+
+import javax.sql.DataSource;
+
+import jakarta.annotation.Resource;
+import jakarta.enterprise.context.ApplicationScoped;
+import jakarta.enterprise.context.Initialized;
+import jakarta.enterprise.event.Observes;
+
+/**
+ * Initializes the database schema and data for Elytron JDBC realm authentication.
+ * This CDI bean runs at application startup to create tables and populate
+ * test user credentials.
+ *
+ * @author Mohammed Abourass mouhammedmax@hotmail.com
+ */
+@ApplicationScoped
+public class DatabaseInitializer {
+
+    private static final Logger LOGGER = Logger.getLogger(DatabaseInitializer.class.getName());
+
+    @Resource(lookup = "java:jboss/datasources/ServletSecurityDS")
+    private DataSource dataSource;
+
+    public void initializeDatabase(@Observes @Initialized(ApplicationScoped.class) Object init) {
+        LOGGER.info("Initializing database schema for servlet-security...");
+
+        try (Connection conn = dataSource.getConnection()) {
+            conn.setAutoCommit(false);
+            try {
+                createTables(conn);
+                insertTestData(conn);
+                conn.commit();
+            } catch (SQLException e) {
+                conn.rollback();
+                throw e;
+            }
+            LOGGER.info("Database initialization completed successfully.");
+        } catch (SQLException e) {
+            LOGGER.log(Level.SEVERE, "Failed to initialize database", e);
+            throw new RuntimeException("Database initialization failed", e);
+        }
+    }
+
+    private void createTables(Connection conn) throws SQLException {
+        try (Statement stmt = conn.createStatement()) {
+            stmt.executeUpdate("DROP TABLE IF EXISTS USERS_ROLES");
+            stmt.executeUpdate("DROP TABLE IF EXISTS ROLES");
+            stmt.executeUpdate("DROP TABLE IF EXISTS USERS");
+
+            stmt.executeUpdate(
+                "CREATE TABLE USERS (" +
+                "ID INT, " +
+                "USERNAME VARCHAR(20), " +
+                "PASSWORD VARCHAR(20))"
+            );
+
+            stmt.executeUpdate(
+                "CREATE TABLE ROLES (" +
+                "ID INT, " +
+                "NAME VARCHAR(20))"
+            );
+
+            stmt.executeUpdate(
+                "CREATE TABLE USERS_ROLES (" +
+                "USER_ID INT, " +
+                "ROLE_ID INT)"
+            );
+
+            LOGGER.info("Database tables created");
+        }
+    }
+
+    private void insertTestData(Connection conn) throws SQLException {
+        try (PreparedStatement insertStmt = conn.prepareStatement(
+            "INSERT INTO USERS (ID, USERNAME, PASSWORD) VALUES (?, ?, ?)")) {
+
+            insertStmt.setInt(1, 1);
+            insertStmt.setString(2, "quickstartUser");
+            insertStmt.setString(3, "quickstartPwd1!");
+            insertStmt.executeUpdate();
+
+            insertStmt.setInt(1, 2);
+            insertStmt.setString(2, "guest");
+            insertStmt.setString(3, "guestPwd1!");
+            insertStmt.executeUpdate();
+        }
+
+        try (PreparedStatement insertStmt = conn.prepareStatement(
+            "INSERT INTO ROLES (ID, NAME) VALUES (?, ?)")) {
+
+            insertStmt.setInt(1, 1);
+            insertStmt.setString(2, "quickstarts");
+            insertStmt.executeUpdate();
+
+            insertStmt.setInt(1, 2);
+            insertStmt.setString(2, "guest");
+            insertStmt.executeUpdate();
+        }
+
+        try (PreparedStatement insertStmt = conn.prepareStatement(
+            "INSERT INTO USERS_ROLES (USER_ID, ROLE_ID) VALUES (?, ?)")) {
+
+            insertStmt.setInt(1, 1);
+            insertStmt.setInt(2, 1);
+            insertStmt.executeUpdate();
+
+            insertStmt.setInt(1, 2);
+            insertStmt.setInt(2, 2);
+            insertStmt.executeUpdate();
+        }
+
+        LOGGER.info("Test data inserted successfully");
+    }
+}