详解spring与jdbc整合操作

详解spring与jdbc整合操作

1. Spring JDBC介绍

Spring JDBC是spring框架中最重要的部分之一，提供了一组用于执行SQL操作和访问关系型数据库的类和接口。

Spring JDBC提供的主要API为JdbcTemplate和NamedParameterJdbcTemplate，以及支持Transaction（事务）和DAO（数据访问）的抽象。

2. 整合操作

整合Spring JDBC时，需要在项目中引入Spring JDBC的相关依赖：

<dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-jdbc</artifactId>
    <version>${org.springframework.version}</version>
</dependency>

<dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-tx</artifactId>
    <version>${org.springframework.version}</version>
</dependency>

3. 配置数据源

可以使用Spring框架中的DataSource来管理数据源，DataSource可以通过JNDI、连接池对象以及简单的驱动管理器来实现。使用Spring框架中的JdbcTemplate来执行SQL语句。

在Spring框架中配置数据源时，可以使用JNDI，也可以使用Spring框架中的DataSource直接配置数据库连接信息。

以下是通过DataSource来配置操作MySQL数据库的示例：

<bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
    <property name="driverClassName" value="com.mysql.jdbc.Driver" />
    <property name="url" value="jdbc:mysql://localhost:3306/testdb" />
    <property name="username" value="root" />
    <property name="password" value="123456" />
</bean>

4. 编写DAO

DAO是数据访问层的抽象，它通常被设计成一个接口，定义了对数据的CRUD操作。Spring JDBC提供了JdbcDaoSupport和NamedParameterJdbcDaoSupport两个类，可以用它们来简化DAO的实现。

4.1 JdbcTemplate的使用

以下是使用JdbcTemplate实现的一个DAO示例：

@Repository
public class UserDaoImpl implements UserDao {
    @Autowired
    private DataSource dataSource;

    private JdbcTemplate jdbcTemplate;

    @PostConstruct
    private void initialize() {
        jdbcTemplate = new JdbcTemplate(dataSource);
    }

    @Override
    public User findUserById(int userId) {
        String sql = "SELECT * FROM user WHERE user_id = ?";
        return jdbcTemplate.queryForObject(sql, new Object[]{userId}, new UserMapper());
    }

    @Override
    public List<User> findAllUsers() {
        String sql = "SELECT * FROM user";
        return jdbcTemplate.query(sql, new UserMapper());
    }

    @Override
    public void addUser(User user) {
        String sql = "INSERT INTO user (user_id, user_name, user_email) values (?, ?, ?)";
        jdbcTemplate.update(sql, user.getUserId(), user.getUserName(), user.getUserEmail());
    }

    @Override
    public void updateUser(User user) {
        String sql = "UPDATE user SET user_name = ?, user_email = ? WHERE user_id = ?";
        jdbcTemplate.update(sql, user.getUserName(), user.getUserEmail(), user.getUserId());
    }

    @Override
    public void deleteUser(int userId) {
        String sql = "DELETE FROM user WHERE user_id = ?";
        jdbcTemplate.update(sql, userId);
    }

    private static final class UserMapper implements RowMapper<User> {
        @Override
        public User mapRow(ResultSet rs, int rowNum) throws SQLException {
            User user = new User();
            user.setUserId(rs.getInt("user_id"));
            user.setUserName(rs.getString("user_name"));
            user.setUserEmail(rs.getString("user_email"));
            return user;
        }
    }
}

可以看出，JdbcTemplate提供了简洁而且易于使用的Sql操作方法，它的update()方法和query()方法可以简化操作MySQL的门槛。

4.2 NamedParameterJdbcTemplate的使用

以下是使用NamedParameterJdbcTemplate实现的一个DAO示例：

@Repository
public class UserDaoImpl implements UserDao {
    @Autowired
    private DataSource dataSource;

    private NamedParameterJdbcTemplate namedParameterJdbcTemplate;

    @PostConstruct
    private void initialize() {
        namedParameterJdbcTemplate = new NamedParameterJdbcTemplate(dataSource);
    }

    @Override
    public User findUserById(int userId) {
        String sql = "SELECT * FROM user WHERE user_id = :userId";
        SqlParameterSource namedParameters = new MapSqlParameterSource("userId", userId);
        return namedParameterJdbcTemplate.queryForObject(sql, namedParameters, new UserMapper());
    }

    @Override
    public List<User> findAllUsers() {
        String sql = "SELECT * FROM user";
        return namedParameterJdbcTemplate.query(sql, new UserMapper());
    }

    @Override
    public void addUser(User user) {
        String sql = "INSERT INTO user (user_id, user_name, user_email) values (:userId, :userName, :userEmail)";
        SqlParameterSource namedParameters = new MapSqlParameterSource()
                .addValue("userId", user.getUserId())
                .addValue("userName", user.getUserName())
                .addValue("userEmail", user.getUserEmail());
        namedParameterJdbcTemplate.update(sql, namedParameters);
    }

    @Override
    public void updateUser(User user) {
        String sql = "UPDATE user SET user_name = :userName, user_email = :userEmail WHERE user_id = :userId";
        SqlParameterSource namedParameters = new MapSqlParameterSource()
                .addValue("userName", user.getUserName())
                .addValue("userEmail", user.getUserEmail())
                .addValue("userId", user.getUserId());
        namedParameterJdbcTemplate.update(sql, namedParameters);
    }

    @Override
    public void deleteUser(int userId) {
        String sql = "DELETE FROM user WHERE user_id = :userId";
        SqlParameterSource namedParameters = new MapSqlParameterSource("userId", userId);
        namedParameterJdbcTemplate.update(sql, namedParameters);
    }

    private static final class UserMapper implements RowMapper<User> {
        @Override
        public User mapRow(ResultSet rs, int rowNum) throws SQLException {
            User user = new User();
            user.setUserId(rs.getInt("user_id"));
            user.setUserName(rs.getString("user_name"));
            user.setUserEmail(rs.getString("user_email"));
            return user;
        }
    }
}

NamedParameterJdbcTemplate提供了比JdbcTemplate更简洁和易于调试的Sql操作方法，它的SqlParameterSource接口能够实现Map或JavaBean的参数绑定。

5. 总结

在本文中，详细介绍了Spring JDBC的基本概念和使用方法，通过整合Spring JDBC和MySQL数据库，演示了使用JdbcTemplate和NamedParameterJdbcTemplate实现的DAO示例。