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)