使用原生JDBC循环读取文件并持久化到数据库

分类：JDBC作者：编程之家用户

先上代码：

package com.demo.common.service;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.Properties;





public class ReadFileService {
    
    private static Integer counts = 0;
    
    private static Connection conn = null;
    private static PreparedStatement pre = null;
    
    //基础信息
    public static void getBase(String strPath) { 
        File dir = new File(strPath);
        File[] files = dir.listFiles(); // 该文件目录下文件全部放入数组
        List<String> filelist = new ArrayList<String>();
        if (files != null ) {
            for (int i = 0; i < files.length; i++) {
                String fileName = files[i].getName();
                String filetype = "";
                String filePath = "";
                String xmmc = "";
                if (files[i].isDirectory()) { // 判断是否文件夹，如果是文件夹则一直遍历
                    getBase(files[i].getAbsolutePath());
                } else { // 判断文件后缀
                    filelist.add(fileName);
                    filePath = files[i].getAbsolutePath().substring(0, files[i].getAbsolutePath().lastIndexOf("\\")+1);
                    if(!"".equals(filePath))filelist.add(filePath);
                    xmmc = fileName.substring(fileName.indexOf("年")-4, fileName.indexOf("."));
                    if(!"".equals(xmmc))filelist.add(xmmc);
                        if(fileName.endsWith("pdf")){
                            filetype = "12";
                        }else{
                            filetype = "11";
                        }
                    filelist.add(filetype);
                    String sql = "insert into g_files_db values (sys_guid(), ?, ?, ?, ?, to_char(sysdate,'yyyy-MM-dd'))";
                    try {
                        //int result = DataBaseHelper.update(sql, new Object[]{fileName,filePath,xmmc,filetype});
                        pre = conn.prepareStatement(sql);
                        pre.setString(1, fileName);
                        pre.setString(2, filePath);
                        pre.setString(3, xmmc);
                        pre.setString(4, filetype);
                        int result = pre.executeUpdate();
                        counts = counts + result;
                    } catch (Exception e) {
                        e.printStackTrace();
                        counts = -1;
                        return;
                    }
                    
                } 
            }
            
        }
    }
    
    //坐标信息
    public static void getCoordinate(String strPath) { 
        File dir = new File(strPath);
        File[] files = dir.listFiles(); // 该文件目录下文件全部放入数组
        List<String> filelist = new ArrayList<String>();
        if (files != null ) {
            for (int i = 0; i < files.length; i++) {
                String fileName = files[i].getName();
                String filetype = "";
                String filePath = "";
                String xmmc = "";
                if (files[i].isDirectory()) { // 判断是否文件夹，如果是文件夹则一直遍历
                    getCoordinate(files[i].getAbsolutePath());
                } else { // 判断文件后缀
                    filelist.add(fileName);
                    filePath = files[i].getAbsolutePath().substring(0, files[i].getAbsolutePath().lastIndexOf("\\")+1);
                    if(!"".equals(filePath))filelist.add(filePath);
                        xmmc = fileName.substring(fileName.indexOf("年")-4, fileName.indexOf("."));
                    if(!"".equals(xmmc))filelist.add(xmmc);
                    if(fileName.endsWith("prj")){
                        filetype = "32";
                    }else if(fileName.endsWith("dbf")){
                        filetype = "33";
                    }else if(fileName.endsWith("sbn")){
                        filetype = "34";
                    }else if(fileName.endsWith("sbx")){
                        filetype = "35";
                    }else if(fileName.endsWith("shp")){
                        filetype = "31";
                    }else if(fileName.endsWith("shp.xml")){
                        filetype = "36";
                    }else if(fileName.endsWith("shx")){
                        filetype = "37";
                    }else{
                        filetype = "40";
                    }
                    filelist.add(filetype);
                    String sql = "insert into g_files_db values (sys_guid(), ?, ?, ?, ?, to_char(sysdate,'yyyy-MM-dd'))";
                    try {
                        //int result = DataBaseHelper.update(sql, new Object[]{fileName,filePath,xmmc,filetype});
                        pre = conn.prepareStatement(sql);
                        pre.setString(1, fileName);
                        pre.setString(2, filePath);
                        pre.setString(3, xmmc);
                        pre.setString(4, filetype);
                        int result = pre.executeUpdate();
                        counts = counts + result;
                    } catch (Exception e) {
                        e.printStackTrace();
                        counts = -2;
                        return;
                    }
                    
                } 
            }
            
        }
    }
    
