Skip to content

Commit ecfeffe

Browse files
author
Roberto Paterlini
committed
Fix migrator
1 parent b81bc98 commit ecfeffe

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/providers/WorkflowCore.QueueProviders.SqlServer/Services/SqlServerQueueProviderMigrator.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -135,12 +135,12 @@ private void CreateMessageType(SqlConnection cn, SqlTransaction tx, string messa
135135

136136
public void CreateDb()
137137
{
138-
var pattern = ";Database=(.[^;]+);";
138+
var pattern = "Database=(.[^;]+);";
139139

140140
var regex = new Regex(pattern);
141141
var db = regex.Match(_connectionString).Groups[1].Value;
142142

143-
var masterCn = _connectionString.Replace(db, "master");
143+
var masterCn = _connectionString.Replace(regex.Match(_connectionString).Groups[0].Value, "Database=master;");
144144

145145
bool dbPresente;
146146
var cn = new SqlConnection(masterCn);

0 commit comments

Comments
 (0)