博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Spring JDBC
阅读量:6000 次
发布时间:2019-06-20

本文共 5931 字,大约阅读时间需要 19 分钟。

hot3.png

Spring JDBC

Spring JDBC是对原生JDBC的轻量级封装,在Spring Boot中使用Spring JDBC需要遵循以下步骤:

1、添加配置文件application.properties,在配置文件中定义数据源信息和连接池信息

#数据库连接信息spring.datasource.name=sampleDsspring.datasource.url=jdbc:mysql://localhost:3306/sampledbspring.datasource.username=rootspring.datasource.password=passwordspring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver#数据库连接池配置spring.datasource.tomcat.max-wait=10000spring.datasource.tomcat.max-active=50spring.datasource.tomcat.max-idle=10spring.datasource.tomcat.min-idle=8spring.datasource.tomcat.test-on-borrow=truespring.datasource.tomcat.validation-query=select 1

2、在DAO类中使用@Autowired注入JdbcTemplate对象或者NamedParameterTemplate对象:

@Repositorypublic class UserDao {    //使用SpringBoot自动管理的Spring jdbc    @Autowired    private JdbcTemplate jdbcTemplate;    //使用命名参数绑定的Spring jdbc    @Autowired    private NamedParameterJdbcTemplate namedParameterJdbcTemplate;    ...}

下面分别介绍Spring JDBC提供的这两个类。

1、JdbcTemplate

    1.1、插入/修改/删除

    插入/修改/删除主要通过JdbcTemplate的一系列update方法实现:

@Repositorypublic class UserDao {    @Autowired    private JdbcTemplate jdbcTemplate;    private static final String INSERTNEWUSER = "insert into t_user (user_name,password) " +            "values(?,?) ";    private static final String MODIFYPASSWORD= "UPDATE t_user SET password = ? " +            "WHERE user_name = ?";        @Transactional    public void insert(User user){        //方法1:使用update(String sql)        jdbcTemplate.update("DELETE * FROM t_user WHERE user_name = 'admin'");        //方法2:update(String sql,Object...args)        jdbcTemplate.update(INSERTNEWUSER,user.getUserName(),"xxxx");    }}

    这两个方法都返回一个int,表示受影响的行数。

