Shiro连接数据库的具体实现原理与步骤是怎样的？

酷盾叔 • 2025年11月13日 05:39 • 数据库 • 阅读 0

Shiro是一个Java安全框架，用于简化安全认证、授权和会话管理等操作，在Shiro中，连接数据库是进行安全认证和授权的基础,以下是Shiro连接数据库的详细步骤：

步骤	说明
配置数据源	在Shiro的配置文件（如shiro.ini）中配置数据源信息，包括数据库类型、URL、用户名和密码等。
创建Realm	Realm是Shiro框架的核心组件，用于处理认证和授权，在Shiro中，需要创建一个自定义的Realm类，继承自AuthorizingRealm或CachingRealm。
重写doGetAuthenticationInfo方法	在自定义的Realm类中，重写doGetAuthenticationInfo方法，用于实现用户认证逻辑，该方法接收一个AuthenticationToken对象，从中获取用户名和密码，然后通过数据库查询用户信息，返回AuthenticationInfo对象。
连接数据库	在doGetAuthenticationInfo方法中，使用JDBC连接数据库，以下是连接数据库的步骤：
加载数据库驱动	使用Class.forName()方法加载数据库驱动，Class.forName(“com.mysql.jdbc.Driver”);
创建连接	使用DriverManager.getConnection()方法创建数据库连接，Connection conn = DriverManager.getConnection(“jdbc:mysql://localhost:3306/yourdatabase”, “username”, “password”);
创建Statement	使用Connection.createStatement()方法创建Statement对象，用于执行SQL语句，Statement stmt = conn.createStatement();
执行查询	使用Statement.executeQuery()方法执行查询语句，获取用户信息，ResultSet rs = stmt.executeQuery(“SELECT * FROM users WHERE username = ‘” + username + “‘”);
验证用户信息	遍历ResultSet，验证用户名和密码是否匹配，如果匹配，则创建AuthenticationInfo对象并返回；如果不匹配，则抛出AuthenticationException异常。
关闭资源	使用trycatchfinally语句确保数据库连接、Statement和ResultSet等资源被正确关闭。

以下是一个简单的示例代码,展示如何使用Shiro连接数据库进行用户认证：

public class MyRealm extends AuthorizingRealm {
    @Override
    protected AuthenticationInfo doGetAuthenticationInfo(AuthenticationToken token) throws AuthenticationException {
        String username = (String) token.getPrincipal();
        String password = new String((char[]) token.getCredentials());
        Connection conn = null;
        Statement stmt = null;
        ResultSet rs = null;
        try {
            Class.forName("com.mysql.jdbc.Driver");
            conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/yourdatabase", "username", "password");
            stmt = conn.createStatement();
            rs = stmt.executeQuery("SELECT * FROM users WHERE username = '" + username + "'");
            if (rs.next()) {
                String dbPassword = rs.getString("password");
                SimpleAuthenticationInfo info = new SimpleAuthenticationInfo(username, dbPassword, getName());
                return info;
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                if (rs != null) rs.close();
                if (stmt != null) stmt.close();
                if (conn != null) conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        throw new UnknownAccountException("用户不存在");
    }
}

FAQs：

问题：Shiro支持哪些数据库连接方式？
解答：Shiro支持多种数据库连接方式，包括JDBC、JPA、Hibernate等,你可以根据实际需求选择合适的连接方式。
问题：Shiro如何处理数据库连接池？
解答：Shiro本身不提供数据库连接池的功能，你可以使用第三方数据库连接池，如c3p0、HikariCP等,在Shiro的配置文件中配置连接池参数。