Mit "LOAD DATA LOCAL INFILE" in Java

Ich habe eine cvs-Datei, die schema ist, wird jedes Feld umgeben ", und getrennt durch , und jedem Tupel wird ein Zeilenumbruch mit \n

So, in meiner Java-Datei, schrieb ich 

                String path = "o.csv";
                String esquel = " LOAD DATA LOCAL INFILE " + path +
                            " INTO TABLE recommendations " +
                            " FIELDS TERMINATED BY \',\' ENCLOSED BY \'\"'" +
                            " LINES TERMINATED BY \'\\n\'";

Und ich führen Sie die Anweisung mit der folgenden Anweisung

statement.executeUpdate(esquel);

Aber es wirft eine SQLException, die sagt:

com.mysql.jdbc.Ausnahmen.jdbc4.MySQLSyntaxErrorException: Sie haben eine
Fehler in Ihrer SQL-syntax; Lesen Sie im Handbuch, das entspricht Ihrem
MySQL-server-version für den richtigen syntax in der Nähe 'o.csv IN
TABELLE Empfehlungen FIELDS TERMINATED BY ',' ENCLOSED BY '"' LINES'
in Zeile 1

Was ist mein Fehler ?

Ich wäre Ihnen dankbar, wenn Sie mir helfen können.

Dank

InformationsquelleAutor CanCeylan | 2012-03-10

  1. 1

    Oh, ich habe es ! Ich habe nicht um mein Pfad Datei mit '.

    Neue sql-Anweisung sollte sein:

    String esquel = " LOAD DATA LOCAL INFILE '" + path +
                            "' INTO TABLE recommendations " +
                            " FIELDS TERMINATED BY \',\' ENCLOSED BY \'\"'" +
                            " LINES TERMINATED BY \'\\n\'";

    InformationsquelleAutor CanCeylan

  2. 1

    Hier arbeitet-code, die ich getestet:

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

public class LoadTRPLog2MySql {

    public static void main(String[] args) {

        Class driver_class = null;
        try {
            driver_class = Class.forName("com.mysql.jdbc.Driver");
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
            return;
        }
        System.out.println("found driver" + driver_class);


        Connection connection = null;
        try {
            connection = DriverManager.getConnection("jdbc:mysql://mysqlserver.com:3306/dbname", "myid","pwd");
        } catch (SQLException e) {
            e.printStackTrace();
        }

        try {
            System.out.println("Established connection to " + connection.getMetaData().getURL());
        } catch (SQLException e1) {
            e1.printStackTrace();
        }

        Statement statement = null;
        try {
            statement = connection.createStatement();
            Statement statement1 = connection.createStatement();
            //windows
            //statement1.executeUpdate( "LOAD DATA LOCAL INFILE 'C:\\Users\\senthil_sivasamy\\Documents\\Projects\\messageprocessing\\log.txt' INTO TABLE  trpwatchlog_tb FIELDS TERMINATED BY ' ' LINES TERMINATED BY '\\n'");
            //linux  ( " LOAD DATA LOCAL INFILE '/home/username/logname.log' INTO TABLE  logname.log FIELDS TERMINATED BY ' ' LINES TERMINATED BY '\\n'");
            statement.executeUpdate( "LOAD DATA LOCAL INFILE '/home/username/avail30trplog' INTO TABLE  logname.log FIELDS TERMINATED BY ' ' LINES TERMINATED BY '\\n'");

            statement1.execute("select * from dbname.tablelog_tb");
            ResultSet rs = statement1.getResultSet();
            System.out.println("Row hostname and timestamp");
            while(rs.next()) {
                System.out.println("Row hostname and timestamp");
                System.out.println(rs.getRow());
                System.out.println(""+rs.getString("hostname"));
                System.out.println(""+rs.getString("timestamp"));
            }
            rs.close();
        } catch(SQLException e) {
        } finally {
            if (statement != null) {
                try {
                    statement.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
        if (connection != null) {
            try {
                connection.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

    InformationsquelleAutor senthil sivasamy

Schreibe einen Kommentar