Java读取txt文件写入数据库的流程

1. 确定需求和准备工作

在开始之前，我们需要明确以下几个方面的内容：

• 数据库信息：数据库名称、表名称、用户名、密码等。
• txt文件的路径和格式：确定要读取的txt文件的路径和格式，例如文件名为sample.txt。
• 数据库连接信息：需要使用哪种方式连接数据库，例如使用JDBC连接。

2. 创建数据库表

在数据库中创建一个表，用于存储txt文件中的数据。可以使用以下SQL代码创建一个示例表：

CREATE TABLE IF NOT EXISTS sample_table (
  id INT PRIMARY KEY AUTO_INCREMENT,
  name VARCHAR(50),
  age INT
);

3. 编写Java代码

接下来，我们可以编写Java代码来实现读取txt文件并将数据写入数据库的功能。

首先，需要导入相关的Java类和包：

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

然后，需要定义一些常量，用于存储数据库连接信息和txt文件位置：

// 数据库连接信息
private static final String DB_URL = "jdbc:mysql://localhost:3306/your_database";
private static final String DB_USER = "your_username";
private static final String DB_PASSWORD = "your_password";

// txt文件位置
private static final String TXT_FILE_PATH = "path_to_your_txt_file/sample.txt";

接着，我们可以编写一个方法，用于读取txt文件并将数据写入数据库：

public static void readTxtAndWriteToDatabase() {
    try {
        // 连接数据库
        Connection connection = DriverManager.getConnection(DB_URL, DB_USER, DB_PASSWORD);
        
        // 读取txt文件
        BufferedReader reader = new BufferedReader(new FileReader(TXT_FILE_PATH));
        String line;
        
        // 逐行读取txt文件中的数据
        while ((line = reader.readLine()) != null) {
            // 使用逗号分隔每一行数据
            String[] data = line.split(",");
            
            // 将数据插入到数据库表中
            String sql = "INSERT INTO sample_table (name, age) VALUES (?, ?)";
            PreparedStatement statement = connection.prepareStatement(sql);
            
            // 设置参数值
            statement.setString(1, data[0]); // name
            statement.setInt(2, Integer.parseInt(data[1])); // age
            
            // 执行插入操作
            statement.executeUpdate();
            
            // 关闭statement
            statement.close();
        }
        
        // 关闭reader
        reader.close();
        
        // 关闭数据库连接
        connection.close();
        
        System.out.println("数据导入成功！");
    } catch (SQLException e) {
        e.printStackTrace();
    } catch (IOException e) {
        e.printStackTrace();
    }
}

4. 调用方法并执行

最后，我们可以在主方法中调用readTxtAndWriteToDatabase方法，以执行读取txt文件并将数据写入数据库的操作：

public static void main(String[] args) {
    readTxtAndWriteToDatabase();
}

以上就是实现Java读取txt文件写入数据库的完整流程。

请注意，以上示例代码仅供参考，实际使用时需要根据具体的数据库和txt文件的格式进行相应的调整。

以下是关系图：

erDiagram
    DATABASE sample_database {
        TABLE sample_table {
            id INT PK
            name VARCHAR
            age INT
        }
    }

希望本文对你有所帮助，如果有任何疑问，请随时向我提问！