fix mssql adapter

anbraten · Dec 11, 2023 · de7de10 · de7de10
1 parent 2192c6b
commit de7de10
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/adapters/mssql_adapter.go b/adapters/mssql_adapter.go
@@ -41,6 +41,14 @@ func (adapter mssqlAdapter) DeleteDatabase(ctx context.Context, database string)
 }
 
 func (adapter mssqlAdapter) HasDatabaseUserWithAccess(ctx context.Context, database string, username string) (bool, error) {
+	dbExists, dbExistsErr := adapter.HasDatabase(ctx, database)
+	if dbExistsErr != nil {
+		return false, dbExistsErr
+	}
+	if !dbExists {
+		return false, nil
+	}
+
 	var count int
 	query := fmt.Sprintf("USE [%s]; SELECT COUNT(*) FROM sys.database_principals WHERE authentication_type=2 AND name='%s';", database, username)
 	err := adapter.db.QueryRowContext(ctx, query).Scan(&count)