spring jdbc

Spring --jdbc

相关的jar包:

spring-jdbc-4.3.9.RELEASE.jar 
spring-tx-4.3.9.RELEASE.jar

一、配置连接池

<!--加载properties文件-->
<context:property-placeholder location="classpath:jdbc.properties"/>
<!--配置连接池-->
<bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource">
    <property name="password" value="${password}"/>
    <property name="driverClassName" value="${driverClassName}"/>
    <property name="username" value="${username}"/>
    <property name="url" value="${url}"/>
</bean>

二、配置jdbc的模板类Template

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

JdbcTemplate(org.springframework.jdbc.core.JdbcTemplate)使用方法

//增删改
template.update(String sql,Object...par);
//查询
//创建结果集处理器
RowMapper<Users> rowMapper = new BeanPropertyRowMapper<>(Users.class);
template.query(Stringsql,RowMapper<T> rowMapper,Object...args);

三、Template的事务处理

在需要执行事务操作的方法或类上添加@Transactional

<!--配置事务管理-->
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
    <property name="dataSource" ref="dataSource"/>
</bean>
<!--开启事务 当事务管理器的id为transactionManager时 可以忽略transaction-manager-->
<tx:annotation-driven transaction-manager="transactionManager"/>

四、返回insert 自动生成的主键

    @Test
    public void testReturnKey(){
        String sql = "INSERT INTO USER (u_name) VALUES (?)";
        KeyHolder keyHolder = new GeneratedKeyHolder();
        int j = jdbcTemplate.update(new PreparedStatementCreator() {
            @Override
            public PreparedStatement createPreparedStatement(Connection conn) throws SQLException {
                PreparedStatement ps = conn.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS);
                ps.setString(1, "yuing");
                return ps;
            }
        }, keyHolder);
            
        int i = keyHolder.getKey().intValue();
        System.out.println(j);
        System.out.println(i);
    }

五、批量操作

    @Test
    public void testBachUpdate(){
        String sql = "insert into user (u_name) values(?)";
        List<Object[]> list = new ArrayList<>();
        for(int i = 0;i<10000;i++){
            list.add(new Object[]{"yuing"+i});
        }
        long sta = System.currentTimeMillis();
        jdbcTemplate.batchUpdate(sql,list);
        long end = System.currentTimeMillis();
        Long i = end-sta;
        System.out.println(i);
    }