Skip to content

Commit

Permalink
Merge pull request #276 from DbUp/bug-tableExistsCheck271
Browse files Browse the repository at this point in the history
Removed exception handlers from the `DoesTableExist` method
  • Loading branch information
droyad committed Nov 2, 2017
2 parents 50642d9 + 718a70e commit 4fdb1cf
Show file tree
Hide file tree
Showing 6 changed files with 14 additions and 44 deletions.
2 changes: 1 addition & 1 deletion src/DbUp.Tests/Support/SQLite/SQLiteTableJournalTests.cs
Original file line number Diff line number Diff line change
Expand Up @@ -45,7 +45,7 @@ public void creates_a_new_journal_table_when_not_exist()
var param2 = Substitute.For<IDbDataParameter>();
dbConnection.CreateCommand().Returns(command);
command.CreateParameter().Returns(param1, param2);
command.ExecuteScalar().Returns(x => { throw new SQLiteException("table not found"); });
command.ExecuteScalar().Returns(x => 0L);
var consoleUpgradeLog = new ConsoleUpgradeLog();
var journal = new SQLiteTableJournal(() => connectionManager, () => consoleUpgradeLog, "SchemaVersions");

Expand Down
6 changes: 5 additions & 1 deletion src/DbUp.Tests/TestInfrastructure/RecordingDbCommand.cs
Original file line number Diff line number Diff line change
Expand Up @@ -70,8 +70,12 @@ public object ExecuteScalar()
{
add(DatabaseAction.ExecuteScalarCommand(CommandText));

if (CommandText == "error" || (CommandText.ToLower().Contains("count") && CommandText.ToLower().Contains("schemaversion") && !schemaTableExists))
if (CommandText == "error")
ThrowError();

if (CommandText.ToLower().Contains("count") && CommandText.ToLower().Contains("schemaversion") && !schemaTableExists)
return CommandText.Contains("sqlite") ? 0L : (object) null;

return null;
}

Expand Down
12 changes: 2 additions & 10 deletions src/DbUp/Support/Firebird/FirebirdTableJournal.cs
Original file line number Diff line number Diff line change
Expand Up @@ -161,17 +161,9 @@ private bool DoesTableExist()
{
return connectionManager().ExecuteCommandsWithManagedConnection(dbCommandFactory =>
{
try
{
using (var command = dbCommandFactory())
{
return VerifyTableExistsCommand(command);
}
}
// can't catch FbException here because this project does not depend upon Firebird
catch (DbException)
using (var command = dbCommandFactory())
{
return false;
return VerifyTableExistsCommand(command);
}
});
}
Expand Down
11 changes: 2 additions & 9 deletions src/DbUp/Support/MySql/MySqlITableJournal.cs
Original file line number Diff line number Diff line change
Expand Up @@ -139,16 +139,9 @@ private bool DoesTableExist()
{
return connectionManager().ExecuteCommandsWithManagedConnection(dbCommandFactory =>
{
try
{
using (var command = dbCommandFactory())
{
return VerifyTableExistsCommand(command, table, schema);
}
}
catch (DbException)
using (var command = dbCommandFactory())
{
return false;
return VerifyTableExistsCommand(command, table, schema);
}
});
}
Expand Down
12 changes: 2 additions & 10 deletions src/DbUp/Support/Postgresql/PostgresqlTableJournal.cs
Original file line number Diff line number Diff line change
Expand Up @@ -151,17 +151,9 @@ private bool DoesTableExist()
{
return connectionManager().ExecuteCommandsWithManagedConnection(dbCommandFactory =>
{
try
{
using (var command = dbCommandFactory())
{
return VerifyTableExistsCommand(command, table, schema);
}
}
// can't catch NpgsqlException here because this project does not depend upon npgsql
catch (DbException)
using (var command = dbCommandFactory())
{
return false;
return VerifyTableExistsCommand(command, table, schema);
}
});
}
Expand Down
15 changes: 2 additions & 13 deletions src/DbUp/Support/SqlServer/SqlTableJournal.cs
Original file line number Diff line number Diff line change
Expand Up @@ -167,20 +167,9 @@ private bool DoesTableExist()
{
return connectionManager().ExecuteCommandsWithManagedConnection(dbCommandFactory =>
{
try
{
using (var command = dbCommandFactory())
{
return VerifyTableExistsCommand(command, table, schema);
}
}
catch (SqlException)
{
return false;
}
catch (DbException)
using (var command = dbCommandFactory())
{
return false;
return VerifyTableExistsCommand(command, table, schema);
}
});
}
Expand Down

0 comments on commit 4fdb1cf

Please sign in to comment.