Spring整合JDBC

Spring中提供了一个可以操作数据库的对象，封装了JDBC技术

JDBCTemplate => JDBC模板对象
与DBUtils中的QueryRunner非常相似

 //准备连接池
        ComboPooledDataSource dataSource = new ComboPooledDataSource();
        dataSource.setDriverClass("com.mysql.jdbc.Driver");
        dataSource.setJdbcUrl("jdbc:mysql://103.249.130.173:3306/hibernate_crm?useUnicode=true&characterEncoding=UTF8");
        dataSource.setUser("appUser");
        dataSource.setPassword("AA1122BB");
        //创建JDBC模板对象
        JdbcTemplate jt = new JdbcTemplate();
        jt.setDataSource(dataSource);
        //书写sql语句并执行
        String sql = "insert into t_user values(null,'rose')";
        jt.update(sql);

Spring整合Dao 数据库

步骤

1 导包

• 4+2 spring包
• spring-test、spring-aop、junit4类库
• c3p0连接池 JDBC驱动
• spring-jdbc spring-tx事务

2 准备数据库

数据库

书写Dao

public interface TUserDao {
    //增
    void save(TUser user);
    //删除
    void delete(Integer id);
    //改
    void update(TUser user);
    //查
    TUser getById(Integer id);

    int getTotalCount();

    List<TUser> getAllTUser();
}

书写实现类impl

public class TUserDaoImpl implements TUserDao {
    private JdbcTemplate jt;

    @Override
    public void save(TUser user) {
        String sql = "insert into t_user values(null,?)";
        jt.update(sql, user.getName());
    }

    @Override
    public void delete(Integer id) {
        String sql = "delete from t_user where id = ?";
        jt.update(sql, id);
    }

    @Override
    public void update(TUser user) {
        String sql = "update t_user set name = ? where id =?";
        jt.update(sql, user.getName(), user.getId());
    }

    @Override
    public TUser getById(Integer id) {
        String sql = "select * from t_user where id = ?";
        TUser tUser = jt.queryForObject(sql, new RowMapper<TUser>() {
            @Override
            public TUser mapRow(ResultSet resultSet, int i) throws SQLException {
                TUser tUser = new TUser();

                tUser.setId(resultSet.getInt("id"));
                tUser.setName(resultSet.getString("name"));
                return tUser;
            }
        }, id);
        return tUser;
    }

    @Override
    public int getTotalCount() {
        String sql = "select count(*) from t_user";
        Integer count = jt.queryForObject(sql, Integer.class);
        return count;
    }

    @Override
    public List<TUser> getAllTUser() {
        String sql = "select * from t_user";
        List<TUser> query = jt.query(sql, new RowMapper<TUser>() {
            @Override
            public TUser mapRow(ResultSet resultSet, int i) throws SQLException {
                TUser tUser = new TUser();

                tUser.setId(resultSet.getInt("id"));
                tUser.setName(resultSet.getString("name"));
                return tUser;
            }
        });
        return query;
    }

    public JdbcTemplate getJt() {
        return jt;
    }

    public void setJt(JdbcTemplate jt) {
        this.jt = jt;
    }
}

实现配置

<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">
    <!--配置目标对象-->
    <bean name="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
        <property name="jdbcUrl"
                  value="jdbc:mysql://103.249.130.173:3306/hibernate_crm?useUnicode=true&amp;characterEncoding=UTF8"></property>
        <property name="driverClass" value="com.mysql.jdbc.Driver"></property>
        <property name="user" value="appUser"></property>
        <property name="password" value="AA1122BB"></property>
    </bean>
    <!--jdbcTemplate放入Spring容器-->
    <bean name="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <property name="dataSource" ref="dataSource"></property>
    </bean>
    <!--将UserDao放入Spring容器-->
    <bean name="userDao" class="cn.probuing.dao.TUserDaoImpl">
        <property name="jt" ref="jdbcTemplate"/>
    </bean>
</beans>

进阶内容

JDBCDaoSupport

JDBCDapSupport根据连接池创建JDBC模板
不需要手动准备JDBC模板，从父类方法中获得即可

JDBCSupport

继承JDBCDaoSupport后，需要直接注入连接池就可以了

  <!--将UserDao放入Spring容器-->
    <bean name="userDao" class="cn.probuing.dao.TUserDaoImpl">
        <!--<property name="jt" ref="jdbcTemplate"/>-->
        <property name="dataSource" ref="dataSource"/>
    </bean>

读取外部的Properties

• 编写.properties文件

为防止properties key键冲突 需要添加前缀 例如 test.key jdbc.key

jdbc.jdbcUrl=jdbc:mysql://xxxxxxxxxx;characterEncoding=UTF8
jdbc.driverClass=com.mysql.jdbc.Driver
jdbc.user=xxxxx
jdbc.password=xxxxxx

• 配置指定读取spring db.properties配置

  
  配置读取指定配置

• 配置读取配置中的值作为配置中的值

  
  图片.png

Spring中aop事务

Spring封装了事务管理的代码

• 打开事务
• 提交事务
• 回滚事务

事务操作对象

因为在不同平台，操作事务的代码各不相同，所以Spring提供了一个接口

• PlatformTransactionManager 接口
  • JDBC平台 DataSourceTransactionManager
  • HibernateTransitionManager
    **在Spring中玩事务管理，最为核心的对象就是TransactionManager对象

Spring管理事务的属性介绍

事务的隔离级别

是否只读

事务的传播行为

事务传播行为

Spring管理事物方式

编码式

将核心事务管理器配置到Spring容器

配置核心事务管理器

配置TransactionTemplate模板

配置TransactionTemplate模板.png

将事务模板注入Service

将事务模板注入Service.png

在Service中调用模板

Service中调用模板

aop xml配置方式

导包

aop
aspect
aop联盟
weaving织入包

导入新的约束(tx)

图片.png

beans: 最基本
context:读取properties配置
aop:配置aop
tx:配置事务通知

配置通知

图片.png

配置将通知织入目标

通知织入目标

注解配置

导包

aop
aspect
aop联盟
weaving织入包

导入新的约束(tx)

图片.png

开启注解管理事务

开启注解管理事务

使用注解

图片.png 图片.png