0

我正在尝试将以下 MySqlCommand 放在一起。

string cols = "(DateTime, Ticker, Open, High, Low, Close, Volume, ReqCode, UpdateTime)"; 
string parametrs = "(?DateTime, ?Ticker, ?Open, ?High, ?Low, ?Close, ?Volume, ?ReqCode, ?UpdateTime)"; //, ?UpdateTime)";

try {
    using (MySqlCommand cmd = new MySqlCommand()) {
        cmd.Connection = myConn;
        cmd.CommandText = "INSERT INTO " + schema + cols + " VALUES" + parametrs + "\n ON DUPLICATE KEY UPDATE ReqCode = ?ReqCode AND UpdateTime = ?UpdateTime";
        cmd.Parameters.Add("?DateTime", MySqlDbType.DateTime).Value = aPriceBar.BarTimestamp;
        cmd.Parameters.Add("?Ticker", MySqlDbType.VarChar).Value = aPriceBar.Ticker;
        cmd.Parameters.Add("?Open", MySqlDbType.Decimal).Value = aPriceBar.Open;
        cmd.Parameters.Add("?High", MySqlDbType.Decimal).Value = aPriceBar.High;
        cmd.Parameters.Add("?Low", MySqlDbType.Decimal).Value = aPriceBar.Low;
        cmd.Parameters.Add("?Close", MySqlDbType.Decimal).Value = aPriceBar.Close;
        cmd.Parameters.Add("?Volume", MySqlDbType.UInt32).Value = aPriceBar.Volume;
        cmd.Parameters.Add("?ReqCode", MySqlDbType.VarChar).Value = aPriceBar.ReqCode;
        cmd.Parameters.Add("?UpdateTime", MySqlDbType.DateTime).Value = aPriceBar.ReqTimestamp;
        cmd.ExecuteNonQuery();
    }
} catch (MySqlException ex) {
    Console.WriteLine(ex.Message);
}

当我运行程序时，我捕获了以下异常：

“您的 SQL 语法有错误；...在 ''2013-10-28 16:23:26.379' 附近使用正确的语法

我确定 2013-10-28 是 ReqTimestamp 中的日期。

我很惊讶，因为当我没有向查询中添加对 UpdateTime 列的引用时，INSERT 查询通过：查询成功地将 DateTime 类型与另一列 (Datetime) 一起使用。但是，a) aPriceBar.ReqTimestamp 是 DateTime，其中 reqTimestamp = DateTime.UtcNow 而 b) aPriceBar.BarTimestamp 由

DateTime datetime = DateTime.ParseExact(sFields[0], "yyyy-MM-dd HH:mm:ss", CultureInfo.InvariantCulture);

''2013-10-28 16:23:26.379'：一天之后的“.379”让我怀疑当我使用 UctNow 时，而不是 ParseExactsome 和 CultureInfo.InvariantCulture，一些时区信息被添加到 DateTime 实例中。

我用 MySQL 工作台检查了表定义，它看起来没问题。

不知道如何解决这个问题。谢谢！

4

2 回答 2

0

如果您的 db 字段是“datetime”而不是 datetime2 /offset，则可能是 xxx:xxx.379 部分的问题。

于 2013-10-28T16:09:11.117 回答
0

我想到了。

问题实际上出在 SQL 查询语法上。

cmd.CommandText = "INSERT INTO " + schema + cols + " VALUES" + parametrs + "\n ON DUPLICATE KEY UPDATE ReqCode = ?ReqCode AND UpdateTime = ?UpdateTime";

ON DUPLICATE KEY UPDATE 不支持 AND 但需要逗号代替 ( http://dev.mysql.com/doc/refman/5.0/en/insert-on-duplicate.html )

cmd.CommandText = "INSERT INTO " + schema + cols + " VALUES" + parametrs + "\n ON DUPLICATE KEY UPDATE ReqCode = ?ReqCode , UpdateTime = ?UpdateTime";

我之前没有弄清楚，因为我还没有找到查看最终查询字符串并检查占位符如何被查询中的参数替换的方法。

谢谢大家的帮助。

于 2013-10-29T08:27:12.353 回答