JdbcTemplate主要提供以下五类方法:_jdbctemplate常用方法-程序员宅基地

JdbcTemplate主要提供以下五类方法:

  • execute方法:可以用于执行任何SQL语句,一般用于执行DDL语句;
  • update方法及batchUpdate方法:update方法用于执行新增、修改、删除等语句;batchUpdate方法用于执行批处理相关语句;
  • query方法及queryForXXX方法:用于执行查询相关语句;
  • call方法:用于执行存储过程、函数相关语句。

 

JdbcTemplate类支持的回调类:

  • 预编译语句及存储过程创建回调:用于根据JdbcTemplate提供的连接创建相应的语句;

         PreparedStatementCreator:通过回调获取JdbcTemplate提供的Connection,由用户使用该Conncetion创建相关的PreparedStatement

         CallableStatementCreator通过回调获取JdbcTemplate提供的Connection,由用户使用该Conncetion创建相关的CallableStatement

  • 预编译语句设值回调:用于给预编译语句相应参数设值;

         PreparedStatementSetter通过回调获取JdbcTemplate提供的PreparedStatement,由用户来对相应的预编译语句相应参数设值;

         BatchPreparedStatementSetter:;类似于PreparedStatementSetter,但用于批处理,需要指定批处理大小;

  • 自定义功能回调:提供给用户一个扩展点,用户可以在指定类型的扩展点执行任何数量需要的操作;

         ConnectionCallback通过回调获取JdbcTemplate提供的Connection,用户可在该Connection执行任何数量的操作;

         StatementCallback通过回调获取JdbcTemplate提供的Statement,用户可以在该Statement执行任何数量的操作;

         PreparedStatementCallback通过回调获取JdbcTemplate提供的PreparedStatement,用户可以在该PreparedStatement执行任何数量的操作;

         CallableStatementCallback通过回调获取JdbcTemplate提供的CallableStatement,用户可以在该CallableStatement执行任何数量的操作;

  • 结果集处理回调:通过回调处理ResultSet或将ResultSet转换为需要的形式;

         RowMapper用于将结果集每行数据转换为需要的类型,用户需实现方法mapRow(ResultSet rs, int rowNum)来完成将每行数据转换为相应的类型。

         RowCallbackHandler用于处理ResultSet的每一行结果,用户需实现方法processRow(ResultSet rs)来完成处理,在该回调方法中无需执行rs.next(),该操作由JdbcTemplate来执行,用户只需按行获取数据然后处理即可。

         ResultSetExtractor用于结果集数据提取,用户需实现方法extractData(ResultSet rs)来处理结果集,用户必须处理整个结果集;

 

接下来让我们看下具体示例吧,在示例中不可能介绍到JdbcTemplate全部方法及回调类的使用方法,我们只介绍代表性的,其余的使用都是类似的;

 

 

1)预编译语句及存储过程创建回调、自定义功能回调使用:

 

java代码:

Java代码  

 

  1. public void testPpreparedStatement1() {  
  2.   int count = jdbcTemplate.execute(new PreparedStatementCreator() {  
  3.      @Override  
  4.      public PreparedStatement createPreparedStatement(Connection conn)  
  5.          throws SQLException {  
  6.          return conn.prepareStatement("select count(*) from test");  
  7.      }}, new PreparedStatementCallback<Integer>() {  
  8.      @Override  
  9.      public Integer doInPreparedStatement(PreparedStatement pstmt)  
  10.          throws SQLException, DataAccessException {  
  11.          pstmt.execute();  
  12.          ResultSet rs = pstmt.getResultSet();  
  13.          rs.next();  
  14.          return rs.getInt(1);  
  15.       }});      
  16.    Assert.assertEquals(0, count);  
  17. }  
  18.    

 

首先使用PreparedStatementCreator创建一个预编译语句,其次由JdbcTemplate通过PreparedStatementCallback回调传回,由用户决定如何执行该PreparedStatement。此处我们使用的是execute方法。

 

2)预编译语句设值回调使用:

 

java代码:

