AI 助理
备案控制台
开发者社区 数据库 文章 正文

JdbcTemplate 来封装数据库jdbc操作细节

2014-03-21 830
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 版权声明：本文为博主原创文章，未经博主允许不得转载。 https://blog.csdn.net/qingfeng812/article/details/21703865 ...
版权声明：本文为博主原创文章，未经博主允许不得转载。 https://blog.csdn.net/qingfeng812/article/details/21703865

提供了JdbcTemplate 来封装数据库jdbc操作细节： 
包括： 数据库连接[打开/关闭] ，异常转义 ，SQL执行 ，查询结果的转换 

使用模板方式封装 jdbc数据库操作-固定流程的动作，提供丰富callback回调接口功能，方便用户自定义加工细节，更好模块化jdbc操作，简化传统的JDBC操作的复杂和繁琐过程。 

1) 使用JdbcTemplate 更新(insert /update /delete)

1 int k = jdbcTemplate.update("UPDATE tblname SET prop1=?,prop2=?...", newObject[]{...});

1 jdbcTemplate.update("INSERT INTO tblname VALUES(?,?,..)", new Object[]{...},
2      new int[]{Types.VARCHAR,Types.NUMERIC});

01 jdbcTemplate.update("INSERT INTO tblname VALUES(?,?,..)",                    
02         newPreparedStatementSetter(){                         
03                public void setValues(PreparedStatement ps) throwsSQLException{     
04                     ps.setLong(1, user.getId(1));
05                     ps.setString(2, user.getName(2));  
06                     ps.setDate(3, new java.sql.Date(newDate().getTime()); 
07                     ps.setTimestamp(4, new Timestamp(new Date().getTime());
08                }                    
09         }
10 );


2) 使用JdbcTemplate 查询 (select)

1 final User user = newUser();
2 jdbcTemplate.query("SELECT id,name,.. FROM tblname WHERE id=1",
3        newRowCallbackHandler(){
4               public void processRow(ResultSet rs) throwsSQLException{
5                     user.setId(rs.getLong(1));
6                     user.setName(rs.getString(2));
7               }
8       }
9 );

01 List uGroup = jdbcTemplate.query("SELECT id,name,.. FROM tblname WHERE igroup=1",
02      newRowMapper(){
03             public Object mapRow(ResultSet rs,int no) throwsSQLException{
04                      User user = newUser();
05                      user.setId(rs.getLong(1));
06                      user.setName(rs.getString(2));
07                      returnuser ;
08             }
09      }
10 };


3)使用JdbcTemplate 便捷方法

1 List uNames = jdbcTemplate.queryForList("SELECT name FROM tblname WHERE id>?",
2     new Integer []{5}, String.class);

1 List<Map> uMapList = (List<Map>) jdbcTemplate.queryForList( "SELECT id, name FROM tblname WHERE id>?",
2              newInteger []{5});
3 for(Map<String,Object> uMap :uMapList){
4       Integer id = uMap.get("id");
5       String name = uMap.get("name");
6 };

1 String user = jdbcTemplate.queryForObject("SELECT name FROM tblname WHERE id=?",
2      new Integer []{5}, String.class );

1 intuNum = jdbcTemplate.queryForInt("SELECT count(*) FROM tblname WHERE id>?",
2     new Integer []{5});



4)使用jdbc 操作类

a)扩展 MappingSqlQuery类

01 class JdbcQueryObject extends MappingSqlQuery { // extends SqlQuery
02       public JdbcQueryObject (DataSource ds,String sql){
03             this.setDataSource( ds );
04             this.setSql( sql );
05             this.declareParameter(newSqlparameter("propName",
06                 Types.VARCHAR);// propName 提示作用
07         this.compile();
08       }
09       public Object mapRow(ResultSet rs,int p) throws SQLException{
10                  // ...
11      }
12 }
13 JdbcQueryObject queryObj = new JdbcQueryObject( ds,
14       "SELECT .. FROM tblName WHERE param=?");
15 List list = queryObj.execute(new Object[]{...});

b)使用 SqlFunction 类 查询单条结果

1 SqlFunction queryFun = newSqlFunction( ds,
2       "select count(*) from tblName where ..." ,new int[]{Types.CHAR,...} );
3 queryFun.compile();
4 queryFun.run(new Object[]{p1,p2,..});

c)使用 SqlUpdate 类 更新