    还有一个特殊的重写可以获取数据库的表自增主键值:

public User insertWithKeyBack(final User user){    //创建一个keyHolder以存储生产的自增长主键    KeyHolder keyHolder = new GeneratedKeyHolder();    jdbcTemplate.update(new PreparedStatementCreator() {        @Override        public PreparedStatement createPreparedStatement(Connection connection) throws SQLException {            PreparedStatement ps = connection.prepareStatement(INSERTNEWUSER);            ps.setObject(1,user.getUserName());            ps.setObject(2,user.getPassword());            return ps;        }    },keyHolder);    //使用KeyHolder的getKey方法获取数据库创建的自增长主键    user.setUserId(keyHolder.getKey().intValue());    return user;}

 KeyHolder的三个方法:

  1. int getKey()获取返回的单个数字
  2. Map<String,Object> getKeys()获取返回的单个主键,key为列名,value为列值
  3. List<Map<String,Object> getKeyList()获取返回的多个主键,存在多个Map中,一个Map对应一个主键。

    1.2、批量更改

如果需要一次性插入大量的数据,直接多次使用update()方法效果十分不理想,可以考虑使用JdbcTemplate的批量更改方法:

    

/** * 批量修改 * @param users */public void batchInsert(final List
users){ final String sql = "INSERT INTO t_user(user_name,password) values(?,?) "; //使用匿名内部类,batchUpdate方法实现批量插入 jdbcTemplate.batchUpdate(sql, new BatchPreparedStatementSetter() { //指定插入的数据 @Override public void setValues(PreparedStatement preparedStatement, int i) throws SQLException { User user = users.get(i); preparedStatement.setObject(1,user.getUserName()); preparedStatement.setObject(2,user.getPassword()); } //指定一批插入的记录数 @Override public int getBatchSize() { return 0; } });}

    1.3、查询

        1.3.1、单值数据查询

        JdbcTemplate有一系列的queryForXX方法用于单值数据查询:

private static final String MATCH_COUNT = "SELECT count(*) from t_user " +        "where user_name = ? and password = ? ";/** * 查询符合的项数 * @param user * @return */public int getMatchCount(User user){    //查询方法,第一个参数为查询字符串,第二个参数为返回的类型(仅限基本类型和String),后面的参数为输入的参数    return jdbcTemplate.queryForObject(MATCH_COUNT,Integer.TYPE,user.getUserName(),user.getPassword());}

        1.3.2、一般查询

/** * 根据用户名查询用户 * 使用query(String sql,RowCallbackHandler r) * @param user */public List
getUsers(final User user){ final String sql = "SELECT * FROM t_user(user_name,password) values(?,?)"; //使用RowCallbackHandler final List
users = new ArrayList<>(); jdbcTemplate.query(sql, new Object[]{user.getUserName(),user.getPassword()},new RowCallbackHandler() { @Override public void processRow(ResultSet resultSet) throws SQLException { User user = new User(); user.setUserName(resultSet.getString("userName")); user.setPassword(resultSet.getString("password")); users.add(user); } }); return users;}/** * 根据用户名查询用户 * 使用query(String sql,RowMapper r) * @param user */public List
getUsers2(final User user){ final String sql = "SELECT * FROM t_user(user_name,password) values(?,?)"; //使用RowMapper return jdbcTemplate.query(sql, new Object[]{user.getUserName(), user.getPassword()}, new RowMapper
() { @Override public User mapRow(ResultSet resultSet, int i) throws SQLException { User user = new User(); user.setUserName(resultSet.getString("userName")); user.setPassword(resultSet.getString("password")); return user; } });}

        RowMapper和RowCallbackHandler的区别:

  1. 查询多行数据时,RowMapper可以直接返回List,RowCallBackHandler需要手动处理;
  2. 在处理大结果集时,RowMapper采用批量化数据处理技术,会一次性将数据读取到内存中,而RowCallBackHandler和原生resultSet一样采用流化处理策略,一边获取数据一边处理,处理完即丢弃。在大结果集查询时,推荐使用RowMapper,效率更高。

2、NamedParameterTemplate

/** * 使用NamedParameterJdbcTemplate插入用户 * @param user */public void insertUser(User user){    final String sql = "INSERT into t_user(user_name,password) " +            "values (:userName,:password)";    SqlParameterSource sqlParameterSource = new BeanPropertySqlParameterSource(user);    namedParameterJdbcTemplate.update(sql,sqlParameterSource);}

注意事项

Spring中,每次HTTP请求都会绑定一个线程,该请求的所有操作都在这个线程中完成。固如果希望在DAO中穿插着使用Spring JDBC和原生JDBC,在获取Connection时,不能直接从DataSource获取,因为直接从DataSource中获取取不到和当前线程绑定的Connection。而应该使用DataSourceUtils获取:

/** * 线程安全地使用原生JDBC */public Connection getNativeConnection(){    return DataSourceUtils.getConnection(jdbcTemplate.getDataSource());}

 

 

转载于:https://my.oschina.net/pierrecai/blog/869784

你可能感兴趣的文章
cacti基础配置,附带软件包
查看>>
Centos 7 Saltstack自动化部署weblogic 12c
查看>>
ORACLE学习笔记--SQL查询语句
查看>>
自学sql之路,SQL 是用于访问和处理数据库的标准的计算机语言!
查看>>
Nginx基本配置
查看>>
[Windows Azure] How to use the Windows Azure Blob Storage Service in .NET
查看>>
LNAMP第二版(nginx 1.2.0+apache 2.4.2+php 5.4)
查看>>
MongoDB repl set权限认证配置步骤
查看>>
java学习笔记(1)
查看>>
jQuery 如何获取何设置 redio标签的值
查看>>
禁止Mysql默认端口访问Internet - MySQL - IT技术网
查看>>
java高并发设计(十五)-- netty通信之全部
查看>>
zend studio 9 字体,颜色,快捷键等相关设置
查看>>
我的友情链接
查看>>
基于用户投票的排名算法(二):Reddit
查看>>
下午最后的草坪
查看>>
我们是经过长时间亲测后的结果
查看>>
Android运行时配置更改
查看>>
一缕清风
查看>>
ECChop出现Strict Standards: Redefining already defined constructor错误
查看>>