Java代码  

  1.         
  2. public void testPreparedStatement2() {  
  3.   String insertSql = "insert into test(name) values (?)";  
  4.   int count = jdbcTemplate.update(insertSql, new PreparedStatementSetter() {  
  5.       @Override  
  6.       public void setValues(PreparedStatement pstmt) throws SQLException {  
  7.           pstmt.setObject(1, "name4");  
  8.   }});  
  9.   Assert.assertEquals(1, count);      
  10.   String deleteSql = "delete from test where name=?";  
  11.   count = jdbcTemplate.update(deleteSql, new Object[] {"name4"});  
  12.   Assert.assertEquals(1, count);  
  13. }  

 

      通过JdbcTemplateint update(String sql, PreparedStatementSetter pss)执行预编译sql,其中sql参数为“insert into test(name) values (?) ”,该sql有一个占位符需要在执行前设值,PreparedStatementSetter实现就是为了设值,使用setValues(PreparedStatement pstmt)回调方法设值相应的占位符位置的值。JdbcTemplate也提供一种更简单的方式“update(String sql, Object... args)”来实现设值,所以只要当使用该种方式不满足需求时才应使用PreparedStatementSetter

 

3)结果集处理回调:

 

java代码:

Java代码  

 

  1. public void testResultSet1() {  
  2.   jdbcTemplate.update("insert into test(name) values('name5')");  
  3.   String listSql = "select * from test";  
  4.   List result = jdbcTemplate.query(listSql, new RowMapper<Map>() {  
  5.       @Override  
  6.       public Map mapRow(ResultSet rs, int rowNum) throws SQLException {  
  7.           Map row = new HashMap();  
  8.           row.put(rs.getInt("id"), rs.getString("name"));  
  9.           return row;  
  10.   }});  
  11.   Assert.assertEquals(1, result.size());  
  12.   jdbcTemplate.update("delete from test where name='name5'");       
  13. }  

 

RowMapper接口提供mapRow(ResultSet rs, int rowNum)方法将结果集的每一行转换为一个Map,当然可以转换为其他类,如表的对象画形式。

 

java代码:

Java代码  

 

  1. public void testResultSet2() {  
  2.   jdbcTemplate.update("insert into test(name) values('name5')");  
  3.   String listSql = "select * from test";  
  4.   final List result = new ArrayList();  
  5.   jdbcTemplate.query(listSql, new RowCallbackHandler() {  
  6.       @Override  
  7.       public void processRow(ResultSet rs) throws SQLException {  
  8.           Map row = new HashMap();  
  9.           row.put(rs.getInt("id"), rs.getString("name"));  
  10.           result.add(row);  
  11.   }});  
  12.   Assert.assertEquals(1, result.size());  
  13.   jdbcTemplate.update("delete from test where name='name5'");  
  14. }  

 

RowCallbackHandler接口也提供方法processRow(ResultSet rs),能将结果集的行转换为需要的形式。

 

java代码:

Java代码  

 

  1. public void testResultSet3() {  
  2.   jdbcTemplate.update("insert into test(name) values('name5')");  
  3.   String listSql = "select * from test";  
  4.   List result = jdbcTemplate.query(listSql, new ResultSetExtractor<List>() {  
  5.       @Override  
  6.       public List extractData(ResultSet rs)  
  7.      throws SQLException, DataAccessException {  
  8.           List result = new ArrayList();  
  9.           while(rs.next()) {  
  10.               Map row = new HashMap();  
  11.               row.put(rs.getInt("id"), rs.getString("name"));  
  12.               result.add(row);  
  13.            }  
  14.            return result;  
  15.   }});  
  16.   Assert.assertEquals(0, result.size());  
  17.   jdbcTemplate.update("delete from test where name='name5'");  
  18. }  

 

ResultSetExtractor使用回调方法extractData(ResultSet rs)提供给用户整个结果集,让用户决定如何处理该结果集。

 

当然JdbcTemplate提供更简单的queryForXXX方法,来简化开发:

 

java代码:

