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
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
|
/*
* Copyright (c) 2011-2013 Eike Stepper (Berlin, Germany) and others.
* All rights reserved. This program and the accompanying materials
* are made available under the terms of the Eclipse Public License v1.0
* which accompanies this distribution, and is available at
* http://www.eclipse.org/legal/epl-v10.html
*
* Contributors:
* Eike Stepper - initial API and implementation
*/
package org.eclipse.emf.cdo.tests.db;
import org.eclipse.emf.cdo.common.CDOCommonRepository.IDGenerationLocation;
import org.eclipse.emf.cdo.server.IStore;
import org.eclipse.emf.cdo.server.db.CDODBUtil;
import org.eclipse.emf.cdo.server.db.mapping.IMappingStrategy;
import org.eclipse.emf.cdo.server.db.mapping.ITypeMapping;
import org.eclipse.emf.cdo.server.internal.db.mapping.TypeMappingRegistry;
import org.eclipse.emf.cdo.tests.config.impl.RepositoryConfig;
import org.eclipse.net4j.db.DBUtil;
import org.eclipse.net4j.db.IDBAdapter;
import org.eclipse.net4j.db.IDBConnectionProvider;
import org.eclipse.net4j.util.container.IPluginContainer;
import javax.sql.DataSource;
import java.util.HashMap;
import java.util.Map;
import java.util.Set;
/**
* @author Eike Stepper
*/
public abstract class DBConfig extends RepositoryConfig
{
public static final String CAPABILITY_RANGES = "DB.ranges";
public static final String CAPABILITY_COPY_ON_BRANCH = "DB.copy.on.branch";
public static final String PROP_TEST_MAPPING_STRATEGY = "test.repository.MappingStrategy";
private static final long serialVersionUID = 1L;
private boolean withRanges;
private boolean copyOnBranch;
public DBConfig(String name, boolean supportingAudits, boolean supportingBranches, boolean withRanges,
boolean copyOnBranch, IDGenerationLocation idGenerationLocation)
{
super(name, supportingAudits, supportingBranches, idGenerationLocation);
this.withRanges = withRanges;
this.copyOnBranch = copyOnBranch;
}
@Override
public void initCapabilities(Set<String> capabilities)
{
super.initCapabilities(capabilities);
capabilities.add(getDBAdapterName());
if (isWithRanges())
{
capabilities.add(CAPABILITY_RANGES);
}
if (isCopyOnBranch())
{
capabilities.add(CAPABILITY_COPY_ON_BRANCH);
}
}
protected abstract String getDBAdapterName();
@Override
protected String getStoreName()
{
return "DB";
}
public boolean isWithRanges()
{
return withRanges;
}
public boolean isCopyOnBranch()
{
return copyOnBranch;
}
@Override
public void setUp() throws Exception
{
CDODBUtil.prepareContainer(IPluginContainer.INSTANCE);
super.setUp();
((TypeMappingRegistry)ITypeMapping.Registry.INSTANCE).init();
}
@Override
protected boolean isOptimizing()
{
return true;
}
public IStore createStore(String repoName)
{
IMappingStrategy mappingStrategy = createMappingStrategy();
mappingStrategy.setProperties(createMappingStrategyProperties());
IDBAdapter dbAdapter = createDBAdapter();
DataSource dataSource = createDataSource(repoName);
IDBConnectionProvider connectionProvider = DBUtil.createConnectionProvider(dataSource);
Map<String, String> props = new HashMap<String, String>();
// props.put(IDBStore.Props.ID_COLUMN_LENGTH, "66");
return CDODBUtil.createStore(mappingStrategy, dbAdapter, connectionProvider, props);
}
protected Map<String, String> createMappingStrategyProperties()
{
Map<String, String> props = new HashMap<String, String>();
props.put(IMappingStrategy.PROP_QUALIFIED_NAMES, "true");
props.put(CDODBUtil.PROP_COPY_ON_BRANCH, Boolean.toString(copyOnBranch));
return props;
}
protected IMappingStrategy createMappingStrategy()
{
IMappingStrategy mappingStrategy = getTestMappingStrategy();
if (mappingStrategy != null)
{
return mappingStrategy;
}
return CDODBUtil.createHorizontalMappingStrategy(isSupportingAudits(), isSupportingBranches(), withRanges);
}
protected IMappingStrategy getTestMappingStrategy()
{
return (IMappingStrategy)getTestProperty(PROP_TEST_MAPPING_STRATEGY);
}
@Override
protected String getMappingStrategySpecialization()
{
return (withRanges ? "-ranges" : "") + (copyOnBranch ? "-copy" : "");
}
protected abstract IDBAdapter createDBAdapter();
protected abstract DataSource createDataSource(String repoName);
}
|
