如何使用C#中的本地数据库使用SQL Server CE执行SQL语句



我正试图将一条新记录插入到已设置的本地数据库的表(HistQuote)中。我正在使用SQL Server CE来创建和执行我的SQL语句。该表由8列组成:

  • 符号,数据类型:nchar(10)
  • 日期,数据类型:日期时间(8)
  • 打开,数据类型:数字(9)
  • 高,数据类型:数字(9)
  • 低,数据类型:数字(9)
  • 关闭,数据类型:数字(9)
  • Volumbe,数据类型:数字(9)
  • AdjClose,数据类型:数字(9)

但是当运行下面的代码时,我在上得到了以下错误

sqlCeCommand.ExecuteNonQuery():

分析查询时出错。[令牌线编号=1,令牌线偏移=64,令牌错误=关闭]

我不确定这是因为我的参数的数据类型与我的表不同还是其他原因。

谢谢你的帮助。

object[] objSQLArray = new object[8];
using (SqlCeConnection connection = new SqlCeConnection(Settings.Default.DataStorageConnectionString))
{ 
    for (int intCurrentQuote = 0; intCurrentQuote < this.clbStockSelect.CheckedItems.Count; ++intCurrentQuote)
    {
        for (int intCurrentDate = 0; intCurrentDate < Quotes[intCurrentQuote].HistStockDate.Count; ++intCurrentDate)
        {
            string strInsert = "INSERT INTO [HistQuote] ";
            string strColumns = "(Symbol, High, Low, Volumne, AdjClose, Close, Open, Date) ";
            string strValues = "VALUES (@Symbol, @High, @Low, @Volumne, @AdjClose, @Close, @Open, @Date)";
            objSQLArray[0] = this.Quotes[intCurrentQuote].HistSymbol;
            objSQLArray[7] = this.Quotes[intCurrentQuote].HistStockDate[intCurrentDate];
            objSQLArray[1] = this.Quotes[intCurrentQuote].HistOpen[intCurrentDate];
            objSQLArray[2] = this.Quotes[intCurrentQuote].HistHigh[intCurrentDate];
            objSQLArray[3] = this.Quotes[intCurrentQuote].HistLow[intCurrentDate];
            objSQLArray[4] = this.Quotes[intCurrentQuote].HistClose[intCurrentDate];
            objSQLArray[5] = this.Quotes[intCurrentQuote].HistVolume[intCurrentDate];
            objSQLArray[6] = this.Quotes[intCurrentQuote].HistAdjClose[intCurrentDate];
            using (SqlCeCommand sqlCeCommand = new SqlCeCommand(strInsert + strColumns + strValues, connection))
            {
                sqlCeCommand.Connection.Open();
                sqlCeCommand.Parameters.Clear();
                sqlCeCommand.Parameters.Add(new SqlCeParameter("@Symbol", SqlDbType.NChar));
                sqlCeCommand.Parameters.Add(new SqlCeParameter("@Date", SqlDbType.DateTime));
                sqlCeCommand.Parameters.Add(new SqlCeParameter("@Open", SqlDbType.Real));
                sqlCeCommand.Parameters.Add(new SqlCeParameter("@High", SqlDbType.Real));
                sqlCeCommand.Parameters.Add(new SqlCeParameter("@Low", SqlDbType.Real));
                sqlCeCommand.Parameters.Add(new SqlCeParameter("@Close", SqlDbType.Real));
                sqlCeCommand.Parameters.Add(new SqlCeParameter("@Volume", SqlDbType.Real));
                sqlCeCommand.Parameters.Add(new SqlCeParameter("@Adj_Close", SqlDbType.Real));
                sqlCeCommand.Parameters["@Symbol"].Size = 10;
                sqlCeCommand.Prepare();
                sqlCeCommand.Parameters["@Symbol"].Value = objSQLArray[0].ToString();
                sqlCeCommand.Parameters["@Date"].Value = objSQLArray[7];
                sqlCeCommand.Parameters["@Open"].Value = objSQLArray[1];
                sqlCeCommand.Parameters["@High"].Value = objSQLArray[2];
                sqlCeCommand.Parameters["@Low"].Value = objSQLArray[3];
                sqlCeCommand.Parameters["@Close"].Value = objSQLArray[4];
                sqlCeCommand.Parameters["@Volume"].Value = objSQLArray[5];
                sqlCeCommand.Parameters["@Adj_Close"].Value = objSQLArray[6];
                sqlCeCommand.ExecuteNonQuery();
                sqlCeCommand.Parameters.Clear();
            }
        }
    }
    connection.Close();
}

打开和关闭都是保留字,请将列名放在sql语句中的方括号中:

[Close], [Open], [Date]

相关内容

  • 没有找到相关文章

最新更新