1 SqlUpdate updateFunc = new SqlUpdate(ds ,"INSERT tblName ...");
2 updateFunc.declareParameter( new SqlParameter("prop",Types.CHAR) );
3 updateFunc.compile();
4 updateFunc.update(new String[]{s1,s1});

5)支持jdbc 事务

spring的事务管理有两种方式：编程式事务、声明式事务

这里谈一下 基于数据库单一资源的编程式事务:

spring用实现TransactionDefinition接口的类定义事务的属性：传播行为；隔离级别；超时值；只读标志

默认实现为：DefaultTransactionDefinition类

01 PlatformTransactionManager tm = 
02 newDataSourceTransactionManager(
03             jdbcTemplate.getDataSource() );
04 TransactionStatus status = null;
05 try{
06     //null 默认事务属性配置DefaultTransactionDefinition
07     status = tm.getTransaction(null);          
08   for(finalString wd: words){         
09    try {
10      jdbcTemplate.update( insertWordSql,
11           new PreparedStatementSetter(){
12  
13     public voidsetValues(PreparedStatement pstate)
14                      throws SQLException {
15                 pstate.setString(1, wd) ;
16         pstate.setTimestamp(2,
17         new Timestamp( newDate().getTime() ));                            
18     }                  
19         }
20      );                
21              
22    } catch (DataAccessException e) {
23        e.printStackTrace();
24        //tm.rollback(status);
25     }
26     } // end for
27 } finally {
28      tm.commit(status);
29 }  

提供了JdbcTemplate 来封装数据库jdbc操作细节： 
包括： 数据库连接[打开/关闭] ，异常转义 ，SQL执行 ，查询结果的转换 

使用模板方式封装 jdbc数据库操作-固定流程的动作，提供丰富callback回调接口功能，方便用户自定义加工细节，更好模块化jdbc操作，简化传统的JDBC操作的复杂和繁琐过程。 

1) 使用JdbcTemplate 更新(insert /update /delete)

1 int k = jdbcTemplate.update("UPDATE tblname SET prop1=?,prop2=?...", newObject[]{...});

1 jdbcTemplate.update("INSERT INTO tblname VALUES(?,?,..)", new Object[]{...},
2      new int[]{Types.VARCHAR,Types.NUMERIC});

01 jdbcTemplate.update("INSERT INTO tblname VALUES(?,?,..)",                    
02         newPreparedStatementSetter(){                         
03                public void setValues(PreparedStatement ps) throwsSQLException{     
04                     ps.setLong(1, user.getId(1));
05                     ps.setString(2, user.getName(2));  
06                     ps.setDate(3, new java.sql.Date(newDate().getTime()); 
07                     ps.setTimestamp(4, new Timestamp(new Date().getTime());
08                }                    
09         }
10 );


2) 使用JdbcTemplate 查询 (select)

1 final User user = newUser();
2 jdbcTemplate.query("SELECT id,name,.. FROM tblname WHERE id=1",
3        newRowCallbackHandler(){
4               public void processRow(ResultSet rs) throwsSQLException{
5                     user.setId(rs.getLong(1));
6                     user.setName(rs.getString(2));
7               }
8       }
9 );

01 List uGroup = jdbcTemplate.query("SELECT id,name,.. FROM tblname WHERE igroup=1",
02      newRowMapper(){
03             public Object mapRow(ResultSet rs,int no) throwsSQLException{
04                      User user = newUser();
05                      user.setId(rs.getLong(1));
06                      user.setName(rs.getString(2));
07                      returnuser ;
08             }
09      }
10 };


3)使用JdbcTemplate 便捷方法

1 List uNames = jdbcTemplate.queryForList("SELECT name FROM tblname WHERE id>?",
2     new Integer []{5}, String.class);

1 List<Map> uMapList = (List<Map>) jdbcTemplate.queryForList( "SELECT id, name FROM tblname WHERE id>?",
2              newInteger []{5});
3 for(Map<String,Object> uMap :uMapList){
4       Integer id = uMap.get("id");
5       String name = uMap.get("name");
6 };

1 String user = jdbcTemplate.queryForObject("SELECT name FROM tblname WHERE id=?",
2      new Integer []{5}, String.class );

1 intuNum = jdbcTemplate.queryForInt("SELECT count(*) FROM tblname WHERE id>?",
2     new Integer []{5});



4)使用jdbc 操作类

a)扩展 MappingSqlQuery类

