从mysql批量导入数据时,出现一个诡异的现象,求帮助


现象是dolphindb这边的count居然会自己缩小。比如说运行一次,所有的行数一样了,过几分钟在运行一次,发现ddb这边的表的行数变小了,于是又出发了导入。
求解答!谢谢。如需要,可以提供mysql表的csv文件
代码如下:

conn = mysql::connect(localhost, 3306, `xxx, "xxx", `db_name)

dbPath="dfs://db_name"
yearRange=date(2005.01M + 12*0..22)

db=database(dbPath,RANGE,yearRange)

a = mysql::load(conn, "select count(*) from `" + i + "`") // i代表其中一个表,为了容易看明白,把循环去掉了
if(existsTable(dbPath, i)){
    b = select count(*) from loadTable(dbPath, i)
}else{
        b = {"count": 0}
}
rows_to_import =  a['count(*)'][0] - b['count'][0]
if (a['count(*)'][0] > 0 and rows_to_import > 0){
    print "         " + i + " in mysql's row count is " + a['count(*)'][0] + " in ddb's is " + b['count'][0]
    print 'importing ' + i + ' with ' + rows_to_import + ' rows'
    mysql::loadEx(conn, db, i, `timestamp, i,, b['count'][0], rows_to_import)
}else{
    print 'skiping ' + i

请先 登录 后评论