質問
私が理解している限り、EF（とEF Core）には、私が照会しているリソースを明示的にロックするオプションはありませんが、この機能はかなり頻繁に必要になります。私がそれを必要とするたびにselectステートメント。
Postgresにのみ必要なので、 FOR UPDATE の仕様に従って、 FOR UPDATEは最後の項目です。ここで説明するようにselect文を取得するのが最も簡単でした。Linq to Entitiesでは、IQueryableをSQLの文字列？ FOR UPDATEを追加して直接実行します。しかし、これは私にパラメータプレースホルダを持つクエリを提供するか、実行計画のキャッシュが実際にはポストグルでは機能しないことを意味する準備されたクエリではないので、どちらの方法においても問題ありません。
Linq to SQLにはDataContext.GetCommandというメソッドがありましたが、EFや特にEF Coreには何もないようです。私はEntityFramework.Extendedとバッチの更新/削除についても見てきましたが、selectステートメントを別のステートメントに変換する必要があるため、私よりもはるかに複雑な処理が必要なので、よりシンプルなソリューションを望みます。
更新：
説明から明らかでない場合は、次のような拡張メソッドを作成します。
public static IList<T> ForUpdate (this IQueryable<T> me)
{
// this line is obviously what is missing for me :)
var theUnderlyingCommand = me.GetTheUnderlyingDbCommandOrSimilar();
theUnderlyingCommand.Text += "FOR UPDATE";
return me.ToList();
}
この方法で、他の開発者は、他のすべての手順と同様のLINQを経由してEFを使用して、代わりに実行することができ.ToList()は、実行したい.ForUpdate() （ FOR UPDATEはpostgresでサポートされている最後のオプションであるため、Updateは実装を容易にするためにクエリを実行し、その後はもう何も存在しないはずです）
人気のある回答
この作業は、SQLServerを使用している（テストされた非同期メソッドはありません）：
まず、DbCommandInterceptorを作成します（HintInterceptor.csと呼ばれます）
using System;
using System.Data.Common;
using System.Data.Entity.Infrastructure.Interception;
using System.Text.RegularExpressions;
public class HintInterceptor : DbCommandInterceptor
{
private static readonly Regex _tableAliasRegex = new Regex(@"(?<tableAlias>FROM +(\[.*\]\.)?(\[.*\]) AS (\[.*\])(?! WITH \(*HINT*\)))", RegexOptions.Multiline | RegexOptions.IgnoreCase | RegexOptions.Compiled);
[ThreadStatic]
public static string HintValue;
private static string Replace(string input)
{
if (!String.IsNullOrWhiteSpace(HintValue))
{
if (!_tableAliasRegex.IsMatch(input))
{
throw new InvalidProgramException("Não foi possÃvel identificar uma tabela para ser marcada para atualização(forupdate)!", new Exception(input));
}
input = _tableAliasRegex.Replace(input, "${tableAlias} WITH (*HINT*)");
input = input.Replace("*HINT*", HintValue);
}
HintValue = String.Empty;
return input;
}
public override void ScalarExecuting(DbCommand command, DbCommandInterceptionContext<object> interceptionContext)
{
command.CommandText = Replace(command.CommandText);
}
public override void ReaderExecuting(DbCommand command, DbCommandInterceptionContext<DbDataReader> interceptionContext)
{
command.CommandText = Replace(command.CommandText);
}
}
Web.configにインターセプタークラスを登録します
<entityFramework>
<defaultConnectionFactory type="System.Data.Entity.Infrastructure.SqlConnectionFactory, EntityFramework" />
<providers>
<provider invariantName="System.Data.SqlClient" type="System.Data.Entity.SqlServer.SqlProviderServices, EntityFramework.SqlServer" />
</providers>
<interceptors>
<interceptor type="Full.Path.Of.Class.HintInterceptor, Dll.Name" />
</interceptors>
</entityFramework>
次に、HintExtensionという静的クラスを作成します
public static class HintExtension
{
public static IQueryable<T> WithHint<T>(this IQueryable<T> set, string hint) where T : class
{
HintInterceptor.HintValue = hint;
return set;
}
public static IQueryable<T> ForUpdate<T>(this IQueryable<T> set) where T : class
{
return set.WithHint("UPDLOCK");
}
}
それだけです。次のようなデータベーストランザクション内で使用できます。
using(var trans = context.Database.BeginTransaction())
{
var query = context.mydbset.Where(a => a.name == "asd").ForUpdate();
// not locked yet
var mylist = query.ToList();
// now are locked for update
// update the props, call saveChanges() and finally call commit ( or rollback)
trans.Commit();
// now are unlocked
}
私の英語で申し訳ありませんが、私の例が役立つことを願っています。
ライセンスを受けた: CC-BY-SA with attribution
所属していない Stack Overflow