[file upload] parse text files and store them in batches through JDBC connection (dynamic table creation and dynamic storage)

Be careful : I use it directly here main Function demonstration , Subsequent integration SpringBoot In the method

Text file format ( Field to !| Division ):

    public static void main(String[] args) throws Exception {
        Connection conn = DriverManager.getConnection("jdbc:mysql://xxx.xxx.xxx.xxx:3306/table", "root", "root");//  Create a data connection 
        LineIterator lineIterator = FileUtils.lineIterator(new File("D:\\Flink\\src\\main\\resources\\AMM_ITF_D_PRD_INFO.TXT"), "utf-8");
        conn.setAutoCommit(false);
        Integer a = 0;
        String tableName = "table_" + System.currentTimeMillis();
        String[] fields = null;
        PreparedStatement ps = null;
        String result = "";
        while (lineIterator.hasNext()) {
            result = lineIterator.next();
            if (a == 0) {
                fields = result.split("\\!\\|");
                // Dynamic table building 
                String sql = "create table " + tableName + "(";
                if (fields != null && fields.length > 0) {
                    int len = fields.length;
                    for (int i = 0; i < len; i++) {
                        // Add fields 
                        sql += fields[i].trim() + " text";
                        // Prevent the last ,
                        if (i < len - 1) {
                            sql += ",";
                        }
                    }
                }
                // Put together   Create table statement   Set default character set 
                sql += ")";
                System.out.println(" The table creation statement is ：" + sql);
                PreparedStatement preparedStatement = conn.prepareStatement(sql);
                preparedStatement.executeUpdate(sql);
                conn.commit();
                preparedStatement.close();

                sql = "insert into " + tableName + "(";
                int length = fields.length;
                for (int i = 0; i < length; i++) {
                    sql += fields[i];
                    // Prevent the last ,
                    if (i < length - 1) {
                        sql += ",";
                    }
                }
                sql += ") values(";
                for (int i = 0; i < length; i++) {
                    sql += "?";
                    // Prevent the last ,
                    if (i < length - 1) {
                        sql += ",";
                    }
                }
                sql += ");";
                ps = conn.prepareStatement(sql);

                a++;
            } else {
                String[] data = result.split("\\!\\|");
                if (fields.length == data.length) {
                    // Injection parameters 
                    for (int i = 0; i < fields.length; i++) {
                        ps.setString(i + 1, data[i]);
                    }
                    ps.addBatch();
                }
                if (a % 5 == 0) {
                    ps.executeBatch();
                    conn.commit();
                    ps.clearBatch();
                }
                a++;
            }
        }
        ps.executeBatch();
        conn.commit();
        ps.clearBatch();
        // Close database connection 
        conn.close();
    }