    //1,首先需要找到目录为“项目清单”的文件夹
    public static void getDirectory(String strPath) {
        File dir = new File(strPath);
        File[] files = dir.listFiles(); // 该文件目录下文件全部放入数组
        //String fileDirectory = "";
        if (files != null ) {
            for (int i = 0; i < files.length; i++) {
                String fileName = files[i].getName();
                if (files[i].isDirectory()) { // 判断是否是对应的目录
                    if(fileName.contains("项目清单")){
                        getType(files[i].getAbsolutePath());   //调用方法，查找是否包含“项目调查表”、“坐标”文件夹。
                    }
                    else getDirectory(files[i].getAbsolutePath());
                }else{
                    continue;
                } 
            }
            
        }
    }
    
    //2.找到基础信息目录和坐标目录，文件夹需要创建合理
    public static void getType(String strPath) {
        File dir = new File(strPath);
        File[] files = dir.listFiles(); // 该文件目录下文件全部放入数组
        if (files != null ) {
            for (int i = 0; i < files.length; i++) {
                String fileName = files[i].getName();
                if (files[i].isDirectory()) { // 判断是文件还是文件夹
                    if(fileName.contains("项目调查表")){
                        getBase(files[i].getAbsolutePath());
                    }else if(fileName.contains("坐标")){
                        getCoordinate(files[i].getAbsolutePath());
                    }else getType(files[i].getAbsolutePath());
                }else{
                    continue;
                }
            }
        }
    }
    
    //将所有shp格式的文件写入到文件中
    public static void writeSHP(String path){
        File file = new File(path);
        String sql = "select filepath || regexp_substr(filename, '[^.]+', 1, 1) filename from G_FILES_DB where type = '31'";
        try {
            if(!file.exists()){
                file.createNewFile();
            }
            FileOutputStream outStream = new FileOutputStream(file,true);
            pre = conn.prepareStatement(sql);
            ResultSet re = pre.executeQuery();
            while(re.next()){
                outStream.write(re.getString(1).getBytes("utf-8"));
                outStream.write("\r\n".getBytes("utf-8"));
            }
            outStream.close();
            //counts = 0;
        } catch (Exception e) {
            e.printStackTrace();
        }
        counts = 0;
    }
    
    //方法入口
    public static void main(String[] args) {
        Properties prop = read();
        String path = prop.getProperty("file.path");
        String savePath = prop.getProperty("file.savePath");
        String url = prop.getProperty("file.url");
        String user = prop.getProperty("file.user");
        String psd = prop.getProperty("file.password");
        conn = getConn(url, user, psd);
        getDirectory(path);
        if(counts < 0){
            System.out.println("数据已存在，再次插入失败！");
        }else{
            System.out.println("更新了"+counts+"条数据");
            writeSHP(savePath);
            closeConn();
        }
    }
    
     //获取连接
        public static Connection getConn(String url,String user,String psd){
            try {
                Class.forName("oracle.jdbc.driver.OracleDriver");
            } catch (Exception e) {
                e.printStackTrace();
            }
            try {
                conn = DriverManager.getConnection(url,user,psd);
            } catch (Exception e1) {
                e1.printStackTrace();
            }
            return conn;
        }
    
