Skip to content

Commit 40587a6

Browse files
committed
Uses raw databaseName for running queries
1 parent 467fbe9 commit 40587a6

2 files changed

Lines changed: 6 additions & 7 deletions

File tree

KustoSchemaTools/KustoSchemaHandler.cs

Lines changed: 4 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -36,23 +36,20 @@ public KustoSchemaHandler(ILogger<KustoSchemaHandler<T>> schemaHandlerLogger, Ya
3636
var yamlHandler = YamlDatabaseHandlerFactory.Create(path, databaseName);
3737
var yamlDb = await yamlHandler.LoadAsync();
3838

39-
var escapedDbName = databaseName.BracketIfIdentifier();
40-
41-
4239
foreach (var cluster in clusters.Connections)
4340
{
44-
Log.LogInformation($"Generating diff markdown for {Path.Combine(path, databaseName)} => {cluster}/{escapedDbName}");
41+
Log.LogInformation($"Generating diff markdown for {Path.Combine(path, databaseName)} => {cluster}/{databaseName}");
4542

46-
var dbHandler = KustoDatabaseHandlerFactory.Create(cluster.Url, escapedDbName);
43+
var dbHandler = KustoDatabaseHandlerFactory.Create(cluster.Url, databaseName);
4744
var kustoDb = await dbHandler.LoadAsync();
48-
var changes = DatabaseChanges.GenerateChanges(kustoDb, yamlDb, escapedDbName, Log);
45+
var changes = DatabaseChanges.GenerateChanges(kustoDb, yamlDb, databaseName, Log);
4946

5047
var comments = changes.Select(itm => itm.Comment).Where(itm => itm != null).ToList();
5148

5249

5350
isValid &= changes.All(itm => itm.Scripts.All(itm => itm.IsValid != false)) && comments.All(itm => itm.FailsRollout == false);
5451

55-
sb.AppendLine($"# {cluster.Name}/{escapedDbName} ({cluster.Url})");
52+
sb.AppendLine($"# {cluster.Name}/{databaseName} ({cluster.Url})");
5653

5754
foreach (var comment in comments)
5855
{

KustoSchemaTools/Model/Database.cs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
11
using KustoSchemaTools.Changes;
2+
using KustoSchemaTools.Parser;
23
using System.Diagnostics.CodeAnalysis;
34

45
namespace KustoSchemaTools.Model
@@ -36,5 +37,6 @@ public class Database
3637

3738
public Dictionary<string, FollowerDatabase> Followers { get; set; } = new Dictionary<string, FollowerDatabase>();
3839

40+
public string EscapedName => Name.BracketIfIdentifier();
3941
}
4042
}

0 commit comments

Comments
 (0)