捕获重复条目OleDbException -覆盖-覆盖

Question

​

​

在尝试向Access数据库添加行时，我在处理条目时遇到此错误。问题是，我正在处理的一些条目是唯一的，而另一些条目可能具有对相关列进行更新的重复主键。但是，由于其中一些具有重复的主键，因此处理的所有内容都会失败。

我想用新数据覆盖重复的条目，并添加新条目。我该怎么做呢？

我在下面做了一些测试，试图使用try / catch块解决所有失败的问题，但都没有用：

            using (OleDbConnection myCon = new OleDbConnection("Provider=Microsoft.ACE.OLEDB.12.0;Data Source=C:\\Users\\Lenovo\\Desktop\\Weather Cruncher\\wcMainDB.accdb"))
            {
                OleDbCommand cmd = new OleDbCommand();
                cmd.CommandText = "Insert into stations_NOAA " +
                    "([stationID],[stationName],[stationMinDate],[stationMaxDate],[stationDataCoverage]," +
                    "[stationLatitude],[stationLongitude],[stationElevation],[stationElevationUnit])" +
                    "values (?,?,?,?,?,?,?,?,?)";
                cmd.Connection = myCon;
                myCon.Open();

                // Populate Access Database
                foreach (Station loc in noaa.results)
                {
                    try
                    {
                        cmd.Parameters.AddWithValue("@stationID", loc.id); // Short Text data type
                        cmd.Parameters.AddWithValue("@stationName", loc.name); // Short Text data type
                        cmd.Parameters.AddWithValue("@stationMinDate", loc.mindate); // Short Text data type
                        cmd.Parameters.AddWithValue("@stationMaxDate", loc.maxdate); // Short Text data type
                        cmd.Parameters.AddWithValue("@stationDataCoverage", loc.datacoverage); // Number data type
                        cmd.Parameters.AddWithValue("@stationLatitude", loc.latitude); // Number data type
                        cmd.Parameters.AddWithValue("@stationLongitude", loc.longitude); // Number data type
                        cmd.Parameters.AddWithValue("@stationElevation", loc.elevation); // Number data type
                        cmd.Parameters.AddWithValue("@stationElevationUnit", loc.elevationUnit); // Short Text data type
                        cmd.ExecuteNonQuery();
                        cmd.Parameters.Clear();
                    }
                    catch(Exception ex)
                    {
                        if (ex.Message.Contains("duplicate values")) // It is a primary key violation, ignore
                        {
                            Console.WriteLine("Dupe skipped.");
                            continue;
                        }
                        else
                        {
                            MessageBox.Show(ex.ToString() + "\n\n" + ex.Message);
                        }
                    }
                }
            }

它正在处理20个查询，其中15个是唯一的。我一边比较主键和程序正在处理的数据，一边一步一步地看着它。如何解决这两个问题？

Answer 1

也许可以考虑像这样的事情。假设Station_ID是一个唯一的字段...

foreach (Station loc in noaa.results)
{
    cmdCount.CommandText = "SELECT count(*) from stations_NOAA WHERE StationId = @station_id";
    cmdCount.Parameters.AddWithValue("@station_id", loc.id);
    int count = (int)cmdCount.ExecuteScalar();

    if (count > 0)
    {
         // UPDATE STATEMENT
         cmd.CommandText "UPDATE stations_NOAA Set stationMinDate = @stationMinDate, Set StationMaxDate = @stationMaxDate, ...
             where StationID = @stationID;"
        cmd.Parameters.AddWithValue("@stationID", loc.id); // Short Text data type
        cmd.Parameters.AddWithValue("@stationMinDate", loc.mindate); // Short Text data type
        cmd.Parameters.AddWithValue("@stationMaxDate", loc.maxdate); // Short Text data type
        ...
        ...
        cmd.ExecuteNonQuery();
    }
    else
    {
         // INSERT STATEMENT
         commandText = ("Insert into stations_NOAA " +
                        "([stationID],[stationName],[stationMinDate],[stationMaxDate],[stationDataCoverage]," +
                        "[stationLatitude],[stationLongitude],[stationElevation],[stationElevationUnit])" +
                        "values (?,?,?,?,?,?,?,?,?)";
         cmd.Parameters.AddWithValue("@stationID", loc.id); // Short Text data type
        cmd.Parameters.AddWithValue("@stationMinDate", loc.mindate); // Short Text data type
        cmd.Parameters.AddWithValue("@stationMaxDate", loc.maxdate); // Short Text data type
        ...
        ...
        cmd.ExecuteNonQuery();
    }
    cmd.Parameters.Clear();
}

如果Update和Insert中的所有参数都相同，则此模式：

foreach (Station loc in noaa.results)
{
    cmd.CommandText = "SELECT count(*) from stations_NOAA WHERE StationId = @station_id", myConnection);
    cmdCount.Parameters.AddWithValue("@station_id", loc.id);
    int count = (int)cmdCount.ExecuteScalar();

    if (count > 0)
        cmd.CommandText "UPDATE stations_NOAA " _
            "Set stationMinDate = @stationMinDate, " _
            "Set StationMaxDate = @ StationMaxDate, " _
               ...
            "where StationID = @stationID;"

    else
        commandText = "Insert into stations_NOAA " +
                        "([stationID],[stationName],[stationMinDate],[stationMaxDate],[stationDataCoverage]," +
                        "[stationLatitude],[stationLongitude],[stationElevation],[stationElevationUnit])" +
                        "values (@stationID,@stationMinDate, @ ...)";

    cmd.Parameters.AddWithValue("@stationID", loc.id); // Short Text data type
    cmd.Parameters.AddWithValue("@stationMinDate", loc.mindate); // Short Text data type
    cmd.Parameters.AddWithValue("@stationMaxDate", loc.maxdate); // Short Text data type
    ...
    ...

    cmd.ExecuteNonQuery();      

    cmd.Parameters.Clear();
}

但是，只有当Insert和Update都有相同的字段，并且更清晰易读时，这才能起作用。