我正在使用 PostLikes 表搜索 (PostId,UserId)SqlDataAdapter
,如果找到该行,我正在使用SqlCommandBuilder.GetDeleteCommand()
生成删除指令并删除底层行,如果找不到该行,那么我使用SqlCommandBuilder.GetInsertCommand()
生成插入命令并将行插入到表中使用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");
和桌子
帖子喜欢(喜欢 ID、帖子 ID、用户 ID)
有几个问题:
- 您希望重用相同的命令来检测该行是否存在,并提供给
SqlAdapter
为了SqlCommandBuilder
.
- 您应该参数化初始选择查询以防止 Sql 注入攻击(并且有一点性能优势)。 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
组合。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)