[大数据] 数据库查询结果集生成dbf文件

开发: C++知识库 Java知识库 JavaScript Python PHP知识库人工智能区块链大数据移动开发嵌入式开发工具数据结构与算法开发测试游戏开发网络协议系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑笔记本显卡显示器固态硬盘硬盘耳机手机 iphone vivo oppo 小米华为单反装机图拉丁

-> 大数据 -> 数据库查询结果集生成dbf文件 -> 正文阅读

[大数据]数据库查询结果集生成dbf文件

		<dependency>
            <groupId>com.github.albfernandez</groupId>
            <artifactId>javadbf</artifactId>
            <version>1.13.2</version>
        </dependency>

//ResultSet结果集转化为dbf文件
    @org.junit.jupiter.api.Test
    public void resultSetToDbf() {
        MySQLDBUtil mySQLDBUtil = null;
        Connection connection = null;
        PreparedStatement preparedStatement = null;
        ResultSet resultSet = null;
        try {
            Database database = DataBaseUtil.getDataBase(0);
            mySQLDBUtil = new MySQLDBUtil(database);
            connection = mySQLDBUtil.getConnection();
            String sql = "select * from event_table";
            preparedStatement = connection.prepareStatement(sql);
            resultSet = preparedStatement.executeQuery(sql);
            DbfUtil.createDbf("E:\\test.dbf",resultSet, "gbk");
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            MySQLDBUtil.closeAllS(resultSet, preparedStatement, connection);
        }
    }

package com.parameter.tools;

import com.linuxense.javadbf.DBFDataType;
import com.linuxense.javadbf.DBFField;
import com.linuxense.javadbf.DBFWriter;
import java.io.*;
import java.nio.charset.Charset;
import java.sql.*;
import java.text.SimpleDateFormat;

/**
 * @author xiaodong
 * @version 1.0.0
 * @ClassName DbfUtil.java
 * @Description TODO
 * @createTime 2022年04月08日 13:20:00
 */
public class DbfUtil {
    /**
     * 创建dbf
     *
     * @param path:文件路径
     * @throws IOException
     */
    public static void createDbf(String path, ResultSet crs, String charsetName) {
        //定义DBFWriter实例用来写DBF文件
        DBFWriter dbfWriter = null;
        try {
            ResultSetMetaData metaData = crs.getMetaData();
            int columnCount = metaData.getColumnCount();
            DBFField[] fields = new DBFField[columnCount];
            for (int i = 1; i <= columnCount; i++) {
                DBFField field = new DBFField();
                String columnName = metaData.getColumnName(i);
                field.setName(columnName);//字段名称
                field.setType(DBFDataType.CHARACTER);//指定字段类型为字符串
                field.setLength(metaData.getPrecision(i));//指定字段长度
                fields[i-1] = field;
            }
            dbfWriter = new DBFWriter(new FileOutputStream(path), Charset.forName(charsetName));
            //设置字段
            dbfWriter.setFields(fields);
            //添加记录
            while (crs.next()) {
                Object[] rowData = new Object[columnCount];
                for (int i = 1; i <= columnCount; i++) {
                     if(crs.getObject(i).getClass().getName().equals("java.sql.Timestamp")){
                         Timestamp timestamp = (Timestamp) crs.getObject(i);
                         Date date = new Date(timestamp.getTime());
                         SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
                         rowData[i-1] = sdf.format(date);
                    }else{
                         rowData[i-1] = crs.getString(i);
                     }
                }
                dbfWriter.addRecord(rowData);
            }
        } catch (FileNotFoundException | SQLException e) {
            e.printStackTrace();
        }finally {
            //写入dbf文件并关闭
            ByteArray.closeStream(dbfWriter);
        }
    }
}