快上网专注成都网站设计 成都网站制作 成都网站建设
成都网站建设公司服务热线:028-86922220

网站建设知识

十年网站开发经验 + 多家企业客户 + 靠谱的建站团队

量身定制 + 运营维护+专业推广+无忧售后,网站问题一站解决

spring利用batch实现读取多个文件并将文件导入数据库

spring利用 batch实现读取多个文件并将文件导入数据库?很多新手对此不是很清楚,为了帮助大家解决这个难题,下面小编将为大家详细讲解,有这方面需求的人可以来学习下,希望你能有所收获。

网站设计制作、成都网站制作中从网站色彩、结构布局、栏目设置、关键词群组等细微处着手,突出企业的产品/服务/品牌,帮助企业锁定精准用户,提高在线咨询和转化,使成都网站营销成为有效果、有回报的无锡营销推广。创新互联建站专业成都网站建设十年了,客户满意度97.8%,欢迎成都创新互联客户联系。

项目的目录结构

spring利用 batch实现读取多个文件并将文件导入数据库

需要读取文件的的数据格式

spring利用 batch实现读取多个文件并将文件导入数据库

applicatonContext.xml的配置

<?xml version="1.0" encoding="UTF-8"?>

  
  
  
    
  
  
    
    
  
     
   
     
   
   
   
   
   
  
    
      classpath:com/aliyun/springbatch/sample/db/jdbc.properties
    
  
   
  
    
    
    
    
  

batch.xml的配置

<?xml version="1.0" encoding="UTF-8"?>


  
  
  
  
  
    
      
        
        
      
    
  

  
  
  

    

    
  
    
  
  
  
  
  
  
  
   
    
    
      
      
        
      
    
    
    
      
        
      
    
   
  
 
 
 
  
  
  
  


jdbc.properties  MySQL数据源配置文件

#Oracle
#hibernate.dialect=org.hibernate.dialect.OracleDialect
#validationQuery.sqlserver=SELECT 1 FROM DUAL
#jdbc.driver=oracle.jdbc.driver.OracleDriver
#jdbc.url=jdbc:oracle:thin:@localhost:1521:orcl
#jdbc.username=activitproject
#jdbc.password=activitproject
#Mysql
jdbc.driver=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://127.0.0.1:3306/spring_batch_demo
jdbc.username=root
jdbc.password=root

封装数据的实体类就自己写吧 

测试主方法:

 public static void main(String[] args) {
    ApplicationContext context = new ClassPathXmlApplicationContext(
        "com/aliyun/springbatch/sample/db/batch.xml");
    JobLauncher launcher = (JobLauncher) context.getBean("jobLauncher");
    Job job = (Job) context.getBean("dbJob");

    try {
      
      // JOB执行,设置参数添加读取文件的路径
      JobExecution result = launcher.run(
          job,
          //添加job参数时,将读取的文件目录加入到job的参数中
          new JobParametersBuilder()
              .addString("inputFile",
                  "src/main/java/com/aliyun/springbatch/sample/db/inputFile*.csv")
              .toJobParameters());
      // 运行结果输出
      System.out.println(result.toString());
    } catch (Exception e) {
      e.printStackTrace();
    }
  }

看完上述内容是否对您有帮助呢?如果还想对相关知识有进一步的了解或阅读更多相关文章,请关注创新互联行业资讯频道,感谢您对创新互联的支持。


当前文章:spring利用batch实现读取多个文件并将文件导入数据库
标题网址:http://6mz.cn/article/igsicj.html

其他资讯