01 class JdbcQueryObject extends MappingSqlQuery { // extends SqlQuery
02       public JdbcQueryObject (DataSource ds,String sql){
03             this.setDataSource( ds );
04             this.setSql( sql );
05             this.declareParameter(newSqlparameter("propName",
06                 Types.VARCHAR);// propName 提示作用
07         this.compile();
08       }
09       public Object mapRow(ResultSet rs,int p) throws SQLException{
10                  // ...
11      }
12 }
13 JdbcQueryObject queryObj = new JdbcQueryObject( ds,
14       "SELECT .. FROM tblName WHERE param=?");
15 List list = queryObj.execute(new Object[]{...});

b)使用 SqlFunction 类 查询单条结果

1 SqlFunction queryFun = newSqlFunction( ds,
2       "select count(*) from tblName where ..." ,new int[]{Types.CHAR,...} );
3 queryFun.compile();
4 queryFun.run(new Object[]{p1,p2,..});

c)使用 SqlUpdate 类 更新

1 SqlUpdate updateFunc = new SqlUpdate(ds ,"INSERT tblName ...");
2 updateFunc.declareParameter( new SqlParameter("prop",Types.CHAR) );
3 updateFunc.compile();
4 updateFunc.update(new String[]{s1,s1});

5)支持jdbc 事务

spring的事务管理有两种方式：编程式事务、声明式事务

这里谈一下 基于数据库单一资源的编程式事务:

spring用实现TransactionDefinition接口的类定义事务的属性：传播行为；隔离级别；超时值；只读标志

默认实现为：DefaultTransactionDefinition类

01 PlatformTransactionManager tm = 
02 newDataSourceTransactionManager(
03             jdbcTemplate.getDataSource() );
04 TransactionStatus status = null;
05 try{
06     //null 默认事务属性配置DefaultTransactionDefinition
07     status = tm.getTransaction(null);          
08   for(finalString wd: words){         
09    try {
10      jdbcTemplate.update( insertWordSql,
11           new PreparedStatementSetter(){
12  
13     public voidsetValues(PreparedStatement pstate)
14                      throws SQLException {
15                 pstate.setString(1, wd) ;
16         pstate.setTimestamp(2,
17         new Timestamp( newDate().getTime() ));                            
18     }                  
19         }
20      );                
21              
22    } catch (DataAccessException e) {
23        e.printStackTrace();
24        //tm.rollback(status);
25     }
26     } // end for
27 } finally {
28      tm.commit(status);
29 }  
文章标签：
数据库
Java
数据库连接
SQL
Spring
关键词：
数据库封装
数据库jdbctemplate
数据库jdbc
封装jdbc
jdbctemplate数据库
聚优云惠
目录
相关文章
潜意识Java
|
1月前
|
SQL Java 关系型数据库
使用 JDBC 实现 Java 数据库操作
JDBC（Java Database Connectivity）是 Java 提供的数据库访问技术，允许通过 SQL 语句与数据库交互。本文详细介绍了 JDBC 的使用方法，包括环境准备、编程步骤和完整示例。
潜意识Java
141 7
东方睿赢
|
6月前
|
Java 关系型数据库 数据库连接
JDBC：Java与数据库的“黄金搭档”，为何它如此重要？
JDBC：Java与数据库的“黄金搭档”，为何它如此重要？
东方睿赢
67 8
龙大吉
|
6月前
|
Java 数据库连接 API
JDBC：Java数据库连接的“黑科技”大揭秘
JDBC：Java数据库连接的“黑科技”大揭秘
龙大吉
49 7
二流小码农
|
2月前
|
SQL 关系型数据库 API
HarmonyOs开发：关系型数据库封装之增删改查
每个方法都预留了多种调用方式，比如使用callback异步回调或者使用Promise异步回调，亦或者同步执行，大家在使用的过程中，可以根据自身业务需要进行选择性调用，也分别暴露了成功和失败的方法，可以针对性的判断在执行的过程中是否执行成功。
二流小码农
127 13
三三是该溜子
|
2月前
|
SQL Java 数据库连接
JDBC编程安装———通过代码操控数据库
本文，教你从0开始学习JBCD，包括驱动包的下载安装调试设置，以及java是如何通过JBDC实现对数据库的操作，以及代码的分析，超级详细
三三是该溜子
39 0
java冯坚持
|
4月前
|
Java 关系型数据库 MySQL
springboot学习四：springboot链接mysql数据库，使用JdbcTemplate 操作mysql
这篇文章是关于如何使用Spring Boot框架通过JdbcTemplate操作MySQL数据库的教程。
java冯坚持
257 0
springboot学习四：springboot链接mysql数据库，使用JdbcTemplate 操作mysql
nanshaws
|
4月前
|
SQL Java 数据库
Springboot+spring-boot-starter-data-jdbc实现数据库的操作
本文介绍了如何使用Spring Boot的spring-boot-starter-data-jdbc依赖来操作数据库，包括添加依赖、配置数据库信息和编写基于JdbcTemplate的数据访问代码。
nanshaws
562 2
Codelinghu
|
4月前
|
SQL druid Java
JDBC和数据库连接池-两个工具类-JDBCUtilsByDruid和BasicDAO
JDBC和数据库连接池-两个工具类-JDBCUtilsByDruid和BasicDAO
Codelinghu
248 0
东方睿赢
|
6月前
|
SQL Java 数据库连接
JDBC之旅：从陌生到熟悉的Java数据库连接之路
JDBC之旅：从陌生到熟悉的Java数据库连接之路
东方睿赢
47 9
龙大吉
|
6月前
|
SQL Java 数据库连接
Java开发者必知：JDBC连接数据库的“三大法宝”
Java开发者必知：JDBC连接数据库的“三大法宝”
龙大吉
68 7

