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

简介: 版权声明:本文为博主原创文章,未经博主允许不得转载。 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(3new java.sql.Date(newDate().getTime()); 
07                     ps.setTimestamp(4new 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(3new java.sql.Date(newDate().getTime()); 
07                     ps.setTimestamp(4new 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 }  
相关文章
|
21天前
|
Oracle 关系型数据库 Java
实时计算 Flink版操作报错之读取Oracle数据库时遇到找不到驱动,是什么原因
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
实时计算 Flink版操作报错之读取Oracle数据库时遇到找不到驱动,是什么原因
|
20天前
|
SQL 关系型数据库 MySQL
实时计算 Flink版产品使用合集之数据库执行的是UPDATE操作,那么Flink监听到的类型是什么
实时计算Flink版作为一种强大的流处理和批处理统一的计算框架,广泛应用于各种需要实时数据处理和分析的场景。实时计算Flink版通常结合SQL接口、DataStreamAPI、以及与上下游数据源和存储系统的丰富连接器,提供了一套全面的解决方案,以应对各种实时计算需求。其低延迟、高吞吐、容错性强的特点,使其成为众多企业和组织实时数据处理首选的技术平台。以下是实时计算Flink版的一些典型使用合集。
|
21天前
|
Java 关系型数据库 数据库连接
实时计算 Flink版操作报错之在使用JDBC连接MySQL数据库时遇到报错,识别不到jdbc了,怎么解决
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
|
2天前
|
分布式计算 DataWorks API
DataWorks操作报错合集之数据集成同步到本地数据库时,出现报错,如何解决
DataWorks是阿里云提供的一站式大数据开发与治理平台,支持数据集成、数据开发、数据服务、数据质量管理、数据安全管理等全流程数据处理。在使用DataWorks过程中,可能会遇到各种操作报错。以下是一些常见的报错情况及其可能的原因和解决方法。
|
2天前
|
SQL 关系型数据库 MySQL
Python 操作 MySQL 数据库
Python 操作 MySQL 数据库
|
5天前
|
NoSQL JavaScript 安全
精心操作MongoDB:删除数据库的关键步骤和重要事项
精心操作MongoDB:删除数据库的关键步骤和重要事项
|
6天前
|
关系型数据库 数据库连接 分布式数据库
PolarDB操作报错合集之数据库访问量低时,可以正常连接数据库,访问量高了所有用户都连接不了数据库,为什么
PolarDB是阿里云推出的一种云原生数据库服务,专为云设计,提供兼容MySQL、PostgreSQL的高性能、低成本、弹性可扩展的数据库解决方案,可以有效地管理和优化PolarDB实例,确保数据库服务的稳定、高效运行。以下是使用PolarDB产品的一些建议和最佳实践合集。
|
7天前
|
Java 数据库连接 数据库
Spring日志完结篇,MyBatis操作数据库(入门)
Spring日志完结篇,MyBatis操作数据库(入门)
|
7天前
|
存储 SQL 数据可视化
【Databend】数据库和表操作
【Databend】数据库和表操作
|
12天前
|
SQL Java 数据库连接
Java JDBC连接与操作深度解析
Java JDBC连接与操作深度解析
12 1