Skip to content

Commit 1ee4938

Browse files
committed
Returns old api for StorageNodeManager
1 parent 3116637 commit 1ee4938

5 files changed

Lines changed: 12 additions & 72 deletions

File tree

Orm/Xtensive.Orm.Tests/Storage/Multinode/ConnectionOverrideTest.cs

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,8 @@ void commandValidator(object sender, DbCommandEventArgs args)
6161
session.Events.DbCommandExecuted -= commandValidator;
6262
}
6363

64-
var selectedNode = domain.StorageNodeManager.GetOrAddNode(nodeConfig);
64+
_ = domain.StorageNodeManager.AddNode(nodeConfig);
65+
var selectedNode = domain.StorageNodeManager.GetNode(nodeConfig.NodeId);
6566
using (var session = selectedNode.OpenSession())
6667
using (var tx = session.OpenTransaction()){
6768
var connection = ((SqlSessionHandler) session.Handler).Connection;
@@ -113,7 +114,8 @@ void commandValidator(object sender, DbCommandEventArgs args)
113114
session.Events.DbCommandExecuted -= commandValidator;
114115
}
115116

116-
var selectedNode = domain.StorageNodeManager.GetOrAddNode(nodeConfig);
117+
_ = domain.StorageNodeManager.AddNode(nodeConfig);
118+
var selectedNode = domain.StorageNodeManager.GetNode(nodeConfig.NodeId);
117119
using (var session = selectedNode.OpenSession())
118120
using (var tx = session.OpenTransaction()) {
119121
var connection = ((SqlSessionHandler) session.Handler).Connection;

Orm/Xtensive.Orm.Tests/Storage/Multinode/DynamicTypeIdTest.cs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -343,7 +343,8 @@ public void TypeIdExtractionTest()
343343
}
344344
}
345345

346-
var selectedNode = domain.StorageNodeManager.GetOrAddNode(nodeConfiguration);
346+
_ = domain.StorageNodeManager.AddNode(nodeConfiguration);
347+
var selectedNode = domain.StorageNodeManager.GetNode(nodeConfiguration.NodeId);
347348
using (var session = selectedNode.OpenSession()) {
348349
var types = new[] { typeof(BaseEntity), typeof(Entity1), typeof(Entity2) };
349350
foreach (var type in types) {

Orm/Xtensive.Orm.Tests/Storage/Multinode/InitializationSqlOverrideTest.cs

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,8 @@ public void NullNodeInitSql()
5151
}
5252
}
5353

54-
var selectedNode = domain.StorageNodeManager.GetOrAddNode(nodeConfig);
54+
_ = domain.StorageNodeManager.AddNode(nodeConfig);
55+
var selectedNode = domain.StorageNodeManager.GetNode(nodeConfig.NodeId);
5556
using (var session = selectedNode.OpenSession())
5657
using (var tx = session.OpenTransaction()) {
5758
var service = session.Services.Get<DirectSqlAccessor>();
@@ -92,7 +93,8 @@ public void EmptyStringIninSql()
9293
}
9394
}
9495

95-
var selectedNode = domain.StorageNodeManager.GetOrAddNode(nodeConfig);
96+
_ = domain.StorageNodeManager.AddNode(nodeConfig);
97+
var selectedNode = domain.StorageNodeManager.GetNode(nodeConfig.NodeId);
9698
using (var session = selectedNode.OpenSession())
9799
using (var tx = session.OpenTransaction()) {
98100
var service = session.Services.Get<DirectSqlAccessor>();
@@ -133,7 +135,8 @@ public void ValidInitSql()
133135
}
134136
}
135137

136-
var selectedNode = domain.StorageNodeManager.GetOrAddNode(nodeConfig);
138+
_ = domain.StorageNodeManager.AddNode(nodeConfig);
139+
var selectedNode = domain.StorageNodeManager.GetNode(nodeConfig.NodeId);
137140
using (var session = selectedNode.OpenSession())
138141
using (var tx = session.OpenTransaction()) {
139142
var service = session.Services.Get<DirectSqlAccessor>();

Orm/Xtensive.Orm.Tests/Storage/Multinode/StorageNodeManagerTest.cs

Lines changed: 0 additions & 41 deletions
Original file line numberDiff line numberDiff line change
@@ -162,47 +162,6 @@ public void RemoveExistingNode()
162162
Assert.That(result, Is.True);
163163
}
164164

