11.1 使用Spring JDBC访问数据库

2024-04-17 02:58
文章标签 java 访问 使用 jdbc spring 数据库 11.1

本文主要是介绍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访问数据库的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/910617。

相关文章

C语言中联合体union的使用

C语言中联合体union的使用

本文编辑整理自： http://bbs.chinaunix.net/forum.php?mod=viewthread&tid=179471 一、前言 “联合体”(union）与“结构体”(struct)有一些相似之处。但两者有本质上的不同。在结构体中,各成员有各自的内存空间, 一个结构变量的总长度是各成员长度之和。而在“联合”中,各成员共享一段内存空间, 一个联合变量
阅读更多...
Java五子棋之坐标校正

Java五子棋之坐标校正

上篇针对了Java项目中的解构思维，在这篇内容中我们不妨从整体项目中拆解拿出一个非常重要的五子棋逻辑实现：坐标校正，我们如何使漫无目的鼠标点击变得有序化和可控化呢？ 目录 一、从鼠标监听到获取坐标 1.MouseListener和MouseAdapter 2.mousePressed方法 二、坐标校正的具体实现方法 1.关于fillOval方法 2.坐标获取 3.坐标转换 4.坐
阅读更多...
Spring Cloud：构建分布式系统的利器

Spring Cloud：构建分布式系统的利器

引言 在当今的云计算和微服务架构时代，构建高效、可靠的分布式系统成为软件开发的重要任务。Spring Cloud 提供了一套完整的解决方案，帮助开发者快速构建分布式系统中的一些常见模式（例如配置管理、服务发现、断路器等）。本文将探讨 Spring Cloud 的定义、核心组件、应用场景以及未来的发展趋势。 什么是 Spring Cloud Spring Cloud 是一个基于 Spring
阅读更多...
Tolua使用笔记（上）

Tolua使用笔记（上）

目录   1.准备工作 2.运行例子 01.HelloWorld：在C#中，创建和销毁Lua虚拟机 和 简单调用。 02.ScriptsFromFile：在C#中，对一个lua文件的执行调用 03.CallLuaFunction：在C#中，对lua函数的操作 04.AccessingLuaVariables：在C#中，对lua变量的操作 05.LuaCoroutine：在Lua中，
阅读更多...
Javascript高级程序设计(第四版)--学习记录之变量、内存

Javascript高级程序设计(第四版)--学习记录之变量、内存

原始值与引用值 原始值：简单的数据即基础数据类型，按值访问。 引用值：由多个值构成的对象即复杂数据类型，按引用访问。 动态属性 对于引用值而言，可以随时添加、修改和删除其属性和方法。 let person = new Object();person.name = 'Jason';person.age = 42;console.log(person.name,person.age);//'J
阅读更多...
java8的新特性之一（Java Lambda表达式）

java8的新特性之一（Java Lambda表达式）

1：Java8的新特性 Lambda 表达式： 允许以更简洁的方式表示匿名函数（或称为闭包）。可以将Lambda表达式作为参数传递给方法或赋值给函数式接口类型的变量。 Stream API： 提供了一种处理集合数据的流式处理方式，支持函数式编程风格。 允许以声明性方式处理数据集合（如List、Set等）。提供了一系列操作，如map、filter、reduce等，以支持复杂的查询和转
阅读更多...
Vim使用基础篇

Vim使用基础篇

本文内容大部分来自 vimtutor，自带的教程的总结。在终端输入vimtutor 即可进入教程。 先总结一下，然后再分别介绍正常模式，插入模式，和可视模式三种模式下的命令。 目录 看完以后的汇总 1.正常模式（Normal模式） 1.移动光标 2.删除 3.【:】输入符 4.撤销 5.替换 6.重复命令【. ; ,】 7.复制粘贴 8.缩进 2.插入模式 INSERT
阅读更多...
Java面试八股之怎么通过Java程序判断JVM是32位还是64位

Java面试八股之怎么通过Java程序判断JVM是32位还是64位

怎么通过Java程序判断JVM是32位还是64位 可以通过Java程序内部检查系统属性来判断当前运行的JVM是32位还是64位。以下是一个简单的方法： public class JvmBitCheck {public static void main(String[] args) {String arch = System.getProperty("os.arch");String dataM
阅读更多...
详细分析Springmvc中的@ModelAttribute基本知识（附Demo）

详细分析Springmvc中的@ModelAttribute基本知识（附Demo）

目录 前言1. 注解用法1.1 方法参数1.2 方法1.3 类 2. 注解场景2.1 表单参数2.2 AJAX请求2.3 文件上传 3. 实战4. 总结 前言 将请求参数绑定到模型对象上，或者在请求处理之前添加模型属性 可以在方法参数、方法或者类上使用 一般适用这几种场景： 表单处理：通过 @ModelAttribute 将表单数据绑定到模型对象上预处理逻辑：在请求处理之前
阅读更多...
eclipse运行springboot项目，找不到主类

eclipse运行springboot项目，找不到主类

解决办法尝试了很多种，下载sts压缩包行不通。最后解决办法如图： help--->Eclipse Marketplace--->Popular--->找到Spring Tools 3---->Installed。
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2