使用变量加载数据INFILE

Has*_*han 5 c# mysql load-data-infile

我想把LOAD DATA INFILE用作sotred程序,但似乎无法完成.然后我尝试了通常的方式将代码嵌入到应用程序本身,就像这样,

conn = new MySqlConnection(connStr);
conn.Open();
MySqlCommand cmd = new MySqlCommand();
cmd = conn.CreateCommand();
string tableName = getTableName(serverName);
string query = "LOAD DATA INFILE '" + fileName + "'INTO TABLE "+ tableName +" FIELDS TERMINATED BY '"+colSep+"' ENCLOSED BY '"+colEncap+"' ESCAPED BY '"+colEncap+"'LINES TERMINATED BY '"+colNewLine+"' ("+colUpFormat+");";
cmd.CommandText = query;
cmd.ExecuteNonQuery();
conn.Close();
Run Code Online (Sandbox Code Playgroud)

生成的查询保存在字符串变量查询中,

        LOAD DATA INFILE 'data_file.csv'INTO TABLE tbl_shadowserver_bot_geo FIELDS TERMINATED BY ',' ENCLOSED BY '"' ESCAPED BY '"'LINES TERMINATED BY '\n' (timestamp,ip,port,asn,@dummy,@dummy,@dummy,@dummy,@dummy,@dummy,url,agent,@dummy,@dummy,@dummy,@dummy,@dummy,@dummy,@dummy,@dummy,@dummy,@dummy,@dummy);
Run Code Online (Sandbox Code Playgroud)

但现在当我运行该程序时,它给出了一个错误说,

        MySQLException(0x80004005) Parameter @dummy must be defined first.
Run Code Online (Sandbox Code Playgroud)

我不知道怎么解决这个问题,但是当我直接在mysql上使用相同的查询时它工作正常.请帮助我......非常感谢你:)

Has*_*han 8

我自己找到了解决方案,就是设定这个条件,

      Allow User Variables=true;
Run Code Online (Sandbox Code Playgroud)

在连接字符串中允许在查询中使用@parameter值:)

感谢您的回复 :)