SqlDataAdapter.update（）不更新数据库

Question

我正在使用（）查找PostLikes表中的（PostId，UserId）SqlDataAdapter，如果找到该行，则SqlCommandBuilder.GetDeleteCommand()用于生成delete指令并删除基础行，如果未找到该行，则SqlCommandBuilder.GetInsertCommand()用于生成insert命令并使用将该行插入表中SqlDataAdapter.Update()。但是该行未插入数据库中的表中。这是我到目前为止所做的

SqlConnection con = new SqlConnection(connectionStrings);
SqlDataAdapter sqlDataAdapter=new SqlDataAdapter("select * from PostLikes where PostId like "
                                                 +postlike.PostId+" and UserId like "
                                                 +postlike.UserId,con);
DataSet ds = new DataSet();
sqlDataAdapter.Fill(ds, "Result");
con.Open();
SqlCommandBuilder sqlCommandBuilder = new SqlCommandBuilder(sqlDataAdapter);
if(ds.Tables["Result"].Rows.Count==1)
{
    sqlDataAdapter.DeleteCommand = sqlCommandBuilder.GetDeleteCommand(true);
    msg = "Data is deleted";
}
else
{
    sqlDataAdapter.InsertCommand = sqlCommandBuilder.GetInsertCommand(true);
    msg = "Data is inserted";
}
sqlDataAdapter.Update(ds, "Result");

和表
PostLikes（LikeId，PostId，UserId）

Answer 1

有几个问题：

• 您正在寻找重复使用相同的命令，这两个检测行是否存在，并提供给SqlAdapter了SqlCommandBuilder。
• 您应该对初始选择查询进行参数设置，以防止SqlInjection攻击（并且性能会有次要的好处）。CommandBuilder将自动参数化Insert/Delete命令
• 在使用创建了插入/删除命令SqlCommandBuilder之后，您需要更改基础数据集，以便在期间对表进行任何更改Update。
• 请注意，许多Sql对象都是IDisposable并且应该尽快处置-using范围在这里有所帮助。

。

var postId = 1;
var userId = 1;
string msg;
using (var con = new SqlConnection(@"data source=..."))
using (var selectCommand = new SqlCommand(
 "select LikeId, PostId, UserId from PostLikes WHERE PostId=@PostId AND UserId=@UserId", con))
using (var sqlDataAdapter = new SqlDataAdapter(selectCommand))
using (var ds = new DataSet())
{
    con.Open();
    selectCommand.Parameters.AddWithValue("@PostId", postId);
    selectCommand.Parameters.AddWithValue("@UserId", userId);
    sqlDataAdapter.Fill(ds, "Result");
    using (var sqlCommandBuilder = new SqlCommandBuilder(sqlDataAdapter))
    {
        if (ds.Tables["Result"].Rows.Count == 1)
        {
            sqlDataAdapter.DeleteCommand = sqlCommandBuilder.GetDeleteCommand(true);
            ds.Tables["Result"].Rows[0].Delete();
            msg = "Data will be deleted";
        }
        else
        {
            sqlDataAdapter.InsertCommand = sqlCommandBuilder.GetInsertCommand(true);
            // Null because LikeId is Identity and will be auto inserted
            ds.Tables["Result"].Rows.Add(null, postId, userId);
            msg = "Data will be inserted";
        }
        sqlDataAdapter.Update(ds, "Result");
    }
}

我假设以下架构：

CREATE TABLE PostLikes
(
    LikeId INT IDENTITY(1,1) PRIMARY KEY,
    PostId INT,
    UserId INT
)

而且我假设您想通过组合来“切换”行的插入或删除postId, userid。