Skip to content

Commit 8fed24a

Browse files
authored
Merge pull request #109 from github/bugfix/escaped_apply
fix escaped names for import and apply
2 parents 51a611e + 6f80fe6 commit 8fed24a

1 file changed

Lines changed: 4 additions & 6 deletions

File tree

KustoSchemaTools/KustoSchemaHandler.cs

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -108,8 +108,7 @@ public async Task Import(string path, string databaseName, bool includeColumns)
108108
var clustersFile = File.ReadAllText(Path.Combine(path, "clusters.yml"));
109109
var clusters = Serialization.YamlPascalCaseDeserializer.Deserialize<Clusters>(clustersFile);
110110

111-
var escapedDbName = databaseName.BracketIfIdentifier();
112-
var dbHandler = KustoDatabaseHandlerFactory.Create(clusters.Connections[0].Url, escapedDbName);
111+
var dbHandler = KustoDatabaseHandlerFactory.Create(clusters.Connections[0].Url, databaseName);
113112

114113
var db = await dbHandler.LoadAsync();
115114
if (includeColumns == false)
@@ -130,7 +129,6 @@ public async Task<ConcurrentDictionary<string,Exception>> Apply(string path, str
130129
var clustersFile = File.ReadAllText(Path.Combine(path, "clusters.yml"));
131130
var clusters = Serialization.YamlPascalCaseDeserializer.Deserialize<Clusters>(clustersFile);
132131

133-
var escapedDbName = databaseName.BracketIfIdentifier();
134132
var yamlHandler = YamlDatabaseHandlerFactory.Create(path, databaseName);
135133
var yamlDb = await yamlHandler.LoadAsync();
136134

@@ -140,10 +138,10 @@ await Parallel.ForEachAsync(clusters.Connections, async (cluster, token) =>
140138
{
141139
try
142140
{
143-
Log.LogInformation($"Generating and applying script for {Path.Combine(path, databaseName)} => {cluster}/{escapedDbName}");
144-
var dbHandler = KustoDatabaseHandlerFactory.Create(cluster.Url, escapedDbName);
141+
Log.LogInformation($"Generating and applying script for {Path.Combine(path, databaseName)} => {cluster}/{databaseName}");
142+
var dbHandler = KustoDatabaseHandlerFactory.Create(cluster.Url, databaseName);
145143
await dbHandler.WriteAsync(yamlDb);
146-
results.TryAdd(cluster.Url, null);
144+
results.TryAdd(cluster.Url, null!);
147145
}
148146
catch (Exception ex)
149147
{

0 commit comments

Comments
 (0)