libbrep/database-lock.cxx


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

// file      : libbrep/database-lock.cxx -*- C++ -*-
// copyright : Copyright (c) 2014-2018 Code Synthesis Ltd
// license   : MIT; see accompanying LICENSE file

#include <libbrep/database-lock.hxx>

#include <odb/pgsql/database.hxx>
#include <odb/pgsql/exceptions.hxx>
#include <odb/pgsql/transaction.hxx>

namespace brep
{
  using namespace odb::pgsql;

  database_lock::
  database_lock (database& db)
  {
    // Before locking the table make sure it exists.
    //
    {
      transaction t (db.begin ());
      db.execute ("CREATE TABLE IF NOT EXISTS database_mutex ()");
      t.commit ();
    }

    connection_ = db.connection ();

    // Don't make current. Will be rolled back in destructor.
    //
    transaction_.reset (new transaction (connection_->begin (), false));

    try
    {
      connection_->execute ("LOCK TABLE database_mutex NOWAIT");
    }
    catch (const database_exception& e)
    {
      if (e.sqlstate () == "55P03") // The table is already locked.
        throw database_locked ();

      throw;
    }
  }
}