备案控制台
探索云世界
开发者社区 数据库 文章 正文

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

2014-03-21 788
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 版权声明：本文为博主原创文章，未经博主允许不得转载。 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
关键词：
数据库jdbc
数据库操作
jdbc封装
数据库封装
jdbc操作
聚优云惠
目录
相关文章
穆雄雄.
|
26天前
|
SQL 数据库连接 数据库
你不知道ADo.Net中操作数据库的步骤【超详细整理】
你不知道ADo.Net中操作数据库的步骤【超详细整理】
穆雄雄.
15 0
仍在探索未知中
|
3月前
|
SQL 关系型数据库 MySQL
MySQL | 数据库的管理和操作【表的增删改查】（一）
MySQL | 数据库的管理和操作【表的增删改查】
仍在探索未知中
146 0
仍在探索未知中
|
3月前
|
SQL 关系型数据库 MySQL
MySQL | 数据库的管理和操作【表的增删改查】（二）
MySQL | 数据库的管理和操作【表的增删改查】（二）
仍在探索未知中
151 0
穆雄雄.
|
26天前
|
安全 Java 数据库连接
jdbc实现批量给多个表中更新数据（解析Excel表数据插入到数据库中）
jdbc实现批量给多个表中更新数据（解析Excel表数据插入到数据库中）
穆雄雄.
153 0
不会就选C.
|
1月前
|
缓存 NoSQL 数据库
[Redis]——数据一致性，先操作数据库，还是先更新缓存？
[Redis]——数据一致性，先操作数据库，还是先更新缓存？
不会就选C.
26 0
起飞的风筝
|
1月前
|
SQL 存储 关系型数据库
【mysql】—— 数据库的操作
【mysql】—— 数据库的操作
起飞的风筝
49 0
【mysql】—— 数据库的操作
麒麟改bug
|
2月前
|
SQL Java 数据库连接
JDBC如何封装成Mybaits持久层框架只需4
本文主要讲解JDBC怎么演变到Mybatis的渐变过程，重点讲解了为什么要将JDBC封装成Mybaits这样一个持久层框架。再而论述Mybatis作为一个数据持久层框架本身有待改进之处。
麒麟改bug
16 0
爱学习的千影
|
2月前
|
存储 SQL 数据库连接
连接并操作数据库：Python 数据库案例
数据库是一种用于存储和管理数据的工具，它以一种有组织的方式将数据存储在文件或内存中，以便于检索和处理。数据库系统通常使用 SQL（Structured Query Language）语言来进行数据的操作，包括数据的插入、查询、更新和删除等。
爱学习的千影
22 1
红目香薰
|
2月前
|
前端开发 数据库连接 数据库
ASP.NETMVC数据库完整CRUD操作示例
ASP.NETMVC数据库完整CRUD操作示例
红目香薰
29 0
童小纯
|
2月前
|
SQL druid Java
JDBC技术【分页查询、数据库连接池、应用程序分层、封装通用的BaseDao】(四)-全面详解（学习总结---从入门到深化）
JDBC技术【分页查询、数据库连接池、应用程序分层、封装通用的BaseDao】(四)-全面详解（学习总结---从入门到深化）
童小纯
28 0

热门文章

最新文章

  • 1
    性能工具之JMeter JDBC Request 基础
  • 2
    TiDB的优势：为何选择TiDB作为您的数据库解决方案
  • 3
    [Redis]——数据一致性，先操作数据库，还是先更新缓存？
  • 4
    Flink扩展问题之jdbc connector扩展失败如何解决
  • 5
    Flink cdc报错问题之使用jdbc connector报错如何解决
  • 6
    Java的JDBC编程
  • 7
    Flink报错问题之jdbc表报错如何解决
  • 8
    [SQL]SQL注入与SQL执行过程（基于JDBC）
  • 9
    JDBC PreparedStatement 字段值为null导致TBase带宽飙升的案例分析
  • 10
    使用Mybatis与直觉用jdbc相比，哪个更有优势？
  • 1
    TiDB的优势：为何选择TiDB作为您的数据库解决方案
    69
  • 2
    [Redis]——数据一致性，先操作数据库，还是先更新缓存？
    26
  • 3
    阿里云数据库使用方法，从购买、创建数据库账号密码到连接数据库全流程
    326
  • 4
    【mysql】—— 数据库的操作
    49
  • 5
    悦数图数据库推出 AI 知识图谱构建器及图语言生成助手
    32
  • 6
    Windows公网远程连接MongoDB数据库【无公网IP】
    43
  • 7
    嵌入式数据库sqlite3【基础篇】基本命令操作，小白一看就懂（C/C++）
    410
  • 8
    Java代码高效连接数据库
    15
  • 9
    如何处理爬取到的数据，例如存储到数据库或文件中？
    32
  • 10
    Python中使用pymysql和pymssql进行数据库操作的完整指南
    121

    • 相关课程

    更多
  • 数据库的前世今生
  • 数据库核心概念
  • 从传统数据库到云数据库演进
  • 数据库常见问题排查
  • 数据库及SQL/MySQL基础
  • 高校精品课-西安交通大学 -数据库理论与技术

    • 相关电子书

    更多
  • 2022 DTCC-阿里云一站式数据库上云最佳实践
  • 云时代的数据库技术趋势
  • 超大型金融机构国产数据库全面迁移成功实践

    • 相关实验场景

    更多
  • PolarDB for AI：在数据库中通过SQL实现AI能力
  • 云原生HTAP数据库，让你的交易和分析一库搞定
  • Excel文件转存到RDS数据库
  • 快速体验PolarDB开源数据库
  • 手把手教你把IoT传感器数据存储到数据库
  • WorkBench操作云上数据库
    • 下一篇
    部署LAMP环境（Alibaba Cloud Linux 3）
    为什么选择阿里云什么是云计算全球基础设施技术领先稳定可靠安全合规分析师报告
    产品和定价全部产品免费试用产品动态产品定价价格计算器云上成本管理
    解决方案技术解决方案
    文档与社区文档开发者社区天池大赛培训与认证
    权益中心免费试用高校计划企业扶持计划推荐返现计划
    支持与服务基础服务企业增值服务迁云服务官网公告健康看板信任中心
    关注阿里云
    关注阿里云公众号或下载阿里云APP，关注云资讯，随时随地运维管控云服务
    阿里云APP阿里云微信
    联系我们：4008013260
    法律声明Cookies政策廉正举报安全举报联系我们加入我们
    阿里巴巴集团淘宝网天猫全球速卖通阿里巴巴国际交易市场1688阿里妈妈飞猪阿里云计算AliOS万网高德UC友盟优酷钉钉支付宝达摩院淘宝海外阿里云盘饿了么
    © 2009-2024 Aliyun.com 版权所有 增值电信业务经营许可证： 浙B2-20080101 域名注册服务机构许可： 浙D3-20210002 京D3-20220015
    浙公网安备 33010602009975号浙B2-20080101-4