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
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
|
/*
* Copyright (c) 2007, 2014, Oracle and/or its affiliates. All rights reserved.
*
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU General Public License as
* published by the Free Software Foundation; version 2 of the
* License.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
* 02110-1301 USA
*/
#include <grts/structs.db.migration.h>
#include <grtpp_util.h>
class db_migration_Migration::ImplData
{
public:
ImplData(){};
virtual ~ImplData() {};
void addSourceObject(const std::string& id, const grt::Ref<GrtObject> &object)
{
source_objects[id] = object;
}
grt::Ref<GrtObject>& getSourceObject(const std::string& id)
{
return source_objects[id];
}
void addTargetObject(const std::string& id, const grt::Ref<GrtObject> &object)
{
target_objects[id] = object;
}
grt::Ref<GrtObject>& getTargetObject(const std::string& id)
{
return target_objects[id];
}
private:
std::map<std::string, grt::Ref<GrtObject> > target_objects;
std::map<std::string, grt::Ref<GrtObject> > source_objects;
};
//================================================================================
// db_migration_Migration
void db_migration_Migration::init()
{
if (!_data) _data= new db_migration_Migration::ImplData();
}
db_migration_Migration::~db_migration_Migration()
{
delete _data;
}
grt::Ref<GrtLogObject> db_migration_Migration::addMigrationLogEntry(ssize_t type, const grt::Ref<GrtObject> &sourceObject, const grt::Ref<GrtObject> &targetObject, const std::string &message)
{
GrtLogObjectRef log = findMigrationLogEntry(sourceObject, targetObject);
if (!log.is_valid())
{
log = GrtLogObjectRef(get_grt());
log->owner(this);
log->logObject(sourceObject);
log->refObject(targetObject);
migrationLog().insert(log);
}
GrtLogEntryRef entry = GrtLogEntryRef(get_grt());
entry->owner(log);
entry->entryType(type);
entry->name(grt::StringRef(message));
log->entries().insert(entry);
if(0 == type)
{
this->_data->addSourceObject(targetObject->id(), sourceObject);
this->_data->addTargetObject(sourceObject->id(), targetObject);
}
return log;
}
grt::Ref<GrtLogObject> db_migration_Migration::findMigrationLogEntry(const grt::Ref<GrtObject> &sourceObject, const grt::Ref<GrtObject> &targetObject)
{
for (size_t c = migrationLog().count(), i = 0; i < c; i++)
{
GrtLogObjectRef log(migrationLog()[i]);
if (log->logObject() == sourceObject && log->refObject() == targetObject)
return log;
}
return GrtLogObjectRef();
}
grt::Ref<GrtObject> db_migration_Migration::lookupMigratedObject(const grt::Ref<GrtObject> &sourceObject)
{
return this->_data->getTargetObject(sourceObject->id());
}
grt::Ref<GrtObject> db_migration_Migration::lookupSourceObject(const grt::Ref<GrtObject> &targetObject)
{
return this->_data->getSourceObject(targetObject->id());
}
|