Java代码  

  1. //1.查询一行数据并返回int型结果  
  2. jdbcTemplate.queryForInt("select count(*) from test");  
  3. //2. 查询一行数据并将该行数据转换为Map返回  
  4. jdbcTemplate.queryForMap("select * from test where name='name5'");  
  5. //3.查询一行任何类型的数据,最后一个参数指定返回结果类型  
  6. jdbcTemplate.queryForObject("select count(*) from test", Integer.class);  
  7. //4.查询一批数据,默认将每行数据转换为Map       
  8. jdbcTemplate.queryForList("select * from test");  
  9. //5.只查询一列数据列表,列类型是String类型,列名字是name  
  10. jdbcTemplate.queryForList("  
  11. select name from test where name=?", new Object[]{"name5"}, String.class);  
  12. //6.查询一批数据,返回为SqlRowSet,类似于ResultSet,但不再绑定到连接上  
  13. SqlRowSet rs = jdbcTemplate.queryForRowSet("select * from test");  

 

3 存储过程及函数回调:

首先修改JdbcTemplateTestsetUp方法,修改后如下所示:

 

 

java代码:

Java代码  

  1.       
  2. @Before  
  3. public void setUp() {  
  4.     String createTableSql = "create memory table test" +  
  5.     "(id int GENERATED BY DEFAULT AS IDENTITY PRIMARY KEY, " +  
  6.     "name varchar(100))";  
  7.     jdbcTemplate.update(createTableSql);  
  8.          
  9.     String createHsqldbFunctionSql =  
  10.       "CREATE FUNCTION FUNCTION_TEST(str CHAR(100)) " +  
  11.       "returns INT begin atomic return length(str);end";  
  12.     jdbcTemplate.update(createHsqldbFunctionSql);  
  13.     String createHsqldbProcedureSql =  
  14.       "CREATE PROCEDURE PROCEDURE_TEST" +  
  15.       "(INOUT inOutName VARCHAR(100), OUT outId INT) " +  
  16.       "MODIFIES SQL DATA " +  
  17.       "BEGIN ATOMIC " +  
  18.       "  insert into test(name) values (inOutName); " +  
  19.       "  SET outId = IDENTITY(); " +  
  20.       "  SET inOutName = 'Hello,' + inOutName; " +  
  21.     "END";  
  22.     jdbcTemplate.execute(createHsqldbProcedureSql);  
  23. }  

 

       其中CREATE FUNCTION FUNCTION_TEST用于创建自定义函数,CREATE PROCEDURE PROCEDURE_TEST用于创建存储过程,注意这些创建语句是数据库相关的,本示例中的语句只适用于HSQLDB数据库。

 

       其次修改JdbcTemplateTesttearDown方法,修改后如下所示:

 

java代码:

Java代码  

 

  1. public void tearDown() {  
  2.     jdbcTemplate.execute("DROP FUNCTION FUNCTION_TEST");  
  3.     jdbcTemplate.execute("DROP PROCEDURE PROCEDURE_TEST");  
  4.     String dropTableSql = "drop table test";  
  5.     jdbcTemplate.execute(dropTableSql);  
  6. }  

 

       其中drop语句用于删除创建的存储过程、自定义函数及数据库表。

 

       接下来看一下hsqldb如何调用自定义函数:

 

java代码:

Java代码  

 

  1. public void testCallableStatementCreator1() {  
  2.     final String callFunctionSql = "{call FUNCTION_TEST(?)}";  
  3.     List<SqlParameter> params = new ArrayList<SqlParameter>();  
  4.     params.add(new SqlParameter(Types.VARCHAR));  
  5.     params.add(new SqlReturnResultSet("result",  
  6.        new ResultSetExtractor<Integer>() {  
  7.            @Override  
  8.            public Integer extractData(ResultSet rs) throws SQLException,  
  9.                DataAccessException {  
  10.                while(rs.next()) {  
  11.                    return rs.getInt(1);  
  12.                }  
  13.               return 0;  
  14.        }));  
  15.     Map<String, Object> outValues = jdbcTemplate.call(  
  16.        new CallableStatementCreator() {  
  17.             @Override  
  18.             public CallableStatement createCallableStatement(Connection conn) throws SQLException {  
  19.               CallableStatement cstmt = conn.prepareCall(callFunctionSql);  
  20.               cstmt.setString(1, "test");  
  21.               return cstmt;  
  22.     }}, params);  
  23.     Assert.assertEquals(4, outValues.get("result"));  
  24. }  
  25.    

 

  • {call FUNCTION_TEST(?)}定义自定义函数的sql语句,注意hsqldb {?= call …}{call …}含义是一样的,而比如mysql中两种含义是不一样的;
  • params:用于描述自定义函数占位符参数或命名参数类型;SqlParameter用于描述IN类型参数、SqlOutParameter用于描述OUT类型参数、SqlInOutParameter用于描述INOUT类型参数、SqlReturnResultSet用于描述调用存储过程或自定义函数返回的ResultSet类型数据,其中SqlReturnResultSet需要提供结果集处理回调用于将结果集转换为相应的形式,hsqldb自定义函数返回值是ResultSet类型。
  • CallableStatementCreator提供Connection对象用于创建CallableStatement对象
  • outValues:调用call方法将返回类型为Map<String, Object>对象;
  • outValues.get("result")获取结果,即通过SqlReturnResultSet对象转换过的数据;其中SqlOutParameterSqlInOutParameterSqlReturnResultSet指定的name用于从call执行后返回的Map中获取相应的结果,即nameMap的键。

注:因为hsqldb {?= call …}{call …}含义是一样的,因此调用自定义函数将返回一个包含结果的ResultSet

 

最后让我们示例下mysql如何调用自定义函数:

 

java代码:

Java代码  

 

  1. public void testCallableStatementCreator2() {  
  2.     JdbcTemplate mysqlJdbcTemplate = new JdbcTemplate(getMysqlDataSource);  
  3.     //2.创建自定义函数  
  4. String createFunctionSql =  
  5.     "CREATE FUNCTION FUNCTION_TEST(str VARCHAR(100)) " +  
  6.      "returns INT return LENGTH(str)";  
  7. String dropFunctionSql = "DROP FUNCTION IF EXISTS FUNCTION_TEST";  
  8. mysqlJdbcTemplate.update(dropFunctionSql);         
  9. mysqlJdbcTemplate.update(createFunctionSql);  
  10. //3.准备sql,mysql支持{?= call …}  
  11. final String callFunctionSql = "{?= call FUNCTION_TEST(?)}";  
  12. //4.定义参数  
  13. List<SqlParameter> params = new ArrayList<SqlParameter>();  
  14. params.add(new SqlOutParameter("result", Types.INTEGER));  
  15. params.add(new SqlParameter("str", Types.VARCHAR));  
  16. Map<String, Object> outValues = mysqlJdbcTemplate.call(  
  17. new CallableStatementCreator() {  
  18.     @Override  
  19.     public CallableStatement createCallableStatement(Connection conn) throws SQLException {  
  20.       CallableStatement cstmt = conn.prepareCall(callFunctionSql);  
  21.       cstmt.registerOutParameter(1, Types.INTEGER);  
  22.       cstmt.setString(2, "test");  
  23.         return cstmt;  
  24.     }}, params);  
  25.    Assert.assertEquals(4, outValues.get("result"));  
  26. }  
  27. public
版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/qmdweb/article/details/81224330

智能推荐

freeRTOS学习 — 事件标志组,很好用哦!!!_freertos里成功标志位用什么好-程序员宅基地

文章浏览阅读1.4k次。freeRTOS中还有一种可以用于任务之间同步的手段 — 事件标志组。_freertos里成功标志位用什么好

cad命令栏怎么调出来_中望CAD菜单栏和功能栏都消失怎么办-程序员宅基地

文章浏览阅读4.9k次。在我们使用中望CAD的时候,有时候会发现菜单栏和功能栏都消失不见了,这时候我们很多操作习惯可能就可能无法实现,当遇到这个问题我们该怎么办了?首先,我使用中望CAD安装包进行重新安装,但是还是没有作用,这时候可能确认的是并非软件问题,而是我们操作中出现的问题。第二,我们可以选择的方法有两种,第一就是用命令行输入命令去解决,第二就是使用我们常用的鼠标去进行操作。(1)用命令行的方法:1、在中望CAD..._中望cad命令栏不见了

xmysql:可为MySql生成REST API的神奇命令_mysql x devapi-程序员宅基地

文章浏览阅读1.5w次,点赞2次,收藏14次。原文:xmysql: one command to generate REST APIs for any MySql database 作者:o1lab 翻译:Vincent为什么用这个命令?为MySql数据库快速生成REST API,而且还不遵循诸如rails、django等框架的约定,这可能是一种不太受欢迎的冒险行为。 但是也正因为如此。该命令的功能都是由node packa_mysql x devapi

【java web毕业设计】 基于opencv与SVM的车牌识别系统_车牌识别 毕业设计 web-程序员宅基地

文章浏览阅读68次。基于opencv与SVM的车牌识别系统用python3+opencv3做的中国车牌识别,包括算法和客户端界面,只有2个文件,surface.py是界面代码,predict.py是算法代码,界面不是重点所以用tkinter写得很简单。python3.7.3opencv4.0.0.21numpy1.16.2TkinterPIL5.4.1算法思想来自于网上资源,先使用图像边缘和车牌颜色定位车牌,再识别字符。由于训练样本有限,测试时会发现,车牌字符识别,可能存在误差,尤其是第一个中文字符出现的误差概率较大_车牌识别 毕业设计 web

计算机系统要素-从零开始构建现代计算机-答案_计算机系统要素:从零开始构建现-程序员宅基地

文章浏览阅读1.6k次,点赞3次,收藏16次。关于这本书的好处 豆瓣上已经有一堆人说了 我就不重复了 直接附上项目答案练习题答案全套工具这本书的PDF可以百度自己下载内容简介本书通过展现简单但功能强大的计算机系统之构建过程,为读者呈现了一幅完整、严格的计算机应用科学大图景。本书作者认为,理解计算机工作原理的最好方法就是亲自动手,从零开始构建计算机系统。通过12个章节和项目来引领读者从头开始,本书逐步地构建一个基本的硬件平台和现代..._计算机系统要素:从零开始构建现

VMware虚拟机上Ubuntu与Windows XP文件共享_vmmuyub-程序员宅基地

文章浏览阅读3.4k次。现在使用虚拟机的人越来越多,它的确给我们带来了很大的方便。但是其中总会有一些问题困扰着我们,今天我就给大家讲一讲我的一点小小的经验。关于VMware虚拟机上Ubuntu与Windows XP文件共享的问题! 我的情况:本人电脑系统为Windows XP,在该系统上装了VMware 6.0虚拟机,并在虚拟机上安装了Ubuntu 9.04。最终实现了两系统的文件共享!(其他系统大同小略) 进入正题,以下为详细步骤: 一. 首先确保你的虚拟系统正确安装了VMware-Tools,并_vmmuyub

随便推点

webstorm 扩大内存_webstorm设置内存-程序员宅基地

文章浏览阅读1.1k次。个人感知-----vs/ws对于vscode 总是很多东西操作不熟练 还是喜欢用wenstorm ,可视化能力简直不要太好!!!但是不得不承认ws真的巨慢巨卡,尤其是公司电脑配置不高的情况下 更是恼火5分钟改个bug 提代码用了半小时。面对测试及其他人的冷眼斜视,我很无奈!!!更改一下内存设置,默认值为2M多一点 ,也是太慢好不好!所以玩命加!!!只能说还有是有点点效果的 操作切换分支时没有那么卡 持续找解决办法。。。。。..._webstorm设置内存

python docx官网_Python操作docx文档-程序员宅基地

文章浏览阅读1.2k次。最近学 Python 的一部分原因是我想用Python的docx包来写一个自动化生成word报告的脚本(需求产生动力),本来是打算用rmarkdown来出报告的,其对网页版支持比较好(样式也好看),对PDF支持也不错(毕竟可以依靠latex),但是对于word的可操作性并是不很好(可能使用的比较粗糙);最后听人说Python的docx包不错,专门对于window下的word进行操作,所以尝试下对于..._python word处理 官网

Un*、Id分别突变情况下单闭环直流调速系统仿真-程序员宅基地

文章浏览阅读1.7k次,点赞2次,收藏9次。P、PI调节器在直流电机调速上的MATLAB SIMULINK仿真分析

Kafka ACL(SASL/SCRAM-SHA-256)动态权限管理【windows】-程序员宅基地

文章浏览阅读2.1k次。Window系统下配置Kafka ACL SASL/SCRAM-SHA-256 模式动态权限管理_scram-sha-256

cad字体修改方案分享-缺少SHX字体、替换字体_cad缺少字体如何用万能字体替换-程序员宅基地

文章浏览阅读1.3w次,点赞3次,收藏13次。本文提供了cad缺少SHX字体时的解决方案,对于饱受每次打开都被提醒更换字体的兄弟有较大帮助。_cad缺少字体如何用万能字体替换

干货分享:在Windows下使用Visual Studio搭建C语言开发环境_visual studio c语言-程序员宅基地

文章浏览阅读4.3k次,点赞5次,收藏29次。前言:本文将教大家如何使用 VIsual Studio Code 搭建 C 语言开发环境,包括使用 VS Code 如何编译和调试 C 语言程序,需要 用到的工具有 Visual Studio Code 、MinGw-w64 。1. 安装 C/C++ 插件C/C++ 是由 Microsoft 发布的支持 C/C++ 智能提示和调试等功能的插件,安装步骤如下:使用快捷键Ctrl + Shift + X呼出扩展面板在搜索框中输入:C/C++再安装由Microsoft提供的名为C/C++插._visual studio c语言

推荐文章

热门文章

相关标签