Java 使用 Streamload 将 CSV 数据导入 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 数据库，你需要将适当的驱动程序添加到你的项目依赖项中。