我的问题是,是否有一种方法可以用 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需要时间。:-)
暂无答案!
目前还没有任何答案,快来回答吧!