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

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

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

public class CSVParser {
    public static void main(String[] args) {
        String csvFile = "data.csv";
        String dbUrl = "jdbc:postgresql://localhost:5432/statrocks";
        String dbUser = "username";
        String dbPassword = "password";

        try (Connection connection = DriverManager.getConnection(dbUrl, dbUser, dbPassword);
             BufferedReader br = new BufferedReader(new FileReader(csvFile))) {

            String line;
            while ((line = br.readLine()) != null) {
                String[] data = line.split(",");

                // Prepare SQL statement
                String sql = "INSERT INTO table_name (column1, column2, column3) VALUES (?, ?, ?)";
                PreparedStatement statement = connection.prepareStatement(sql);

                // Set values for each column
                statement.setString(1, data[0]);
                statement.setString(2, data[1]);
                statement.setInt(3, Integer.parseInt(data[2]));

                // Execute the statement
                statement.executeUpdate();
            }

            System.out.println("Data inserted successfully!");

        } catch (IOException | SQLException e) {
            e.printStackTrace();
        }
    }
}

请注意，你需要将以下变量替换为你自己的值：

• csvFile：CSV文件的路径，例如"data.csv"。
• dbUrl：Statrocks数据库的URL。
• dbUser：Statrocks数据库的用户名。
• dbPassword：Statrocks数据库的密码。
• table_name：要插入数据的表名。
• column1, column2, column3：要插入的列名。

确保你已经将相应的JDBC驱动程序添加到你的项目中。此示例使用PostgreSQL数据库，你需要将适当的驱动程序添加到你的项目依赖项中。