Трудно найти хороший учебник по SqlDataAdapter / заставить мой код работать

Question

Ранее я задавал вопрос о том, как я могу сделать простую вставку / обновление из файла CSV в базу данных. Мне дали код, который я принял здесь. RecordList - это проанализированный CSV-файл как коллекция:

SqlDataAdapter dataAdpater = new SqlDataAdapter(
    "SELECT * FROM Cats WHERE UniqueCatName = @UniqueCatName", "data source=localhost;initial catalog=Kitties;integrated security=True;MultipleActiveResultSets=True;");

DataTable testTable = new DataTable();

  dataAdpater.Update(testTable);

foreach (var record in recordList)
{
    dataAdpater.SelectCommand.Parameters.AddWithValue("@UniqueCatName", record.UniqueCatName);

    int rowsAdded = dataAdpater.Fill(testTable);
    if (rowsAdded == 0)
    {
        testTable.Rows.Add(
            record.UniqueCatName,
            record.Forename,
            record.Surname
            );
    }
    else
    {

    }
}

dataAdpater.Update(testTable);

Я как бы зашла в тупик, я просмотрела тонну учебных пособий, но не смогла найти ту, в которой было бы четко продемонстрировано, как использовать SqlDataAdapter для добавления и обновления.

Из того, что я прочитал, вы должны указать команду обновления и команду вставки? Так что я не уверен, что происходит с кодом выше, но я думаю, что он может сделать простую вставку без дополнительных инструкций.

Я не мог понять, что вставить в бит "еще", хотя тот, который дал ответ на мой предыдущий вопрос, дал. Мне нужно получить и обновить конкретную строку, но я не знаю, как это сделать. Есть идеи?

Answer 1

Если кому-то интересно, я сделал это. Это нерефакторированная версия. Он вставляет, если они не существуют, и обновляет существующие записи, если они уже существуют. Я надеюсь, что это поможет кому-то в будущем:

SqlDataAdapter dataAdpater = new SqlDataAdapter(
    "SELECT * FROM Cats WHERE URN = @URN", "data source=...");

dataAdpater.InsertCommand = new SqlCommand("INSERT INTO Cats VALUES (@URN, @Forename, @Middlename, @Surname)", new SqlConnection("data source=..."));

dataAdpater.UpdateCommand = new SqlCommand("UPDATE Cats SET Forename=@Forename, Middlename=@Middlename, Surname=@Surname WHERE URN=@URN", new SqlConnection("data source=..."));

DataTable testTable = new DataTable();

dataAdpater.Update(testTable);

dataAdpater.SelectCommand.Parameters.Add("@URN", SqlDbType.NVarChar, 256, "URN");

dataAdpater.InsertCommand.Parameters.Add("@URN", SqlDbType.NVarChar, 256, "URN");
dataAdpater.InsertCommand.Parameters.Add("@Forename", SqlDbType.NVarChar, 256, "Forename");
dataAdpater.InsertCommand.Parameters.Add("@Middlename", SqlDbType.NVarChar, 256, "Middlename");
dataAdpater.InsertCommand.Parameters.Add("@Surname", SqlDbType.NVarChar, 256, "Surname");

dataAdpater.UpdateCommand.Parameters.Add("@URN", SqlDbType.NVarChar, 256, "URN");
dataAdpater.UpdateCommand.Parameters.Add("@Forename", SqlDbType.NVarChar, 256, "Forename");
dataAdpater.UpdateCommand.Parameters.Add("@Middlename", SqlDbType.NVarChar, 256, "Middlename");
dataAdpater.UpdateCommand.Parameters.Add("@Surname", SqlDbType.NVarChar, 256, "Surname");

foreach (var record in recordList)
{
    dataAdpater.SelectCommand.Parameters["@URN"].Value = record.URN;

    int rowsAdded = dataAdpater.Fill(testTable);
    if (rowsAdded == 0)
    {
        var newRow = testTable.NewRow();

        newRow["URN"] = record.URN;
        newRow["Forename"] = record.Forename;
        newRow["MiddleName"] = record.MiddleName;
        newRow["Surname"] = record.Surname;

        testTable.Rows.Add(newRow);
    }
    else
    {
        foreach (DataRow row in testTable.Rows)
        {
            if (row[1].ToString() == record.URN)
            {
                row["Forename"] = record.Forename;
                row["MiddleName"] = record.MiddleName;
                row["Surname"] = record.Surname;
            }
        }
    }
}

dataAdpater.Update(testTable);

Answer 2

Вы можете начать с чего-то вроде этого, который добавит все записи из RecordList:

string connectionString = ....;
SqlDataAdapter  adapter = new SqlDataAdapter("Select * From Cats", connectionString);

// The command builder will generate the Add, Update and Delete commands
// based on the select command
SqlCommandBuilder cmdBuilder = new SqlCommandBuilder(adapter);

DataTable testTable = new DataTable("Cats");
adapter.Fill(testTable);  // retrieve all existing rows

// Add each record from recordList
foreach (var record in recordList)
{
    // TODO - Handle duplicates
    testTable.Rows.Add(
        record.UniqueCatName,
        record.Forename,
        record.Surname
    );
}

adapter.Update(testTable);