Spring Batch之读数据库——JdbcCursorItemReader之自定义PreparedStatementSetter（三十八）

一、自定义PreparedStatementSetter

详情参考我的另一篇博客：

Spring Batch之读数据库——JdbcCursorItemReader（三十五）_人……杰的博客-CSDN博客

二、项目实例

1.项目实例

2.代码实现

BatchMain.java：

package com.xj.demo29;import org.springframework.batch.core.Job;
import org.springframework.batch.core.JobExecution;
import org.springframework.batch.core.JobParametersBuilder;
import org.springframework.batch.core.launch.JobLauncher;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
/*** @Author : xjfu* @Date : 2021/10/26 20:01* @Description : demo29 JdbcCursorItemReader之自定义PreparedStatementSetter*/
public class BatchMain {public static void main(String[] args) {ApplicationContext context = new ClassPathXmlApplicationContext("demo29/job/demo29-job.xml");//Spring Batch的作业启动器,JobLauncher launcher = (JobLauncher) context.getBean("jobLauncher");//在batch.xml中配置的一个作业Job job  = (Job)context.getBean("billJob");try{//开始执行这个作业,获得处理结果(要运行的job,job参数对象)JobExecution result = launcher.run(job, new JobParametersBuilder().addLong("time",System.currentTimeMillis())//主要是为了防止出现“A job instance already exists and is complete for parameters”异常.toJobParameters());System.out.println(result.toString());}catch (Exception e){e.printStackTrace();}}
}

CreditBill.java：

package com.xj.demo29;/*** @Author : xjfu* @Date : 2021/10/26 19:27* @Description :*/
public class CreditBill {//银行卡账户IDprivate String accountID = "";//持卡人姓名private String name = "";//消费金额private double amount = 0;//消费日期private String date = "";//消费场所private String address = "";public String getAccountID() {return accountID;}public void setAccountID(String accountID) {this.accountID = accountID;}public String getName() {return name;}public void setName(String name) {this.name = name;}public double getAmount() {return amount;}public void setAmount(double amount) {this.amount = amount;}public String getDate() {return date;}public void setDate(String date) {this.date = date;}public String getAddress() {return address;}public void setAddress(String address) {this.address = address;}@Overridepublic String toString() {return this.accountID + "," + this.name + "," + this.amount + "," + this.date + "," + this.address;}
}

CreditBillPreparedStatementSetter.java：

package com.xj.demo29;import org.springframework.jdbc.core.PreparedStatementSetter;
import java.sql.PreparedStatement;
import java.sql.SQLException;public class CreditBillPreparedStatementSetter implementsPreparedStatementSetter {public void setValues(PreparedStatement ps) throws SQLException {//此处设置第一个参数为“5”ps.setString(1, "5");}}

CreditBillProcessor.java：

package com.xj.demo29;import org.springframework.batch.item.ItemProcessor;public class CreditBillProcessor implementsItemProcessor<CreditBill, CreditBill> {public CreditBill process(CreditBill bill) throws Exception {System.out.println(bill.toString());return bill;}
}

CreditBillRowMapper.java：

package com.xj.demo29;import org.springframework.jdbc.core.RowMapper;
import java.sql.ResultSet;
import java.sql.SQLException;
/*** @Author : xjfu* @Date : 2023/7/17 01:31* @Description : 自定义RowMapper实现CreditBillRowMapper，将给定的结果集ResultSet转化为CreditBill对象*/
public class CreditBillRowMapper implements RowMapper<CreditBill> {public CreditBill mapRow(ResultSet rs, int rowNum) throws SQLException {CreditBill bill = new CreditBill();bill.setAccountID(rs.getString("ACCOUNTID"));bill.setAddress(rs.getString("ADDRESS"));bill.setAmount(rs.getDouble("AMOUNT"));bill.setDate(rs.getString("DATE"));bill.setName(rs.getString("NAME"));return bill;}
}

DummyCreditItemWriter.java：

package com.xj.demo29;import org.springframework.batch.item.ItemWriter;
import java.util.ArrayList;
import java.util.List;public class DummyCreditItemWriter implements ItemWriter<CreditBill> {public List<CreditBill> creditBills = new ArrayList<CreditBill>();public void write(List<? extends CreditBill> items) throws Exception {creditBills.addAll(items);}public List<CreditBill> getCredits() {return creditBills;}
}

demo29-job.xml：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:batch="http://www.springframework.org/schema/batch"xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/batch http://www.springframework.org/schema/batch/spring-batch.xsd"><!--导入文件--><import resource="classpath:demo29/job/demo29-jobContext.xml"/><!--定义名字为billJob的作业--><batch:job id="billJob"><!--定义名字为billStep的作业步--><batch:step id="billStep"><batch:tasklet transaction-manager="transactionManager"><!--定义读、处理、写操作，规定每处理两条数据，进行一次写入操作，这样可以提高写的效率--><batch:chunk reader="jdbcParameterItemReader" processor="creditBillProcessor" writer="creditItemWriter"   commit-interval="2"></batch:chunk></batch:tasklet></batch:step></batch:job>
</beans>

demo29-jobContext.xml：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:batch="http://www.springframework.org/schema/batch"xmlns:context="http://www.springframework.org/schema/context"xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/batch http://www.springframework.org/schema/batch/spring-batch.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd"><!--引入配置参数--><context:property-placeholder location="classpath:/demo29/properties/demo29-batch-mysql.properties" /><!--data-source:定义数据源，默认dataSourcetransaction-manager:定义事务管理器isolation-level-for-create:定义创建Job Execution时候的事务隔离级别，避免多个Job Execution执行一个Job Instance，默认SERIALIZABLEtable_prefix:定义使用的数据库表的前缀为BATCH_，默认BATCH_max-varchar-length:定义varchar的最大长度为1000，默认值为2500--><batch:job-repositoryid="jobRepository"data-source="dataSource"transaction-manager="transactionManager"isolation-level-for-create="SERIALIZABLE"table-prefix="BATCH_"max-varchar-length="1000"/><!--数据库的事务管理器--><bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"><property name="dataSource" ref="dataSource"/></bean><!--定义作业调度器，用来启动job--><bean id="jobLauncher" class="org.springframework.batch.core.launch.support.SimpleJobLauncher"><!--注入jobRepository--><property name="jobRepository" ref="jobRepository"/></bean><!--数据源--><bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource"><property name="driverClassName"><value>${datasource.driver}</value></property><property name="url"><value>${datasource.url}</value></property><property name="username" value="${datasource.username}"></property><property name="password" value="${datasource.password}"></property></bean><!-- 参数化读取db --><bean id="jdbcParameterItemReader" scope="step"class="org.springframework.batch.item.database.JdbcCursorItemReader" ><!--指定访问的数据源--><property name="dataSource" ref="dataSource"/><!--指定查询的SQL语句--><property name="sql" value="select ID,ACCOUNTID,NAME,AMOUNT,DATE,ADDRESS from t_credit where id between 1 and ? "/><property name="rowMapper" ref="custCreditRowMapper" /><!--使用自定义PreparedStatementSetter来设置SQL语句需要的参数--><property name="preparedStatementSetter" ref="custPreparedStatementSetter"/></bean><!--自定义PreparedStatementSetter--><bean id="custPreparedStatementSetter" class="com.xj.demo29.CreditBillPreparedStatementSetter"/><!--自定义RowMapper--><bean id="custCreditRowMapper" class="com.xj.demo29.CreditBillRowMapper"/><!--处理类--><bean id="creditBillProcessor" scope="step" class="com.xj.demo29.CreditBillProcessor"/><!--写类--><bean id="creditItemWriter" class="com.xj.demo29.DummyCreditItemWriter"/></beans>

create-tables-mysql.sql：

DROP TABLE IF EXISTS t_credit;
DROP TABLE IF EXISTS t_destcredit;CREATE TABLE t_credit(ID VARCHAR(10),ACCOUNTID VARCHAR(20),NAME VARCHAR(10),AMOUNT NUMERIC(10,2),DATE VARCHAR(20),ADDRESS VARCHAR(128),primary key (ID))ENGINE=InnoDB DEFAULT CHARSET=utf8;CREATE TABLE t_destcredit(ID VARCHAR(10),ACCOUNTID VARCHAR(20),NAME VARCHAR(10),AMOUNT NUMERIC(10,2),DATE VARCHAR(20),ADDRESS VARCHAR(128),primary key (ID))ENGINE=InnoDB DEFAULT CHARSET=utf8;INSERT INTO t_credit(ID,ACCOUNTID,NAME,AMOUNT,DATE,ADDRESS) VALUES('1','4047390012345678','tom',100.00,'2013-2-2 12:00:08','Lu Jia Zui road');
INSERT INTO t_credit(ID,ACCOUNTID,NAME,AMOUNT,DATE,ADDRESS) VALUES('2','4047390012345678','tom',320.00,'2013-2-3 10:35:21','Lu Jia Zui road');
INSERT INTO t_credit(ID,ACCOUNTID,NAME,AMOUNT,DATE,ADDRESS) VALUES('3','4047390012345678','tom',674.70,'2013-2-6 16:26:49','South Linyi road');
INSERT INTO t_credit(ID,ACCOUNTID,NAME,AMOUNT,DATE,ADDRESS) VALUES('4','4047390012345678','tom',793.20,'2013-2-9 15:15:37','Longyang road');
INSERT INTO t_credit(ID,ACCOUNTID,NAME,AMOUNT,DATE,ADDRESS) VALUES('5','4047390012345678','tom',360.00,'2013-2-11 11:12:38','Longyang road');

demo29-batch-mysql.properties：

datasource.driver=com.mysql.jdbc.Driver
datasource.url=jdbc:mysql://127.0.0.1:3306/spring_batch_demo1?serverTimezone=UTC
datasource.username=root
datasource.password=12345

3.运行结果

 

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.hqwc.cn/news/28448.html

如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

electron+vue3全家桶+vite项目搭建【23】url唤醒应用，并传递参数

electron+vue3全家桶+vite项目搭建【23】url唤醒应用，并传递参数

文章目录 引入实现效果实现步骤测试代码 引入 demo项目地址 很多场景下我们都希望通过url快速唤醒应用&#xff0c;例如百度网盘&#xff0c;在网页中唤醒应用&#xff0c;并传递下载链接&#xff0c;在electron中要实现这样的效果&#xff0c;就需要针对不同的平台做对应的处…
阅读更多...
【数学建模】——相关系数

【数学建模】——相关系数

第一部分&#xff1a;皮尔逊相关系数的计算以及数据的描述性统计 本讲我们将介绍两种最为常见的相关系数&#xff1a;皮尔逊person相关系数和斯皮尔曼spearman等级相关系数。它们可以用来衡量两个变量之间的相关性的大小&#xff0c;根据数组满足的不同条件&#xff0c;我们要选…
阅读更多...
3天学会Ascend C编程 | Day1 Ascend C基本概念及常用接口

3天学会Ascend C编程 | Day1 Ascend C基本概念及常用接口

本文分享自《【2023 CANN训练营第一季】——Ascend C算子开发入门——第一次课》&#xff0c;作者&#xff1a;weixin_54022960 。 Ascend C是华为昇腾面向算子开发场景的编程语言&#xff0c;使用C/C作为前端语言的算子开发工具&#xff0c;通过四层接口抽象、并行编程范式、…
阅读更多...
微服务系列文章 之 Nginx状态监控日志分析详解

微服务系列文章 之 Nginx状态监控日志分析详解

1、Nginx状态监控 Nginx提供了一个内置的状态信息监控页面可用于监控Nginx的整体访问情况&#xff0c;这个功能由ngx_http_stub_status_module模块进行实现。 使用nginx -V 2>&1 | grep -o with-http_stub_status_module命令检测当前Nginx是否有status功能&#xff0c…
阅读更多...
OpenMMLab MMTracking目标跟踪官方文档学习（一）

OpenMMLab MMTracking目标跟踪官方文档学习（一）

介绍 MMTracking 是PyTorch的开源视频感知工具箱。它是OpenMMLab项目的一部分。 它支持 4 个视频任务&#xff1a; 视频对象检测 (VID) 单目标跟踪 (SOT) 多目标跟踪 (MOT) 视频实例分割 (VIS) 主要特点 第一个统一视频感知平台 我们是第一个统一多功能视频感知任务的开源工…
阅读更多...
数据结构day4（2023.7.18）

数据结构day4（2023.7.18）

一、Xmind整理&#xff1a; 链表的插入和删除&#xff1a; 二、课上练习&#xff1a; 练习1&#xff1a;顺序表去重 33 22 22 11 11 i jfor(int i0;i<list->len-1;i){for(int ji1;j<len;j){if(list->data[i]list->data[j]){delete_by_sub(j,list); …
阅读更多...
WebRTC基础

WebRTC基础

有用的网址&#xff1a; https://webrtc.org/ WebRTC API - Web API 接口参考 | MDN Browser APIs and Protocols: WebRTC - High Performance Browser Networking(OReilly) 浏览器中查看webrtc运行的实时信息&#xff1a; Chrome浏览器&#xff1a;chrome://webrtc-inter…
阅读更多...
ArrayList和LinkedList

ArrayList和LinkedList

ArrayList的注意事项 1、在ArrayList中可以放任意元素&#xff0c;包括空值&#xff0c;任何元素&#xff0c;且可重复添加。 2、ArrayList底层是由数组来实现数据存储的 3、ArrayList基本等同于Vector&#xff0c;除了ArrayList是线程不安全(执行效率高),看源码 在多线程的…
阅读更多...
依赖注入三种方式，以及传统xml文件传参，还包括@Bean方式传参，还有Resource注入（详细版，每步都有提及）

依赖注入三种方式，以及传统xml文件传参，还包括@Bean方式传参，还有Resource注入（详细版，每步都有提及）

获取bean对象&#xff0c;也称为对象装配&#xff0c;对象注入&#xff0c;依赖注入。 对象装配的实现方法有3种&#xff1a; 1.属性注入&#xff1b; 2.构造方法注入&#xff1b; 3.Setter注入。 再讲本节内容之前&#xff0c;我们先来提两个传参的方式&#xff0c;首先呢…
阅读更多...
新手如何自学PostgreSQL(PG)

新手如何自学PostgreSQL(PG)

如果你是一个新手&#xff0c;想要自学PostgreSQL&#xff0c;下面是一些步骤和资源&#xff0c;可以帮助你入门&#xff1a; ①了解数据库基础知识&#xff1a;在开始学习PostgreSQL之前&#xff0c;建议你先了解一些数据库的基础概念和术语&#xff0c;例如表、列、行、SQL查…
阅读更多...
什么是芯片组，南桥与北桥芯片的作用与区别

什么是芯片组，南桥与北桥芯片的作用与区别

主板是连接计算机所有部件的PCB。在老式计算机中&#xff0c;所有芯片都分布在主板上。在现代计算机中&#xff0c;芯片数量减少并集中在特定位置。因此&#xff0c;将多个芯片组合起来形成一个芯片。这种可以替代大量芯片的芯片称为芯片组。主板上有一个芯片组。芯片组处理CPU…
阅读更多...
echarts开发遇到的问题

echarts开发遇到的问题

echarts开发遇到的问题 1.rich富文本标签作为横向柱状图的刻度标签&#xff0c;其中带有icon。rich里不能写参数&#xff0c;只能写死&#xff1f;圆角设置无效&#xff1f; 解决办法&#xff1a; 自己写横向柱状图 散点图性能优化配置的临界点&#xff0c;最低优化数值必须…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023