Java怎么實現文件導入數據庫

116次閱讀

共計 2106 個字符，預計需要花費 6 分鐘才能閱讀完成。

在 Java 中實現將文件導入數據庫，可以按照以下步驟進行：
1. 首先，使用 Java 的文件操作相關類（如 FileInputStream、BufferedReader 等）讀取文件內容。
2. 將讀取的文件內容解析為數據庫表的字段值，可以使用 Java 的字符串分割、正則表達式匹配等方法進行解析。
3. 使用 Java 的 JDBC 相關類（如 Connection、Statement、PreparedStatement 等）連接到數據庫。
4. 創建插入數據的 SQL 語句，將解析得到的字段值插入到數據庫表中。
5. 使用 JDBC 的 PreparedStatement 類的 setXXX() 方法，將字段值設置到 SQL 語句中。
6. 執行 SQL 語句，將數據插入到數據庫表中。
以下是一個簡單的示例代碼，演示了將 CSV 文件導入到 MySQL 數據庫表中的過程：

import java.io.BufferedReader;
import java.io.FileInputStream;
import java.io.InputStreamReader;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
public class FileImportToDB {
    public static void main(String[] args) {
        String csvFilePath = "path/to/csv/file.csv";
        String dbUrl = "jdbc:mysql://localhost:3306/database_name";
        String dbUser = "username";
        String dbPassword = "password";
        
        try {
            //  讀取 CSV 文件
            BufferedReader reader = new BufferedReader(new InputStreamReader(new FileInputStream(csvFilePath)));
            String line;
            
            //  連接數據庫
            Connection conn = DriverManager.getConnection(dbUrl, dbUser, dbPassword);
            
            //  創建插入數據的 SQL 語句
            String sql = "INSERT INTO table_name (column1, column2, column3) VALUES (?, ?, ?)";
            PreparedStatement stmt = conn.prepareStatement(sql);
            
            //  逐行讀取 CSV 文件內容并插入數據庫
            while ((line = reader.readLine()) != null) {
                String[] values = line.split(","); //  根據 CSV 文件的分隔符進行分割，這里假設是逗號分隔
                
                //  設置 SQL 語句中的字段值
                stmt.setString(1, values[0]);
                stmt.setString(2, values[1]);
                stmt.setString(3, values[2]);
                
                //  執行插入操作
                stmt.executeUpdate();
            }
            
            //  關閉資源
            stmt.close();
            conn.close();
            reader.close();
            
            System.out.println(" 文件導入數據庫成功！");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }}