dataframe到配置单元的插入查询

4ioopgfo  于 2021-06-01  发布在  Hadoop
关注(0)|答案(0)|浏览(299)

我的问题是,是否有一种方法可以用 insert 语句,其中x为列,y为行,类似于pandas的dataframe对象:

query = "INSERT INTO %s SELECT %s, %s, %s, %s, %s, %s, %s from " % (
    table_name, column_names[0], column_names[1], column_names[2], column_names[3], column_names[4], column_names[5], column_names[6])

我以以下Dataframe为例:

metric predict_date         value        y_date      x_date  ... (many columns) 
0  sales   2017-10-01  7.539010e+06   2016-06-01   2017-09-01
1  sales   2017-11-01  8.364379e+06   2016-07-01   2017-09-01
2  sales   2017-12-01  9.533355e+06   2016-08-01   2017-09-01
.
.
.
(many rows)

这里的用例只是构造查询。
注:
pandas的to_sql()实际上是在向sql中写入我不想在我的用例中使用的内容。
我相信spark是一种选择,但是有没有一种快速简单的方法来生成它,因为设置spark cluster需要时间。:-)

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题