我可以在shell中执行SQL:
LOAD DATA LOCAL INPATH '/tmp/sql.txt' INTO TABLE files;
Run Code Online (Sandbox Code Playgroud)
这是sql.txt中的内容:
4e6c924a-1fa2-4326-86eb-975d1007f0a6 FileScoreConverterTest.java /home/xiehaozhe/Development/Kloud-Document-Analyzer/kda/src/test/java/com/kda/filescore/type/FileScoreConverterTest.java
ab6ee610-c980-4ff7-b472-8546766e0f89 FileWordCountConverterTest.java /home/xiehaozhe/Development/Kloud-Document-Analyzer/kda/src/test/java/com/kda/filescore/type/FileWordCountConverterTest.java
Run Code Online (Sandbox Code Playgroud)
表的结构(命名文件)是
guid STRING
filename STRING
filepath STRING
Run Code Online (Sandbox Code Playgroud)
如果我在Java中执行sql,我得到一个例外:
Exception in thread "main" java.sql.SQLException: Query returned non-zero code: 40000, cause: FAILED: ParseException line 1:54 mismatched input ';' expecting EOF near 'files'
Run Code Online (Sandbox Code Playgroud)
这是代码:
Class.forName("org.apache.hadoop.hive.jdbc.HiveDriver");
String sql = "LOAD DATA LOCAL INPATH '" + sqlFilePath + "' INTO TABLE files;";
Connection connection = DriverManager.getConnection(databaseAddress, databaseUsername, databasePassword);
Statement statement = connection.createStatement();
statement.executeQuery(sql);
Run Code Online (Sandbox Code Playgroud)
我该怎么办?
在shell中编写查询时,应使用';' 在SQL语句的末尾:
LOAD DATA LOCAL INPATH '/tmp/sql.txt' INTO TABLE files;
Run Code Online (Sandbox Code Playgroud)
但是,你不能使用';' 在使用Java时SQL语句的末尾:
LOAD DATA LOCAL INPATH '/tmp/sql.txt' INTO TABLE files
Run Code Online (Sandbox Code Playgroud)
所以,这就是引起异常的原因.
归档时间: |
|
查看次数: |
21041 次 |
最近记录: |