热门文章

最新文章

  • 1
    Docker Compose V2 安装常用数据库MySQL+Mongo
  • 2
    【赵渝强老师】达梦数据库的产品系列
  • 3
    华为数据库openGauss与PostgreSQL使用对比
  • 4
    【上云基础系列04】基于标准架构的数据库升级
  • 5
    【02】Java+若依+vue.js技术栈实现钱包积分管理系统项目-商业级电玩城积分系统商业项目实战-ui设计图figmaUI设计准备-figma汉化插件-mysql数据库设计-优雅草卓伊凡商业项目实战
  • 6
    【SQL技术】不同数据库引擎 SQL 优化方案剖析
  • 7
    【01】Java+若依+vue.js技术栈实现钱包积分管理系统项目-商业级电玩城积分系统商业项目实战-需求改为思维导图-设计数据库-确定基础架构和设计-优雅草卓伊凡商业项目实战
  • 8
    如何排查和解决PHP连接数据库MYSQL失败写锁的问题
  • 9
    如何解决 MySQL 数据库服务器 CPU 飙升的情况
  • 10
    java语言后台管理ruoyi后台管理框架-登录提示“无效的会话，或者会话已过期，请重新登录。”-扩展知识数据库中密码加密的方法-问题如何解决-以及如何重置若依后台管理框架admin密码-优雅草卓伊凡
  • 1
    【YashanDB 知识库】oracle 与 yashanDB 的 jdbc 返回常量列"0.00"的精度和刻度不一致
    13
  • 2
    【潜意识Java】Java中JDBC过时方法的替代方案以及JDBC为什么过时详细分析
    44
  • 3
    Cause: dm.jdbc.driver.DMException: Digital overflow
    153
  • 4
    JDBC编程安装———通过代码操控数据库
    39
  • 5
    springboot java.lang.ClassNotFoundException: dm.jdbc.driver.DmDriver应该如何解决
    395
  • 6
    gbase8a JDBC常用特性-Kerberos认证方式连接
    84
  • 7
    JDBC常用特性-SSH隧道连接
    137
  • 8
    南大通用 GBase 8s JDBC字符集参数详解
    76
  • 9
    mysql5.7 jdbc驱动
    901
  • 10
    JDBC和数据库连接池-两个工具类-JDBCUtilsByDruid和BasicDAO
    248

    • 相关课程

    更多
  • 数据库核心概念
  • 数据库常见问题排查
  • JDBC数据库开发入门
  • 数据库及SQL/MySQL基础
  • JDBC数据库开发进阶
  • 高校精品课-西安交通大学 -数据库理论与技术

    • 相关电子书

    更多
  • DTCC 2022大会集锦《云原生一站式数据库技术与实践》
  • 阿里云瑶池数据库精要2022版
  • 2022 DTCC-阿里云一站式数据库上云最佳实践

    • 相关实验场景

    更多
  • 使用DAS实现数据库SQL优化
  • 自建数据库迁移到云数据库
  • PolarDB for AI：在数据库中通过SQL实现AI能力
  • 云原生HTAP数据库，让你的交易和分析一库搞定
  • 快速体验PolarDB开源数据库
  • SQLServer数据库的创建
    • 下一篇
    通义万相：视觉生成大模型再进化