blob: 7ea83130838d5038fc047cc4f6ccf27411b98ab6 (
plain)
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
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
|
// file : odb/database.cxx
// copyright : Copyright (c) 2009-2015 Code Synthesis Tools CC
// license : GNU GPL v2; see accompanying LICENSE file
#include <odb/database.hxx>
#include <odb/details/lock.hxx>
using namespace std;
namespace odb
{
using details::lock;
database::
~database ()
{
}
unsigned long long database::
execute (const char* st, std::size_t n)
{
connection_type& c (transaction::current ().connection ());
return c.execute (st, n);
}
const database::schema_version_migration_type& database::
schema_version_migration (const string& name) const
{
lock l (*mutex_); // Prevents concurrent loading.
schema_version_map::const_iterator i (schema_version_map_.find (name));
return i != schema_version_map_.end () && i->second.version != 0
? i->second
: load_schema_version (name);
}
void database::
schema_version_migration (const schema_version_migration_type& svm,
const string& name)
{
// Note: no lock, not thread-safe.
schema_version_info& svi (schema_version_map_[name]);
if (svi.version != svm.version || svi.migration != svm.migration)
{
svi.version = svm.version;
svi.migration = svm.migration;
schema_version_seq_++;
}
}
bool database::
call_query_factory (const char* name, connection_type& c) const
{
query_factory_map::const_iterator i (query_factory_map_.find (name));
if (i == query_factory_map_.end ())
i = query_factory_map_.find (""); // Wildcard factory.
if (i == query_factory_map_.end ())
return false;
const query_factory_wrapper& fw (i->second);
if (fw.std_function == 0)
fw.function (name, c);
else
{
typedef void (*caller) (const void*, const char*, connection_type&);
reinterpret_cast<caller> (fw.function) (fw.std_function, name, c);
}
return true;
}
void database::
query_factory (const char* name, query_factory_wrapper w)
{
if (w)
query_factory_map_[name] = w; // Destructive copy assignment (move).
else
query_factory_map_.erase (name);
}
}
|