2016-02-03 26 views
1

我使用ORC創建了一個配置單元表。如果我從hive控制檯插入數據,它的工作原理是完美的。但是如果我從Jdbc代碼插入數據,它會拋出配置單元語義異常。在插入數據時配置單元語義異常

錯誤

rg.apache.hive.service.cli.HiveSQLException:錯誤在編譯聲明:失敗:SemanticException [錯誤10293]:無法創建類型TOK_TABLE_OR_COL的插入值表達臨時文件不支持插入/值 org.apache.hive.service.cli.operation.Operation.toSQLException(Operation.java:326) org.apache.hive.service.cli.operation.SQLOperation.prepare(SQLOperation.java: 102) org.apache.hive.service.cli.operation.SQLOperation.runInternal(SQLOperation.java:171) org.apache.hive.ser (Operation.java:268) org.apache.hive.service.cli.session.HiveSessionImpl.executeStatementInternal(HiveSessionImpl.java:410) org.apache.hive.service.cli。 session.HiveSessionImpl.executeStatementAsync(HiveSessionImpl.java:397) sun.reflect.GeneratedMethodAccessor24.invoke(未知來源) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke( Method.java:606) org.apache.hive.service.cli.session.HiveSessionProxy.invoke(HiveSessionProxy.java:78) org.apache.hive.service.cli.session.HiveSessionProxy.access $ 000(HiveSessionProxy.java :36) org.apache.hive.service.cli.session.HiveSessionProxy $ 1.run(HiveSessionProxy.java:63) java.security.AccessController.doPrivileged(本機方法) javax.security.auth.Subject.doAs(Subject.java:415) org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1671) 組織.apache.hive.service.cli.session.HiveSessionProxy.invoke(HiveSessionProxy.java:59) com.sun.proxy。$ Proxy25.executeStatementAsync(Unknown Source) org.apache.hive.service.cli.CLIService.executeStatementAsync (CLIService.java:258) org.apache.hive.service.cli.thrift.ThriftCLIService.ExecuteStatement(ThriftCLIService.java:509) org.apache.hive.service.cli.thrift.TCLIService $ Processor $ ExecuteStatement.getResult (TCLIService.java:1313) org.apache.hive.service.cli.thrift.TCLIService $ Processor $ ExecuteStatement.getResult(TCLIService.jav a:1298) org.apache.thrift.ProcessFunction.process(ProcessFunction.java:39) org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:39) org.apache.hive.service.auth.TSetIpAddressProcessor .process(TSetIpAddressProcessor.java:56) org.apache.thrift.server.TThreadPoolServer $ WorkerProcess.run(TThreadPoolServer.java:285) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) java。 util.concurrent.ThreadPoolExecutor $ Worker.run(ThreadPoolExecutor.java:615) java.lang.Thread.run(Thread.java:745)

插入查詢

result = name+","+age+","+job; 
String stmt = "INSERT INTO table real_estate.addressinformation_orc VALUES(" + result + ")"; 

任何幫助將不勝感激。

回答

1

您需要引用字符串。假設年齡是一個整數,這將工作,但它是一個壞的解決方案:

result = "'" + name + "'," + age + ",'" + job + "'" 

這是一個淺的解決方案,因爲如果姓名和工countain報價,這會破壞你的代碼。 更好的解決方案是使用預準備語句。通過準備好的語句,您不必擔心qoting:

preparedStatement = dbConnection. 
    prepareStatement("INSERT INTO table " +  
    "real_estate.addressinformation_orc VALUES(?,?,?)"); 

preparedStatement.setString(1, name); 
preparedStatement.setInt(2, age); 
preparedStatement.setString(3, job); 

// execute insert SQL stetement 
preparedStatement.executeUpdate(); 
0

您需要將結果變量添加到字符串引號中。

例如: insert into table test1(sno,name)values(1,jj);

上面一行拋出錯誤,如果我們編輯下同它的工作原理

插入到表TEST1(SNO,姓名)值(1, 「JJ」);

這裏名字的數據類型是字符串

相關問題