Атомарные транзакции MySQL в Anorm

Я написал простой счетчик посещений, который обновляет таблицу базы данных MySQL с помощью Anorm. Я хочу, чтобы транзакция была атомарной. Я думаю, что лучшим способом было бы объединить все строки SQL вместе и выполнить один запрос, но с Anorm это не представляется возможным. Вместо этого я поместил каждый выбор, обновление и фиксацию в отдельные строки. Это работает, но я не могу отделаться от мысли, что это должно быть лучше.

private def incrementHitCounter(urlName:String) {
  DB.withConnection { implicit connection =>
    SQL("start transaction;").executeUpdate()
    SQL("select @hits:=hits from content_url_name where url_name={urlName};").on("urlName" -> urlName).apply()
    SQL("update content_url_name set hits = @hits + 1 where url_name={urlName};").on("urlName" -> urlName).executeUpdate()
    SQL("commit;").executeUpdate()
  }
}

Может ли кто-нибудь увидеть лучший способ сделать это?


mysql scala anorm
person Arthur    schedule 16.03.2014    source источник

Ответы (1)


arrow_upward
10
arrow_downward

Используйте withTransaction вместо withConnection следующим образом:

private def incrementHitCounter(urlName:String) {
  DB.withTransaction { implicit connection =>
    SQL("select @hits:=hits from content_url_name where url_name={urlName};").on("urlName" -> urlName).apply()
    SQL("update content_url_name set hits = @hits + 1 where url_name={urlName};").on("urlName" -> urlName).executeUpdate()
  }
}

И зачем вообще использовать здесь транзакцию? Это также должно работать:

private def incrementHitCounter(urlName:String) {
  DB.withConnection { implicit connection =>
    SQL("update content_url_name set hits = (select hits from content_url_name where url_name={urlName}) + 1 where url_name={urlName};").on("urlName" -> urlName).executeUpdate()
  }
}
person serejja    schedule 17.03.2014