        //关闭所有连接
        public static void closeConn (){
            try {
                if(pre != null){
                    pre.close();
                    pre = null;
                }
                if(conn != null){
                    conn.close();
                    conn = null;
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
            
        }
        
        //获取配置文件访问对象
        public static Properties read() {
            Properties pro = new Properties(); 
            File file = new File("C:\\EIfilePath\\application.properties");
            try {
                FileInputStream in = new FileInputStream(file);
                pro.load(in);
            } catch (Exception e) {
                System.out.println(e);
            }
            return pro;
        }
}
View Code

1，类中的方法主要是根据需要遍历的目的文件夹进行遍历，根据类型的不同，存入到数据库中，同时也包括了JDBC对象的创建、使用、关闭。同时将部分数据写入到txt文件中。

2，除了Java文件外，还需要创建一个配置文件，配置文件中配置了遍历目的文件夹，数据库信息，写入字符串到哪个文件。

在eclipse等IDE中直接运行主函数即可。

3，如果使用cmd窗口直接运行class文件，则需要注意以下几点：

　　1），在cmd中输入：javac -encoding utf-8 ReadFileService.java                  //ReadFileService是类名；-encoding utf-8设置编码格式，如果不设置，且类中有中文，则会报错。

　　2），编译完成后，再执行命令：java ReadFileService                                //执行命令前，要确保Java文件同目录下有对应的配置文件，且在配置文件中，所需配置都配置无误。

4，说下环境变量配置问题，由于使用cmd运行class文件，且类中涉及与数据库交互问题，则需要在classpath中配置驱动jar包路径，这里以Oracle为例吧。

.;%JAVA_HOME%\lib;%JAVA_HOME%\lib\tools.jar;C:\ojdbc6.jar            // .; 注意不要忘记

.class文件，.properties配置文件一定在同一目录下，因为程序中使用的是通过获取.class文件的路径然后获取.properties文件的。

5，application.properties中的属性配置

 

file.path=C:\\EIfilePath
file.url=jdbc:oracle:thin:@172.16.1.23:1521:orcl
file.user=nfb_Devs_v5
file.password=1qazxsw2
file.savePath = C:\\EIfilePath\\SHP.txt

类似如此的循环遍历功能，需要文件夹及文件的命名规则要一直，要保持一定的统一标准。

原文地址：https://www.cnblogs.com/lovefaner/p/10763127.html

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。

相关推荐

讲解JDBC
连接数据库的方式：第一种方式：ODBC：开放数据库连接是微软公司开放服务结构中有关数据库的一个组成部分，是数据库访问接口标准。ODBC是基于C语言实现的。提供了语言和数据库进行交互的一致性的接口，便于语言和数据库通信以及语言对数据库的各种操作。第二种方式：JDBC（本章重点）在Java中，
Jmeter 数据库请求
JDBCRequest 使用VariableNamesmysql：数据库连接池对象variousname：设置的变量名称 如何使用该变量a_#、b_#、c_#、d_#：代表行数a_1：第1行、第1列b_2：第2行、第2列
抽取基本JDBC中的基本操作与数据连接池
 1.JDBCDBC(JavaDataBaseConnectivity)：Java数据库连接技术：具体讲就是通过Java连接广泛的数据库，并对表中数据执行增、删、改、查等操作的技术。JDBC是数据库与Java代码的桥梁。JDBC中定义了操作数据库的各种接口和类型：增删改基本操作：（1）获取连接：Connectionconnection=
JDBC操作流程
1.需要jar包的支持：java.sqljavax.sqlmysql-conneter-java...连接驱动（必须要导入）<dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>5.1.46</version></depend
Activiti可视化流程管理器
1.简介Activiti是一个业务流程管理(BPM)框架,它是覆盖了业务流程管理，工作流，服务协作等领域的一个开源，灵活的，易扩展的可执行流程语言框架。在Java工作流引擎中可谓是主流，我们的项目也是使用的这个框架进行流程相关的开发。与流程息息相关的就是我们的流程定义BPMN文件，包含有一系列
0811JDBC随笔
1.JDBC体系系统一组规范：接口JDBC接口（API）包括两个层次：面向应用的API：JavaAPI，抽象接口，供应用开发人员使用（连接数据库，执行SQL语句，获得结果）面向数据库的API：JavaDriverAPI，供开发商开发数据库驱动程序JDBC是sun公司提供一套用于数据库操作的接口，java程序员只需要面向这套接
JDBC的基本概念
原文链接JDBC一般指Java数据库连接（JavaDatabaseConnectivity）api应用程序接口（API）：可以调用或者使用类/接口/方法等去完成某个目标。API制定的类/方法可以做什么。API由开发人员调用。spi服务提供接口（SPI）：需要继承或实现某些类/接口/方法等去完成某个目标。SPI告诉你
Shardingsphere-ShardingSphere-JDBC-Spring Boot配置-分片规则
spring.shardingsphere.datasource.names=#省略数据源配置，请参考用法#标准分表配置spring.shardingsphere.rules.sharding.tables.<table-name>.actual-data-nodes=#描述数据源名称和实际表，分隔符为点，多个数据节点用逗号分隔，支持内联表达式。Absent表示仅对数据库进行分片
20220814 idea_springboot_启动 Cannot load driver class: com.mysql.cj.jdbc.Driver
1问题Cannotloaddriverclass:com.mysql.cj.jdbc.Driver 2解决方案2.1已解决2.1.1首先，去查看项目中MySQL的版本如果找不到，说明可能还没有jdbc驱动，需要配置或者引入       （1）如果是直接引用的jar包，就去lib文件夹中查看，后缀是版
JDBC
JDBC一、JDBC概述什么是JDBC？JDBC是使用Java语言操作关系型数据库的一套API。这套API是交由不同的数据库厂商实现的。我们利用JDBC编写操作数据库的代码，真正执行的是各个数据库的实现类（驱动）。全称：（JavaDataBaseConnectivity）Java数据库连接。JDBC的好处面向接口编
从关系型数据库中创建DataFrame
说明：/*需要引入依赖<dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>8.0.18</version></dependency>*/代码：objec
通过jmeter连接人大金仓数据库
1.概要在“配置元件”中添加“JDBCConnectionConfiguration”。配置如下图： 2.重点：配置人大金仓数据库连接下面着重介绍人大金仓数据库连接配置：DatabaseURL输入：jdbc:kingbase8://192.132.180.101:54321/hj_yc   （备注：应输入 jdbc:kingbase8://IP:
2022-8-18第一组孙乃宇JDBC
JDBC概念：JavaDataBaseconnectivityJava数据库连接，Java语言操作数据库JDBc本质∶其实是官方(sun公司)定义的一套操作所有关系型数据库的规则，即接口。各个数据库商去实现这套接口，提供数据库驱动jar包。我们可以使用这套接口(JDBC）编程,真正执行的代码是驱动jar包中的实现类
mybatis核心配置文件
Mybatis核心配置文件习惯上命名mybatis-config.xml，整合Spring之后，整个配置文件可以省略核心配置文件主要用于配置连接数据库的环境以及MyBatis的全局配置信息标签顺序顺序出错会报错propertiessettingstypeAliasestypeHandlersobjectFactoryobjectWrapperFa
2022-8-18 第六组 JDBC
JDBC1.概念：JavaDataBaseConnectivityJava数据库连接，Java语言操作数据库JDBC本质：其实是官方（sun公司）定义的一套操作所有关系型数据库的规则，即接口。各个数据库厂商去实现这套接口，提供数据库驱动jar包。我们可以使用这套接口（JDBC）编程，真正执行的代码是驱动jar包中的实现类。
JDBC出现The server time zone value&#039;Öйú±ê׼ʱ¼ä&#039; is unrec问题
  1.出现这个问题的原因 ：在安装mysql的时候时区设置的不正确，mysql默认的是美国的时区，而我们中国大陆要比他们迟8小时，采用+8:00格式使用的数据库是MySQL，没有指定MySQL驱动版本的情况下它自动依赖的驱动是8.0.12很高的版本，这是由于数据库和系统时区差异所造成的，在jdbc连
ShardingSphere-JDBC实战
一、环境准备1.数据库创建2个库2个表：xdclass_shop_order_0product_order_0product_order_1ad_configproduct_order_item_0product_order_item_1xdclass_shop_order_1product_order_0product_order_1ad_configproduct_order_item_0product_order_item_1数据
Springboot整合JDBC
编写配置文件(application.yml)spring:datasource:username:rootpassword:123456url:jdbc:mysql://localhost:3306/mybatis?useUnicode&characterEncoding=utf-8driver-class-name:com.mysql.cj.jdbc.Driver测试连接@SpringBootTestclassSprin
ssm相关配置
结构图pom.xml<?xmlversion="1.0"encoding="UTF-8"?><projectxmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http:/
MySql JDBC url 参数详解
MySql链接url参数详解 jdbc:mysql://[host:port],[host:port].../[database][?参数名1][=参数值1][&参数名2][=参数值2]... 常用的几个较为重要的参数： 参数名称参数说明缺省值最低版本要求 user 数据库用户名（用于连接数据库） 所有版本passWord用户密码（用于连接
pythonJavaScriptjavaHTMLPHPreactjsC#AndroidCSSNode.jssqlrpython-3.xMysqLjQueryc++pandasFlutterangularIOSdjangolinuxswifttypescript路由器JSON路由器设置无线路由器h3c华三华三路由器设置华三路由器电脑软件教程arraysdocker软件图文教程Cvue.jslaravelspring-boot