本文主要是介绍11.1 使用Spring JDBC访问数据库，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
参考《企业应用开发实战》第11章。
细节：
如果某参数不希望在方法中改变，可以声明为final
实战经验：
一般在配置文件中先声明一下 dataSource、jdbcTemplate等bean，之后在需要用的DAO类中，一般先写个基类BaseDao，在基类中定义一些通用的功能，例如声明JDBCTemplate、分页查询等多种。
@Autowired
private JdbcTemplate jdbcTemplate;更改
jdbcTemplate的update语句：
比较好的写法是用 ?占位符
String sql = " INSERT INTO t_post(topicId,postText) VALUES(?,?)";
Object[] params = new Object[]{post.getTopicId(),post.getPostText()};
jdbcTemplate.update(sql, params,new int[]{Types.VARCHAR,Types.VARCHAR});将某个类的对象插到数据库中，想让主键值自动绑定到该对象上？方便后继的使用
// ForumJdbcDao里的方法@Overridepublic void addForum(Forum forum) {// TODO Auto-generated method stubfinal String sql = "INSERT INTO t_forum(forumName,forumDesc) VALUES(?,?)";// 创建一个主键执有者KeyHolder keyHolder = new GeneratedKeyHolder();getJdbcTemplate().update(new PreparedStatementCreator() {public PreparedStatement createPreparedStatement(Connection conn)throws SQLException {PreparedStatement ps = conn.prepareStatement(sql);ps.setString(1, forum.getForumName());ps.setString(2, forum.getForumDesc());return ps;}}, keyHolder);// 从主键执有者中获取主键forum.setForumId(keyHolder.getKey().intValue());}批量更改数据
// 一次性新增多个论坛版块
public void addForums(final List<Forum> forums) {final String sql = "INSERT INTO t_forum(forum_name,forum_desc) VALUES(?,?)";jdbcTemplate.batchUpdate(sql, new BatchPreparedStatementSetter() {public int getBatchSize() {return forums.size();}public void setValues(PreparedStatement ps, int index)throws SQLException {Forum forum = forums.get(index);ps.setString(1, forum.getForumName());ps.setString(2, forum.getForumDesc());}});}查询
经过SQL语句查询得到的数据需要转化为类的对象并返回！
查询得到单条数据：
Spring会遍历查询的结果集，对结果集的每一行调用RowCallbackHandler回调接口处理数据
与RowCallbackHandler类似的RowMapper就不详说了（见书P371）
// 查询forum_name,forum_desc是为了后面返回Forum的对象
public Forum getForum(final int forumId) {String sql = "SELECT forum_name,forum_desc FROM t_forum WHERE forum_id=?";final Forum forum = new Forum();jdbcTemplate.query(sql, new Object[] { forumId },new RowCallbackHandler() {public void processRow(ResultSet rs) throws SQLException {forum.setForumId(forumId);forum.setForumName(rs.getString("forum_name"));forum.setForumDesc(rs.getString("forum_desc"));}});return forum;}查询返回多条数据：
// 查询forum_id在一组区间内的多条数据
public List<Forum> getForums(final int fromId, final int toId) {String sql = "SELECT forum_id,forum_name,forum_desc FROM t_forum WHERE forum_id between ? and ?";List<Forum> forums = new ArrayList<Forum>();jdbcTemplate.query(sql,new Object[]{fromId,toId},newRowCallbackHandler(){ public void processRow(ResultSet rs) throws SQLException { Forum forum = new Forum();forum.setForumId(rs.getInt("forum_id"));forum.setForumName(rs.getString("forum_name"));forum.setForumDesc(rs.getString("forum_desc")); forums.add(forum);}}); return forums;}查询单值数据
//1.查询一行数据并返回int型结果
jdbcTemplate.queryForInt("select count(*) from test");
//2. 查询一行数据并将该行数据转换为Map返回
jdbcTemplate.queryForMap("select * from test where name='name5'");
//3.查询一行任何类型的数据，最后一个参数指定返回结果类型
jdbcTemplate.queryForObject("select count(*) from test", Integer.class);
//4.查询一批数据，默认将每行数据转换为Map
jdbcTemplate.queryForList("select * from test");
//5.只查询一列数据列表，列类型是String类型，列名字是name
jdbcTemplate.queryForList("
select name from test where name=?", new Object[]{"name5"}, String.class);
//6.查询一批数据，返回为SqlRowSet，类似于ResultSet，但不再绑定到连接上
SqlRowSet rs = jdbcTemplate.queryForRowSet("select * from test"); 调用存储过程
具体见P375
先创建存储过程：
public int getUserTopicNum(final int userId) {// 调用存储过程String sql = "{call P_GET_TOPIC_NUM(?,?)}";Integer num = jdbcTemplate.execute(sql,new CallableStatementCallback<Integer>() {public Integer doInCallableStatement(CallableStatement cs)throws SQLException, DataAccessException {cs.setInt(1, userId); // 绑定传入参数cs.registerOutParameter(2, Types.INTEGER); //注册输出参数cs.execute();return cs.getInt(2); //获取输出参数的值}});return num;}BLOB/CLOB类型数据的操作
LOB代表大数据对象，其中BLOB用于存储大块的二进制数据例如图片、视频，CLOB用于存储长文本数据例如帖子。
数据库内部对应的类型是：Oracle对应BLOB/CLOB，MySQL对应的是BLOB/longtext。
longtext操作起来和简单类型一样，但是用户可能用流的方式操作LOB类型的数据。
写 BLOB/CLOB类型
例：
--- Post.java
包含多个属性，例如// 在数据库中postText是longtext（相当于CLOB），postAttach是BLOBprivate String postText;private byte[] postAttach;--- PostDao.javaimport java.sql.PreparedStatement;
import java.sql.SQLException;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.support.AbstractLobCreatingPreparedStatementCallback;
import org.springframework.jdbc.support.incrementer.DataFieldMaxValueIncrementer;
import org.springframework.jdbc.support.lob.LobCreator;
import org.springframework.jdbc.support.lob.LobHandler;
import org.springframework.stereotype.Repository;import chapter11.domain.Post;@Repository
public class PostDao {@Autowiredprivate JdbcTemplate jdbcTemplate;@Autowiredprivate LobHandler lobHandler;@Autowiredprivate DataFieldMaxValueIncrementer incre; public void addPost(final Post post){String sql = " INSERT INTO t_post(postId,userId,postText,postAttach)"+ " VALUES(?,?,?,?)";jdbcTemplate.execute(sql,new AbstractLobCreatingPreparedStatementCallback(this.lobHandler) {protected void setValues(PreparedStatement ps,LobCreator lobCreator)throws SQLException {//2：通过自增键指定主键值 ps.setInt(1, incre.nextIntValue());ps.setInt(2, post.getUserId()); // 设置CLOB和BLOB字段lobCreator.setClobAsString(ps, 3, post.getPostText());lobCreator.setBlobAsBytes(ps, 4, post.getPostAttach());}});}}注意点：一是类的标注 @Repository，二是主键自增的写法，三是CLOB和BLOB字段--- 配置文件<context:component-scan base-package="chapter11" /> <context:property-placeholder location="classpath:jdbc.properties" /><bean id="dataSource" class="org.apache.commons.dbcp2.BasicDataSource"destroy-method="close"p:driverClassName="${jdbc.driverClassName}"p:url="${jdbc.url}"p:username="${jdbc.username}"p:password="${jdbc.password}" /><bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate"p:dataSource-ref="dataSource"/><bean id="namedParamJdbcTemplate" class="org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate"><constructor-arg ref="dataSource"/></bean> <bean id="nativeJdbcExtractor" class="org.springframework.jdbc.support.nativejdbc.CommonsDbcpNativeJdbcExtractor"lazy-init="true" /><bean id="lobHandler" class="org.springframework.jdbc.support.lob.DefaultLobHandler"lazy-init="true" /><!-- 1：基于数据库序列的自增器 --><!-- <bean id="incre" class="org.springframework.jdbc.support.incrementer.OracleSequenceMaxValueIncrementer"p:incrementerName="seq_post_id"p:dataSource-ref="dataSource"/> --><!-- 1：基于数据表的自增器 --> <bean id="incre" class="org.springframework.jdbc.support.incrementer.MySQLMaxValueIncrementer"p:incrementerName="t_post_id"p:columnName="sequence_id"p:cacheSize="10"p:dataSource-ref="dataSource"/><bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"p:dataSource-ref="dataSource"/><bean id="bbtForum" class="chapter11.service.JdbcBbtForum"p:forumDao-ref="forumDao"/>测试：
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations={"classpath:applicationContext.xml"})
@TransactionConfiguration
@Transactional
public class MyTest {@Autowiredprivate PostDao postDao;@Test@Rollback(false)public void testAddPost() throws Throwable{// 创建postPost post = new Post();post.setUserId(2);// 将图片转化为字节ClassPathResource res = new ClassPathResource("temp.jpg");byte[] mockImg = FileCopyUtils.copyToByteArray(res.getFile());post.setPostAttach(mockImg);post.setPostText("ceshi ");// 上面新建post时还没有对postId赋值默认初始值，在addPost方法中才对postId赋值postDao.addPost(post);}}
注意点：第一行的@RunWith(SpringJUnit4ClassRunner.class)容易丢导致出错
读BLOB、CLOB数据：
（1）以块数据方式读取Lob数据
以String读取Clob字段，以byte[]读取Blob字段
// 在PostDao类中加上方法
// 查看用户发表的所有帖子public List<Post> getAttachs(final int userId) {String sql = " SELECT post_id,post_attach FROM t_post where user_id =? and post_attach is not null ";return jdbcTemplate.query(sql, new Object[] { userId },new RowMapper<Post>() {public Post mapRow(ResultSet rs, int rowNum)throws SQLException {int postId = rs.getInt(1);byte[] attach = lobHandler.getBlobAsBytes(rs, 2);Post post = new Post();post.setPostId(postId);post.setPostAttach(attach);return post;}});}（2）以流数据方式读取Lob数据
如果数据很大，可以用流数据方式读取
public void getAttach(final int postId, final OutputStream os){String sql = "SELECT post_attach FROM t_post WHERE post_id=? ";jdbcTemplate.query(sql, new Object[] {postId},new AbstractLobStreamingResultSetExtractor<Object>() {// 以流的方式处理LOB字段@Overrideprotected void streamData(ResultSet rs) throws SQLException, IOException, DataAccessException {// TODO Auto-generated method stubInputStream is = lobHandler.getBlobAsBinaryStream(rs, 1);if(is!=null)FileCopyUtils.copy(is, os);}protected void handleNoRowFound() throws LobRetrievalFailureException {System.out.println("Not Found result!");}});}这篇关于11.1 使用Spring JDBC访问数据库的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
