sql - 在 R 中使用 rimpala 将插入插入到查询中

Question

我正在尝试使用函数insert into对 impala 表执行查询，但出现错误。我正在执行的查询是：rimpala.query()R

for(x in nrow)
{
    rite <- paste("INSERT INTO table1 (account_no, data_id, date_id, industry_no, sales_no, sales) VALUES (1445367,",data_frame1$data_id[x] ,",25,11346,23,", data_frame1$sales[x], ")",sep="")
    sql <- rimpala.query(rite);

}

其中data_frame1是具有一堆行的数据框，nrow是 中的行数data_frame1。第一条insert into语句执行并将第一个数据插入到数据库中，但在执行之后它会抛出一个错误，因为

Error in rimpala.query(sql) : SQL error Error: The query did not generate a result set!

如何消除此错误？

Answer 1

错误出现在RImpala客户端中，该客户端使用executeQuery来运行所有查询，即使是那些修改状态的查询。他们应该对 DDL 和 INSERT、UPDATE 或 DELETE 查询使用executeUpdate 。我已经为你在上游提交了一个问题。