java 程序示例解析 csv 文件使用 streamload 方式将数据写入 doris 数据库

以下是一个使用Java解析CSV文件并将数据写入Doris数据库的示例程序：

import java.io.BufferedReader;
import java.io.FileReader;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class CSVLoader {
    private static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";
    private static final String DB_URL = "jdbc:mysql://localhost:3306/dorisdb";
    private static final String USER = "username";
    private static final String PASS = "password";

    public static void main(String[] args) {
        try {
            // 加载JDBC驱动
            Class.forName(JDBC_DRIVER);

            // 创建数据库连接
            Connection conn = DriverManager.getConnection(DB_URL, USER, PASS);

            // 创建PreparedStatement
            PreparedStatement pstmt = conn.prepareStatement("INSERT INTO tablename (col1, col2, col3) VALUES (?, ?, ?)");

            // 读取CSV文件
            BufferedReader reader = new BufferedReader(new FileReader("data.csv"));
            String line;
            while ((line = reader.readLine()) != null) {
                // 解析CSV行
                String[] values = line.split(",");

                // 设置参数
                pstmt.setString(1, values[0]);
                pstmt.setString(2, values[1]);
                pstmt.setString(3, values[2]);

                // 执行插入操作
                pstmt.executeUpdate();
            }

            // 关闭资源
            pstmt.close();
            conn.close();
            reader.close();

            System.out.println("数据导入完成");
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

注意替换以下变量的值：

• DB_URL：Doris数据库的连接URL。
• USER：Doris数据库的用户名。
• PASS：Doris数据库的密码。
• "INSERT INTO tablename (col1, col2, col3) VALUES (?, ?, ?)"：将其替换为适合你的表结构的插入语句。

此示例假设CSV文件的每一行包含3个字段，以逗号分隔。你可以根据自己的需求修改代码以适应不同的CSV文件格式和表结构。