如何使用SpringMVC检查MySQL数据库中邮箱是否已注册

先看你现有的代码，存在几个需要优化的地方，我来一步步帮你修正和改进：

现有代码的问题点 #

• 类型错误：conn.prepareStatement()返回的是PreparedStatement，但你声明的是Statement类型，这会导致编译错误。
• 低效全表扫描：你查询了整个Registration表然后循环判断，当数据量大的时候性能很差，应该直接通过SQL条件查询目标邮箱。
• 资源未释放：Connection、PreparedStatement、ResultSet这些资源没有关闭，会造成数据库连接泄漏。
• 硬编码配置：数据库连接信息直接写在代码里，不符合Spring的配置化思想，也不利于维护。
• 业务逻辑与打印耦合：在业务方法里直接打印提示信息，应该把判断结果返回给上层控制器处理。

改进后的原生JDBC实现（修正基础问题） #

先给你修正基础的JDBC代码，解决上述问题：

public boolean exists(String email) throws SQLException {
    // 定义资源变量，后续统一关闭
    Connection conn = null;
    PreparedStatement pstmt = null;
    ResultSet rs = null;
    try {
        conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/Spring3", "root", "root");
        // 使用带参数的SQL，直接查询对应邮箱的记录
        String sql = "SELECT 1 FROM Registration WHERE email = ?";
        pstmt = conn.prepareStatement(sql);
        // 设置参数，避免SQL注入
        pstmt.setString(1, email);
        rs = pstmt.executeQuery();
        // 只要有结果返回，说明邮箱已存在
        return rs.next();
    } finally {
        // 关闭资源，注意顺序：ResultSet -> PreparedStatement -> Connection
        if (rs != null) {
            try {
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        if (pstmt != null) {
            try {
                pstmt.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        if (conn != null) {
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

SpringMVC中推荐的实现方式（使用JdbcTemplate） #

在SpringMVC项目中，更推荐使用Spring提供的JdbcTemplate来管理数据库操作，它会自动帮你处理资源关闭、异常转换等工作，代码更简洁：

1. 配置数据源和JdbcTemplate #

首先在Spring的配置文件（比如applicationContext.xml）中配置数据源和JdbcTemplate：

<!-- 配置数据源 -->
<bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
    <property name="driverClassName" value="com.mysql.cj.jdbc.Driver"/>
    <property name="url" value="jdbc:mysql://localhost:3306/Spring3?useSSL=false&serverTimezone=UTC"/>
    <property name="username" value="root"/>
    <property name="password" value="root"/>
</bean>

<!-- 配置JdbcTemplate -->
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
    <property name="dataSource" ref="dataSource"/>
</bean>

2. 编写业务类 #

然后在你的业务类中注入JdbcTemplate，实现邮箱检查逻辑：

import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Service;

@Service
public class UserService {

    private final JdbcTemplate jdbcTemplate;

    // 构造方法注入JdbcTemplate
    public UserService(JdbcTemplate jdbcTemplate) {
        this.jdbcTemplate = jdbcTemplate;
    }

    public boolean isEmailRegistered(String email) {
        String sql = "SELECT COUNT(*) FROM Registration WHERE email = ?";
        // queryForObject返回查询结果，这里统计数量，大于0则说明已注册
        Integer count = jdbcTemplate.queryForObject(sql, Integer.class, email);
        return count != null && count > 0;
    }
}

3. 在Controller中调用 #

最后在SpringMVC的Controller中调用这个方法，处理请求：

import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;

@Controller
public class UserController {

    private final UserService userService;

    public UserController(UserService userService) {
        this.userService = userService;
    }

    @PostMapping("/check-email")
    @ResponseBody
    public String checkEmail(@RequestParam String email) {
        if (userService.isEmailRegistered(email)) {
            return "Email already registered!!";
        } else {
            return "Email is available.";
        }
    }
}

额外注意事项 #

• SQL注入防护：使用PreparedStatement或者JdbcTemplate的参数绑定方式，避免直接拼接SQL，防止SQL注入攻击。
• 异常处理：在实际项目中，不要直接抛出SQLException，可以用Spring的异常转换，或者自定义业务异常来处理。
• 数据库连接池：生产环境中建议使用连接池（比如HikariCP）代替DriverManagerDataSource，提升性能和稳定性。

内容的提问来源于stack exchange，提问作者Akki