Rails Postgres requis ne renvoie pas de nouveaux enregistrements

C'est ce que le test est pour. xxx

vous testez le code: xxx

etc

P.S. Pensez à utiliser Redis ou quelque chose comme ça. Sinon, vous voulez faire quelque chose comme des serrures de table pour vous assurer de ne pas marcher sur vous-même. Et vous ne voulez probablement pas faire des serrures de table.

Un moyen d'empêcher les doublons dans les rails est avec des validations: Correction correcte de prévenir les enregistrements en double dans les rails

Cependant Vos critères sont plus complexes car ils traitent de plus d'une ligne. Je pense que vos critères sont, n'autorisent pas l'entrée d'un enregistrement de transit si l'enregistrement de transit le plus récent a été créé il y a moins de 20 secondes. Est-ce correct? P>

Essayer de faire respecter une contrainte qui consiste à regarder des données de nombreuses lignes est mentionnée comme indésirable ici: SQL Sous-requêtes dans la contrainte de contrôle P>

Un déclencheur pourrait être utilisé pour appliquer votre contrainte au niveau de la base de données. On pourrait attraper la gâchette dans une exception. Il y a un gemme nommé huillard qui pourrait être utile, pas sûr. P>

Prendre des idées d'ici: https : //karolganancienk.com/blog/2016/05/06/When-validation-is-not-Eveng-Postgresql-triggers-for-Data-Integrity/ P>

Exemple avec la gâchette postgreSQL : p> xxx pré>

Voici la partie de notre requête qui donne la dernière entrée de transit avec notre étiquette p> xxx pré>

modifiant pour donner La différence entre le courant_timettamp (maintenant) et la dernière entrée de transit avec notre balise. Cette différence est un intervalle dans PostgreSQL. Utilisation de UTC pour correspondre aux rails: P>

#!/usr/bin/env ruby

require 'active_record'
require 'action_view'

path = "/home/user1/rails/dup_test/app/models"
require "#{path}/application_record.rb"
Dir.glob(path + "/*.rb").sort.each do | file |
  require file
end

ActiveRecord::Base.establish_connection(
  :adapter => "postgresql",
  :database  => 'dup_test_development',
  encoding: "unicode",
  username: "user1",
  password: nil
)
class Test
  def initialize()
  end
  def go()
    begin
      t = Transit.new(tag: 'test_tag')
      t.save
    rescue ActiveRecord::StatementInvalid => e
      p e
      p e.cause.message
    end
  end
end

def main
  begin
    t = Test.new()
    t.go()
  rescue Exception => e
    puts e.message
  end
end

main

Je crois que c'était une question de concurrence.

Les transactions RAILS continuent de manière asynchrone après les retours Activerecord. À tout moment, le commit prend 15 secondes pour l'appliquer, cela entraînera ce problème. Ceci est long et improbable, mais possible.

Je ne peux pas prouver que c'est ce qui s'est passé, mais il semble être la seule explication. Empêcher cela nécessiterait une procédure stockée DB ou comme @philipwright suggérée ou un verrou distribué comme vous et @kwerle suggéré.