From bee4d03051f24b20fc895fbe624602e3d6e07b7d Mon Sep 17 00:00:00 2001 From: wanggang <76527413@qq.com> Date: Thu, 17 Sep 2020 17:28:24 +0800 Subject: [PATCH] update Former-commit-id: 7a7a36ef69139b0e335d276903a6ee87cfe5ec0d Former-commit-id: b252302cec00f1d2baae4b6db8fdfee7e46694c5 --- labs/kafka/KafkaEFTest/Program.cs | 2 ++ 1 file changed, 2 insertions(+) diff --git a/labs/kafka/KafkaEFTest/Program.cs b/labs/kafka/KafkaEFTest/Program.cs index df50b6bc..1f2b8b91 100644 --- a/labs/kafka/KafkaEFTest/Program.cs +++ b/labs/kafka/KafkaEFTest/Program.cs @@ -158,6 +158,8 @@ namespace KafkaEFTest using (var cmd = conn.CreateCommand()) { cmd.CommandTimeout = 60; + //不需要update,只需要插入,主键相同的自动合并 + //可以delete,不建议delete,建议更新标志位 cmd.CommandText = $"insert into test (`id`,`value`,`number`) values ('{entity.Id}','{entity.Value}',{entity.Number})"; cmd.ExecuteNonQuery(); }