3 mysql数据导入到dolphindb的过程中,是否可以对数据进行修改?

mysql数据导入到dolphindb的过程中,是否可以对数据进行修改?如果可以,请问如何修改?能否举一个例子

请先 登录 后评论

1 个回答

Xinhai Tang

mysql数据导入到dolphindb的过程中,可以对数据进行修改。

方案1

通过mysql::load(connection, table_or_query, [schema], [startRow], [rowNum])将MySQL数据导入DolphinDB的一个内存表,对内存表进行修改操作后,再写入DolphinDB的dfs表。

方案2

通过mysql::loadEx(connection, dbHandle,tableName,partitionColumns,table_or_query,[schema],[startRow],[rowNum],[transform])直接将MySQL的数据导入DolphinDB的dfs表,可以通过transform参数做修改操作。

示例代码如下:



db = database("dfs://US", RANGE, 0 50000 10000)
def replaceTable(mutable t){
	return t.replaceColumn!(`svalue,t[`savlue]-1)
}
t=mysql::loadEx(conn, db, "",`stockid, 'select  * from US where stockid<=1000000',,,,replaceTable)



请先 登录 后评论