2016-02-03 24 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”);

这里名字的数据类型是字符串

相关问题