165-
[Test]
166-
public void GetOrAddByConfigWithNullNameTest()
167-
{
168-
var nodeConfiguration = new NodeConfiguration() { UpgradeMode = DomainUpgradeMode.Recreate };
169-
nodeConfiguration.SchemaMapping.Add("dbo", "Model1");
170-
_ = Assert.Throws<InvalidOperationException>(() => Domain.StorageNodeManager.GetOrAddNode(nodeConfiguration));
171-
}
172-
173-
[Test]
174-
public void GetOrAddByConfigWithEmptyNameTest()
175-
{
176-
var nodeConfiguration = new NodeConfiguration(string.Empty) { UpgradeMode = DomainUpgradeMode.Recreate };
177-
nodeConfiguration.SchemaMapping.Add("dbo", "Model1");
178-
_ = Assert.Throws<InvalidOperationException>(() => Domain.StorageNodeManager.GetOrAddNode(nodeConfiguration));
179-
}
180-
181-
[Test]
182-
public void GetOrAddByConfigOfExistingNodeTest()
183-
{
184-
var nodeConfiguration = GetBaseNodeConfig();
185-
nodeConfiguration.SchemaMapping.Add("dbo", "Model1");
186-
var result = Domain.StorageNodeManager.AddNode(nodeConfiguration);
187-
Assert.That(result, Is.True);
188-
var existingNode = Domain.StorageNodeManager.GetNode(nodeConfiguration.NodeId);
189-
190-
var node = Domain.StorageNodeManager.GetOrAddNode((NodeConfiguration)nodeConfiguration.Clone());
191-
Assert.That(node, Is.EqualTo(existingNode));
192-
}
193-
194-
[Test]
195-
public void GetOrAddByConfigOfAbsentNodeTest()
196-
{
197-
var nodeConfiguration = GetBaseNodeConfig();
198-
nodeConfiguration.SchemaMapping.Add("dbo", "Model1");
199-
var existingNode = Domain.StorageNodeManager.GetNode(nodeConfiguration.NodeId);
200-
Assert.That(existingNode, Is.Null);
201-
202-
var node = Domain.StorageNodeManager.GetOrAddNode((NodeConfiguration) nodeConfiguration.Clone());
203-
Assert.That(node, Is.Not.Null);
204-
}
205-
206165
private NodeConfiguration GetBaseNodeConfig()
207166
{
208167
var nodeConfiguration = new NodeConfiguration(Guid.NewGuid().ToString()) {

Orm/Xtensive.Orm/Orm/StorageNodeManager.cs

Lines changed: 0 additions & 25 deletions
Original file line numberDiff line numberDiff line change
@@ -52,31 +52,6 @@ public StorageNode GetNode([NotNull] string nodeId)
5252
return handlers.StorageNodeRegistry.TryGet(nodeId);
5353
}
5454

55-
/// <summary>
56-
/// Gets node with <paramref name="configuration"/>.NodeId if it exists, otherwise,
57-
/// adds node with the specified <paramref name="configuration"/> and performs required upgrade actions
58-
/// and return added node.
59-
/// </summary>
60-
/// <param name="configuration">Node configuration.</param>
61-
/// <exception cref="InvalidOperationException">Given configurations has no <see cref="NodeConfiguration.NodeId"/> specified.</exception>
62-
/// <exception cref="InvalidOperationException">New node cannot be registered.</exception>
63-
[NotNull]
64-
public StorageNode GetOrAddNode([NotNull] NodeConfiguration configuration)
65-
{
66-
if (string.IsNullOrEmpty(configuration.NodeId)) {
67-
throw new InvalidOperationException(Strings.ExInvalidNodeIdentifier);
68-
}
69-
var node = GetNode(configuration.NodeId);
70-
if (node != null) {
71-
return node;
72-
}
73-
node = UpgradingDomainBuilder.BuildNode(handlers.Domain, configuration);
74-
return handlers.StorageNodeRegistry.Add(node)
75-
? node
76-
: throw new InvalidOperationException("Node was build but couldn't be registered.");
77-
}
78-
79-
8055
// Constructors
8156

8257
internal StorageNodeManager(HandlerAccessor handlers)

0 commit comments

Comments
 (0)