首页 > 解决方案 > 读取文件夹中的多个文本文件并导入数据库

问题描述

我需要将一堆文本文件(292)导入不同的数据库。每个文件必须在不同的表和数据库中。它将从表 sys_doc 中检索 doc_no 和 doc_cde。我的想法是使用循环。还想知道如何根据他们的数据库过滤这些文本文件,基于 doc_cde。

这是我认为我现在将使用的代码示例。完成我的任务的任何其他想法都会有所帮助。

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;
import java.sql.ResultSet;
import java.sql.SQLException;

public class automateImport
{
   public static void main(String[] args) 
   {
       DBase db = new DBase();
       Connection conn = db.connect("jdbc:mysql://localhost:3306/test","root","caspian");
       db.importData(conn,args[0]);
   }

}

class DBase
{
    public DBase(){}

    public Connection connect(String db_connect_str, 
    String db_userid, String db_password)
    {
        Connection conn;
        try
        {
           Class.forName("com.mysql.jdbc.Driver").newInstance();

            conn = DriverManager.getConnection(db_connect_str, 
            db_userid, db_password);

        }
        catch(Exception e){
            e.printStackTrace();
            conn = null;
        }

        return conn;    
    }

    public void importData(Connection conn,String filename)
    {
        Statement stmt;
        String query;

        try
        {
            stmt = conn.createStatement(
            ResultSet.TYPE_SCROLL_SENSITIVE,
            ResultSet.CONCUR_UPDATABLE);

            query = "LOAD DATA INFILE '"+filename+
                     "' INTO TABLE testtable (text,price);";

            stmt.executeUpdate(query);

        }
        catch(Exception e){
            e.printStackTrace();
            stmt = null;
        }
    }
};

标签: javamysql

解决方案


推荐阅读